Synnefo

DEFAULT_BLOCK_PARAMS = { 'mappool': None, 'blockpool': None }

#DEFAULT_QUEUE_HOSTS = '[amqp://guest:guest@localhost:5672]'

#DEFAULT_QUEUE_EXCHANGE = 'pithos'

QUEUE_MESSAGE_KEY_PREFIX = 'pithos.%s'

QUEUE_CLIENT_ID = 'pithos'

                 quotaholder_enabled=False,

                 quotaholder_url=None, quotaholder_token=None,

                 quotaholder_client_poolsize=None,

        db_module = db_module or DEFAULT_DB_MODULE

        db_connection = db_connection or DEFAULT_DB_CONNECTION

        block_module = block_module or DEFAULT_BLOCK_MODULE

        #queue_hosts = queue_hosts or DEFAULT_QUEUE_HOSTS

        #queue_exchange = queue_exchange or DEFAULT_QUEUE_EXCHANGE

        self.hash_algorithm = 'sha256'

        self.block_size = 4 * 1024 * 1024  # 4MB

        self.free_versioning = free_versioning

                     account, container, prefix)

        public = {}

        for path, p in self.permissions.public_list('/'.join((account, container, prefix))):

        return public

    @backend_method

        self._can_read(user, account, container, name)

        path = self._lookup_object(account, container, name)[0]

        p = self.permissions.public_get(path)

        return p

    @backend_method

        if not public:

            self.permissions.public_unset(path)

        else:

    @backend_method

    def get_object_hashmap(self, user, account, container, name, version=None):

        """Return the (account, container, name) for the public id given."""

        logger.debug("get_public: %s %s", user, public)

        if path is None:

            raise NameError

        account, container, name = path.split('/', 2)