| 743 | } |
| 744 | |
| 745 | DDS::ReadCondition_ptr DataReaderImpl::create_readcondition( |
| 746 | DDS::SampleStateMask sample_states, |
| 747 | DDS::ViewStateMask view_states, |
| 748 | DDS::InstanceStateMask instance_states) |
| 749 | { |
| 750 | ACE_GUARD_RETURN(ACE_Recursive_Thread_Mutex, guard, this->sample_lock_, 0); |
| 751 | DDS::ReadCondition_var rc = new ReadConditionImpl(this, sample_states, |
| 752 | view_states, instance_states); |
| 753 | read_conditions_.insert(rc); |
| 754 | return rc._retn(); |
| 755 | } |
| 756 | |
| 757 | #ifndef OPENDDS_NO_QUERY_CONDITION |
| 758 | DDS::QueryCondition_ptr DataReaderImpl::create_querycondition( |