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]
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]
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()