in simplestore/src/main/java/com/uber/simplestore/impl/SimpleStoreImpl.java [172:197]
public ListenableFuture<Void> clear() {
requireOpen();
return Futures.submitAsync(
() -> {
Exception isDead = isDead();
if (isDead != null) {
return Futures.immediateFailedFuture(isDead);
}
try {
File[] files = Objects.requireNonNull(namespacedDirectory).listFiles(File::isFile);
if (files != null && files.length > 0) {
for (File f : files) {
//noinspection ResultOfMethodCallIgnored
f.delete();
}
}
//noinspection ResultOfMethodCallIgnored
namespacedDirectory.delete();
cache.clear();
} catch (Exception e) {
return Futures.immediateFailedFuture(e);
}
return Futures.immediateFuture(null);
},
orderedIoExecutor);
}