Skip to content

Commit bc76074

Browse files
Cluster nodes created by makeClusterPSOCK() gained attribute 'calls'
1 parent 9282f4d commit bc76074

File tree

4 files changed

+7
-1
lines changed

4 files changed

+7
-1
lines changed

DESCRIPTION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
Package: parallelly
2-
Version: 1.44.0-9021
2+
Version: 1.44.0-9022
33
Title: Enhancing the 'parallel' Package
44
Imports:
55
parallel,

NEWS.md

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,10 @@
2020
* `availableWorkers()` gained argument `...`, which passes any
2121
additional arguments to `availableCores()`, if specified.
2222

23+
* Cluster nodes created by `makeClusterPSOCK()` gained attribute
24+
`calls`, which records the `sys.calls()`. This can be useful when
25+
troubleshooting from where a cluster was created.
26+
2327
## Bug Fixes
2428

2529
* `availableCores()` would not respect `method = "fallback"` if

R/launchNodePSOCK.R

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -221,6 +221,7 @@ launchNodePSOCK <- function(options, verbose = FALSE) {
221221
structure(
222222
list(con = con, host = worker, rank = rank, rshlogfile = rshlogfile),
223223
options = options,
224+
calls = sys.calls(),
224225
class = c("RichSOCKnode", if (useXDR) "SOCKnode" else "SOCK0node")
225226
)
226227
} ## launchNodePSOCK()

R/makeClusterPSOCK.R

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -385,6 +385,7 @@ makeClusterPSOCK <- function(workers, makeNode = makeNodePSOCK, port = c("auto",
385385
scon <- structure(
386386
list(con = con, host = localhostHostname, rank = ready),
387387
options = options,
388+
calls = sys.calls(),
388389
class = nodeClass
389390
)
390391
res <- tryCatch({

0 commit comments

Comments
 (0)