summaryrefslogtreecommitdiffstats
path: root/src/server/threadpool.c
diff options
context:
space:
mode:
authorSimon Rettberg2015-02-22 22:03:39 +0100
committerSimon Rettberg2015-02-22 22:03:39 +0100
commitea8f4961c6e4f94bf82e4c4cadbab4ec08824ae4 (patch)
tree4371eacef27e477523d6e05ef29c741540a77e32 /src/server/threadpool.c
parentGet rid of unneccessary volatile (diff)
downloaddnbd3-ea8f4961c6e4f94bf82e4c4cadbab4ec08824ae4.tar.gz
dnbd3-ea8f4961c6e4f94bf82e4c4cadbab4ec08824ae4.tar.xz
dnbd3-ea8f4961c6e4f94bf82e4c4cadbab4ec08824ae4.zip
[SERVER] Overhauled logging
- Added message type parameter - Log to file and stdout, no more logging in memory - Added options to server.conf to filter which messages show up where
Diffstat (limited to 'src/server/threadpool.c')
-rw-r--r--src/server/threadpool.c10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/server/threadpool.c b/src/server/threadpool.c
index 44649e4..ad146ea 100644
--- a/src/server/threadpool.c
+++ b/src/server/threadpool.c
@@ -57,17 +57,17 @@ bool threadpool_run(void *(*startRoutine)(void *), void *arg)
if ( entry == NULL ) {
entry = (entry_t*)malloc( sizeof(entry_t) );
if ( entry == NULL ) {
- printf( "[WARNING] Could not alloc entry_t for new thread\n" );
+ logadd( LOG_WARNING, "Could not alloc entry_t for new thread\n" );
return false;
}
entry->signalFd = signal_newBlocking();
if ( entry->signalFd < 0 ) {
- printf( "[WARNING] Could not create signalFd for new thread pool thread\n" );
+ logadd( LOG_WARNING, "Could not create signalFd for new thread pool thread\n" );
free( entry );
return false;
}
if ( 0 != thread_create( &(entry->thread), &threadAttrs, threadpool_worker, (void*)entry ) ) {
- printf( "[WARNING] Could not create new thread for thread pool\n" );
+ logadd( LOG_WARNING, "Could not create new thread for thread pool\n" );
signal_close( entry->signalFd );
free( entry );
return false;
@@ -93,7 +93,7 @@ static void *threadpool_worker(void *entryPtr)
if ( _shutdown ) break;
if ( ret > 0 ) {
if ( entry->startRoutine == NULL ) {
- printf( "[DEBUG] Worker woke up but has no work to do!\n" );
+ logadd( LOG_DEBUG1, "Worker woke up but has no work to do!\n" );
continue;
}
// Start assigned work
@@ -119,7 +119,7 @@ static void *threadpool_worker(void *entryPtr)
spin_unlock( &poolLock );
setThreadName( "[pool]" );
} else {
- printf( "[DEBUG] Unexpected return value %d for signal_wait in threadpool worker!\n", ret );
+ logadd( LOG_DEBUG1, "Unexpected return value %d for signal_wait in threadpool worker!\n", ret );
}
}
signal_close( entry->signalFd );