| 88 | } |
| 89 | |
| 90 | int DCPS_IR_Topic_Description::remove_subscription_reference(DCPS_IR_Subscription* subscription) |
| 91 | { |
| 92 | int status = subscriptionRefs_.remove(subscription); |
| 93 | |
| 94 | if (0 == status) { |
| 95 | if (OpenDDS::DCPS::DCPS_debug_level > 0) { |
| 96 | OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id()); |
| 97 | ACE_DEBUG((LM_DEBUG, |
| 98 | ACE_TEXT("(%P|%t) DCPS_IR_Topic_Description::remove_subscription_reference: ") |
| 99 | ACE_TEXT("topic description %C removed subscription %C.\n"), |
| 100 | this->name_.c_str(), |
| 101 | std::string(converter).c_str())); |
| 102 | } |
| 103 | |
| 104 | } else { |
| 105 | OpenDDS::DCPS::RepoIdConverter converter(subscription->get_id()); |
| 106 | ACE_ERROR((LM_ERROR, |
| 107 | ACE_TEXT("(%P|%t) ERROR: DCPS_IR_Topic_Description::remove_subscription_reference: ") |
| 108 | ACE_TEXT("topic description %C failed to remove subscription %C.\n"), |
| 109 | this->name_.c_str(), |
| 110 | std::string(converter).c_str())); |
| 111 | } // if (0 == status) |
| 112 | |
| 113 | return status; |
| 114 | } |
| 115 | |
| 116 | int DCPS_IR_Topic_Description::add_topic(DCPS_IR_Topic* topic) |
| 117 | { |