#include "config.h"
#include <stdlib.h>
#include <stddef.h>
#include <string.h>
#include <assert.h>
#include "page_buffer.h"
#include "storage_common.h"
#include "memory_alloc.h"
#include "system_parameter.h"
#include "error_manager.h"
#include "file_io.h"
#include "lockfree_circular_queue.hpp"
#include "log_append.hpp"
#include "log_manager.h"
#include "log_impl.h"
#include "log_volids.hpp"
#include "transaction_sr.h"
#include "memory_hash.h"
#include "critical_section.h"
#include "perf_monitor.h"
#include "porting_inline.hpp"
#include "environment_variable.h"
#include "thread_daemon.hpp"
#include "thread_entry_task.hpp"
#include "thread_manager.hpp"
#include "list_file.h"
#include "tsc_timer.h"
#include "query_manager.h"
#include "xserver_interface.h"
#include "btree_load.h"
#include "boot_sr.h"
#include "double_write_buffer.h"
#include "resource_tracker.hpp"
#include "tde.h"
#include "show_scan.h"
#include "numeric_opfunc.h"
#include "dbtype.h"
#include "thread_entry.hpp"

Classes
struct	pgbuf_status

struct	pgbuf_status_snapshot

struct	pgbuf_status_old

struct	pgbuf_holder_info

struct	pgbuf_holder_stat

struct	pgbuf_batch_flush_helper

struct	pgbuf_holder

struct	pgbuf_holder_anchor

struct	pgbuf_holder_set

struct	pgbuf_bcb

struct	pgbuf_iopage_buffer

struct	pgbuf_buffer_lock

struct	pgbuf_buffer_hash

struct	pgbuf_lru_list

struct	pgbuf_invalid_list

struct	pgbuf_aout_buf

struct	pgbuf_aout_list

struct	pgbuf_seq_flusher

struct	pgbuf_page_monitor

struct	pgbuf_page_quota

struct	pgbuf_buffer_pool

struct	pgbuf_victim_candidate_list

struct	pgbuf_monitor_bcb_mutex

struct	pgbuf_fix_perf

struct	pgbuf_dealloc_undo_data

Macros
#define	PGBUF_MINIMUM_BUFFERS (MAX_NTRANS * 10)

#define	PGBUF_DEFAULT_FIX_COUNT 7

#define	PGBUF_NUM_ALLOC_HOLDER 10

#define	pthread_mutex_init(a, b)

#define	pthread_mutex_destroy(a)

#define	pthread_mutex_lock(a) 0

#define	pthread_mutex_unlock(a)

#define	PGBUF_TIMEOUT 300 /* timeout seconds */

#define	PGBUF_FIX_COUNT_THRESHOLD 64 /* fix count threshold. used as indicator for hot pages. */

#define	SIZEOF_IOPAGE_PAGESIZE_AND_GUARD() (IO_PAGESIZE)

#define	PGBUF_BCB_SIZEOF (sizeof (PGBUF_BCB))

#define	PGBUF_IOPAGE_BUFFER_SIZE

#define	PGBUF_BUFFER_HASH_SIZEOF (sizeof (PGBUF_BUFFER_HASH))

#define	PGBUF_BUFFER_LOCK_SIZEOF (sizeof (PGBUF_BUFFER_LOCK))

#define	PGBUF_LRU_LIST_SIZEOF (sizeof (PGBUF_LRU_LIST))

#define	PGBUF_HOLDER_SIZEOF (sizeof (PGBUF_HOLDER))

#define	PGBUF_HOLDER_SET_SIZEOF (sizeof (PGBUF_HOLDER_SET))

#define	PGBUF_HOLDER_ANCHOR_SIZEOF (sizeof (PGBUF_HOLDER_ANCHOR))

#define	PGBUF_FIND_BCB_PTR(i) ((PGBUF_BCB ) ((char ) &(pgbuf_Pool.BCB_table[0]) + (PGBUF_BCB_SIZEOF * (i))))

#define	PGBUF_FIND_IOPAGE_PTR(i) ((PGBUF_IOPAGE_BUFFER ) ((char ) &(pgbuf_Pool.iopage_table[0]) + (PGBUF_IOPAGE_BUFFER_SIZE * (i))))

#define	PGBUF_FIND_BUFFER_GUARD(bufptr) (&bufptr->iopage_buffer->iopage.page[DB_PAGESIZE])

#define	CAST_PGPTR_TO_BFPTR(bufptr, pgptr)

#define	CAST_PGPTR_TO_IOPGPTR(io_pgptr, pgptr)

#define	CAST_IOPGPTR_TO_PGPTR(pgptr, io_pgptr)

#define	CAST_BFPTR_TO_PGPTR(pgptr, bufptr)

#define	PGBUF_IS_AUXILIARY_VOLUME(volid) ((volid) < LOG_DBFIRST_VOLID ? true : false)

#define	PGBUF_LRU_NBITS 16

#define	PGBUF_LRU_LIST_MAX_COUNT ((int) 1 << PGBUF_LRU_NBITS) /* 64k */

#define	PGBUF_LRU_INDEX_MASK (PGBUF_LRU_LIST_MAX_COUNT - 1) /* 0x0000FFFF */

#define	PGBUF_MAKE_ZONE(list_id, zone) ((list_id) \| (zone))

#define	PGBUF_GET_ZONE(flags) ((PGBUF_ZONE) ((flags) & PGBUF_ZONE_MASK))

#define	PGBUF_GET_LRU_INDEX(flags) ((flags) & PGBUF_LRU_INDEX_MASK)

#define	PGBUF_BCB_DIRTY_FLAG ((int) 0x80000000)

#define	PGBUF_BCB_FLUSHING_TO_DISK_FLAG ((int) 0x40000000)

#define	PGBUF_BCB_VICTIM_DIRECT_FLAG ((int) 0x20000000)

#define	PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG ((int) 0x10000000)

#define	PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG ((int) 0x08000000)

#define	PGBUF_BCB_TO_VACUUM_FLAG ((int) 0x04000000)

#define	PGBUF_BCB_ASYNC_FLUSH_REQ ((int) 0x02000000)

#define	PGBUF_BCB_FLAGS_MASK

#define	PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK

#define	PGBUF_BCB_INIT_FLAGS PGBUF_INVALID_ZONE

#define	PGBUF_BCB_COUNT_FIX_SHIFT_BITS 16

#define	PGBUF_BCB_AVOID_DEALLOC_MASK ((int) 0x0000FFFF)

#define	PGBUF_TRAN_THRESHOLD_ACTIVITY (pgbuf_Pool.num_buffers / 4)

#define	PGBUF_TRAN_MAX_ACTIVITY (10 * PGBUF_TRAN_THRESHOLD_ACTIVITY)

#define	PGBUF_AOUT_NOT_FOUND -2

#define	PGBUF_THREAD_SHOULD_IGNORE_UNFIX(th) false

#define	HASH_SIZE_BITS 20

#define	PGBUF_HASH_SIZE (1 << HASH_SIZE_BITS)

#define	PGBUF_HASH_VALUE(vpid) pgbuf_hash_func_mirror(vpid)

#define	PGBUF_FLUSH_VICTIM_BOOST_MULT 10

#define	PGBUF_NEIGHBOR_FLUSH_NONDIRTY (prm_get_bool_value (PRM_ID_PB_NEIGHBOR_FLUSH_NONDIRTY))

#define	PGBUF_MAX_NEIGHBOR_PAGES 32

#define	PGBUF_NEIGHBOR_PAGES (prm_get_integer_value (PRM_ID_PB_NEIGHBOR_FLUSH_PAGES))

#define	PGBUF_NEIGHBOR_POS(idx) (PGBUF_NEIGHBOR_PAGES - 1 + (idx))

#define	PGBUF_MAX_PAGE_WATCHERS 64

#define	PGBUF_MAX_PAGE_FIXED_BY_TRAN 64

#define	PGBUF_CHKPT_MAX_FLUSH_RATE 1200

#define	PGBUF_CHKPT_MIN_FLUSH_RATE 50

#define	PGBUF_CHKPT_BURST_PAGES 16

#define	INIT_HOLDER_STAT(perf_stat)

#define	PGBUF_LRU_ZONE_MIN_RATIO 0.05f

#define	PGBUF_LRU_ZONE_MAX_RATIO 0.90f

#define	AOUT_HASH_DIVIDE_RATIO 1000

#define	AOUT_HASH_IDX(vpid, list) ((vpid)->pageid % list->num_hashes)

#define	PGBUF_BCB_LOCK(bcb)

#define	PGBUF_BCB_TRYLOCK(bcb) (0)

#define	PGBUF_BCB_UNLOCK(bcb)

#define	PGBUF_BCB_CHECK_OWN(bcb) (true)

#define	PGBUF_BCB_CHECK_MUTEX_LEAKS()

#define	PGBUF_GET_LRU_LIST(lru_idx) (&pgbuf_Pool.buf_LRU_list[lru_idx])

#define	PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE(bcb) (pgbuf_bcb_get_zone (bcb) == PGBUF_LRU_3_ZONE)

#define	PGBUF_IS_BCB_IN_LRU(bcb) ((pgbuf_bcb_get_zone (bcb) & PGBUF_LRU_ZONE_MASK) != 0)

#define	PGBUF_AGE_DIFF(bcb_age, list_age) (((list_age) >= (bcb_age)) ? ((list_age) - (bcb_age)) : (DB_INT32_MAX - ((bcb_age) - (list_age))))

#define	PGBUF_IS_BCB_OLD_ENOUGH(bcb, lru_list) (PGBUF_AGE_DIFF ((bcb)->tick_lru_list, (lru_list)->tick_list) >= ((lru_list)->count_lru2 / 2))

#define	PGBUF_LRU_ZONE_ONE_TWO_COUNT(list) ((list)->count_lru1 + (list)->count_lru2)

#define	PGBUF_LRU_LIST_COUNT(list) (PGBUF_LRU_ZONE_ONE_TWO_COUNT(list) + (list)->count_lru3)

#define	PGBUF_LRU_VICTIM_ZONE_COUNT(list) ((list)->count_lru3)

#define	PGBUF_LRU_IS_ZONE_ONE_OVER_THRESHOLD(list) ((list)->threshold_lru1 < (list)->count_lru1)

#define	PGBUF_LRU_IS_ZONE_TWO_OVER_THRESHOLD(list) ((list)->threshold_lru2 < (list)->count_lru2)

#define	PGBUF_LRU_ARE_ZONES_ONE_TWO_OVER_THRESHOLD(list) ((list)->threshold_lru1 + (list)->threshold_lru2 < PGBUF_LRU_ZONE_ONE_TWO_COUNT(list))

#define	PGBUF_PRIVATE_LRU_MIN_COUNT 4

#define	PGBUF_PRIVATE_LRU_MAX_HARD_QUOTA 5000

#define	PGBUF_MIN_PAGES_IN_SHARED_LIST 1000

#define	PGBUF_MIN_SHARED_LIST_ADJUST_SIZE 50

#define	PGBUF_PAGE_QUOTA_IS_ENABLED (pgbuf_Pool.quota.num_private_LRU_list > 0)

#define	PGBUF_PRIVATE_LRU_FROM_THREAD(thread_p) 0

#define	PGBUF_THREAD_HAS_PRIVATE_LRU(thread_p) false

#define	PGBUF_SHARED_LRU_COUNT (pgbuf_Pool.num_LRU_list)

#define	PGBUF_PRIVATE_LRU_COUNT (pgbuf_Pool.quota.num_private_LRU_list)

#define	PGBUF_TOTAL_LRU_COUNT (PGBUF_SHARED_LRU_COUNT + PGBUF_PRIVATE_LRU_COUNT)

#define	PGBUF_PRIVATE_LIST_FROM_LRU_INDEX(i) ((i) - PGBUF_SHARED_LRU_COUNT)

#define	PGBUF_LRU_INDEX_FROM_PRIVATE(private_id) (PGBUF_SHARED_LRU_COUNT + (private_id))

#define	PGBUF_IS_SHARED_LRU_INDEX(lru_idx) ((lru_idx) < PGBUF_SHARED_LRU_COUNT)

#define	PGBUF_IS_PRIVATE_LRU_INDEX(lru_idx) ((lru_idx) >= PGBUF_SHARED_LRU_COUNT)

#define	PGBUF_LRU_LIST_IS_OVER_QUOTA(list) (PGBUF_LRU_LIST_COUNT (list) > (list)->quota)

#define	PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA(list) ((PGBUF_LRU_ZONE_ONE_TWO_COUNT (list) > (list)->quota))

#define	PGBUF_LRU_LIST_OVER_QUOTA_COUNT(list) (PGBUF_LRU_LIST_COUNT (list) - (list)->quota)

#define	PGBUF_IS_PRIVATE_LRU_OVER_QUOTA(lru_idx) (PGBUF_IS_PRIVATE_LRU_INDEX (lru_idx) && PGBUF_LRU_LIST_IS_OVER_QUOTA (PGBUF_GET_LRU_LIST (lru_idx)))

#define	PGBUF_IS_PRIVATE_LRU_ONE_TWO_OVER_QUOTA(lru_idx) (PGBUF_IS_PRIVATE_LRU_INDEX (lru_idx) && PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA (PGBUF_GET_LRU_LIST (lru_idx)))

#define	PGBUF_OVER_QUOTA_BUFFER(quota) MAX (10, (int) (quota * 0.01f))

#define	PGBUF_LRU_LIST_IS_OVER_QUOTA_WITH_BUFFER(list) (PGBUF_LRU_LIST_COUNT (list) > (list)->quota + PGBUF_OVER_QUOTA_BUFFER ((list)->quota))

#define	PBGUF_BIG_PRIVATE_MIN_SIZE 100

#define	PGBUF_LRU_VICTIM_LFCQ_FLAG ((int) 0x80000000)

#define	PGBUF_ABORT_RELEASE() assert (false)

#define	VOLID_LSB_BITS 8

#define	detailed_er_log(...) if (detailed_logging) _er_log_debug (ARG_FILE_LINE, __VA_ARGS__)

#define	WAIT_FLUSH_VICTIMS_MAX_MSEC 1500.0f

#define	detailed_er_log(...) if (detailed_logging) _er_log_debug (ARG_FILE_LINE, __VA_ARGS__)

#define	PGBUF_LIMIT_AOUT_BUFFERS 32768

#define	PAGE_ADD_REFRESH_STAT MAX (2 * pgbuf_Pool.num_buffers / PGBUF_SHARED_LRU_COUNT, 10000)

#define	PERF(id) if (detailed_perf) perfmon_inc_stat (thread_p, id)

#define	PERF(pstatid) if (perf_tracking) perfmon_inc_stat (thread_p, pstatid)

#define	MAX_DEPTH 1000

#define	PGBUF_PAGES_COUNT_THRESHOLD 4

#define	MAX_PRIVATE_RATIO 0.998f

#define	MIN_PRIVATE_RATIO 0.01f

#define	PERF(id) if (detailed_perf) perfmon_inc_stat (thread_p, id)

#define	PERF(id) if (detailed_perf) perfmon_inc_stat (thread_p, id)

#define	PGBUF_MIN_VICTIM_REQ 10 /* set a minimum number of requests */

#define	PGBUF_DESIRED_HIT_VS_MISS_RATE 1000 /* 99.9% hit ratio */

Typedefs
typedef struct pgbuf_holder	PGBUF_HOLDER

typedef struct pgbuf_holder_anchor	PGBUF_HOLDER_ANCHOR

typedef struct pgbuf_holder_set	PGBUF_HOLDER_SET

typedef struct pgbuf_bcb	PGBUF_BCB

typedef struct pgbuf_iopage_buffer	PGBUF_IOPAGE_BUFFER

typedef struct pgbuf_aout_buf	PGBUF_AOUT_BUF

typedef struct pgbuf_buffer_lock	PGBUF_BUFFER_LOCK

typedef struct pgbuf_buffer_hash	PGBUF_BUFFER_HASH

typedef struct pgbuf_lru_list	PGBUF_LRU_LIST

typedef struct pgbuf_aout_list	PGBUF_AOUT_LIST

typedef struct pgbuf_seq_flusher	PGBUF_SEQ_FLUSHER

typedef struct pgbuf_invalid_list	PGBUF_INVALID_LIST

typedef struct pgbuf_victim_candidate_list	PGBUF_VICTIM_CANDIDATE_LIST

typedef struct pgbuf_buffer_pool	PGBUF_BUFFER_POOL

typedef struct pgbuf_monitor_bcb_mutex	PGBUF_MONITOR_BCB_MUTEX

typedef struct pgbuf_holder_info	PGBUF_HOLDER_INFO

typedef struct pgbuf_status	PGBUF_STATUS

typedef struct pgbuf_status_snapshot	PGBUF_STATUS_SNAPSHOT

typedef struct pgbuf_status_old	PGBUF_STATUS_OLD

typedef struct pgbuf_holder_stat	PGBUF_HOLDER_STAT

typedef struct pgbuf_batch_flush_helper	PGBUF_BATCH_FLUSH_HELPER

typedef struct pgbuf_page_monitor	PGBUF_PAGE_MONITOR

typedef struct pgbuf_page_quota	PGBUF_PAGE_QUOTA

typedef struct pgbuf_fix_perf	PGBUF_FIX_PERF

typedef struct pgbuf_dealloc_undo_data	PGBUF_DEALLOC_UNDO_DATA

Enumerations
enum	PGBUF_ZONE { PGBUF_LRU_1_ZONE = 1 << PGBUF_LRU_NBITS, PGBUF_LRU_2_ZONE = 2 << PGBUF_LRU_NBITS, PGBUF_LRU_3_ZONE = 3 << PGBUF_LRU_NBITS, PGBUF_LRU_ZONE_MASK = PGBUF_LRU_1_ZONE \| PGBUF_LRU_2_ZONE \| PGBUF_LRU_3_ZONE, PGBUF_INVALID_ZONE = 1 << (PGBUF_LRU_NBITS + 2), PGBUF_VOID_ZONE = 2 << (PGBUF_LRU_NBITS + 2), PGBUF_ZONE_MASK = (PGBUF_LRU_ZONE_MASK \| PGBUF_INVALID_ZONE \| PGBUF_VOID_ZONE) }

enum	{ PGBUF_LOCK_WAITER = 0, PGBUF_LOCK_HOLDER }

enum	{ PGBUF_CONTENT_BAD = 0, PGBUF_CONTENT_GOOD, PGBUF_CONTENT_LIKELY_BAD, PGBUF_CONTENT_ERROR }

enum	{ NEIGHBOR_ABORT_RANGE = 1, NEIGHBOR_ABORT_NOTFOUND_NONDIRTY_BACK, NEIGHBOR_ABORT_NOTFOUND_DIRTY_BACK, NEIGHBOR_ABORT_LATCH_NONDIRTY_BACK, NEIGHBOR_ABORT_LATCH_DIRTY_BACK, NEIGHBOR_ABORT_NONDIRTY_NOT_ALLOWED, NEIGHBOR_ABORT_TWO_CONSECTIVE_NONDIRTIES, NEIGHBOR_ABORT_TOO_MANY_NONDIRTIES }

Functions
static INLINE unsigned int	pgbuf_hash_func_mirror (const VPID *vpid) __attribute__((ALWAYS_INLINE))

static INLINE bool	pgbuf_is_temporary_volume (VOLID volid) __attribute__((ALWAYS_INLINE))

static int	pgbuf_initialize_bcb_table (void)

static int	pgbuf_initialize_hash_table (void)

static int	pgbuf_initialize_lock_table (void)

static int	pgbuf_initialize_lru_list (void)

static int	pgbuf_initialize_aout_list (void)

static int	pgbuf_initialize_invalid_list (void)

static int	pgbuf_initialize_page_quota_parameters (void)

static int	pgbuf_initialize_page_quota (void)

static int	pgbuf_initialize_page_monitor (void)

static int	pgbuf_initialize_thrd_holder (void)

STATIC_INLINE PGBUF_HOLDER *	pgbuf_allocate_thrd_holder_entry (THREAD_ENTRY *thread_p) __attribute__((ALWAYS_INLINE))

STATIC_INLINE PGBUF_HOLDER *	pgbuf_find_thrd_holder (THREAD_ENTRY thread_p, PGBUF_BCB bufptr) __attribute__((ALWAYS_INLINE))

STATIC_INLINE int	pgbuf_remove_thrd_holder (THREAD_ENTRY thread_p, PGBUF_HOLDER holder) __attribute__((ALWAYS_INLINE))

STATIC_INLINE int	pgbuf_unlatch_thrd_holder (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, PGBUF_HOLDER_STAT *holder_perf_stat_p) __attribute__((ALWAYS_INLINE))

STATIC_INLINE int	pgbuf_unlatch_bcb_upon_unfix (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, int holder_status) __attribute__((ALWAYS_INLINE))

static void	pgbuf_unlatch_void_zone_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int thread_private_lru_index)

STATIC_INLINE bool	pgbuf_should_move_private_to_shared (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int thread_private_lru_index) __attribute__((ALWAYS_INLINE))

static int	pgbuf_block_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, PGBUF_LATCH_MODE request_mode, int request_fcnt, bool as_promote)

STATIC_INLINE int	pgbuf_latch_bcb_upon_fix (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, PGBUF_LATCH_MODE request_mode, int buf_lock_acquired, PGBUF_LATCH_CONDITION condition, bool *is_latch_wait) __attribute__((ALWAYS_INLINE))

static int	pgbuf_latch_idle_page (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, PGBUF_LATCH_MODE request_mode)

STATIC_INLINE PGBUF_BCB *	pgbuf_search_hash_chain (THREAD_ENTRY thread_p, PGBUF_BUFFER_HASH hash_anchor, const VPID *vpid) __attribute__((ALWAYS_INLINE))

STATIC_INLINE int	pgbuf_insert_into_hash_chain (THREAD_ENTRY thread_p, PGBUF_BUFFER_HASH hash_anchor, PGBUF_BCB *bufptr) __attribute__((ALWAYS_INLINE))

STATIC_INLINE int	pgbuf_delete_from_hash_chain (THREAD_ENTRY thread_p, PGBUF_BCB bufptr) __attribute__((ALWAYS_INLINE))

static int	pgbuf_lock_page (THREAD_ENTRY thread_p, PGBUF_BUFFER_HASH hash_anchor, const VPID *vpid)

static int	pgbuf_unlock_page (THREAD_ENTRY thread_p, PGBUF_BUFFER_HASH hash_anchor, const VPID *vpid, int need_hash_mutex)

static PGBUF_BCB *	pgbuf_allocate_bcb (THREAD_ENTRY thread_p, const VPID src_vpid)

static PGBUF_BCB *	pgbuf_claim_bcb_for_fix (THREAD_ENTRY thread_p, const VPID vpid, PAGE_FETCH_MODE fetch_mode, PGBUF_BUFFER_HASH hash_anchor, PGBUF_FIX_PERF perf, bool *try_again)

static int	pgbuf_victimize_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bufptr)

static int	pgbuf_bcb_safe_flush_internal (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, bool synchronous, bool *locked)

static int	pgbuf_invalidate_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bufptr)

static int	pgbuf_bcb_safe_flush_force_lock (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, bool synchronous)

static int	pgbuf_bcb_safe_flush_force_unlock (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, bool synchronous)

static PGBUF_BCB *	pgbuf_get_bcb_from_invalid_list (THREAD_ENTRY *thread_p)

static int	pgbuf_put_bcb_into_invalid_list (THREAD_ENTRY thread_p, PGBUF_BCB bufptr)

STATIC_INLINE int	pgbuf_get_shared_lru_index_for_add (void)

unsigned int	pgbuf_hash_vpid (const void *key_vpid, unsigned int htsize)

int	pgbuf_compare_vpid (const void key_vpid1, const void key_vpid2)

int	pgbuf_initialize (void)

void	pgbuf_finalize (void)

PAGE_PTR	pgbuf_fix_with_retry (THREAD_ENTRY thread_p, const VPID vpid, PAGE_FETCH_MODE fetch_mode, PGBUF_LATCH_MODE request_mode, int retry)

PAGE_PTR	pgbuf_fix_debug (THREAD_ENTRY thread_p, const VPID vpid, PAGE_FETCH_MODE fetch_mode, PGBUF_LATCH_MODE request_mode, PGBUF_LATCH_CONDITION condition, const char *caller_file, int caller_line)

int	pgbuf_promote_read_latch_debug (THREAD_ENTRY thread_p, PAGE_PTR pgptr_p, PGBUF_PROMOTE_CONDITION condition, const char *caller_file, int caller_line)

void	pgbuf_unfix_debug (THREAD_ENTRY thread_p, PAGE_PTR pgptr, const char caller_file, int caller_line)

void	pgbuf_unfix_all (THREAD_ENTRY *thread_p)

int	pgbuf_invalidate_debug (THREAD_ENTRY thread_p, PAGE_PTR pgptr, const char caller_file, int caller_line)

int	pgbuf_invalidate_all_debug (THREAD_ENTRY thread_p, VOLID volid, const char caller_file, int caller_line)

void	pgbuf_flush (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, bool free_page)

PAGE_PTR	pgbuf_flush_with_wal (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)

void	pgbuf_flush_if_requested (THREAD_ENTRY *thread_p, PAGE_PTR page)

static int	pgbuf_flush_all_helper (THREAD_ENTRY *thread_p, VOLID volid, bool is_unfixed_only, bool is_set_lsa_as_null)

int	pgbuf_flush_all (THREAD_ENTRY *thread_p, VOLID volid)

int	pgbuf_flush_all_unfixed (THREAD_ENTRY *thread_p, VOLID volid)

int	pgbuf_flush_all_unfixed_and_set_lsa_as_null (THREAD_ENTRY *thread_p, VOLID volid)

static int	pgbuf_compare_victim_list (const void p1, const void p2)

static int	pgbuf_get_victim_candidates_from_lru (THREAD_ENTRY thread_p, int check_count, float lru_sum_flush_priority, bool assigned_directly)

int	pgbuf_flush_victim_candidates (THREAD_ENTRY thread_p, float flush_ratio, PERF_UTIME_TRACKER perf_tracker, bool *stop)

int	pgbuf_flush_checkpoint (THREAD_ENTRY thread_p, const LOG_LSA flush_upto_lsa, const LOG_LSA prev_chkpt_redo_lsa, LOG_LSA smallest_lsa, int *flushed_page_cnt)

static int	pgbuf_flush_chkpt_seq_list (THREAD_ENTRY thread_p, PGBUF_SEQ_FLUSHER seq_flusher, const LOG_LSA prev_chkpt_redo_lsa, LOG_LSA chkpt_smallest_lsa)

static int	pgbuf_flush_seq_list (THREAD_ENTRY thread_p, PGBUF_SEQ_FLUSHER seq_flusher, struct timeval limit_time, const LOG_LSA prev_chkpt_redo_lsa, LOG_LSA chkpt_smallest_lsa, int time_rem)

void *	pgbuf_copy_to_area (THREAD_ENTRY thread_p, const VPID vpid, int start_offset, int length, void *area, bool do_fetch)

void *	pgbuf_copy_from_area (THREAD_ENTRY thread_p, const VPID vpid, int start_offset, int length, void *area, bool do_fetch, TDE_ALGORITHM tde_algo)

void	pgbuf_set_dirty (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, bool free_page)

LOG_LSA *	pgbuf_get_lsa (PAGE_PTR pgptr)

int	pgbuf_page_has_changed (PAGE_PTR pgptr, LOG_LSA *ref_lsa)

const LOG_LSA *	pgbuf_set_lsa (THREAD_ENTRY thread_p, PAGE_PTR pgptr, const LOG_LSA lsa_ptr)

void	pgbuf_reset_temp_lsa (PAGE_PTR pgptr)

void	pgbuf_set_tde_algorithm (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, TDE_ALGORITHM tde_algo, bool skip_logging)

int	pgbuf_rv_set_tde_algorithm (THREAD_ENTRY thread_p, LOG_RCV rcv)

TDE_ALGORITHM	pgbuf_get_tde_algorithm (PAGE_PTR pgptr)

