Method QueueOutgoingData

src/OSSupport/SocketThreads.cpp:665–689

void cSocketThreads::cSocketThread::QueueOutgoingData(void)
{
	cCSLock Lock(m_Parent->m_CS);
	for (int i = 0; i < m_NumSlots; i++)
	{
		if (m_Slots[i].m_Client != NULL)
		{
			AString Data;
			m_Slots[i].m_Client->GetOutgoingData(Data);
			m_Slots[i].m_Outgoing.append(Data);
		}
		if (m_Slots[i].m_Outgoing.empty())
		{
			// No outgoing data is ready
			if (m_Slots[i].m_State == sSlot::ssWritingRestOut)
			{
				// The socket doesn't want to be kept alive anymore, and doesn't have any remaining data to send.
				// Shut it down and then close it after a timeout, or when the other side agrees
				m_Slots[i].m_State = sSlot::ssShuttingDown;
				m_Slots[i].m_Socket.ShutdownReadWrite();
			}
			continue;
		}
	}
}