Revision 03493855 kamaki/clients/test/__init__.py
| b/kamaki/clients/test/__init__.py | ||
|---|---|---|
| 35 | 35 |
from time import sleep |
| 36 | 36 |
|
| 37 | 37 |
from kamaki.clients.test.astakos import Astakos |
| 38 |
#from kamaki.clients.test.cyclades import Cyclades
|
|
| 38 |
from kamaki.clients.test.cyclades import Cyclades |
|
| 39 | 39 |
from kamaki.clients.test.image import Image |
| 40 | 40 |
#from kamaki.clients.test.pithos import Pithos |
| 41 | 41 |
|
| ... | ... | |
| 64 | 64 |
while self.can_finish < methodid and wait < 4: |
| 65 | 65 |
sleep(wait) |
| 66 | 66 |
wait = 2 * wait |
| 67 |
self._value = methodid |
|
| 67 | 68 |
self.assertTrue(wait < 4) |
| 68 | 69 |
|
| 69 | 70 |
def setUp(self): |
| 70 | 71 |
from kamaki.clients import SilentEvent |
| 71 | 72 |
self.SE = SilentEvent |
| 72 | 73 |
|
| 73 |
def test_parallel(self):
|
|
| 74 |
def test_threads(self):
|
|
| 74 | 75 |
threads = [] |
| 75 | 76 |
for i in range(4): |
| 76 | 77 |
threads.append(self.SE(self.thread_content, i)) |
Also available in: Unified diff