Public Attributes
std::queue< csv_file_buffer_parser::ParseBufferRequest >	pending_requests

std::mutex	pending_requests_mutex

std::condition_variable	pending_requests_condition

std::queue< csv_file_buffer_parser::ParseBufferRequest >	request_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

Definition at line 514 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::CsvDataWrapper::populateChunkMetadata(), and foreign_storage::update_metadata().

◆ 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

Definition at line 512 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::CsvDataWrapper::populateChunkMetadata(), and foreign_storage::update_metadata().

◆ 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

Definition at line 511 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::dispatch_metadata_scan_requests(), foreign_storage::get_next_metadata_scan_request(), and foreign_storage::CsvDataWrapper::populateChunkMetadata().

◆ pending_requests

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

Definition at line 505 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::dispatch_metadata_scan_request(), foreign_storage::dispatch_metadata_scan_requests(), and foreign_storage::get_next_metadata_scan_request().

◆ pending_requests_condition

std::condition_variable foreign_storage::MetadataScanMultiThreadingParams::pending_requests_condition

Definition at line 507 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::dispatch_metadata_scan_request(), foreign_storage::dispatch_metadata_scan_requests(), foreign_storage::get_next_metadata_scan_request(), and foreign_storage::CsvDataWrapper::populateChunkMetadata().

◆ pending_requests_mutex

std::mutex foreign_storage::MetadataScanMultiThreadingParams::pending_requests_mutex

Definition at line 506 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::dispatch_metadata_scan_request(), foreign_storage::dispatch_metadata_scan_requests(), foreign_storage::get_next_metadata_scan_request(), and foreign_storage::CsvDataWrapper::populateChunkMetadata().

◆ request_pool

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

Definition at line 508 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::add_request_to_pool(), foreign_storage::get_request_from_pool(), and foreign_storage::CsvDataWrapper::populateChunkMetadata().

◆ request_pool_condition

std::condition_variable foreign_storage::MetadataScanMultiThreadingParams::request_pool_condition

Definition at line 510 of file CsvDataWrapper.cpp.

Referenced by foreign_storage::add_request_to_pool(), and foreign_storage::get_request_from_pool().

◆ request_pool_mutex

std::mutex foreign_storage::MetadataScanMultiThreadingParams::request_pool_mutex

Definition at line 509 of file CsvDataWrapper.cpp.