Fix line endings. WHAMMY.

1 files changed, 192 insertions, 192 deletions

diff --git a/mp/src/utils/common/MySqlDatabase.cpp b/mp/src/utils/common/MySqlDatabase.cpp
index 46d8a4b9..2558ba08 100644
--- a/mp/src/utils/common/MySqlDatabase.cpp
+++ b/mp/src/utils/common/MySqlDatabase.cpp
@@ -1,192 +1,192 @@
-//========= Copyright Valve Corporation, All rights reserved. ============//

-//

-// Purpose: 

-//

-// $NoKeywords: $

-//=============================================================================//

-

-#include "MySqlDatabase.h"

-

-//-----------------------------------------------------------------------------

-// Purpose: Constructor

-//-----------------------------------------------------------------------------

-CMySqlDatabase::CMySqlDatabase()

-{

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Destructor

-//			blocks until db process thread has stopped

-//-----------------------------------------------------------------------------

-CMySqlDatabase::~CMySqlDatabase()

-{

-	// flag the thread to stop

-	m_bRunThread = false;

-

-	// pulse the thread to make it run

-	::SetEvent(m_hEvent);

-

-	// make sure it's done

-	::EnterCriticalSection(&m_csThread);

-	::LeaveCriticalSection(&m_csThread);

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Thread access function

-//-----------------------------------------------------------------------------

-static DWORD WINAPI staticThreadFunc(void *param)

-{

-	((CMySqlDatabase *)param)->RunThread();

-	return 0;

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Establishes connection to the database and sets up this object to handle db command

-// Output : Returns true on success, false on failure.

-//-----------------------------------------------------------------------------

-bool CMySqlDatabase::Initialize()

-{

-	// prepare critical sections

-	//!! need to download SDK and replace these with InitializeCriticalSectionAndSpinCount() calls

-	::InitializeCriticalSection(&m_csThread);

-	::InitializeCriticalSection(&m_csInQueue);

-	::InitializeCriticalSection(&m_csOutQueue);

-	::InitializeCriticalSection(&m_csDBAccess);

-

-	// initialize wait calls

-	m_hEvent = ::CreateEvent(NULL, false, true, NULL);

-

-	// start the DB-access thread

-	m_bRunThread = true;

-

-	unsigned long threadID;

-	::CreateThread(NULL, 0, staticThreadFunc, this, 0, &threadID);

-

-	return true;

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Main thread loop

-//-----------------------------------------------------------------------------

-void CMySqlDatabase::RunThread()

-{

-	::EnterCriticalSection(&m_csThread);

-	while (m_bRunThread)

-	{

-		if (m_InQueue.Count() > 0)

-		{

-			// get a dispatched DB request

-			::EnterCriticalSection(&m_csInQueue);

-

-			// pop the front of the queue

-			int headIndex = m_InQueue.Head();

-			msg_t msg = m_InQueue[headIndex];

-			m_InQueue.Remove(headIndex);

-

-			::LeaveCriticalSection(&m_csInQueue);

-

-			::EnterCriticalSection(&m_csDBAccess);

-			

-			// run sqldb command

-			msg.result = msg.cmd->RunCommand();

-

-			::LeaveCriticalSection(&m_csDBAccess);

-

-			if (msg.replyTarget)

-			{

-				// put the results in the outgoing queue

-				::EnterCriticalSection(&m_csOutQueue);

-				m_OutQueue.AddToTail(msg);

-				::LeaveCriticalSection(&m_csOutQueue);

-

-				// wake up out queue

-				msg.replyTarget->WakeUp();

-			}

-			else

-			{

-				// there is no return data from the call, so kill the object now

-				msg.cmd->deleteThis();

-			}

-		}

-		else

-		{

-			// nothing in incoming queue, so wait until we get the signal

-			::WaitForSingleObject(m_hEvent, INFINITE);

-		}

-

-		// check the size of the outqueue; if it's getting too big, sleep to let the main thread catch up

-		if (m_OutQueue.Count() > 50)

-		{

-			::Sleep(2);

-		}

-	}

-	::LeaveCriticalSection(&m_csThread);

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Adds a database command to the queue, and wakes the db thread

-//-----------------------------------------------------------------------------

-void CMySqlDatabase::AddCommandToQueue(ISQLDBCommand *cmd, ISQLDBReplyTarget *replyTarget, int returnState)

-{

-	::EnterCriticalSection(&m_csInQueue);

-

-	// add to the queue

-	msg_t msg = { cmd, replyTarget, 0, returnState };

-	m_InQueue.AddToTail(msg);

-

-	::LeaveCriticalSection(&m_csInQueue);

-

-	// signal the thread to start running

-	::SetEvent(m_hEvent);

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: Dispatches responses to SQLDB queries

-//-----------------------------------------------------------------------------

-bool CMySqlDatabase::RunFrame()

-{

-	bool doneWork = false;

-

-	while (m_OutQueue.Count() > 0)

-	{

-		::EnterCriticalSection(&m_csOutQueue);

-

-		// pop the first item in the queue

-		int headIndex = m_OutQueue.Head();

-		msg_t msg = m_OutQueue[headIndex];

-		m_OutQueue.Remove(headIndex);

-

-		::LeaveCriticalSection(&m_csOutQueue);

-

-		// run result

-		if (msg.replyTarget)

-		{

-			msg.replyTarget->SQLDBResponse(msg.cmd->GetID(), msg.returnState, msg.result, msg.cmd->GetReturnData());

-

-			// kill command

-			// it would be a good optimization to be able to reuse these

-			msg.cmd->deleteThis();

-		}

-

-		doneWork = true;

-	}

-

-	return doneWork;

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: load info - returns the number of sql db queries waiting to be processed

-//-----------------------------------------------------------------------------

-int CMySqlDatabase::QueriesInOutQueue()

-{

-	// the queue names are from the DB point of view, not the server - thus the reversal

-	return m_InQueue.Count();

-}

-

-//-----------------------------------------------------------------------------

-// Purpose: number of queries finished processing, waiting to be responded to

-//-----------------------------------------------------------------------------

-int CMySqlDatabase::QueriesInFinishedQueue()

-{

-	return m_OutQueue.Count();

-}

+//========= Copyright Valve Corporation, All rights reserved. ============//
+//
+// Purpose: 
+//
+// $NoKeywords: $
+//=============================================================================//
+
+#include "MySqlDatabase.h"
+
+//-----------------------------------------------------------------------------
+// Purpose: Constructor
+//-----------------------------------------------------------------------------
+CMySqlDatabase::CMySqlDatabase()
+{
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Destructor
+//			blocks until db process thread has stopped
+//-----------------------------------------------------------------------------
+CMySqlDatabase::~CMySqlDatabase()
+{
+	// flag the thread to stop
+	m_bRunThread = false;
+
+	// pulse the thread to make it run
+	::SetEvent(m_hEvent);
+
+	// make sure it's done
+	::EnterCriticalSection(&m_csThread);
+	::LeaveCriticalSection(&m_csThread);
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Thread access function
+//-----------------------------------------------------------------------------
+static DWORD WINAPI staticThreadFunc(void *param)
+{
+	((CMySqlDatabase *)param)->RunThread();
+	return 0;
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Establishes connection to the database and sets up this object to handle db command
+// Output : Returns true on success, false on failure.
+//-----------------------------------------------------------------------------
+bool CMySqlDatabase::Initialize()
+{
+	// prepare critical sections
+	//!! need to download SDK and replace these with InitializeCriticalSectionAndSpinCount() calls
+	::InitializeCriticalSection(&m_csThread);
+	::InitializeCriticalSection(&m_csInQueue);
+	::InitializeCriticalSection(&m_csOutQueue);
+	::InitializeCriticalSection(&m_csDBAccess);
+
+	// initialize wait calls
+	m_hEvent = ::CreateEvent(NULL, false, true, NULL);
+
+	// start the DB-access thread
+	m_bRunThread = true;
+
+	unsigned long threadID;
+	::CreateThread(NULL, 0, staticThreadFunc, this, 0, &threadID);
+
+	return true;
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Main thread loop
+//-----------------------------------------------------------------------------
+void CMySqlDatabase::RunThread()
+{
+	::EnterCriticalSection(&m_csThread);
+	while (m_bRunThread)
+	{
+		if (m_InQueue.Count() > 0)
+		{
+			// get a dispatched DB request
+			::EnterCriticalSection(&m_csInQueue);
+
+			// pop the front of the queue
+			int headIndex = m_InQueue.Head();
+			msg_t msg = m_InQueue[headIndex];
+			m_InQueue.Remove(headIndex);
+
+			::LeaveCriticalSection(&m_csInQueue);
+
+			::EnterCriticalSection(&m_csDBAccess);
+			
+			// run sqldb command
+			msg.result = msg.cmd->RunCommand();
+
+			::LeaveCriticalSection(&m_csDBAccess);
+
+			if (msg.replyTarget)
+			{
+				// put the results in the outgoing queue
+				::EnterCriticalSection(&m_csOutQueue);
+				m_OutQueue.AddToTail(msg);
+				::LeaveCriticalSection(&m_csOutQueue);
+
+				// wake up out queue
+				msg.replyTarget->WakeUp();
+			}
+			else
+			{
+				// there is no return data from the call, so kill the object now
+				msg.cmd->deleteThis();
+			}
+		}
+		else
+		{
+			// nothing in incoming queue, so wait until we get the signal
+			::WaitForSingleObject(m_hEvent, INFINITE);
+		}
+
+		// check the size of the outqueue; if it's getting too big, sleep to let the main thread catch up
+		if (m_OutQueue.Count() > 50)
+		{
+			::Sleep(2);
+		}
+	}
+	::LeaveCriticalSection(&m_csThread);
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Adds a database command to the queue, and wakes the db thread
+//-----------------------------------------------------------------------------
+void CMySqlDatabase::AddCommandToQueue(ISQLDBCommand *cmd, ISQLDBReplyTarget *replyTarget, int returnState)
+{
+	::EnterCriticalSection(&m_csInQueue);
+
+	// add to the queue
+	msg_t msg = { cmd, replyTarget, 0, returnState };
+	m_InQueue.AddToTail(msg);
+
+	::LeaveCriticalSection(&m_csInQueue);
+
+	// signal the thread to start running
+	::SetEvent(m_hEvent);
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: Dispatches responses to SQLDB queries
+//-----------------------------------------------------------------------------
+bool CMySqlDatabase::RunFrame()
+{
+	bool doneWork = false;
+
+	while (m_OutQueue.Count() > 0)
+	{
+		::EnterCriticalSection(&m_csOutQueue);
+
+		// pop the first item in the queue
+		int headIndex = m_OutQueue.Head();
+		msg_t msg = m_OutQueue[headIndex];
+		m_OutQueue.Remove(headIndex);
+
+		::LeaveCriticalSection(&m_csOutQueue);
+
+		// run result
+		if (msg.replyTarget)
+		{
+			msg.replyTarget->SQLDBResponse(msg.cmd->GetID(), msg.returnState, msg.result, msg.cmd->GetReturnData());
+
+			// kill command
+			// it would be a good optimization to be able to reuse these
+			msg.cmd->deleteThis();
+		}
+
+		doneWork = true;
+	}
+
+	return doneWork;
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: load info - returns the number of sql db queries waiting to be processed
+//-----------------------------------------------------------------------------
+int CMySqlDatabase::QueriesInOutQueue()
+{
+	// the queue names are from the DB point of view, not the server - thus the reversal
+	return m_InQueue.Count();
+}
+
+//-----------------------------------------------------------------------------
+// Purpose: number of queries finished processing, waiting to be responded to
+//-----------------------------------------------------------------------------
+int CMySqlDatabase::QueriesInFinishedQueue()
+{
+	return m_OutQueue.Count();
+}