library(parallelly)

message("*** Internal functions ...")

## Reset memoization
parallelly:::maxCores(NA_integer_)
parallelly:::procPath(NA_character_)
getUID <- parallelly:::getUID
environment(getUID)$.uid <- NULL

message("getUID(): ", getUID())
message("getUID(): ", getUID())

message("getCGroupsVersion(): ", parallelly:::getCGroupsVersion())
message("getCGroupsVersion(): ", parallelly:::getCGroupsVersion())

message("getCGroupsRoot(): ", parallelly:::getCGroupsRoot())
message("getCGroupsRoot(): ", parallelly:::getCGroupsRoot())

options(parallelly.cgroups.cpuset = 0:3)
message("getCGroups1CpuSet(): ", paste(parallelly:::getCGroups1CpuSet(), collapse = ", "))
options(parallelly.cgroups.cpuset = NULL)

options(parallelly.cgroups.cpuquota = 2.5)
message("getCGroups1CpuQuota(): ", parallelly:::getCGroups1CpuQuota())
options(parallelly.cgroups.cpuquota = NULL)

options(parallelly.cgroups2.cpuset.cpus = 0:3)
message("getCGroups2CpuSet(): ", paste(parallelly:::getCGroups2CpuSet(), collapse = ", "))
message("getCGroups2CpuSet('cpuset.cpus'): ", paste(parallelly:::getCGroups2CpuSet("cpuset.cpus"), collapse = ", "))
options(parallelly.cgroups2.cpuset.cpus = NULL)

options(parallelly.cgroups2.cpuset.cpus.effective = 0:3)
message("getCGroups2CpuSet('cpuset.cpus.effective'): ", paste(parallelly:::getCGroups2CpuSet("cpuset.cpus.effective"), collapse = ", "))
options(parallelly.cgroups2.cpuset.cpus.effective = NULL)

options(parallelly.cgroups2.cpu.max = 100000L)
message("getCGroups2CpuMax(): ", parallelly:::getCGroups2CpuMax())
options(parallelly.cgroups2.cpu.max = NULL)

local({
  opwd <- setwd(tempdir())
  on.exit(setwd(opwd))
  tarfile <- parallelly:::cloneCGroups()
  print(file.info(tarfile))
  stopifnot(utils::file_test("-f", tarfile))
  file.remove(tarfile)
})

message("*** Internal functions ... DONE")



message("*** cgroups ...")

message("- getCGroups()")
cgroups <- parallelly:::getCGroups()
print(cgroups)
stopifnot(
  is.data.frame(cgroups),
  identical(colnames(cgroups), c("hierarchy_id", "controller", "path")),
  nrow(cgroups) == 0L || !is.null(cgroups$controller)
)

message("- getCGroupsRoot()")
root <- parallelly:::getCGroupsRoot()
cat(sprintf("cgroups root path: %s\n", sQuote(root)))
stopifnot(length(root) == 1L, is.character(root))

message("- getCGroups()")
cgroups <- parallelly:::getCGroups()
print(cgroups)
stopifnot(is.data.frame(cgroups))

message("- getCGroupsPath()")
path <- parallelly:::getCGroupsPath("cpu")
cat(sprintf("cgroups 'cpu' path: %s\n", sQuote(path)))
stopifnot(length(path) == 1L, is.character(path))

path <- parallelly:::getCGroupsPath("cpuset")
cat(sprintf("cgroups 'cpuset' path: %s\n", sQuote(path)))
stopifnot(length(path) == 1L, is.character(path))


message("- getCGroups1Value()")
value <- parallelly:::getCGroups1Value("cpu", "cpu.cfs_quota_us")
cat(sprintf("cgroups v1 'cpu.cfs_quota_us' value: %s\n", sQuote(value)))
stopifnot(length(value) == 1L, is.character(value))

value <- parallelly:::getCGroups1Value("cpu", "cpu.cfs_total_us")
cat(sprintf("cgroups v1 'cpu.cfs_total_us' value: %s\n", sQuote(value)))
stopifnot(length(value) == 1L, is.character(value))

