|
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 |
Public Member Functions inherited from ypc::internal::sealed_file_base | |
| 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 |
Protected Attributes inherited from ypc::internal::sealed_file_base | |
| blockfile_t | m_file |
Additional Inherited Members | |
Public Types inherited from ypc::internal::sealed_file_base | |
| using | blockfile_t = blockfile< 0x4788d13e7fefe21f, 1024 *1024, 256 *::ypc::utc::max_item_size > |
1.8.17