149 int start_index = -1;
155 start_index = (int)
i;
166 const size_t RCV_DATA_DEFAULT_SIZE = 1024;
170 for (std::size_t
i = start_index;
i <
m_cursor; ++
i)
181 rcv_data_buffer.extend_to (redo.
length);
182 std::memcpy (rcv_data_buffer.get_ptr (), data_ptr, redo.
length);
189 m_cursor = start_index;
std::size_t m_redo_data_offset
static const std::size_t REDO_DATA_MAX_SIZE
int log_execute_run_postpone(THREAD_ENTRY *thread_p, LOG_LSA *log_lsa, LOG_REC_REDO *redo, char *redo_rcv_data)
const block_allocator PRIVATE_BLOCK_ALLOCATOR
#define PTR_ALIGN(addr, boundary)
bool m_is_redo_data_buf_full
std::size_t get_size() const
void add_lsa(const log_lsa &lsa)
std::array< cache_entry, MAX_CACHE_ENTRIES > m_cache_entries
bool do_postpone(cubthread::entry &thread_ref, const log_lsa &start_postpone_lsa)
static const std::size_t MAX_CACHE_ENTRIES
static const std::size_t BUFFER_RESET_SIZE
cubmem::extensible_block m_redo_data_buf
void extend_to(size_t total_bytes)
void add_redo_data(const log_prior_node &node)