overflow_file.c File Reference

#include "overflow_file.h"
#include "config.h"
#include "error_manager.h"
#include "file_manager.h"
#include "heap_file.h"
#include "log_append.hpp"
#include "log_manager.h"
#include "memory_alloc.h"
#include "mvcc.h"
#include "page_buffer.h"
#include "slotted_page.h"
#include "storage_common.h"
#include <string.h>

Include dependency graph for overflow_file.c:

Go to the source code of this file.

Classes
struct	overflow_first_part
struct	overflow_rest_part

Macros
#define	OVERFLOW_ALLOCVPID_ARRAY_SIZE   64

Typedefs
typedef struct overflow_first_part	OVERFLOW_FIRST_PART
typedef struct overflow_rest_part	OVERFLOW_REST_PART

Enumerations
enum	OVERFLOW_DO_FUNC { OVERFLOW_DO_DELETE, OVERFLOW_DO_FLUSH }

Functions
static void	overflow_next_vpid (const VPID *ovf_vpid, VPID *vpid, PAGE_PTR pgptr)
static const VPID *	overflow_traverse (THREAD_ENTRY *thread_p, const VFID *ovf_vfid, const VPID *ovf_vpid, OVERFLOW_DO_FUNC func)
static int	overflow_delete_internal (THREAD_ENTRY *thread_p, const VFID *ovf_vfid, VPID *vpid, PAGE_PTR pgptr)
static int	overflow_flush_internal (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)
int	overflow_insert (THREAD_ENTRY *thread_p, const VFID *ovf_vfid, VPID *ovf_vpid, RECDES *recdes, FILE_TYPE file_type)
int	overflow_update (THREAD_ENTRY *thread_p, const VFID *ovf_vfid, const VPID *ovf_vpid, RECDES *recdes, FILE_TYPE file_type)
const VPID *	overflow_delete (THREAD_ENTRY *thread_p, const VFID *ovf_vfid, const VPID *ovf_vpid)
void	overflow_flush (THREAD_ENTRY *thread_p, const VPID *ovf_vpid)
int	overflow_get_length (THREAD_ENTRY *thread_p, const VPID *ovf_vpid)
SCAN_CODE	overflow_get_nbytes (THREAD_ENTRY *thread_p, const VPID *ovf_vpid, RECDES *recdes, int start_offset, int max_nbytes, int *remaining_length, MVCC_SNAPSHOT *mvcc_snapshot)
SCAN_CODE	overflow_get (THREAD_ENTRY *thread_p, const VPID *ovf_vpid, RECDES *recdes, MVCC_SNAPSHOT *mvcc_snapshot)
int	overflow_get_capacity (THREAD_ENTRY *thread_p, const VPID *ovf_vpid, int *ovf_size, int *ovf_num_pages, int *ovf_overhead, int *ovf_free_space)
int	overflow_rv_newpage_insert_redo (THREAD_ENTRY *thread_p, LOG_RCV *rcv)
int	overflow_rv_newpage_link_undo (THREAD_ENTRY *thread_p, LOG_RCV *rcv)
int	overflow_rv_link (THREAD_ENTRY *thread_p, LOG_RCV *rcv)
void	overflow_rv_link_dump (FILE *fp, int length_ignore, void *data)
int	overflow_rv_page_update_redo (THREAD_ENTRY *thread_p, LOG_RCV *rcv)
void	overflow_rv_page_dump (FILE *fp, int length, void *data)
char *	overflow_get_first_page_data (char *page_ptr)

Macro Definition Documentation

#define OVERFLOW_ALLOCVPID_ARRAY_SIZE   64

Definition at line 41 of file overflow_file.c.

Referenced by overflow_insert().

Typedef Documentation

typedef struct overflow_first_part OVERFLOW_FIRST_PART

Definition at line 43 of file overflow_file.c.

typedef struct overflow_rest_part OVERFLOW_REST_PART

Definition at line 51 of file overflow_file.c.

Enumeration Type Documentation

