Method remove_publication

dds/InfoRepo/DCPSInfo_i.cpp:656–705

}

void TAO_DDS_DCPSInfo_i::remove_publication(
  DDS::DomainId_t domainId,
  const OpenDDS::DCPS::GUID_t& participantId,
  const OpenDDS::DCPS::GUID_t& publicationId)
{
  ACE_GUARD(ACE_Recursive_Thread_Mutex, guard, this->lock_);

  // Grab the domain.
  DCPS_IR_Domain_Map::iterator where = this->domains_.find(domainId);

  if (where == this->domains_.end()) {
    throw OpenDDS::DCPS::Invalid_Domain();
  }

  // Grab the participant.
  DCPS_IR_Participant* const partPtr = where->second->participant(participantId);
  if (!partPtr) {
    throw OpenDDS::DCPS::Invalid_Participant();
  }

  const bool in_cleanup =
#ifdef DDS_HAS_MINIMUM_BIT
    false;
#else
    in_cleanup_all_built_in_topics_;
#endif

  if (partPtr->remove_publication(publicationId) != 0) {
    where->second->remove_dead_participants(in_cleanup);

    // throw exception because the publication was not removed!
    throw OpenDDS::DCPS::Invalid_Publication();
  }

  where->second->remove_dead_participants(in_cleanup);

  if (um_ && partPtr->isOwner() && !partPtr->isBitPublisher()) {
    Update::IdPath path(domainId, participantId, publicationId);
    this->um_->destroy(path, Update::Actor, Update::DataWriter);

    if (OpenDDS::DCPS::DCPS_debug_level > 4) {
      OpenDDS::DCPS::RepoIdConverter converter(publicationId);
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) TAO_DDS_DCPSInfo_i::remove_publication: ")
                 ACE_TEXT("pushing deletion of publication %C in domain %d.\n"),
                 std::string(converter).c_str(),
                 domainId));
    }
  }
}

OpenDDS::DCPS::GUID_t TAO_DDS_DCPSInfo_i::reserve_subscription_id(DDS::DomainId_t domainId,
                                                                  const OpenDDS::DCPS::GUID_t& participantId,