void	pgbuf_get_vpid (PAGE_PTR pgptr, VPID *vpid)

VPID *	pgbuf_get_vpid_ptr (PAGE_PTR pgptr)

PGBUF_LATCH_MODE	pgbuf_get_latch_mode (PAGE_PTR pgptr)

PAGEID	pgbuf_get_page_id (PAGE_PTR pgptr)

PAGE_TYPE	pgbuf_get_page_ptype (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)

VOLID	pgbuf_get_volume_id (PAGE_PTR pgptr)

const char *	pgbuf_get_volume_label (PAGE_PTR pgptr)

void	pgbuf_force_to_check_for_interrupts (void)

bool	pgbuf_is_log_check_for_interrupts (THREAD_ENTRY *thread_p)

void	pgbuf_set_lsa_as_temporary (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)

STATIC_INLINE void	pgbuf_set_bcb_page_vpid (PGBUF_BCB *bufptr, bool force_set_vpid)

void	pgbuf_set_page_ptype (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, PAGE_TYPE ptype)

bool	pgbuf_is_lsa_temporary (PAGE_PTR pgptr)

static PGBUF_BCB *	pgbuf_get_victim (THREAD_ENTRY *thread_p)

STATIC_INLINE bool	pgbuf_is_bcb_fixed_by_any (PGBUF_BCB *bcb, bool has_mutex_lock)

STATIC_INLINE bool	pgbuf_is_bcb_victimizable (PGBUF_BCB *bcb, bool has_mutex_lock)

static PGBUF_BCB *	pgbuf_get_victim_from_lru_list (THREAD_ENTRY *thread_p, const int lru_idx)

STATIC_INLINE void	pgbuf_lru_add_bcb_to_top (THREAD_ENTRY thread_p, PGBUF_BCB bcb, PGBUF_LRU_LIST *lru_list)

STATIC_INLINE void	pgbuf_lru_add_bcb_to_middle (THREAD_ENTRY thread_p, PGBUF_BCB bcb, PGBUF_LRU_LIST *lru_list)

STATIC_INLINE void	pgbuf_lru_add_bcb_to_bottom (THREAD_ENTRY thread_p, PGBUF_BCB bcb, PGBUF_LRU_LIST *lru_list)

STATIC_INLINE void	pgbuf_lru_adjust_zone1 (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, bool min_one)

STATIC_INLINE void	pgbuf_lru_adjust_zone2 (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, bool min_one)

STATIC_INLINE void	pgbuf_lru_adjust_zones (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, bool min_one)

STATIC_INLINE void	pgbuf_lru_fall_bcb_to_zone_3 (THREAD_ENTRY thread_p, PGBUF_BCB bcb, PGBUF_LRU_LIST *lru_list)

static void	pgbuf_lru_boost_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_lru_add_new_bcb_to_top (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int lru_idx)

STATIC_INLINE void	pgbuf_lru_add_new_bcb_to_middle (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int lru_idx)

STATIC_INLINE void	pgbuf_lru_add_new_bcb_to_bottom (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int lru_idx)

