(self, namespace, data_dir=None, file_dir=None, lock_dir=None,
digest_filenames=True, **kwargs)
| 511 | |
| 512 | class FileNamespaceManager(OpenResourceNamespaceManager): |
| 513 | def __init__(self, namespace, data_dir=None, file_dir=None, lock_dir=None, |
| 514 | digest_filenames=True, **kwargs): |
| 515 | self.digest_filenames = digest_filenames |
| 516 | |
| 517 | if not file_dir and not data_dir: |
| 518 | raise MissingCacheParameter("data_dir or file_dir is required") |
| 519 | elif file_dir: |
| 520 | self.file_dir = file_dir |
| 521 | else: |
| 522 | self.file_dir = data_dir + "/container_file" |
| 523 | util.verify_directory(self.file_dir) |
| 524 | |
| 525 | if not lock_dir and not data_dir: |
| 526 | raise MissingCacheParameter("data_dir or lock_dir is required") |
| 527 | elif lock_dir: |
| 528 | self.lock_dir = lock_dir |
| 529 | else: |
| 530 | self.lock_dir = data_dir + "/container_file_lock" |
| 531 | util.verify_directory(self.lock_dir) |
| 532 | OpenResourceNamespaceManager.__init__(self, namespace) |
| 533 | |
| 534 | self.file = util.encoded_path(root=self.file_dir, |
| 535 | identifiers=[self.namespace], |
| 536 | extension='.cache', |
| 537 | digest_filenames=self.digest_filenames) |
| 538 | self.hash = {} |
| 539 | |
| 540 | debug("data file %s", self.file) |
| 541 | |
| 542 | def get_access_lock(self): |
| 543 | return file_synchronizer(identifier=self.namespace, |
nothing calls this directly
no test coverage detected