Revision f62290bb
| b/snf-pithos-backend/pithos/backends/lib/hashfiler/__init__.py | ||
|---|---|---|
| 34 | 34 |
from store import Store |
| 35 | 35 |
|
| 36 | 36 |
__all__ = ["Store"] |
| 37 |
|
|
| b/snf-pithos-backend/pithos/backends/lib/hashfiler/archipelagomapper.py | ||
|---|---|---|
| 123 | 123 |
req.put() |
| 124 | 124 |
self.ioctx_pool.pool_put(ioctx) |
| 125 | 125 |
for idx in xrange(0, len(data), namelen): |
| 126 |
hashes = hashes + (data[idx:idx+namelen],)
|
|
| 126 |
hashes = hashes + (data[idx:idx + namelen],)
|
|
| 127 | 127 |
hashes = list(hashes) |
| 128 | 128 |
else: |
| 129 | 129 |
req.put() |
| b/snf-pithos-backend/pithos/backends/lib/hashfiler/context_archipelago.py | ||
|---|---|---|
| 164 | 164 |
while 1: |
| 165 | 165 |
ioctx = self.ioctx_pool.pool_get() |
| 166 | 166 |
req = read(ioctx, self.dst_port, |
| 167 |
self.name, size=dsize-datalen, offset=self.offset)
|
|
| 167 |
self.name, size=dsize - datalen, offset=self.offset)
|
|
| 168 | 168 |
req.submit() |
| 169 | 169 |
req.wait() |
| 170 | 170 |
ret = req.success() |
| 171 | 171 |
if ret: |
| 172 |
s = string_at(req.get_data(), dsize-datalen)
|
|
| 172 |
s = string_at(req.get_data(), dsize - datalen)
|
|
| 173 | 173 |
else: |
| 174 | 174 |
s = None |
| 175 | 175 |
req.put() |
| b/snf-pithos-backend/pithos/workers/glue.py | ||
|---|---|---|
| 88 | 88 |
self.cnt) |
| 89 | 89 |
self.cnt += 1 |
| 90 | 90 |
return ioctx |
| 91 |
elif self.worker_id == None:
|
|
| 91 |
elif self.worker_id is None:
|
|
| 92 | 92 |
ioctx = Xseg_ctx(self.segment, 200) |
| 93 | 93 |
return ioctx |
| 94 | 94 |
|
Also available in: Unified diff