MCPcopy Create free account
hub / github.com/OpenDDS/OpenDDS / take

Method take

tests/DCPS/ContentFilteredTopic/ContentFilteredTopicTest.cpp:101–113  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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 {

Callers 2

Calls 2

copyFunction · 0.70
take_w_conditionMethod · 0.45

Tested by

no test coverage detected