64 |
64 |
|
65 |
65 |
def _init_data(self):
|
66 |
66 |
self.c1 = 'c1_' + unicode(self.now)
|
67 |
|
self.client.create_container(self.c1)
|
68 |
67 |
self.c2 = 'c2_' + unicode(self.now)
|
69 |
|
self.client.create_container(self.c2)
|
70 |
68 |
self.c3 = 'c3_' + unicode(self.now)
|
71 |
|
self.client.create_container(self.c3)
|
|
69 |
try:
|
|
70 |
self.client.create_container(self.c2)
|
|
71 |
except ClientError:
|
|
72 |
pass
|
|
73 |
try:
|
|
74 |
self.client.create_container(self.c1)
|
|
75 |
except ClientError:
|
|
76 |
pass
|
|
77 |
try:
|
|
78 |
self.client.create_container(self.c3)
|
|
79 |
except ClientError:
|
|
80 |
pass
|
72 |
81 |
|
73 |
82 |
self.create_remote_object(self.c1, 'test')
|
74 |
83 |
self.create_remote_object(self.c2, 'test')
|
... | ... | |
98 |
107 |
"""Destroy test cases"""
|
99 |
108 |
for fname in self.fnames:
|
100 |
109 |
try:
|
101 |
|
os.remove(self.fname)
|
|
110 |
os.remove(fname)
|
102 |
111 |
except OSError:
|
103 |
112 |
pass
|
104 |
113 |
self.forceDeleteContainer(self.c1)
|
... | ... | |
798 |
807 |
newf.close()
|
799 |
808 |
"""Check if file has been uploaded"""
|
800 |
809 |
r = self.client.get_object_info('sample.file')
|
801 |
|
self.assertEqual(int(r['content-length']), 10260)
|
|
810 |
self.assertEqual(int(r['content-length']), 10240)
|
802 |
811 |
|
803 |
812 |
"""Some problems with transfer-encoding?"""
|
804 |
813 |
|
... | ... | |
1165 |
1174 |
|
1166 |
1175 |
def create_large_file(self, size, name):
|
1167 |
1176 |
"""Create a large file at fs"""
|
|
1177 |
Ki = size / 10
|
|
1178 |
bytelist = [b * Ki for b in range(size / Ki)]
|
1168 |
1179 |
with open(name, 'w') as f:
|
1169 |
1180 |
def append2file(step):
|
1170 |
1181 |
f.seek(step)
|
1171 |
|
f.write(os.urandom(8))
|
|
1182 |
f.write(os.urandom(Ki))
|
1172 |
1183 |
self.do_with_progress_bar(
|
1173 |
1184 |
append2file,
|
1174 |
1185 |
' create rand file %s (%sB): ' % (name, size),
|
1175 |
|
[hobyte * 8 for hobyte in xrange(size / 8)])
|
|
1186 |
bytelist)
|