Increase the time between progress updates from 500ms to 2000ms, plus…

… make it...
gorpipe · Oct 14, 2024 · f693f82 · f693f82
1 parent a819ed2
commit f693f82
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 13 deletions.
diff --git a/gortools/src/main/scala/gorsat/Iterators/ServerGorSource.scala b/gortools/src/main/scala/gorsat/Iterators/ServerGorSource.scala
@@ -30,4 +30,4 @@ class ServerGorSource(options: String, context: GorContext, executeNor: Boolean,
     context,
     executeNor,
     context.getSession.getSystemContext.getMonitor,
-    500))
+      Integer.parseInt(System.getProperty("gor.monitor.log.interval", "2000"))))
diff --git a/gortools/src/main/scala/gorsat/Utilities/IteratorUtilities.scala b/gortools/src/main/scala/gorsat/Utilities/IteratorUtilities.scala
@@ -45,15 +45,14 @@ object IteratorUtilities {
 
   def getHeader(filename: String, gorRoot: String, context: GorContext): String = {
     val gm: GorMonitor = null
-    val minLogTime = Int.MaxValue
     var header = ""
     context.getSession.getCache.getHeaderMap.synchronized {
       Option(context.getSession.getCache.getHeaderMap.getOrDefault(filename, null)) match {
         case Some(h) => header = h
         case None =>
           var gs:FastGorSource = null
           try {
-            gs = new FastGorSource(filename, gorRoot, context, false, gm, minLogTime)
+            gs = new FastGorSource(filename, gorRoot, context, false, gm, Int.MaxValue)
             header = gs.getHeader
             context.getSession.getCache.getHeaderMap.put(filename, header)
           } finally {

diff --git a/model/src/main/java/org/gorpipe/gor/monitor/GorMonitor.java b/model/src/main/java/org/gorpipe/gor/monitor/GorMonitor.java
@@ -55,22 +55,14 @@ public boolean notify(String chr, int pos, String prevChr) {
      * @param msg log message
      */
     public void log(String msg) {
-        final long time = System.currentTimeMillis();
-        synchronized (timestampFormatter) {
-            String timestamp = timestampFormatter.format(new Date(time));
-            log.info("Log: {} {}", timestamp, msg);
-        }
+        log.info(msg);
     }
 
     /**
      * @param msg debug message
      */
     public void debug(String msg) {
-        final long time = System.currentTimeMillis();
-        synchronized (timestampFormatter) {
-            String timestamp = timestampFormatter.format(new Date(time));
-            log.debug("Log: {} {}", timestamp, msg);
-        }
+        log.debug(msg);
     }
 
     public void close() {}