... | ... |
@@ -247,6 +247,8 @@ parseExtraParams <- function(allParams, extraParams) |
247 | 247 |
return(allParams) |
248 | 248 |
} |
249 | 249 |
|
250 |
+## TODO these checks should be in the C++ code so that file names are checked |
|
251 |
+## just as much as R variables |
|
250 | 252 |
#' check that provided data is valid |
251 | 253 |
#' @keywords internal |
252 | 254 |
#' |
... | ... |
@@ -350,6 +350,13 @@ const DataType &uncertainty, GapsRandomState *randState) |
350 | 350 |
elapsed.seconds); |
351 | 351 |
} |
352 | 352 |
|
353 |
+ // if we are running distributed, each worker needs to print when it's started |
|
354 |
+ if (params.runningDistributed) |
|
355 |
+ { |
|
356 |
+ gaps_printf(" worker %d is starting!\n", params.workerID); |
|
357 |
+ gaps_flush(); |
|
358 |
+ } |
|
359 |
+ |
|
353 | 360 |
// these variables will get overwritten by checkpoint if provided |
354 | 361 |
GapsStatistics stats(params.nGenes, params.nSamples, params.nPatterns); |
355 | 362 |
GapsRng rng(randState); |