Namespaces
	_parsers

	_samlutils

	_utils

	common

	completion_hints

	connection

	cursor

	dtypes

	exceptions

	extension_functions

	serialized_result_set

	thrift

Classes
struct	DeviceIdentifier

class	UUID

Typedefs
using	DeviceGroup = std::vector< DeviceIdentifier >

Functions
size_t	file_size (const int fd)

void *	checked_mmap (const int fd, const size_t sz)

void	checked_munmap (void *addr, size_t length)

int	msync (void *addr, size_t length, bool async)

int	fsync (int fd)

int	open (const char *path, int flags, int mode)

void	close (const int fd)

::FILE *	fopen (const char filename, const char mode)

int	get_page_size ()

std::vector< std::string >	glob (const std::string &pattern)

std::string	get_hostname ()

std::string	get_root_abs_path ()

bool	operator== (const UUID &lhs, const UUID &rhs) noexcept

bool	operator!= (const UUID &lhs, const UUID &rhs) noexcept

bool	operator< (const UUID &lhs, const UUID &rhs) noexcept

std::string	to_string (const UUID &uuid)

Variables
tuple	__version__ = get_distribution(__name__)

string	apilevel = "2.0"

int	threadsafety = 2

string	paramstyle = "named"

constexpr UUID	empty_uuid {}

Typedef Documentation

using omnisci::DeviceGroup = typedef std::vector<DeviceIdentifier>

Definition at line 15 of file DeviceGroup.h.

Function Documentation

void * omnisci::checked_mmap	(	const int	fd,
		const size_t	sz
	)

Definition at line 38 of file omnisci_fs.cpp.

References CHECK.

Referenced by StringDictionary::checkAndConditionallyIncreaseOffsetCapacity(), StringDictionary::checkAndConditionallyIncreasePayloadCapacity(), and StringDictionary::StringDictionary().

                                                   {
   auto ptr = mmap(nullptr, sz, PROT_WRITE | PROT_READ, MAP_SHARED, fd, 0);
   CHECK(ptr != reinterpret_cast<void*>(-1));
 #ifdef __linux__
 #ifdef MADV_HUGEPAGE
   madvise(ptr, sz, MADV_RANDOM | MADV_WILLNEED | MADV_HUGEPAGE);
 #else
   madvise(ptr, sz, MADV_RANDOM | MADV_WILLNEED);
 #endif
 #endif
   return ptr;
 }

Here is the caller graph for this function:

void omnisci::checked_munmap	(	void *	addr,
		size_t	length
	)

Definition at line 51 of file omnisci_fs.cpp.

References CHECK_EQ.

Referenced by StringDictionary::checkAndConditionallyIncreaseOffsetCapacity(), StringDictionary::checkAndConditionallyIncreasePayloadCapacity(), and StringDictionary::~StringDictionary().

                                                {
   CHECK_EQ(0, munmap(addr, length));
 }

Here is the caller graph for this function:

void omnisci::close ( const int fd )

Definition at line 68 of file omnisci_fs.cpp.

Referenced by import_export::DataStreamSink::import_compressed(), CommandLineOptions::validate(), and StringDictionary::~StringDictionary().

                          {
   ::close(fd);
 }

Here is the caller graph for this function:

size_t omnisci::file_size ( const int fd )

Definition at line 31 of file omnisci_fs.cpp.

References CHECK_EQ.

Referenced by anonymous_namespace{TableArchiver.cpp}::adjust_altered_table_files(), get_filesize(), File_Namespace::FileMgr::getMetadataForFile(), File_Namespace::FileMgr::openAndReadEpochFile(), File_Namespace::FileMgr::openAndReadLegacyEpochFile(), File_Namespace::FileMgr::readVersionFromDisk(), and StringDictionary::StringDictionary().

                                {
   struct stat buf;
   int err = fstat(fd, &buf);
   CHECK_EQ(0, err);
   return buf.st_size;
 }

Here is the caller graph for this function:

FILE * omnisci::fopen	(	const char *	filename,
		const char *	mode
	)

Definition at line 72 of file omnisci_fs.cpp.

Referenced by anonymous_namespace{TableArchiver.cpp}::adjust_altered_table_files(), foreign_storage::SingleFileReader::checkForMoreRows(), File_Namespace::create(), TableArchiver::dumpTable(), import_export::Detector::importDelimited(), import_export::Importer::importDelimited(), PosixFileArchive::init_for_read(), File_Namespace::open(), and foreign_storage::SingleFileReader::SingleFileReader().

                                                     {
   return ::fopen(filename, mode);
 }

Here is the caller graph for this function:

int omnisci::fsync ( int fd )

Definition at line 60 of file omnisci_fs.cpp.

Referenced by StringDictionary::checkpoint(), File_Namespace::FileInfo::syncToDisk(), File_Namespace::FileMgr::writeAndSyncEpochToDisk(), and File_Namespace::FileMgr::writeAndSyncVersionToDisk().

                   {
   return ::fsync(fd);
 }

