From 54224e9679035c2034819931dc185cedfe8071ef Mon Sep 17 00:00:00 2001
From: Jason Volk <jason@zemos.net>
Date: Thu, 28 Feb 2019 10:59:10 -0800
Subject: [PATCH] ircd::ctx: Add allocator to ctx::queue template.

---
 include/ircd/ctx/queue.h | 76 +++++++++++++++++++++++++++-------------
 1 file changed, 52 insertions(+), 24 deletions(-)

diff --git a/include/ircd/ctx/queue.h b/include/ircd/ctx/queue.h
index 7363fed4b..d5d6f0026 100644
--- a/include/ircd/ctx/queue.h
+++ b/include/ircd/ctx/queue.h
@@ -13,14 +13,17 @@
 
 namespace ircd::ctx
 {
-	template<class T> class queue;
+	template<class T,
+	         class A = std::allocator<T>>
+	class queue;
 }
 
-template<class T>
+template<class T,
+         class A>
 class ircd::ctx::queue
 {
 	dock d;
-	std::deque<T> q;
+	std::deque<T, A> q;
 	size_t w {0};
 
   public:
@@ -38,46 +41,66 @@ class ircd::ctx::queue
 	void push(const T &);
 	void push(T &&) noexcept;
 
-	queue() = default;
+	queue();
+	queue(A&& alloc);
 	~queue() noexcept;
 };
 
-template<class T>
-ircd::ctx::queue<T>::~queue()
+template<class T,
+         class A>
+ircd::ctx::queue<T, A>::queue()
+:q(std::allocator<T>())
+{
+}
+
+template<class T,
+         class A>
+ircd::ctx::queue<T, A>::queue(A&& alloc)
+:q(std::forward<A>(alloc))
+{
+}
+
+template<class T,
+         class A>
+ircd::ctx::queue<T, A>::~queue()
 noexcept
 {
 	assert(q.empty());
 }
 
-template<class T>
+template<class T,
+         class A>
 void
-ircd::ctx::queue<T>::push(T&& t)
+ircd::ctx::queue<T, A>::push(T&& t)
 noexcept
 {
 	q.push_back(std::forward<T>(t));
 	d.notify();
 }
 
-template<class T>
+template<class T,
+         class A>
 void
-ircd::ctx::queue<T>::push(const T &t)
+ircd::ctx::queue<T, A>::push(const T &t)
 {
 	q.push_back(t);
 	d.notify();
 }
 
-template<class T>
+template<class T,
+         class A>
 template<class... args>
 void
-ircd::ctx::queue<T>::emplace(args&&... a)
+ircd::ctx::queue<T, A>::emplace(args&&... a)
 {
 	q.emplace(std::forward<args>(a)...);
 	d.notify();
 }
 
-template<class T>
+template<class T,
+         class A>
 T
-ircd::ctx::queue<T>::pop()
+ircd::ctx::queue<T, A>::pop()
 {
 	++w;
 	const unwind uw{[this]
@@ -96,10 +119,11 @@ ircd::ctx::queue<T>::pop()
 	return ret;
 }
 
-template<class T>
+template<class T,
+         class A>
 template<class duration>
 T
-ircd::ctx::queue<T>::pop_for(const duration &dur)
+ircd::ctx::queue<T, A>::pop_for(const duration &dur)
 {
 	++w;
 	const unwind uw{[this]
@@ -124,10 +148,11 @@ ircd::ctx::queue<T>::pop_for(const duration &dur)
 	return ret;
 }
 
-template<class T>
+template<class T,
+         class A>
 template<class time_point>
 T
-ircd::ctx::queue<T>::pop_until(time_point&& tp)
+ircd::ctx::queue<T, A>::pop_until(time_point&& tp)
 {
 	++w;
 	const unwind uw{[this]
@@ -152,25 +177,28 @@ ircd::ctx::queue<T>::pop_until(time_point&& tp)
 	return ret;
 }
 
-template<class T>
+template<class T,
+         class A>
 size_t
-ircd::ctx::queue<T>::waiting()
+ircd::ctx::queue<T, A>::waiting()
 const
 {
 	return w;
 }
 
-template<class T>
+template<class T,
+         class A>
 size_t
-ircd::ctx::queue<T>::size()
+ircd::ctx::queue<T, A>::size()
 const
 {
 	return q.size();
 }
 
-template<class T>
+template<class T,
+         class A>
 size_t
-ircd::ctx::queue<T>::empty()
+ircd::ctx::queue<T, A>::empty()
 const
 {
 	return q.empty();