omnisci Namespace Reference

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)
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::init(), File_Namespace::FileMgr::openDBMetaFile(), File_Namespace::FileMgr::openEpochFile(), foreign_storage::ForeignStorageCache::setLimit(), 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:

int omnisci::fsync

(

int

fd

)

Definition at line 60 of file omnisci_fs.cpp.

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

                  {
  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 import_export::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.