Revision 89e2b4d2 test/ganeti.workerpool_unittest.py
b/test/ganeti.workerpool_unittest.py | ||
---|---|---|
62 | 62 |
"""Workerpool tests""" |
63 | 63 |
|
64 | 64 |
def testDummy(self): |
65 |
wp = workerpool.WorkerPool(3, DummyBaseWorker) |
|
65 |
wp = workerpool.WorkerPool("Test", 3, DummyBaseWorker)
|
|
66 | 66 |
try: |
67 | 67 |
self._CheckWorkerCount(wp, 3) |
68 | 68 |
|
... | ... | |
75 | 75 |
self._CheckWorkerCount(wp, 0) |
76 | 76 |
|
77 | 77 |
def testNoTasks(self): |
78 |
wp = workerpool.WorkerPool(3, DummyBaseWorker) |
|
78 |
wp = workerpool.WorkerPool("Test", 3, DummyBaseWorker)
|
|
79 | 79 |
try: |
80 | 80 |
self._CheckWorkerCount(wp, 3) |
81 | 81 |
self._CheckNoTasks(wp) |
... | ... | |
84 | 84 |
self._CheckWorkerCount(wp, 0) |
85 | 85 |
|
86 | 86 |
def testNoTasksQuiesce(self): |
87 |
wp = workerpool.WorkerPool(3, DummyBaseWorker) |
|
87 |
wp = workerpool.WorkerPool("Test", 3, DummyBaseWorker)
|
|
88 | 88 |
try: |
89 | 89 |
self._CheckWorkerCount(wp, 3) |
90 | 90 |
self._CheckNoTasks(wp) |
... | ... | |
97 | 97 |
def testChecksum(self): |
98 | 98 |
# Tests whether all tasks are run and, since we're only using a single |
99 | 99 |
# thread, whether everything is started in order. |
100 |
wp = workerpool.WorkerPool(1, ChecksumBaseWorker) |
|
100 |
wp = workerpool.WorkerPool("Test", 1, ChecksumBaseWorker)
|
|
101 | 101 |
try: |
102 | 102 |
self._CheckWorkerCount(wp, 1) |
103 | 103 |
|
Also available in: Unified diff