From 1e771fa52ec5133b31b7d7a95966fc832c4c020f Mon Sep 17 00:00:00 2001 From: Hollos Roland Date: Mon, 22 Nov 2021 13:57:59 +0100 Subject: [PATCH] fixing undefined future return --- RBBGCMuso/R/multiSite.R | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/RBBGCMuso/R/multiSite.R b/RBBGCMuso/R/multiSite.R index 7063593..4c6ac06 100644 --- a/RBBGCMuso/R/multiSite.R +++ b/RBBGCMuso/R/multiSite.R @@ -168,10 +168,11 @@ multiSiteCalib <- function(measurements, tryCatch( { - multiSiteThread(measuredData = measurements, parameters = parameters, calTable=calTable, + result <- multiSiteThread(measuredData = measurements, parameters = parameters, calTable=calTable, dataVar = dataVar, iterations = threadCount[i], likelihood = likelihood, threadNumber= i, constraints=constraints, th=th) setwd("../../") + return(result) } , error = function(e){ @@ -256,7 +257,7 @@ multiSiteCalib <- function(measurements, dev.off() } } - origModOut <- future::value(fut[[1]], stdout = FALSE, signal=FALSE)[["origModOut"]] + origModOut <- future::value(fut[[1]], stdout = FALSE, signal=FALSE)[["origModOut"]] # Just single objective version TODO:Multiobjective results <- results[results[,"Const"] == 1,] if(nrow(results)==0){ @@ -479,9 +480,12 @@ multiSiteThread <- function(measuredData, parameters = NULL, startDate = NULL, writeLines(as.character(i-1),"progress.txt") #UNCOMMENT IMPORTANT } } + if(threadNumber == 1){ return(originalRun) } + + return(0) } distributeCores <- function(iterations, numCores){ perProcess<- iterations %/% numCores