Method unregister_all

dds/DCPS/WriteDataContainer.cpp:1319–1351

}

void
WriteDataContainer::unregister_all()
{
  DBG_ENTRY_LVL("WriteDataContainer","unregister_all",6);
  shutdown_ = true;

  //The internal list needs protection since this call may result from the
  //the delete_datawriter call which does not acquire the lock in advance.
  ACE_GUARD(ACE_Recursive_Thread_Mutex,
            guard,
            lock_);
  // Tell transport remove all control messages currently
  // transport is processing.
  (void) this->writer_->remove_all_msgs();

  // Broadcast to wake up all waiting threads.
  if (waiting_on_release_) {
    condition_.notify_all();
  }

  Message_Block_Ptr registered_sample;

  for (PublicationInstanceMapType::iterator pos = instances_.begin(), limit = instances_.end(); pos != limit;) {
    // Release the instance data.
    if (remove_instance(pos->second, registered_sample, false) != DDS::RETCODE_OK) {
      ACE_ERROR((LM_ERROR, "(%P|%t) ERROR: WriteDataContainer::unregister_all, "
                 "remove_instance %X failed\n", pos->first));
    }

    writer_->return_handle(pos->first);
    instances_.erase(pos++);
  }
}

PublicationInstance_rch
WriteDataContainer::get_handle_instance(DDS::InstanceHandle_t handle)