Optionally synchronize upload on S3 by property 'synchronizeUpload=tr…

…ue' #1710
dcm4che · Nov 29, 2018 · ddf09e5 · ddf09e5
1 parent 75717be
commit ddf09e5
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/dcm4chee-arc-storage-cloud/src/main/java/org/dcm4chee/arc/storage/cloud/CloudStorage.java b/dcm4chee-arc-storage-cloud/src/main/java/org/dcm4chee/arc/storage/cloud/CloudStorage.java
@@ -167,6 +167,15 @@ protected void afterOutputStreamClosed(WriteContext ctx) throws IOException {
     }
 
     private void upload(WriteContext ctx, InputStream in) throws IOException {
+        if (isSynchronizeUpload())
+            synchronized (descriptor) {
+                upload(in, ctx);
+            }
+        else
+            upload(in, ctx);
+    }
+
+    private void upload(InputStream in, WriteContext ctx) throws IOException {
         BlobStore blobStore = context.getBlobStore();
         String storagePath = pathFormat.format(ctx.getAttributes());
         if (count++ == 0 && !blobStore.containerExists(container))
@@ -180,6 +189,10 @@ private void upload(WriteContext ctx, InputStream in) throws IOException {
         ctx.setStoragePath(storagePath);
     }
 
+    private boolean isSynchronizeUpload() {
+        return "true".equals(descriptor.getProperty("synchronizeUpload", "false"));
+    }
+
     @Override
     protected InputStream openInputStreamA(ReadContext ctx) throws IOException {
         BlobStore blobStore = context.getBlobStore();