STATIC_INLINE void	pgbuf_lru_remove_bcb (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

static void	pgbuf_lru_move_from_private_to_shared (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_remove_from_lru_list (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, PGBUF_LRU_LIST *lru_list)

static void	pgbuf_move_bcb_to_bottom_lru (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_add_vpid_to_aout_list (THREAD_ENTRY thread_p, const VPID vpid, const int lru_idx)

static int	pgbuf_remove_vpid_from_aout_list (THREAD_ENTRY thread_p, const VPID vpid)

static int	pgbuf_remove_private_from_aout_list (const int lru_idx)

STATIC_INLINE int	pgbuf_bcb_flush_with_wal (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, bool is_page_flush_thread, bool *is_bcb_locked)

static void	pgbuf_wake_flush_waiters (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE bool	pgbuf_is_exist_blocked_reader_writer (PGBUF_BCB *bufptr)

STATIC_INLINE bool	pgbuf_get_check_page_validation_level (int page_validation_level)

DISK_ISVALID	pgbuf_is_valid_page (THREAD_ENTRY thread_p, const VPID vpid, bool no_error, DISK_ISVALID(fun)(const VPID vpid, void args), void args)

static bool	pgbuf_is_valid_page_ptr (const PAGE_PTR pgptr)

bool	pgbuf_check_page_ptype (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, PAGE_TYPE ptype)

bool	pgbuf_check_page_type_no_error (THREAD_ENTRY *thread_p, PAGE_PTR pgptr, PAGE_TYPE ptype)

STATIC_INLINE bool	pgbuf_check_page_ptype_internal (PAGE_PTR pgptr, PAGE_TYPE ptype, bool no_error)

STATIC_INLINE bool	pgbuf_check_bcb_page_vpid (PGBUF_BCB *bufptr, bool maybe_deallocated)

static void	pgbuf_add_fixed_at (PGBUF_HOLDER holder, const char caller_file, int caller_line, bool reset)

STATIC_INLINE void	pgbuf_set_dirty_buffer_ptr (THREAD_ENTRY thread_p, PGBUF_BCB bufptr)

static void	pgbuf_wakeup_page_flush_daemon (THREAD_ENTRY *thread_p)

bool	pgbuf_has_perm_pages_fixed (THREAD_ENTRY *thread_p)

static int	pgbuf_flush_page_and_neighbors_fb (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, int *flushed_pages)

STATIC_INLINE void	pgbuf_add_bufptr_to_batch (PGBUF_BCB *bufptr, int idx)

STATIC_INLINE int	pgbuf_flush_neighbor_safe (THREAD_ENTRY thread_p, PGBUF_BCB bufptr, VPID expected_vpid, bool flushed)

static int	pgbuf_compare_hold_vpid_for_sort (const void p1, const void p2)

int	pgbuf_ordered_fix_debug (THREAD_ENTRY thread_p, const VPID req_vpid, PAGE_FETCH_MODE fetch_mode, const PGBUF_LATCH_MODE request_mode, PGBUF_WATCHER req_watcher, const char caller_file, int caller_line)

static int	pgbuf_get_groupid_and_unfix (THREAD_ENTRY thread_p, const VPID req_vpid, PAGE_PTR pgptr, VPID groupid, bool do_unfix)

void	pgbuf_ordered_unfix_debug (THREAD_ENTRY thread_p, PGBUF_WATCHER watcher_object, const char *caller_file, int caller_line)

STATIC_INLINE void	pgbuf_add_watch_instance_internal (PGBUF_HOLDER holder, PAGE_PTR pgptr, PGBUF_WATCHER watcher, const PGBUF_LATCH_MODE latch_mode, const bool clear_unfix_flag, const char *caller_file, const int caller_line)

void	pgbuf_attach_watcher_debug (THREAD_ENTRY thread_p, PAGE_PTR pgptr, PGBUF_LATCH_MODE latch_mode, HFID hfid, PGBUF_WATCHER watcher, const char caller_file, const int caller_line)

static PGBUF_HOLDER *	pgbuf_get_holder (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)

static void	pgbuf_remove_watcher (PGBUF_HOLDER holder, PGBUF_WATCHER watcher_object)

void	pgbuf_replace_watcher_debug (THREAD_ENTRY thread_p, PGBUF_WATCHER old_watcher, PGBUF_WATCHER new_watcher, const char caller_file, const int caller_line)

void	pgbuf_ordered_set_dirty_and_free (THREAD_ENTRY thread_p, PGBUF_WATCHER pg_watcher)

int	pgbuf_get_condition_for_ordered_fix (const VPID vpid_new_page, const VPID vpid_fixed_page, const HFID *hfid)

void	pgbuf_watcher_init_debug (PGBUF_WATCHER watcher, const char caller_file, const int caller_line, bool add)

bool	pgbuf_is_page_fixed_by_thread (THREAD_ENTRY thread_p, const VPID vpid_p)

static void	pgbuf_compute_lru_vict_target (float *lru_sum_flush_priority)

void	pgbuf_adjust_quotas (THREAD_ENTRY *thread_p)

int	pgbuf_assign_private_lru (THREAD_ENTRY *thread_p, bool is_vacuum, const int id)

int	pgbuf_release_private_lru (THREAD_ENTRY *thread_p, const int private_idx)

static int	pgbuf_initialize_seq_flusher (PGBUF_SEQ_FLUSHER seq_flusher, PGBUF_VICTIM_CANDIDATE_LIST f_list, const int cnt)

bool	pgbuf_has_any_waiters (PAGE_PTR pgptr)

bool	pgbuf_has_any_non_vacuum_waiters (PAGE_PTR pgptr)

bool	pgbuf_has_prevent_dealloc (PAGE_PTR pgptr)

void	pgbuf_peek_stats (UINT64 fixed_cnt, UINT64 dirty_cnt, UINT64 lru1_cnt, UINT64 lru2_cnt, UINT64 lru3_cnt, UINT64 victim_candidates, UINT64 avoid_dealloc_cnt, UINT64 avoid_victim_cnt, UINT64 private_quota, UINT64 private_cnt, UINT64 alloc_bcb_waiter_high, UINT64 alloc_bcb_waiter_med, UINT64 flushed_bcbs_waiting_direct_assign, UINT64 lfcq_big_prv_num, UINT64 lfcq_prv_num, UINT64 lfcq_shr_num)

int	pgbuf_flush_control_from_dirty_ratio (void)

int	pgbuf_rv_flush_page (THREAD_ENTRY thread_p, LOG_RCV rcv)

void	pgbuf_rv_flush_page_dump (FILE fp, int length, void data)

static const char *	pgbuf_latch_mode_str (PGBUF_LATCH_MODE latch_mode)

static const char *	pgbuf_zone_str (PGBUF_ZONE zone)

static const char *	pgbuf_consistent_str (int consistent)

int	pgbuf_get_fix_count (PAGE_PTR pgptr)

int	pgbuf_get_hold_count (THREAD_ENTRY *thread_p)

PERF_PAGE_TYPE	pgbuf_get_page_type_for_stat (THREAD_ENTRY *thread_p, PAGE_PTR pgptr)

void	pgbuf_log_new_page (THREAD_ENTRY *thread_p, PAGE_PTR page_new, int data_size, PAGE_TYPE ptype_new)

void	pgbuf_log_redo_new_page (THREAD_ENTRY *thread_p, PAGE_PTR page_new, int data_size, PAGE_TYPE ptype_new)

int	pgbuf_rv_new_page_redo (THREAD_ENTRY thread_p, LOG_RCV rcv)

int	pgbuf_rv_new_page_undo (THREAD_ENTRY thread_p, LOG_RCV rcv)

void	pgbuf_dealloc_page (THREAD_ENTRY *thread_p, PAGE_PTR page_dealloc)

int	pgbuf_rv_dealloc_redo (THREAD_ENTRY thread_p, LOG_RCV rcv)

int	pgbuf_rv_dealloc_undo (THREAD_ENTRY thread_p, LOG_RCV rcv)

int	pgbuf_rv_dealloc_undo_compensate (THREAD_ENTRY thread_p, LOG_RCV rcv)

int	pgbuf_fix_if_not_deallocated_with_caller (THREAD_ENTRY thread_p, const VPID vpid, PGBUF_LATCH_MODE latch_mode, PGBUF_LATCH_CONDITION latch_condition, PAGE_PTR page, const char caller_file, int caller_line)

STATIC_INLINE bool	pgbuf_assign_direct_victim (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_lru_add_victim_candidate (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_lru_remove_victim_candidate (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_lru_advance_victim_hint (THREAD_ENTRY thread_p, PGBUF_LRU_LIST lru_list, PGBUF_BCB bcb_prev_hint, PGBUF_BCB bcb_new_hint, bool was_vict_count_updated)

STATIC_INLINE void	pgbuf_bcb_update_flags (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int set_flags, int clear_flags)

STATIC_INLINE void	pgbuf_bcb_change_zone (THREAD_ENTRY thread_p, PGBUF_BCB bcb, int new_lru_idx, PGBUF_ZONE new_zone)

STATIC_INLINE PGBUF_ZONE	pgbuf_bcb_get_zone (const PGBUF_BCB *bcb)

STATIC_INLINE int	pgbuf_bcb_get_lru_index (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_is_dirty (const PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_bcb_set_dirty (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_bcb_clear_dirty (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE bool	pgbuf_bcb_mark_is_flushing (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_bcb_mark_was_flushed (THREAD_ENTRY thread_p, PGBUF_BCB bcb)

STATIC_INLINE void	pgbuf_bcb_mark_was_not_flushed (THREAD_ENTRY thread_p, PGBUF_BCB bcb, bool mark_dirty)

STATIC_INLINE bool	pgbuf_bcb_is_flushing (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_is_direct_victim (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_is_invalid_direct_victim (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_is_async_flush_request (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_should_be_moved_to_bottom_lru (const PGBUF_BCB *bcb)

void	pgbuf_notify_vacuum_follows (THREAD_ENTRY *thread_p, PAGE_PTR page)

STATIC_INLINE bool	pgbuf_bcb_is_to_vacuum (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_avoid_victim (const PGBUF_BCB *bcb)

STATIC_INLINE int	pgbuf_bcb_get_pool_index (const PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_bcb_register_avoid_deallocation (PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_bcb_unregister_avoid_deallocation (PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_should_avoid_deallocation (const PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc (PGBUF_BCB bcb, const char file, int line)

STATIC_INLINE void	pgbuf_bcb_register_fix (PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_bcb_is_hot (const PGBUF_BCB *bcb)

STATIC_INLINE bool	pgbuf_lfcq_add_lru_with_victims (PGBUF_LRU_LIST *lru_list)

static PGBUF_BCB *	pgbuf_lfcq_get_victim_from_private_lru (THREAD_ENTRY *thread_p, bool restricted)

static PGBUF_BCB *	pgbuf_lfcq_get_victim_from_shared_lru (THREAD_ENTRY *thread_p, bool multi_threaded)

STATIC_INLINE PGBUF_LRU_LIST *	pgbuf_lru_list_from_bcb (const PGBUF_BCB *bcb)

STATIC_INLINE void	pgbuf_bcb_register_hit_for_lru (PGBUF_BCB *bcb)

bool	pgbuf_is_io_stressful (void)

STATIC_INLINE bool	pgbuf_is_hit_ratio_low (void)

static void	pgbuf_flags_mask_sanity_check (void)

static void	pgbuf_lru_sanity_check (const PGBUF_LRU_LIST *lru)

STATIC_INLINE int	pgbuf_find_current_wait_msecs (THREAD_ENTRY *thread_p)

void	pgbuf_get_page_flush_interval (bool &is_timed_wait, cubthread::delta_time &period)

void	pgbuf_daemons_get_stats (UINT64 *stats_out)

static bool	pgbuf_is_page_flush_daemon_available ()

static bool	pgbuf_is_temp_lsa (const log_lsa &lsa)

static void	pgbuf_init_temp_page_lsa (FILEIO_PAGE *io_page, PGLENGTH page_size)

static void	pgbuf_scan_bcb_table ()

int	pgbuf_start_scan (THREAD_ENTRY thread_p, int type, DB_VALUE arg_values, int arg_cnt, void *ptr)

Variables
const VPID	vpid_Null_vpid = { NULL_PAGEID, NULL_VOLID }

static int	rv

static PGBUF_BUFFER_POOL	pgbuf_Pool

static PGBUF_BATCH_FLUSH_HELPER	pgbuf_Flush_helper

HFID *	pgbuf_ordered_null_hfid = NULL

Macro Definition Documentation

#define AOUT_HASH_DIVIDE_RATIO 1000

Definition at line 816 of file page_buffer.c.

Referenced by pgbuf_initialize_aout_list().

#define AOUT_HASH_IDX	(	vpid,
		list
	)	((vpid)->pageid % list->num_hashes)

Definition at line 817 of file page_buffer.c.

Referenced by pgbuf_add_vpid_to_aout_list(), pgbuf_remove_private_from_aout_list(), and pgbuf_remove_vpid_from_aout_list().

#define CAST_BFPTR_TO_PGPTR	(	pgptr,
		bufptr
	)

Value:

do { \
    assert ((bufptr) == (bufptr)->iopage_buffer->bcb); \
    (pgptr) = ((PAGE_PTR) ((char *) (bufptr->iopage_buffer) + offsetof (PGBUF_IOPAGE_BUFFER, iopage.page))); \
  } while (0)

Definition at line 155 of file page_buffer.c.

Referenced by pgbuf_bcb_flush_with_wal(), pgbuf_copy_to_area(), pgbuf_fix_debug(), pgbuf_ordered_fix_debug(), pgbuf_unfix_all(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_thrd_holder().

#define CAST_IOPGPTR_TO_PGPTR	(	pgptr,
		io_pgptr
	)

Value:

do { \
    (pgptr) = (PAGE_PTR) ((char *) (io_pgptr)->page); \
  } while (0)

Definition at line 150 of file page_buffer.c.

Referenced by pgbuf_claim_bcb_for_fix().

#define CAST_PGPTR_TO_BFPTR	(	bufptr,
		pgptr
	)

Value:

do { \
    (bufptr) = ((PGBUF_BCB *) ((PGBUF_IOPAGE_BUFFER *) \
      ((char *) pgptr - offsetof (PGBUF_IOPAGE_BUFFER, iopage.page)))->bcb); \
    assert ((bufptr) == (bufptr)->iopage_buffer->bcb); \
  } while (0)

Definition at line 138 of file page_buffer.c.

Referenced by pgbuf_check_page_ptype_internal(), pgbuf_dealloc_page(), pgbuf_flush_if_requested(), pgbuf_flush_with_wal(), pgbuf_get_fix_count(), pgbuf_get_holder(), pgbuf_get_latch_mode(), pgbuf_get_page_id(), pgbuf_get_page_ptype(), pgbuf_get_volume_id(), pgbuf_get_volume_label(), pgbuf_get_vpid(), pgbuf_get_vpid_ptr(), pgbuf_has_any_non_vacuum_waiters(), pgbuf_has_any_waiters(), pgbuf_has_prevent_dealloc(), pgbuf_invalidate_debug(), pgbuf_is_lsa_temporary(), pgbuf_notify_vacuum_follows(), pgbuf_ordered_fix_debug(), pgbuf_promote_read_latch_debug(), pgbuf_reset_temp_lsa(), pgbuf_set_dirty(), pgbuf_set_lsa(), pgbuf_set_lsa_as_temporary(), pgbuf_set_page_ptype(), pgbuf_unfix_all(), and pgbuf_unfix_debug().

#define CAST_PGPTR_TO_IOPGPTR	(	io_pgptr,
		pgptr
	)

Value:

do { \
    (io_pgptr) = (FILEIO_PAGE *) ((char *) pgptr - offsetof (FILEIO_PAGE, page)); \
  } while (0)

Definition at line 145 of file page_buffer.c.

Referenced by pgbuf_get_lsa(), pgbuf_get_page_type_for_stat(), pgbuf_get_tde_algorithm(), pgbuf_rv_dealloc_undo(), pgbuf_rv_dealloc_undo_compensate(), and pgbuf_set_tde_algorithm().

#define detailed_er_log ( ... ) if (detailed_logging) _er_log_debug (ARG_FILE_LINE, __VA_ARGS__)

Referenced by pgbuf_flush_checkpoint(), and pgbuf_flush_seq_list().

#define detailed_er_log ( ... ) if (detailed_logging) _er_log_debug (ARG_FILE_LINE, __VA_ARGS__)

#define HASH_SIZE_BITS 20

Definition at line 278 of file page_buffer.c.

#define INIT_HOLDER_STAT ( perf_stat )

Value:

do \
    { \
      (perf_stat)->dirty_before_hold = 0; \
      (perf_stat)->dirtied_by_holder = 0; \
      (perf_stat)->hold_has_write_latch = 0; \
      (perf_stat)->hold_has_read_latch = 0; \
    } \
  while (0)

Definition at line 309 of file page_buffer.c.

Referenced by pgbuf_initialize_thrd_holder(), pgbuf_latch_bcb_upon_fix(), and pgbuf_unfix_debug().

#define MAX_DEPTH 1000

Referenced by pgbuf_get_victim_from_lru_list().

#define MAX_PRIVATE_RATIO 0.998f

Referenced by pgbuf_adjust_quotas().

#define MIN_PRIVATE_RATIO 0.01f

Referenced by pgbuf_adjust_quotas().

#define PAGE_ADD_REFRESH_STAT MAX (2 * pgbuf_Pool.num_buffers / PGBUF_SHARED_LRU_COUNT, 10000)

Referenced by pgbuf_put_bcb_into_invalid_list().

#define PBGUF_BIG_PRIVATE_MIN_SIZE 100

Definition at line 953 of file page_buffer.c.

Referenced by pgbuf_lfcq_get_victim_from_private_lru().

#define PERF ( id ) if (detailed_perf) perfmon_inc_stat (thread_p, id)

Referenced by pgbuf_get_victim(), pgbuf_get_victim_from_lru_list(), pgbuf_lfcq_get_victim_from_private_lru(), and pgbuf_lfcq_get_victim_from_shared_lru().

#define PERF ( pstatid ) if (perf_tracking) perfmon_inc_stat (thread_p, pstatid)

#define PERF ( id ) if (detailed_perf) perfmon_inc_stat (thread_p, id)

#define PGBUF_ABORT_RELEASE ( ) assert (false)

Definition at line 967 of file page_buffer.c.

Referenced by pgbuf_flags_mask_sanity_check(), and pgbuf_is_hit_ratio_low().

#define PGBUF_AGE_DIFF	(	bcb_age,
		list_age
	)	(((list_age) >= (bcb_age)) ? ((list_age) - (bcb_age)) : (DB_INT32_MAX - ((bcb_age) - (list_age))))

Definition at line 886 of file page_buffer.c.

Referenced by pgbuf_lru_add_victim_candidate().

#define PGBUF_AOUT_NOT_FOUND -2

Definition at line 269 of file page_buffer.c.

Referenced by pgbuf_initialize_aout_list(), pgbuf_remove_private_from_aout_list(), pgbuf_remove_vpid_from_aout_list(), and pgbuf_unlatch_void_zone_bcb().

#define PGBUF_BCB_ASYNC_FLUSH_REQ ((int) 0x02000000)

Definition at line 231 of file page_buffer.c.

Referenced by pgbuf_bcb_is_async_flush_request(), pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_safe_flush_internal(), and pgbuf_claim_bcb_for_fix().

#define PGBUF_BCB_AVOID_DEALLOC_MASK ((int) 0x0000FFFF)

Definition at line 259 of file page_buffer.c.

Referenced by pgbuf_bcb_should_avoid_deallocation(), and pgbuf_bcb_unregister_avoid_deallocation().

#define PGBUF_BCB_CHECK_MUTEX_LEAKS ( )

Definition at line 846 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_claim_bcb_for_fix(), pgbuf_fix_debug(), pgbuf_flush_if_requested(), pgbuf_flush_victim_candidates(), and pgbuf_unfix_debug().

#define PGBUF_BCB_CHECK_OWN ( bcb ) (true)

Definition at line 845 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_flush_with_wal(), pgbuf_bcb_safe_flush_internal(), pgbuf_is_bcb_fixed_by_any(), and pgbuf_wake_flush_waiters().

#define PGBUF_BCB_COUNT_FIX_SHIFT_BITS 16

Definition at line 258 of file page_buffer.c.

Referenced by pgbuf_bcb_is_hot(), and pgbuf_bcb_register_fix().

#define PGBUF_BCB_DIRTY_FLAG ((int) 0x80000000)

Definition at line 214 of file page_buffer.c.

Referenced by pgbuf_bcb_clear_dirty(), pgbuf_bcb_is_dirty(), pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_mark_was_not_flushed(), pgbuf_bcb_set_dirty(), pgbuf_bcb_update_flags(), pgbuf_dealloc_page(), pgbuf_peek_stats(), and pgbuf_scan_bcb_table().

#define PGBUF_BCB_FLAGS_MASK

Value:

(PGBUF_BCB_DIRTY_FLAG \
   | PGBUF_BCB_FLUSHING_TO_DISK_FLAG \
   | PGBUF_BCB_VICTIM_DIRECT_FLAG \
   | PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG \
   | PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG \
   | PGBUF_BCB_TO_VACUUM_FLAG \
   | PGBUF_BCB_ASYNC_FLUSH_REQ)

Definition at line 234 of file page_buffer.c.

Referenced by pgbuf_bcb_change_zone(), pgbuf_bcb_update_flags(), pgbuf_flags_mask_sanity_check(), and pgbuf_put_bcb_into_invalid_list().

#define PGBUF_BCB_FLUSHING_TO_DISK_FLAG ((int) 0x40000000)

Definition at line 217 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_is_flushing(), pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_mark_was_flushed(), pgbuf_bcb_mark_was_not_flushed(), and pgbuf_peek_stats().

#define PGBUF_BCB_INIT_FLAGS PGBUF_INVALID_ZONE

Definition at line 255 of file page_buffer.c.

Referenced by pgbuf_initialize_bcb_table().

#define PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK

Value:

(PGBUF_BCB_DIRTY_FLAG \
   | PGBUF_BCB_FLUSHING_TO_DISK_FLAG \
   | PGBUF_BCB_VICTIM_DIRECT_FLAG \
   | PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG)

Definition at line 248 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_avoid_victim(), pgbuf_bcb_change_zone(), pgbuf_bcb_set_dirty(), and pgbuf_bcb_update_flags().

#define PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG ((int) 0x10000000)

Definition at line 225 of file page_buffer.c.

Referenced by pgbuf_allocate_bcb(), pgbuf_assign_direct_victim(), pgbuf_bcb_is_invalid_direct_victim(), and pgbuf_fix_debug().

#define PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG ((int) 0x08000000)

Definition at line 227 of file page_buffer.c.

Referenced by pgbuf_bcb_should_be_moved_to_bottom_lru(), pgbuf_dealloc_page(), and pgbuf_move_bcb_to_bottom_lru().

#define PGBUF_BCB_SIZEOF (sizeof (PGBUF_BCB))

Definition at line 110 of file page_buffer.c.

Referenced by pgbuf_initialize_bcb_table().

#define PGBUF_BCB_TO_VACUUM_FLAG ((int) 0x04000000)

Definition at line 229 of file page_buffer.c.

Referenced by pgbuf_bcb_is_to_vacuum(), pgbuf_fix_debug(), pgbuf_notify_vacuum_follows(), and pgbuf_victimize_bcb().

#define PGBUF_BCB_TRYLOCK ( bcb ) (0)

Definition at line 843 of file page_buffer.c.

Referenced by pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_fall_bcb_to_zone_3(), and pgbuf_search_hash_chain().

#define PGBUF_BCB_UNLOCK ( bcb )

Definition at line 844 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_flush_with_wal(), pgbuf_bcb_safe_flush_force_lock(), pgbuf_bcb_safe_flush_force_unlock(), pgbuf_block_bcb(), pgbuf_check_bcb_page_vpid(), pgbuf_copy_from_area(), pgbuf_copy_to_area(), pgbuf_delete_from_hash_chain(), pgbuf_fix_debug(), pgbuf_flush_all_helper(), pgbuf_flush_checkpoint(), pgbuf_flush_neighbor_safe(), pgbuf_flush_page_and_neighbors_fb(), pgbuf_flush_seq_list(), pgbuf_flush_victim_candidates(), pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_has_any_waiters(), pgbuf_invalidate_all_debug(), pgbuf_invalidate_bcb(), pgbuf_invalidate_debug(), pgbuf_is_valid_page_ptr(), pgbuf_latch_bcb_upon_fix(), pgbuf_latch_idle_page(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_ordered_fix_debug(), pgbuf_promote_read_latch_debug(), pgbuf_put_bcb_into_invalid_list(), pgbuf_search_hash_chain(), pgbuf_unfix_debug(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_victimize_bcb().

#define PGBUF_BCB_VICTIM_DIRECT_FLAG ((int) 0x20000000)

Definition at line 224 of file page_buffer.c.

Referenced by pgbuf_allocate_bcb(), pgbuf_assign_direct_victim(), pgbuf_bcb_is_direct_victim(), and pgbuf_fix_debug().

#define PGBUF_BUFFER_HASH_SIZEOF (sizeof (PGBUF_BUFFER_HASH))

Definition at line 115 of file page_buffer.c.

Referenced by pgbuf_initialize_hash_table().

#define PGBUF_BUFFER_LOCK_SIZEOF (sizeof (PGBUF_BUFFER_LOCK))

Definition at line 117 of file page_buffer.c.

Referenced by pgbuf_initialize_lock_table().

#define PGBUF_CHKPT_BURST_PAGES 16

Definition at line 307 of file page_buffer.c.

Referenced by pgbuf_flush_chkpt_seq_list().

#define PGBUF_CHKPT_MAX_FLUSH_RATE 1200

Definition at line 303 of file page_buffer.c.

Referenced by pgbuf_flush_seq_list().

#define PGBUF_CHKPT_MIN_FLUSH_RATE 50

Definition at line 304 of file page_buffer.c.

Referenced by pgbuf_flush_seq_list().

#define PGBUF_DEFAULT_FIX_COUNT 7

Definition at line 83 of file page_buffer.c.

Referenced by pgbuf_initialize_thrd_holder().

#define PGBUF_DESIRED_HIT_VS_MISS_RATE 1000 /* 99.9% hit ratio */

Referenced by pgbuf_is_hit_ratio_low().

#define PGBUF_FIND_BCB_PTR ( i ) ((PGBUF_BCB *) ((char *) &(pgbuf_Pool.BCB_table[0]) + (PGBUF_BCB_SIZEOF * (i))))

Definition at line 128 of file page_buffer.c.

Referenced by pgbuf_check_bcb_page_vpid(), pgbuf_finalize(), pgbuf_flush_all_helper(), pgbuf_flush_checkpoint(), pgbuf_initialize_bcb_table(), pgbuf_initialize_invalid_list(), pgbuf_invalidate_all_debug(), pgbuf_is_valid_page_ptr(), pgbuf_peek_stats(), and pgbuf_scan_bcb_table().

#define PGBUF_FIND_BUFFER_GUARD ( bufptr ) (&bufptr->iopage_buffer->iopage.page[DB_PAGESIZE])

Definition at line 134 of file page_buffer.c.

Referenced by pgbuf_check_bcb_page_vpid(), pgbuf_initialize_bcb_table(), and pgbuf_unfix_debug().

#define PGBUF_FIND_IOPAGE_PTR ( i ) ((PGBUF_IOPAGE_BUFFER *) ((char *) &(pgbuf_Pool.iopage_table[0]) + (PGBUF_IOPAGE_BUFFER_SIZE * (i))))

Definition at line 131 of file page_buffer.c.

Referenced by pgbuf_initialize_bcb_table().

#define PGBUF_FIX_COUNT_THRESHOLD 64 /* fix count threshold. used as indicator for hot pages. */

Definition at line 100 of file page_buffer.c.

Referenced by pgbuf_bcb_is_hot(), and pgbuf_bcb_register_fix().

#define PGBUF_FLUSH_VICTIM_BOOST_MULT 10

Definition at line 286 of file page_buffer.c.

Referenced by pgbuf_flush_victim_candidates().

#define PGBUF_GET_LRU_INDEX ( flags ) ((flags) & PGBUF_LRU_INDEX_MASK)

Definition at line 206 of file page_buffer.c.

Referenced by pgbuf_bcb_change_zone(), and pgbuf_bcb_get_lru_index().

#define PGBUF_GET_LRU_LIST ( lru_idx ) (&pgbuf_Pool.buf_LRU_list[lru_idx])

Definition at line 880 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_private_lru(), pgbuf_bcb_change_zone(), pgbuf_compute_lru_vict_target(), pgbuf_get_victim(), pgbuf_get_victim_from_lru_list(), pgbuf_lfcq_get_victim_from_private_lru(), pgbuf_lfcq_get_victim_from_shared_lru(), pgbuf_lru_list_from_bcb(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_put_bcb_into_invalid_list(), and pgbuf_should_move_private_to_shared().

#define PGBUF_GET_ZONE ( flags ) ((PGBUF_ZONE) ((flags) & PGBUF_ZONE_MASK))

Definition at line 205 of file page_buffer.c.

Referenced by pgbuf_bcb_change_zone(), pgbuf_bcb_get_zone(), pgbuf_bcb_set_dirty(), pgbuf_bcb_update_flags(), pgbuf_peek_stats(), and pgbuf_scan_bcb_table().

#define PGBUF_HASH_SIZE (1 << HASH_SIZE_BITS)

Definition at line 279 of file page_buffer.c.

Referenced by pgbuf_finalize(), and pgbuf_initialize_hash_table().

#define PGBUF_HASH_VALUE ( vpid ) pgbuf_hash_func_mirror(vpid)

Definition at line 281 of file page_buffer.c.

Referenced by pgbuf_copy_from_area(), pgbuf_copy_to_area(), pgbuf_delete_from_hash_chain(), pgbuf_fix_debug(), pgbuf_flush_page_and_neighbors_fb(), and pgbuf_ordered_fix_debug().

#define PGBUF_HOLDER_ANCHOR_SIZEOF (sizeof (PGBUF_HOLDER_ANCHOR))

Definition at line 125 of file page_buffer.c.

Referenced by pgbuf_initialize_thrd_holder().

#define PGBUF_HOLDER_SET_SIZEOF (sizeof (PGBUF_HOLDER_SET))

Definition at line 123 of file page_buffer.c.

Referenced by pgbuf_allocate_thrd_holder_entry().

#define PGBUF_HOLDER_SIZEOF (sizeof (PGBUF_HOLDER))

Definition at line 121 of file page_buffer.c.

Referenced by pgbuf_initialize_thrd_holder().

#define PGBUF_IOPAGE_BUFFER_SIZE

Value:

((size_t)(offsetof (PGBUF_IOPAGE_BUFFER, iopage) + \

SIZEOF_IOPAGE_PAGESIZE_AND_GUARD()))

pgbuf_iopage_buffer

Definition: page_buffer.c:504

SIZEOF_IOPAGE_PAGESIZE_AND_GUARD

#define SIZEOF_IOPAGE_PAGESIZE_AND_GUARD()

Definition: page_buffer.c:106

Definition at line 111 of file page_buffer.c.

Referenced by pgbuf_initialize_bcb_table(), and pgbuf_start_scan().

#define PGBUF_IS_AUXILIARY_VOLUME ( volid ) ((volid) < LOG_DBFIRST_VOLID ? true : false)

Definition at line 162 of file page_buffer.c.

Referenced by pgbuf_set_lsa(), and pgbuf_unfix_debug().

#define PGBUF_IS_BCB_IN_LRU ( bcb ) ((pgbuf_bcb_get_zone (bcb) & PGBUF_LRU_ZONE_MASK) != 0)

Definition at line 883 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_get_lru_index(), pgbuf_bcb_register_hit_for_lru(), pgbuf_invalidate_bcb(), pgbuf_lru_add_new_bcb_to_bottom(), pgbuf_lru_add_new_bcb_to_middle(), pgbuf_lru_add_new_bcb_to_top(), pgbuf_lru_boost_bcb(), pgbuf_lru_list_from_bcb(), and pgbuf_lru_remove_bcb().

#define PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE ( bcb ) (pgbuf_bcb_get_zone (bcb) == PGBUF_LRU_3_ZONE)

Definition at line 882 of file page_buffer.c.

Referenced by pgbuf_assign_direct_victim(), pgbuf_flush_victim_candidates(), pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_add_bcb_to_bottom(), pgbuf_lru_add_victim_candidate(), and pgbuf_lru_advance_victim_hint().

#define PGBUF_IS_BCB_OLD_ENOUGH	(	bcb,
		lru_list
	)	(PGBUF_AGE_DIFF ((bcb)->tick_lru_list, (lru_list)->tick_list) >= ((lru_list)->count_lru2 / 2))

Definition at line 890 of file page_buffer.c.

Referenced by pgbuf_should_move_private_to_shared(), and pgbuf_unlatch_bcb_upon_unfix().

#define PGBUF_IS_PRIVATE_LRU_INDEX ( lru_idx ) ((lru_idx) >= PGBUF_SHARED_LRU_COUNT)

Definition at line 938 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_direct_victim(), pgbuf_compute_lru_vict_target(), pgbuf_initialize_page_quota(), pgbuf_lfcq_add_lru_with_victims(), pgbuf_lfcq_get_victim_from_private_lru(), pgbuf_lru_boost_bcb(), pgbuf_lru_move_from_private_to_shared(), pgbuf_peek_stats(), and pgbuf_unlatch_bcb_upon_unfix().

#define PGBUF_IS_PRIVATE_LRU_ONE_TWO_OVER_QUOTA ( lru_idx ) (PGBUF_IS_PRIVATE_LRU_INDEX (lru_idx) && PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA (PGBUF_GET_LRU_LIST (lru_idx)))

Definition at line 946 of file page_buffer.c.

Referenced by pgbuf_get_victim_from_lru_list().

#define PGBUF_IS_PRIVATE_LRU_OVER_QUOTA ( lru_idx ) (PGBUF_IS_PRIVATE_LRU_INDEX (lru_idx) && PGBUF_LRU_LIST_IS_OVER_QUOTA (PGBUF_GET_LRU_LIST (lru_idx)))

Definition at line 944 of file page_buffer.c.

#define PGBUF_IS_SHARED_LRU_INDEX ( lru_idx ) ((lru_idx) < PGBUF_SHARED_LRU_COUNT)

Definition at line 937 of file page_buffer.c.

Referenced by pgbuf_bcb_change_zone(), pgbuf_compute_lru_vict_target(), pgbuf_lfcq_get_victim_from_shared_lru(), pgbuf_lru_add_victim_candidate(), and pgbuf_should_move_private_to_shared().

#define PGBUF_LIMIT_AOUT_BUFFERS 32768

Referenced by pgbuf_initialize_aout_list().

#define PGBUF_LRU_ARE_ZONES_ONE_TWO_OVER_THRESHOLD ( list ) ((list)->threshold_lru1 + (list)->threshold_lru2 < PGBUF_LRU_ZONE_ONE_TWO_COUNT(list))

Definition at line 899 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas().

#define PGBUF_LRU_INDEX_FROM_PRIVATE ( private_id ) (PGBUF_SHARED_LRU_COUNT + (private_id))

Definition at line 935 of file page_buffer.c.

Referenced by pgbuf_compute_lru_vict_target(), pgbuf_get_victim(), pgbuf_get_victim_from_lru_list(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_release_private_lru(), and pgbuf_unlatch_bcb_upon_unfix().

#define PGBUF_LRU_INDEX_MASK (PGBUF_LRU_LIST_MAX_COUNT - 1) /* 0x0000FFFF */

Definition at line 172 of file page_buffer.c.

Referenced by pgbuf_flags_mask_sanity_check(), and pgbuf_peek_stats().

#define PGBUF_LRU_IS_ZONE_ONE_OVER_THRESHOLD ( list ) ((list)->threshold_lru1 < (list)->count_lru1)

Definition at line 897 of file page_buffer.c.

#define PGBUF_LRU_IS_ZONE_TWO_OVER_THRESHOLD ( list ) ((list)->threshold_lru2 < (list)->count_lru2)

Definition at line 898 of file page_buffer.c.

#define PGBUF_LRU_LIST_COUNT ( list ) (PGBUF_LRU_ZONE_ONE_TWO_COUNT(list) + (list)->count_lru3)

Definition at line 894 of file page_buffer.c.

Referenced by pgbuf_assign_private_lru(), pgbuf_compute_lru_vict_target(), pgbuf_lfcq_get_victim_from_private_lru(), and pgbuf_put_bcb_into_invalid_list().

#define PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA ( list ) ((PGBUF_LRU_ZONE_ONE_TWO_COUNT (list) > (list)->quota))

Definition at line 941 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), and pgbuf_get_victim().

#define PGBUF_LRU_LIST_IS_OVER_QUOTA ( list ) (PGBUF_LRU_LIST_COUNT (list) > (list)->quota)

Definition at line 940 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_direct_victim(), pgbuf_get_victim(), pgbuf_lfcq_get_victim_from_private_lru(), and pgbuf_lru_add_victim_candidate().

#define PGBUF_LRU_LIST_IS_OVER_QUOTA_WITH_BUFFER ( list ) (PGBUF_LRU_LIST_COUNT (list) > (list)->quota + PGBUF_OVER_QUOTA_BUFFER ((list)->quota))

Definition at line 950 of file page_buffer.c.

Referenced by pgbuf_get_victim().

#define PGBUF_LRU_LIST_MAX_COUNT ((int) 1 << PGBUF_LRU_NBITS) /* 64k */

Definition at line 171 of file page_buffer.c.

#define PGBUF_LRU_LIST_OVER_QUOTA_COUNT ( list ) (PGBUF_LRU_LIST_COUNT (list) - (list)->quota)

Definition at line 942 of file page_buffer.c.

#define PGBUF_LRU_LIST_SIZEOF (sizeof (PGBUF_LRU_LIST))

Definition at line 119 of file page_buffer.c.

Referenced by pgbuf_initialize_lru_list().

#define PGBUF_LRU_NBITS 16

Definition at line 170 of file page_buffer.c.

#define PGBUF_LRU_VICTIM_LFCQ_FLAG ((int) 0x80000000)

Definition at line 956 of file page_buffer.c.

Referenced by pgbuf_lfcq_add_lru_with_victims(), pgbuf_lfcq_get_victim_from_private_lru(), and pgbuf_lfcq_get_victim_from_shared_lru().

#define PGBUF_LRU_VICTIM_ZONE_COUNT ( list ) ((list)->count_lru3)

Definition at line 895 of file page_buffer.c.

#define PGBUF_LRU_ZONE_MAX_RATIO 0.90f

Definition at line 324 of file page_buffer.c.

Referenced by pgbuf_initialize().

#define PGBUF_LRU_ZONE_MIN_RATIO 0.05f

Definition at line 323 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_compute_lru_vict_target(), and pgbuf_initialize().

#define PGBUF_LRU_ZONE_ONE_TWO_COUNT ( list ) ((list)->count_lru1 + (list)->count_lru2)

Definition at line 893 of file page_buffer.c.

Referenced by pgbuf_lru_adjust_zones().

#define PGBUF_MAKE_ZONE	(	list_id,
		zone
	)	((list_id) \| (zone))

Definition at line 204 of file page_buffer.c.

Referenced by pgbuf_bcb_change_zone().

#define PGBUF_MAX_NEIGHBOR_PAGES 32

Definition at line 291 of file page_buffer.c.

#define PGBUF_MAX_PAGE_FIXED_BY_TRAN 64

Definition at line 300 of file page_buffer.c.

Referenced by pgbuf_ordered_fix_debug().

#define PGBUF_MAX_PAGE_WATCHERS 64

Definition at line 298 of file page_buffer.c.

Referenced by pgbuf_add_watch_instance_internal(), and pgbuf_ordered_fix_debug().

#define PGBUF_MIN_PAGES_IN_SHARED_LIST 1000

Definition at line 909 of file page_buffer.c.

Referenced by pgbuf_initialize_lru_list().

#define PGBUF_MIN_SHARED_LIST_ADJUST_SIZE 50

Definition at line 910 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), and pgbuf_compute_lru_vict_target().

#define PGBUF_MIN_VICTIM_REQ 10 /* set a minimum number of requests */

Referenced by pgbuf_is_hit_ratio_low().

#define PGBUF_MINIMUM_BUFFERS (MAX_NTRANS * 10)

Definition at line 77 of file page_buffer.c.

Referenced by pgbuf_initialize().

#define PGBUF_NEIGHBOR_FLUSH_NONDIRTY (prm_get_bool_value (PRM_ID_PB_NEIGHBOR_FLUSH_NONDIRTY))

Definition at line 288 of file page_buffer.c.

Referenced by pgbuf_flush_page_and_neighbors_fb().

#define PGBUF_NEIGHBOR_PAGES (prm_get_integer_value (PRM_ID_PB_NEIGHBOR_FLUSH_PAGES))

Definition at line 292 of file page_buffer.c.

Referenced by pgbuf_add_bufptr_to_batch(), pgbuf_flush_page_and_neighbors_fb(), and pgbuf_flush_victim_candidates().

#define PGBUF_NEIGHBOR_POS ( idx ) (PGBUF_NEIGHBOR_PAGES - 1 + (idx))

Definition at line 295 of file page_buffer.c.

Referenced by pgbuf_add_bufptr_to_batch(), and pgbuf_flush_page_and_neighbors_fb().

#define PGBUF_NUM_ALLOC_HOLDER 10

Definition at line 87 of file page_buffer.c.

Referenced by pgbuf_allocate_thrd_holder_entry().

#define PGBUF_OVER_QUOTA_BUFFER ( quota ) MAX (10, (int) (quota * 0.01f))

Definition at line 949 of file page_buffer.c.

#define PGBUF_PAGE_QUOTA_IS_ENABLED (pgbuf_Pool.quota.num_private_LRU_list > 0)

Definition at line 912 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_private_lru(), pgbuf_get_victim(), pgbuf_initialize(), pgbuf_initialize_page_quota(), and pgbuf_release_private_lru().

#define PGBUF_PAGES_COUNT_THRESHOLD 4

Referenced by pgbuf_flush_page_and_neighbors_fb().

#define PGBUF_PRIVATE_LIST_FROM_LRU_INDEX ( i ) ((i) - PGBUF_SHARED_LRU_COUNT)

Definition at line 934 of file page_buffer.c.

Referenced by pgbuf_assign_private_lru(), and pgbuf_initialize_page_quota().

#define PGBUF_PRIVATE_LRU_COUNT (pgbuf_Pool.quota.num_private_LRU_list)

Definition at line 931 of file page_buffer.c.

Referenced by pgbuf_get_victim_from_lru_list(), pgbuf_initialize(), pgbuf_initialize_page_quota(), and pgbuf_release_private_lru().

#define PGBUF_PRIVATE_LRU_FROM_THREAD ( thread_p ) 0

Definition at line 926 of file page_buffer.c.

Referenced by pgbuf_get_victim(), pgbuf_move_bcb_to_bottom_lru(), and pgbuf_unlatch_bcb_upon_unfix().

#define PGBUF_PRIVATE_LRU_MAX_HARD_QUOTA 5000

Definition at line 906 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas().

#define PGBUF_PRIVATE_LRU_MIN_COUNT 4

Definition at line 905 of file page_buffer.c.

Referenced by pgbuf_initialize_page_quota_parameters().

#define PGBUF_SHARED_LRU_COUNT (pgbuf_Pool.num_LRU_list)

Definition at line 930 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_private_lru(), pgbuf_compute_lru_vict_target(), pgbuf_get_victim_from_lru_list(), pgbuf_initialize(), and pgbuf_put_bcb_into_invalid_list().

#define PGBUF_THREAD_HAS_PRIVATE_LRU ( thread_p ) false

Definition at line 927 of file page_buffer.c.

Referenced by pgbuf_get_victim(), pgbuf_move_bcb_to_bottom_lru(), and pgbuf_unlatch_bcb_upon_unfix().

#define PGBUF_THREAD_SHOULD_IGNORE_UNFIX ( th ) false

Definition at line 275 of file page_buffer.c.

Referenced by pgbuf_get_victim(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_void_zone_bcb().

#define PGBUF_TIMEOUT 300 /* timeout seconds */

Definition at line 99 of file page_buffer.c.

Referenced by pgbuf_allocate_bcb(), and pgbuf_block_bcb().

#define PGBUF_TOTAL_LRU_COUNT (PGBUF_SHARED_LRU_COUNT + PGBUF_PRIVATE_LRU_COUNT)

Definition at line 932 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas(), pgbuf_assign_private_lru(), pgbuf_compute_lru_vict_target(), pgbuf_finalize(), pgbuf_get_victim_candidates_from_lru(), pgbuf_initialize_lru_list(), pgbuf_initialize_page_monitor(), pgbuf_initialize_page_quota(), and pgbuf_peek_stats().

#define PGBUF_TRAN_MAX_ACTIVITY (10 * PGBUF_TRAN_THRESHOLD_ACTIVITY)

Definition at line 267 of file page_buffer.c.

Referenced by pgbuf_assign_private_lru().

#define PGBUF_TRAN_THRESHOLD_ACTIVITY (pgbuf_Pool.num_buffers / 4)

Definition at line 266 of file page_buffer.c.

Referenced by pgbuf_adjust_quotas().

#define pthread_mutex_destroy ( a )

Definition at line 92 of file page_buffer.c.

Referenced by pgbuf_finalize(), and pgbuf_initialize_aout_list().

#define pthread_mutex_init	(	a,
		b
	)

Definition at line 91 of file page_buffer.c.

Referenced by pgbuf_initialize(), pgbuf_initialize_aout_list(), pgbuf_initialize_bcb_table(), pgbuf_initialize_hash_table(), pgbuf_initialize_invalid_list(), pgbuf_initialize_lru_list(), and pgbuf_initialize_thrd_holder().

#define pthread_mutex_lock ( a ) 0

#define pthread_mutex_unlock ( a )

Definition at line 94 of file page_buffer.c.

Referenced by pgbuf_add_fixed_at(), pgbuf_add_vpid_to_aout_list(), pgbuf_adjust_quotas(), pgbuf_allocate_thrd_holder_entry(), pgbuf_check_bcb_page_vpid(), pgbuf_claim_bcb_for_fix(), pgbuf_copy_from_area(), pgbuf_copy_to_area(), pgbuf_delete_from_hash_chain(), pgbuf_fix_debug(), pgbuf_flush_page_and_neighbors_fb(), pgbuf_get_bcb_from_invalid_list(), pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_is_hit_ratio_low(), pgbuf_lock_page(), pgbuf_lru_add_new_bcb_to_bottom(), pgbuf_lru_add_new_bcb_to_middle(), pgbuf_lru_add_new_bcb_to_top(), pgbuf_lru_boost_bcb(), pgbuf_lru_remove_bcb(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_ordered_fix_debug(), pgbuf_put_bcb_into_invalid_list(), pgbuf_remove_private_from_aout_list(), pgbuf_remove_vpid_from_aout_list(), pgbuf_search_hash_chain(), pgbuf_set_lsa(), pgbuf_start_scan(), and pgbuf_unlock_page().

#define SIZEOF_IOPAGE_PAGESIZE_AND_GUARD ( ) (IO_PAGESIZE)

Definition at line 106 of file page_buffer.c.

#define VOLID_LSB_BITS 8

#define WAIT_FLUSH_VICTIMS_MAX_MSEC 1500.0f

Referenced by pgbuf_flush_chkpt_seq_list().

Typedef Documentation

typedef struct pgbuf_aout_buf PGBUF_AOUT_BUF

Definition at line 347 of file page_buffer.c.

typedef struct pgbuf_aout_list PGBUF_AOUT_LIST

Definition at line 353 of file page_buffer.c.

typedef struct pgbuf_batch_flush_helper PGBUF_BATCH_FLUSH_HELPER

Definition at line 425 of file page_buffer.c.

typedef struct pgbuf_bcb PGBUF_BCB

Definition at line 345 of file page_buffer.c.

typedef struct pgbuf_buffer_hash PGBUF_BUFFER_HASH

Definition at line 350 of file page_buffer.c.

typedef struct pgbuf_buffer_lock PGBUF_BUFFER_LOCK

Definition at line 349 of file page_buffer.c.

typedef struct pgbuf_buffer_pool PGBUF_BUFFER_POOL

Definition at line 359 of file page_buffer.c.

typedef struct pgbuf_dealloc_undo_data PGBUF_DEALLOC_UNDO_DATA

Definition at line 868 of file page_buffer.c.

typedef struct pgbuf_fix_perf PGBUF_FIX_PERF

Definition at line 850 of file page_buffer.c.

typedef struct pgbuf_holder PGBUF_HOLDER

Definition at line 341 of file page_buffer.c.

typedef struct pgbuf_holder_anchor PGBUF_HOLDER_ANCHOR

Definition at line 342 of file page_buffer.c.

typedef struct pgbuf_holder_info PGBUF_HOLDER_INFO

Definition at line 363 of file page_buffer.c.

typedef struct pgbuf_holder_set PGBUF_HOLDER_SET

Definition at line 343 of file page_buffer.c.

typedef struct pgbuf_holder_stat PGBUF_HOLDER_STAT

Definition at line 414 of file page_buffer.c.

typedef struct pgbuf_invalid_list PGBUF_INVALID_LIST

Definition at line 356 of file page_buffer.c.

typedef struct pgbuf_iopage_buffer PGBUF_IOPAGE_BUFFER

Definition at line 346 of file page_buffer.c.

typedef struct pgbuf_lru_list PGBUF_LRU_LIST

Definition at line 352 of file page_buffer.c.

typedef struct pgbuf_monitor_bcb_mutex PGBUF_MONITOR_BCB_MUTEX

Definition at line 361 of file page_buffer.c.

typedef struct pgbuf_page_monitor PGBUF_PAGE_MONITOR

Definition at line 650 of file page_buffer.c.

typedef struct pgbuf_page_quota PGBUF_PAGE_QUOTA

Definition at line 672 of file page_buffer.c.

typedef struct pgbuf_seq_flusher PGBUF_SEQ_FLUSHER

Definition at line 354 of file page_buffer.c.

typedef struct pgbuf_status PGBUF_STATUS

Definition at line 365 of file page_buffer.c.

typedef struct pgbuf_status_old PGBUF_STATUS_OLD

Definition at line 367 of file page_buffer.c.

typedef struct pgbuf_status_snapshot PGBUF_STATUS_SNAPSHOT

Definition at line 366 of file page_buffer.c.

typedef struct pgbuf_victim_candidate_list PGBUF_VICTIM_CANDIDATE_LIST

Definition at line 357 of file page_buffer.c.

Enumeration Type Documentation

anonymous enum

Enumerator
PGBUF_LOCK_WAITER
PGBUF_LOCK_HOLDER

Definition at line 327 of file page_buffer.c.

anonymous enum

Enumerator
PGBUF_CONTENT_BAD
PGBUF_CONTENT_GOOD
PGBUF_CONTENT_LIKELY_BAD
PGBUF_CONTENT_ERROR

Definition at line 333 of file page_buffer.c.

anonymous enum

Enumerator
NEIGHBOR_ABORT_RANGE
NEIGHBOR_ABORT_NOTFOUND_NONDIRTY_BACK
NEIGHBOR_ABORT_NOTFOUND_DIRTY_BACK
NEIGHBOR_ABORT_LATCH_NONDIRTY_BACK
NEIGHBOR_ABORT_LATCH_DIRTY_BACK
NEIGHBOR_ABORT_NONDIRTY_NOT_ALLOWED
NEIGHBOR_ABORT_TWO_CONSECTIVE_NONDIRTIES
NEIGHBOR_ABORT_TOO_MANY_NONDIRTIES

Definition at line 10951 of file page_buffer.c.

enum PGBUF_ZONE

Enumerator
PGBUF_LRU_1_ZONE
PGBUF_LRU_2_ZONE
PGBUF_LRU_3_ZONE
PGBUF_LRU_ZONE_MASK
PGBUF_INVALID_ZONE
PGBUF_VOID_ZONE
PGBUF_ZONE_MASK

Definition at line 175 of file page_buffer.c.

Function Documentation

STATIC_INLINE void pgbuf_add_bufptr_to_batch	(	PGBUF_BCB *	bufptr,
		int	idx
	)

Definition at line 11270 of file page_buffer.c.

References assert, pgbuf_batch_flush_helper::back_offset, pgbuf_batch_flush_helper::fwd_offset, pgbuf_bcb::latch_mode, pgbuf_batch_flush_helper::npages, pgbuf_batch_flush_helper::pages_bufptr, pgbuf_Flush_helper, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_NEIGHBOR_PAGES, PGBUF_NEIGHBOR_POS, PGBUF_NO_LATCH, STATIC_INLINE, pgbuf_bcb::vpid, VPID_COPY, and pgbuf_batch_flush_helper::vpids.

Referenced by pgbuf_flush_page_and_neighbors_fb().

Here is the caller graph for this function:

static void pgbuf_add_fixed_at	(	PGBUF_HOLDER *	holder,
		const char *	caller_file,
		int	caller_line,
		bool	reset
	)

static

Definition at line 10716 of file page_buffer.c.

References ARG_FILE_LINE, assert, ER_CSS_PTHREAD_COND_SIGNAL, ER_ERROR_SEVERITY, er_log_debug, er_set_with_oserror(), pgbuf_holder::fixed_at, pgbuf_holder::fixed_at_size, NO_ERROR, NULL, p, PGBUF_NO_LATCH, pthread_mutex_unlock, STATIC_INLINE, strlen, thread_lock_entry(), THREAD_PGBUF_RESUMED, THREAD_PGBUF_SUSPENDED, thread_suspend_wakeup_and_unlock_entry(), and thread_unlock_entry().

Referenced by pgbuf_fix_debug(), and pgbuf_promote_read_latch_debug().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_add_vpid_to_aout_list	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		const int	lru_idx
	)

Definition at line 9642 of file page_buffer.c.

References pgbuf_aout_list::Aout_bottom, pgbuf_aout_list::aout_buf_ht, pgbuf_aout_list::Aout_free, AOUT_HASH_IDX, pgbuf_aout_list::Aout_top, assert, pgbuf_buffer_pool::buf_AOUT_list, pgbuf_aout_buf::lru_idx, pgbuf_aout_list::max_count, mht_put(), mht_rem(), pgbuf_aout_buf::next, NULL, pgbuf_aout_buf::prev, pthread_mutex_lock, pthread_mutex_unlock, rv, pgbuf_aout_buf::vpid, VPID_COPY, and VPID_ISNULL.

Referenced by pgbuf_assign_direct_victim(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_fall_bcb_to_zone_3(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_add_watch_instance_internal	(	PGBUF_HOLDER *	holder,
		PAGE_PTR	pgptr,
		PGBUF_WATCHER *	watcher,
		const PGBUF_LATCH_MODE	latch_mode,
		const bool	clear_unfix_flag,
		const char *	caller_file,
		const int	caller_line
	)

Definition at line 12351 of file page_buffer.c.

References assert, pgbuf_holder::first_watcher, pgbuf_holder::last_watcher, pgbuf_watcher::latch_mode, pgbuf_watcher::next, NULL, p, pgbuf_watcher::page_was_unfixed, PGBUF_MAX_PAGE_WATCHERS, pgbuf_watcher::pgptr, pgbuf_watcher::prev, strlen, pgbuf_holder::watch_count, and pgbuf_watcher::watched_at.

Referenced by pgbuf_attach_watcher_debug(), pgbuf_ordered_fix_debug(), and pgbuf_replace_watcher_debug().

Here is the caller graph for this function:

void pgbuf_adjust_quotas ( THREAD_ENTRY * thread_p )

Definition at line 13052 of file page_buffer.c.

References pgbuf_page_quota::adjust_age, assert, pgbuf_buffer_pool::buf_invalid_list, pgbuf_lru_list::count_lru1, pgbuf_lru_list::count_lru2, pgbuf_lru_list::count_vict_cand, i, pgbuf_invalid_list::invalid_cnt, pgbuf_page_quota::is_adjusting, pgbuf_page_quota::last_adjust_time, pgbuf_page_monitor::lru_activity, pgbuf_page_monitor::lru_hits, MAX_PRIVATE_RATIO, MIN_PRIVATE_RATIO, pgbuf_buffer_pool::monitor, NULL, pgbuf_buffer_pool::num_buffers, pgbuf_buffer_pool::num_LRU_list, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_is_perf_tracking_and_active(), pgbuf_page_monitor::pg_unfix_cnt, PGBUF_BCB_CHECK_MUTEX_LEAKS, PGBUF_GET_LRU_LIST, PGBUF_IS_PRIVATE_LRU_INDEX, pgbuf_lfcq_add_lru_with_victims(), pgbuf_lru_adjust_zones(), PGBUF_LRU_ARE_ZONES_ONE_TWO_OVER_THRESHOLD, PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA, PGBUF_LRU_LIST_IS_OVER_QUOTA, PGBUF_LRU_ZONE_MIN_RATIO, PGBUF_MIN_SHARED_LIST_ADJUST_SIZE, PGBUF_PAGE_QUOTA_IS_ENABLED, PGBUF_PRIVATE_LRU_MAX_HARD_QUOTA, PGBUF_SHARED_LRU_COUNT, PGBUF_TOTAL_LRU_COUNT, PGBUF_TRAN_THRESHOLD_ACTIVITY, pgbuf_page_quota::private_pages_ratio, pthread_mutex_lock, pthread_mutex_unlock, pgbuf_lru_list::quota, pgbuf_buffer_pool::quota, pgbuf_buffer_pool::ratio_lru1, pgbuf_buffer_pool::ratio_lru2, thread_get_thread_entry_info(), pgbuf_lru_list::threshold_lru1, pgbuf_lru_list::threshold_lru2, tsc_elapsed_utime(), tsc_getticks(), and pgbuf_page_monitor::victim_rich.

Referenced by pgbuf_assign_private_lru(), pgbuf_get_page_flush_interval(), and pgbuf_release_private_lru().

Here is the caller graph for this function:

static PGBUF_BCB * pgbuf_allocate_bcb	(	THREAD_ENTRY *	thread_p,
		const VPID *	src_vpid
	)

static

Definition at line 7400 of file page_buffer.c.

References ARG_FILE_LINE, assert, ER_CSS_PTHREAD_COND_TIMEDOUT, er_errid(), ER_ERROR_SEVERITY, ER_INTERRUPTED, ER_PB_ALL_BUFFERS_DIRTY, er_set(), LOG_FIND_THREAD_TRAN_INDEX, NO_ERROR, NULL, pgbuf_status::num_flusher_waiting_threads, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG, pgbuf_bcb_update_flags(), PGBUF_BCB_VICTIM_DIRECT_FLAG, pgbuf_get_bcb_from_invalid_list(), pgbuf_get_victim(), pgbuf_is_page_flush_daemon_available(), PGBUF_TIMEOUT, pgbuf_victimize_bcb(), pgbuf_wakeup_page_flush_daemon(), PSTAT_PB_ALLOC_BCB, PSTAT_PB_ALLOC_BCB_COND_WAIT_HIGH_PRIO, PSTAT_PB_ALLOC_BCB_COND_WAIT_LOW_PRIO, PSTAT_PB_ALLOC_BCB_PRIORITIZE_VACUUM, PSTAT_PB_ALLOC_BCB_SEARCH_VICTIM, pgbuf_buffer_pool::show_status, THREAD_ALLOC_BCB_RESUMED, THREAD_ALLOC_BCB_SUSPENDED, thread_lock_entry(), THREAD_RESUME_DUE_TO_INTERRUPT, THREAD_RESUME_DUE_TO_SHUTDOWN, thread_suspend_timeout_wakeup_and_unlock_entry(), thread_unlock_entry(), and VACUUM_IS_THREAD_VACUUM.

Referenced by pgbuf_claim_bcb_for_fix().

Here is the caller graph for this function:

STATIC_INLINE PGBUF_HOLDER * pgbuf_allocate_thrd_holder_entry ( THREAD_ENTRY * thread_p )

Definition at line 5371 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_holder_set::element, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_holder::first_watcher, pgbuf_buffer_pool::free_holder_set, pgbuf_buffer_pool::free_index, pgbuf_holder::last_watcher, pgbuf_holder::next_holder, pgbuf_holder_set::next_set, NULL, pgbuf_holder_anchor::num_free_cnt, pgbuf_holder_anchor::num_hold_cnt, PGBUF_HOLDER_SET_SIZEOF, PGBUF_NUM_ALLOC_HOLDER, pthread_mutex_lock, pthread_mutex_unlock, rv, STATIC_INLINE, pgbuf_holder_anchor::thrd_free_list, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, thread_get_entry_index(), and pgbuf_holder::watch_count.

Referenced by pgbuf_latch_bcb_upon_fix(), pgbuf_latch_idle_page(), and pgbuf_promote_read_latch_debug().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_assign_direct_victim	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 14222 of file page_buffer.c.

References assert, cubregex::count(), pgbuf_bcb::flags, NULL, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), pgbuf_add_vpid_to_aout_list(), PGBUF_BCB_CHECK_OWN, PGBUF_BCB_FLUSHING_TO_DISK_FLAG, pgbuf_bcb_get_lru_index(), pgbuf_bcb_get_zone(), PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK, PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG, pgbuf_bcb_is_direct_victim(), pgbuf_bcb_is_dirty(), pgbuf_bcb_is_invalid_direct_victim(), PGBUF_BCB_LOCK, pgbuf_bcb_mark_was_flushed(), PGBUF_BCB_UNLOCK, pgbuf_bcb_update_flags(), PGBUF_BCB_VICTIM_DIRECT_FLAG, PGBUF_INVALID_ZONE, pgbuf_is_bcb_fixed_by_any(), PGBUF_IS_BCB_IN_LRU, PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, pgbuf_is_bcb_victimizable(), PGBUF_IS_PRIVATE_LRU_INDEX, pgbuf_lru_list_from_bcb(), PGBUF_LRU_LIST_IS_OVER_QUOTA, pgbuf_lru_remove_bcb(), PGBUF_VOID_ZONE, pgbuf_wake_flush_waiters(), PSTAT_PB_ASSIGN_DIRECT_BCB, PSTAT_PB_VICTIM_ASSIGN_DIRECT_FLUSH, REFPTR, STATIC_INLINE, THREAD_ALLOC_BCB_RESUMED, THREAD_ALLOC_BCB_SUSPENDED, thread_lock_entry(), thread_unlock_entry(), thread_wakeup_already_had_mutex(), and pgbuf_bcb::vpid.

Referenced by pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_add_new_bcb_to_bottom(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

int pgbuf_assign_private_lru	(	THREAD_ENTRY *	thread_p,
		bool	is_vacuum,
		const int	id
	)

Definition at line 13312 of file page_buffer.c.

References assert, i, pgbuf_page_monitor::lru_activity, pgbuf_buffer_pool::monitor, pgbuf_buffer_pool::num_buffers, pgbuf_adjust_quotas(), PGBUF_GET_LRU_LIST, PGBUF_LRU_LIST_COUNT, PGBUF_PAGE_QUOTA_IS_ENABLED, PGBUF_PRIVATE_LIST_FROM_LRU_INDEX, PGBUF_SHARED_LRU_COUNT, PGBUF_TOTAL_LRU_COUNT, PGBUF_TRAN_MAX_ACTIVITY, pgbuf_page_quota::private_lru_session_cnt, and pgbuf_buffer_pool::quota.

Referenced by session_state_create(), and vacuum_initialize().

Here is the caller graph for this function:

void pgbuf_attach_watcher_debug	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr,
		PGBUF_LATCH_MODE	latch_mode,
		HFID *	hfid,
		PGBUF_WATCHER *	watcher,
		const char *	caller_file,
		const int	caller_line
	)

Definition at line 12429 of file page_buffer.c.

References assert, pgbuf_watcher::curr_rank, HFID_IS_NULL, hfid::hpgid, NULL, vpid::pageid, pgbuf_add_watch_instance_internal(), pgbuf_get_holder(), pgbuf_get_vpid_ptr(), PGBUF_INIT_WATCHER, PGBUF_ORDERED_HEAP_HDR, PGBUF_ORDERED_HEAP_NORMAL, hfid::vfid, vpid::volid, vfid::volid, VPID_EQ, and VPID_INITIALIZER.

STATIC_INLINE bool pgbuf_bcb_avoid_victim ( const PGBUF_BCB * bcb )

Definition at line 15016 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK, and STATIC_INLINE.

Referenced by pgbuf_claim_bcb_for_fix(), pgbuf_get_victim_from_lru_list(), pgbuf_invalidate_all_debug(), pgbuf_invalidate_debug(), pgbuf_is_bcb_victimizable(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_change_zone	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		int	new_lru_idx,
		PGBUF_ZONE	new_zone
	)

Definition at line 14682 of file page_buffer.c.

References assert, pgbuf_lru_list::count_lru1, pgbuf_lru_list::count_lru2, pgbuf_lru_list::count_lru3, pgbuf_bcb::flags, pgbuf_page_monitor::lru_shared_pgs_cnt, pgbuf_buffer_pool::monitor, NULL, PGBUF_BCB_FLAGS_MASK, PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK, PGBUF_GET_LRU_INDEX, PGBUF_GET_LRU_LIST, PGBUF_GET_ZONE, PGBUF_IS_SHARED_LRU_INDEX, PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, PGBUF_LRU_3_ZONE, pgbuf_lru_add_victim_candidate(), pgbuf_lru_remove_victim_candidate(), PGBUF_LRU_ZONE_MASK, PGBUF_MAKE_ZONE, STATIC_INLINE, and pgbuf_lru_list::victim_hint.

Referenced by pgbuf_get_bcb_from_invalid_list(), pgbuf_lru_add_bcb_to_bottom(), pgbuf_lru_add_bcb_to_middle(), pgbuf_lru_add_bcb_to_top(), pgbuf_lru_adjust_zone1(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_put_bcb_into_invalid_list(), and pgbuf_remove_from_lru_list().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc	(	PGBUF_BCB *	bcb,
		const char *	file,
		int	line
	)

Definition at line 15116 of file page_buffer.c.

References pgbuf_bcb::count_fix_and_avoid_dealloc, er_log_debug, pgbuf_bcb_should_avoid_deallocation(), STATIC_INLINE, pgbuf_bcb::vpid, and VPID_AS_ARGS.

Referenced by pgbuf_claim_bcb_for_fix(), pgbuf_delete_from_hash_chain(), and pgbuf_put_bcb_into_invalid_list().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_clear_dirty	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 14861 of file page_buffer.c.

References PGBUF_BCB_DIRTY_FLAG, pgbuf_bcb_update_flags(), and STATIC_INLINE.

Referenced by pgbuf_invalidate_bcb().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_bcb_flush_with_wal	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		bool	is_page_flush_thread,
		bool *	is_bcb_locked
	)

Definition at line 9897 of file page_buffer.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR, pgbuf_holder::bufptr, CAST_BFPTR_TO_PGPTR, dwb_add_page(), dwb_is_created(), dwb_set_data_on_next_slot(), ER_FAILED, er_log_debug, error(), fileio_get_volume_descriptor(), fileio_write(), FILEIO_WRITE_DEFAULT_WRITE, FILEIO_WRITE_NO_COMPENSATE_WRITE, IO_MAX_PAGE_SIZE, IO_PAGESIZE, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_bcb::latch_mode, LOG_FIND_THREAD_TRAN_INDEX, logpb_flush_log_for_wal(), fileio_page_reserved::lsa, LSA_COPY(), LSA_ISNULL(), LSA_SET_NULL(), MAX_ALIGNMENT, NO_ERROR, NULL, pgbuf_status::num_pages_written, pgbuf_bcb::oldest_unflush_lsa, vpid::pageid, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), PGBUF_BCB_CHECK_OWN, PGBUF_BCB_LOCK, pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_mark_was_flushed(), pgbuf_bcb_mark_was_not_flushed(), PGBUF_BCB_UNLOCK, pgbuf_check_bcb_page_vpid(), pgbuf_get_tde_algorithm(), pgbuf_is_temporary_volume(), PGBUF_LATCH_FLUSH, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_NO_LATCH, pgbuf_wake_flush_waiters(), fileio_page::prv, PSTAT_PB_FLUSH_PAGE_FLUSHED, PSTAT_PB_FLUSH_SEND_DIRTY_TO_POST_FLUSH, PSTAT_PB_NUM_IOWRITES, PTR_ALIGN, qmgr_get_current_query_id(), pgbuf_buffer_pool::show_status, TDE_ALGORITHM_NONE, tde_encrypt_data_page(), pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, vpid::volid, pgbuf_bcb::vpid, VPID_AS_ARGS, and cubthread::daemon::wakeup().

Referenced by pgbuf_bcb_safe_flush_internal(), pgbuf_flush_neighbor_safe(), and pgbuf_flush_victim_candidates().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_bcb_get_lru_index ( const PGBUF_BCB * bcb )

Definition at line 14800 of file page_buffer.c.

References assert, pgbuf_bcb::flags, PGBUF_GET_LRU_INDEX, PGBUF_IS_BCB_IN_LRU, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_register_hit_for_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_advance_victim_hint(), pgbuf_lru_list_from_bcb(), pgbuf_lru_move_from_private_to_shared(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_should_move_private_to_shared(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_bcb_get_pool_index ( const PGBUF_BCB * bcb )

Definition at line 15028 of file page_buffer.c.

References pgbuf_buffer_pool::BCB_table, and STATIC_INLINE.

Referenced by pgbuf_check_bcb_page_vpid(), and pgbuf_unfix_all().

Here is the caller graph for this function:

STATIC_INLINE PGBUF_ZONE pgbuf_bcb_get_zone ( const PGBUF_BCB * bcb )

Definition at line 14788 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_GET_ZONE, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_invalidate_bcb(), pgbuf_lru_add_bcb_to_middle(), pgbuf_lru_adjust_zone1(), pgbuf_lru_adjust_zone2(), pgbuf_lru_adjust_zones(), pgbuf_lru_boost_bcb(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_lru_sanity_check(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_remove_from_lru_list(), pgbuf_unfix_all(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_async_flush_request ( const PGBUF_BCB * bcb )

Definition at line 14962 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_ASYNC_FLUSH_REQ, and STATIC_INLINE.

Referenced by pgbuf_block_bcb(), pgbuf_check_bcb_page_vpid(), pgbuf_flush_if_requested(), pgbuf_unfix_all(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_direct_victim ( const PGBUF_BCB * bcb )

Definition at line 14938 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_VICTIM_DIRECT_FLAG, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_fix_debug(), and pgbuf_invalidate_bcb().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_dirty ( const PGBUF_BCB * bcb )

Definition at line 14813 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_DIRTY_FLAG, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_safe_flush_internal(), pgbuf_check_bcb_page_vpid(), pgbuf_fix_debug(), pgbuf_flush_all_helper(), pgbuf_flush_checkpoint(), pgbuf_flush_page_and_neighbors_fb(), pgbuf_flush_seq_list(), pgbuf_flush_victim_candidates(), pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_invalidate_all_debug(), pgbuf_latch_bcb_upon_fix(), pgbuf_latch_idle_page(), pgbuf_unfix_all(), pgbuf_unfix_debug(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_flushing ( const PGBUF_BCB * bcb )

Definition at line 14926 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_FLUSHING_TO_DISK_FLAG, and STATIC_INLINE.

Referenced by pgbuf_bcb_safe_flush_internal(), pgbuf_block_bcb(), pgbuf_check_bcb_page_vpid(), pgbuf_delete_from_hash_chain(), pgbuf_flush_neighbor_safe(), pgbuf_flush_page_and_neighbors_fb(), pgbuf_flush_victim_candidates(), and pgbuf_unfix_all().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_hot ( const PGBUF_BCB * bcb )

Definition at line 15154 of file page_buffer.c.

References assert, pgbuf_bcb::count_fix_and_avoid_dealloc, PGBUF_BCB_COUNT_FIX_SHIFT_BITS, PGBUF_FIX_COUNT_THRESHOLD, and STATIC_INLINE.

Referenced by pgbuf_should_move_private_to_shared().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_invalid_direct_victim ( const PGBUF_BCB * bcb )

Definition at line 14950 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_is_to_vacuum ( const PGBUF_BCB * bcb )

Definition at line 15002 of file page_buffer.c.

References pgbuf_bcb::flags, PGBUF_BCB_TO_VACUUM_FLAG, and STATIC_INLINE.

Referenced by pgbuf_lru_fall_bcb_to_zone_3(), and pgbuf_victimize_bcb().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_mark_is_flushing	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 14876 of file page_buffer.c.

References PGBUF_BCB_ASYNC_FLUSH_REQ, PGBUF_BCB_DIRTY_FLAG, PGBUF_BCB_FLUSHING_TO_DISK_FLAG, pgbuf_bcb_is_dirty(), pgbuf_bcb_update_flags(), and STATIC_INLINE.

Referenced by pgbuf_bcb_flush_with_wal().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_mark_was_flushed	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 14899 of file page_buffer.c.

References PGBUF_BCB_FLUSHING_TO_DISK_FLAG, pgbuf_bcb_update_flags(), and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), and pgbuf_bcb_flush_with_wal().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_mark_was_not_flushed	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		bool	mark_dirty
	)

Definition at line 14913 of file page_buffer.c.

References PGBUF_BCB_DIRTY_FLAG, PGBUF_BCB_FLUSHING_TO_DISK_FLAG, pgbuf_bcb_update_flags(), and STATIC_INLINE.

Referenced by pgbuf_bcb_flush_with_wal().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_register_avoid_deallocation ( PGBUF_BCB * bcb )

Definition at line 15040 of file page_buffer.c.

References assert, pgbuf_bcb::count_fix_and_avoid_dealloc, and STATIC_INLINE.

Referenced by pgbuf_fix_debug(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_register_fix ( PGBUF_BCB * bcb )

Definition at line 15133 of file page_buffer.c.

References assert, pgbuf_bcb::count_fix_and_avoid_dealloc, PGBUF_BCB_COUNT_FIX_SHIFT_BITS, PGBUF_FIX_COUNT_THRESHOLD, and STATIC_INLINE.

Referenced by pgbuf_fix_debug().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_register_hit_for_lru ( PGBUF_BCB * bcb )

Definition at line 15392 of file page_buffer.c.

References pgbuf_page_quota::adjust_age, assert, pgbuf_bcb::hit_age, pgbuf_page_monitor::lru_hits, pgbuf_buffer_pool::monitor, pgbuf_bcb_get_lru_index(), PGBUF_IS_BCB_IN_LRU, and pgbuf_buffer_pool::quota.

Referenced by pgbuf_lru_move_from_private_to_shared(), pgbuf_unlatch_bcb_upon_unfix(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

static int pgbuf_bcb_safe_flush_force_lock	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		bool	synchronous
	)

static

Definition at line 7985 of file page_buffer.c.

References NO_ERROR, PGBUF_BCB_LOCK, pgbuf_bcb_safe_flush_internal(), and PGBUF_BCB_UNLOCK.

Referenced by pgbuf_flush_seq_list(), pgbuf_invalidate_all_debug(), and pgbuf_invalidate_debug().

Here is the caller graph for this function:

static int pgbuf_bcb_safe_flush_force_unlock	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		bool	synchronous
	)

static

Definition at line 7962 of file page_buffer.c.

References NO_ERROR, pgbuf_bcb_safe_flush_internal(), and PGBUF_BCB_UNLOCK.

Referenced by pgbuf_flush_all_helper(), pgbuf_flush_if_requested(), pgbuf_flush_with_wal(), pgbuf_unfix_debug(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

static int pgbuf_bcb_safe_flush_internal	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		bool	synchronous,
		bool *	locked
	)

static

Definition at line 8018 of file page_buffer.c.

References assert, ASSERT_ERROR, pgbuf_bcb::latch_mode, NO_ERROR, NULL, PGBUF_BCB_ASYNC_FLUSH_REQ, PGBUF_BCB_CHECK_OWN, pgbuf_bcb_flush_with_wal(), pgbuf_bcb_is_dirty(), pgbuf_bcb_is_flushing(), pgbuf_bcb_update_flags(), pgbuf_block_bcb(), pgbuf_find_thrd_holder(), PGBUF_LATCH_FLUSH, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, and PGBUF_NO_LATCH.

Referenced by pgbuf_bcb_safe_flush_force_lock(), pgbuf_bcb_safe_flush_force_unlock(), and pgbuf_flush_seq_list().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_set_dirty	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 14825 of file page_buffer.c.

References assert, pgbuf_page_monitor::dirties_cnt, pgbuf_bcb::flags, pgbuf_buffer_pool::monitor, pgbuf_buffer_pool::num_buffers, PGBUF_BCB_DIRTY_FLAG, PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK, PGBUF_GET_ZONE, PGBUF_LRU_3_ZONE, pgbuf_lru_list_from_bcb(), pgbuf_lru_remove_victim_candidate(), and STATIC_INLINE.

Referenced by pgbuf_set_dirty_buffer_ptr().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_should_avoid_deallocation ( const PGBUF_BCB * bcb )

Definition at line 15097 of file page_buffer.c.

References assert, pgbuf_bcb::count_fix_and_avoid_dealloc, PGBUF_BCB_AVOID_DEALLOC_MASK, and STATIC_INLINE.

Referenced by pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc(), pgbuf_has_prevent_dealloc(), pgbuf_ordered_fix_debug(), and pgbuf_peek_stats().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_bcb_should_be_moved_to_bottom_lru ( const PGBUF_BCB * bcb )

Definition at line 14974 of file page_buffer.c.

References pgbuf_bcb::flags, and PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG.

Referenced by pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_unregister_avoid_deallocation ( PGBUF_BCB * bcb )

Definition at line 15053 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_bcb::count_fix_and_avoid_dealloc, er_log_debug, PGBUF_BCB_AVOID_DEALLOC_MASK, STATIC_INLINE, pgbuf_bcb::vpid, and VPID_AS_ARGS.

Referenced by pgbuf_fix_debug(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_bcb_update_flags	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		int	set_flags,
		int	clear_flags
	)

Definition at line 14584 of file page_buffer.c.

References assert, pgbuf_page_monitor::dirties_cnt, pgbuf_bcb::flags, pgbuf_buffer_pool::monitor, NULL, pgbuf_buffer_pool::num_buffers, PGBUF_BCB_DIRTY_FLAG, PGBUF_BCB_FLAGS_MASK, PGBUF_BCB_INVALID_VICTIM_CANDIDATE_MASK, PGBUF_GET_ZONE, PGBUF_LRU_3_ZONE, pgbuf_lru_add_victim_candidate(), pgbuf_lru_list_from_bcb(), pgbuf_lru_remove_victim_candidate(), and STATIC_INLINE.

Referenced by pgbuf_allocate_bcb(), pgbuf_assign_direct_victim(), pgbuf_bcb_clear_dirty(), pgbuf_bcb_mark_is_flushing(), pgbuf_bcb_mark_was_flushed(), pgbuf_bcb_mark_was_not_flushed(), pgbuf_bcb_safe_flush_internal(), pgbuf_claim_bcb_for_fix(), pgbuf_dealloc_page(), pgbuf_fix_debug(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_notify_vacuum_follows(), and pgbuf_victimize_bcb().

Here is the caller graph for this function:

static int pgbuf_block_bcb	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		PGBUF_LATCH_MODE	request_mode,
		int	request_fcnt,
		bool	as_promote
	)

static

Definition at line 6410 of file page_buffer.c.

References ARG_FILE_LINE, assert, ER_CSS_PTHREAD_COND_TIMEDWAIT, ER_ERROR_SEVERITY, ER_FAILED, ER_INTERRUPTED, ER_LK_PAGE_TIMEOUT, ER_LK_UNILATERALLY_ABORTED, er_log_debug, ER_PAGE_LATCH_TIMEDOUT, er_set(), er_set_with_oserror(), pgbuf_bcb::fcnt, if(), pgbuf_bcb::latch_mode, LK_FORCE_ZERO_WAIT, LK_INFINITE_WAIT, LK_ZERO_WAIT, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_client_name_host_pid(), logtb_is_current_active(), NO_ERROR, NULL, vpid::pageid, pgbuf_bcb_is_async_flush_request(), pgbuf_bcb_is_flushing(), PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, pgbuf_find_current_wait_msecs(), PGBUF_LATCH_FLUSH, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_NO_LATCH, PGBUF_TIMEOUT, STATIC_INLINE, thread_get_thread_entry_info(), thread_lock_entry(), THREAD_PGBUF_RESUMED, THREAD_PGBUF_SUSPENDED, thread_suspend_wakeup_and_unlock_entry(), thread_unlock_entry(), TSC_ADD_TIMEVAL, tsc_elapsed_time_usec(), tsc_getticks(), vpid::volid, and pgbuf_bcb::vpid.

Referenced by pgbuf_bcb_safe_flush_internal(), pgbuf_latch_bcb_upon_fix(), and pgbuf_promote_read_latch_debug().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_check_bcb_page_vpid	(	PGBUF_BCB *	bufptr,
		bool	maybe_deallocated
	)

Definition at line 10415 of file page_buffer.c.

Referenced by pgbuf_bcb_flush_with_wal(), pgbuf_check_page_ptype_internal(), pgbuf_fix_debug(), pgbuf_get_page_id(), pgbuf_get_page_ptype(), pgbuf_set_page_ptype(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

bool pgbuf_check_page_ptype	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr,
		PAGE_TYPE	ptype
	)

Definition at line 10326 of file page_buffer.c.

References pgbuf_check_page_ptype_internal().

Referenced by btree_advance_to_next_slot_and_fix_page(), btree_build_nleafs(), btree_check_pages(), btree_check_tree(), btree_find_AR_sampling_leaf(), btree_find_boundary_leaf(), btree_find_free_overflow_oids_page(), btree_find_key(), btree_find_key_from_nleaf(), btree_find_min_or_max_key(), btree_find_next_index_record_holding_current_helper(), btree_fix_ovfl_oid_page(), btree_fix_ovfl_oid_pages_tree(), btree_get_asc_desc(), btree_get_new_page(), btree_get_next_page(), btree_get_node_header(), btree_get_num_visible_oids_from_all_ovf(), btree_get_overflow_header(), btree_get_root_header(), btree_get_stats(), btree_get_subtree_capacity(), btree_get_unique_statistics(), btree_index_capacity(), btree_key_find_first_visible_row_from_all_ovf(), btree_load_new_page(), btree_merge_node(), btree_merge_node_and_advance(), btree_node_number_of_keys(), btree_read_key_type(), btree_reflect_global_unique_statistics(), btree_repair_prev_link_by_btid(), btree_replace_first_oid_with_ovfl_oid(), btree_rv_read_keyval_info_nocopy(), btree_verify_subtree(), btree_verify_tree(), catalog_adjust_directory_count(), catalog_check_class_consistency(), catalog_create(), catalog_drop_disk_representation_from_page(), catalog_drop_representation_class_from_page(), catalog_drop_representation_helper(), catalog_fetch_btree_statistics(), catalog_file_map_find_optimal_page(), catalog_get_class_info(), catalog_get_new_page(), catalog_get_record_from_page(), catalog_get_rep_dir(), catalog_get_representation_record(), catalog_update_class_info(), disk_rv_reserve_sectors(), disk_rv_unreserve_sectors(), disk_verify_volume_header(), disk_volheader_check_magic(), ehash_create_helper(), ehash_fix_old_page(), ehash_insert_to_bucket_after_create(), heap_check_all_pages(), heap_compact_pages(), heap_delete_bigone(), heap_estimate(), heap_find_location_and_insert_rec_newhome(), heap_fix_forward_page(), heap_fix_header_page(), heap_flush(), heap_get_num_objects(), heap_ovf_find_vfid(), heap_reuse(), heap_rv_redo_reuse_page(), heap_rv_undoredo_pagehdr(), heap_scan_pb_lock_and_fetch_debug(), heap_stats_find_best_page(), heap_stats_sync_bestspace(), heap_stats_update_internal(), heap_vacuum_all_objects(), heap_vpid_next(), heap_vpid_prev(), orc_diskrep_from_record(), overflow_get_capacity(), overflow_get_length(), overflow_get_nbytes(), overflow_insert(), overflow_traverse(), overflow_update(), pgbuf_copy_to_area(), pgbuf_ordered_fix_debug(), qfile_reopen_list_as_append_mode(), qmgr_get_old_page(), scan_open_index_scan(), vacuum_heap_page(), xbtree_add_index(), xbtree_delete_index(), xbtree_get_unique_pk(), xfile_apply_tde_to_class_files(), and xheap_reclaim_addresses().

STATIC_INLINE bool pgbuf_check_page_ptype_internal	(	PAGE_PTR	pgptr,
		PAGE_TYPE	ptype,
		bool	no_error
	)

Definition at line 10356 of file page_buffer.c.

References assert, assert_release, CAST_PGPTR_TO_BFPTR, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, log_is_in_crash_recovery(), NULL, PAGE_UNKNOWN, pgbuf_check_bcb_page_vpid(), PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), fileio_page::prv, fileio_page_reserved::ptype, STATIC_INLINE, pgbuf_bcb::vpid, and VPID_ISNULL.

Referenced by pgbuf_check_page_ptype(), and pgbuf_check_page_type_no_error().

Here is the caller graph for this function:

bool pgbuf_check_page_type_no_error	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr,
		PAGE_TYPE	ptype
	)

Definition at line 10341 of file page_buffer.c.

References pgbuf_check_page_ptype_internal(), and STATIC_INLINE.

static PGBUF_BCB * pgbuf_claim_bcb_for_fix	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		PAGE_FETCH_MODE	fetch_mode,
		PGBUF_BUFFER_HASH *	hash_anchor,
		PGBUF_FIX_PERF *	perf,
		bool *	try_again
	)

static

Definition at line 7617 of file page_buffer.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR, CAST_IOPGPTR_TO_PGPTR, dwb_read_page(), pgbuf_fix_perf::end_tick, ER_CSS_PTHREAD_MUTEX_TRYLOCK, er_errid(), fileio_get_volume_descriptor(), fileio_init_lsa_of_page(), fileio_read(), IO_PAGESIZE, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_fix_perf::is_perf_tracking, pgbuf_bcb::latch_mode, pgbuf_fix_perf::lock_wait_time, LOG_FIND_THREAD_TRAN_INDEX, log_is_in_crash_recovery(), fileio_page_reserved::lsa, LSA_ISNULL(), LSA_SET_NULL(), NEW_PAGE, NO_ERROR, NULL, NULL_VOLID, pgbuf_status::num_hit, pgbuf_status::num_pages_created, pgbuf_status::num_pages_read, OLD_PAGE_IF_IN_BUFFER, pgbuf_bcb::oldest_unflush_lsa, fileio_page_reserved::pageid, vpid::pageid, pgbuf_fix_perf::perf_page_found, PERF_PAGE_MODE_NEW_LOCK_WAIT, PERF_PAGE_MODE_NEW_NO_WAIT, PERF_PAGE_MODE_OLD_LOCK_WAIT, PERF_PAGE_MODE_OLD_NO_WAIT, perfmon_inc_stat(), pgbuf_allocate_bcb(), PGBUF_BCB_ASYNC_FLUSH_REQ, pgbuf_bcb_avoid_victim(), pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc(), PGBUF_BCB_CHECK_MUTEX_LEAKS, pgbuf_bcb_update_flags(), pgbuf_get_tde_algorithm(), pgbuf_init_temp_page_lsa(), pgbuf_is_temp_lsa(), pgbuf_is_temporary_volume(), PGBUF_LOCK_HOLDER, pgbuf_lock_page(), PGBUF_NO_LATCH, pgbuf_put_bcb_into_invalid_list(), pgbuf_set_dirty_buffer_ptr(), pgbuf_unlock_page(), fileio_page::prv, PSTAT_PB_NUM_IOREADS, PSTAT_SORT_NUM_DATA_PAGES, PSTAT_SORT_NUM_IO_PAGES, pthread_mutex_unlock, qmgr_get_current_query_id(), pgbuf_buffer_pool::show_status, pgbuf_fix_perf::start_tick, success(), TDE_ALGORITHM_NONE, tde_decrypt_data_page(), thread_get_sort_stats_active(), tsc_elapsed_time_usec(), tsc_getticks(), pgbuf_fix_perf::tv_diff, fileio_page_reserved::volid, vpid::volid, and pgbuf_bcb::vpid.

Referenced by pgbuf_fix_debug().

Here is the caller graph for this function:

static int pgbuf_compare_hold_vpid_for_sort	(	const void *	p1,
		const void *	p2
	)

static

Definition at line 11355 of file page_buffer.c.

References diff, pgbuf_holder_info::group_id, vpid::pageid, pgbuf_holder_info::rank, vpid::volid, pgbuf_holder_info::vpid, and VPID_ISNULL.

Referenced by pgbuf_get_condition_for_ordered_fix(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

static int pgbuf_compare_victim_list	(	const void *	p1,
		const void *	p2
	)

static

Definition at line 3128 of file page_buffer.c.

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

Referenced by pgbuf_flush_checkpoint(), and pgbuf_flush_victim_candidates().

Here is the caller graph for this function:

int pgbuf_compare_vpid	(	const void *	key_vpid1,
		const void *	key_vpid2
	)

Definition at line 1287 of file page_buffer.c.

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

Referenced by pgbuf_initialize_aout_list().

Here is the caller graph for this function:

static void pgbuf_compute_lru_vict_target ( float * lru_sum_flush_priority )

static

Definition at line 12919 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_invalid_list, pgbuf_lru_list::count_lru3, diff, i, pgbuf_invalid_list::invalid_cnt, pgbuf_page_monitor::lru_shared_pgs_cnt, pgbuf_page_quota::lru_victim_flush_priority_per_lru, pgbuf_buffer_pool::monitor, NULL, pgbuf_buffer_pool::num_buffers, pgbuf_buffer_pool::num_LRU_list, PGBUF_GET_LRU_LIST, PGBUF_IS_PRIVATE_LRU_INDEX, PGBUF_IS_SHARED_LRU_INDEX, PGBUF_LRU_INDEX_FROM_PRIVATE, PGBUF_LRU_LIST_COUNT, PGBUF_LRU_ZONE_MIN_RATIO, PGBUF_MIN_SHARED_LIST_ADJUST_SIZE, PGBUF_SHARED_LRU_COUNT, PGBUF_TOTAL_LRU_COUNT, pgbuf_page_quota::private_pages_ratio, pgbuf_lru_list::quota, pgbuf_buffer_pool::quota, pgbuf_buffer_pool::ratio_lru1, and pgbuf_buffer_pool::ratio_lru2.

Referenced by pgbuf_flush_victim_candidates().

Here is the caller graph for this function:

static const char* pgbuf_consistent_str ( int consistent )

static

Definition at line 13810 of file page_buffer.c.

References PGBUF_CONTENT_BAD, and PGBUF_CONTENT_GOOD.

Referenced by pgbuf_check_bcb_page_vpid(), and pgbuf_unfix_all().

Here is the caller graph for this function:

void* pgbuf_copy_from_area	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		int	start_offset,
		int	length,
		void *	area,
		bool	do_fetch,
		TDE_ALGORITHM	tde_algo
	)

Definition at line 4192 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_hash_table, DB_PAGESIZE, DISK_VALID, ER_CSS_PTHREAD_MUTEX_TRYLOCK, er_errid(), fileio_get_volume_descriptor(), FREE, log_skip_logging(), NEW_PAGE, NULL, log_data_addr::offset, PAGE_AREA, vpid::pageid, perfmon_inc_stat(), PGBUF_BCB_UNLOCK, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_fix, pgbuf_get_check_page_validation_level(), PGBUF_HASH_VALUE, pgbuf_is_valid_page(), PGBUF_LATCH_WRITE, pgbuf_search_hash_chain(), pgbuf_set_dirty(), pgbuf_set_page_ptype(), pgbuf_set_tde_algorithm(), PGBUF_UNCONDITIONAL_LATCH, log_data_addr::pgptr, PSTAT_PB_NUM_IOWRITES, pthread_mutex_unlock, log_data_addr::vfid, and vpid::volid.

Referenced by sort_write_area().

Here is the caller graph for this function:

void* pgbuf_copy_to_area	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		int	start_offset,
		int	length,
		void *	area,
		bool	do_fetch
	)

Definition at line 4067 of file page_buffer.c.

References ARG_FILE_LINE, pgbuf_buffer_pool::buf_hash_table, CAST_BFPTR_TO_PGPTR, pgbuf_buffer_pool::check_for_interrupts, DB_PAGESIZE, DISK_VALID, ER_CSS_PTHREAD_MUTEX_TRYLOCK, er_errid(), ER_ERROR_SEVERITY, ER_FATAL_ERROR_SEVERITY, ER_GENERIC_ERROR, ER_INTERRUPTED, er_log_debug, er_set(), fileio_get_volume_descriptor(), logtb_is_interrupted(), NULL, OLD_PAGE, PAGE_AREA, vpid::pageid, perfmon_inc_stat(), PGBUF_BCB_UNLOCK, pgbuf_check_page_ptype(), PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_fix, pgbuf_get_check_page_validation_level(), PGBUF_HASH_VALUE, pgbuf_is_valid_page(), PGBUF_LATCH_READ, pgbuf_search_hash_chain(), PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix_and_init, PSTAT_PB_NUM_IOREADS, PSTAT_SORT_NUM_DATA_PAGES, pthread_mutex_unlock, thread_get_sort_stats_active(), and vpid::volid.

Referenced by sort_read_area().

Here is the caller graph for this function:

void pgbuf_daemons_get_stats ( UINT64 * stats_out )

Definition at line 16048 of file page_buffer.c.

References cubthread::daemon::get_stats(), cubthread::daemon::get_stats_value_count(), and NULL.

Referenced by perfmon_stat_dump_in_buffer_thread_daemon_stats().

Here is the caller graph for this function:

void pgbuf_dealloc_page	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	page_dealloc
	)

Definition at line 13976 of file page_buffer.c.

References ARG_FILE_LINE, assert, CAST_PGPTR_TO_BFPTR, er_log_debug, pgbuf_bcb::fcnt, FILEIO_PAGE_FLAG_ENCRYPTED_MASK, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, log_append_undoredo_data2(), NULL, PAGE_UNKNOWN, fileio_page_reserved::pageid, pgbuf_dealloc_undo_data::pageid, fileio_page_reserved::pflag, pgbuf_dealloc_undo_data::pflag, PGBUF_BCB_DIRTY_FLAG, PGBUF_BCB_LOCK, PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG, pgbuf_bcb_update_flags(), pgbuf_get_tde_algorithm(), pgbuf_unlatch_bcb_upon_unfix(), pgbuf_unlatch_thrd_holder(), fileio_page::prv, fileio_page_reserved::ptype, pgbuf_dealloc_undo_data::ptype, RVPGBUF_DEALLOC, tde_get_algorithm_name(), fileio_page_reserved::volid, pgbuf_dealloc_undo_data::volid, pgbuf_bcb::vpid, and VPID_AS_ARGS.

Referenced by file_destroy(), file_perm_dealloc(), file_sector_map_dealloc(), and file_table_move_partial_sectors_to_header().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_delete_from_hash_chain	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr
	)

Definition at line 7099 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_buffer_pool::buf_hash_table, ER_FAILED, pgbuf_bcb::hash_next, pgbuf_buffer_hash::hash_next, pgbuf_bcb::latch_mode, NO_ERROR, NULL, PERFMON_ACTIVATION_FLAG_PB_HASH_ANCHOR, perfmon_add_stat(), perfmon_get_activation_flag(), perfmon_inc_stat(), perfmon_is_perf_tracking(), perfmon_is_perf_tracking_and_active(), pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc(), pgbuf_bcb_is_flushing(), PGBUF_BCB_UNLOCK, PGBUF_HASH_VALUE, PGBUF_NO_LATCH, pgbuf_put_bcb_into_invalid_list(), PSTAT_PB_NUM_HASH_ANCHOR_WAITS, PSTAT_PB_TIME_HASH_ANCHOR_WAIT, pthread_mutex_lock, pthread_mutex_unlock, rv, tsc_elapsed_utime(), tsc_getticks(), pgbuf_bcb::vpid, and VPID_SET_NULL.

Referenced by pgbuf_invalidate_bcb(), and pgbuf_victimize_bcb().

Here is the caller graph for this function:

void pgbuf_finalize ( void )

Definition at line 1528 of file page_buffer.c.

Referenced by logtb_undefine_trantable(), and pgbuf_initialize().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_find_current_wait_msecs ( THREAD_ENTRY * thread_p )

Definition at line 15744 of file page_buffer.c.

References LOG_FIND_TDES(), LOG_FIND_THREAD_TRAN_INDEX, NULL, and log_tdes::wait_msecs.

Referenced by pgbuf_block_bcb(), pgbuf_fix_debug(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

STATIC_INLINE PGBUF_HOLDER * pgbuf_find_thrd_holder	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr
	)

Definition at line 5450 of file page_buffer.c.

References assert, pgbuf_holder::bufptr, pgbuf_holder::next_holder, NULL, STATIC_INLINE, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, and thread_get_entry_index().

Referenced by pgbuf_bcb_safe_flush_internal(), pgbuf_fix_debug(), pgbuf_flush_if_requested(), pgbuf_flush_with_wal(), pgbuf_latch_bcb_upon_fix(), pgbuf_latch_idle_page(), pgbuf_promote_read_latch_debug(), pgbuf_set_dirty_buffer_ptr(), and pgbuf_unlatch_thrd_holder().

Here is the caller graph for this function:

PAGE_PTR pgbuf_fix_debug	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		PAGE_FETCH_MODE	fetch_mode,
		PGBUF_LATCH_MODE	request_mode,
		PGBUF_LATCH_CONDITION	condition,
		const char *	caller_file,
		int	caller_line
	)

Definition at line 1789 of file page_buffer.c.

References ARG_FILE_LINE, assert, ASSERT_ERROR, assert_release, pgbuf_iopage_buffer::bcb, pgbuf_buffer_pool::buf_hash_table, CAST_BFPTR_TO_PGPTR, pgbuf_buffer_pool::check_for_interrupts, DISK_VALID, pgbuf_fix_perf::end_tick, ER_ERROR_SEVERITY, ER_FATAL_ERROR_SEVERITY, ER_INTERRUPTED, ER_PB_BAD_PAGEID, er_set(), ER_WARNING_SEVERITY, fileio_get_volume_label(), pgbuf_page_monitor::fix_req_cnt, pgbuf_fix_perf::fix_wait_time, pgbuf_fix_perf::holder_wait_time, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_fix_perf::is_perf_tracking, pgbuf_holder::last_watcher, LK_FORCE_ZERO_WAIT, LK_ZERO_WAIT, pgbuf_fix_perf::lock_wait_time, LOG_FIND_THREAD_TRAN_INDEX, log_is_in_crash_recovery_and_not_yet_completes_redo(), logtb_get_check_interrupt(), logtb_is_interrupted(), LSA_ISNULL(), pgbuf_watcher::magic, pgbuf_buffer_pool::monitor, NEW_PAGE, NO_ERROR, NULL, pgbuf_status::num_hit, pgbuf_status::num_page_request, OLD_PAGE, OLD_PAGE_DEALLOCATED, OLD_PAGE_IF_IN_BUFFER, OLD_PAGE_MAYBE_DEALLOCATED, OLD_PAGE_PREVENT_DEALLOC, pgbuf_bcb::oldest_unflush_lsa, PAGE_UNKNOWN, vpid::pageid, PEEK, pgbuf_fix_perf::perf_cond_type, PERF_CONDITIONAL_FIX, PERF_HOLDER_LATCH_READ, PERF_HOLDER_LATCH_WRITE, pgbuf_fix_perf::perf_latch_mode, pgbuf_fix_perf::perf_page_found, PERF_PAGE_MODE_OLD_IN_BUFFER, pgbuf_fix_perf::perf_page_type, PERF_UNCONDITIONAL_FIX_NO_WAIT, PERF_UNCONDITIONAL_FIX_WITH_WAIT, perfmon_inc_stat(), perfmon_is_perf_tracking(), pgbuf_add_fixed_at(), PGBUF_BCB_CHECK_MUTEX_LEAKS, PGBUF_BCB_INVALIDATE_DIRECT_VICTIM_FLAG, pgbuf_bcb_is_direct_victim(), pgbuf_bcb_is_dirty(), PGBUF_BCB_LOCK, pgbuf_bcb_register_avoid_deallocation(), pgbuf_bcb_register_fix(), PGBUF_BCB_TO_VACUUM_FLAG, PGBUF_BCB_UNLOCK, pgbuf_bcb_unregister_avoid_deallocation(), pgbuf_bcb_update_flags(), PGBUF_BCB_VICTIM_DIRECT_FLAG, pgbuf_check_bcb_page_vpid(), pgbuf_claim_bcb_for_fix(), PGBUF_CONDITIONAL_LATCH, PGBUF_DEBUG_PAGE_VALIDATION_FETCH, pgbuf_find_current_wait_msecs(), pgbuf_find_thrd_holder(), pgbuf_get_check_page_validation_level(), pgbuf_get_holder(), pgbuf_get_page_type_for_stat(), PGBUF_HASH_VALUE, pgbuf_insert_into_hash_chain(), pgbuf_is_lsa_temporary(), pgbuf_is_valid_page(), pgbuf_latch_bcb_upon_fix(), PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, pgbuf_put_bcb_into_invalid_list(), pgbuf_search_hash_chain(), pgbuf_set_bcb_page_vpid(), PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix, pgbuf_unlock_page(), PGBUF_WATCHER_MAGIC_NUMBER, pgbuf_watcher::prev, fileio_page::prv, PSTAT_PB_NUM_FETCHES, pthread_mutex_unlock, fileio_page_reserved::ptype, pgbuf_buffer_pool::show_status, pgbuf_fix_perf::start_holder_tick, pgbuf_fix_perf::start_tick, tsc_elapsed_time_usec(), tsc_getticks(), pgbuf_fix_perf::tv_diff, VACUUM_IS_THREAD_VACUUM_WORKER, and vpid::volid.

Referenced by heap_scan_pb_lock_and_fetch_debug(), pgbuf_fix_if_not_deallocated_with_caller(), pgbuf_fix_with_retry(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

int pgbuf_fix_if_not_deallocated_with_caller	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		PGBUF_LATCH_MODE	latch_mode,
		PGBUF_LATCH_CONDITION	latch_condition,
		PAGE_PTR *	page,
		const char *	caller_file,
		int	caller_line
	)

Definition at line 14152 of file page_buffer.c.

References assert, ASSERT_ERROR_AND_SET, DISK_ERROR, DISK_INVALID, disk_is_page_sector_reserved(), DISK_VALID, er_clear(), ER_PB_BAD_PAGEID, log_is_in_crash_recovery_and_not_yet_completes_redo(), NO_ERROR, NULL, OLD_PAGE_MAYBE_DEALLOCATED, vpid::pageid, pgbuf_fix_debug(), pgbuf_is_hit_ratio_low(), STATIC_INLINE, vpid::volid, and VPID_ISNULL.

PAGE_PTR pgbuf_fix_with_retry	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		PAGE_FETCH_MODE	fetch_mode,
		PGBUF_LATCH_MODE	request_mode,
		int	retry
	)

Definition at line 1723 of file page_buffer.c.

References ARG_FILE_LINE, er_errid(), ER_ERROR_SEVERITY, ER_INTERRUPTED, ER_LK_PAGE_TIMEOUT, ER_LK_UNILATERALLY_ABORTED, ER_PAGE_LATCH_ABORTED, ER_PAGE_LATCH_TIMEDOUT, er_set(), NO_ERROR, NULL, vpid::pageid, pgbuf_fix, pgbuf_fix_debug(), PGBUF_UNCONDITIONAL_LATCH, and vpid::volid.

static void pgbuf_flags_mask_sanity_check ( void )

static

Definition at line 15634 of file page_buffer.c.

References PGBUF_ABORT_RELEASE, PGBUF_BCB_FLAGS_MASK, PGBUF_INVALID_ZONE, PGBUF_LRU_INDEX_MASK, PGBUF_LRU_ZONE_MASK, PGBUF_VOID_ZONE, and PGBUF_ZONE_MASK.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

void pgbuf_flush	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr,
		bool	free_page
	)

Definition at line 2933 of file page_buffer.c.

References ASSERT_ERROR, FREE, NULL, pgbuf_flush_with_wal(), and pgbuf_unfix.

Referenced by disk_set_checkpoint(), disk_set_creation(), disk_set_link(), disk_stab_init(), and pgbuf_rv_flush_page().

Here is the caller graph for this function:

int pgbuf_flush_all	(	THREAD_ENTRY *	thread_p,
		VOLID	volid
	)

Definition at line 3083 of file page_buffer.c.

References pgbuf_flush_all_helper().

Referenced by boot_create_all_volumes(), disk_format(), disk_unformat(), log_final(), log_recovery(), log_recovery_redo(), log_recovery_undo(), log_recreate(), log_rv_outside_noop_redo(), and logpb_rename_all_volumes_files().

Here is the caller graph for this function:

static int pgbuf_flush_all_helper	(	THREAD_ENTRY *	thread_p,
		VOLID	volid,
		bool	is_unfixed_only,
		bool	is_set_lsa_as_null
	)

static

Definition at line 3030 of file page_buffer.c.

References assert, ER_FAILED, pgbuf_bcb::fcnt, fileio_init_lsa_of_page(), i, IO_PAGESIZE, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, NO_ERROR, NULL_VOLID, pgbuf_buffer_pool::num_buffers, pgbuf_bcb_is_dirty(), PGBUF_BCB_LOCK, pgbuf_bcb_safe_flush_force_unlock(), PGBUF_BCB_UNLOCK, PGBUF_FIND_BCB_PTR, vpid::volid, and pgbuf_bcb::vpid.

Referenced by pgbuf_flush_all(), pgbuf_flush_all_unfixed(), and pgbuf_flush_all_unfixed_and_set_lsa_as_null().

Here is the caller graph for this function:

int pgbuf_flush_all_unfixed	(	THREAD_ENTRY *	thread_p,
		VOLID	volid
	)

Definition at line 3099 of file page_buffer.c.

References pgbuf_flush_all_helper().

Referenced by log_commit(), logpb_backup_for_volume(), and logpb_copy_volume().

Here is the caller graph for this function:

int pgbuf_flush_all_unfixed_and_set_lsa_as_null	(	THREAD_ENTRY *	thread_p,
		VOLID	volid
	)

Definition at line 3116 of file page_buffer.c.

References pgbuf_flush_all_helper().

Referenced by log_recreate(), logpb_copy_database(), and logpb_copy_volume().

Here is the caller graph for this function:

int pgbuf_flush_checkpoint	(	THREAD_ENTRY *	thread_p,
		const LOG_LSA *	flush_upto_lsa,
		const LOG_LSA *	prev_chkpt_redo_lsa,
		LOG_LSA *	smallest_lsa,
		int *	flushed_page_cnt
	)

Definition at line 3552 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_victim_candidate_list::bufptr, detailed_er_log, ER_ERROR_SEVERITY, ER_FAILED, ER_LOG_CHECKPOINT_SKIP_INVALID_PAGE, er_set(), er_stack_pop(), er_stack_push(), error(), fileio_get_volume_label(), pgbuf_seq_flusher::flush_cnt, pgbuf_seq_flusher::flush_idx, pgbuf_seq_flusher::flush_list, pgbuf_seq_flusher::flush_max_size, pgbuf_seq_flusher::flush_upto_lsa, pgbuf_seq_flusher::flushed_pages, logpb_flush_log_for_wal(), LSA_COPY(), LSA_GT(), LSA_ISNULL(), LSA_LT(), LSA_SET_NULL(), NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, log_lsa::offset, pgbuf_bcb::oldest_unflush_lsa, log_lsa::pageid, vpid::pageid, PEEK, pgbuf_bcb_is_dirty(), PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, pgbuf_compare_victim_list(), PGBUF_FIND_BCB_PTR, pgbuf_flush_chkpt_seq_list(), prm_get_bool_value(), PRM_ID_LOG_CHKPT_DETAILED, pgbuf_buffer_pool::seq_chkpt_flusher, vpid::volid, pgbuf_bcb::vpid, and VPID_COPY.

Referenced by logpb_checkpoint(), logpb_fatal_error_internal(), and logpb_remove_archive_logs().

Here is the caller graph for this function:

static int pgbuf_flush_chkpt_seq_list	(	THREAD_ENTRY *	thread_p,
		PGBUF_SEQ_FLUSHER *	seq_flusher,
		const LOG_LSA *	prev_chkpt_redo_lsa,
		LOG_LSA *	chkpt_smallest_lsa
	)

static

Definition at line 3693 of file page_buffer.c.

References pgbuf_seq_flusher::control_flushed, pgbuf_seq_flusher::control_intervals_cnt, ER_FAILED, error(), pgbuf_seq_flusher::flush_cnt, pgbuf_seq_flusher::flush_idx, pgbuf_seq_flusher::flush_rate, pgbuf_seq_flusher::flushed_pages, pgbuf_seq_flusher::interval_msec, NO_ERROR, NULL, PGBUF_CHKPT_BURST_PAGES, pgbuf_flush_seq_list(), prm_get_integer_value(), PRM_ID_LOG_CHECKPOINT_SLEEP_MSECS, thread_sleep(), timeval_add_msec(), and WAIT_FLUSH_VICTIMS_MAX_MSEC.

Referenced by pgbuf_flush_checkpoint().

Here is the caller graph for this function:

int pgbuf_flush_control_from_dirty_ratio ( void )

Definition at line 13647 of file page_buffer.c.

References diff, pgbuf_page_monitor::dirties_cnt, if(), pgbuf_buffer_pool::monitor, and pgbuf_buffer_pool::num_buffers.

Referenced by fileio_flush_control_get_desired_rate().

Here is the caller graph for this function:

void pgbuf_flush_if_requested	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	page
	)

Definition at line 2996 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, pgbuf_bcb::latch_mode, NO_ERROR, NULL, PGBUF_BCB_CHECK_MUTEX_LEAKS, pgbuf_bcb_is_async_flush_request(), PGBUF_BCB_LOCK, pgbuf_bcb_safe_flush_force_unlock(), PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_find_thrd_holder(), pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), PGBUF_LATCH_WRITE, pgbuf_bcb::vpid, and VPID_ISNULL.

Referenced by vacuum_data_unload_first_and_last_page().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_flush_neighbor_safe	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		VPID *	expected_vpid,
		bool *	flushed
	)

Definition at line 11307 of file page_buffer.c.

References assert, ASSERT_ERROR, error(), pgbuf_bcb::latch_mode, NO_ERROR, NULL, pgbuf_bcb_flush_with_wal(), pgbuf_bcb_is_flushing(), PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, PGBUF_LATCH_READ, pgbuf_bcb::vpid, VPID_EQ, and VPID_ISNULL.

Referenced by pgbuf_flush_page_and_neighbors_fb().

Here is the caller graph for this function:

static int pgbuf_flush_page_and_neighbors_fb	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		int *	flushed_pages
	)

static

Definition at line 10977 of file page_buffer.c.

References _er_log_debug(), ARG_FILE_LINE, ASSERT_ERROR, pgbuf_batch_flush_helper::back_offset, pgbuf_buffer_pool::buf_hash_table, error(), pgbuf_batch_flush_helper::fwd_offset, i, pgbuf_bcb::latch_mode, logpb_flush_log_for_wal(), LSA_COPY(), LSA_LT(), NEIGHBOR_ABORT_LATCH_DIRTY_BACK, NEIGHBOR_ABORT_LATCH_NONDIRTY_BACK, NEIGHBOR_ABORT_NONDIRTY_NOT_ALLOWED, NEIGHBOR_ABORT_NOTFOUND_DIRTY_BACK, NEIGHBOR_ABORT_NOTFOUND_NONDIRTY_BACK, NEIGHBOR_ABORT_RANGE, NEIGHBOR_ABORT_TOO_MANY_NONDIRTIES, NEIGHBOR_ABORT_TWO_CONSECTIVE_NONDIRTIES, NO_ERROR, pgbuf_batch_flush_helper::npages, NULL, pgbuf_bcb::oldest_unflush_lsa, vpid::pageid, PAGEID_MAX, pgbuf_batch_flush_helper::pages_bufptr, pgbuf_add_bufptr_to_batch(), pgbuf_bcb_is_dirty(), pgbuf_bcb_is_flushing(), PGBUF_BCB_UNLOCK, pgbuf_Flush_helper, pgbuf_flush_neighbor_safe(), PGBUF_HASH_VALUE, PGBUF_LATCH_READ, PGBUF_NEIGHBOR_FLUSH_NONDIRTY, PGBUF_NEIGHBOR_PAGES, PGBUF_NEIGHBOR_POS, PGBUF_PAGES_COUNT_THRESHOLD, pgbuf_search_hash_chain(), prm_get_bool_value(), PRM_ID_LOG_PGBUF_VICTIM_FLUSH, pthread_mutex_unlock, qmgr_get_current_query_id(), STATIC_INLINE, pgbuf_bcb::vpid, VPID_COPY, and pgbuf_batch_flush_helper::vpids.

Referenced by pgbuf_flush_victim_candidates().

Here is the caller graph for this function:

static int pgbuf_flush_seq_list	(	THREAD_ENTRY *	thread_p,
		PGBUF_SEQ_FLUSHER *	seq_flusher,
		struct timeval *	limit_time,
		const LOG_LSA *	prev_chkpt_redo_lsa,
		LOG_LSA *	chkpt_smallest_lsa,
		int *	time_rem
	)

static

Definition at line 3801 of file page_buffer.c.

References assert, assert_release, pgbuf_victim_candidate_list::bufptr, pgbuf_seq_flusher::burst_mode, pgbuf_seq_flusher::control_flushed, pgbuf_seq_flusher::control_intervals_cnt, detailed_er_log, ER_FAILED, error(), pgbuf_seq_flusher::flush_cnt, pgbuf_seq_flusher::flush_idx, pgbuf_seq_flusher::flush_list, pgbuf_seq_flusher::flush_rate, pgbuf_seq_flusher::flush_upto_lsa, pgbuf_seq_flusher::flushed_pages, pgbuf_seq_flusher::interval_msec, LSA_AS_ARGS, LSA_COPY(), LSA_GT(), LSA_ISNULL(), LSA_LE(), LSA_LT(), NO_ERROR, NULL, pgbuf_bcb::oldest_unflush_lsa, log_lsa::pageid, vpid::pageid, pgbuf_bcb_is_dirty(), PGBUF_BCB_LOCK, pgbuf_bcb_safe_flush_force_lock(), pgbuf_bcb_safe_flush_internal(), PGBUF_BCB_UNLOCK, PGBUF_CHKPT_MAX_FLUSH_RATE, PGBUF_CHKPT_MIN_FLUSH_RATE, prm_get_bool_value(), PRM_ID_LOG_CHKPT_DETAILED, thread_sleep(), timeval_diff_in_msec(), pgbuf_bcb::vpid, pgbuf_victim_candidate_list::vpid, VPID_AS_ARGS, and VPID_EQ.

Referenced by pgbuf_flush_chkpt_seq_list().

Here is the caller graph for this function:

int pgbuf_flush_victim_candidates	(	THREAD_ENTRY *	thread_p,
		float	flush_ratio,
		PERF_UTIME_TRACKER *	perf_tracker,
		bool *	stop
	)

Definition at line 3237 of file page_buffer.c.

References _er_log_debug(), ARG_FILE_LINE, assert, pgbuf_victim_candidate_list::bufptr, db_page_size(), ER_LOG_FLUSH_VICTIM_FINISHED, ER_LOG_FLUSH_VICTIM_STARTED, ER_NOTIFICATION_SEVERITY, er_set(), error(), pgbuf_page_monitor::fix_req_cnt, i, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_bcb::latch_mode, log_is_log_flush_daemon_available(), log_wakeup_log_flush_daemon(), logpb_flush_log_for_wal(), logpb_force_flush_pages(), logpb_need_wal(), pgbuf_page_monitor::lru_victim_req_cnt, fileio_page_reserved::lsa, LSA_COPY(), LSA_INITIALIZER, LSA_ISNULL(), LSA_LE(), LSA_LT(), pgbuf_buffer_pool::monitor, NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_add_stat(), perfmon_is_perf_tracking_and_active(), perfmon_time_stat(), PGBUF_BCB_CHECK_MUTEX_LEAKS, pgbuf_bcb_flush_with_wal(), pgbuf_bcb_is_dirty(), pgbuf_bcb_is_flushing(), PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, pgbuf_compare_victim_list(), pgbuf_compute_lru_vict_target(), pgbuf_flush_page_and_neighbors_fb(), PGBUF_FLUSH_VICTIM_BOOST_MULT, pgbuf_get_victim_candidates_from_lru(), PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, pgbuf_is_page_flush_daemon_available(), PGBUF_NEIGHBOR_PAGES, PGBUF_NO_LATCH, prm_get_bool_value(), PRM_ID_LOG_PGBUF_VICTIM_FLUSH, PRM_ID_PB_SEQUENTIAL_VICTIM_FLUSH, fileio_page::prv, PSTAT_PB_FLUSH_COLLECT, PSTAT_PB_FLUSH_COLLECT_PER_PAGE, PSTAT_PB_FLUSH_FLUSH, PSTAT_PB_FLUSH_FLUSH_PER_PAGE, PSTAT_PB_NUM_FLUSHED, PSTAT_PB_NUM_SKIPPED_ALREADY_FLUSHED, PSTAT_PB_NUM_SKIPPED_FIXED_OR_HOT, PSTAT_PB_NUM_SKIPPED_FLUSH, PSTAT_PB_NUM_SKIPPED_NEED_WAL, tsc_elapsed_utime(), tsc_getticks(), pgbuf_buffer_pool::victim_cand_list, pgbuf_bcb::vpid, pgbuf_victim_candidate_list::vpid, and VPID_EQ.

Referenced by pgbuf_get_page_flush_interval(), and pgbuf_wakeup_page_flush_daemon().

Here is the caller graph for this function:

PAGE_PTR pgbuf_flush_with_wal	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr
	)

Definition at line 2956 of file page_buffer.c.

References assert, ASSERT_ERROR, CAST_PGPTR_TO_BFPTR, pgbuf_bcb::latch_mode, NO_ERROR, NULL, PGBUF_BCB_LOCK, pgbuf_bcb_safe_flush_force_unlock(), PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_find_thrd_holder(), pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), PGBUF_LATCH_READ, pgbuf_bcb::vpid, and VPID_ISNULL.

Referenced by heap_flush(), overflow_flush_internal(), and pgbuf_flush().

Here is the caller graph for this function:

void pgbuf_force_to_check_for_interrupts ( void )

Definition at line 4750 of file page_buffer.c.

References pgbuf_buffer_pool::check_for_interrupts.

Referenced by logtb_set_tran_index_interrupt().

Here is the caller graph for this function:

static PGBUF_BCB * pgbuf_get_bcb_from_invalid_list ( THREAD_ENTRY * thread_p )

static

Definition at line 8087 of file page_buffer.c.

References pgbuf_buffer_pool::buf_invalid_list, pgbuf_invalid_list::invalid_cnt, pgbuf_invalid_list::invalid_top, pgbuf_bcb::next_BCB, NULL, perfmon_inc_stat(), pgbuf_bcb_change_zone(), PGBUF_BCB_LOCK, PGBUF_VOID_ZONE, PSTAT_PB_VICTIM_USE_INVALID_BCB, pthread_mutex_lock, pthread_mutex_unlock, and rv.

Referenced by pgbuf_allocate_bcb().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_get_check_page_validation_level ( int page_validation_level )

Definition at line 10209 of file page_buffer.c.

References prm_get_integer_value(), and PRM_ID_PB_DEBUG_PAGE_VALIDATION_LEVEL.

Referenced by pgbuf_check_bcb_page_vpid(), pgbuf_check_page_ptype_internal(), pgbuf_copy_from_area(), pgbuf_copy_to_area(), pgbuf_fix_debug(), pgbuf_flush_if_requested(), pgbuf_flush_with_wal(), pgbuf_get_latch_mode(), pgbuf_get_lsa(), pgbuf_get_page_ptype(), pgbuf_get_volume_id(), pgbuf_get_vpid(), pgbuf_get_vpid_ptr(), pgbuf_invalidate_debug(), pgbuf_promote_read_latch_debug(), pgbuf_set_dirty(), pgbuf_set_lsa(), pgbuf_set_page_ptype(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

int pgbuf_get_condition_for_ordered_fix	(	const VPID *	vpid_new_page,
		const VPID *	vpid_fixed_page,
		const HFID *	hfid
	)

Definition at line 12627 of file page_buffer.c.

References pgbuf_holder_info::group_id, hfid::hpgid, vpid::pageid, pgbuf_compare_hold_vpid_for_sort(), PGBUF_CONDITIONAL_LATCH, PGBUF_ORDERED_HEAP_HDR, PGBUF_ORDERED_HEAP_NORMAL, PGBUF_UNCONDITIONAL_LATCH, pgbuf_holder_info::rank, hfid::vfid, vpid::volid, vfid::volid, pgbuf_holder_info::vpid, VPID_COPY, and VPID_EQ.

Referenced by vacuum_heap_prepare_record().

Here is the caller graph for this function:

int pgbuf_get_fix_count ( PAGE_PTR pgptr )

Definition at line 13837 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, pgbuf_bcb::fcnt, and NULL.

Referenced by vacuum_verify_vacuum_data_page_fix_count().

Here is the caller graph for this function:

static int pgbuf_get_groupid_and_unfix	(	THREAD_ENTRY *	thread_p,
		const VPID *	req_vpid,
		PAGE_PTR *	pgptr,
		VPID *	groupid,
		bool	do_unfix
	)

static

Definition at line 12216 of file page_buffer.c.

References ARG_FILE_LINE, assert, boot_find_root_heap(), ER_ERROR_SEVERITY, ER_PB_ORDERED_NO_HEAP, er_set(), heap_get_class_info(), heap_get_class_oid_from_page(), HFID_IS_NULL, hfid::hpgid, NO_ERROR, NULL, OID_IS_ROOTOID, vpid::pageid, pgbuf_unfix_and_init, thread_get_entry_index(), hfid::vfid, vpid::volid, vfid::volid, VPID_ISNULL, and VPID_SET_NULL.

Referenced by pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

int pgbuf_get_hold_count ( THREAD_ENTRY * thread_p )

Definition at line 13855 of file page_buffer.c.

References pgbuf_holder_anchor::num_hold_cnt, pgbuf_buffer_pool::thrd_holder_info, and thread_get_entry_index().

Referenced by vacuum_verify_vacuum_data_page_fix_count().

Here is the caller graph for this function:

static PGBUF_HOLDER* pgbuf_get_holder	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr
	)

static

Definition at line 12478 of file page_buffer.c.

References assert, pgbuf_holder::bufptr, CAST_PGPTR_TO_BFPTR, NULL, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, and thread_get_entry_index().

Referenced by pgbuf_attach_watcher_debug(), pgbuf_fix_debug(), pgbuf_ordered_unfix_debug(), pgbuf_replace_watcher_debug(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

PGBUF_LATCH_MODE pgbuf_get_latch_mode ( PAGE_PTR pgptr )

Definition at line 4633 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, pgbuf_bcb::latch_mode, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), and PGBUF_LATCH_INVALID.

Referenced by btree_key_delete_remove_object(), btree_key_find_and_lock_unique_of_non_unique(), btree_key_insert_new_key(), btree_key_insert_new_object(), btree_key_remove_delete_mvccid(), btree_key_remove_insert_mvccid(), btree_key_remove_object_and_keep_visible_first(), btree_leaf_record_replace_first_with_last(), btree_merge_node_and_advance(), btree_split_node(), btree_split_node_and_advance(), spage_update(), and spage_update_record_type().

Here is the caller graph for this function:

LOG_LSA* pgbuf_get_lsa ( PAGE_PTR pgptr )

Definition at line 4318 of file page_buffer.c.

References CAST_PGPTR_TO_IOPGPTR, fileio_page_reserved::lsa, NULL, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), and fileio_page::prv.

Referenced by btree_delete_key_from_leaf(), btree_get_next_key_info(), btree_insert_mvcc_delid_into_page(), btree_key_append_object_as_new_overflow(), btree_key_append_object_non_unique(), btree_key_append_object_to_overflow(), btree_key_append_object_unique(), btree_key_find_and_lock_unique_of_non_unique(), btree_key_insert_new_key(), btree_key_lock_and_append_object_unique(), btree_key_online_index_IB_insert(), btree_key_online_index_tran_delete(), btree_key_online_index_tran_insert(), btree_key_online_index_tran_insert_DF(), btree_key_relocate_last_into_ovf(), btree_key_remove_delete_mvccid_non_unique(), btree_key_remove_delete_mvccid_unique(), btree_key_remove_insert_mvccid(), btree_key_remove_object_and_keep_visible_first(), btree_leaf_record_replace_first_with_last(), btree_merge_node_and_advance(), btree_modify_leaf_ovfl_vpid(), btree_modify_overflow_link(), btree_range_scan(), btree_range_scan_resume(), btree_record_remove_object(), btree_reflect_global_unique_statistics(), btree_replace_first_oid_with_ovfl_oid(), btree_split_node_and_advance(), disk_volume_expand(), file_alloc_sticky_first_page(), file_dealloc(), file_extdata_find_and_remove_item(), file_extdata_merge_pages(), file_header_update_mark_deleted(), file_log_extdata_set_next(), file_numerable_add_page(), file_perm_alloc(), file_perm_dealloc(), file_perm_expand(), file_rv_user_page_unmark_delete_logical(), file_table_add_full_sector(), file_table_move_partial_sectors_to_header(), file_tracker_item_mark_heap_deleted(), file_tracker_item_reuse_heap(), file_tracker_register_internal(), log_recovery_redo(), log_skip_logging(), pgbuf_page_has_changed(), and scan_next_heap_scan().

void pgbuf_get_page_flush_interval	(	bool &	is_timed_wait,
		cubthread::delta_time &	period
	)

PAGEID pgbuf_get_page_id ( PAGE_PTR pgptr )

PAGE_TYPE pgbuf_get_page_ptype	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr
	)

Definition at line 4675 of file page_buffer.c.

References assert, assert_release, CAST_PGPTR_TO_BFPTR, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, PAGE_LAST, PAGE_UNKNOWN, pgbuf_check_bcb_page_vpid(), PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), fileio_page::prv, and fileio_page_reserved::ptype.

Referenced by btree_build_nleafs(), file_alloc(), file_sector_map_dealloc(), file_sector_map_pages(), file_tracker_register_internal(), heap_is_page_header(), pgbuf_ordered_fix_debug(), pgbuf_rv_dealloc_undo(), qmgr_get_external_file_page(), spage_compact(), spage_header_start_scan(), spage_slots_start_scan(), and vacuum_heap_page().

Here is the caller graph for this function:

PERF_PAGE_TYPE pgbuf_get_page_type_for_stat	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr
	)

Definition at line 13868 of file page_buffer.c.

References btree_get_perf_btree_page_type(), CAST_PGPTR_TO_IOPGPTR, PAGE_BTREE, PERFMON_ACTIVATION_FLAG_DETAILED_BTREE_PAGE, perfmon_get_activation_flag(), fileio_page::prv, and fileio_page_reserved::ptype.

Referenced by pgbuf_fix_debug(), pgbuf_promote_read_latch_debug(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_get_shared_lru_index_for_add ( void )

Definition at line 1022 of file page_buffer.c.

Referenced by pgbuf_lru_move_from_private_to_shared(), pgbuf_move_bcb_to_bottom_lru(), pgbuf_put_bcb_into_invalid_list(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

TDE_ALGORITHM pgbuf_get_tde_algorithm ( PAGE_PTR pgptr )

Definition at line 4548 of file page_buffer.c.

References assert, CAST_PGPTR_TO_IOPGPTR, FILEIO_PAGE_FLAG_ENCRYPTED_AES, FILEIO_PAGE_FLAG_ENCRYPTED_ARIA, NULL, fileio_page_reserved::pflag, fileio_page::prv, TDE_ALGORITHM_AES, TDE_ALGORITHM_ARIA, and TDE_ALGORITHM_NONE.

Referenced by file_alloc(), log_append_compensate_internal(), log_append_postpone(), log_append_redo_crumbs(), log_append_run_postpone(), log_append_undo_crumbs(), log_append_undoredo_crumbs(), pgbuf_bcb_flush_with_wal(), pgbuf_claim_bcb_for_fix(), pgbuf_dealloc_page(), pgbuf_rv_dealloc_undo(), pgbuf_rv_dealloc_undo_compensate(), and pgbuf_set_tde_algorithm().

Here is the caller graph for this function:

static PGBUF_BCB* pgbuf_get_victim ( THREAD_ENTRY * thread_p )

static

Definition at line 8248 of file page_buffer.c.

References assert, pgbuf_lru_list::count_vict_cand, lockfree::circular_queue< T >::get_consumer_cursor(), lockfree::circular_queue< T >::is_empty(), pgbuf_page_monitor::lru_victim_req_cnt, pgbuf_buffer_pool::monitor, NULL, pgbuf_buffer_pool::num_LRU_list, PERF, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_is_perf_tracking_and_active(), PGBUF_GET_LRU_LIST, pgbuf_get_victim_from_lru_list(), pgbuf_is_page_flush_daemon_available(), pgbuf_lfcq_get_victim_from_private_lru(), pgbuf_lfcq_get_victim_from_shared_lru(), PGBUF_LRU_INDEX_FROM_PRIVATE, PGBUF_LRU_LIST_IS_ONE_TWO_OVER_QUOTA, PGBUF_LRU_LIST_IS_OVER_QUOTA, PGBUF_LRU_LIST_IS_OVER_QUOTA_WITH_BUFFER, PGBUF_PAGE_QUOTA_IS_ENABLED, PGBUF_PRIVATE_LRU_FROM_THREAD, PGBUF_THREAD_HAS_PRIVATE_LRU, PGBUF_THREAD_SHOULD_IGNORE_UNFIX, PSTAT_PB_OWN_VICTIM_PRIVATE_LRU_SUCCESS, PSTAT_PB_VICTIM_ALL_LRU_FAIL, PSTAT_PB_VICTIM_OWN_PRIVATE_LRU_FAIL, PSTAT_PB_VICTIM_SEARCH_OTHERS_PRIVATE_LISTS, PSTAT_PB_VICTIM_SEARCH_OWN_PRIVATE_LISTS, PSTAT_PB_VICTIM_SEARCH_SHARED_LISTS, pgbuf_buffer_pool::shared_lrus_with_victims, and STATIC_INLINE.

Referenced by pgbuf_allocate_bcb().

Here is the caller graph for this function:

static int pgbuf_get_victim_candidates_from_lru	(	THREAD_ENTRY *	thread_p,
		int	check_count,
		float	lru_sum_flush_priority,
		bool *	assigned_directly
	)

static

static PGBUF_BCB* pgbuf_get_victim_from_lru_list	(	THREAD_ENTRY *	thread_p,
		const int	lru_idx
	)

static

Definition at line 8494 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_buffer_pool::buf_LRU_list, cubregex::count(), pgbuf_lru_list::count_vict_cand, pgbuf_lru_list::index, MAX_DEPTH, NULL, PERF, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), pgbuf_add_vpid_to_aout_list(), pgbuf_assign_direct_victim(), pgbuf_bcb_avoid_victim(), pgbuf_bcb_get_lru_index(), pgbuf_bcb_is_dirty(), PGBUF_BCB_TRYLOCK, PGBUF_BCB_UNLOCK, PGBUF_GET_LRU_LIST, pgbuf_is_bcb_fixed_by_any(), PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, pgbuf_is_bcb_victimizable(), pgbuf_is_page_flush_daemon_available(), PGBUF_IS_PRIVATE_LRU_ONE_TWO_OVER_QUOTA, pgbuf_lru_adjust_zones(), pgbuf_lru_advance_victim_hint(), PGBUF_LRU_INDEX_FROM_PRIVATE, PGBUF_PRIVATE_LRU_COUNT, pgbuf_remove_from_lru_list(), PGBUF_SHARED_LRU_COUNT, pgbuf_wakeup_page_flush_daemon(), pgbuf_bcb::prev_BCB, PSTAT_PB_VICTIM_ASSIGN_DIRECT_PANIC, PSTAT_PB_VICTIM_GET_FROM_LRU, PSTAT_PB_VICTIM_GET_FROM_LRU_BAD_HINT, PSTAT_PB_VICTIM_GET_FROM_LRU_FAIL, PSTAT_PB_VICTIM_GET_FROM_LRU_LIST_WAS_EMPTY, pthread_mutex_lock, pthread_mutex_unlock, STATIC_INLINE, thread_num_total_threads(), pgbuf_lru_list::victim_hint, and pgbuf_bcb::vpid.

Referenced by pgbuf_get_victim(), pgbuf_lfcq_get_victim_from_private_lru(), and pgbuf_lfcq_get_victim_from_shared_lru().

Here is the caller graph for this function:

VOLID pgbuf_get_volume_id ( PAGE_PTR pgptr )

Definition at line 4707 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, NULL_VOLID, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), vpid::volid, and pgbuf_bcb::vpid.

Referenced by disk_rv_reserve_sectors(), disk_rv_unreserve_sectors(), heap_chkreloc_next(), heap_find_location_and_insert_rec_newhome(), heap_get_insert_location_with_lock(), heap_get_mvcc_header(), and heap_rv_redo_reuse_page().

Here is the caller graph for this function:

const char* pgbuf_get_volume_label ( PAGE_PTR pgptr )

Definition at line 4731 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, fileio_get_volume_label(), PEEK, vpid::volid, pgbuf_bcb::vpid, and VPID_ISNULL.

Referenced by spage_check(), spage_check_mvcc_updatable(), spage_check_slot_owner(), spage_check_updatable(), spage_delete(), spage_dump(), spage_get_record(), spage_get_record_length(), spage_get_record_offset(), spage_get_space_for_record(), spage_insert_at(), spage_mark_deleted_slot_as_reusable(), spage_merge(), spage_overwrite(), spage_put_helper(), spage_split(), spage_take_out(), spage_take_slot_in_use(), and spage_update_record_type().

Here is the caller graph for this function:

void pgbuf_get_vpid	(	PAGE_PTR	pgptr,
		VPID *	vpid
	)

Definition at line 4579 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), pgbuf_bcb::vpid, and VPID_SET_NULL.

Referenced by btree_dump_page(), btree_key_find_and_lock_unique_of_non_unique(), btree_locate_key(), btree_overflow_remove_object(), catalog_create(), catalog_file_map_find_optimal_page(), disk_rv_reserve_sectors(), disk_rv_unreserve_sectors(), file_extdata_find_and_remove_item(), file_numerable_find_nth(), file_rv_tracker_mark_heap_deleted_compensate_or_run_postpone(), file_table_collect_ftab_pages(), heap_remove_page_on_vacuum(), heap_vpid_next(), heap_vpid_prev(), log_rv_redo_record(), log_rv_undo_record(), scan_next_heap_scan(), spage_compact(), spage_verify_header(), vacuum_data_empty_page(), vacuum_data_load_and_recover(), vacuum_data_unload_first_and_last_page(), and vacuum_heap_prepare_record().

VPID* pgbuf_get_vpid_ptr ( PAGE_PTR pgptr )

Definition at line 4609 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, NULL, PGBUF_DEBUG_PAGE_VALIDATION_ALL, pgbuf_get_check_page_validation_level(), pgbuf_is_valid_page_ptr(), and pgbuf_bcb::vpid.

Referenced by btree_key_append_object_as_new_overflow(), btree_key_insert_new_key(), btree_key_remove_delete_mvccid_non_unique(), btree_key_remove_delete_mvccid_unique(), btree_key_remove_object_and_keep_visible_first(), btree_merge_node(), btree_merge_root(), btree_range_scan(), btree_rv_log_delete_object(), btree_rv_log_insert_object(), btree_split_node_and_advance(), file_extdata_apply_funcs(), file_rv_user_page_unmark_delete_logical(), file_tracker_item_mark_heap_deleted(), vacuum_job_cursor::get_page_vpid(), heap_check_all_pages_by_heapchain(), heap_get_num_objects(), heap_get_record_location(), heap_next_internal(), heap_prepare_object_page(), heap_scanrange_to_following(), heap_stats_find_best_page(), heap_stats_update(), heap_update_set_prev_version(), overflow_update(), pgbuf_attach_watcher_debug(), prior_lsa_gen_postpone_record(), prior_lsa_gen_undoredo_record_from_crumbs(), spage_dump(), spage_get_saved_spaces(), spage_save_space(), spage_vacuum_slot(), vacuum_data_empty_page(), vacuum_heap_prepare_record(), and vacuum_rv_set_next_page_dropped_files().

bool pgbuf_has_any_non_vacuum_waiters ( PAGE_PTR pgptr )

Definition at line 13495 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, NULL, and TT_VACUUM_WORKER.

Referenced by vacuum_heap_page().

Here is the caller graph for this function:

bool pgbuf_has_any_waiters ( PAGE_PTR pgptr )

Definition at line 13468 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, NULL, PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, and pgbuf_is_exist_blocked_reader_writer().

Referenced by btree_insert_list::check_release_latch(), file_header_sanity_check(), and heap_remove_page_on_vacuum().

Here is the caller graph for this function:

bool pgbuf_has_perm_pages_fixed ( THREAD_ENTRY * thread_p )

Definition at line 10874 of file page_buffer.c.

References btree_get_perf_btree_page_type(), pgbuf_holder::bufptr, heap_is_page_header(), pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, NULL, pgbuf_holder_anchor::num_hold_cnt, fileio_page::page, PAGE_BTREE, PAGE_FTAB, PAGE_HEAP, PAGE_QRESULT, PAGE_VOLHEADER, PERF_PAGE_BTREE_ROOT, fileio_page::prv, fileio_page_reserved::ptype, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, and thread_get_entry_index().

Referenced by logpb_flush_pages().

Here is the caller graph for this function:

bool pgbuf_has_prevent_dealloc ( PAGE_PTR pgptr )

Definition at line 13527 of file page_buffer.c.

References assert, CAST_PGPTR_TO_BFPTR, NULL, and pgbuf_bcb_should_avoid_deallocation().

Referenced by heap_remove_page_on_vacuum(), and vacuum_heap_page().

Here is the caller graph for this function:

static INLINE unsigned int pgbuf_hash_func_mirror ( const VPID * vpid )

static

unsigned int pgbuf_hash_vpid	(	const void *	key_vpid,
		unsigned int	htsize
	)

Definition at line 1273 of file page_buffer.c.

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

Referenced by pgbuf_initialize_aout_list().

Here is the caller graph for this function:

static void pgbuf_init_temp_page_lsa	(	FILEIO_PAGE *	io_page,
		PGLENGTH	page_size
	)

static

Definition at line 16100 of file page_buffer.c.

References fileio_get_page_watermark_pos(), fileio_page_reserved::lsa, fileio_page_watermark::lsa, PGBUF_TEMP_LSA, and fileio_page::prv.

Referenced by pgbuf_claim_bcb_for_fix(), pgbuf_reset_temp_lsa(), pgbuf_set_lsa(), and pgbuf_set_lsa_as_temporary().

Here is the caller graph for this function:

int pgbuf_initialize ( void )

Definition at line 1311 of file page_buffer.c.

Referenced by logtb_define_trantable_log_latch().

Here is the caller graph for this function:

static int pgbuf_initialize_aout_list ( void )

static

Definition at line 5168 of file page_buffer.c.

References pgbuf_aout_list::Aout_bottom, pgbuf_aout_list::aout_buf_ht, pgbuf_aout_list::Aout_free, AOUT_HASH_DIVIDE_RATIO, pgbuf_aout_list::Aout_top, ARG_FILE_LINE, pgbuf_buffer_pool::buf_AOUT_list, pgbuf_aout_list::bufarray, ER_ERROR_SEVERITY, ER_FAILED, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), free_and_init, i, pgbuf_aout_buf::lru_idx, pgbuf_aout_list::max_count, mht_create(), mht_destroy(), pgbuf_aout_buf::next, NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, pgbuf_aout_list::num_hashes, PGBUF_AOUT_NOT_FOUND, pgbuf_compare_vpid(), pgbuf_hash_vpid(), PGBUF_LIMIT_AOUT_BUFFERS, pgbuf_aout_buf::prev, prm_get_float_value(), PRM_ID_PB_AOUT_RATIO, pthread_mutex_destroy, pthread_mutex_init, pgbuf_aout_buf::vpid, and VPID_SET_NULL.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_bcb_table ( void )

static

Definition at line 4924 of file page_buffer.c.

References ARG_FILE_LINE, pgbuf_iopage_buffer::bcb, pgbuf_buffer_pool::BCB_table, pgbuf_bcb::count_fix_and_avoid_dealloc, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, ER_PRM_BAD_VALUE, er_set(), pgbuf_bcb::fcnt, fileio_init_lsa_of_page(), pgbuf_bcb::flags, free_and_init, pgbuf_bcb::hash_next, pgbuf_bcb::hit_age, i, if(), IO_PAGESIZE, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_buffer_pool::iopage_table, pgbuf_bcb::latch_mode, LSA_SET_NULL(), MEM_SIZE_IS_VALID, pgbuf_bcb::next_BCB, NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, pgbuf_bcb::oldest_unflush_lsa, fileio_page_reserved::p_reserve_1, fileio_page_reserved::p_reserve_2, fileio_page_reserved::pageid, fileio_page_reserved::pflag, PGBUF_BCB_INIT_FLAGS, PGBUF_BCB_SIZEOF, PGBUF_FIND_BCB_PTR, PGBUF_FIND_BUFFER_GUARD, PGBUF_FIND_IOPAGE_PTR, PGBUF_IOPAGE_BUFFER_SIZE, PGBUF_LATCH_INVALID, pgbuf_bcb::prev_BCB, fileio_page::prv, pthread_mutex_init, fileio_page_reserved::ptype, fileio_page_reserved::tde_nonce, pgbuf_bcb::tick_lru3, pgbuf_bcb::tick_lru_list, fileio_page_reserved::volid, pgbuf_bcb::vpid, and VPID_SET_NULL.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_hash_table ( void )

static

Definition at line 5036 of file page_buffer.c.

References ARG_FILE_LINE, pgbuf_buffer_pool::buf_hash_table, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_buffer_hash::hash_next, i, pgbuf_buffer_hash::lock_next, NO_ERROR, NULL, PGBUF_BUFFER_HASH_SIZEOF, PGBUF_HASH_SIZE, and pthread_mutex_init.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_invalid_list ( void )

static

Definition at line 5272 of file page_buffer.c.

References pgbuf_buffer_pool::buf_invalid_list, pgbuf_invalid_list::invalid_cnt, pgbuf_invalid_list::invalid_top, NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, PGBUF_FIND_BCB_PTR, and pthread_mutex_init.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_lock_table ( void )

static

Definition at line 5065 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_buffer_pool::buf_lock_table, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), i, pgbuf_buffer_lock::lock_next, MAX_NTRANS, NO_ERROR, NULL, PGBUF_BUFFER_LOCK_SIZEOF, thread_num_total_threads(), pgbuf_buffer_lock::vpid, and VPID_SET_NULL.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_lru_list ( void )

