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().

                                                                                        {
  if (g_enable_non_kernel_time_query_interrupt && !query_session.empty()) {
    mapd_shared_lock<mapd_shared_mutex> session_read_lock(executor->getSessionLock());
    return executor->checkIsQuerySessionInterrupted(query_session, session_read_lock);
  }
  return false;
}

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().

                                                               {
  if (copy_params_threads > 0) {
    return static_cast<size_t>(copy_params_threads);
  }
  return std::min(static_cast<size_t>(std::thread::hardware_concurrency()),
                  g_max_import_threads);
}

Here is the caller graph for this function: