helics  3.0.1
Public Member Functions | List of all members
helics::FilterFederate Class Reference

Public Member Functions

 FilterFederate (GlobalFederateId fedID, std::string name, GlobalBrokerId coreID, Core *core)
 
 ~FilterFederate ()
 
void processMessageFilter (ActionMessage &cmd)
 
void processFilterReturn (ActionMessage &cmd)
 
void processDestFilterReturn (ActionMessage &command)
 
FilterInfocreateFilter (GlobalBrokerId dest, InterfaceHandle handle, const std::string &key, const std::string &type_in, const std::string &type_out, bool cloning)
 
void setCallbacks (std::function< void(const ActionMessage &)> queueMessage, std::function< void(ActionMessage &&)> queueMessageMove, std::function< void(const ActionMessage &)> sendMessage, std::function< void(ActionMessage &&)> sendMessageMove)
 
void setLogger (std::function< void(int, const std::string &, const std::string &)> logger)
 
void setDeliver (std::function< void(ActionMessage &)> deliverMessage)
 
void setAirLockFunction (std::function< gmlc::containers::AirLock< std::any > &(int)> getAirLock)
 
void organizeFilterOperations ()
 
void handleMessage (ActionMessage &command)
 
void processFilterInfo (ActionMessage &command)
 
ActionMessageprocessMessage (ActionMessage &command, const BasicHandleInfo *handle)
 
bool destinationProcessMessage (ActionMessage &command, const BasicHandleInfo *handle)
 
void addFilteredEndpoint (Json::Value &block, GlobalFederateId fed) const
 
void setHandleManager (HandleManager *handles)
 
std::string query (const std::string &queryStr) const
 
bool hasActiveTimeDependencies () const
 

Constructor & Destructor Documentation

◆ ~FilterFederate()

helics::FilterFederate::~FilterFederate ( )

map of all local filters

sets of ongoing filtered messages

sets of ongoing destination filter processing

Member Function Documentation

◆ createFilter()

FilterInfo * helics::FilterFederate::createFilter ( GlobalBrokerId  dest,
InterfaceHandle  handle,
const std::string &  key,
const std::string &  type_in,
const std::string &  type_out,
bool  cloning 
)

◆ destinationProcessMessage()

bool helics::FilterFederate::destinationProcessMessage ( ActionMessage command,
const BasicHandleInfo handle 
)

◆ hasActiveTimeDependencies()

bool helics::FilterFederate::hasActiveTimeDependencies ( ) const

check if the filter federate has active time dependencies other than parent

References helics::TimeCoordinator::hasActiveTimeDependencies().

Referenced by helics::CommonCore::allDisconnected().

◆ processDestFilterReturn()

void helics::FilterFederate::processDestFilterReturn ( ActionMessage command)

◆ processFilterReturn()

void helics::FilterFederate::processFilterReturn ( ActionMessage cmd)

◆ processMessageFilter()

void helics::FilterFederate::processMessageFilter ( ActionMessage cmd)

process any filter or route the message

References checkActionFlag(), helics::createMessageFromCommand(), disconnected_flag, and helics::parent_broker_id.


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