Method InputNotify

adapter/micro_thread/mt_net.cpp:1352–1394

}

int CSockLink::InputNotify()
{
    int32_t ret = 0;
    
    this->_last_access = mt_time_ms();

    if (_proto_type == NET_PROTO_UDP)
    {
        ret = cache_udp_recv(&_recv_cache, _fd, NULL);
    }
    else
    {
        ret = cache_tcp_recv(&_recv_cache, _fd);
    }

    if (ret < 0)
    {
        if (ret == -SK_ERR_NEED_CLOSE)
        {
            MTLOG_DEBUG("recv on link failed, remote close");
            _errno = RC_REMOTE_CLOSED;
        }
        else
        {
            MTLOG_ERROR("recv on link failed, close it, ret %d[%m]", ret);
            _errno = RC_RECV_FAIL;
        }
    
        this->Destroy();
        return -1;
    }

    ret = this->RecvDispath();
    if (ret < 0)
    {
        MTLOG_DEBUG("recv dispath failed, close it, ret %d[%m]", ret);
        this->Destroy();
        return -2;
    }

    return 0;
    
}

int CSockLink::OutputNotify()
{