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
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"
req = self.xseg.wait_requests(reqs)
self.evaluate_req(req)
reqs.remove(req)
+ self.assertTrue(req.put())
def test_close(self):
volume = "myvolume"
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
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):