Method SendProxyHeader

phxsqlproxy/proxy_protocol_handler.cpp:264–289

}

int ProxyProtocolHandler::SendProxyHeader(int fd) {
    int ret = 0;
    std::string header;
    switch (config_->ProxyProtocol()) {
    case 0:
        return 0;
    case 1:
        ret = MakeProxyHeaderV1(header);
        break;
    case 2:
        ret = MakeProxyHeaderV2(header);
        break;
    default:
        return -__LINE__;
    }

    while (ret == 0) {
        ret = RoutineWriteWithTimeout(fd, header.c_str(), header.size(), config_->WriteTimeoutMs());
        if (ret != 0 && ret != (int) header.size()) {
            LOG_ERR("write header to fd [%d] failed, ret %d, hdr size %zu", fd, ret, header.size());
            return -__LINE__;
        }
    }

    return ret;
}

int ProxyProtocolHandler::MakeProxyHeaderV1(std::string & header) {
    if (src_addr_.ss_family == AF_INET && dst_addr_.ss_family == AF_INET) {