 |
helics
3.3.0
|
9 #include "../NetworkCommsInterface.hpp"
16 namespace gmlc::networking {
34 void addConnections(
const std::vector<std::string>& newConnections);
36 virtual void setFlag(std::string_view flag,
bool val)
override;
43 bool outgoingConnectionsAllowed{
true};
44 bool reuse_address{
false};
45 std::string encryption_config;
46 std::vector<std::string> connections;
47 virtual int getDefaultBrokerPort()
const override;
48 virtual void queue_rx_function()
override;
49 virtual void queue_tx_function()
override;
61 size_t dataReceive(gmlc::networking::TcpConnection* connection,
63 size_t bytes_received);
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:153
virtual void setFlag(std::string_view flag, bool val) override
Definition: NetworkCommsInterface.cpp:209
@ processed
the message was used to update the current state
virtual void setFlag(std::string_view flag, bool val) override
Definition: TcpCommsSS.cpp:76
void addConnection(std::string_view newConn)
Definition: TcpCommsSS.cpp:55
thread_generation
Definition: CommsInterface.hpp:29
std::atomic< int > PortNumber
port to use for the local connection
Definition: NetworkCommsInterface.hpp:60
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: TcpCommsSS.cpp:39
Definition: NetworkBrokerData.hpp:23
std::chrono::milliseconds connectionTimeout
Definition: CommsInterface.hpp:146
TcpCommsSS() noexcept
Definition: TcpCommsSS.cpp:26
std::string getAddress() const
Definition: NetworkCommsInterface.cpp:260
Definition: ActionMessage.hpp:30
void logError(std::string_view message) const
Definition: CommsInterface.cpp:581
Definition: TcpCommsSS.h:24
void addConnections(const std::vector< std::string > &newConnections)
Definition: TcpCommsSS.cpp:63
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:155
~TcpCommsSS()
Definition: TcpCommsSS.cpp:33
std::function< void(ActionMessage &&)> ActionCallback
the callback for what to do with a received message
Definition: CommsInterface.hpp:151
void disconnect()
Definition: CommsInterface.cpp:385
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
bool reuse_address
Definition: NetworkBrokerData.hpp:48
std::string brokerName
Definition: CommsInterface.hpp:126
@ HELICS_CORE_TYPE_TCP_SS
Definition: helics_enums.h:47
std::string prettyPrintString(const ActionMessage &command)
Definition: ActionMessage.cpp:846
bool isDisconnectCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:277
Definition: CommsInterface.hpp:25
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
const char * actionMessageType(action_message_def::action_t action)
Definition: ActionMessage.cpp:811
bool serverMode
some comms have a server mode and non-server mode
Definition: CommsInterface.hpp:141
bool encrypted
Definition: NetworkCommsInterface.hpp:65
Definition: NetworkCommsInterface.hpp:18
int maxMessageSize
the maximum message size for the queues (if needed)
Definition: CommsInterface.hpp:147