chrono::synchrono::SynCommunicator Class Referenceabstract

Description

Base class communicator used to establish and facilitate communication between nodes.

#include <SynCommunicator.h>

Inheritance diagram for chrono::synchrono::SynCommunicator:
Collaboration diagram for chrono::synchrono::SynCommunicator:

Public Member Functions

 SynCommunicator ()
 Default constructor. More...
 
virtual ~SynCommunicator ()
 Destructor. More...
 
virtual void Initialize ()
 Initialization method typically responsible for establishing a connection. More...
 
virtual void Synchronize ()=0
 This method is responsible for continuous synchronous synchronization steps This method is the blocking form of the communication interface. More...
 
virtual void Barrier ()=0
 This method is responsible for blocking until an action is received or done. More...
 
void Reset ()
 Reset the communicator Will clear out message buffers. More...
 
void AddOutgoingMessages (SynMessageList &messages)
 Add the messages to the outgoing message buffer. More...
 
void AddQuitMessage ()
 Adds a quit message to the queue telling other nodes to end the simulation.
 
void AddIncomingMessages (SynMessageList &messages)
 Add the messages to the incoming message buffer. More...
 
void ProcessBuffer (std::vector< uint8_t > &data)
 Process a data buffer by passing it to the underlying FlatBuffersManager. More...
 
virtual SynMessageList & GetMessages ()
 Get the messages received by the communicator. More...
 

Protected Attributes

bool m_initialized
 whether the communicator has been initialized
 
SynMessageList m_incoming_messages
 Incoming messages.
 
SynFlatBuffersManager m_flatbuffers_manager
 flatbuffer manager for this rank
 

Constructor & Destructor Documentation

◆ SynCommunicator()

chrono::synchrono::SynCommunicator::SynCommunicator ( )

Default constructor.

◆ ~SynCommunicator()

chrono::synchrono::SynCommunicator::~SynCommunicator ( )
virtual

Destructor.

Member Function Documentation

◆ AddIncomingMessages()

void chrono::synchrono::SynCommunicator::AddIncomingMessages ( SynMessageList &  messages)

Add the messages to the incoming message buffer.

Parameters
messagesa list of handles to messages to add to the incoming buffer

◆ AddOutgoingMessages()

void chrono::synchrono::SynCommunicator::AddOutgoingMessages ( SynMessageList &  messages)

Add the messages to the outgoing message buffer.

Parameters
messagesa list of handles to messages to add to the outgoing buffer

◆ Barrier()

virtual void chrono::synchrono::SynCommunicator::Barrier ( )
pure virtual

This method is responsible for blocking until an action is received or done.

For example, a process may call Barrier to wait until another process has established certain classes and initialized certain quantities. This functionality should be implemented in this method.

Implemented in chrono::synchrono::SynDDSCommunicator, and chrono::synchrono::SynMPICommunicator.

◆ GetMessages()

virtual SynMessageList& chrono::synchrono::SynCommunicator::GetMessages ( )
inlinevirtual

Get the messages received by the communicator.

Returns
SynMessageList the received messages

Reimplemented in chrono::synchrono::SynMPICommunicator.

◆ Initialize()

void chrono::synchrono::SynCommunicator::Initialize ( )
virtual

Initialization method typically responsible for establishing a connection.

Although not necessarily true, this method should handle initial peer-to-peer communication. This could mean a simple handshake or an actual exchange of information used during the simulation.

Reimplemented in chrono::synchrono::SynDDSCommunicator, and chrono::synchrono::SynMPICommunicator.

◆ ProcessBuffer()

void chrono::synchrono::SynCommunicator::ProcessBuffer ( std::vector< uint8_t > &  data)

Process a data buffer by passing it to the underlying FlatBuffersManager.

Parameters
datathe data to process

◆ Reset()

void chrono::synchrono::SynCommunicator::Reset ( void  )

Reset the communicator Will clear out message buffers.

◆ Synchronize()

virtual void chrono::synchrono::SynCommunicator::Synchronize ( )
pure virtual

This method is responsible for continuous synchronous synchronization steps This method is the blocking form of the communication interface.

This method could use synchronous method calls to implement its communication interface. For asynchronous method cases, please use/implement Asynchronize()

Implemented in chrono::synchrono::SynDDSCommunicator, and chrono::synchrono::SynMPICommunicator.


The documentation for this class was generated from the following files:
  • /builds/uwsbel/chrono/src/chrono_synchrono/communication/SynCommunicator.h
  • /builds/uwsbel/chrono/src/chrono_synchrono/communication/SynCommunicator.cpp