Mercurial > repos > siwaa > redelac_stics_s
annotate parallelSticsRRotation.R @ 0:ca96540c23cd draft
"planemo upload for repository https://forgemia.inra.fr/redelac"
author | siwaa |
---|---|
date | Thu, 08 Jun 2023 01:13:08 +0000 |
parents | |
children | be10e3fb6e64 |
rev | line source |
---|---|
0
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
1 library(SticsRFiles) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
2 library(SticsOnR) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
3 library(parallel) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
4 library(doParallel) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
5 library(readxl) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
6 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
7 workspace <- paste0(getwd(), "/WS") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
8 javastics_path <- getwd() |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
9 default_config_path <- paste0(javastics_path, "/config") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
10 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
11 # copy of the var.mod and rap.mod into the config folder |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
12 # generalizing maybe should be inside a config folder |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
13 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
14 #file.copy(from = file.path(workspace, "var.mod"), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
15 # to = file.path(default_config_path, "var.mod"), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
16 # overwrite = TRUE) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
17 #file.copy(from = file.path(workspace, "rap.mod"), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
18 # to = file.path(default_config_path, "rap.mod"), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
19 # overwrite = TRUE) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
20 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
21 txt_path <- paste0(getwd(), "/WS/txt_files") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
22 #dir.create(txt_path,recursive = T) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
23 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
24 #gen_usms_xml2txt(javastics = javastics_path, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
25 # workspace = workspace, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
26 # out_dir = txt_path, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
27 # check = FALSE) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
28 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
29 print("==================================") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
30 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
31 print(paste0("Cores=", detectCores())) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
32 print(paste0("javastics=", javastics_path)) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
33 print(paste0("ws=", workspace)) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
34 print(paste0("out_dir=", txt_path)) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
35 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
36 print("==================================") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
37 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
38 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
39 # List of successive USMs |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
40 successive_usms_file <- ("successionPlan.csv") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
41 successive_usms_tab <- read.csv(file = file.path(workspace, successive_usms_file), sep =";") |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
42 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
43 no_cores <- detectCores() - 1 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
44 cl <- makeCluster(no_cores) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
45 registerDoParallel(cl) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
46 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
47 result <- foreach(i=1:nrow(successive_usms_tab), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
48 .packages = c("SticsRFiles", "SticsOnR") ) %dopar% { |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
49 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
50 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
51 print(paste("coucou ", i)) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
52 nusms <- as.numeric(successive_usms_tab[i,2]) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
53 print(paste0("coco ", nusms)) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
54 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
55 vec <- as.character(successive_usms_tab[i,c(3:(2+nusms))]) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
56 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
57 list_successive_usms <- list(vec) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
58 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
59 sim_options <- stics_wrapper_options(javastics = javastics_path, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
60 stics_exe = paste0(javastics_path,"/bin/stics_modulo"), |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
61 workspace = txt_path, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
62 verbose = TRUE, |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
63 successive = list_successive_usms) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
64 list_usms <- vec |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
65 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
66 stics_wrapper(model_options = sim_options, situation = list_usms) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
67 } |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
68 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
69 stopCluster(cl) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
70 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
71 for (i in 1:nrow(successive_usms_tab)) { #i=1 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
72 if (i == 1) { |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
73 simPCP <- result[[i]] |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
74 } else { |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
75 simPCP$sim_list <- c(simPCP$sim_list, result[[i]]$sim_list) |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
76 } |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
77 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
78 } |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
79 |
ca96540c23cd
"planemo upload for repository https://forgemia.inra.fr/redelac"
siwaa
parents:
diff
changeset
|
80 save(simPCP, file = "results.RData") |