Synnefo » Pithos

DEFAULT_DB_CONNECTION = 'sqlite:///backend.db'

DEFAULT_BLOCK_MODULE = 'pithos.backends.lib.hashfiler'

DEFAULT_BLOCK_PATH = 'data/'

( CLUSTER_NORMAL, CLUSTER_HISTORY, CLUSTER_DELETED ) = range(3)

        if queue_module and queue_connection:

            self.queue_module = load_module(queue_module)

            self.queue = self.queue_module.Queue(**params)

        else:

            class NoQueue:

            for h in hashes:

                self.store.map_delete(h)

            self.node.node_purge_children(node, until, CLUSTER_DELETED)

            return

        if self._get_statistics(node)[0] > 0:

            self.store.map_delete(h)

        self.node.node_purge_children(node, inf, CLUSTER_DELETED)

        self.node.node_remove(node)

    @backend_method

    def list_objects(self, user, account, container, prefix='', delimiter=None, marker=None, limit=10000, virtual=True, domain=None, keys=[], shared=False, until=None, size_range=None):

        pre_version_id, dest_version_id = self._update_object_hash(user, account, container, name, size, binascii.hexlify(hash), permissions)

        self._put_metadata_duplicate(pre_version_id, dest_version_id, domain, meta, replace_meta)

        self.store.map_put(hash, map)

        return dest_version_id

    def _copy_object(self, user, src_account, src_container, src_name, dest_account, dest_container, dest_name, dest_domain=None, dest_meta={}, replace_meta=False, permissions=None, src_version=None, is_move=False):

        logger.debug("copy_object: %s %s %s %s %s %s %s %s %s %s %s", src_account, src_container, src_name, dest_account, dest_container, dest_name, domain, meta, replace_meta, permissions, src_version)

        dest_version_id = self._copy_object(user, src_account, src_container, src_name, dest_account, dest_container, dest_name, domain, meta, replace_meta, permissions, src_version, False)

        return dest_version_id

    @backend_method

        dest_version_id = self._copy_object(user, src_account, src_container, src_name, dest_account, dest_container, dest_name, domain, meta, replace_meta, permissions, None, True)

        if (src_account, src_container, src_name) != (dest_account, dest_container, dest_name):

            self._delete_object(user, src_account, src_container, src_name)

        return dest_version_id

    def _delete_object(self, user, account, container, name, until=None):

                props = self._get_version(node)

            except NameError:

                self.permissions.access_clear(path)

            return

        path, node = self._lookup_object(account, container, name)

        if versioning != 'auto':

            hash = self.node.version_remove(version_id)

            self.store.map_delete(hash)

    # Access control functions.