OmniSciDB  085a039ca4
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
anonymous_namespace{Importer.cpp} Namespace Reference

Functions

bool check_session_interrupted (const QuerySessionId &query_session, Executor *executor)
 
const size_t num_import_threads (const int copy_params_threads)
 

Function Documentation

bool anonymous_namespace{Importer.cpp}::check_session_interrupted ( const QuerySessionId query_session,
Executor executor 
)

Definition at line 125 of file Importer.cpp.

References g_enable_non_kernel_time_query_interrupt.

Referenced by import_export::import_thread_delimited(), import_export::import_thread_shapefile(), and import_export::Importer::importGDALRaster().

125  {
126  if (g_enable_non_kernel_time_query_interrupt && !query_session.empty()) {
127  mapd_shared_lock<mapd_shared_mutex> session_read_lock(executor->getSessionLock());
128  return executor->checkIsQuerySessionInterrupted(query_session, session_read_lock);
129  }
130  return false;
131 }
bool g_enable_non_kernel_time_query_interrupt
Definition: Execute.cpp:126

+ Here is the caller graph for this function:

const size_t anonymous_namespace{Importer.cpp}::num_import_threads ( const int  copy_params_threads)

Definition at line 133 of file Importer.cpp.

References g_max_import_threads.

Referenced by import_export::Importer::importDelimited(), import_export::Importer::importGDALGeo(), and import_export::Importer::importGDALRaster().

133  {
134  if (copy_params_threads > 0) {
135  return static_cast<size_t>(copy_params_threads);
136  }
137  return std::min(static_cast<size_t>(std::thread::hardware_concurrency()),
139 }
size_t g_max_import_threads
Definition: Importer.cpp:106

+ Here is the caller graph for this function: