X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/5a5c578e2e358a121cdb9234a6cb11c4ecfbf323..be7cf844f59fa483423724e8e4b5e663e5b88ddd:/rpc/thr_pool.cc

diff --git a/rpc/thr_pool.cc b/rpc/thr_pool.cc
index 8b9691b..7d3cf7d 100644
--- a/rpc/thr_pool.cc
+++ b/rpc/thr_pool.cc
@@ -3,16 +3,14 @@
 // if blocking, then addJob() blocks when queue is full
 // otherwise, addJob() simply returns false when queue is full
 ThrPool::ThrPool(size_t sz, bool blocking)
-: nthreads_(sz),blockadd_(blocking),jobq_(100*sz) 
-{
+: nthreads_(sz),blockadd_(blocking),jobq_(100*sz) {
 	for (size_t i=0; i<nthreads_; i++)
         th_.emplace_back(&ThrPool::do_worker, this);
 }
 
 // IMPORTANT: this function can be called only when no external thread 
 // will ever use this thread pool again or is currently blocking on it
-ThrPool::~ThrPool()
-{
+ThrPool::~ThrPool() {
 	for (size_t i=0; i<nthreads_; i++)
 		jobq_.enq(job_t());
 
@@ -20,15 +18,11 @@ ThrPool::~ThrPool()
         th_[i].join();
 }
 
-bool 
-ThrPool::addJob(const job_t &j)
-{
+bool ThrPool::addJob(const job_t &j) {
 	return jobq_.enq(j,blockadd_);
 }
 
-void
-ThrPool::do_worker()
-{
+void ThrPool::do_worker() {
     job_t j;
 	while (1) {
         jobq_.deq(&j);