static

Definition at line 5105 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_lru_list::bottom, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_buffer_pool::buf_LRU_list, pgbuf_lru_list::count_lru1, pgbuf_lru_list::count_lru2, pgbuf_lru_list::count_lru3, pgbuf_lru_list::count_vict_cand, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_lru_list::flags, i, pgbuf_lru_list::index, MAX_NTRANS, NO_ERROR, NULL, pgbuf_buffer_pool::num_buffers, pgbuf_buffer_pool::num_LRU_list, PGBUF_LRU_LIST_SIZEOF, PGBUF_MIN_PAGES_IN_SHARED_LIST, PGBUF_TOTAL_LRU_COUNT, prm_get_integer_value(), PRM_ID_PB_NUM_LRU_CHAINS, pthread_mutex_init, pgbuf_lru_list::quota, pgbuf_lru_list::threshold_lru1, pgbuf_lru_list::threshold_lru2, pgbuf_lru_list::tick_list, pgbuf_lru_list::tick_lru3, pgbuf_lru_list::top, and pgbuf_lru_list::victim_hint.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_page_monitor ( void )

static

Definition at line 12848 of file page_buffer.c.

References ARG_FILE_LINE, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_page_monitor::fix_req_cnt, i, pgbuf_page_monitor::lru_activity, pgbuf_page_monitor::lru_hits, pgbuf_page_monitor::lru_shared_pgs_cnt, pgbuf_page_monitor::lru_victim_req_cnt, pgbuf_buffer_pool::monitor, NO_ERROR, NULL, pgbuf_page_monitor::pg_unfix_cnt, PGBUF_TOTAL_LRU_COUNT, thread_num_total_threads(), and pgbuf_page_monitor::victim_rich.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_page_quota ( void )

