OpenDDS::Federator::UpdateProcessor< DataType > Class Template Reference

Interface for managing update publications. More...

#include <UpdateProcessor_T.h>

Public Member Functions
	UpdateProcessor ()
virtual	~UpdateProcessor ()
virtual void	processCreate (const DataType *sample, const DDS::SampleInfo *info)=0
	Entities are created. More...
virtual void	processUpdateQos1 (const DataType *sample, const DDS::SampleInfo *info)=0
	Entity Qos values are modified. More...
virtual void	processUpdateQos2 (const DataType *sample, const DDS::SampleInfo *info)
virtual void	processUpdateFilterExpressionParams (const DataType *sample, const DDS::SampleInfo *info)
	A default null implementation is provided. More...
virtual void	processDelete (const DataType *sample, const DDS::SampleInfo *info)=0
	Entities are destroyed. More...
void	processSample (const DataType *sample, const DDS::SampleInfo *info)
	Update publication information with sample data. More...

Detailed Description

template<class DataType>
class OpenDDS::Federator::UpdateProcessor< DataType >

Interface for managing update publications.

This class provides interfaces to manage update data received from federated repositories.

Definition at line 35 of file UpdateProcessor_T.h.

Constructor & Destructor Documentation

UpdateProcessor()

template<class DataType >

OpenDDS::Federator::UpdateProcessor< DataType >::UpdateProcessor

(

)

Definition at line 25 of file UpdateProcessor_T.cpp.

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) UpdateProcessor::UpdateProcessor()\n")));
  }
}

~UpdateProcessor()

template<class DataType >

OpenDDS::Federator::UpdateProcessor< DataType >::~UpdateProcessor ( )

virtual

Definition at line 34 of file UpdateProcessor_T.cpp.

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) UpdateProcessor::~UpdateProcessor()\n")));
  }
}

Member Function Documentation

processCreate()

template<class DataType>

virtual void OpenDDS::Federator::UpdateProcessor< DataType >::processCreate ( const DataType *  sample, const DDS::SampleInfo *  info  )

pure virtual

Entities are created.

Implemented in OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, and OpenDDS::Federator::ManagerImpl.

processDelete()

template<class DataType>

virtual void OpenDDS::Federator::UpdateProcessor< DataType >::processDelete ( const DataType *  sample, const DDS::SampleInfo *  info  )

pure virtual

Entities are destroyed.

Implemented in OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, and OpenDDS::Federator::ManagerImpl.

processSample()

template<class DataType >

void OpenDDS::Federator::UpdateProcessor< DataType >::processSample	(	const DataType *	sample,
		const DDS::SampleInfo *	info
	)

Update publication information with sample data.

Definition at line 44 of file UpdateProcessor_T.cpp.

{
  if (OpenDDS::DCPS::DCPS_debug_level > 0) {
    ACE_DEBUG((LM_DEBUG,
               ACE_TEXT("(%P|%t) UpdateProcessor::processSample()\n")));
  }

  if (info->valid_data) {
    switch (sample->action) {
    case CreateEntity:
      this->processCreate(sample, info);
      break;
    case UpdateQosValue1:
      this->processUpdateQos1(sample, info);
      break;
    case UpdateQosValue2:
      this->processUpdateQos2(sample, info);
      break;
    case UpdateFilterExpressionParams:
      this->processUpdateFilterExpressionParams(sample, info);
      break;
    case DestroyEntity:
      this->processDelete(sample, info);
      break;
    default:
      ACE_ERROR((LM_ERROR,
                 ACE_TEXT("(%P|%t) ERROR: UpdateProcessor::processSample() - ")
                 ACE_TEXT("upsupported action type: %d.\n"),
                 sample->action));
      break;
    }

  } else {
    if (OpenDDS::DCPS::DCPS_debug_level > 0) {
      ACE_DEBUG((LM_DEBUG,
                 ACE_TEXT("(%P|%t) UpdateProcessor::processSample() - ")
                 ACE_TEXT("sample not valid, declining to process.\n")));
    }
  }
}

processUpdateFilterExpressionParams()

template<class DataType >

void OpenDDS::Federator::UpdateProcessor< DataType >::processUpdateFilterExpressionParams ( const DataType *  sample, const DDS::SampleInfo *  info  )

virtual

A default null implementation is provided.

Reimplemented in OpenDDS::Federator::ManagerImpl.

Definition at line 98 of file UpdateProcessor_T.cpp.

{
  /* This method intentionally left unimplemented. */
}

processUpdateQos1()

template<class DataType>

virtual void OpenDDS::Federator::UpdateProcessor< DataType >::processUpdateQos1 ( const DataType *  sample, const DDS::SampleInfo *  info  )

pure virtual

Entity Qos values are modified.

Implemented in OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, OpenDDS::Federator::ManagerImpl, and OpenDDS::Federator::ManagerImpl.

processUpdateQos2()

template<class DataType >

void OpenDDS::Federator::UpdateProcessor< DataType >::processUpdateQos2 ( const DataType *  sample, const DDS::SampleInfo *  info  )

virtual

Entity additional Qos values are modified. A default null implementation is provided.

Reimplemented in OpenDDS::Federator::ManagerImpl, and OpenDDS::Federator::ManagerImpl.

Definition at line 89 of file UpdateProcessor_T.cpp.

{
  /* This method intentionally left unimplemented. */
}

---

The documentation for this class was generated from the following files:

• UpdateProcessor_T.h
• UpdateProcessor_T.cpp