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;
173 void termReceivers();
175 void initIterators() noexcept;
176 void startReceivers();
185 timeout_t initPause = { 0 };
190 timeout_t maxHeartBeat = { 10 };
191 IOController::IOStateList::iterator itHeartBeat;
194 timeout_t steptime = { 1000 };
196 std::atomic_bool activated = {
false };
197 std::atomic_bool cancelled = {
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_ Пассивный таймер
Definition: PassiveTimer.h:92
static std::shared_ptr< UNetExchange > init_unetexchange(int argc, const char *const argv[], uniset::ObjectId shmID, const std::shared_ptr< SharedMemory > &ic=0, const std::string &prefix="unet")
Definition: unetexchange.cc:860
Definition: CallbackTimer.h:29
Definition: UNetExchange.h:125
Definition: MessageType.h:168
Definition: UniSetObject.h:73
static void help_print(int argc, const char *argv[]) noexcept
Definition: unetexchange.cc:818
Definition: VMonitor.h:116
const ObjectId DefaultObjectId
Definition: UniSetTypes.h:69
Event
Definition: UNetReceiver.h:152
virtual bool activateObject() override
Активизация объекта (переопределяется для необходимых действий после активизации) ...
Definition: unetexchange.cc:736
Definition: MessageType.h:124
virtual bool deactivateObject() override
Деактивиция объекта (переопределяется для необходимых действий при завершении работы) ...
Definition: unetexchange.cc:752
Definition: MessageType.h:211
Definition: UniSetTypes_i.idl:64
long ObjectId
Definition: UniSetTypes_i.idl:30