Add option for adding blobs

1 files changed, 21 insertions, 0 deletions

diff --git a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDBRegistry.java b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDBRegistry.java
index ce582a8a1a8..4605d5e5f5c 100644
--- a/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDBRegistry.java
+++ b/configserver/src/main/java/com/yahoo/vespa/config/server/filedistribution/FileDBRegistry.java
@@ -51,6 +51,22 @@ public class FileDBRegistry implements FileRegistry {
     }
 
     @Override
+    public FileReference addBlob(ByteBuffer blob) {
+        long blobHash = XXHashFactory.fastestJavaInstance().hash64().hash(blob, 0);
+        String blobName = Long.toHexString(blobHash);
+        String relativePath = blobToRelativeFile(blob, blobName);
+        synchronized (this) {
+            Optional<FileReference> cachedReference = Optional.ofNullable(fileReferenceCache.get(blobName));
+            return cachedReference.orElseGet(() -> {
+                FileReference newRef = manager.addBlob(blob, relativePath);
+                entries.add(new Entry(blobName, newRef));
+                fileReferenceCache.put(blobName, newRef);
+                return newRef;
+            });
+        }
+    }
+
+    @Override
     public String fileSourceHost() {
         return HostName.getLocalhost();
     }
@@ -72,4 +88,9 @@ public class FileDBRegistry implements FileRegistry {
         return relative;
     }
 
+    private static String blobToRelativeFile(ByteBuffer blob, String blobName) {
+        String relative = "blob/" + blobName;
+        return relative;
+    }
+
 }