diff options
Diffstat (limited to 'src/tools')
| -rw-r--r-- | src/tools/ocbr/ocbr_server.c | 11 | ||||
| -rw-r--r-- | src/tools/oping/oping_client.c | 2 | 
2 files changed, 8 insertions, 5 deletions
| diff --git a/src/tools/ocbr/ocbr_server.c b/src/tools/ocbr/ocbr_server.c index 7f347971..05659dc4 100644 --- a/src/tools/ocbr/ocbr_server.c +++ b/src/tools/ocbr/ocbr_server.c @@ -142,6 +142,11 @@ static void handle_flow(int fd)          flow_dealloc(fd);  } +static void __cleanup_mutex_unlock(void * mutex) +{ +        pthread_mutex_unlock((pthread_mutex_t *) mutex); +} +  static void * worker(void * o)  {          int cli_fd; @@ -150,8 +155,7 @@ static void * worker(void * o)          while (true) {                  pthread_mutex_lock(&fds_lock); -                pthread_cleanup_push((void(*)(void *)) pthread_mutex_unlock, -                                     (void *) &fds_lock); +                pthread_cleanup_push(__cleanup_mutex_unlock, &fds_lock);                  while (fds[fds_index] == -1)                          pthread_cond_wait(&fds_signal, &fds_lock); @@ -184,8 +188,7 @@ static void * listener(void * o)          while (true) {                  pthread_mutex_lock(&fds_lock); -                pthread_cleanup_push((void(*)(void *)) pthread_mutex_unlock, -                                     (void *) &fds_lock); +                pthread_cleanup_push(__cleanup_mutex_unlock, &fds_lock);                  while (fds_count == THREADS_SIZE) {                          printf("Can't accept any more flows, waiting.\n"); diff --git a/src/tools/oping/oping_client.c b/src/tools/oping/oping_client.c index a310338d..0ab5a4af 100644 --- a/src/tools/oping/oping_client.c +++ b/src/tools/oping/oping_client.c @@ -163,7 +163,7 @@ void * writer(void * o)                  printf("Pinging %s with %d bytes of data (%u packets):\n\n",                         client.s_apn, client.size, client.count); -        pthread_cleanup_push((void (*) (void *)) free, buf); +        pthread_cleanup_push(free, buf);          while (!stop && client.sent < client.count) {                  nanosleep(&wait, NULL); | 
