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

Method lookup_instance_handles

dds/DCPS/DataReaderImpl.cpp:2398–2428  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

2396
2397
2398void
2399DataReaderImpl::lookup_instance_handles(const WriterIdSeq& ids,
2400 DDS::InstanceHandleSeq & hdls)
2401{
2402 CORBA::ULong const num_wrts = ids.length();
2403
2404 if (DCPS_debug_level > 9) {
2405 const char* separator = "";
2406 OPENDDS_STRING guids;
2407
2408 for (CORBA::ULong i = 0; i < num_wrts; ++i) {
2409 guids += separator;
2410 guids += LogGuid(ids[i]).conv_;
2411 separator = ", ";
2412 }
2413
2414 ACE_DEBUG((LM_DEBUG,
2415 ACE_TEXT("(%P|%t) DataReaderImpl::lookup_instance_handles: ")
2416 ACE_TEXT("searching for handles for writer Ids: %C.\n"),
2417 guids.c_str()));
2418 }
2419
2420 hdls.length(num_wrts);
2421
2422 RcHandle<DomainParticipantImpl> participant = this->participant_servant_.lock();
2423 if (participant) {
2424 for (CORBA::ULong i = 0; i < num_wrts; ++i) {
2425 hdls[i] = participant->lookup_handle(ids[i]);
2426 }
2427 }
2428}
2429
2430bool
2431DataReaderImpl::filter_sample(const DataSampleHeader& header)

Calls 4

LogGuidFunction · 0.85
lookup_handleMethod · 0.80
lengthMethod · 0.45
lockMethod · 0.45

Tested by

no test coverage detected