static

Definition at line 12788 of file page_buffer.c.

References pgbuf_page_quota::add_shared_lru_idx, ARG_FILE_LINE, pgbuf_page_quota::avoid_shared_lru_idx, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), i, pgbuf_page_quota::lru_victim_flush_priority_per_lru, NO_ERROR, NULL, PGBUF_IS_PRIVATE_LRU_INDEX, PGBUF_PAGE_QUOTA_IS_ENABLED, PGBUF_PRIVATE_LIST_FROM_LRU_INDEX, PGBUF_PRIVATE_LRU_COUNT, PGBUF_TOTAL_LRU_COUNT, pgbuf_page_quota::private_lru_session_cnt, pgbuf_page_quota::private_pages_ratio, and pgbuf_buffer_pool::quota.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_page_quota_parameters ( void )

static

Definition at line 12744 of file page_buffer.c.

References pgbuf_page_quota::adjust_age, pgbuf_page_quota::is_adjusting, pgbuf_page_quota::last_adjust_time, MAX_NTRANS, NO_ERROR, pgbuf_page_quota::num_private_LRU_list, PGBUF_PRIVATE_LRU_MIN_COUNT, prm_get_integer_value(), PRM_ID_PB_NUM_PRIVATE_CHAINS, pgbuf_buffer_pool::quota, tsc_getticks(), and VACUUM_MAX_WORKER_COUNT.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_seq_flusher	(	PGBUF_SEQ_FLUSHER *	seq_flusher,
		PGBUF_VICTIM_CANDIDATE_LIST *	f_list,
		const int	cnt
	)

