 |
helics
3.0.1
|
9 #include "../CommsInterface.hpp"
10 #include "helics/helics-config.h"
29 virtual void queue_rx_function()
override;
30 virtual void queue_tx_function()
override;
35 std::string getAddress()
const;
std::string brokerTargetAddress
the base for the broker address
Definition: CommsInterface.hpp:125
bool propertyLock()
Definition: CommsInterface.cpp:153
~InprocComms()
Definition: InprocComms.cpp:27
bool observer
true for connections that are for observation only
Definition: CommsInterface.hpp:143
@ processed
the message was used to update the current state
std::string name
the name of the object
Definition: CommsInterface.hpp:123
@ terminated
the connection has been terminated
void logWarning(const std::string &message) const
Definition: CommsInterface.cpp:571
std::shared_ptr< Broker > findBroker(const std::string &brokerName)
Definition: BrokerFactory.cpp:182
void logError(const std::string &message) const
Definition: CommsInterface.cpp:580
thread_generation
Definition: CommsInterface.hpp:30
@ INPROC
core/broker using a stripped down in process core type
size_t cleanUpBrokers()
Definition: BrokerFactory.cpp:269
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
gmlc::containers::BlockingPriorityQueue< std::pair< route_id, ActionMessage > > txQueue
set of messages waiting to be transmitted
Definition: CommsInterface.hpp:154
Definition: InprocComms.h:19
InprocComms()
Definition: InprocComms.cpp:24
@ error
some error occurred on the connection
void disconnect()
Definition: CommsInterface.cpp:385
std::shared_ptr< Core > findCore(const std::string &name)
Definition: CoreFactory.cpp:275
int getPort() const
Definition: InprocComms.h:33
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:841
bool isDisconnectCommand(const ActionMessage &command) noexcept
Definition: ActionMessage.hpp:276
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 copyBrokerIdentifier(const std::string ©FromName, const std::string ©ToName)
Definition: BrokerFactory.cpp:296
bool serverMode
some comms have a server mode and non-server mode
Definition: CommsInterface.hpp:140
std::shared_ptr< Broker > create(CoreType type, const std::string &configureString)
Definition: BrokerFactory.cpp:98
bool copyCoreIdentifier(const std::string ©FromName, const std::string ©ToName)
Definition: CoreFactory.cpp:353
bool autoBroker
the broker should be automatically generated if needed
Definition: CommsInterface.hpp:141
virtual void loadNetworkInfo(const NetworkBrokerData &netInfo) override
Definition: InprocComms.cpp:29
std::shared_ptr< Broker > findJoinableBrokerOfType(CoreType type)
Definition: BrokerFactory.cpp:214
@ connected
we are connected