Method init_tcp_socket

source/AgentCommon/Transceiver.cpp:144–179

}

uint16_t Transceiver::init_tcp_socket(uint16_t port, bool bind)
{
    LogFunc << VAR(port) << VAR(bind);

    is_tcp_ = true;

    zmq_sock_ = zmq::socket_t(zmq_ctx_, zmq::socket_type::pair);

    zmq_pollitem_send_ = zmq::pollitem_t(zmq_sock_.handle(), 0, ZMQ_POLLOUT, 0);
    zmq_pollitem_recv_ = zmq::pollitem_t(zmq_sock_.handle(), 0, ZMQ_POLLIN, 0);

    is_bound_ = bind;

    if (is_bound_) {
        // 如果 port 为 0，使用通配符让系统自动分配端口
        std::string bind_addr = std::format("tcp://127.0.0.1:{}", port == 0 ? "*" : std::to_string(port));
        zmq_sock_.bind(bind_addr);

        // 获取实际绑定的端点
        char endpoint[256] = { };
        size_t endpoint_len = sizeof(endpoint);
        zmq_getsockopt(zmq_sock_.handle(), ZMQ_LAST_ENDPOINT, endpoint, &endpoint_len);
        ipc_addr_ = endpoint;

        tcp_port_ = parse_port_from_endpoint(ipc_addr_);
        LogInfo << "TCP socket bound" << VAR(ipc_addr_) << VAR(tcp_port_);
    }
    else {
        ipc_addr_ = std::format("tcp://127.0.0.1:{}", port);
        tcp_port_ = port;
        zmq_sock_.connect(ipc_addr_);
        LogInfo << "TCP socket connected" << VAR(ipc_addr_);
    }

    return tcp_port_;
}

bool Transceiver::should_fallback_to_tcp()
{