OmniSciDB  2e3a973ef4
foreign_storage::MetadataScanMultiThreadingParams Struct Reference

Public Attributes

std::queue< csv_file_buffer_parser::ParseBufferRequestpending_requests
 
std::mutex pending_requests_mutex
 
std::condition_variable pending_requests_condition
 
std::queue< csv_file_buffer_parser::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::mutex chunk_encoder_buffers_mutex
 
std::map< ChunkKey, size_t > chunk_byte_count
 
std::mutex chunk_byte_count_mutex
 

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 CSV files for metadata.

Definition at line 504 of file CsvDataWrapper.cpp.

Member Data Documentation

◆ chunk_byte_count

std::map<ChunkKey, size_t> foreign_storage::MetadataScanMultiThreadingParams::chunk_byte_count

◆ chunk_byte_count_mutex

std::mutex foreign_storage::MetadataScanMultiThreadingParams::chunk_byte_count_mutex

Definition at line 515 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::update_metadata().

◆ chunk_encoder_buffers

std::map<ChunkKey, std::unique_ptr<ForeignStorageBuffer> > foreign_storage::MetadataScanMultiThreadingParams::chunk_encoder_buffers

◆ chunk_encoder_buffers_mutex

std::mutex foreign_storage::MetadataScanMultiThreadingParams::chunk_encoder_buffers_mutex

Definition at line 513 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::update_metadata().

◆ continue_processing

bool foreign_storage::MetadataScanMultiThreadingParams::continue_processing

◆ pending_requests

◆ pending_requests_condition

std::condition_variable foreign_storage::MetadataScanMultiThreadingParams::pending_requests_condition

◆ pending_requests_mutex

◆ request_pool

std::queue<csv_file_buffer_parser::ParseBufferRequest> foreign_storage::MetadataScanMultiThreadingParams::request_pool

◆ request_pool_condition

std::condition_variable foreign_storage::MetadataScanMultiThreadingParams::request_pool_condition

◆ request_pool_mutex

std::mutex foreign_storage::MetadataScanMultiThreadingParams::request_pool_mutex

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