Method CreateSock

adapter/micro_thread/mt_net.cpp:833–880

}

int32_t CSockLink::CreateSock()
{
    if (_fd > 0)
    {
        return _fd;
    }

    if (NET_PROTO_TCP == _proto_type)
    {
        _fd = socket(AF_INET, SOCK_STREAM, 0);
    }
    else
    {
        _fd = socket(AF_INET, SOCK_DGRAM, 0);
    }

    if (_fd < 0)
    {
        MTLOG_ERROR("create socket failed, ret %d[%m]", _fd);
        return -1;
    }

    int flags = 1;
    if (ioctl(_fd, FIONBIO, &flags) < 0)
    {
        MTLOG_ERROR("socket unblock failed, %m");
        close(_fd);
        _fd = -1;
        return -2;
    }

    if (NET_PROTO_TCP == _proto_type)
    {
        setsockopt(_fd, IPPROTO_TCP, TCP_NODELAY, &flags, sizeof(flags));
        this->EnableOutput();
    }

    this->EnableInput();
    if (!MtFrame::Instance()->KqueueAddObj(this))
    {
        MTLOG_ERROR("socket epoll mng failed, %m");
        close(_fd);
        _fd = -1;
        return -3;
    }

    return _fd;
}

struct sockaddr_in* CSockLink::GetDestAddr(struct sockaddr_in* addr)
{