 |
helics
2.8.1
|
9 #include "../CommsInterface.hpp"
27 std::atomic<int> ipcbackchannel{
29 virtual void queue_rx_function()
override;
30 virtual void queue_tx_function()
override;
31 virtual void closeReceiver()
override;
37 std::string getAddress()
const;
40 #define IPC_BACKCHANNEL_TRY_RESET 2
41 #define IPC_BACKCHANNEL_DISCONNECT 4
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:152
~IpcComms()
Definition: IpcComms.cpp:37
Definition: IpcComms.h:17
std::string name
the name of the object
Definition: CommsInterface.hpp:123
@ terminated
the connection has been terminated
std::atomic< bool > disconnecting
flag indicating that the comm system is in the process of disconnecting
Definition: CommsInterface.hpp:156
IpcComms()
Definition: IpcComms.cpp:31
void logError(const std::string &message) const
Definition: CommsInterface.cpp:579
int getPort() const
Definition: IpcComms.h:35
Definition: IpcQueueHelper.h:90
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: IpcComms.cpp:39
Definition: NetworkBrokerData.hpp:36
std::chrono::milliseconds connectionTimeout
Definition: CommsInterface.hpp:144
Definition: ActionMessage.hpp:29
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:153
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
void transmit(route_id rid, const ActionMessage &cmd)
Definition: CommsInterface.cpp:169
std::string localTargetAddress
the base for the receive address
Definition: CommsInterface.hpp:124
Definition: CommsInterface.hpp:26
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
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo)
Definition: CommsInterface.cpp:104
bool serverMode
some comms have a server mode and non-server mode
Definition: CommsInterface.hpp:140
int maxMessageSize
the maximum message size for the queues (if needed)
Definition: CommsInterface.hpp:145
bool isPriorityCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:232
@ connected
we are connected
int maxMessageCount
the maximum number of message to buffer (if needed)
Definition: CommsInterface.hpp:146