Function GetPeerName

phxsqlproxy/phxsqlproxyutil.cpp:191–203

}

int GetPeerName(int fd, std::string & ip, int & port) {
    struct sockaddr_storage addr_storage;
    struct sockaddr * addr = (struct sockaddr *) &addr_storage;
    socklen_t sock_len = sizeof(addr_storage);

    int ret = getpeername(fd, addr, &sock_len);
    if (ret == -1) {
        LogError("getpeername fd [%d] failed, ret %d, errno (%d:%s)", fd, ret, errno, strerror(errno));
        return -__LINE__;
    }

    return SockAddrToIPPort(addr, ip, port);
}

uint64_t DecodedLengthBinary(const char * buf, int len, int & len_field_size) {
    uint8_t first_bit = (uint8_t)(buf[0]);