SendInLoop()

void Spices::Net::TcpConnection::SendInLoop ( const char * message, size_t len )

private

Send message to socket.

Parameters

[in]	message	Data pointer.
[in]	len	message bytes.

ShutDown has been called before.

First writing.

Send message separatly.

ShutDown has been called before.

First writing.

Send message separatly.

Definition at line 177 of file TcpConnection.cpp.

    {
        int nWrote = 0;
        size_t remaining = len;
        bool faultError = false;
 
        if (m_State.load() == State::Disconnected)
        {
            SPICES_CORE_ERROR("Disconnected, Can bot send message")
            return;
        }
 
        if (!m_Channel->IsWriting() && m_OutputBuffer.ReadableBytes() == 0)
        {
            nWrote = ::send(m_Channel->Fd(), message, len, 0);
            if (nWrote >= 0)
            {
                remaining = len - nWrote;
                if (remaining == 0 && m_WriteCompleteCallback.size() > 0)
                {
                    m_IoLoop->QueueInLoop([=]() { m_WriteCompleteCallback.Broadcast(shared_from_this()); });
                }
            }
            else
            {
                nWrote = 0;
                const int err = WSAGetLastError();
 
                if (err != WSAEWOULDBLOCK)
                {
                    SPICES_CORE_ERROR(" TcpConnection::SendInLoop")
 
                    if (err == WSAECONNRESET || err == WSAECONNRESET)
                    {
                        faultError = true;
                    }
                }
            }
        }
 
        if (!faultError && remaining > 0)
        {
            const size_t oldLen = m_OutputBuffer.ReadableBytes();
            if (oldLen + remaining >= HighWaterMark && oldLen < HighWaterMark && m_HighWaterMarkCallback.size() > 0)
            {
                m_IoLoop->QueueInLoop([=]() { m_HighWaterMarkCallback.Broadcast(shared_from_this(), oldLen + remaining); });
            }
            m_OutputBuffer.Append((char*)message + nWrote, remaining);
            if (!m_Channel->IsWriting())
            {
                m_Channel->EnableWriting();
            }
        }
    }

References m_IoLoop.