edg-l/ddnet
1
0
Fork 0
mirror of https://github.com/ddnet/ddnet.git synced 2024-11-10 10:08:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Show nr of skipped log messages

Browse source
This commit is contained in:
Dennis Felsing 2017-04-21 10:50:16 +02:00
parent d84911618a
commit 63ca2f8749
1 changed files with 18 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
src/base/system.c
View file

@ -119,6 +119,7 @@ typedef struct
char q[QUEUE_SIZE][1024*4]; char q[QUEUE_SIZE][1024*4];
int begin; int begin;
int end; int end;
int skipped;
SEMAPHORE mutex; SEMAPHORE mutex;
SEMAPHORE notempty; SEMAPHORE notempty;
} Queue; } Queue;
@ -145,11 +146,19 @@ void dbg_msg_thread(void *v)
semaphore_wait(&log_queue.notempty); semaphore_wait(&log_queue.notempty);
semaphore_wait(&log_queue.mutex); semaphore_wait(&log_queue.mutex);
if(queue_empty(&log_queue))
{
str_format(str, sizeof(str), "Skipped %d log messages because of full queue.", log_queue.skipped);
log_queue.skipped = 0;
}
else
{
str_copy(str, log_queue.q[log_queue.begin], sizeof(str)); str_copy(str, log_queue.q[log_queue.begin], sizeof(str));
log_queue.begin = (log_queue.begin + 1) % QUEUE_SIZE; log_queue.begin = (log_queue.begin + 1) % QUEUE_SIZE;
}
if(!queue_empty(&log_queue)) if(!queue_empty(&log_queue) || log_queue.skipped > 0)
semaphore_signal(&log_queue.notempty); semaphore_signal(&log_queue.notempty);
semaphore_signal(&log_queue.mutex); semaphore_signal(&log_queue.mutex);
@ -167,6 +176,7 @@ void dbg_enable_threaded()
q = &log_queue; q = &log_queue;
q->begin = 0; q->begin = 0;
q->end = 0; q->end = 0;
q->skipped = 0;
semaphore_init(&q->mutex); semaphore_init(&q->mutex);
semaphore_init(&q->notempty); semaphore_init(&q->notempty);
semaphore_signal(&q->mutex); semaphore_signal(&q->mutex);
@ -199,7 +209,11 @@ void dbg_msg(const char *sys, const char *fmt, ...)
{ {
semaphore_wait(&log_queue.mutex); semaphore_wait(&log_queue.mutex);
if(!queue_full(&log_queue)) if(queue_full(&log_queue))
{
log_queue.skipped++;
}
else
{ {
int e = queue_empty(&log_queue); int e = queue_empty(&log_queue);