enum OVERFLOW_DO_FUNC

Enumerator
OVERFLOW_DO_DELETE
OVERFLOW_DO_FLUSH

Definition at line 58 of file overflow_file.c.

Function Documentation

const VPID* overflow_delete	(	THREAD_ENTRY *	thread_p,
		const VFID *	ovf_vfid,
		const VPID *	ovf_vpid
	)

Definition at line 650 of file overflow_file.c.

References OVERFLOW_DO_DELETE, and overflow_traverse().

Referenced by btree_delete_overflow_key(), ehash_delete(), ehash_insert_to_bucket(), and heap_ovf_delete().

Here is the caller graph for this function:

static int overflow_delete_internal ( THREAD_ENTRY *  thread_p, const VFID *  ovf_vfid, VPID *  vpid, PAGE_PTR  pgptr  )

static

Definition at line 619 of file overflow_file.c.

References er_errid(), ER_FAILED, file_dealloc(), FILE_UNKNOWN_TYPE, NO_ERROR, and pgbuf_unfix_and_init.

Referenced by overflow_traverse().

Here is the caller graph for this function:

void overflow_flush	(	THREAD_ENTRY *	thread_p,
		const VPID *	ovf_vpid
	)

Definition at line 683 of file overflow_file.c.

References NULL, OVERFLOW_DO_FLUSH, and overflow_traverse().

Referenced by heap_ovf_flush().

Here is the caller graph for this function:

static int overflow_flush_internal ( THREAD_ENTRY *  thread_p, PAGE_PTR  pgptr  )

static

Definition at line 661 of file overflow_file.c.

References er_errid(), ER_FAILED, NO_ERROR, NULL, and pgbuf_flush_with_wal().

Referenced by overflow_traverse().

Here is the caller graph for this function:

SCAN_CODE overflow_get	(	THREAD_ENTRY *	thread_p,
		const VPID *	ovf_vpid,
		RECDES *	recdes,
		MVCC_SNAPSHOT *	mvcc_snapshot
	)

Definition at line 916 of file overflow_file.c.

References overflow_get_nbytes().

Referenced by btree_load_overflow_key(), ehash_free_recdes(), heap_ovf_get(), and sort_retrieve_longrec().

Here is the caller graph for this function:

int overflow_get_capacity	(	THREAD_ENTRY *	thread_p,
		const VPID *	ovf_vpid,
		int *	ovf_size,
		int *	ovf_num_pages,
		int *	ovf_overhead,
		int *	ovf_free_space
	)

Definition at line 934 of file overflow_file.c.

References ARG_FILE_LINE, overflow_first_part::data, overflow_rest_part::data, DB_PAGESIZE, er_errid(), ER_ERROR_SEVERITY, ER_FAILED, ER_HEAP_OVFADDRESS_CORRUPTED, er_set(), i, overflow_first_part::length, overflow_first_part::next_vpid, overflow_rest_part::next_vpid, NO_ERROR, NULL, NULL_SLOTID, OLD_PAGE, PAGE_OVERFLOW, vpid::pageid, pgbuf_check_page_ptype(), pgbuf_fix, PGBUF_LATCH_READ, PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix_and_init, vpid::volid, VPID_ISNULL, and while().

Referenced by heap_ovf_get_capacity().

Here is the caller graph for this function:

char* overflow_get_first_page_data

(

char *

page_ptr

)

Definition at line 1213 of file overflow_file.c.

References assert, and NULL.

Referenced by heap_get_mvcc_rec_header_from_overflow(), heap_set_mvcc_rec_header_on_overflow(), and heap_update_set_prev_version().

Here is the caller graph for this function:

int overflow_get_length	(	THREAD_ENTRY *	thread_p,
		const VPID *	ovf_vpid
	)

Definition at line 697 of file overflow_file.c.

References overflow_first_part::length, NULL, OLD_PAGE, PAGE_OVERFLOW, pgbuf_check_page_ptype(), pgbuf_fix, PGBUF_LATCH_READ, PGBUF_UNCONDITIONAL_LATCH, and pgbuf_unfix_and_init.

