 |
helics
2.8.1
|
10 #include "../NetworkCommsInterface.hpp"
37 virtual int getDefaultBrokerPort()
const override;
38 virtual void queue_rx_function()
override;
39 virtual void queue_tx_function()
override;
42 int processIncomingMessage(zmq::message_t& msg,
43 std::map<std::string, std::string>& connection_info);
47 std::map<route_id, std::string>& routes,
48 std::map<std::string, std::string>& connection_info);
51 int processRxMessage(zmq::socket_t& socket,
52 std::map<std::string, std::string>& connection_info);
55 int replyToIncomingMessage(zmq::message_t& msg, zmq::socket_t& sock);
57 int initializeConnectionToBroker(zmq::socket_t& brokerConnection);
59 int initializeBrokerConnections(zmq::socket_t& brokerSocket,
60 zmq::socket_t& brokerConnection);
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:152
void insertProtocol(std::string &networkAddress, interface_type interfaceT)
Definition: NetworkBrokerData.cpp:291
@ processed
the message was used to update the current state
std::string name
the name of the object
Definition: CommsInterface.hpp:123
ZmqCommsSS() noexcept
Definition: ZmqCommsSS.cpp:53
@ terminated
the connection has been terminated
void logWarning(const std::string &message) const
Definition: CommsInterface.cpp:570
std::pair< std::string, int > extractInterfaceandPort(const std::string &address)
Definition: NetworkBrokerData.cpp:226
std::atomic< bool > disconnecting
flag indicating that the comm system is in the process of disconnecting
Definition: CommsInterface.hpp:156
~ZmqCommsSS() final
Definition: ZmqCommsSS.cpp:60
void logError(const std::string &message) const
Definition: CommsInterface.cpp:579
thread_generation
Definition: CommsInterface.hpp:30
std::atomic< int > PortNumber
port to use for the local connection
Definition: NetworkCommsInterface.hpp:57
std::string brokerInitString
the initialization string for any automatically generated broker
Definition: CommsInterface.hpp:128
Definition: NetworkBrokerData.hpp:36
std::chrono::milliseconds connectionTimeout
Definition: CommsInterface.hpp:144
std::string getAddress() const
Definition: NetworkCommsInterface.cpp:228
Definition: ActionMessage.hpp:29
ActionMessage generateReplyToIncomingMessage(ActionMessage &cmd)
Definition: NetworkCommsInterface.cpp:194
static std::shared_ptr< ZmqContextManager > getContextPointer(const std::string &contextName=std::string{})
Definition: ZmqContextManager.cpp:37
Definition: ZmqCommsSS.h:26
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:153
bool isValidCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:317
std::function< void(ActionMessage &&)> ActionCallback
the callback for what to do with a received message
Definition: CommsInterface.hpp:149
@ error
some error occurred on the connection
void disconnect()
Definition: CommsInterface.cpp:384
int brokerPort
standardized broker port to use for connection to the brokers
Definition: NetworkCommsInterface.hpp:56
std::string localTargetAddress
the base for the receive address
Definition: CommsInterface.hpp:124
std::string brokerName
the identifier for the broker
Definition: CommsInterface.hpp:126
std::string prettyPrintString(const ActionMessage &command)
Definition: ActionMessage.cpp:861
bool isDisconnectCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:276
Definition: CommsInterface.hpp:26
std::atomic< bool > requestDisconnect
flag gets set when disconnect is called
Definition: CommsInterface.hpp:147
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: NetworkCommsInterface.cpp:77
@ tcp
using tcp ports for communication
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
interface_type
Definition: NetworkBrokerData.hpp:24
bool serverMode
some comms have a server mode and non-server mode
Definition: CommsInterface.hpp:140
std::string makePortAddress(const std::string &networkInterface, int portNumber)
Definition: NetworkBrokerData.cpp:216
Definition: NetworkCommsInterface.hpp:18
bool appendNameToAddress
flag to append the name to the network address
Definition: NetworkCommsInterface.hpp:60
@ connected
we are connected
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: ZmqCommsSS.cpp:28
void logMessage(const std::string &message) const
Definition: CommsInterface.cpp:561