Method ThreadProc

BeefySysLib/util/BeefPerf.cpp:897–1382

}

void BpManager::ThreadProc()
{
	BfpThread_SetName(NULL, "BeefPerf", NULL);

	if (!Connect())
	{				
		mConnectState = BpConnectState_Failed;
		LostConnection();		
		FinishWorkThread();
		return;
	}	

	Buffer threadBuffer;
	String tempStr;
	CircularBuffer::View outView;

	timeval timeout;
	timeout.tv_sec  = 0;
	timeout.tv_usec = 20 * 1000; // 20ms

	uint32 gLastMsgTick = BFTickCount();

	DWORD lastTimeTick = 0;

	while (mConnectState != BpConnectState_NotConnected)
	{
		bool wantsExit = mShutdownEvent.WaitFor(0);

		FD_SET socketReadSet;
		FD_ZERO(&socketReadSet);
		FD_SET(mSocket, &socketReadSet);

		FD_SET socketWriteSet;
		FD_ZERO(&socketWriteSet);
		if (mOutBuffer.GetSize() > 0)			
			FD_SET(mSocket, &socketWriteSet);

		FD_SET socketErrorSet;
		FD_ZERO(&socketErrorSet);
		FD_SET(mSocket, &socketErrorSet);

		int selResult = select((int)mSocket + 1, &socketReadSet, &socketWriteSet, &socketErrorSet, &timeout);
		if (FD_ISSET(mSocket, &socketWriteSet))
		{
			TrySendData();
			//continue;
		}
		if (FD_ISSET(mSocket, &socketReadSet))
		{
			// Just eat the data
			uint8 data[4096];
			int len = recv(mSocket, (char*)data, 4096, 0);
			int b = 0;
		}
		if (FD_ISSET(mSocket, &socketErrorSet))
		{
#ifdef BF_PLATFORM_WINDOWS
			int err = WSAGetLastError();