initial importHEADmain

1 files changed, 260 insertions, 0 deletions

diff --git a/src/libparsec/utl_logfile.cpp b/src/libparsec/utl_logfile.cpp
new file mode 100644
index 0000000..60ee101
--- /dev/null
+++ b/src/libparsec/utl_logfile.cpp
@@ -0,0 +1,260 @@
+/*
+ * PARSEC - Logfile class 
+ *
+ * $Author: uberlinuxguy $ - $Date: 2004/09/26 03:43:46 $
+ *
+ * Orginally written by:
+ *   Copyright (c) Clemens Beer        <cbx@parsec.org>   2002
+ *
+ *  This program 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 2 of the License, or
+ *  (at your option) any later version.
+ *
+ *  This program 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 this program; if not, write to the Free Software
+ *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ */ 
+
+// C library
+#include <stdio.h>
+#include <string.h>
+#include <math.h>
+#include <stdarg.h>
+
+// compilation flags/debug support
+#include "config.h"
+#include "debug.h"
+
+// C library 
+#ifdef SYSTEM_TARGET_WINDOWS
+#  include <time.h>
+#else
+#  include <sys/time.h>
+#endif
+
+// platform specific includes
+#ifdef SYSTEM_TARGET_WINDOWS
+	#include "windows.h"
+	#include "mmsystem.h"
+	#pragma comment( lib, "winmm.lib" )
+#endif // SYSTEM_TARGET_WINDOWS
+
+
+// general definitions
+#include "general.h"
+#include "objstruc.h"
+
+// global externals
+#include "globals.h"
+
+// subsystem headers
+#include "sys_defs.h"
+
+// local module header
+#include "utl_logfile.h"
+
+
+// flags ----------------------------------------------------------------------
+//
+#define ENABLE_AUTO_FLUSH
+
+// constants ------------------------------------------------------------------
+//
+#define MAX_REGISTERED_LOGFILES		10
+
+
+
+// global logfile -------------------------------------------------------------
+//
+#ifdef ENABLE_LOGOUT_COMMAND
+	
+	UTL_LogFile g_Logfile( "global.log" );
+
+#endif // ENABLE_LOGOUT_COMMAND
+
+// global list of registered logfiles -----------------------------------------
+//
+static UTL_LogFile*	g_RegisteredLogfiles[ MAX_REGISTERED_LOGFILES ];
+static int			g_nNumRegisteredLogfiles = 0;
+
+
+// register a logfile globally to ensure it is flushed upon program termination
+//
+PRIVATE 
+int RegisterLogfile( UTL_LogFile* pLogfile )
+{
+	ASSERT( pLogfile != NULL );
+
+	// check if list is full
+	if ( g_nNumRegisteredLogfiles >= MAX_REGISTERED_LOGFILES ) {
+		return FALSE;
+	}
+
+	// append to list
+	g_RegisteredLogfiles[ g_nNumRegisteredLogfiles ] = pLogfile;
+	g_nNumRegisteredLogfiles++;
+
+	return TRUE;
+}
+
+
+// flush all registerd logfiles -----------------------------------------------
+//
+void UTL_FlushRegisteredLogfiles()
+{
+	for( int nLogfile = 0; nLogfile < g_nNumRegisteredLogfiles; nLogfile++ ) {
+		g_RegisteredLogfiles[ nLogfile ]->Flush();
+	}
+}
+
+
+// add an entry to the logfile ------------------------------------------------
+//
+void UTL_LogFile::_AddEntry( const char* szEntry, size_t len2 )
+{
+	ASSERT( szEntry != NULL );
+
+	//FIXME: use SYSs_GetCurTimeString()
+
+	// prepend the current date/time
+	
+#ifdef SYSTEM_TARGET_WINDOWS
+
+	//FIXME: recheck whether SYSs_GetCurTimeString() works properly
+	//fprintf( fp, "%s: ", SYSs_GetCurTimeString() );
+
+	LARGE_INTEGER now;
+	LARGE_INTEGER TimeFreq;
+	QueryPerformanceCounter( &now );
+	QueryPerformanceFrequency( &TimeFreq );
+
+	timeval tv;
+	tv.tv_usec = (long) ( ( now.QuadPart % TimeFreq.QuadPart * 1000000 ) / TimeFreq.QuadPart );
+	tv.tv_sec  = (long) ( now.QuadPart / TimeFreq.QuadPart );
+
+#else
+
+	struct timeval  tv;
+	struct timezone tz;
+	gettimeofday( &tv, &tz );
+	
+#endif
+
+	char szTimeString[ 32 + 1 ];
+	snprintf( szTimeString, 32, "%u.%06u\t", (unsigned int)tv.tv_sec, (unsigned int)tv.tv_usec );
+	szTimeString[ 32 ] = 0;
+	
+	size_t len1 = strlen( szTimeString );
+
+	if ( ( m_nBufferLen + len1 + len2 ) >= MAX_LOG_BUFFER_LEN ) {
+		Flush();
+	}
+
+	// check whether to directly write to the file
+	if ( ( len1 + len2 ) >= MAX_LOG_BUFFER_LEN ) {
+		fwrite( szTimeString, 1, len1, m_pFile );
+		fwrite( szEntry,      1, len2, m_pFile );
+	} else {
+		// copy strings to buffer
+		memcpy( &m_szBuffer[ m_nBufferLen ],        szTimeString, len1 );
+		memcpy( &m_szBuffer[ m_nBufferLen + len1 ], szEntry,      len2 );
+		m_nBufferLen += ( len1 + len2 );
+		m_szBuffer[ m_nBufferLen ] = 0;
+
+#define REFFRAME_TO_FORCE_FLUSH		DEFAULT_REFFRAME_FREQUENCY
+
+#ifdef ENABLE_AUTO_FLUSH
+		// check for forced flush
+		if ( ( m_LastFlushRefframe + REFFRAME_TO_FORCE_FLUSH ) < SYSs_GetRefFrameCount() )  {
+			Flush();
+		}
+#endif // ENABLE_AUTO_FLUSH
+	}
+}
+
+// standard ctor --------------------------------------------------------------
+//
+UTL_LogFile::UTL_LogFile( const char* szFilename /* = NULL */) :
+	m_nBufferLen( 0 ),
+	m_pFile( NULL )
+{
+	m_szBuffer[ 0 ] = 0;
+
+	if ( szFilename != NULL ) {
+		if ( !Open( szFilename ) ) {
+			MSGOUT( "error opening logfile '%s'", szFilename );
+		}
+	}
+
+	m_LastFlushRefframe = SYSs_GetRefFrameCount();
+
+	// register the logfile
+	RegisterLogfile( this );
+}
+
+// standard dtor --------------------------------------------------------------
+//
+UTL_LogFile::~UTL_LogFile()
+{
+	if ( m_pFile != NULL ) {
+		Flush();
+		fclose( m_pFile );
+	}
+}
+
+// open the logfile -----------------------------------------------------------
+//
+int UTL_LogFile::Open( const char* szFilename )
+{
+	ASSERT( szFilename != NULL );
+	ASSERT( m_pFile == NULL );
+
+	m_pFile = fopen( szFilename, "a" );
+	return ( m_pFile != NULL );
+}
+
+// printf like adding to the logfile ------------------------------------------
+//
+int UTL_LogFile::printf( const char *format, ... )
+{
+	long formatlen = strlen( format );
+	if ( formatlen < 1 ) {
+		return -1;
+	}
+
+	char szTemp[ MAX_LOG_BUFFER_LEN + 1 ];
+
+	va_list	ap;
+	va_start( ap, format );
+	int rc = vsnprintf( szTemp, MAX_LOG_BUFFER_LEN, format, ap );
+	va_end( ap );
+
+	if ( rc > 0 ) {
+		strcat( szTemp, "\n" );
+		_AddEntry( szTemp, rc + 1 );
+	}
+
+	return rc;
+}
+
+// flush the buffer to the disk file ------------------------------------------
+//
+void UTL_LogFile::Flush()
+{
+	ASSERT( m_pFile != NULL );
+
+	fwrite( m_szBuffer, m_nBufferLen, 1, m_pFile );
+
+	m_szBuffer[ 0 ] = 0;
+	m_nBufferLen	= 0;
+
+	m_LastFlushRefframe = SYSs_GetRefFrameCount();
+
+	fflush( m_pFile );
+}