Aren/haiku
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Implemented the "Last message repeated x times." thing in the kernel (hash based).

Browse Source 
git-svn-id: file:///srv/svn/repos/haiku/haiku/trunk@16968 a95241bf-73f2-0310-859d-f6bbb57e9c96
This commit is contained in:
Michael Lotz 2006-04-02 16:23:47 +00:00
parent ac1f397e60
commit 3352a462a7
1 changed files with 94 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

102
src/system/kernel/debug/debug.c
View File

@ -61,6 +61,14 @@ static struct debugger_command *sCommands;
#define OUTPUT_BUFFER_SIZE 1024
static char sOutputBuffer[OUTPUT_BUFFER_SIZE];
static int64 hash_string(const char *string);
static void flush_pending_repeats(void);
static status_t check_pending_repeats(void *data);
static int64 sLastMessageHash = 0;
static int64 sMessageRepeatTime = 0;
static int32 sMessageRepeatCount = 0;
#define LINE_BUFFER_SIZE 1024
#define MAX_ARGS 16
#define HISTORY_SIZE 16
@ -575,6 +583,7 @@ void
debug_puts(const char *string)
{
cpu_status state;
int64 newHash;
// we only need the length for syslog
size_t length = 0;
@ -584,7 +593,15 @@ debug_puts(const char *string)
state = disable_interrupts();
acquire_spinlock(&sSpinlock);
kputs(string);
newHash = hash_string(string);
if (newHash == sLastMessageHash) {
sMessageRepeatCount++;
sMessageRepeatTime = system_time();
} else {
flush_pending_repeats();
kputs(string);
sLastMessageHash = newHash;
}
// kputs() doesn't output to syslog (as it's only used
// from the kernel debugger elsewhere)
@ -663,6 +680,11 @@ debug_init_post_vm(kernel_args *args)
status_t
debug_init_post_modules(struct kernel_args *args)
{
thread_id thread = spawn_kernel_thread(check_pending_repeats,
"check repeats", B_LOW_PRIORITY, NULL);
if (thread >= B_OK)
resume_thread(thread);
syslog_init_post_threads();
return frame_buffer_console_init_post_modules(args);
@ -804,14 +826,68 @@ set_dprintf_enabled(bool newState)
}
static int64
hash_string(const char *string)
{
char ch;
int64 result = 0;
while ((ch = *string++) != 0) {
result = (result << 7) ^ (result >> 24);
result ^= ch;
}
result ^= result << 12;
return result;
}
static void
flush_pending_repeats(void)
{
if (sMessageRepeatCount > 0) {
char temp[128];
int32 length = snprintf(temp, sizeof(temp),
"Last message repeated %ld times.\n", sMessageRepeatCount);
if (sSerialDebugEnabled)
arch_debug_serial_puts(temp);
if (sSyslogOutputEnabled)
syslog_write(temp, length);
if (sBlueScreenEnabled || sDebugScreenEnabled)
blue_screen_puts(temp);
sMessageRepeatCount = 0;
}
}
static status_t
check_pending_repeats(void *data)
{
cpu_status state;
while (true) {
if (sMessageRepeatCount > 0
&& (system_time() - sMessageRepeatTime) > 1000000)
flush_pending_repeats();
snooze(1000000);
}
return B_OK;
}
void
dprintf(const char *format, ...)
{
cpu_status state;
va_list args;
int64 newHash;
int32 length;
if (!sSerialDebugEnabled && !sSyslogOutputEnabled)
if (!sSerialDebugEnabled && !sSyslogOutputEnabled && !sBlueScreenEnabled)
return;
// ToDo: maybe add a non-interrupt buffer and path that only
@ -825,12 +901,22 @@ dprintf(const char *format, ...)
length = vsnprintf(sOutputBuffer, OUTPUT_BUFFER_SIZE, format, args);
va_end(args);
if (sSerialDebugEnabled)
arch_debug_serial_puts(sOutputBuffer);
if (sSyslogOutputEnabled)
syslog_write(sOutputBuffer, length);
if (sBlueScreenEnabled || sDebugScreenEnabled)
blue_screen_puts(sOutputBuffer);
newHash = hash_string(sOutputBuffer);
if (newHash == sLastMessageHash) {
sMessageRepeatCount++;
sMessageRepeatTime = system_time();
} else {
flush_pending_repeats();
if (sSerialDebugEnabled)
arch_debug_serial_puts(sOutputBuffer);
if (sSyslogOutputEnabled)
syslog_write(sOutputBuffer, length);
if (sBlueScreenEnabled || sDebugScreenEnabled)
blue_screen_puts(sOutputBuffer);
sLastMessageHash = newHash;
}
release_spinlock(&sSpinlock);
restore_interrupts(state);