From 584af68e190898da1bc1676baf743288ba46af19 Mon Sep 17 00:00:00 2001
From: Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com>
Date: Sat, 2 Oct 2010 14:38:37 +0000
Subject: 2010-10-02  Tatsuhiro Tsujikawa  <t-tujikawa@users.sourceforge.net>

	Execute 5 DHT tasks concurrently in each task queue.
	* src/DHTTaskExecutor.cc
	* src/DHTTaskExecutor.h
	* src/DHTTaskQueueImpl.cc
	* src/DHTTaskQueueImpl.h
	* src/Makefile.am
	* test/DHTTaskExecutorTest.cc
	* test/Makefile.am
	* test/MockDHTTask.h
---
 src/DHTTaskQueueImpl.h | 19 +++++++------------
 1 file changed, 7 insertions(+), 12 deletions(-)

(limited to 'src/DHTTaskQueueImpl.h')

diff --git a/src/DHTTaskQueueImpl.h b/src/DHTTaskQueueImpl.h
index 53edd078..d0ec0e95 100644
--- a/src/DHTTaskQueueImpl.h
+++ b/src/DHTTaskQueueImpl.h
@@ -36,26 +36,21 @@
 #define _D_DHT_TASK_QUEUE_IMPL_H_
 
 #include "DHTTaskQueue.h"
-#include <deque>
+#include "DHTTaskExecutor.h"
 
 namespace aria2 {
 
+class Logger;
+
 class DHTTaskQueueImpl:public DHTTaskQueue {
 private:
+  DHTTaskExecutor periodicTaskQueue1_;
 
-  SharedHandle<DHTTask> periodicTask1_;
-
-  SharedHandle<DHTTask> periodicTask2_;
-
-  SharedHandle<DHTTask> immediateTask_;
-
-  std::deque<SharedHandle<DHTTask> > periodicTaskQueue1_;
-
-  std::deque<SharedHandle<DHTTask> > periodicTaskQueue2_;
+  DHTTaskExecutor periodicTaskQueue2_;
 
-  std::deque<SharedHandle<DHTTask> > immediateTaskQueue_;
+  DHTTaskExecutor immediateTaskQueue_;
 
-  void executeTask(SharedHandle<DHTTask>& task, std::deque<SharedHandle<DHTTask> >& taskQueue);
+  Logger* logger_;
 public:
   DHTTaskQueueImpl();
 
-- 
cgit