Revision 278c9018
b/kamaki/cli/commands/pithos_cli.py | ||
---|---|---|
1075 | 1075 |
if progress_bar: |
1076 | 1076 |
hash_bar = progress_bar.clone() |
1077 | 1077 |
hash_cb = hash_bar.get_generator( |
1078 |
'Calculating block hashes' |
|
1079 |
) |
|
1078 |
'Calculating block hashes') |
|
1080 | 1079 |
else: |
1081 | 1080 |
hash_cb = None |
1082 | 1081 |
self.client.upload_object( |
b/kamaki/clients/connection/test.py | ||
---|---|---|
48 | 48 |
from kamaki.clients.connection import KamakiConnection as HTTPC |
49 | 49 |
self.conn = HTTPC() |
50 | 50 |
|
51 |
def test_poolsize(self): |
|
52 |
|
|
53 |
def set_poolsize(poolsize): |
|
54 |
self.conn.poolsize = poolsize |
|
55 |
|
|
56 |
from kamaki.clients.connection import KamakiConnection as HTTPC |
|
57 |
for poolsize in ('non integer', -10, 0): |
|
58 |
err = AssertionError |
|
59 |
self.assertRaises(err, set_poolsize, poolsize) |
|
60 |
for poolsize in (1, 100, 1024 * 1024 * 1024 * 1024): |
|
61 |
self.conn.poolsize = poolsize |
|
62 |
self.assertEquals(self.conn.poolsize, poolsize) |
|
63 |
self.assertEquals(HTTPC(poolsize=poolsize).poolsize, poolsize) |
|
64 |
|
|
51 | 65 |
def test_set_header(self): |
52 | 66 |
cnn = self.conn |
53 | 67 |
for k, v in self.v_samples.items(): |
Also available in: Unified diff