| 2696 | |
| 2697 | |
| 2698 | void |
| 2699 | DataWriterImpl::lookup_instance_handles(const ReaderIdSeq& ids, |
| 2700 | DDS::InstanceHandleSeq & hdls) |
| 2701 | { |
| 2702 | CORBA::ULong const num_rds = ids.length(); |
| 2703 | RcHandle<DomainParticipantImpl> participant = this->participant_servant_.lock(); |
| 2704 | |
| 2705 | if (!participant) |
| 2706 | return; |
| 2707 | |
| 2708 | if (DCPS_debug_level > 9) { |
| 2709 | OPENDDS_STRING separator; |
| 2710 | OPENDDS_STRING buffer; |
| 2711 | |
| 2712 | for (CORBA::ULong i = 0; i < num_rds; ++i) { |
| 2713 | buffer += separator + LogGuid(ids[i]).conv_; |
| 2714 | separator = ", "; |
| 2715 | } |
| 2716 | |
| 2717 | ACE_DEBUG((LM_DEBUG, |
| 2718 | ACE_TEXT("(%P|%t) DataWriterImpl::lookup_instance_handles: ") |
| 2719 | ACE_TEXT("searching for handles for reader Ids: %C.\n"), |
| 2720 | buffer.c_str())); |
| 2721 | } |
| 2722 | |
| 2723 | hdls.length(num_rds); |
| 2724 | |
| 2725 | for (CORBA::ULong i = 0; i < num_rds; ++i) { |
| 2726 | hdls[i] = participant->lookup_handle(ids[i]); |
| 2727 | } |
| 2728 | } |
| 2729 | |
| 2730 | #ifndef OPENDDS_NO_PERSISTENCE_PROFILE |
| 2731 | bool |
no test coverage detected