inst/seqplots/functions/LOCAL/mceval.R

In Przemol/seqplots: An interactive tool for visualizing NGS signals and sequence motif densities along genomic features using average plots and heatmaps

mceval <- function(do, do.iter=NULL, do.final=NULL, ...) {
  
  if(is.null(isolate(values$proc))) {
    values$proc <- parallel::mcparallel(do)
    invalidateLater(500, session)
    
  } else if ( is.null(parallel:::selectChildren(isolate(values$proc))) ) {
    parallel::mccollect( isolate(values$proc) ); values$proc <- NULL 
    session$sendCustomMessage("jsExec", "$('#progressModal').modal('hide'); alert('Job canceled!');")
    if(!is.null(values$progress)) values$progress$close()
    
  } else if( parallel:::selectChildren(isolate(values$proc)) == parallel:::processID(isolate(values$proc)) ) {
    res <- parallel::mccollect(isolate(values$proc), wait=FALSE)[[1]]
    
    if(class(res) == 'try-error' ) {
      parallel::mccollect( isolate(values$proc) ); values$proc <- NULL 
      session$sendCustomMessage("jsAlert", res); session$sendCustomMessage("jsExec", "$('#progressModal').modal('hide');")
      
    } else if ( is.null(res) ) {
      parallel::mccollect( isolate(values$proc) ); values$proc <- NULL 
      session$sendCustomMessage("jsExec", "$('#progressModal').modal('hide'); alert('Job canceled.');")
      if(!is.null(values$progress)) values$progress$close()
      
    } else {
      parallel::mccollect( isolate(values$proc) )
      values$proc <- NULL 
      session$sendCustomMessage("jsExec", "$('#progressModal').modal('hide').find('#summary2').text('')")      
      eval( do.final )
      
    }
    
  } else { 
    if(!is.null(do.iter)) eval( do.iter ) 
    invalidateLater(500, session); 
    
  }  
}