Method Execute

src/OSSupport/SocketThreads.cpp:381–420

void cSocketThreads::cSocketThread::Execute(void)
{
	// Connect the "client" part of the Control socket:
	m_ControlSocket1 = cSocket::CreateSocket(cSocket::IPv4);
	ASSERT(m_ControlSocket2.GetPort() != 0);  // We checked in the Start() method, but let's be sure
	if (!m_ControlSocket1.ConnectToLocalhostIPv4(m_ControlSocket2.GetPort()))
	{
		LOGERROR("Cannot connect Control sockets for a cSocketThread (\"%s\"); continuing, but the server may be unreachable from now on.", cSocket::GetLastErrorString().c_str());
		m_ControlSocket2.CloseSocket();
		return;
	}
	
	// The main thread loop:
	while (!m_ShouldTerminate)
	{
		// Read outgoing data from the clients:
		QueueOutgoingData();
		
		// Put sockets into the sets
		fd_set fdRead;
		fd_set fdWrite;
		cSocket::xSocket Highest = m_ControlSocket1.GetSocket();
		PrepareSets(&fdRead, &fdWrite, Highest);
		
		// Wait for the sockets:
		timeval Timeout;
		Timeout.tv_sec = 5;
		Timeout.tv_usec = 0;
		if (select(Highest + 1, &fdRead, &fdWrite, NULL, &Timeout) == -1)
		{
			LOG("select() call failed in cSocketThread: \"%s\"", cSocket::GetLastErrorString().c_str());
			continue;
		}
		
		// Perform the IO:
		ReadFromSockets(&fdRead);
		WriteToSockets(&fdWrite);
		CleanUpShutSockets();
	}  // while (!mShouldTerminate)
}