mirrors
/
opentracker
mirror of /home/gitosis/repositories/opentracker.git
1
0
Fork 0
Code Releases Activity

allow threads to be named. not posix compliant.

This commit is contained in:
Dirk Engling 2008-10-07 23:44:59 +00:00
parent 779df22409
commit ad7c574c0e
4 changed files with 28 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
ot_clean.c
View File

@ -8,6 +8,9 @@
#include <string.h>
#include <pthread.h>
#include <sys/uio.h>
#ifdef WANT_THREAD_NAME_NP
#include <pthread_np.h>
#endif
/* Libowfat */
#include "byte.h"
@ -126,10 +129,13 @@ void clean_all_torrents( ) {
static pthread_t thread_id;
void clean_init( void ) {
pthread_create( &thread_id, NULL, clean_worker, NULL );
#ifdef WANT_THREAD_NAME_NP
pthread_set_name_np( thread_id, "opentracker (cleanup)");
#endif
}
void clean_deinit( void ) {
pthread_cancel( thread_id );
}
const char *g_version_clean_c = "$Source: /home/cvsroot/opentracker/ot_clean.c,v $: $Revision: 1.7 $\n";
const char *g_version_clean_c = "$Source: /home/cvsroot/opentracker/ot_clean.c,v $: $Revision: 1.8 $\n";

8
ot_fullscrape.c
View File

@ -15,6 +15,9 @@
#ifdef WANT_COMPRESSION_GZIP
#include <zlib.h>
#endif
#ifdef WANT_THREAD_NAME_NP
#include <pthread_np.h>
#endif
/* Libowfat */
#include "byte.h"
@ -73,6 +76,9 @@ static void * fullscrape_worker( void * args ) {
static pthread_t thread_id;
void fullscrape_init( ) {
pthread_create( &thread_id, NULL, fullscrape_worker, NULL );
#ifdef WANT_THREAD_NAME_NP
pthread_set_name_np( thread_id, "opentracker (fullscrape)");
#endif
}
void fullscrape_deinit( ) {
@ -230,4 +236,4 @@ static void fullscrape_make( int *iovec_entries, struct iovec **iovector, ot_tas
}
#endif
const char *g_version_fullscrape_c = "$Source: /home/cvsroot/opentracker/ot_fullscrape.c,v $: $Revision: 1.20 $\n";
const char *g_version_fullscrape_c = "$Source: /home/cvsroot/opentracker/ot_fullscrape.c,v $: $Revision: 1.21 $\n";

8
ot_livesync.c
View File

@ -8,6 +8,9 @@
#include <sys/uio.h>
#include <string.h>
#include <pthread.h>
#ifdef WANT_THREAD_NAME_NP
#include <pthread_np.h>
#endif
/* Libowfat */
#include "socket.h"
@ -53,6 +56,9 @@ void livesync_init( ) {
livesync_lastpacket_time = g_now;
pthread_create( &thread_id, NULL, livesync_worker, NULL );
#ifdef WANT_THREAD_NAME_NP
pthread_set_name_np( thread_id, "opentracker (livesync)");
#endif
}
void livesync_deinit() {
@ -159,4 +165,4 @@ static void * livesync_worker( void * args ) {
}
#endif
const char *g_version_livesync_c = "$Source: /home/cvsroot/opentracker/ot_livesync.c,v $: $Revision: 1.2 $\n";
const char *g_version_livesync_c = "$Source: /home/cvsroot/opentracker/ot_livesync.c,v $: $Revision: 1.3 $\n";

8
ot_sync.c
View File

@ -10,6 +10,9 @@
#include <stdio.h>
#include <string.h>
#include <pthread.h>
#ifdef WANT_THREAD_NAME_NP
#include <pthread_np.h>
#endif
/* Libowfat */
#include "scan.h"
@ -151,6 +154,9 @@ static void * sync_worker( void * args) {
static pthread_t thread_id;
void sync_init( ) {
pthread_create( &thread_id, NULL, sync_worker, NULL );
#ifdef WANT_THREAD_NAME_NP
pthread_set_name_np( thread_id, "opentracker (batchsync)");
#endif
}
void sync_deinit( ) {
@ -163,4 +169,4 @@ void sync_deliver( int64 socket ) {
#endif
const char *g_version_sync_c = "$Source: /home/cvsroot/opentracker/ot_sync.c,v $: $Revision: 1.6 $\n";
const char *g_version_sync_c = "$Source: /home/cvsroot/opentracker/ot_sync.c,v $: $Revision: 1.7 $\n";