Revision 863d25a5 snf-pithos-backend/pithos/backends/lib/hashfiler/archipelagomapper.py
b/snf-pithos-backend/pithos/backends/lib/hashfiler/archipelagomapper.py | ||
---|---|---|
35 | 35 |
import os |
36 | 36 |
import re |
37 | 37 |
import ctypes |
38 |
import logging |
|
38 | 39 |
|
39 | 40 |
from context_archipelago import ArchipelagoObject |
40 | 41 |
from archipelago.common import ( |
... | ... | |
52 | 53 |
|
53 | 54 |
monkey.patch_Request() |
54 | 55 |
|
56 |
logger = logging.getLogger(__name__) |
|
55 | 57 |
|
56 | 58 |
class ArchipelagoMapper(object): |
57 | 59 |
"""Mapper. |
... | ... | |
153 | 155 |
req.put() |
154 | 156 |
self.ioctx_pool.pool_put(ioctx) |
155 | 157 |
raise Exception("Could not retrieve Archipelago mapfile.") |
158 |
req = Request.get_close_request(ioctx, self.mapperd_port, maphash); |
|
159 |
req.submit() |
|
160 |
req.wait() |
|
161 |
ret = req.success(); |
|
162 |
if ret is False: |
|
163 |
logger.warning("Could not close map %s" % maphash) |
|
164 |
pass |
|
165 |
req.put(); |
|
156 | 166 |
self.ioctx_pool.pool_put(ioctx) |
157 | 167 |
return hashes |
158 | 168 |
|
Also available in: Unified diff