select gc column by name+1 (fixes #240)

mschubert · Mar 25, 2021 · 68c03c8 · 68c03c8
1 parent 0ad38f0
commit 68c03c8
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/NEWS.md b/NEWS.md
@@ -1,3 +1,7 @@
+# head
+
+* Fix bug where max memory reporting by `gc()` may be in different column (#240)
+
 # v 0.8.95
 
 * We are now using _ZeroMQ_ via `Rcpp` in preparation for `v0.9` (#151)

diff --git a/R/worker.r b/R/worker.r
@@ -125,10 +125,12 @@ worker = function(master, timeout=getOption("clustermq.worker.timeout", 600),
     run_time = proc.time() - start_time
 
     message("shutting down worker")
+    gc = gc()
+    max_mb = which(colnames(gc) == "max used") + 1
     zmq$send(list(
         id = "WORKER_DONE",
         time = run_time,
-        mem = sum(gc()[,6]),
+        mem = sum(gc[,max_mb]),
         calls = counter,
         auth = auth
     ))