Method SendCacheTcp

adapter/micro_thread/mt_net.cpp:1020–1080

}

int32_t CSockLink::SendCacheTcp(void* data, uint32_t len)
{
    void* buff = NULL;
    uint32_t buff_len = 0;
    struct iovec iov[64];
    int32_t count = 0;
    CNetHandler* item = NULL;
    CNetHandler* tmp = NULL;

    TAILQ_FOREACH_SAFE(item, &_wait_send, _link_entry, tmp)
    {
        item->GetSendData(buff, buff_len); 
        iov[count].iov_base = buff;
        iov[count].iov_len  = (int32_t)buff_len;
        count++;
        if (count >= 64)
        {
            break;
        }
    }
    if ((count < 64) && (data != NULL))
    {
        iov[count].iov_base = data;
        iov[count].iov_len  = (int32_t)len;
        count++;
    }
    
    ssize_t bytes = writev(_fd, iov, count);
    if (bytes < 0)
    {
        if ((errno == EAGAIN) || (errno == EINTR))
        {
            return 0;
        }
        else
        {
            MTLOG_ERROR("socket writev failed, fd %d, errno %d(%s)", _fd, 
                   errno, strerror(errno));
            return -1;
        }
    }

    uint32_t send_left = (uint32_t)bytes;
    TAILQ_FOREACH_SAFE(item, &_wait_send, _link_entry, tmp)
    {
        send_left -= item->SkipSendPos(send_left);
        item->GetSendData(buff, buff_len); 
        if (buff_len == 0)
        {
            NotifyThread(item, 0);
            item->SwitchToIdle();
        }

        if (send_left == 0)
        {
            break;
        }
    }