0002252: Re add a buffer flush at the end of a push and at the end of…

… a file push.
JumpMind · Apr 3, 2015 · 1820f0a · 1820f0a
1 parent 56f960e
commit 1820f0a
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/FileSyncPushUriHandler.java
@@ -73,6 +73,8 @@ public void handle(HttpServletRequest req, HttpServletResponse res) throws IOExc
 
             }
         }
+
+        res.flushBuffer();
 
     }
 

diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/PushUriHandler.java
@@ -53,6 +53,7 @@ public PushUriHandler(IParameterService parameterService, IDataLoaderService dat
         this.dataLoaderService = dataLoaderService;
         this.statisticManager = statisticManager;
         this.nodeService = nodeService;
+        log.info("Patched version of PushUriHandler with buffer flush is deployed");
     }
 
     public void handle(HttpServletRequest req, HttpServletResponse res) throws IOException,
@@ -65,6 +66,7 @@ public void handle(HttpServletRequest req, HttpServletResponse res) throws IOExc
 
         push(nodeId, inputStream, outputStream);
 
+        res.flushBuffer();
         log.debug("Push completed for {}", nodeId);
 
     }