Lines Matching refs:recv_sys_t

59 recv_sys_t	recv_sys;
732 inline void recv_sys_t::trim(const page_id_t page_id, lsn_t lsn) in trim()
739 for (recv_sys_t::map::iterator p = pages.lower_bound(page_id); in trim()
741 recv_sys_t::map::iterator r = p++; in trim()
757 void recv_sys_t::open_log_files_if_needed() in open_log_files_if_needed()
769 void recv_sys_t::read(os_offset_t total_offset, span<byte> buf) in read()
779 inline size_t recv_sys_t::files_size() in files_size()
922 void recv_sys_t::close() in close()
951 void recv_sys_t::create() in create()
981 inline void recv_sys_t::clear() in clear()
1001 void recv_sys_t::debug_free() in debug_free()
1016 inline void *recv_sys_t::alloc(size_t len) in alloc()
1058 inline void recv_sys_t::free(const void *data) in free()
1668 inline void recv_sys_t::add(map::iterator it, lsn_t start_lsn, lsn_t lsn, in add()
1753 bool recv_sys_t::parse(lsn_t checkpoint_lsn, store_t *store, bool apply) in parse()
2235 const recv_sys_t::map::iterator& p, in recv_recover_page()
2456 ATTRIBUTE_COLD void recv_sys_t::free_corrupted_page(page_id_t page_id) in free_corrupted_page()
2491 recv_sys_t::map::iterator p = recv_sys.pages.find(bpage->id()); in recv_recover_page()
2510 static void recv_read_in_area(page_id_t page_id, recv_sys_t::map::iterator i) in recv_read_in_area()
2541 inline buf_block_t *recv_sys_t::recover_low(const page_id_t page_id, in recover_low()
2591 buf_block_t *recv_sys_t::recover_low(const page_id_t page_id) in recover_low()
2640 void recv_sys_t::apply(bool last_batch) in apply()
2836 inline bool recv_sys_t::is_memory_exhausted(store_t *store) in is_memory_exhausted()
3251 for (recv_sys_t::map::iterator p = recv_sys.pages.begin(); in recv_validate_tablespace()
3272 recv_sys_t::map::iterator r = p++; in recv_validate_tablespace()