Next >> Developer Interface

nextstream retrieves the currently stored L'Ecuyer-CMRG RNG stream for the specified compute profile and advances it to the next stream.

nextget retrieves the specified item from the specified compute profile.

nextcode translates integer exit codes returned by daemon().

Usage

nextstream(.compute = "default")

nextget(x, .compute = "default")

nextcode(xc)

Arguments

.compute

(character) name of the compute profile. Each profile has its own independent set of daemons. NULL (default) uses the 'default' profile.

x

(character) item to retrieve: "n" (daemon count), "dispatcher" (dispatcher-to-host URL), "url" (daemon connection URL), or "tls" (client TLS configuration).

xc

(integer) return value from daemon().

Value

For nextstream: a length 7 integer vector, as given by .Random.seed when the L'Ecuyer-CMRG RNG is in use (may be passed directly to the rs argument of daemon()), or else NULL if a stream has not yet been created.

For nextget: the requested item, or else NULL if not present.

For nextcode: character string.

Details

These functions are exported for use by packages extending mirai with alternative launchers of daemon() processes.

For nextstream: Calling this function advances the stream stored within the compute profile. This ensures that the next recursive stream is returned on subsequent calls.

Examples

daemons(sync = TRUE)
nextstream()
#> [1]       10407   955490588 -1688047763  -588725430  2073633859  -457412440
#> [7]   759611017
nextstream()
#> [1]       10407  1813634809  1271865761 -1234193909 -1161227463  1750100714
#> [7] -2071934474

nextget("url")
#> [1] "abstract://a551917c90224fa50bde833d"

daemons(0)

nextcode(0L)
#> [1] "0 | Daemon connection terminated"
nextcode(1L)
#> [1] "1 | Daemon idletime limit reached"