static

Definition at line 13430 of file page_buffer.c.

References ARG_FILE_LINE, pgbuf_seq_flusher::burst_mode, pgbuf_seq_flusher::control_flushed, pgbuf_seq_flusher::control_intervals_cnt, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_seq_flusher::flush_cnt, pgbuf_seq_flusher::flush_idx, pgbuf_seq_flusher::flush_list, pgbuf_seq_flusher::flush_max_size, NO_ERROR, and NULL.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

static int pgbuf_initialize_thrd_holder ( void )

static

Definition at line 5287 of file page_buffer.c.

References ARG_FILE_LINE, assert, pgbuf_holder::bufptr, ER_ERROR_SEVERITY, ER_OUT_OF_VIRTUAL_MEMORY, er_set(), pgbuf_holder::first_watcher, pgbuf_holder::fix_count, pgbuf_buffer_pool::free_holder_set, pgbuf_buffer_pool::free_index, i, INIT_HOLDER_STAT, pgbuf_holder::last_watcher, MAX_NTRANS, pgbuf_holder::next_holder, NO_ERROR, NULL, pgbuf_holder_anchor::num_free_cnt, pgbuf_holder_anchor::num_hold_cnt, pgbuf_holder::perf_stat, PGBUF_DEFAULT_FIX_COUNT, PGBUF_HOLDER_ANCHOR_SIZEOF, PGBUF_HOLDER_SIZEOF, pthread_mutex_init, STATIC_INLINE, pgbuf_holder_anchor::thrd_free_list, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, pgbuf_buffer_pool::thrd_reserved_holder, thread_num_total_threads(), and pgbuf_holder::watch_count.

