projects
/
archipelago
/ commitdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
| commitdiff |
tree
raw
|
patch
|
inline
| side by side (parent:
01e239f
)
tests: Put requests on multi-request tests
author
Filippos Giannakos
<philipgian@grnet.gr>
Fri, 13 Sep 2013 10:47:38 +0000
(13:47 +0300)
committer
Filippos Giannakos
<philipgian@grnet.gr>
Wed, 4 Dec 2013 14:51:48 +0000
(16:51 +0200)
xseg/tools/qa/tests.py
patch
|
blob
|
history
diff --git
a/xseg/tools/qa/tests.py
b/xseg/tools/qa/tests.py
index
eb07ea1
..
21e9623
100644
(file)
--- a/
xseg/tools/qa/tests.py
+++ b/
xseg/tools/qa/tests.py
@@
-628,6
+628,7
@@
class VlmcdTest(XsegTest):
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=xinfo)
reqs.remove(req)
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=xinfo)
reqs.remove(req)
+ self.assertTrue(req.put())
def test_hash(self):
blocksize = self.blocksize
def test_hash(self):
blocksize = self.blocksize
@@
-852,6
+853,7
@@
class MapperdTest(XsegTest):
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=xinfo)
reqs.remove(req)
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=xinfo)
reqs.remove(req)
+ self.assertTrue(req.put())
def test_open(self):
volume = "myvolume"
def test_open(self):
volume = "myvolume"
@@
-874,6
+876,7
@@
class MapperdTest(XsegTest):
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req)
reqs.remove(req)
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req)
reqs.remove(req)
+ self.assertTrue(req.put())
def test_close(self):
volume = "myvolume"
def test_close(self):
volume = "myvolume"
@@
-923,6
+926,7
@@
class MapperdTest(XsegTest):
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=ret)
reqs.remove(req)
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=ret)
reqs.remove(req)
+ self.assertTrue(req.put())
def test_mapw(self):
blocksize = self.blocksize
def test_mapw(self):
blocksize = self.blocksize
@@
-986,6
+990,7
@@
class MapperdTest(XsegTest):
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=ret)
reqs.remove(req)
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req, data=ret)
reqs.remove(req)
+ self.assertTrue(req.put())
class BlockerTest(object):
def test_write_read(self):
class BlockerTest(object):
def test_write_read(self):