Here is the caller graph for this function:

std::string omnisci::get_hostname ( )

Definition at line 23 of file omnisci_hostname.cpp.

Referenced by DBHandler::get_memory(), DBHandler::get_server_status(), and DBHandler::get_status().

                          {
   char hostname[_POSIX_HOST_NAME_MAX];
   gethostname(hostname, _POSIX_HOST_NAME_MAX);
   return {hostname};
 }

Here is the caller graph for this function:

int omnisci::get_page_size ( )

Definition at line 27 of file omnisci_fs.cpp.

                     {
   return getpagesize();
 }

std::string omnisci::get_root_abs_path ( )

Definition at line 32 of file omnisci_path.cpp.

References CHECK_GT, and CHECK_LT.

Referenced by Geospatial::GDAL::init(), main(), and start_calcite_server_as_daemon().

                               {
 #ifdef __APPLE__
   char abs_exe_path[PROC_PIDPATHINFO_MAXSIZE] = {0};
   auto path_len = proc_pidpath(getpid(), abs_exe_path, sizeof(abs_exe_path));
 #else
   char abs_exe_path[PATH_MAX] = {0};
   auto path_len = readlink("/proc/self/exe", abs_exe_path, sizeof(abs_exe_path));
 #endif
   CHECK_GT(path_len, 0);
   CHECK_LT(static_cast<size_t>(path_len), sizeof(abs_exe_path));
   boost::filesystem::path abs_exe_dir(std::string(abs_exe_path, path_len));
   abs_exe_dir.remove_filename();
 #ifdef XCODE
   const auto mapd_root = abs_exe_dir.parent_path().parent_path();
 #else
   const auto mapd_root = abs_exe_dir.parent_path();
 #endif
   return mapd_root.string();
 }

Here is the caller graph for this function:

std::vector< std::string > omnisci::glob ( const std::string & pattern )

Definition at line 24 of file omnisci_glob.cpp.

Referenced by import_export::DataStreamSink::archivePlumber(), and ddl_utils::get_expanded_file_paths().

                                                     {
   std::vector<std::string> results;
   glob_t glob_result;
   ::glob(pattern.c_str(), GLOB_BRACE | GLOB_TILDE, nullptr, &glob_result);
   for (size_t i = 0; i < glob_result.gl_pathc; i++) {
     results.emplace_back(glob_result.gl_pathv[i]);
   }
   globfree(&glob_result);
   return results;
 }

Here is the caller graph for this function:

int omnisci::msync	(	void *	addr,
		size_t	length,
		bool	async
	)

Definition at line 55 of file omnisci_fs.cpp.

Referenced by StringDictionary::checkpoint().

                                                  {
   // TODO: support MS_INVALIDATE?
   return ::msync(addr, length, async ? MS_ASYNC : MS_SYNC);
 }

Here is the caller graph for this function:

int omnisci::open	(	const char *	path,
		int	flags,
		int	mode
	)

Definition at line 64 of file omnisci_fs.cpp.

Referenced by anonymous_namespace{StringDictionary.cpp}::checked_open(), create_table.SyntheticTable::generateData(), analyze_benchmark.BenchmarkLoader::load(), run_benchmark::read_query_files(), run_benchmark::send_results_db(), run_benchmark::send_results_file_json(), run_benchmark::send_results_jenkins_bench(), and CommandLineOptions::validate().

                                                 {
   return ::open(path, flags, mode);
 }

Here is the caller graph for this function:

bool omnisci::operator!=	(	const UUID &	lhs,
		const UUID &	rhs
	)

inlinenoexcept

Definition at line 103 of file uuid.h.

                                                                   {
   return !(lhs == rhs);
 }

bool omnisci::operator<	(	const UUID &	lhs,
		const UUID &	rhs
	)

inlinenoexcept

Definition at line 107 of file uuid.h.

                                                                  {
   return lhs.data_ < rhs.data_;
 }

bool omnisci::operator==	(	const UUID &	lhs,
		const UUID &	rhs
	)

inlinenoexcept

Definition at line 99 of file uuid.h.

                                                                   {
   return lhs.data_ == rhs.data_;
 }

std::string omnisci::to_string ( const UUID & uuid )

inline

Definition at line 111 of file uuid.h.

                                              {
   std::stringstream ss;
   ss << uuid;
   return ss.str();
 }

Variable Documentation

tuple omnisci.__version__ = get_distribution(__name__)

Definition at line 5 of file __init__.py.

string omnisci.apilevel = "2.0"

Definition at line 13 of file __init__.py.

constexpr UUID omnisci::empty_uuid {}

Definition at line 117 of file uuid.h.

string omnisci.paramstyle = "named"

Definition at line 15 of file __init__.py.

int omnisci.threadsafety = 2

Definition at line 14 of file __init__.py.

Namespaces

Classes

Typedefs

Functions

Variables

Typedef Documentation

Function Documentation

Variable Documentation