Referenced by pgbuf_initialize().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_insert_into_hash_chain	(	THREAD_ENTRY *	thread_p,
		PGBUF_BUFFER_HASH *	hash_anchor,
		PGBUF_BCB *	bufptr
	)

Definition at line 7053 of file page_buffer.c.

References pgbuf_bcb::hash_next, pgbuf_buffer_hash::hash_next, NO_ERROR, PERFMON_ACTIVATION_FLAG_PB_HASH_ANCHOR, perfmon_add_stat(), perfmon_get_activation_flag(), perfmon_inc_stat(), perfmon_is_perf_tracking(), perfmon_is_perf_tracking_and_active(), PSTAT_PB_NUM_HASH_ANCHOR_WAITS, PSTAT_PB_TIME_HASH_ANCHOR_WAIT, pthread_mutex_lock, rv, STATIC_INLINE, tsc_elapsed_utime(), and tsc_getticks().

Referenced by pgbuf_fix_debug().

Here is the caller graph for this function:

int pgbuf_invalidate_all_debug	(	THREAD_ENTRY *	thread_p,
		VOLID	volid,
		const char *	caller_file,
		int	caller_line
	)

static int pgbuf_invalidate_bcb	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr
	)

static

Definition at line 7892 of file page_buffer.c.

References assert, ER_FAILED, pgbuf_bcb::latch_mode, LSA_SET_NULL(), NO_ERROR, pgbuf_bcb::oldest_unflush_lsa, pgbuf_bcb_clear_dirty(), pgbuf_bcb_get_zone(), pgbuf_bcb_is_direct_victim(), PGBUF_BCB_UNLOCK, pgbuf_delete_from_hash_chain(), PGBUF_IS_BCB_IN_LRU, PGBUF_LATCH_INVALID, pgbuf_lru_remove_bcb(), PGBUF_NO_LATCH, pgbuf_put_bcb_into_invalid_list(), and PGBUF_VOID_ZONE.

Referenced by pgbuf_invalidate_all_debug(), pgbuf_invalidate_debug(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

int pgbuf_invalidate_debug	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	pgptr,
		const char *	caller_file,
		int	caller_line
	)

STATIC_INLINE bool pgbuf_is_bcb_fixed_by_any	(	PGBUF_BCB *	bcb,
		bool	has_mutex_lock
	)

Definition at line 8438 of file page_buffer.c.

References pgbuf_bcb::fcnt, pgbuf_bcb::latch_mode, NULL, PGBUF_BCB_CHECK_OWN, PGBUF_NO_LATCH, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_get_victim_from_lru_list(), and pgbuf_is_bcb_victimizable().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_is_bcb_victimizable	(	PGBUF_BCB *	bcb,
		bool	has_mutex_lock
	)

Definition at line 8464 of file page_buffer.c.

References pgbuf_bcb_avoid_victim(), and pgbuf_is_bcb_fixed_by_any().

Referenced by pgbuf_assign_direct_victim(), pgbuf_get_victim_candidates_from_lru(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_add_new_bcb_to_bottom(), pgbuf_lru_fall_bcb_to_zone_3(), and pgbuf_victimize_bcb().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_is_exist_blocked_reader_writer ( PGBUF_BCB * bufptr )

Definition at line 10182 of file page_buffer.c.

References NULL, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, and STATIC_INLINE.

Referenced by pgbuf_has_any_waiters(), pgbuf_latch_bcb_upon_fix(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_is_hit_ratio_low ( void )

Definition at line 15425 of file page_buffer.c.

References assert_release, pgbuf_monitor_bcb_mutex::bcb, pgbuf_monitor_bcb_mutex::bcb_second, pgbuf_page_monitor::fix_req_cnt, pgbuf_monitor_bcb_mutex::line, pgbuf_monitor_bcb_mutex::line_second, pgbuf_page_monitor::lru_victim_req_cnt, pgbuf_buffer_pool::monitor, NULL, PGBUF_ABORT_RELEASE, PGBUF_DESIRED_HIT_VS_MISS_RATE, PGBUF_MIN_VICTIM_REQ, pthread_mutex_lock, pthread_mutex_trylock, pthread_mutex_unlock, rv, and thread_get_current_entry_index().

Referenced by pgbuf_fix_if_not_deallocated_with_caller().

Here is the caller graph for this function:

bool pgbuf_is_io_stressful ( void )

Definition at line 15409 of file page_buffer.c.

References STATIC_INLINE.

Referenced by btree_merge_node_and_advance().

Here is the caller graph for this function:

bool pgbuf_is_log_check_for_interrupts ( THREAD_ENTRY * thread_p )

Definition at line 4762 of file page_buffer.c.

References ARG_FILE_LINE, pgbuf_buffer_pool::check_for_interrupts, ER_ERROR_SEVERITY, ER_INTERRUPTED, er_set(), and logtb_is_interrupted().

Referenced by fileio_backup_volume(), fileio_create_backup_volume(), fileio_initialize_pages(), and fileio_write_backup_node().

Here is the caller graph for this function:

bool pgbuf_is_lsa_temporary ( PAGE_PTR pgptr )

Definition at line 4885 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, fileio_page_reserved::lsa, pgbuf_is_temp_lsa(), pgbuf_is_temporary_volume(), fileio_page::prv, STATIC_INLINE, vpid::volid, and pgbuf_bcb::vpid.

Referenced by log_can_skip_redo_logging(), log_can_skip_undo_logging(), log_skip_logging(), and pgbuf_fix_debug().

Here is the caller graph for this function:

bool pgbuf_is_page_fixed_by_thread	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid_p
	)

Definition at line 12715 of file page_buffer.c.

References assert, pgbuf_holder::bufptr, pgbuf_holder::next_holder, NULL, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, thread_get_entry_index(), pgbuf_bcb::vpid, and VPID_EQ.

Referenced by heap_add_chain_links(), heap_alloc_new_page(), locator_multi_insert_force(), logtb_delete_global_unique_stats(), and logtb_get_global_unique_stats_entry().

Here is the caller graph for this function:

static bool pgbuf_is_page_flush_daemon_available ( )

static

Definition at line 16084 of file page_buffer.c.

References NULL.

Referenced by pgbuf_allocate_bcb(), pgbuf_flush_victim_candidates(), pgbuf_get_victim(), pgbuf_get_victim_from_lru_list(), and pgbuf_wakeup_page_flush_daemon().

Here is the caller graph for this function:

static bool pgbuf_is_temp_lsa ( const log_lsa & lsa )

static

Definition at line 16094 of file page_buffer.c.

References PGBUF_TEMP_LSA.

Referenced by pgbuf_claim_bcb_for_fix(), pgbuf_is_lsa_temporary(), pgbuf_set_lsa(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_is_temporary_volume ( VOLID volid )

static

Definition at line 4908 of file page_buffer.c.

References DB_TEMPORARY_DATA_PURPOSE, LOG_DBFIRST_VOLID, LOG_ISRESTARTED, NULL, and xdisk_get_purpose().

Referenced by pgbuf_bcb_flush_with_wal(), pgbuf_claim_bcb_for_fix(), pgbuf_is_lsa_temporary(), pgbuf_scan_bcb_table(), and pgbuf_set_lsa().

Here is the caller graph for this function:

DISK_ISVALID pgbuf_is_valid_page	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid,
		bool	no_error,
		DISK_ISVALID()(const VPID vpid, void *args)	fun,
		void *	args
	)

Definition at line 10233 of file page_buffer.c.

References ARG_FILE_LINE, assert, DISK_ERROR, DISK_INVALID, disk_is_page_sector_reserved_with_debug_crash(), DISK_VALID, ER_FATAL_ERROR_SEVERITY, ER_PB_BAD_PAGEID, er_set(), fileio_get_volume_label(), NULL, vpid::pageid, PEEK, vpid::volid, and VPID_ISNULL.

Referenced by btree_check_valid_record(), heap_rv_postpone_append_pages_to_heap(), pgbuf_copy_from_area(), pgbuf_copy_to_area(), pgbuf_fix_debug(), and pgbuf_ordered_fix_debug().

Here is the caller graph for this function:

static bool pgbuf_is_valid_page_ptr ( const PAGE_PTR pgptr )

static

Definition at line 10272 of file page_buffer.c.

References ARG_FILE_LINE, assert, ER_FATAL_ERROR_SEVERITY, ER_PB_UNFIXED_PAGEPTR, ER_PB_UNKNOWN_PAGEPTR, er_set(), pgbuf_bcb::fcnt, fileio_get_volume_label(), pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, NULL, pgbuf_buffer_pool::num_buffers, fileio_page::page, vpid::pageid, PEEK, PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, PGBUF_FIND_BCB_PTR, vpid::volid, and pgbuf_bcb::vpid.

Referenced by pgbuf_check_page_ptype_internal(), pgbuf_flush_if_requested(), pgbuf_flush_with_wal(), pgbuf_get_latch_mode(), pgbuf_get_lsa(), pgbuf_get_page_ptype(), pgbuf_get_volume_id(), pgbuf_get_vpid(), pgbuf_get_vpid_ptr(), pgbuf_invalidate_debug(), pgbuf_promote_read_latch_debug(), pgbuf_set_dirty(), pgbuf_set_lsa(), pgbuf_set_page_ptype(), and pgbuf_unfix_debug().

Here is the caller graph for this function:

STATIC_INLINE int pgbuf_latch_bcb_upon_fix	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		PGBUF_LATCH_MODE	request_mode,
		int	buf_lock_acquired,
		PGBUF_LATCH_CONDITION	condition,
		bool *	is_latch_wait
	)

Definition at line 5682 of file page_buffer.c.

References ARG_FILE_LINE, assert, assert_release, pgbuf_holder::bufptr, pgbuf_holder_stat::dirtied_by_holder, pgbuf_holder_stat::dirty_before_hold, ER_ERROR_SEVERITY, ER_FAILED, ER_LK_PAGE_TIMEOUT, er_set(), pgbuf_bcb::fcnt, pgbuf_holder::fix_count, pgbuf_holder_stat::hold_has_read_latch, pgbuf_holder_stat::hold_has_write_latch, INIT_HOLDER_STAT, pgbuf_bcb::latch_mode, LK_ZERO_WAIT, LOG_FIND_THREAD_TRAN_INDEX, logtb_find_client_name_host_pid(), logtb_find_wait_msecs(), NO_ERROR, NULL, vpid::pageid, pgbuf_holder::perf_stat, pgbuf_allocate_thrd_holder_entry(), pgbuf_bcb_is_dirty(), PGBUF_BCB_UNLOCK, pgbuf_block_bcb(), PGBUF_CONDITIONAL_LATCH, pgbuf_find_thrd_holder(), pgbuf_is_exist_blocked_reader_writer(), pgbuf_latch_idle_page(), PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_NO_LATCH, pgbuf_remove_thrd_holder(), PGBUF_UNCONDITIONAL_LATCH, STATIC_INLINE, vpid::volid, and pgbuf_bcb::vpid.

Referenced by pgbuf_fix_debug().

Here is the caller graph for this function:

static int pgbuf_latch_idle_page	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		PGBUF_LATCH_MODE	request_mode
	)

static

Definition at line 5619 of file page_buffer.c.

References assert, pgbuf_holder::bufptr, pgbuf_holder_stat::dirtied_by_holder, pgbuf_holder_stat::dirty_before_hold, ER_FAILED, pgbuf_bcb::fcnt, pgbuf_holder::fix_count, pgbuf_holder_stat::hold_has_read_latch, pgbuf_holder_stat::hold_has_write_latch, pgbuf_bcb::latch_mode, NO_ERROR, NULL, pgbuf_holder::perf_stat, pgbuf_allocate_thrd_holder_entry(), pgbuf_bcb_is_dirty(), PGBUF_BCB_UNLOCK, pgbuf_find_thrd_holder(), PGBUF_LATCH_WRITE, and STATIC_INLINE.

Referenced by pgbuf_latch_bcb_upon_fix().

Here is the caller graph for this function:

static const char* pgbuf_latch_mode_str ( PGBUF_LATCH_MODE latch_mode )

static

Definition at line 13744 of file page_buffer.c.

References PGBUF_LATCH_FLUSH, PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, and PGBUF_NO_LATCH.

Referenced by pgbuf_check_bcb_page_vpid(), and pgbuf_unfix_all().

Here is the caller graph for this function:

STATIC_INLINE bool pgbuf_lfcq_add_lru_with_victims ( PGBUF_LRU_LIST * lru_list )

Definition at line 15169 of file page_buffer.c.

References pgbuf_lru_list::flags, pgbuf_lru_list::index, PGBUF_IS_PRIVATE_LRU_INDEX, PGBUF_LRU_VICTIM_LFCQ_FLAG, pgbuf_buffer_pool::private_lrus_with_victims, lockfree::circular_queue< T >::produce(), and pgbuf_buffer_pool::shared_lrus_with_victims.

Referenced by pgbuf_adjust_quotas(), and pgbuf_lru_add_victim_candidate().

Here is the caller graph for this function:

static PGBUF_BCB* pgbuf_lfcq_get_victim_from_private_lru	(	THREAD_ENTRY *	thread_p,
		bool	restricted
	)

static

Definition at line 15215 of file page_buffer.c.

References assert, pgbuf_buffer_pool::big_private_lrus_with_victims, lockfree::circular_queue< T >::consume(), pgbuf_lru_list::count_vict_cand, pgbuf_lru_list::flags, NULL, PBGUF_BIG_PRIVATE_MIN_SIZE, PERF, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_is_perf_tracking_and_active(), PGBUF_GET_LRU_LIST, pgbuf_get_victim_from_lru_list(), PGBUF_IS_PRIVATE_LRU_INDEX, PGBUF_LRU_LIST_COUNT, PGBUF_LRU_LIST_IS_OVER_QUOTA, PGBUF_LRU_VICTIM_LFCQ_FLAG, pgbuf_buffer_pool::private_lrus_with_victims, lockfree::circular_queue< T >::produce(), PSTAT_PB_LFCQ_LRU_PRV_GET_BIG, PSTAT_PB_LFCQ_LRU_PRV_GET_CALLS, PSTAT_PB_LFCQ_LRU_PRV_GET_EMPTY, PSTAT_PB_VICTIM_OTHER_PRIVATE_LRU_FAIL, PSTAT_PB_VICTIM_OTHER_PRIVATE_LRU_SUCCESS, and pgbuf_lru_list::quota.

Referenced by pgbuf_get_victim().

Here is the caller graph for this function:

static PGBUF_BCB* pgbuf_lfcq_get_victim_from_shared_lru	(	THREAD_ENTRY *	thread_p,
		bool	multi_threaded
	)

static

Definition at line 15307 of file page_buffer.c.

References assert, lockfree::circular_queue< T >::consume(), pgbuf_lru_list::count_vict_cand, pgbuf_lru_list::flags, NULL, PERF, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_is_perf_tracking_and_active(), PGBUF_GET_LRU_LIST, pgbuf_get_victim_from_lru_list(), PGBUF_IS_SHARED_LRU_INDEX, PGBUF_LRU_VICTIM_LFCQ_FLAG, lockfree::circular_queue< T >::produce(), PSTAT_PB_LFCQ_LRU_SHR_GET_CALLS, PSTAT_PB_LFCQ_LRU_SHR_GET_EMPTY, PSTAT_PB_VICTIM_SHARED_LRU_FAIL, PSTAT_PB_VICTIM_SHARED_LRU_SUCCESS, pgbuf_buffer_pool::shared_lrus_with_victims, and STATIC_INLINE.

Referenced by pgbuf_get_victim().

Here is the caller graph for this function:

static int pgbuf_lock_page	(	THREAD_ENTRY *	thread_p,
		PGBUF_BUFFER_HASH *	hash_anchor,
		const VPID *	vpid
	)

static

Definition at line 7202 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_lock_table, pgbuf_buffer_lock::lock_next, pgbuf_buffer_hash::lock_next, NULL, PERFMON_ACTIVATION_FLAG_PB_HASH_ANCHOR, perfmon_add_stat(), perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), PGBUF_LOCK_HOLDER, PGBUF_LOCK_WAITER, PSTAT_LK_NUM_ACQUIRED_ON_PAGES, PSTAT_LK_NUM_WAITED_ON_PAGES, PSTAT_PB_NUM_HASH_ANCHOR_WAITS, PSTAT_PB_TIME_HASH_ANCHOR_WAIT, pthread_mutex_lock, pthread_mutex_unlock, thread_get_thread_entry_info(), THREAD_PGBUF_RESUMED, tsc_elapsed_utime(), tsc_getticks(), pgbuf_buffer_lock::vpid, and VPID_EQ.

