diff options
Diffstat (limited to 'xlators/performance/io-threads/src/io-threads.c')
| -rw-r--r-- | xlators/performance/io-threads/src/io-threads.c | 14 |
1 files changed, 0 insertions, 14 deletions
diff --git a/xlators/performance/io-threads/src/io-threads.c b/xlators/performance/io-threads/src/io-threads.c index 27140a39821..346e1234bb9 100644 --- a/xlators/performance/io-threads/src/io-threads.c +++ b/xlators/performance/io-threads/src/io-threads.c @@ -1022,8 +1022,6 @@ iot_queue (iot_worker_t *worker, { iot_queue_t *queue; iot_conf_t *conf = worker->conf; - iot_local_t *local = stub->frame->local; - size_t frame_size = local->frame_size; queue = CALLOC (1, sizeof (*queue)); ERR_ABORT (queue); @@ -1031,11 +1029,6 @@ iot_queue (iot_worker_t *worker, pthread_mutex_lock (&conf->lock); - if (conf->cache_size) { - while (frame_size && (conf->current_size >= conf->cache_size)) - pthread_cond_wait (&conf->q_cond, &conf->lock); - } - queue->next = &worker->queue; queue->prev = worker->queue.prev; @@ -1046,8 +1039,6 @@ iot_queue (iot_worker_t *worker, worker->queue_size++; worker->q++; - conf->current_size += local->frame_size; - pthread_cond_broadcast (&worker->dq_cond); pthread_mutex_unlock (&conf->lock); @@ -1059,7 +1050,6 @@ iot_dequeue (iot_worker_t *worker) call_stub_t *stub = NULL; iot_queue_t *queue = NULL; iot_conf_t *conf = worker->conf; - iot_local_t *local = NULL; pthread_mutex_lock (&conf->lock); @@ -1073,14 +1063,10 @@ iot_dequeue (iot_worker_t *worker) queue->prev->next = queue->next; stub = queue->stub; - local = stub->frame->local; worker->queue_size--; worker->dq++; - /* q_cond */ - conf->current_size -= local->frame_size; - pthread_cond_broadcast (&conf->q_cond); pthread_mutex_unlock (&conf->lock); |