Referenced by btree_load_overflow_key(), ehash_free_recdes(), heap_ovf_get_length(), and sort_retrieve_longrec().

Here is the caller graph for this function:

SCAN_CODE overflow_get_nbytes	(	THREAD_ENTRY *	thread_p,
		const VPID *	ovf_vpid,
		RECDES *	recdes,
		int	start_offset,
		int	max_nbytes,
		int *	remaining_length,
		MVCC_SNAPSHOT *	mvcc_snapshot
	)

Definition at line 742 of file overflow_file.c.

References recdes::area_size, ARG_FILE_LINE, CAST_BUFLEN, overflow_first_part::data, overflow_rest_part::data, recdes::data, DB_PAGESIZE, ER_ERROR_SEVERITY, ER_HEAP_OVFADDRESS_CORRUPTED, er_set(), heap_get_mvcc_rec_header_from_overflow(), overflow_first_part::length, recdes::length, overflow_first_part::next_vpid, overflow_rest_part::next_vpid, NULL, NULL_SLOTID, OLD_PAGE, PAGE_OVERFLOW, vpid::pageid, pgbuf_check_page_ptype(), pgbuf_fix, PGBUF_LATCH_READ, PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix_and_init, S_DOESNT_FIT, S_ERROR, S_SNAPSHOT_NOT_SATISFIED, S_SUCCESS, mvcc_snapshot::snapshot_fnc, TOO_OLD_FOR_SNAPSHOT, vpid::volid, VPID_ISNULL, and while().

Referenced by heap_ovf_get(), and overflow_get().

Here is the caller graph for this function:

int overflow_insert	(	THREAD_ENTRY *	thread_p,
		const VFID *	ovf_vfid,
		VPID *	ovf_vpid,
		RECDES *	recdes,
		FILE_TYPE	file_type
	)

Definition at line 95 of file overflow_file.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR, ASSERT_ERROR_AND_SET, CAST_BUFLEN, CEIL_PTVDIV, overflow_first_part::data, overflow_rest_part::data, recdes::data, DB_PAGESIZE, ER_ERROR_SEVERITY, ER_FAILED, er_log_debug, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), file_alloc_multiple(), FILE_BTREE_OVERFLOW_KEY, file_init_page_type(), file_init_temp_page_type(), FILE_MULTIPAGE_OBJECT_HEAP, FILE_TEMP, free_and_init, i, overflow_first_part::length, recdes::length, log_append_empty_record(), log_append_redo_data(), LOG_DUMMY_OVF_RECORD, log_sysop_abort(), log_sysop_attach_to_outer(), log_sysop_start(), overflow_first_part::next_vpid, overflow_rest_part::next_vpid, NO_ERROR, NULL, log_data_addr::offset, OLD_PAGE, OVERFLOW_ALLOCVPID_ARRAY_SIZE, PAGE_OVERFLOW, pgbuf_check_page_ptype(), pgbuf_fix, PGBUF_LATCH_WRITE, pgbuf_set_dirty_and_free, PGBUF_UNCONDITIONAL_LATCH, log_data_addr::pgptr, RVOVF_NEWPAGE_INSERT, log_data_addr::vfid, VFID_ISNULL, VPID_ISNULL, and VPID_SET_NULL.

Referenced by btree_store_overflow_key(), ehash_insert_to_bucket(), heap_ovf_insert(), and sort_inphase_sort().

Here is the caller graph for this function:

static void overflow_next_vpid ( const VPID *  ovf_vpid, VPID *  vpid, PAGE_PTR  pgptr  )

static

Definition at line 287 of file overflow_file.c.

References VPID_EQ.

Referenced by overflow_traverse().

Here is the caller graph for this function:

int overflow_rv_link	(	THREAD_ENTRY *	thread_p,
		LOG_RCV *	rcv
	)

Definition at line 1140 of file overflow_file.c.

