From 5f01b261077e236c143440d218d4393597ebe6c1 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Mon, 15 Aug 2022 23:07:50 +0200
Subject: [PATCH] Implement backuppable class

---
 .../java/org/warp/filesponge/DiskCache.java    | 18 +++++++++++++++++-
 1 file changed, 17 insertions(+), 1 deletion(-)

diff --git a/src/main/java/org/warp/filesponge/DiskCache.java b/src/main/java/org/warp/filesponge/DiskCache.java
index fac2eef..abcb038 100644
--- a/src/main/java/org/warp/filesponge/DiskCache.java
+++ b/src/main/java/org/warp/filesponge/DiskCache.java
@@ -24,6 +24,7 @@ import static org.warp.filesponge.FileSponge.BLOCK_SIZE;
 import io.netty5.buffer.api.Buffer;
 import io.netty5.util.Resource;
 import io.netty5.util.Send;
+import it.cavallium.dbengine.client.IBackuppable;
 import it.cavallium.dbengine.database.BufSupplier;
 import it.cavallium.dbengine.database.ColumnUtils;
 import it.cavallium.dbengine.database.LLDatabaseConnection;
@@ -47,7 +48,7 @@ import reactor.core.scheduler.Schedulers;
 import reactor.util.function.Tuple2;
 import reactor.util.function.Tuples;
 
-public class DiskCache implements URLsDiskHandler, URLsWriter {
+public class DiskCache implements URLsDiskHandler, URLsWriter, IBackuppable {
 
 	private final DiskMetadataSerializer diskMetadataSerializer;
 
@@ -294,4 +295,19 @@ public class DiskCache implements URLsDiskHandler, URLsWriter {
 	public Mono<Void> close() {
 		return db.close();
 	}
+
+	@Override
+	public Mono<Void> pauseForBackup() {
+		return db.pauseForBackup();
+	}
+
+	@Override
+	public Mono<Void> resumeAfterBackup() {
+		return db.resumeAfterBackup();
+	}
+
+	@Override
+	public boolean isPaused() {
+		return db.isPaused();
+	}
 }