OpenDDS  Snapshot(2023/04/28-20:55)
Public Member Functions | List of all members
OpenDDS::Federator::UpdateProcessor< DataType > Class Template Referenceabstract

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.

26 {
28  ACE_DEBUG((LM_DEBUG,
29  ACE_TEXT("(%P|%t) UpdateProcessor::UpdateProcessor()\n")));
30  }
31 }
#define ACE_DEBUG(X)
ACE_TEXT("TCP_Factory")
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
Definition: debug.cpp:30

◆ ~UpdateProcessor()

template<class DataType >
OpenDDS::Federator::UpdateProcessor< DataType >::~UpdateProcessor ( )
virtual

Definition at line 34 of file UpdateProcessor_T.cpp.

35 {
37  ACE_DEBUG((LM_DEBUG,
38  ACE_TEXT("(%P|%t) UpdateProcessor::~UpdateProcessor()\n")));
39  }
40 }
#define ACE_DEBUG(X)
ACE_TEXT("TCP_Factory")
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
Definition: debug.cpp:30

Member Function Documentation

◆ processCreate()

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

◆ processDelete()

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

◆ 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.

47 {
49  ACE_DEBUG((LM_DEBUG,
50  ACE_TEXT("(%P|%t) UpdateProcessor::processSample()\n")));
51  }
52 
53  if (info->valid_data) {
54  switch (sample->action) {
55  case CreateEntity:
56  this->processCreate(sample, info);
57  break;
58  case UpdateQosValue1:
59  this->processUpdateQos1(sample, info);
60  break;
61  case UpdateQosValue2:
62  this->processUpdateQos2(sample, info);
63  break;
65  this->processUpdateFilterExpressionParams(sample, info);
66  break;
67  case DestroyEntity:
68  this->processDelete(sample, info);
69  break;
70  default:
71  ACE_ERROR((LM_ERROR,
72  ACE_TEXT("(%P|%t) ERROR: UpdateProcessor::processSample() - ")
73  ACE_TEXT("upsupported action type: %d.\n"),
74  sample->action));
75  break;
76  }
77 
78  } else {
80  ACE_DEBUG((LM_DEBUG,
81  ACE_TEXT("(%P|%t) UpdateProcessor::processSample() - ")
82  ACE_TEXT("sample not valid, declining to process.\n")));
83  }
84  }
85 }
virtual void processUpdateQos2(const DataType *sample, const DDS::SampleInfo *info)
#define ACE_DEBUG(X)
#define ACE_ERROR(X)
virtual void processUpdateQos1(const DataType *sample, const DDS::SampleInfo *info)=0
Entity Qos values are modified.
virtual void processUpdateFilterExpressionParams(const DataType *sample, const DDS::SampleInfo *info)
A default null implementation is provided.
ACE_TEXT("TCP_Factory")
OpenDDS_Dcps_Export unsigned int DCPS_debug_level
Definition: debug.cpp:30
virtual void processDelete(const DataType *sample, const DDS::SampleInfo *info)=0
Entities are destroyed.
virtual void processCreate(const DataType *sample, const DDS::SampleInfo *info)=0
Entities are created.

◆ 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.

101 {
102  /* This method intentionally left unimplemented. */
103 }

◆ processUpdateQos1()

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

◆ 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.

92 {
93  /* This method intentionally left unimplemented. */
94 }

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