Michael Blow has uploaded a new change for review.

  https://asterix-gerrit.ics.uci.edu/1029

Change subject: ASTERIXDB-1553: Create ClusterControllerService Dir/File 
Creation
......................................................................

ASTERIXDB-1553: Create ClusterControllerService Dir/File Creation

Change-Id: Ie2e65cf083b3eb2db3e716f2b34fb28fe01debca
---
M 
hyracks-fullstack/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/logs/LogFile.java
1 file changed, 11 insertions(+), 6 deletions(-)


  git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb 
refs/changes/29/1029/1

diff --git 
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/logs/LogFile.java
 
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/logs/LogFile.java
index 7eb0674..d3fa282 100644
--- 
a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/logs/LogFile.java
+++ 
b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-common/src/main/java/org/apache/hyracks/control/common/logs/LogFile.java
@@ -27,6 +27,7 @@
 public class LogFile {
     private final File root;
 
+    private long openTime;
     private PrintWriter out;
 
     public LogFile(File root) {
@@ -34,18 +35,22 @@
     }
 
     public void open() throws Exception {
-        root.mkdirs();
-        out = new PrintWriter(new FileOutputStream(new File(root, 
String.valueOf(System.currentTimeMillis()) + ".log"),
-                true));
+        openTime = System.currentTimeMillis();
     }
 
-    public void log(JSONObject object) throws Exception {
+    public synchronized void log(JSONObject object) throws Exception {
+        if (out == null) {
+            root.mkdirs();
+            out = new PrintWriter(new FileOutputStream(new File(root, openTime 
+ ".log"), true));
+        }
         out.println(object.toString(1));
         out.flush();
     }
 
     public void close() {
-        out.flush();
-        out.close();
+        if (out != null) {
+            out.flush();
+            out.close();
+        }
     }
 }

-- 
To view, visit https://asterix-gerrit.ics.uci.edu/1029
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings

Gerrit-MessageType: newchange
Gerrit-Change-Id: Ie2e65cf083b3eb2db3e716f2b34fb28fe01debca
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: Michael Blow <[email protected]>

Reply via email to