ckolivas/lrzip
1
0
Fork 0
mirror of https://github.com/ckolivas/lrzip.git synced 2025-12-06 07:12:00 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Detach threads from the compression side since we don't explicitly join them as they may count towards max thread count otherwise.

Browse source
This commit is contained in:
Con Kolivas 2011-04-23 08:15:44 +10:00
parent dcc3606507
commit 7ed977b1c1
1 changed files with 9 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
stream.c
View file

@ -135,13 +135,19 @@ static void cond_broadcast(pthread_cond_t *cond)
fatal("pthread_cond_broadcast failed"); fatal("pthread_cond_broadcast failed");
} }
void create_pthread(pthread_t * thread, pthread_attr_t * attr, void create_pthread(pthread_t *thread, pthread_attr_t * attr,
void * (*start_routine)(void *), void *arg) void * (*start_routine)(void *), void *arg)
{ {
if (pthread_create(thread, attr, start_routine, arg)) if (unlikely(pthread_create(thread, attr, start_routine, arg)))
fatal("pthread_create"); fatal("pthread_create");
} }
void detach_pthread(pthread_t *thread)
{
if (unlikely(pthread_detach(*thread)))
fatal("pthread_detach");
}
void join_pthread(pthread_t th, void **thread_return) void join_pthread(pthread_t th, void **thread_return)
{ {
if (pthread_join(th, thread_return)) if (pthread_join(th, thread_return))
@ -1435,6 +1441,7 @@ static void clear_buffer(rzip_control *control, struct stream_info *sinfo, int s
s->i = i; s->i = i;
s->control = control; s->control = control;
create_pthread(&threads[i], NULL, compthread, s); create_pthread(&threads[i], NULL, compthread, s);
detach_pthread(&threads[i]);
if (newbuf) { if (newbuf) {
/* The stream buffer has been given to the thread, allocate a /* The stream buffer has been given to the thread, allocate a