| 99 | size_t takeSamples(F filter); |
| 100 | |
| 101 | DDS::ReturnCode_t take(MessageSeq& data, DDS::SampleInfoSeq& info) |
| 102 | { |
| 103 | if (dyn_reader_) { |
| 104 | DynamicDataSeq dyn_data; |
| 105 | const DDS::ReturnCode_t ret = dyn_reader_->take(dyn_data, info, LENGTH_UNLIMITED, ANY_SAMPLE_STATE, ANY_VIEW_STATE, ANY_INSTANCE_STATE); |
| 106 | if (ret == RETCODE_OK) { |
| 107 | copy(data, dyn_data, info); |
| 108 | } |
| 109 | return ret; |
| 110 | } |
| 111 | |
| 112 | return msg_reader_->take(data, info, LENGTH_UNLIMITED, ANY_SAMPLE_STATE, ANY_VIEW_STATE, ANY_INSTANCE_STATE); |
| 113 | } |
| 114 | |
| 115 | DDS::ReturnCode_t take(MessageSeq& data, DDS::SampleInfoSeq& info, DDS::ReadCondition* cond) |
| 116 | { |
no test coverage detected