R/db-invalidate-cache.R

In misha: Toolkit for Analysis of Genomic Data

# Drop the process-static index cache entries that misha maintains for
# `dir` (a track or interval-set directory). Call this from R-level
# mutation points (rm, create-atomic rename, convert) so subsequent
# readers don't route through a stale `dir -> shared_ptr<TrackIndex>`
# entry. Without this, "rm <track>; create_*<track>" cycles on indexed
# DBs can route reads to a non-existent track.dat.
#
# Best-effort: failures swallowed - cache miss is not fatal.
.gdb.invalidate_dir_cache <- function(dir) {
    if (is.null(dir) || length(dir) == 0L) {
        return(invisible(NULL))
    }
    dir <- as.character(dir)
    dir <- dir[nzchar(dir)]
    if (!length(dir)) {
        return(invisible(NULL))
    }
    tryCatch(
        .gcall("gdb_invalidate_dir_cache", dir, .misha_env()),
        error = function(e) NULL
    )
    invisible(NULL)
}

# Wipe every process-static index-cache entry (1D / 2D track index, 1D /
# 2D bigset index). Used by gdb.reload(rescan = TRUE) so out-of-process
# mutations (a sibling R session, a manual rm/cp, an external rebuild)
# cannot leave the caller routing reads through a stale `dir ->
# shared_ptr<TrackIndex>` entry.
#
# Best-effort: failures swallowed.
.gdb.clear_all_dir_caches <- function() {
    tryCatch(
        .gcall("gdb_clear_all_dir_caches", .misha_env()),
        error = function(e) NULL
    )
    invisible(NULL)
}