QSys: Class for basic queuing system functions

Description Methods

Description

Provides the basic functions needed to communicate between machines This should abstract most functions of rZMQ so the scheduler implementations can rely on the higher level functionality

Methods

Public methods


Method new()

Usage
QSys$new(
  data = NULL,
  reuse = FALSE,
  ports = 6000:8000,
  master = NULL,
  node = host(),
  protocol = "tcp",
  template = NULL
)

Method submit_jobs()

Usage
QSys$submit_jobs(...)

Method send_call()

Usage
QSys$send_call(expr, env = list(), ref = substitute(expr))

Method set_common_data()

Usage
QSys$set_common_data(...)

Method send_common_data()

Usage
QSys$send_common_data()

Method send_job_data()

Usage
QSys$send_job_data(...)

Method send_wait()

Usage
QSys$send_wait(wait = 0.05 * self$workers_running)

Method receive_data()

Usage
QSys$receive_data(timeout = Inf, with_checks = TRUE)

Method send_shutdown_worker()

Usage
QSys$send_shutdown_worker()

Method cleanup()

Usage
QSys$cleanup(quiet = FALSE, timeout = 5)

clustermq documentation built on March 26, 2020, 9:17 p.m.