OmniSciDB
bf83d84833
|
#include <ForeignTableRefresh.h>
Static Public Member Functions | |
static void | start (std::atomic< bool > &is_program_running) |
static void | stop () |
static void | setWaitDuration (int64_t duration_in_seconds) |
static bool | isRunning () |
static bool | hasRefreshedTable () |
static void | resetHasRefreshedTable () |
Static Private Attributes | |
static bool | is_scheduler_running_ {false} |
static std::chrono::seconds | thread_wait_duration_ {60} |
static std::thread | scheduler_thread_ |
static std::atomic< bool > | has_refreshed_table_ {false} |
Definition at line 28 of file ForeignTableRefresh.h.
|
static |
Definition at line 92 of file ForeignTableRefresh.cpp.
References has_refreshed_table_.
|
static |
Definition at line 88 of file ForeignTableRefresh.cpp.
References is_scheduler_running_.
|
static |
Definition at line 96 of file ForeignTableRefresh.cpp.
References has_refreshed_table_.
|
static |
Definition at line 84 of file ForeignTableRefresh.cpp.
References thread_wait_duration_.
|
static |
Definition at line 53 of file ForeignTableRefresh.cpp.
References logger::ERROR, has_refreshed_table_, Catalog_Namespace::SysCatalog::instance(), is_scheduler_running_, LOG, foreign_storage::refresh_foreign_table(), scheduler_thread_, run_benchmark_import::tables, and thread_wait_duration_.
Referenced by startMapdServer().
|
static |
Definition at line 77 of file ForeignTableRefresh.cpp.
References is_scheduler_running_, and scheduler_thread_.
Referenced by startMapdServer().
|
staticprivate |
Definition at line 43 of file ForeignTableRefresh.h.
Referenced by hasRefreshedTable(), resetHasRefreshedTable(), and start().
|
staticprivate |
Definition at line 40 of file ForeignTableRefresh.h.
Referenced by isRunning(), start(), and stop().
|
staticprivate |
Definition at line 42 of file ForeignTableRefresh.h.
|
staticprivate |
Definition at line 41 of file ForeignTableRefresh.h.
Referenced by setWaitDuration(), and start().