Method DriverThreadProc

cpp/src/Driver.cpp:428–581

----------------------------------------------------------------------------- Create and manage the worker threads -----------------------------------------------------------------------------

// Create and manage the worker threads
//-----------------------------------------------------------------------------
void Driver::DriverThreadProc
(
		Event* _exitEvent
)
{
#define WAITOBJECTCOUNT 11

	uint32 attempts = 0;
	bool mfsisReady = false;
	while( true )
	{
		if( Init( attempts ) )
		{
			// Driver has been initialised
			Wait* waitObjects[WAITOBJECTCOUNT];
			waitObjects[0] = _exitEvent;						// Thread must exit.
			waitObjects[1] = m_notificationsEvent;				// Notifications waiting to be sent.
			waitObjects[2] = m_queueMsgEvent; ;					// a DNS and HTTP Event
			waitObjects[3] = m_controller;					    // Controller has received data.
			waitObjects[4] = m_queueEvent[MsgQueue_Command];	// A controller command is in progress.
			waitObjects[5] = m_queueEvent[MsgQueue_NoOp];		// Send device probes and diagnostics messages
			waitObjects[6] = m_queueEvent[MsgQueue_Controller];	// A multi-part controller command is in progress
			waitObjects[7] = m_queueEvent[MsgQueue_WakeUp];		// A node has woken. Pending messages should be sent.
			waitObjects[8] = m_queueEvent[MsgQueue_Send];		// Ordinary requests to be sent.
			waitObjects[9] = m_queueEvent[MsgQueue_Query];		// Node queries are pending.
			waitObjects[10] = m_queueEvent[MsgQueue_Poll];		// Poll request is waiting.

			TimeStamp retryTimeStamp;
			int retryTimeout = RETRY_TIMEOUT;
			Options::Get()->GetOptionAsInt( "RetryTimeout", &retryTimeout );
			//retryTimeout = RETRY_TIMEOUT * 10;
			while( true )
			{
				Log::Write( LogLevel_StreamDetail, "      Top of DriverThreadProc loop." );
				uint32 count = WAITOBJECTCOUNT;
				int32 timeout = Wait::Timeout_Infinite;

				// if the ManufacturerDB class is setting up, we can't do anything yet
				if (mfsisReady == false) {
					count=3;

					// If we're waiting for a message to complete, we can only
					// handle incoming data, notifications, DNS/HTTP  and exit events.
				} else if( m_waitingForAck || m_expectedCallbackId || m_expectedReply )
				{
					count = 4;
					timeout = m_waitingForAck ? ACK_TIMEOUT : retryTimeStamp.TimeRemaining();
					if( timeout < 0 )
					{
						timeout = 0;
					}
				}
				else if( m_currentControllerCommand != NULL )
				{
					count = 7;
				}
				else
				{