OmniSciDB  a987f07e93
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
foreign_storage::MetadataScanMultiThreadingParams Struct Reference

#include <AbstractTextFileDataWrapper.h>

Public Attributes

std::queue< ParseBufferRequestpending_requests
 
std::queue< ParseBufferRequestdeferred_requests
 
std::mutex pending_requests_mutex
 
std::mutex deferred_requests_mutex
 
std::condition_variable pending_requests_condition
 
std::queue< ParseBufferRequestrequest_pool
 
std::mutex request_pool_mutex
 
std::condition_variable request_pool_condition
 
bool continue_processing
 
std::map< ChunkKey,
std::unique_ptr
< ForeignStorageBuffer > > 
chunk_encoder_buffers
 
std::map< ChunkKey,
Chunk_NS::Chunk
cached_chunks
 
std::mutex chunk_encoder_buffers_mutex
 
bool disable_cache
 

Detailed Description

Data structure used to hold shared objects needed for inter-thread synchronization or objects containing data that is updated by multiple threads while scanning files for metadata.

Definition at line 38 of file AbstractTextFileDataWrapper.h.

Member Data Documentation

std::map<ChunkKey, std::unique_ptr<ForeignStorageBuffer> > foreign_storage::MetadataScanMultiThreadingParams::chunk_encoder_buffers
std::mutex foreign_storage::MetadataScanMultiThreadingParams::chunk_encoder_buffers_mutex
std::mutex foreign_storage::MetadataScanMultiThreadingParams::deferred_requests_mutex
std::condition_variable foreign_storage::MetadataScanMultiThreadingParams::request_pool_condition
std::mutex foreign_storage::MetadataScanMultiThreadingParams::request_pool_mutex

The documentation for this struct was generated from the following file: