From bb2e1f012d8418979e14b11e34a6570d501e71f4 Mon Sep 17 00:00:00 2001 From: Robert Varga Date: Mon, 26 Jan 2015 17:22:34 +0100 Subject: [PATCH] NormalizedNodeOutputStreamWriter should forward flush() When flush is called, we should cascade it to underlying stream, if it is a stream. Failure to do so may cause problems with buffering. Change-Id: I5ee32c3a0bab6aa112dc3c323ea1c4d5c4d5af5c Signed-off-by: Robert Varga --- .../node/utils/stream/NormalizedNodeOutputStreamWriter.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeOutputStreamWriter.java b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeOutputStreamWriter.java index ddbc4f5d48..05858a87a1 100644 --- a/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeOutputStreamWriter.java +++ b/opendaylight/md-sal/sal-clustering-commons/src/main/java/org/opendaylight/controller/cluster/datastore/node/utils/stream/NormalizedNodeOutputStreamWriter.java @@ -177,6 +177,9 @@ public class NormalizedNodeOutputStreamWriter implements NormalizedNodeStreamWri @Override public void flush() throws IOException { + if (output instanceof OutputStream) { + ((OutputStream)output).flush(); + } } private void startNode(final QName qName, byte nodeType) throws IOException { -- 2.36.6