Revision 3759eddb
| 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