X-Git-Url: http://git.vrable.net/?a=blobdiff_plain;f=cleaner%2Fcleaner;fp=cleaner%2Fcleaner;h=60c91f501d229e93510b37e3629e8471b9a3ba02;hb=5551523de35c1abaf24d77654928e2c748fd95aa;hp=93feef4c92bba5783bdd05399139011b535a6376;hpb=bf49df0b71a2ef875c7e7fd32d68766be85b1657;p=bluesky.git diff --git a/cleaner/cleaner b/cleaner/cleaner index 93feef4..60c91f5 100755 --- a/cleaner/cleaner +++ b/cleaner/cleaner @@ -96,6 +96,9 @@ class S3Backend(Backend): self.path = path self.cachedir = cachedir self.cache = {} + for f in os.listdir(cachedir): + self.cache[f] = True + print "Initial cache contents:", list(self.cache.keys()) self.connect() self.stats_get = [0, 0] self.stats_put = [0, 0] @@ -466,7 +469,7 @@ class InodeMap: print "%s: %s %s" % (s, u, float(u[1]) / u[0]) if u[1] == 0: print "Would delete..." - #backend.delete(s) + backend.delete(s) deletions[0] += 1 deletions[1] += u[0] @@ -586,7 +589,7 @@ def run_cleaner(backend, inode_map, log, repack_inodes=False): if __name__ == '__main__': start_time = time.time() - backend = S3Backend("mvrable-bluesky-west", cachedir="/export/cache") + backend = S3Backend("mvrable-bluesky-west", cachedir="/tmp/bluesky-cache") #backend = FileBackend(".") chkpt = load_checkpoint_record(backend) print backend.list()