 |
helics
3.0.1
|
9 #include "../NetworkCommsInterface.hpp"
10 #include "gmlc/containers/BlockingQueue.hpp"
36 virtual void setFlag(
const std::string& flag,
bool val)
override;
39 bool reuse_address =
false;
40 virtual int getDefaultBrokerPort()
const override;
41 virtual void queue_rx_function()
override;
42 virtual void queue_tx_function()
override;
44 virtual void closeReceiver()
override;
47 bool establishBrokerConnection(std::shared_ptr<AsioContextManager>& ioctx,
48 std::shared_ptr<TcpConnection>& brokerConnection);
53 gmlc::containers::BlockingQueue<ActionMessage> rxMessageQueue;
55 void txReceive(
const char* data,
size_t bytes_received,
const std::string& errorMessage);
63 size_t dataReceive(
TcpConnection* connection,
const char* data,
size_t bytes_received);
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:153
TcpComms() noexcept
Definition: TcpComms.cpp:25
@ processed
the message was used to update the current state
std::pair< std::string, std::string > extractInterfaceandPortString(const std::string &address)
Definition: NetworkBrokerData.cpp:251
static std::shared_ptr< AsioContextManager > getContextPointer(const std::string &contextName=std::string())
Definition: AsioContextManager.cpp:38
void logWarning(const std::string &message) const
Definition: CommsInterface.cpp:571
std::pair< std::string, int > extractInterfaceandPort(const std::string &address)
Definition: NetworkBrokerData.cpp:227
std::atomic< bool > disconnecting
flag indicating that the comm system is in the process of disconnecting
Definition: CommsInterface.hpp:157
virtual void setFlag(const std::string &flag, bool val) override
Definition: TcpComms.cpp:40
void logError(const std::string &message) const
Definition: CommsInterface.cpp:580
std::atomic< int > PortNumber
port to use for the local connection
Definition: NetworkCommsInterface.hpp:57
~TcpComms()
Definition: TcpComms.cpp:53
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:145
Definition: ActionMessage.hpp:30
ActionMessage generateReplyToIncomingMessage(ActionMessage &cmd)
Definition: NetworkCommsInterface.cpp:194
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:154
asio::io_context & getBaseContext() const
Definition: AsioContextManager.h:116
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: TcpComms.cpp:30
Definition: AsioContextManager.h:32
bool autoPortNumber
use an automatic port numbering based on broker responses
Definition: NetworkCommsInterface.hpp:58
std::function< void(ActionMessage &&)> ActionCallback
the callback for what to do with a received message
Definition: CommsInterface.hpp:150
void disconnect()
Definition: CommsInterface.cpp:385
Definition: TcpHelperClasses.h:26
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
bool reuse_address
allow reuse of binding address
Definition: NetworkBrokerData.hpp:60
std::string brokerName
the identifier for the broker
Definition: CommsInterface.hpp:126
connection_status
Definition: CommsInterface.hpp:108
std::string prettyPrintString(const ActionMessage &command)
Definition: ActionMessage.cpp:841
bool isDisconnectCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:276
std::atomic< bool > requestDisconnect
flag gets set when disconnect is called
Definition: CommsInterface.hpp:148
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: NetworkCommsInterface.cpp:77
bool noAckConnection
flag to bypass the connection acknowledge requirement
Definition: NetworkCommsInterface.hpp:61
Definition: TcpComms.h:27
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
const char * actionMessageType(action_message_def::action_t action)
Definition: ActionMessage.cpp:806
virtual void setFlag(const std::string &flag, bool val) override
Definition: NetworkCommsInterface.cpp:177
Definition: NetworkCommsInterface.hpp:18
InterfaceTypes
Definition: NetworkBrokerData.hpp:24
int maxMessageSize
the maximum message size for the queues (if needed)
Definition: CommsInterface.hpp:146
LoopHandle startContextLoop()
Definition: AsioContextManager.cpp:151
void logMessage(const std::string &message) const
Definition: CommsInterface.cpp:562