DOOM-3-BFG

EventLoop.cpp (6985B)

---

 /*
 ===========================================================================
 
 Doom 3 BFG Edition GPL Source Code
 Copyright (C) 1993-2012 id Software LLC, a ZeniMax Media company. 
 
 This file is part of the Doom 3 BFG Edition GPL Source Code ("Doom 3 BFG Edition Source Code").  
 
 Doom 3 BFG Edition Source Code is free software: you can redistribute it and/or modify
 it under the terms of the GNU General Public License as published by
 the Free Software Foundation, either version 3 of the License, or
 (at your option) any later version.
 
 Doom 3 BFG Edition Source Code is distributed in the hope that it will be useful,
 but WITHOUT ANY WARRANTY; without even the implied warranty of
 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 GNU General Public License for more details.
 
 You should have received a copy of the GNU General Public License
 along with Doom 3 BFG Edition Source Code.  If not, see <http://www.gnu.org/licenses/>.
 
 In addition, the Doom 3 BFG Edition Source Code is also subject to certain additional terms. You should have received a copy of these additional terms immediately following the terms and conditions of the GNU General Public License which accompanied the Doom 3 BFG Edition Source Code.  If not, please request a copy in writing from id Software at the address below.
 
 If you have questions concerning this license or the applicable additional terms, you may contact in writing id Software LLC, c/o ZeniMax Media Inc., Suite 120, Rockville, Maryland 20850 USA.
 
 ===========================================================================
 */
 
 #include "../idlib/precompiled.h"
 #pragma hdrstop
 
 idCVar idEventLoop::com_journal( "com_journal", "0", CVAR_INIT|CVAR_SYSTEM, "1 = record journal, 2 = play back journal", 0, 2, idCmdSystem::ArgCompletion_Integer<0,2> );
 
 idEventLoop eventLoopLocal;
 idEventLoop *eventLoop = &eventLoopLocal;
 
 
 /*
 =================
 idEventLoop::idEventLoop
 =================
 */
 idEventLoop::idEventLoop() {
 	com_journalFile = NULL;
 	com_journalDataFile = NULL;
 	initialTimeOffset = 0;
 }
 
 /*
 =================
 idEventLoop::~idEventLoop
 =================
 */
 idEventLoop::~idEventLoop() {
 }
 
 /*
 =================
 idEventLoop::GetRealEvent
 =================
 */
 sysEvent_t	idEventLoop::GetRealEvent() {
 	int			r;
 	sysEvent_t	ev;
 
 	// either get an event from the system or the journal file
 	if ( com_journal.GetInteger() == 2 ) {
 		r = com_journalFile->Read( &ev, sizeof(ev) );
 		if ( r != sizeof(ev) ) {
 			common->FatalError( "Error reading from journal file" );
 		}
 		if ( ev.evPtrLength ) {
 			ev.evPtr = Mem_ClearedAlloc( ev.evPtrLength, TAG_EVENTS );
 			r = com_journalFile->Read( ev.evPtr, ev.evPtrLength );
 			if ( r != ev.evPtrLength ) {
 				common->FatalError( "Error reading from journal file" );
 			}
 		}
 	} else {
 		ev = Sys_GetEvent();
 
 		// write the journal value out if needed
 		if ( com_journal.GetInteger() == 1 ) {
 			r = com_journalFile->Write( &ev, sizeof(ev) );
 			if ( r != sizeof(ev) ) {
 				common->FatalError( "Error writing to journal file" );
 			}
 			if ( ev.evPtrLength ) {
 				r = com_journalFile->Write( ev.evPtr, ev.evPtrLength );
 				if ( r != ev.evPtrLength ) {
 					common->FatalError( "Error writing to journal file" );
 				}
 			}
 		}
 	}
 
 	return ev;
 }
 
 /*
 =================
 idEventLoop::PushEvent
 =================
 */
 void idEventLoop::PushEvent( sysEvent_t *event ) {
 	sysEvent_t		*ev;
 	static			bool printedWarning;
 
 	ev = &com_pushedEvents[ com_pushedEventsHead & (MAX_PUSHED_EVENTS-1) ];
 
 	if ( com_pushedEventsHead - com_pushedEventsTail >= MAX_PUSHED_EVENTS ) {
 
 		// don't print the warning constantly, or it can give time for more...
 		if ( !printedWarning ) {
 			printedWarning = true;
 			common->Printf( "WARNING: Com_PushEvent overflow\n" );
 		}
 
 		if ( ev->evPtr ) {
 			Mem_Free( ev->evPtr );
 		}
 		com_pushedEventsTail++;
 	} else {
 		printedWarning = false;
 	}
 
 	*ev = *event;
 	com_pushedEventsHead++;
 }
 
 /*
 =================
 idEventLoop::GetEvent
 =================
 */
 sysEvent_t idEventLoop::GetEvent() {
 	if ( com_pushedEventsHead > com_pushedEventsTail ) {
 		com_pushedEventsTail++;
 		return com_pushedEvents[ (com_pushedEventsTail-1) & (MAX_PUSHED_EVENTS-1) ];
 	}
 	return GetRealEvent();
 }
 
 /*
 =================
 idEventLoop::ProcessEvent
 =================
 */
 void idEventLoop::ProcessEvent( sysEvent_t ev ) {
 	// track key up / down states
 	if ( ev.evType == SE_KEY ) {
 		idKeyInput::PreliminaryKeyEvent( ev.evValue, ( ev.evValue2 != 0 ) );
 	}
 
 	if ( ev.evType == SE_CONSOLE ) {
 		// from a text console outside the game window
 		cmdSystem->BufferCommandText( CMD_EXEC_APPEND, (char *)ev.evPtr );
 		cmdSystem->BufferCommandText( CMD_EXEC_APPEND, "\n" );
 	} else {
 		common->ProcessEvent( &ev );
 	}
 
 	// free any block data
 	if ( ev.evPtr ) {
 		Mem_Free( ev.evPtr );
 	}
 }
 
 /*
 ===============
 idEventLoop::RunEventLoop
 ===============
 */
 int idEventLoop::RunEventLoop( bool commandExecution ) {
 	sysEvent_t	ev;
 
 	while ( 1 ) {
 
 		if ( commandExecution ) {
 			// execute any bound commands before processing another event
 			cmdSystem->ExecuteCommandBuffer();
 		}
 
 		ev = GetEvent();
 
 		// if no more events are available
 		if ( ev.evType == SE_NONE ) {
 			return 0;
 		}
 		ProcessEvent( ev );
 	}
 
 	return 0;	// never reached
 }
 
 /*
 =============
 idEventLoop::Init
 =============
 */
 void idEventLoop::Init() {
 
 	initialTimeOffset = Sys_Milliseconds();
 
 	common->StartupVariable( "journal" );
 
 	if ( com_journal.GetInteger() == 1 ) {
 		common->Printf( "Journaling events\n" );
 		com_journalFile = fileSystem->OpenFileWrite( "journal.dat" );
 		com_journalDataFile = fileSystem->OpenFileWrite( "journaldata.dat" );
 	} else if ( com_journal.GetInteger() == 2 ) {
 		common->Printf( "Replaying journaled events\n" );
 		com_journalFile = fileSystem->OpenFileRead( "journal.dat" );
 		com_journalDataFile = fileSystem->OpenFileRead( "journaldata.dat" );
 	}
 
 	if ( !com_journalFile || !com_journalDataFile ) {
 		com_journal.SetInteger( 0 );
 		com_journalFile = 0;
 		com_journalDataFile = 0;
 		common->Printf( "Couldn't open journal files\n" );
 	}
 }
 
 /*
 =============
 idEventLoop::Shutdown
 =============
 */
 void idEventLoop::Shutdown() {
 	if ( com_journalFile ) {
 		fileSystem->CloseFile( com_journalFile );
 		com_journalFile = NULL;
 	}
 	if ( com_journalDataFile ) {
 		fileSystem->CloseFile( com_journalDataFile );
 		com_journalDataFile = NULL;
 	}
 }
 
 /*
 ================
 idEventLoop::Milliseconds
 
 Can be used for profiling, but will be journaled accurately
 ================
 */
 int idEventLoop::Milliseconds() {
 #if 1	// FIXME!
 	return Sys_Milliseconds() - initialTimeOffset;
 #else
 	sysEvent_t	ev;
 
 	// get events and push them until we get a null event with the current time
 	do {
 
 		ev = Com_GetRealEvent();
 		if ( ev.evType != SE_NONE ) {
 			Com_PushEvent( &ev );
 		}
 	} while ( ev.evType != SE_NONE );
 	
 	return ev.evTime;
 #endif
 }
 
 /*
 ================
 idEventLoop::JournalLevel
 ================
 */
 int idEventLoop::JournalLevel() const {
 	return com_journal.GetInteger();
 }