Referenced by pgbuf_claim_bcb_for_fix().

Here is the caller graph for this function:

void pgbuf_log_new_page	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	page_new,
		int	data_size,
		PAGE_TYPE	ptype_new
	)

Definition at line 13897 of file page_buffer.c.

References assert, DONT_FREE, log_append_undoredo_data2(), NULL, PAGE_UNKNOWN, pgbuf_set_dirty(), and RVPGBUF_NEW_PAGE.

Referenced by file_create(), file_numerable_add_page(), file_perm_dealloc(), and file_table_append_full_sector_page().

Here is the caller graph for this function:

void pgbuf_log_redo_new_page	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	page_new,
		int	data_size,
		PAGE_TYPE	ptype_new
	)

Definition at line 13909 of file page_buffer.c.

References assert, DONT_FREE, log_append_redo_data2(), NULL, PAGE_UNKNOWN, pgbuf_set_dirty(), and RVPGBUF_NEW_PAGE.

Referenced by locator_multi_insert_force().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_bcb_to_bottom	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		PGBUF_LRU_LIST *	lru_list
	)

Definition at line 9011 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, DB_INT32_MAX, pgbuf_lru_list::index, pgbuf_bcb::next_BCB, NULL, pgbuf_bcb_change_zone(), PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, PGBUF_LRU_3_ZONE, pgbuf_bcb::prev_BCB, STATIC_INLINE, pgbuf_bcb::tick_lru3, pgbuf_lru_list::tick_lru3, and pgbuf_lru_list::top.

Referenced by pgbuf_lru_add_new_bcb_to_bottom(), and pgbuf_move_bcb_to_bottom_lru().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_bcb_to_middle	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		PGBUF_LRU_LIST *	lru_list
	)

Definition at line 8923 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru2, DB_INT32_MAX, pgbuf_lru_list::index, pgbuf_bcb::next_BCB, NULL, pgbuf_bcb_change_zone(), pgbuf_bcb_get_zone(), PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, pgbuf_bcb::prev_BCB, STATIC_INLINE, pgbuf_lru_list::tick_list, and pgbuf_lru_list::top.

Referenced by pgbuf_lru_add_new_bcb_to_middle().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_bcb_to_top	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		PGBUF_LRU_LIST *	lru_list
	)

Definition at line 8873 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_lru_list::bottom_1, pgbuf_lru_list::count_lru1, DB_INT32_MAX, pgbuf_lru_list::index, pgbuf_bcb::next_BCB, NULL, pgbuf_bcb_change_zone(), PGBUF_LRU_1_ZONE, pgbuf_bcb::prev_BCB, STATIC_INLINE, pgbuf_lru_list::tick_list, and pgbuf_lru_list::top.

Referenced by pgbuf_lru_add_new_bcb_to_top(), and pgbuf_lru_boost_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_new_bcb_to_bottom	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		int	lru_idx
	)

Definition at line 9442 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_LRU_list, pgbuf_assign_direct_victim(), PGBUF_IS_BCB_IN_LRU, pgbuf_is_bcb_victimizable(), pgbuf_lru_add_bcb_to_bottom(), pgbuf_lru_sanity_check(), pthread_mutex_lock, pthread_mutex_unlock, STATIC_INLINE, pgbuf_lru_list::tick_list, and pgbuf_bcb::tick_lru_list.

Referenced by pgbuf_move_bcb_to_bottom_lru().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_new_bcb_to_middle	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		int	lru_idx
	)

Definition at line 9410 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_LRU_list, PGBUF_IS_BCB_IN_LRU, pgbuf_lru_add_bcb_to_middle(), pgbuf_lru_adjust_zone2(), pgbuf_lru_sanity_check(), pthread_mutex_lock, pthread_mutex_unlock, STATIC_INLINE, pgbuf_lru_list::tick_list, and pgbuf_bcb::tick_lru_list.

Referenced by pgbuf_lru_move_from_private_to_shared(), and pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_new_bcb_to_top	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		int	lru_idx
	)

Definition at line 9374 of file page_buffer.c.

References assert, pgbuf_buffer_pool::buf_LRU_list, PGBUF_IS_BCB_IN_LRU, pgbuf_lru_add_bcb_to_top(), pgbuf_lru_adjust_zones(), pgbuf_lru_sanity_check(), pthread_mutex_lock, pthread_mutex_unlock, STATIC_INLINE, pgbuf_lru_list::tick_list, and pgbuf_bcb::tick_lru_list.

Referenced by pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_add_victim_candidate	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		PGBUF_BCB *	bcb
	)

Definition at line 14467 of file page_buffer.c.

References pgbuf_lru_list::count_vict_cand, pgbuf_lru_list::index, NULL, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_is_perf_tracking_and_active(), PGBUF_AGE_DIFF, PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, PGBUF_IS_SHARED_LRU_INDEX, pgbuf_lfcq_add_lru_with_victims(), PGBUF_LRU_LIST_IS_OVER_QUOTA, STATIC_INLINE, pgbuf_bcb::tick_lru3, pgbuf_lru_list::tick_lru3, and pgbuf_lru_list::victim_hint.

Referenced by pgbuf_bcb_change_zone(), and pgbuf_bcb_update_flags().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_adjust_zone1	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		bool	min_one
	)

Definition at line 9060 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru1, pgbuf_lru_list::index, NULL, pgbuf_bcb_change_zone(), pgbuf_bcb_get_zone(), PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, pgbuf_bcb::prev_BCB, STATIC_INLINE, and pgbuf_lru_list::threshold_lru1.

Referenced by pgbuf_lru_adjust_zones(), and pgbuf_lru_boost_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_adjust_zone2	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		bool	min_one
	)

Definition at line 9113 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru2, NULL, pgbuf_bcb_get_zone(), PGBUF_LRU_2_ZONE, pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_bcb::prev_BCB, STATIC_INLINE, and pgbuf_lru_list::threshold_lru2.

Referenced by pgbuf_lru_add_new_bcb_to_middle().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_adjust_zones	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		bool	min_one
	)

Definition at line 9163 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru1, pgbuf_lru_list::count_lru2, NULL, pgbuf_bcb_get_zone(), PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, PGBUF_LRU_3_ZONE, pgbuf_lru_adjust_zone1(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_lru_sanity_check(), PGBUF_LRU_ZONE_ONE_TWO_COUNT, pgbuf_bcb::prev_BCB, STATIC_INLINE, pgbuf_lru_list::threshold_lru1, and pgbuf_lru_list::threshold_lru2.

Referenced by pgbuf_adjust_quotas(), pgbuf_get_victim_from_lru_list(), pgbuf_lru_add_new_bcb_to_top(), and pgbuf_lru_boost_bcb().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_advance_victim_hint	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		PGBUF_BCB *	bcb_prev_hint,
		PGBUF_BCB *	bcb_new_hint,
		bool	was_vict_count_updated
	)

Definition at line 14544 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_lru_list::count_vict_cand, pgbuf_lru_list::index, NULL, pgbuf_bcb_get_lru_index(), PGBUF_IS_BCB_IN_LRU_VICTIM_ZONE, STATIC_INLINE, and pgbuf_lru_list::victim_hint.

Referenced by pgbuf_get_victim_from_lru_list(), and pgbuf_remove_from_lru_list().

Here is the caller graph for this function:

static void pgbuf_lru_boost_bcb	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

static

Definition at line 9299 of file page_buffer.c.

References assert, pgbuf_lru_list::index, perfmon_inc_stat(), pgbuf_bcb_get_zone(), PGBUF_IS_BCB_IN_LRU, PGBUF_IS_PRIVATE_LRU_INDEX, PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, PGBUF_LRU_3_ZONE, pgbuf_lru_add_bcb_to_top(), pgbuf_lru_adjust_zone1(), pgbuf_lru_adjust_zones(), pgbuf_lru_list_from_bcb(), pgbuf_lru_sanity_check(), pgbuf_remove_from_lru_list(), PSTAT_PB_UNFIX_LRU_THREE_PRV_TO_TOP, PSTAT_PB_UNFIX_LRU_THREE_SHR_TO_TOP, PSTAT_PB_UNFIX_LRU_TWO_PRV_TO_TOP, PSTAT_PB_UNFIX_LRU_TWO_SHR_TO_TOP, pthread_mutex_lock, pthread_mutex_unlock, and STATIC_INLINE.

Referenced by pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_fall_bcb_to_zone_3	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb,
		PGBUF_LRU_LIST *	lru_list
	)

Definition at line 9229 of file page_buffer.c.

References assert, DB_INT32_MAX, pgbuf_lru_list::index, PERFMON_ACTIVATION_FLAG_PB_VICTIMIZATION, perfmon_inc_stat(), perfmon_is_perf_tracking_and_active(), pgbuf_add_vpid_to_aout_list(), pgbuf_assign_direct_victim(), pgbuf_bcb_change_zone(), pgbuf_bcb_get_zone(), pgbuf_bcb_is_to_vacuum(), PGBUF_BCB_TRYLOCK, PGBUF_BCB_UNLOCK, pgbuf_is_bcb_victimizable(), PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, PGBUF_LRU_3_ZONE, pgbuf_remove_from_lru_list(), PSTAT_PB_VICTIM_ASSIGN_DIRECT_ADJUST, PSTAT_PB_VICTIM_ASSIGN_DIRECT_ADJUST_TO_VACUUM, pgbuf_bcb::tick_lru3, pgbuf_lru_list::tick_lru3, and pgbuf_bcb::vpid.

Referenced by pgbuf_lru_adjust_zone2(), and pgbuf_lru_adjust_zones().

Here is the caller graph for this function:

STATIC_INLINE PGBUF_LRU_LIST* pgbuf_lru_list_from_bcb ( const PGBUF_BCB * bcb )

Definition at line 15378 of file page_buffer.c.

References assert, pgbuf_bcb_get_lru_index(), PGBUF_GET_LRU_LIST, PGBUF_IS_BCB_IN_LRU, and STATIC_INLINE.

Referenced by pgbuf_assign_direct_victim(), pgbuf_bcb_set_dirty(), pgbuf_bcb_update_flags(), pgbuf_lru_boost_bcb(), pgbuf_lru_remove_bcb(), and pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

static void pgbuf_lru_move_from_private_to_shared	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

static

Definition at line 9505 of file page_buffer.c.

References assert, pgbuf_bcb_get_lru_index(), pgbuf_bcb_register_hit_for_lru(), pgbuf_get_shared_lru_index_for_add(), PGBUF_IS_PRIVATE_LRU_INDEX, pgbuf_lru_add_new_bcb_to_middle(), pgbuf_lru_remove_bcb(), and STATIC_INLINE.

Referenced by pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_remove_bcb	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

Definition at line 9477 of file page_buffer.c.

References assert, PGBUF_IS_BCB_IN_LRU, pgbuf_lru_list_from_bcb(), pgbuf_lru_sanity_check(), pgbuf_remove_from_lru_list(), pthread_mutex_lock, and pthread_mutex_unlock.

Referenced by pgbuf_assign_direct_victim(), pgbuf_invalidate_bcb(), and pgbuf_lru_move_from_private_to_shared().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_lru_remove_victim_candidate	(	THREAD_ENTRY *	thread_p,
		PGBUF_LRU_LIST *	lru_list,
		PGBUF_BCB *	bcb
	)

Definition at line 14521 of file page_buffer.c.

References pgbuf_lru_list::count_vict_cand, and STATIC_INLINE.

Referenced by pgbuf_bcb_change_zone(), pgbuf_bcb_set_dirty(), and pgbuf_bcb_update_flags().

Here is the caller graph for this function:

static void pgbuf_lru_sanity_check ( const PGBUF_LRU_LIST * lru )

static

Definition at line 15663 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru1, pgbuf_lru_list::count_lru2, pgbuf_lru_list::count_lru3, pgbuf_bcb::next_BCB, NULL, pgbuf_bcb_get_zone(), PGBUF_LRU_1_ZONE, PGBUF_LRU_2_ZONE, STATIC_INLINE, and pgbuf_lru_list::top.

Referenced by pgbuf_lru_add_new_bcb_to_bottom(), pgbuf_lru_add_new_bcb_to_middle(), pgbuf_lru_add_new_bcb_to_top(), pgbuf_lru_adjust_zones(), pgbuf_lru_boost_bcb(), and pgbuf_lru_remove_bcb().

Here is the caller graph for this function:

static void pgbuf_move_bcb_to_bottom_lru	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bcb
	)

static

Definition at line 9593 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_bcb_get_lru_index(), pgbuf_bcb_get_zone(), PGBUF_BCB_MOVE_TO_LRU_BOTTOM_FLAG, pgbuf_bcb_update_flags(), PGBUF_GET_LRU_LIST, pgbuf_get_shared_lru_index_for_add(), pgbuf_lru_add_bcb_to_bottom(), pgbuf_lru_add_new_bcb_to_bottom(), PGBUF_LRU_INDEX_FROM_PRIVATE, PGBUF_LRU_ZONE_MASK, PGBUF_PRIVATE_LRU_FROM_THREAD, pgbuf_remove_from_lru_list(), PGBUF_THREAD_HAS_PRIVATE_LRU, PGBUF_VOID_ZONE, pthread_mutex_lock, pthread_mutex_unlock, and STATIC_INLINE.

Referenced by pgbuf_unlatch_bcb_upon_unfix().

Here is the caller graph for this function:

void pgbuf_notify_vacuum_follows	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR	page
	)

Definition at line 14987 of file page_buffer.c.

References CAST_PGPTR_TO_BFPTR, PGBUF_BCB_TO_VACUUM_FLAG, pgbuf_bcb_update_flags(), and STATIC_INLINE.

Referenced by btree_split_node_and_advance(), log_append_undo_crumbs(), log_append_undoredo_crumbs(), and vacuum_find_dropped_file().

Here is the caller graph for this function:

int pgbuf_ordered_fix_debug	(	THREAD_ENTRY *	thread_p,
		const VPID *	req_vpid,
		PAGE_FETCH_MODE	fetch_mode,
		const PGBUF_LATCH_MODE	request_mode,
		PGBUF_WATCHER *	req_watcher,
		const char *	caller_file,
		int	caller_line
	)

Definition at line 11430 of file page_buffer.c.

References _er_log_debug(), ARG_FILE_LINE, assert, assert_release, pgbuf_buffer_pool::buf_hash_table, pgbuf_holder::bufptr, CAST_BFPTR_TO_PGPTR, CAST_PGPTR_TO_BFPTR, pgbuf_watcher::curr_rank, diff, DISK_VALID, er_errid(), er_errid_if_has_error(), ER_ERROR_SEVERITY, ER_FAILED, ER_FAILED_ASSERTION, ER_FATAL_ERROR_SEVERITY, ER_INTERRUPTED, ER_LK_PAGE_TIMEOUT, er_log_debug, ER_PB_BAD_PAGEID, ER_PB_ORDERED_INCONSISTENCY, ER_PB_ORDERED_REFIX_FAILED, er_set(), pgbuf_holder::first_watcher, pgbuf_holder::fix_count, pgbuf_holder::fixed_at, pgbuf_watcher::group_id, pgbuf_holder_info::group_id, i, pgbuf_watcher::initial_rank, pgbuf_iopage_buffer::iopage, pgbuf_bcb::iopage_buffer, pgbuf_holder::last_watcher, pgbuf_watcher::latch_mode, pgbuf_holder_info::latch_mode, LK_FORCE_ZERO_WAIT, LK_ZERO_WAIT, pgbuf_watcher::magic, pgbuf_watcher::next, NO_ERROR, NULL, OLD_PAGE, OLD_PAGE_PREVENT_DEALLOC, PAGE_HEAP, pgbuf_watcher::page_was_unfixed, vpid::pageid, pgbuf_add_watch_instance_internal(), pgbuf_bcb_register_avoid_deallocation(), pgbuf_bcb_should_avoid_deallocation(), PGBUF_BCB_UNLOCK, pgbuf_bcb_unregister_avoid_deallocation(), pgbuf_check_page_ptype(), PGBUF_CLEAR_WATCHER, pgbuf_compare_hold_vpid_for_sort(), PGBUF_CONDITIONAL_LATCH, pgbuf_find_current_wait_msecs(), pgbuf_fix_debug(), pgbuf_get_groupid_and_unfix(), pgbuf_get_page_ptype(), PGBUF_HASH_VALUE, PGBUF_IS_ORDERED_PAGETYPE, pgbuf_is_valid_page(), PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_MAX_PAGE_FIXED_BY_TRAN, PGBUF_MAX_PAGE_WATCHERS, PGBUF_ORDERED_HEAP_HDR, PGBUF_ORDERED_RANK_UNDEFINED, pgbuf_ordered_unfix_and_init, pgbuf_search_hash_chain(), PGBUF_UNCONDITIONAL_LATCH, pgbuf_unfix, pgbuf_unfix_and_init, pgbuf_watcher_init_debug(), PGBUF_WATCHER_MAGIC_NUMBER, pgbuf_watcher::pgptr, pgbuf_holder_info::prevent_dealloc, fileio_page::prv, pthread_mutex_unlock, fileio_page_reserved::ptype, pgbuf_holder_info::ptype, pgbuf_holder_info::rank, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, thread_get_entry_index(), vpid::volid, pgbuf_holder_info::vpid, pgbuf_bcb::vpid, VPID_AS_ARGS, VPID_COPY, VPID_EQ, VPID_ISNULL, VPID_SET_NULL, pgbuf_holder_info::watch_count, pgbuf_holder::watch_count, and pgbuf_holder_info::watcher.

Referenced by heap_scan_pb_lock_and_fetch_debug().

Here is the caller graph for this function:

void pgbuf_ordered_set_dirty_and_free	(	THREAD_ENTRY *	thread_p,
		PGBUF_WATCHER *	pg_watcher
	)

Definition at line 12603 of file page_buffer.c.

References DONT_FREE, pgbuf_ordered_unfix, pgbuf_set_dirty(), and pgbuf_watcher::pgptr.

Referenced by heap_get_num_objects(), heap_stats_find_best_page(), heap_vpid_remove(), and xheap_reclaim_addresses().

Here is the caller graph for this function:

void pgbuf_ordered_unfix_debug	(	THREAD_ENTRY *	thread_p,
		PGBUF_WATCHER *	watcher_object,
		const char *	caller_file,
		int	caller_line
	)

Definition at line 12284 of file page_buffer.c.

References assert, assert_release, pgbuf_holder::fix_count, pgbuf_holder::last_watcher, pgbuf_watcher::magic, NULL, pgbuf_get_holder(), pgbuf_remove_watcher(), pgbuf_unfix, pgbuf_unfix_debug(), pgbuf_watcher_init_debug(), PGBUF_WATCHER_MAGIC_NUMBER, pgbuf_watcher::pgptr, pgbuf_watcher::prev, STATIC_INLINE, and pgbuf_holder::watch_count.

int pgbuf_page_has_changed	(	PAGE_PTR	pgptr,
		LOG_LSA *	ref_lsa
	)

Definition at line 4342 of file page_buffer.c.

References LSA_COPY(), LSA_EQ(), and pgbuf_get_lsa().

Referenced by scan_next_heap_scan().

Here is the caller graph for this function:

void pgbuf_peek_stats	(	UINT64 *	fixed_cnt,
		UINT64 *	dirty_cnt,
		UINT64 *	lru1_cnt,
		UINT64 *	lru2_cnt,
		UINT64 *	lru3_cnt,
		UINT64 *	victim_candidates,
		UINT64 *	avoid_dealloc_cnt,
		UINT64 *	avoid_victim_cnt,
		UINT64 *	private_quota,
		UINT64 *	private_cnt,
		UINT64 *	alloc_bcb_waiter_high,
		UINT64 *	alloc_bcb_waiter_med,
		UINT64 *	flushed_bcbs_waiting_direct_assign,
		UINT64 *	lfcq_big_prv_num,
		UINT64 *	lfcq_prv_num,
		UINT64 *	lfcq_shr_num
	)

int pgbuf_promote_read_latch_debug	(	THREAD_ENTRY *	thread_p,
		PAGE_PTR *	pgptr_p,
		PGBUF_PROMOTE_CONDITION	condition,
		const char *	caller_file,
		int	caller_line
	)

Definition at line 2198 of file page_buffer.c.

References ARG_FILE_LINE, assert, assert_release, pgbuf_holder::bufptr, CAST_PGPTR_TO_BFPTR, ER_FAILED, ER_NOTIFICATION_SEVERITY, ER_PAGE_LATCH_PROMOTE_FAIL, er_set(), pgbuf_bcb::fcnt, pgbuf_holder::fix_count, pgbuf_holder_stat::hold_has_read_latch, pgbuf_holder_stat::hold_has_write_latch, pgbuf_bcb::latch_mode, NO_ERROR, NULL, vpid::pageid, PERF_HOLDER_LATCH_READ, PERF_HOLDER_LATCH_WRITE, PERF_PAGE_UNKNOWN, PERF_PROMOTE_ONLY_READER, PERF_PROMOTE_SHARED_READER, pgbuf_holder::perf_stat, perfmon_is_perf_tracking(), pgbuf_add_fixed_at(), pgbuf_allocate_thrd_holder_entry(), PGBUF_BCB_LOCK, PGBUF_BCB_UNLOCK, pgbuf_block_bcb(), PGBUF_DEBUG_PAGE_VALIDATION_FREE, pgbuf_find_thrd_holder(), pgbuf_get_check_page_validation_level(), pgbuf_get_page_type_for_stat(), pgbuf_is_valid_page_ptr(), PGBUF_LATCH_READ, PGBUF_LATCH_WRITE, PGBUF_PROMOTE_ONLY_READER, PGBUF_PROMOTE_SHARED_READER, pgbuf_remove_thrd_holder(), rv, tsc_elapsed_time_usec(), tsc_getticks(), vpid::volid, pgbuf_bcb::vpid, and VPID_ISNULL.

static int pgbuf_put_bcb_into_invalid_list	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr
	)

static

Definition at line 8136 of file page_buffer.c.

References pgbuf_page_quota::add_shared_lru_idx, ARG_FILE_LINE, assert, pgbuf_page_quota::avoid_shared_lru_idx, pgbuf_buffer_pool::buf_invalid_list, pgbuf_bcb::flags, i, pgbuf_invalid_list::invalid_cnt, pgbuf_invalid_list::invalid_top, pgbuf_bcb::latch_mode, pgbuf_bcb::next_BCB, NO_ERROR, pgbuf_buffer_pool::num_buffers, PAGE_ADD_REFRESH_STAT, pgbuf_bcb_change_zone(), pgbuf_bcb_check_and_reset_fix_and_avoid_dealloc(), PGBUF_BCB_FLAGS_MASK, PGBUF_BCB_UNLOCK, PGBUF_GET_LRU_LIST, pgbuf_get_shared_lru_index_for_add(), PGBUF_INVALID_ZONE, PGBUF_LATCH_INVALID, PGBUF_LRU_LIST_COUNT, PGBUF_SHARED_LRU_COUNT, pthread_mutex_lock, pthread_mutex_unlock, pgbuf_buffer_pool::quota, rv, STATIC_INLINE, pgbuf_bcb::vpid, and VPID_SET_NULL.

Referenced by pgbuf_claim_bcb_for_fix(), pgbuf_delete_from_hash_chain(), pgbuf_fix_debug(), and pgbuf_invalidate_bcb().

Here is the caller graph for this function:

int pgbuf_release_private_lru	(	THREAD_ENTRY *	thread_p,
		const int	private_idx
	)

Definition at line 13406 of file page_buffer.c.

References pgbuf_page_monitor::lru_activity, pgbuf_buffer_pool::monitor, NO_ERROR, pgbuf_buffer_pool::num_buffers, pgbuf_adjust_quotas(), PGBUF_LRU_INDEX_FROM_PRIVATE, PGBUF_PAGE_QUOTA_IS_ENABLED, PGBUF_PRIVATE_LRU_COUNT, pgbuf_page_quota::private_lru_session_cnt, and pgbuf_buffer_pool::quota.

Referenced by session_state_uninit().

Here is the caller graph for this function:

STATIC_INLINE void pgbuf_remove_from_lru_list	(	THREAD_ENTRY *	thread_p,
		PGBUF_BCB *	bufptr,
		PGBUF_LRU_LIST *	lru_list
	)

Definition at line 9530 of file page_buffer.c.

References assert, pgbuf_lru_list::bottom, pgbuf_lru_list::bottom_1, pgbuf_lru_list::bottom_2, pgbuf_lru_list::count_lru2, pgbuf_bcb::next_BCB, NULL, pgbuf_bcb_change_zone(), pgbuf_bcb_get_zone(), PGBUF_LRU_2_ZONE, pgbuf_lru_advance_victim_hint(), PGBUF_VOID_ZONE, pgbuf_bcb::prev_BCB, and pgbuf_lru_list::top.

Referenced by pgbuf_get_victim_from_lru_list(), pgbuf_lru_boost_bcb(), pgbuf_lru_fall_bcb_to_zone_3(), pgbuf_lru_remove_bcb(), and pgbuf_move_bcb_to_bottom_lru().

Here is the caller graph for this function:

static int pgbuf_remove_private_from_aout_list ( const int lru_idx )

static

STATIC_INLINE int pgbuf_remove_thrd_holder	(	THREAD_ENTRY *	thread_p,
		PGBUF_HOLDER *	holder
	)

Definition at line 5545 of file page_buffer.c.

References assert, ER_FAILED, err, pgbuf_holder::fix_count, pgbuf_holder::next_holder, NO_ERROR, NULL, pgbuf_holder_anchor::num_free_cnt, pgbuf_holder_anchor::num_hold_cnt, pgbuf_holder_anchor::thrd_free_list, pgbuf_holder_anchor::thrd_hold_list, pgbuf_buffer_pool::thrd_holder_info, pgbuf_holder::thrd_link, thread_get_entry_index(), and pgbuf_holder::watch_count.

Referenced by pgbuf_latch_bcb_upon_fix(), pgbuf_promote_read_latch_debug(), and pgbuf_unlatch_thrd_holder().

Here is the caller graph for this function:

static int pgbuf_remove_vpid_from_aout_list	(	THREAD_ENTRY *	thread_p,
		const VPID *	vpid
	)

static

Definition at line 9723 of file page_buffer.c.

References pgbuf_aout_list::Aout_bottom, pgbuf_aout_list::aout_buf_ht, pgbuf_aout_list::Aout_free, AOUT_HASH_IDX, pgbuf_aout_list::Aout_top, pgbuf_buffer_pool::buf_AOUT_list, pgbuf_aout_buf::lru_idx, pgbuf_aout_list::max_count, mht_get(), mht_rem(), pgbuf_aout_buf::next, NULL, PGBUF_AOUT_NOT_FOUND, pgbuf_aout_buf::prev, pthread_mutex_lock, pthread_mutex_unlock, rv, pgbuf_aout_buf::vpid, and VPID_SET_NULL.

Referenced by pgbuf_unlatch_void_zone_bcb().

Here is the caller graph for this function:

static void pgbuf_remove_watcher	(	PGBUF_HOLDER *	holder,
		PGBUF_WATCHER *	watcher_object
	)

static

Definition at line 12506 of file page_buffer.c.

References assert, pgbuf_watcher::curr_rank, pgbuf_holder::first_watcher, pgbuf_holder::last_watcher, pgbuf_watcher::magic, pgbuf_watcher::next, NULL, PGBUF_ORDERED_RANK_UNDEFINED, PGBUF_WATCHER_MAGIC_NUMBER, pgbuf_watcher::pgptr, pgbuf_watcher::prev, and pgbuf_holder::watch_count.

Referenced by pgbuf_ordered_unfix_debug(), and pgbuf_replace_watcher_debug().

Here is the caller graph for this function:

void pgbuf_replace_watcher_debug	(	THREAD_ENTRY *	thread_p,
		PGBUF_WATCHER *	old_watcher,
		PGBUF_WATCHER *	new_watcher,
		const char *	caller_file,
		const int	caller_line
	)