YPC
0.2.0
|
Public Member Functions | |
sealed_file_with_cache_opt (const std::string &file_path, bool read) | |
virtual void | reset_read () |
virtual bool | next_item (memref &s) |
sealed_file_with_cache_opt (const sealed_file_with_cache_opt &)=delete | |
sealed_file_with_cache_opt (sealed_file_with_cache_opt &&)=delete | |
sealed_file_with_cache_opt & | operator= (sealed_file_with_cache_opt &&)=delete |
sealed_file_with_cache_opt & | operator= (const sealed_file_with_cache_opt &)=delete |
![]() | |
sealed_file_base (const std::string &file_path, bool read) | |
virtual void | write_item (const bytes &data) |
sealed_file_base (const sealed_file_base &)=delete | |
sealed_file_base (sealed_file_base &&)=delete | |
sealed_file_base & | operator= (sealed_file_base &&)=delete |
sealed_file_base & | operator= (const sealed_file_base &)=delete |
Protected Attributes | |
std::unique_ptr< std::thread > | m_io_thread |
std::queue< memref > | m_cached |
bool | m_reach_end |
std::mutex | m_mutex |
std::condition_variable | m_cond_full |
std::condition_variable | m_cond_empty |
uint32_t | m_max_queue_size |
std::atomic_bool | m_to_close |
![]() | |
blockfile_t | m_file |
Additional Inherited Members | |
![]() | |
using | blockfile_t = blockfile< 0x4788d13e7fefe21f, 1024 *1024, 256 *::ypc::utc::max_item_size > |