anonymous_namespace{Importer.cpp} Namespace Reference

Classes
struct	OGRDataSourceDeleter
struct	OGRFeatureDeleter
struct	OGRSpatialReferenceDeleter

Typedefs
using	OGRDataSourceUqPtr = std::unique_ptr< OGRDataSource, OGRDataSourceDeleter >
using	OGRFeatureUqPtr = std::unique_ptr< OGRFeature, OGRFeatureDeleter >
using	OGRSpatialReferenceUqPtr = std::unique_ptr< OGRSpatialReference, OGRSpatialReferenceDeleter >

Functions
bool	checkInterrupt (const QuerySessionId &query_session, Executor *executor)

Typedef Documentation

using anonymous_namespace{Importer.cpp}::OGRDataSourceUqPtr = typedef std::unique_ptr<OGRDataSource, OGRDataSourceDeleter>

Definition at line 115 of file Importer.cpp.

using anonymous_namespace{Importer.cpp}::OGRFeatureUqPtr = typedef std::unique_ptr<OGRFeature, OGRFeatureDeleter>

Definition at line 124 of file Importer.cpp.

using anonymous_namespace{Importer.cpp}::OGRSpatialReferenceUqPtr = typedef std::unique_ptr<OGRSpatialReference, OGRSpatialReferenceDeleter>

Definition at line 134 of file Importer.cpp.

Function Documentation

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

Definition at line 98 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 Parser::InsertIntoTableAsSelectStmt::populateData().

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

Here is the caller graph for this function: