X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/dfe8486473094c0769fd1922329c3f0dfd8f43c0..c279db4240a3a3c30f069ab9dea8055cf94280da:/rpc/fifo.h

diff --git a/rpc/fifo.h b/rpc/fifo.h
index 93a79cf..9e4933a 100644
--- a/rpc/fifo.h
+++ b/rpc/fifo.h
@@ -1,53 +1,42 @@
 #ifndef fifo_h
 #define fifo_h
 
-#include <list>
-#include "lock.h"
+#include "types.h"
 
-// blocks enq() and deq() when queue is FULL or EMPTY
 template<class T>
 class fifo {
-	public:
-		fifo(int limit=0) : max_(limit) {};
-		bool enq(T, bool blocking=true);
-		void deq(T *);
-		bool size() {
+    public:
+        fifo(size_t limit=0) : max_(limit) {}
+
+        bool enq(T e, bool blocking=true) {
+            lock ml(m_);
+            while (max_ && q_.size() >= max_) {
+                if (!blocking)
+                    return false;
+                has_space_c_.wait(ml);
+            }
+            q_.push_back(e);
+            non_empty_c_.notify_one();
+            return true;
+        }
+
+        T deq() {
             lock ml(m_);
-            return q_.size();
-        };
+            while(q_.empty())
+                non_empty_c_.wait(ml);
+            T t = q_.front();
+            q_.pop_front();
+            if (max_ && q_.size() < max_)
+                has_space_c_.notify_one();
+            return t;
+        }
 
-	private:
-		std::list<T> q_;
-        mutex m_;
+    private:
+        std::list<T> q_;
+        std::mutex m_;
         cond non_empty_c_; // q went non-empty
-		cond has_space_c_; // q is not longer overfull
-		unsigned int max_; // maximum capacity of the queue, block enq threads if exceeds this limit
+        cond has_space_c_; // q is not longer overfull
+        size_t max_; // maximum capacity of the queue, block enq threads if exceeds this limit
 };
 
-template<class T> bool
-fifo<T>::enq(T e, bool blocking)
-{
-    lock ml(m_);
-	while (max_ && q_.size() >= max_) {
-		if (!blocking)
-			return false;
-        has_space_c_.wait(ml);
-	}
-    q_.push_back(e);
-    non_empty_c_.notify_one();
-	return true;
-}
-
-template<class T> void
-fifo<T>::deq(T *e)
-{
-	lock ml(m_);
-	while(q_.empty())
-        non_empty_c_.wait(ml);
-    *e = q_.front();
-    q_.pop_front();
-    if (max_ && q_.size() < max_)
-        has_space_c_.notify_one();
-}
-
 #endif