Remove spaces from the system() calls to avoid ~+~ for each space in the 'ps' and commandArgs() output for parallel workers

Author: HenrikBengtsson

DESCRIPTION

@@ -1,5 +1,5 @@
 Package: parallelly
-Version: 1.42.0-9003
+Version: 1.42.0-9004
 Title: Enhancing the 'parallel' Package
 Imports:
     parallel,

R/makeNodePSOCK.R

@@ -764,7 +764,7 @@ makeNodePSOCK <- function(worker = getOption2("parallelly.localhost.hostname", "
   }
 
   if (length(socketOptions) == 1L) {
-    code <- sprintf("options(socketOptions = \"%s\")", socketOptions)
+    code <- sprintf("options(socketOptions=\"%s\")", socketOptions)
     rscript_expr <- c("-e", shQuote(code, type = rscript_sh[1]))
     rscript_args_internal <- c(rscript_args_internal, rscript_expr)
   }
@@ -830,7 +830,7 @@ makeNodePSOCK <- function(worker = getOption2("parallelly.localhost.hostname", "
       tryCatch({
         parse(text = code)
       }, error = function(ex) {
-        stopf("Argument 'rscript_envs' appears to contain invalid values: %s", paste(sprintf("%s=%s", sQuote(names), sQuote(rscript_envs)), collapse = ", "))
+        stopf("Argument 'rscript_envs' appears to contain invalid values: %s", paste(sprintf("%s=%s", sQuote(names), sQuote(rscript_envs)), collapse = ","))
       })
       rscript_args_internal <- c(rscript_args_internal, "-e", shQuote(code, type = rscript_sh[1]))
     }
@@ -854,7 +854,7 @@ makeNodePSOCK <- function(worker = getOption2("parallelly.localhost.hostname", "
   ## .{slave,work}RSOCK() command already specified?
   if (!any(grepl("parallel:::[.](slave|work)RSOCK[(][)]", rscript_args))) {
     ## In R (>= 4.1.0), parallel:::.slaveRSOCK() was renamed to .workRSOCK()
-    cmd <- "workRSOCK <- tryCatch(parallel:::.workRSOCK, error=function(e) parallel:::.slaveRSOCK); workRSOCK()"
+    cmd <- "workRSOCK<-tryCatch(parallel:::.workRSOCK,error=function(e)parallel:::.slaveRSOCK);workRSOCK()"
     rscript_args_internal <- c(rscript_args_internal, "-e", shQuote(cmd, type = rscript_sh[1]))
   }
 

R/utils,cluster.R

@@ -274,7 +274,7 @@ useWorkerPID <- local({
     pidfile <- tempfile(pattern = sprintf("worker.rank=%d.parallelly.parent=%d.",
                    rank, parent_pid), fileext = ".pid")
     pidfile <- normalizePath(pidfile, winslash = "/", mustWork = FALSE)
-    pidcode <- sprintf('try(suppressWarnings(cat(Sys.getpid(),file="%s")), silent = TRUE)', pidfile)
+    pidcode <- sprintf('try(suppressWarnings(cat(Sys.getpid(),file="%s")),silent=TRUE)', pidfile)
     rscript_pid_args <- c("-e", shQuote(pidcode, type = rscript_sh))
     list(pidfile = pidfile, rscript_pid_args = rscript_pid_args)
   }