add verbose flag (closes #61)

mschubert · Nov 29, 2017 · 8f2677d · 8f2677d
1 parent 449695a
commit 8f2677d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/R/qsys_multicore.r b/R/qsys_multicore.r
@@ -16,7 +16,7 @@ MULTICORE = R6::R6Class("MULTICORE",
 #                                  fun = clustermq:::worker,
 #                                  master = values$master)
 
-            cmd = quote(clustermq:::worker(private$master))
+            cmd = quote(clustermq:::worker(private$master, verbose=FALSE))
             for (i in seq_len(n_jobs)) {
                 p = parallel::mcparallel(cmd, silent=TRUE, detached=TRUE)
                 private$pids = c(private$pids, p$pid)

diff --git a/R/worker.r b/R/worker.r
@@ -5,7 +5,11 @@
 #' @param master   The master address (tcp://ip:port)
 #' @param timeout  Time until worker shuts down without hearing from master
 #' @param ...      Catch-all to not break older template values (ignored)
-worker = function(master, timeout=600, ...) {
+#' @param verbose  Whether to print debug messages
+worker = function(master, timeout=600, ..., verbose=TRUE) {
+    if (!verbose)
+        message = function(...) invisible(NULL)
+
     message("Master: ", master)
     if (length(list(...)) > 0)
         warning("Arguments ignored: ", paste(names(list(...)), collapse=", "))