X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/b86bce0900f88c530f23dd602a8f2ef9ce008f8a..46fb2b4bbe3a0a8516ab04cfafa895a882c70f86:/rpc/thr_pool.cc

diff --git a/rpc/thr_pool.cc b/rpc/thr_pool.cc
index 73f94f4..8b9691b 100644
--- a/rpc/thr_pool.cc
+++ b/rpc/thr_pool.cc
@@ -1,14 +1,11 @@
 #include "thr_pool.h"
-#include <stdlib.h>
-#include <errno.h>
-#include "lang/verify.h"
 
 // if blocking, then addJob() blocks when queue is full
 // otherwise, addJob() simply returns false when queue is full
-ThrPool::ThrPool(int sz, bool blocking)
+ThrPool::ThrPool(size_t sz, bool blocking)
 : nthreads_(sz),blockadd_(blocking),jobq_(100*sz) 
 {
-	for (int i=0; i<nthreads_; i++)
+	for (size_t i=0; i<nthreads_; i++)
         th_.emplace_back(&ThrPool::do_worker, this);
 }
 
@@ -16,10 +13,10 @@ ThrPool::ThrPool(int sz, bool blocking)
 // will ever use this thread pool again or is currently blocking on it
 ThrPool::~ThrPool()
 {
-	for (int i=0; i<nthreads_; i++)
+	for (size_t i=0; i<nthreads_; i++)
 		jobq_.enq(job_t());
 
-	for (int i=0; i<nthreads_; i++)
+	for (size_t i=0; i<nthreads_; i++)
         th_[i].join();
 }