Method IsProxyHeaderNeed

phxsqlproxy/proxy_protocol_handler.cpp:117–142

}

int ProxyProtocolHandler::IsProxyHeaderNeed() { // 1:need, 0:no need, <0:reject
    std::string src_ip;
    std::string dst_ip;
    int src_port;
    int dst_port;

    if (SockAddrToIPPort((struct sockaddr *) &src_addr_, src_ip, src_port) < 0) {
        return -__LINE__;
    }
    if (SockAddrToIPPort((struct sockaddr *) &dst_addr_, dst_ip, dst_port) < 0) {
        return -__LINE__;
    }

    LOG_DEBUG("receive connect from [%s:%d]", src_ip.c_str(), src_port);

    if (dst_port != worker_config_->proxy_port_) {
        return 0;
    }

    if (!group_status_cache_->IsMember(src_ip)) {
        LOG_ERR("non-member ip [%s] connect port [%d], reject", src_ip.c_str(), dst_port);
        return -__LINE__;
    }

    return 1;
}

int ProxyProtocolHandler::ProcessProxyHeader(int fd) {
    int ret = GetAddrFromFD(fd);