 |
helics
3.3.0
|
8 #include "GlobalFederateId.hpp"
24 decltype(std::chrono::steady_clock::now()) lastPing;
36 void setTimeout(std::chrono::milliseconds to) { timeout = to; }
46 parentConnection.disablePing = value;
47 parentConnection.waitingForPingReply =
false;
51 std::chrono::milliseconds timeout{100
'000'000};
52 bool waitingForConnection{
false};
53 decltype(std::chrono::steady_clock::now()) startWaiting;
54 linkConnection parentConnection;
55 std::vector<linkConnection> connections;
virtual void processCommand(ActionMessage &&command) override final
Definition: CommonCore.cpp:3238
@ indicator_flag
flag used for setting values
Definition: flagOperations.hpp:18
bool disablePing
indicator that the connection doesn't respond to pings
Definition: TimeoutMonitor.h:22
GlobalBrokerId higher_broker_id
the id code of the broker 1 level about this broker
Definition: BrokerBase.hpp:49
@ ERROR_LEVEL
only print errors
Definition: logging.hpp:23
void setTimeout(std::chrono::milliseconds to)
Definition: TimeoutMonitor.h:36
Definition: CommonCore.hpp:74
virtual const std::string & getIdentifier() const override final
Definition: CommonCore.cpp:187
bool sendToLogger(GlobalFederateId federateID, int logLevel, std::string_view name, std::string_view message, bool fromRemote=false) const
Definition: BrokerBase.cpp:343
std::atomic< GlobalBrokerId > global_id
Definition: BrokerBase.hpp:46
Definition: GlobalFederateId.hpp:72
Definition: ActionMessage.hpp:30
constexpr GlobalBrokerId parent_broker_id
Definition: GlobalFederateId.hpp:64
GlobalFederateId connection
the id of the connection
Definition: TimeoutMonitor.h:23
virtual void transmit(route_id route, const ActionMessage &command)=0
virtual const std::string & getIdentifier() const override final
Definition: CoreBroker.hpp:297
bool activeConnection
indicator that the connection is active
Definition: TimeoutMonitor.h:21
void addActionMessage(const ActionMessage &m)
Definition: BrokerBase.cpp:551
virtual bool isRoot() const override final
Definition: CoreBroker.hpp:217
int32_t messageID
8 – message ID for a variety of purposes
Definition: ActionMessage.hpp:36
void setActionFlag(FlagContainer &M, FlagIndex flag)
Definition: flagOperations.hpp:130
virtual bool isConnected() const override final
Definition: CoreBroker.cpp:2292
void setParentId(GlobalBrokerId parent_id)
Definition: TimeoutMonitor.h:42
bool waitingForPingReply
indicator that the connection is waiting
Definition: TimeoutMonitor.h:20
Definition: GlobalFederateId.hpp:27
Definition: TimeoutMonitor.h:19
GlobalFederateId dest_id
20 fed_id for a targeted message
Definition: ActionMessage.hpp:39
virtual void transmit(route_id rid, const ActionMessage &command)=0
@ TERMINATED
the termination process has started
@ ERRORED
an error was encountered
the main namespace for the helics co-simulation library User functions will be in the helics namespac...
Definition: AsyncFedCallInfo.hpp:14
void tick(CommonCore *core)
Definition: TimeoutMonitor.cpp:19
void disableParentPing(bool value=true)
Definition: TimeoutMonitor.h:44
void pingSub(CoreBroker *brk)
Definition: TimeoutMonitor.cpp:176
Definition: TimeoutMonitor.h:27
void pingReply(const ActionMessage &cmd, CoreBroker *brk=nullptr)
Definition: TimeoutMonitor.cpp:230
Definition: CoreBroker.hpp:93
void reset()
Definition: TimeoutMonitor.cpp:221
virtual bool isConnected() const override final
Definition: CommonCore.cpp:180
GlobalFederateId source_id
12 – for federate_id or route_id
Definition: ActionMessage.hpp:37
GlobalBrokerId global_broker_id_local
Definition: BrokerBase.hpp:47