#include <ConnectionRecords.h>

Inheritance diagram for OpenDDS::DCPS::WriteConnectionRecords:

Collaboration diagram for OpenDDS::DCPS::WriteConnectionRecords:

[legend]

Public Member Functions
	WriteConnectionRecords (WeakRcHandle< BitSubscriber > bit_sub, const ConnectionRecords &records)

	WriteConnectionRecords (WeakRcHandle< BitSubscriber > bit_sub, bool action, const ConnectionRecord &record)

void	execute ()

Public Member Functions inherited from OpenDDS::DCPS::Job
virtual	~Job ()

Public Member Functions inherited from OpenDDS::DCPS::RcObject
virtual	~RcObject ()

virtual void	_add_ref ()

virtual void	_remove_ref ()

long	ref_count () const

WeakObject *	_get_weak_object () const

Private Attributes
WeakRcHandle< BitSubscriber >	bit_sub_

ConnectionRecords	records_

Additional Inherited Members
Protected Member Functions inherited from OpenDDS::DCPS::RcObject
	RcObject ()

Detailed Description

Definition at line 25 of file ConnectionRecords.h.

Constructor & Destructor Documentation

◆ WriteConnectionRecords() [1/2]

OpenDDS::DCPS::WriteConnectionRecords::WriteConnectionRecords	(	WeakRcHandle< BitSubscriber >	bit_sub,
		const ConnectionRecords &	records
	)

inline

Definition at line 27 of file ConnectionRecords.h.

     : bit_sub_(bit_sub)
     , records_(records)
   {}

◆ WriteConnectionRecords() [2/2]

OpenDDS::DCPS::WriteConnectionRecords::WriteConnectionRecords	(	WeakRcHandle< BitSubscriber >	bit_sub,
		bool	action,
		const ConnectionRecord &	record
	)

inline

Definition at line 33 of file ConnectionRecords.h.

     : bit_sub_(bit_sub)
   {
     records_.push_back(std::make_pair(action, record));
   }

Member Function Documentation

◆ execute()

void OpenDDS::DCPS::WriteConnectionRecords::execute ( void )

virtual

Implements OpenDDS::DCPS::Job.

Definition at line 17 of file ConnectionRecords.cpp.

References bit_sub_, DDS::NEW_VIEW_STATE, OPENDDS_END_VERSIONED_NAMESPACE_DECL, and records_.

 {
   RcHandle<BitSubscriber> bit_sub = bit_sub_.lock();
   if (!bit_sub) {
     return;
   }
 
   for (ConnectionRecords::const_iterator pos = records_.begin(), limit = records_.end(); pos != limit; ++pos) {
     if (pos->first) {
       bit_sub->add_connection_record(pos->second, DDS::NEW_VIEW_STATE);
     } else {
       bit_sub->remove_connection_record(pos->second);
     }
   }
 }

Member Data Documentation

◆ bit_sub_

WeakRcHandle<BitSubscriber> OpenDDS::DCPS::WriteConnectionRecords::bit_sub_

private

Definition at line 44 of file ConnectionRecords.h.

Referenced by execute().

◆ records_

ConnectionRecords OpenDDS::DCPS::WriteConnectionRecords::records_

private

Definition at line 45 of file ConnectionRecords.h.