Synnefo

# interpreted as representing official policies, either expressed

# or implied, of GRNET S.A.

from fileblocker import FileBlocker

def intersect(a, b):

    """ return the intersection of two lists """

    return list(set(a) & set(b))

def union(a, b):

    """ return the union of two lists """

    return list(set(a) | set(b))

            if params['blockpool']:

                from radosblocker import RadosBlocker

                self.rblocker = RadosBlocker(**params)

            pass

        self.fblocker = FileBlocker(**params)

            (_, r_missing) = self.rblocker.block_stor(blocklist)

        return (hashes, union(r_missing, f_missing))

    def block_delta(self, blkhash, offset, data):

        """Construct and store a new block from a given block

           and a data 'patch' applied at offset. Return:

        r_existed = True

        (f_hash, f_existed) = self.fblocker.block_delta(blkhash, offset, data)

        if self.rblocker:

        if not r_hash and not f_hash:

            return None, None

        if self.rblocker and not r_hash: