zhangmeng
2022-01-13 b379104205af838e883a252e9b8358b0388e6015
performance
2个文件已修改
4 ■■■ 已修改文件
src/bn_api.cpp 3 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/nng_wrap.cpp 1 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
src/bn_api.cpp
@@ -42,6 +42,7 @@
        unsigned short port = *(unsigned short*)(out);
        copy_memory(reply, reply_len, (char*)out + port_size, out_len - port_size);
        BHFree(out, out_len);
        printf("======>> recv port %d\n", port);
/////////////////////////////////////////////////////////////////////////
        const auto& url_pub_proxy = get_url(URLPubProxy);
@@ -52,7 +53,7 @@
        const auto& url_hb = get_url(URLHeartBeat);
        respond_survey(url_hb, string{(const char*)proc_info, (const size_t)proc_info_len});
        start_reply(pi.proc_id(), 0);
        start_reply(pi.proc_id(), port);
    }
    return ret;
}
src/nng_wrap.cpp
@@ -512,6 +512,7 @@
        get<1>(get<1>(rep->socks_)) = port;
        ipc = "tcp://0.0.0.0:" + to_string(port);
        if(create_server(&get<0>(get<1>(rep->socks_)), ipc, 62, rep) != 0) return -1;
        printf("======>> create server for remote port %d\n", port);
    }else {
        get<0>(get<1>(rep->socks_)).id = numeric_limits<int32_t>::max();
    }