summaryrefslogtreecommitdiffstats
path: root/xlators/performance/io-threads/src/io-threads.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/performance/io-threads/src/io-threads.c')
-rw-r--r--xlators/performance/io-threads/src/io-threads.c36
1 files changed, 20 insertions, 16 deletions
diff --git a/xlators/performance/io-threads/src/io-threads.c b/xlators/performance/io-threads/src/io-threads.c
index b3054ae6b86..f430117be9f 100644
--- a/xlators/performance/io-threads/src/io-threads.c
+++ b/xlators/performance/io-threads/src/io-threads.c
@@ -1027,17 +1027,19 @@ iot_queue (iot_worker_t *worker,
queue->stub = stub;
pthread_mutex_lock (&worker->qlock);
- queue->next = &worker->queue;
- queue->prev = worker->queue.prev;
+ {
+ queue->next = &worker->queue;
+ queue->prev = worker->queue.prev;
- queue->next->prev = queue;
- queue->prev->next = queue;
+ queue->next->prev = queue;
+ queue->prev->next = queue;
- /* dq_cond */
- worker->queue_size++;
- worker->q++;
+ /* dq_cond */
+ worker->queue_size++;
+ worker->q++;
- pthread_cond_broadcast (&worker->dq_cond);
+ pthread_cond_broadcast (&worker->dq_cond);
+ }
pthread_mutex_unlock (&worker->qlock);
}
@@ -1048,17 +1050,19 @@ iot_dequeue (iot_worker_t *worker)
iot_queue_t *queue = NULL;
pthread_mutex_lock (&worker->qlock);
- while (!worker->queue_size)
- pthread_cond_wait (&worker->dq_cond, &worker->qlock);
+ {
+ while (!worker->queue_size)
+ pthread_cond_wait (&worker->dq_cond, &worker->qlock);
- queue = worker->queue.next;
- queue->next->prev = queue->prev;
- queue->prev->next = queue->next;
+ queue = worker->queue.next;
+ queue->next->prev = queue->prev;
+ queue->prev->next = queue->next;
- stub = queue->stub;
+ stub = queue->stub;
- worker->queue_size--;
- worker->dq++;
+ worker->queue_size--;
+ worker->dq++;
+ }
pthread_mutex_unlock (&worker->qlock);
FREE (queue);