Skip to content

Commit 6c803d3

Browse files
committed
fixes, though something still odd about runArraySimulation with multicores
1 parent 9886cb6 commit 6c803d3

File tree

2 files changed

+4
-2
lines changed

2 files changed

+4
-2
lines changed

R/analysis.R

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -53,8 +53,7 @@ Analysis <- function(Functions, condition, replications, fixed_objects, cl, MPI,
5353
allow_na=allow_na, allow_nan=allow_nan, use_try=use_try,
5454
allow_gen_errors=allow_gen_errors), TRUE)
5555
} else {
56-
try(lapply_timer(1L:replications, mainsim,
57-
max_time=max_time, max_RAM=max_RAM,
56+
try(lapply(1L:replications, mainsim,
5857
condition=condition,
5958
generate=Functions$generate,
6059
analyse=Functions$analyse,
@@ -69,6 +68,7 @@ Analysis <- function(Functions, condition, replications, fixed_objects, cl, MPI,
6968
useGenerate=useGenerate, useAnalyseHandler=useAnalyseHandler,
7069
include_replication_index=include_replication_index,
7170
allow_na=allow_na, allow_nan=allow_nan, use_try=use_try,
71+
max_time.start=max_time.start, max_time=max_time,
7272
allow_gen_errors=allow_gen_errors), TRUE)
7373
}
7474
} else {

R/functions.R

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -428,6 +428,8 @@ mainsim <- function(index, condition, generate, analyse, fixed_objects, max_erro
428428
mainsim_maxtime <- function(max_time, max_time.start, ...){
429429
st <- proc.time()['elapsed']
430430
time_left <- max_time - (st - max_time.start)
431+
if(time_left <= 0)
432+
stop("Simulation terminated due to max_time constraint", call.=FALSE)
431433
out <- R.utils::withTimeout(mainsim(...),
432434
timeout = time_left,
433435
onTimeout = 'warning')

0 commit comments

Comments
 (0)