diff options
Diffstat (limited to 'ot_fullscrape.c')
| -rw-r--r-- | ot_fullscrape.c | 6 |
1 files changed, 5 insertions, 1 deletions
diff --git a/ot_fullscrape.c b/ot_fullscrape.c index 6f898c4..bcf238c 100644 --- a/ot_fullscrape.c +++ b/ot_fullscrape.c | |||
| @@ -52,11 +52,15 @@ static void * fullscrape_worker( void * args) { | |||
| 52 | return NULL; | 52 | return NULL; |
| 53 | } | 53 | } |
| 54 | 54 | ||
| 55 | static pthread_t thread_id; | ||
| 55 | void fullscrape_init( ) { | 56 | void fullscrape_init( ) { |
| 56 | pthread_t thread_id; | ||
| 57 | pthread_create( &thread_id, NULL, fullscrape_worker, NULL ); | 57 | pthread_create( &thread_id, NULL, fullscrape_worker, NULL ); |
| 58 | } | 58 | } |
| 59 | 59 | ||
| 60 | void fullscrape_deinit( ) { | ||
| 61 | pthread_cancel( thread_id ); | ||
| 62 | } | ||
| 63 | |||
| 60 | void fullscrape_deliver( int64 socket, ot_tasktype tasktype ) { | 64 | void fullscrape_deliver( int64 socket, ot_tasktype tasktype ) { |
| 61 | mutex_workqueue_pushtask( socket, tasktype ); | 65 | mutex_workqueue_pushtask( socket, tasktype ); |
| 62 | } | 66 | } |