References log_rcv::data, DONT_FREE, overflow_rest_part::next_vpid, NO_ERROR, pgbuf_set_dirty(), and log_rcv::pgptr.

void overflow_rv_link_dump	(	FILE *	fp,
		int	length_ignore,
		void *	data
	)

Definition at line 1160 of file overflow_file.c.

References vpid::pageid, and vpid::volid.

int overflow_rv_newpage_insert_redo	(	THREAD_ENTRY *	thread_p,
		LOG_RCV *	rcv
	)

Definition at line 1108 of file overflow_file.c.

References log_rv_copy_char().

int overflow_rv_newpage_link_undo	(	THREAD_ENTRY *	thread_p,
		LOG_RCV *	rcv
	)

Definition at line 1120 of file overflow_file.c.

References DONT_FREE, overflow_rest_part::next_vpid, NO_ERROR, pgbuf_set_dirty(), log_rcv::pgptr, and VPID_SET_NULL.

void overflow_rv_page_dump	(	FILE *	fp,
		int	length,
		void *	data
	)

Definition at line 1188 of file overflow_file.c.

References log_rv_dump_char(), overflow_rest_part::next_vpid, vpid::pageid, and vpid::volid.

int overflow_rv_page_update_redo	(	THREAD_ENTRY *	thread_p,
		LOG_RCV *	rcv
	)

Definition at line 1174 of file overflow_file.c.

References log_rv_copy_char(), PAGE_OVERFLOW, pgbuf_set_page_ptype(), and log_rcv::pgptr.

static const VPID * overflow_traverse ( THREAD_ENTRY *  thread_p, const VFID *  ovf_vfid, const VPID *  ovf_vpid, OVERFLOW_DO_FUNC  func  )

static

Definition at line 308 of file overflow_file.c.

References overflow_first_part::next_vpid, NO_ERROR, NULL, OLD_PAGE, overflow_delete_internal(), OVERFLOW_DO_DELETE, OVERFLOW_DO_FLUSH, overflow_flush_internal(), overflow_next_vpid(), PAGE_OVERFLOW, pgbuf_check_page_ptype(), pgbuf_fix, PGBUF_LATCH_WRITE, PGBUF_UNCONDITIONAL_LATCH, and VPID_ISNULL.

Referenced by overflow_delete(), and overflow_flush().

Here is the caller graph for this function:

int overflow_update	(	THREAD_ENTRY *	thread_p,
		const VFID *	ovf_vfid,
		const VPID *	ovf_vpid,
		RECDES *	recdes,
		FILE_TYPE	file_type
	)

Definition at line 383 of file overflow_file.c.

References assert, ASSERT_ERROR, ASSERT_ERROR_AND_SET, overflow_first_part::data, overflow_rest_part::data, recdes::data, DB_PAGESIZE, file_alloc(), file_dealloc(), file_init_page_type(), FILE_MULTIPAGE_OBJECT_HEAP, overflow_first_part::length, recdes::length, log_append_empty_record(), log_append_redo_data(), log_append_undo_data(), log_append_undoredo_data(), LOG_DUMMY_OVF_RECORD, log_sysop_abort(), log_sysop_attach_to_outer(), log_sysop_start(), overflow_first_part::next_vpid, overflow_rest_part::next_vpid, NO_ERROR, NULL, log_data_addr::offset, OLD_PAGE, PAGE_OVERFLOW, pgbuf_check_page_ptype(), pgbuf_fix, pgbuf_get_vpid_ptr(), PGBUF_LATCH_WRITE, pgbuf_set_dirty_and_free, PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix_and_init, log_data_addr::pgptr, RVOVF_CHANGE_LINK, RVOVF_NEWPAGE_LINK, RVOVF_PAGE_UPDATE, log_data_addr::vfid, VFID_ISNULL, VPID_EQ, VPID_ISNULL, and VPID_SET_NULL.

Referenced by heap_ovf_update().

Here is the caller graph for this function: