R.pkg: add a TODO

diff --git a/code/draft_R_pkg/R/main.R b/code/draft_R_pkg/R/main.R
index 0b46da4..6746d88 100644 (file)
--- a/code/draft_R_pkg/R/main.R
+++ b/code/draft_R_pkg/R/main.R
@@ -55,6 +55,7 @@ epclust = function(data, K, nb_series_per_chunk, min_series_per_chunk=10*K,
        #concerning ncores, any non-integer type will be treated as "use parallel:detectCores()"
 
        #1) acquire data (process curves, get as coeffs)
+       #TODO: for data.frame and custom function, run in parallel (connections are sequential[?!])
        index = 1
        nb_curves = 0
        repeat
@@ -99,7 +100,7 @@ epclust = function(data, K, nb_series_per_chunk, min_series_per_chunk=10*K,
        library(parallel)
        ncores = ifelse(is.integer(ncores), ncores, parallel::detectCores())
        cl = parallel::makeCluster(ncores)
-       parallel::clusterExport(cl=cl, varlist=c("X", "Y", "K", "p"), envir=environment())
+       parallel::clusterExport(cl=cl, varlist=c("TODO:", "what", "to", "export?"), envir=environment())
        #TODO: be careful of writing to a new temp file, then flush initial one, then re-use it...
        repeat
        {
@@ -117,7 +118,7 @@ epclust = function(data, K, nb_series_per_chunk, min_series_per_chunk=10*K,
                } else if (remainder > 0)
                {
                        #spread the load among other workers
-                       
+                       #...
                }
                li = parallel::parLapply(cl, indices, processChunk, K, WER=="mix")
                #C) flush tmp file (current parallel processes will write in it)