mirror of
https://github.com/aria2/aria2.git
synced 2025-01-09 03:21:33 +00:00
584af68e19
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
49 lines
1.3 KiB
C++
49 lines
1.3 KiB
C++
#include "DHTTaskExecutor.h"
|
|
|
|
#include <cppunit/extensions/HelperMacros.h>
|
|
|
|
#include "MockDHTTask.h"
|
|
#include "array_fun.h"
|
|
|
|
namespace aria2 {
|
|
|
|
class DHTTaskExecutorTest:public CppUnit::TestFixture {
|
|
|
|
CPPUNIT_TEST_SUITE(DHTTaskExecutorTest);
|
|
CPPUNIT_TEST(testUpdate);
|
|
CPPUNIT_TEST_SUITE_END();
|
|
public:
|
|
void testUpdate();
|
|
};
|
|
|
|
CPPUNIT_TEST_SUITE_REGISTRATION(DHTTaskExecutorTest);
|
|
|
|
void DHTTaskExecutorTest::testUpdate()
|
|
{
|
|
SharedHandle<DHTNode> rn;
|
|
DHTTaskExecutor tex(2);
|
|
SharedHandle<MockDHTTask> tasks[] = {
|
|
SharedHandle<MockDHTTask>(new MockDHTTask(rn)),
|
|
SharedHandle<MockDHTTask>(new MockDHTTask(rn)),
|
|
SharedHandle<MockDHTTask>(new MockDHTTask(rn)),
|
|
SharedHandle<MockDHTTask>(new MockDHTTask(rn))
|
|
};
|
|
tasks[1]->finished_ = true;
|
|
for(size_t i = 0; i < A2_ARRAY_LEN(tasks); ++i) {
|
|
tex.addTask(tasks[i]);
|
|
}
|
|
CPPUNIT_ASSERT_EQUAL((size_t)0, tex.getExecutingTaskSize());
|
|
CPPUNIT_ASSERT_EQUAL((size_t)4, tex.getQueueSize());
|
|
tex.update();
|
|
CPPUNIT_ASSERT_EQUAL((size_t)2, tex.getExecutingTaskSize());
|
|
CPPUNIT_ASSERT_EQUAL((size_t)1, tex.getQueueSize());
|
|
tasks[0]->finished_ = true;
|
|
tasks[2]->finished_ = true;
|
|
tasks[3]->finished_ = true;
|
|
tex.update();
|
|
CPPUNIT_ASSERT_EQUAL((size_t)0, tex.getExecutingTaskSize());
|
|
CPPUNIT_ASSERT_EQUAL((size_t)0, tex.getQueueSize());
|
|
}
|
|
|
|
} // namespace aria2
|