Skip to content

Commit 44b001d

Browse files
Code cleanup
1 parent 32e5b5a commit 44b001d

File tree

2 files changed

+13
-22
lines changed

2 files changed

+13
-22
lines changed

DESCRIPTION

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
Package: doFuture
2-
Version: 1.1.1-9001
2+
Version: 1.1.1-9002
33
Title: Use Foreach to Parallelize via the Future Framework
44
Depends:
55
foreach (>= 1.5.0),

R/utils-debug.R

Lines changed: 12 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -16,67 +16,58 @@ debug_indent <- local({
1616
if (!exists(".debug", inherits = FALSE)) .debug <- new.env(parent = emptyenv())
1717
if (!"stack" %in% names(".debug")) .debug$stack <- list()
1818

19-
mdebug_push <- function(..., debug = isTRUE(getOption("doFuture.debug"))) {
20-
if (!debug) return()
21-
msg <- mdebug(..., debug = debug)
19+
mdebug_push <- function(...) {
20+
msg <- mdebug(...)
2221
.debug$stack <- c(.debug$stack, msg)
2322
invisible(msg)
2423
}
2524

26-
mdebugf_push <- function(..., debug = isTRUE(getOption("doFuture.debug"))) {
27-
if (!debug) return()
28-
msg <- mdebugf(..., debug = debug)
25+
mdebugf_push <- function(...) {
26+
msg <- mdebugf(...)
2927
.debug$stack <- c(.debug$stack, msg)
3028
invisible(msg)
3129
}
3230

33-
mdebug_pop <- function(..., debug = isTRUE(getOption("doFuture.debug"))) {
34-
if (!debug) return()
31+
mdebug_pop <- function(...) {
3532
n <- length(.debug$stack)
3633
msg <- c(...)
3734
if (length(msg) == 0) {
3835
msg <- .debug$stack[n]
3936
msg <- sprintf("%s done", msg)
4037
}
4138
.debug$stack <- .debug$stack[-n]
42-
if (length(msg) == 0 || !is.na(msg)) mdebug(msg, debug = debug)
39+
if (length(msg) == 0 || !is.na(msg)) mdebug(msg)
4340
}
4441

45-
mdebugf_pop <- function(..., debug = isTRUE(getOption("doFuture.debug"))) {
46-
if (!debug) return()
42+
mdebugf_pop <- function(...) {
4743
n <- length(.debug$stack)
4844
msg <- .debug$stack[n]
4945
.debug$stack <- .debug$stack[-n]
50-
mdebug(sprintf("%s done", msg), debug = debug)
46+
mdebug(sprintf("%s done", msg))
5147
}
5248

53-
mdebug <- function(..., prefix = now(), debug = isTRUE(getOption("doFuture.debug"))) {
54-
if (!debug) return()
49+
mdebug <- function(..., prefix = now()) {
5550
prefix <- paste(prefix, debug_indent(), sep = "")
5651
msg <- paste(..., sep = "")
5752
message(sprintf("%s%s", prefix, msg))
5853
invisible(msg)
5954
}
6055

61-
mdebugf <- function(..., appendLF = TRUE,
62-
prefix = now(), debug = isTRUE(getOption("doFuture.debug"))) {
63-
if (!debug) return()
56+
mdebugf <- function(..., appendLF = TRUE, prefix = now()) {
6457
prefix <- paste(prefix, debug_indent(), sep = "")
6558
msg <- sprintf(...)
6659
message(sprintf("%s%s", prefix, msg), appendLF = appendLF)
6760
invisible(msg)
6861
}
6962

7063
#' @importFrom utils capture.output
71-
mprint <- function(..., appendLF = TRUE, prefix = now(), debug = isTRUE(getOption("doFuture.debug"))) {
72-
if (!debug) return()
64+
mprint <- function(..., appendLF = TRUE, prefix = now()) {
7365
prefix <- paste(prefix, debug_indent(), sep = "")
7466
message(paste(prefix, capture.output(print(...)), sep = "", collapse = "\n"), appendLF = appendLF)
7567
}
7668

7769
#' @importFrom utils capture.output str
78-
mstr <- function(..., appendLF = TRUE, prefix = now(), debug = isTRUE(getOption("doFuture.debug"))) {
79-
if (!debug) return()
70+
mstr <- function(..., appendLF = TRUE, prefix = now()) {
8071
prefix <- paste(prefix, debug_indent(), sep = "")
8172
message(paste(prefix, capture.output(str(...)), sep = "", collapse = "\n"), appendLF = appendLF)
8273
}

0 commit comments

Comments
 (0)