2 files changed, 0 insertions, 40 deletions

diff --git a/xlators/performance/io-threads/src/io-threads.c b/xlators/performance/io-threads/src/io-threads.c
index 5acdd627da4..27140a39821 100644
--- a/xlators/performance/io-threads/src/io-threads.c
+++ b/xlators/performance/io-threads/src/io-threads.c
@@ -1031,10 +1031,6 @@ iot_queue (iot_worker_t *worker,
 
 	pthread_mutex_lock (&conf->lock);
 
-	/*
-	  while (worker->queue_size >= worker->queue_limit)
-	  pthread_cond_wait (&worker->q_cond, &worker->lock);
-	*/
 	if (conf->cache_size) {
 		while (frame_size && (conf->current_size >= conf->cache_size))
 			pthread_cond_wait (&conf->q_cond, &conf->lock);
@@ -1069,9 +1065,6 @@ iot_dequeue (iot_worker_t *worker)
 	pthread_mutex_lock (&conf->lock);
 
 	while (!worker->queue_size)
-		/*
-		  pthread_cond_wait (&worker->dq_cond, &worker->lock);
-		*/
 		pthread_cond_wait (&worker->dq_cond, &conf->lock);
 
 	queue = worker->queue.next;
@@ -1110,23 +1103,6 @@ iot_worker (void *arg)
 	}
 }
 
-#if 0
-static void *
-iot_reply (void *arg)
-{
-	iot_worker_t *reply = arg;
-
-	while (1) {
-		call_stub_t *stub;
-
-		stub = iot_dequeue (reply);
-		FREE (stub->frame->local);
-		stub->frame->local = NULL;
-		call_resume (stub);
-	}
-}
-#endif
-
 static void
 workers_init (iot_conf_t *conf)
 {
@@ -1148,16 +1124,7 @@ workers_init (iot_conf_t *conf)
 		worker->queue.next = &worker->queue;
 		worker->queue.prev = &worker->queue;
 
-		/*
-		  pthread_mutex_init (&worker->lock, NULL);
-		  pthread_cond_init (&worker->q_cond, NULL);
-		*/
 		pthread_cond_init (&worker->dq_cond, NULL);
-
-		/*
-		  worker->queue_limit = conf->queue_limit;
-		*/
-
 		worker->conf = conf;
 
 		pthread_create (&worker->thread, NULL, iot_worker, worker);
diff --git a/xlators/performance/io-threads/src/io-threads.h b/xlators/performance/io-threads/src/io-threads.h
index 6595d3e277b..db578115750 100644
--- a/xlators/performance/io-threads/src/io-threads.h
+++ b/xlators/performance/io-threads/src/io-threads.h
@@ -58,15 +58,8 @@ struct iot_worker {
   struct iot_conf *conf;
   int64_t q,dq;
   pthread_cond_t dq_cond;
-  /*
-    pthread_cond_t q_cond;
-    pthread_mutex_t lock;
-  */
   int32_t fd_count;
   int32_t queue_size;
-  /*
-    int32_t queue_limit;
-  */
   pthread_t thread;
 };