libwww/Library/src/HTMemLog.c - view - 2.21

NEW TRACE MESSAGES - see http://lists.w3.org/Archives/Public/www-lib/1999JanMar/0267.html for details

/*								 HTMemLog.c
**	MEMORY BUFFERED DATA LOGGING UTILITIES
**
**	(c) COPYRIGHT MIT 1996.
**	Please first read the full copyright statement in the file COPYRIGH.
**	@(#) $Id: HTMemLog.c,v 2.21 1999年02月22日 22:10:11 frystyk Exp $
**
** 26 Nov 96 (EGP)	started
*/
/* Library include files */
#include "wwwsys.h"
#include "HTUtils.h"
#include "HTInet.h"
#include "HTMemLog.h"
#include "HTTimer.h"
#ifdef O_SYNC
#define OPEN_FLAGS	O_WRONLY|O_CREAT|O_TRUNC|O_SYNC
#else
#define OPEN_FLAGS	O_WRONLY|O_CREAT|O_TRUNC
#endif
#ifdef HTDEBUG
#ifdef USE_SYSLOG
#define PRINT_BUFF_SIZE	8200
#else /* USE_SYSLOG */
#define PRINT_BUFF_SIZE	200
#endif /* !USE_SYSLOG */
PRIVATE size_t		LogBuffSize = 1024; /* default size is 1k */
PRIVATE int		LogFd = 2;
PRIVATE const char *	LogName = NULL;
PRIVATE char *		LogBuff = NULL;
PRIVATE size_t		LogLen = 0;
PRIVATE BOOL		KeepOpen = YES;
PRIVATE HTTimer *	Timer = NULL;
#ifdef USE_EXCLUDES
typedef struct {char * str; int len;} StrIndexIndex;
PRIVATE StrIndexIndex Excludes[] = {{"HTReader_read", 13}, {"HTWriter_write", 14}, {"HTEventList_loop", 16}};
PRIVATE int StrIndex (char * str, StrIndexIndex element[], int elements)
{
 int i;
 for (i = 0; i < elements; i++)
	if (!strncmp(element[i].str, str, element[i].len))
	 return i + 1;
 return 0;
}
#endif /* USE_EXCLUDES */
PRIVATE int MemLogTimeout (HTTimer * timer, void * param, HTEventType type)
{
 int ret;
 HTTRACE(CORE_TRACE, "MemLog...... flushing on timeout\n");
 ret = HTMemLog_flush();
 return ret;
}
PRIVATE ms_t HTMemLog_addTime(void)
{
 char buff[20];
 ms_t ms = HTGetTimeInMillis();
 int len = sprintf(buff, "%lu", ms);
 HTMemLog_add(buff, len);
 return ms;
}
#endif /* HTDEBUG */
/* ------------------------------------------------------------------------- */
PUBLIC int HTMemLog_open (char * logName, size_t size, BOOL keepOpen)
{
#ifdef HTDEBUG
#ifdef USE_SYSLOG
 openlog(LogName, LOG_NDELAY, LOG_USER);
#else /* USE_SYSLOG */
 LogName = logName;
 KeepOpen = keepOpen;
 if ((LogFd = open(LogName, OPEN_FLAGS, 0666)) == -1)
	return HT_ERROR;
 if (!KeepOpen)
	close(LogFd);
 LogBuffSize = size;
 if ((LogBuff = (char *) HT_MALLOC(size)) == NULL)
	HT_OUTOFMEM("HTMemLog_open");
 LogLen = 0;
#endif /* !USE_SYSLOG */
 HTTraceData_setCallback(HTMemLog_callback);
 Timer = HTTimer_new(NULL, MemLogTimeout, NULL, 10000, YES, YES);
#endif /* HTDEBUG */
 return HT_OK;
}
PUBLIC int HTMemLog_flush(void)
{
#ifdef HTDEBUG
 if (LogLen) {
	if (!KeepOpen)
	 if ((LogFd = open(LogName, O_WRONLY|O_CREAT|O_APPEND, 0666)) == -1)
		return HT_ERROR;
	write(LogFd, LogBuff, LogLen);
	LogLen = 0;
 }
 if (!KeepOpen) close(LogFd);
#endif /* HTDEBUG */
 return HT_OK;
}
PUBLIC int HTMemLog_add(char * buf, size_t len)
{
#ifdef HTDEBUG
 if (LogBuff) {
	/*
	**	Dump everything that won't fit in buffer
	*/
	while (len + LogLen > LogBuffSize) {
	 size_t toWrite = LogBuffSize-LogLen;
	 memcpy(LogBuff+LogLen, buf, toWrite);
	 LogLen = LogBuffSize;	/* same as += toWrite */
	 HTMemLog_flush();
	 buf += toWrite;
	 len -= toWrite;
	}
	memcpy(LogBuff+LogLen, buf, len);
	LogLen += len;
	return HT_OK;
 }
 return HT_ERROR;
#else
 return HT_OK;
#endif /* HTDEBUG */
}
PUBLIC void HTMemLog_close (void)
{
#ifdef HTDEBUG
#ifdef USE_SYSLOG
 closelog();
#else /* USE_SYSLOG */
 HTMemLog_flush();
 if (LogFd > 2) close(LogFd);
 if (LogBuff != NULL) HT_FREE(LogBuff);
#endif /* !USE_SYSLOG */
#endif
}
PUBLIC int HTMemLog_callback (char * data, size_t len, char * fmt, va_list pArgs)
{
#ifdef HTDEBUG
 char buff[PRINT_BUFF_SIZE];
 int ret;
#ifdef USE_EXCLUDES
 if (StrIndex(fmt, Excludes, sizeof(Excludes)/sizeof(Excludes[0])))
	return 0;
#endif /* USE_EXCLUDES */
#ifdef USE_SYSLOG
 ret = vsprintf(buff, fmt, pArgs);
 syslog(LOG_DEBUG, "%s\n", buff);
 if (len > 8192)
	len = 8192;
 strncpy(buff, data, len);
 buff[len] = 0;
 syslog(LOG_DEBUG, "%s\n", buff);
#else /* USE_SYSLOG */
 HTMemLog_addTime();
#ifdef HAVE_LONG_SIZE_T
 ret = sprintf(buff, " %ld ", len);
#else
 ret = sprintf(buff, " %d ", len);
#endif
 HTMemLog_add(buff, ret);
 if (fmt) {
 ret = vsprintf(buff, fmt, pArgs);
 HTMemLog_add(buff, ret);
 }
 HTMemLog_add("\n", 1);
 HTMemLog_add(data, len);
 HTMemLog_add("\n", 1);
#endif /* !USE_SYSLOG */
 return ret;
#else
 return 0;
#endif /* HTDEBUG */
}