| 2311 | } |
| 2312 | |
| 2313 | void |
| 2314 | DataReaderImpl::notify_subscription_disconnected(const WriterIdSeq& pubids) |
| 2315 | { |
| 2316 | DBG_ENTRY_LVL("DataReaderImpl","notify_subscription_disconnected",6); |
| 2317 | |
| 2318 | // Narrow to DDS::DCPS::DataReaderListener. If a DDS::DataReaderListener |
| 2319 | // is given to this DataReader then narrow() fails. |
| 2320 | DataReaderListener_var the_listener = get_ext_listener(); |
| 2321 | |
| 2322 | if (!CORBA::is_nil(the_listener.in())) { |
| 2323 | SubscriptionLostStatus status; |
| 2324 | |
| 2325 | // Since this callback may come after remove_association which removes |
| 2326 | // the writer from id_to_handle map, we can ignore this error. |
| 2327 | this->lookup_instance_handles(pubids, status.publication_handles); |
| 2328 | the_listener->on_subscription_disconnected(this, status); |
| 2329 | } |
| 2330 | } |
| 2331 | |
| 2332 | void |
| 2333 | DataReaderImpl::notify_subscription_reconnected(const WriterIdSeq& pubids) |
nothing calls this directly
no test coverage detected