17 #ifndef UNetExchange_H_
18 #define UNetExchange_H_
24 #include "UniSetObject.h"
27 #include "SMInterface.h"
28 #include "SharedMemory.h"
29 #include "ThreadCreator.h"
30 #include "UNetReceiver.h"
31 #include "UNetSender.h"
32 #include "LogServer.h"
33 #include "DebugStream.h"
34 #include "UNetLogSugar.h"
35 #include "LogAgregator.h"
39 #define vmonit( var ) vmon.add( #var, var )
133 static std::shared_ptr<UNetExchange>
init_unetexchange(
int argc,
const char*
const argv[],
134 uniset::ObjectId shmID,
const std::shared_ptr<SharedMemory>& ic = 0,
const std::string& prefix =
"unet" );
137 static void help_print(
int argc,
const char* argv[] ) noexcept;
139 bool checkExistUNetHost(
const std::string& host,
int port ) noexcept;
141 inline std::shared_ptr<LogAgregator> getLogAggregator() noexcept
145 inline std::shared_ptr<DebugStream> log() noexcept
156 std::string s_fvalue;
158 std::shared_ptr<SMInterface> shm;
159 void step() noexcept;
164 void askSensors( UniversalIO::UIOCommand cmd );
166 void receiverEvent(
const std::shared_ptr<UNetReceiver>& r,
UNetReceiver::Event ev ) noexcept;
172 virtual void sigterm(
int signo );
174 void termReceivers();
176 void initIterators() noexcept;
177 void startReceivers();
186 timeout_t initPause = { 0 };
191 timeout_t maxHeartBeat = { 10 };
192 IOController::IOStateList::iterator itHeartBeat;
195 timeout_t steptime = { 1000 };
197 std::atomic_bool activated = {
false };
198 timeout_t activateTimeout = { 20000 };
202 ReceiverInfo() noexcept: r1(
nullptr), r2(
nullptr),
204 respondInvert(
false),
209 ReceiverInfo(
const std::shared_ptr<UNetReceiver>& _r1,
const std::shared_ptr<UNetReceiver>& _r2 ) noexcept:
212 respondInvert(
false),
217 std::shared_ptr<UNetReceiver> r1;
218 std::shared_ptr<UNetReceiver> r2;
220 void step(
const std::shared_ptr<SMInterface>& shm,
const std::string& myname, std::shared_ptr<DebugStream>& log ) noexcept;
222 inline void setRespondID(
uniset::ObjectId id,
bool invert =
false ) noexcept
225 respondInvert = invert;
236 inline void initIterators(
const std::shared_ptr<SMInterface>& shm ) noexcept
238 shm->initIterator(itLostPackets);
239 shm->initIterator(itRespond);
240 shm->initIterator(itChannelNum);
248 IOController::IOStateList::iterator itRespond;
249 bool respondInvert = {
false };
251 IOController::IOStateList::iterator itLostPackets;
253 IOController::IOStateList::iterator itChannelNum;
256 typedef std::deque<ReceiverInfo> ReceiverList;
257 ReceiverList recvlist;
259 bool no_sender = {
false };
260 std::shared_ptr<UNetSender> sender;
261 std::shared_ptr<UNetSender> sender2;
263 std::shared_ptr<LogAgregator> loga;
264 std::shared_ptr<DebugStream> unetlog;
265 std::shared_ptr<LogServer> logserv;
266 std::string logserv_host = {
""};
267 int logserv_port = {0};
274 #endif // UNetExchange_H_