Method WaitSend

adapter/micro_thread/mt_net.cpp:322–368

}

int32_t CNetHandler::WaitSend(uint64_t timeout)
{
    CSockLink* conn = (CSockLink*)this->_conn_ptr;
    if (NULL == conn)
    {
        MTLOG_ERROR("get sock link handle failed");
        return RC_MEM_ERROR;
    }
    
    int32_t ret = conn->SendData(_req_data, _req_len);
    if (ret < 0)
    {
        MTLOG_ERROR("sock send failed, ret %d[%m]", ret);
        return RC_SEND_FAIL;
    }
    this->SkipSendPos(ret);
    
    if (_req_len == 0)
    {
        MTLOG_DEBUG("sock send ok");
        return RC_SUCCESS;
    }

    this->SwitchToSend();

    MtFrame* mtframe = MtFrame::Instance();
    mtframe->WaitNotify(timeout);

    this->SwitchToIdle();

    if (_err_no != 0)
    {
        MTLOG_ERROR("send get out errno %d", _err_no);
        return _err_no;
    }

    if (_req_len == 0)
    {
        MTLOG_DEBUG("send req ok, len %u", _send_pos);
        return 0;
    }
    else
    {
        MTLOG_TRACE("send req not ok, left len %u", _req_len);
        return RC_SEND_FAIL;
    }
}

int32_t CNetHandler::WaitRecv(uint64_t timeout)
{