 |
helics
3.3.0
|
10 #include "../NetworkCommsInterface.hpp"
34 virtual int getDefaultBrokerPort()
const override;
35 virtual void queue_rx_function()
override;
36 virtual void queue_tx_function()
override;
37 virtual void closeReceiver()
override;
41 int processIncomingMessage(zmq::message_t& msg);
44 int replyToIncomingMessage(zmq::message_t& msg, zmq::socket_t& sock);
46 int initializeBrokerConnections(zmq::socket_t& controlSocket);
49 std::string getPushAddress()
const;
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:153
@ processed
the message was used to update the current state
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: ZmqComms.cpp:31
std::string name
the name of the object
Definition: CommsInterface.hpp:123
ZmqComms() noexcept
Definition: ZmqComms.cpp:57
@ HELICS_CORE_TYPE_ZMQ
Definition: helics_enums.h:26
Definition: ZmqComms.h:23
std::atomic< bool > disconnecting
flag indicating that the comm system is in the process of disconnecting
Definition: CommsInterface.hpp:158
std::atomic< int > PortNumber
port to use for the local connection
Definition: NetworkCommsInterface.hpp:60
bool forceConnection
Definition: NetworkCommsInterface.hpp:68
Definition: NetworkBrokerData.hpp:23
std::chrono::milliseconds connectionTimeout
Definition: CommsInterface.hpp:146
~ZmqComms()
Definition: ZmqComms.cpp:60
ActionMessage generateReplyToIncomingMessage(ActionMessage &cmd)
Definition: NetworkCommsInterface.cpp:226
void logError(std::string_view message) const
Definition: CommsInterface.cpp:581
static std::shared_ptr< ZmqContextManager > getContextPointer(const std::string &contextName=std::string{})
Definition: ZmqContextManager.cpp:37
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:155
bool isValidCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:338
bool isIgnoreableCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:317
void logMessage(std::string_view message) const
Definition: CommsInterface.cpp:563
std::function< void(ActionMessage &&)> ActionCallback
the callback for what to do with a received message
Definition: CommsInterface.hpp:151
@ ERRORED
some ERRORED occurred on the connection
void setActionFlag(FlagContainer &M, FlagIndex flag)
Definition: flagOperations.hpp:130
void disconnect()
Definition: CommsInterface.cpp:385
void transmit(route_id rid, const ActionMessage &cmd)
Definition: CommsInterface.cpp:170
@ TERMINATED
the connection has been TERMINATED
bool useJsonSerialization
true to make all connections use JSON serialization
Definition: CommsInterface.hpp:143
void logWarning(std::string_view message) const
Definition: CommsInterface.cpp:572
int brokerPort
standardized broker port to use for connection to the brokers
Definition: NetworkCommsInterface.hpp:59
std::string localTargetAddress
the base for the receive address
Definition: CommsInterface.hpp:124
std::string brokerName
Definition: CommsInterface.hpp:126
std::string prettyPrintString(const ActionMessage &command)
Definition: ActionMessage.cpp:846
std::atomic< bool > requestDisconnect
flag gets set when disconnect is called
Definition: CommsInterface.hpp:149
@ STARTUP
the connection is in STARTUP mode
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: NetworkCommsInterface.cpp:97
bool isProtocolCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:226
the main namespace for the helics co-simulation library User functions will be in the helics namespac...
Definition: AsyncFedCallInfo.hpp:14
@ HELICS_ERROR_TERMINATED
Definition: helics_enums.h:248
bool serverMode
some comms have a server mode and non-server mode
Definition: CommsInterface.hpp:141
bool checkActionFlag(uint16_t flags, FlagIndex flag)
Definition: flagOperations.hpp:138
@ use_json_serialization_flag
flag to indicate it should use the json packetization
Definition: flagOperations.hpp:79
Definition: NetworkCommsInterface.hpp:18
@ CONNECTED
we are CONNECTED
const std::string & getRandomID() const
Definition: CommsInterface.hpp:185