[brooklyn-server] 03/05: Buffer the text stream from winrm4j

[heneveld]

This is an automated email from the ASF dual-hosted git repository.

heneveld pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/brooklyn-server.git

commit a7704d0e1ead1d5f568eb7f2ddf833b39c5ebc33
Author: Duncan Grant <duncan.gr...@cloudsoft.io>
AuthorDate: Thu Nov 12 14:35:37 2020 +0000

    Buffer the text stream from winrm4j
    
    In case of craziness coming from the winrm4j script.
---
 .../brooklyn/util/core/internal/winrm/winrm4j/Winrm4jTool.java    | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git 
a/software/winrm/src/main/java/org/apache/brooklyn/util/core/internal/winrm/winrm4j/Winrm4jTool.java
 
b/software/winrm/src/main/java/org/apache/brooklyn/util/core/internal/winrm/winrm4j/Winrm4jTool.java
index 4295168..0ce9bc5 100644
--- 
a/software/winrm/src/main/java/org/apache/brooklyn/util/core/internal/winrm/winrm4j/Winrm4jTool.java
+++ 
b/software/winrm/src/main/java/org/apache/brooklyn/util/core/internal/winrm/winrm4j/Winrm4jTool.java
@@ -118,8 +118,8 @@ public class Winrm4jTool implements 
org.apache.brooklyn.util.core.internal.winrm
         return exec(tool -> {
             OutputStream outputStream = bag.get(ShellTool.PROP_OUT_STREAM);
             OutputStream errorStream = bag.get(ShellTool.PROP_ERR_STREAM);
-            Writer out = outputStream != null ? new 
OutputStreamWriter(outputStream): new StringWriter();
-            Writer err = errorStream != null ? new 
OutputStreamWriter(errorStream): new StringWriter();
+            Writer out = outputStream != null ? new BufferedWriter(new 
OutputStreamWriter(outputStream)): new StringWriter();
+            Writer err = errorStream != null ? new BufferedWriter(new 
OutputStreamWriter(errorStream)): new StringWriter();
             return tool.executeCommand(commands, out, err);
         });
     }
@@ -135,8 +135,8 @@ public class Winrm4jTool implements 
org.apache.brooklyn.util.core.internal.winrm
         return exec(tool -> {
             OutputStream outputStream = bag.get(ShellTool.PROP_OUT_STREAM);
             OutputStream errorStream = bag.get(ShellTool.PROP_ERR_STREAM);
-            Writer out = outputStream != null ? new 
OutputStreamWriter(outputStream): new StringWriter();
-            Writer err = errorStream != null ? new 
OutputStreamWriter(errorStream): new StringWriter();
+            Writer out = outputStream != null ? new BufferedWriter(new 
OutputStreamWriter(outputStream)): new StringWriter();
+            Writer err = errorStream != null ? new BufferedWriter(new 
OutputStreamWriter(errorStream)): new StringWriter();
             return tool.executePs(commands, out, err);
         });
     }