| 2396 | |
| 2397 | |
| 2398 | void |
| 2399 | DataReaderImpl::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 | |
| 2430 | bool |
| 2431 | DataReaderImpl::filter_sample(const DataSampleHeader& header) |
no test coverage detected