src/common.h
@@ -179,6 +179,7 @@ }; enum { INIT, RECV, WAIT, SEND }; enum { REPLY_IPC, REPLY_TCP }; struct work { int state{-1}; nng_aio *aio{}; @@ -186,6 +187,7 @@ nng_ctx ctx{}; void(*cb_recv)(work*){}; void* user_data{}; int mode{-1}; }; static const std::string rr_unblocking_msg_{"~!@#$%^&*()-=<<UNBLOCKING>>=-()*&^%$#@!~"};