Sedp.cpp File Reference

#include "Sedp.h"
#include "Spdp.h"
#include "MessageTypes.h"
#include "RtpsDiscovery.h"
#include "RtpsCoreTypeSupportImpl.h"
#include "ParameterListConverter.h"
#include "dds/DCPS/transport/framework/ReceivedDataSample.h"
#include "dds/DCPS/transport/rtps_udp/RtpsUdpInst.h"
#include "dds/DCPS/transport/rtps_udp/RtpsUdpInst_rch.h"
#include "dds/DCPS/Serializer.h"
#include "dds/DCPS/Definitions.h"
#include "dds/DCPS/GuidConverter.h"
#include "dds/DCPS/GuidUtils.h"
#include "dds/DdsDcpsGuidTypeSupportImpl.h"
#include "dds/DCPS/AssociationData.h"
#include "dds/DCPS/Service_Participant.h"
#include "dds/DCPS/Qos_Helper.h"
#include "dds/DCPS/DataSampleHeader.h"
#include "dds/DCPS/SendStateDataSampleList.h"
#include "dds/DCPS/DataReaderCallbacks.h"
#include "dds/DCPS/DataWriterCallbacks.h"
#include "dds/DCPS/Marked_Default_Qos.h"
#include "dds/DCPS/BuiltInTopicUtils.h"
#include "dds/DCPS/DCPS_Utils.h"
#include "dds/DCPS/transport/framework/NetworkAddress.h"
#include <ace/Reverse_Lock_T.h>
#include <ace/Auto_Ptr.h>
#include <cstring>

Include dependency graph for Sedp.cpp:

Go to the source code of this file.

Namespaces
namespace	OpenDDS
namespace	OpenDDS::RTPS
Functions
bool	qosChanged (DDS::PublicationBuiltinTopicData &dest, const DDS::PublicationBuiltinTopicData &src)
bool	qosChanged (DDS::SubscriptionBuiltinTopicData &dest, const DDS::SubscriptionBuiltinTopicData &src)
bool	paramsChanged (OpenDDS::DCPS::ContentFilterProperty_t &dest, const OpenDDS::DCPS::ContentFilterProperty_t &src)
void	OpenDDS::RTPS::create_association_data_proto (DCPS::AssociationData &proto, const SPDPdiscoveredParticipantData &pdata)
static bool	OpenDDS::RTPS::decode_parameter_list (const DCPS::ReceivedDataSample &sample, DCPS::Serializer &ser, const ACE_CDR::Octet &encap, ParameterList &data)

---

Function Documentation

bool @35::paramsChanged	(	OpenDDS::DCPS::ContentFilterProperty_t &	dest,
		const OpenDDS::DCPS::ContentFilterProperty_t &	src
	)			[static]

Definition at line 143 of file Sedp.cpp.

References OpenDDS::DCPS::ContentFilterProperty_t::expressionParameters.

Referenced by OpenDDS::RTPS::Sedp::data_received().

{
  if (dest.expressionParameters.length() != src.expressionParameters.length()) {
    dest.expressionParameters = src.expressionParameters;
    return true;
  }
  for (CORBA::ULong i = 0; i < src.expressionParameters.length(); ++i) {
    if (0 != std::strcmp(dest.expressionParameters[i],
                         src.expressionParameters[i])) {
      dest.expressionParameters = src.expressionParameters;
      return true;
    }
  }
  return false;
}

bool @35::qosChanged	(	DDS::SubscriptionBuiltinTopicData &	dest,
		const DDS::SubscriptionBuiltinTopicData &	src
	)			[static]

Definition at line 95 of file Sedp.cpp.

References DDS::SubscriptionBuiltinTopicData::deadline, DDS::SubscriptionBuiltinTopicData::group_data, DDS::SubscriptionBuiltinTopicData::latency_budget, DDS::SubscriptionBuiltinTopicData::partition, DDS::SubscriptionBuiltinTopicData::time_based_filter, DDS::SubscriptionBuiltinTopicData::topic_data, and DDS::SubscriptionBuiltinTopicData::user_data.

{
#ifndef OPENDDS_SAFETY_PROFILE
  using OpenDDS::DCPS::operator!=;
#endif
  bool changed = false;

  // check each Changeable QoS policy value in Subcription BIT Data

  if (dest.deadline != src.deadline) {
    changed = true;
    dest.deadline = src.deadline;
  }

  if (dest.latency_budget != src.latency_budget) {
    changed = true;
    dest.latency_budget = src.latency_budget;
  }

  if (dest.user_data != src.user_data) {
    changed = true;
    dest.user_data = src.user_data;
  }

  if (dest.time_based_filter != src.time_based_filter) {
    changed = true;
    dest.time_based_filter = src.time_based_filter;
  }

  if (dest.partition != src.partition) {
    changed = true;
    dest.partition = src.partition;
  }

  if (dest.topic_data != src.topic_data) {
    changed = true;
    dest.topic_data = src.topic_data;
  }

  if (dest.group_data != src.group_data) {
    changed = true;
    dest.group_data = src.group_data;
  }

  return changed;
}

bool @35::qosChanged	(	DDS::PublicationBuiltinTopicData &	dest,
		const DDS::PublicationBuiltinTopicData &	src
	)			[static]

Definition at line 42 of file Sedp.cpp.

References DDS::PublicationBuiltinTopicData::deadline, DDS::PublicationBuiltinTopicData::group_data, DDS::PublicationBuiltinTopicData::latency_budget, DDS::PublicationBuiltinTopicData::lifespan, DDS::PublicationBuiltinTopicData::ownership_strength, DDS::PublicationBuiltinTopicData::partition, DDS::PublicationBuiltinTopicData::topic_data, and DDS::PublicationBuiltinTopicData::user_data.

Referenced by OpenDDS::RTPS::Sedp::data_received().

{
#ifndef OPENDDS_SAFETY_PROFILE
  using OpenDDS::DCPS::operator!=;
#endif
  bool changed = false;

  // check each Changeable QoS policy value in Publication BIT Data

  if (dest.deadline != src.deadline) {
    changed = true;
    dest.deadline = src.deadline;
  }

  if (dest.latency_budget != src.latency_budget) {
    changed = true;
    dest.latency_budget = src.latency_budget;
  }

  if (dest.lifespan != src.lifespan) {
    changed = true;
    dest.lifespan = src.lifespan;
  }

  if (dest.user_data != src.user_data) {
    changed = true;
    dest.user_data = src.user_data;
  }

  if (dest.ownership_strength != src.ownership_strength) {
    changed = true;
    dest.ownership_strength = src.ownership_strength;
  }

  if (dest.partition != src.partition) {
    changed = true;
    dest.partition = src.partition;
  }

  if (dest.topic_data != src.topic_data) {
    changed = true;
    dest.topic_data = src.topic_data;
  }

  if (dest.group_data != src.group_data) {
    changed = true;
    dest.group_data = src.group_data;
  }

  return changed;
}

---