diff options
| author | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-10-02 14:38:37 +0000 |
|---|---|---|
| committer | Tatsuhiro Tsujikawa <tatsuhiro.t@gmail.com> | 2010-10-02 14:38:37 +0000 |
| commit | 584af68e190898da1bc1676baf743288ba46af19 (patch) | |
| tree | e9391d53bb3a43568de4bd4161c4686989108c57 /src/DHTTaskQueueImpl.h | |
| parent | 7375a778c4ad3acda07b138d8530974df490be29 (diff) | |
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
Diffstat (limited to 'src/DHTTaskQueueImpl.h')
| -rw-r--r-- | src/DHTTaskQueueImpl.h | 19 |
1 files changed, 7 insertions, 12 deletions
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(); |