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.c14
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);