R/timer.R

In rdaemon: Run an R Daemon Process in the Background

timerData <- new.env(parent = emptyenv())

getTimerName <- function(class, name){
    paste0(class, name)
}

## The first execution always return TRUE 
isTimeout <- function(class, name, timeout){
    timerName <- getTimerName(class, name)
    lastTime <- timerData[[timerName]]
    if(is.null(lastTime)||
       .difftime(Sys.time(), lastTime) > timeout){
        resetTimer(class, name)
        TRUE
    }else{
        FALSE
    }
}

resetTimer <- function(class, name){
    timerName <- getTimerName(class, name)
    timerData[[timerName]] <- Sys.time()
}


waitUntilTimeout <- function(class, name, timeout){
    timerName <- getTimerName(class, name)
    lastTime <- timerData[[timerName]]
    resetTimer(class, name)
    if(is.null(lastTime)){
        return()
    }
    waitTime <- timeout - .difftime(Sys.time(), lastTime)
    if(waitTime > 0)
        Sys.sleep(waitTime)
}