bug fixed ps_sub thread join

zhangmeng

2023-03-01 0f53806de20f07b0bc15877c7a9b293758acbfa7

 src/common.h

@@ -17,17 +17,20 @@

namespace nng_wrap {

static thread_local std::string verbose_info{};
#define TAG
#define PRNTVITAG(args)

/*
#ifndef PRNTVITAG
static thread_local std::string verbose_info{};
#define TAG do{ verbose_info.clear(); \
                verbose_info=string("function [")+__FUNCTION__+string("]"); \
            }while(0)
#define PRNTVITAG(msg) do{ \
            verbose_info+=string("-> (") + msg + string(")"); \
        }while(0)
// #define TAG
// #define PRNTVITAG(args)
#endif
*/

/////////////////////////////////////////////////
enum{
@@ -179,6 +182,7 @@
};

enum { INIT, RECV, WAIT, SEND };
enum { REPLY_IPC, REPLY_TCP };
struct work {
    int state{-1};
    nng_aio *aio{};
@@ -186,6 +190,7 @@
    nng_ctx  ctx{};
    void(*cb_recv)(work*){};
    void* user_data{};
    int mode{-1};
};

static const std::string rr_unblocking_msg_{"~!@#$%^&*()-=<<UNBLOCKING>>=-()*&^%$#@!~"};