value <- parallelly:::getCGroups1Value("cpuset", "cpuset.cpus")
cat(sprintf("cgroups v1 'cpuset.cpus' value: %s\n", sQuote(value)))
stopifnot(length(value) == 1L, is.character(value))


message("- getCGroups1CpuSet()")
value <- parallelly:::getCGroups1CpuSet()
cat(sprintf("CPU set: [n=%d] %s\n", length(value), paste(sQuote(value), collapse = ", ")))
stopifnot(length(value) >= 0L, is.integer(value), !any(is.na(value)))


message("- getCGroups1CpuQuotaMicroseconds()")
value <- parallelly:::getCGroups1CpuQuotaMicroseconds()
cat(sprintf("CPU quota (ms): %d\n", value))
stopifnot(
  length(value) == 1L,
  is.integer(value),
  is.na(value) || value == -1 || value > 0
)

message("- getCGroups1CpuPeriodMicroseconds()")
value <- parallelly:::getCGroups1CpuPeriodMicroseconds()
cat(sprintf("CPU total (ms): %d\n", value))
stopifnot(
  length(value) == 1L,
  is.integer(value),
  is.na(value) || value > 0
)

message("- getCGroups1CpuQuota()")
value <- parallelly:::getCGroups1CpuQuota()
cat(sprintf("CPU quota (ratio): %g\n", value))
stopifnot(
  length(value) == 1L,
  is.numeric(value),
  !is.infinite(value),
  is.na(value) || value > 0
)

message("- getCGroups2CpuSet()")
value <- parallelly:::getCGroups2CpuSet()
cat(sprintf("CPU set: [n=%d] %s\n", length(value), paste(sQuote(value), collapse = ", ")))
stopifnot(length(value) >= 0L, is.integer(value), !any(is.na(value)))

message("- getCGroups2CpuSet('cpuset.cpus.effective')")
value <- parallelly:::getCGroups2CpuSet("cpuset.cpus.effective")
cat(sprintf("CPU set: [n=%d] %s\n", length(value), paste(sQuote(value), collapse = ", ")))
stopifnot(length(value) >= 0L, is.integer(value), !any(is.na(value)))

message("- getCGroups2CpuMax()")
value <- parallelly:::getCGroups2CpuMax()
cat(sprintf("CPU quota (ratio): %g\n", value))
stopifnot(
  length(value) == 1L,
  is.numeric(value),
  !is.infinite(value),
  is.na(value) || value > 0
)

message("- availableCores(methods = 'cgroups2.cpuset.cpus')")
n <- availableCores(methods = "cgroups2.cpuset.cpus", na.rm = FALSE)
cat(sprintf("Number of cores: %s\n", n))
stopifnot(length(n) == 1L, is.integer(n), is.na(n) || n >= 1L)

message("- availableCores(methods = 'cgroups2.cpuset.cpus.effective')")
n <- availableCores(methods = "cgroups2.cpuset.cpus.effective", na.rm = FALSE)
cat(sprintf("Number of cores: %s\n", n))
stopifnot(length(n) == 1L, is.integer(n), is.na(n) || n >= 1L)

message("*** cgroups ... DONE")

root <- system.file(package = "parallelly", "test-data", mustWork = TRUE)
for (dir in c("no-cgroups", "mixed-cgroups", "cgroups1", "cgroups2")) {
  message(sprintf("%s - real-world ...", dir))
  path <- file.path(root, dir)
  stopifnot(file_test("-d", path))
  tarballs <- dir(path = path, pattern = ".*[.]tar[.]gz", full.names = TRUE)
  names(tarballs) <- sub("[.]tar[.]gz$", "", basename(tarballs))

  for (name in names(tarballs)) {
    parallelly:::withCGroups(tarballs[name], {
      file <- file.path(path, sprintf("%s.R", name))
      if (file_test("-f", file)) {
        message("Running custom test script: ", sQuote(file))
        source(file, local = FALSE)
      }
    })
  }
  message(sprintf("%s - real-world ... done", dir))
}

message("cgroups - real-world ... DONE")