PostgreSQL Source Code
git master
|
Go to the source code of this file.
Data Structures | |
struct | SlruSharedData |
struct | SlruCtlData |
Macros | |
#define | SLRU_PAGES_PER_SEGMENT 32 |
#define | SlruPagePrecedesUnitTests(ctl, per_page) do {} while (0) |
Typedefs | |
typedef struct SlruSharedData | SlruSharedData |
typedef SlruSharedData * | SlruShared |
typedef struct SlruCtlData | SlruCtlData |
typedef SlruCtlData * | SlruCtl |
typedef bool(* | SlruScanCallback) (SlruCtl ctl, char *filename, int segpage, void *data) |
Enumerations | |
enum | SlruPageStatus { SLRU_PAGE_EMPTY , SLRU_PAGE_READ_IN_PROGRESS , SLRU_PAGE_VALID , SLRU_PAGE_WRITE_IN_PROGRESS } |
Functions | |
Size | SimpleLruShmemSize (int nslots, int nlsns) |
void | SimpleLruInit (SlruCtl ctl, const char *name, int nslots, int nlsns, LWLock *ctllock, const char *subdir, int tranche_id, SyncRequestHandler sync_handler) |
int | SimpleLruZeroPage (SlruCtl ctl, int pageno) |
int | SimpleLruReadPage (SlruCtl ctl, int pageno, bool write_ok, TransactionId xid) |
int | SimpleLruReadPage_ReadOnly (SlruCtl ctl, int pageno, TransactionId xid) |
void | SimpleLruWritePage (SlruCtl ctl, int slotno) |
void | SimpleLruWriteAll (SlruCtl ctl, bool allow_redirtied) |
void | SimpleLruTruncate (SlruCtl ctl, int cutoffPage) |
bool | SimpleLruDoesPhysicalPageExist (SlruCtl ctl, int pageno) |
bool | SlruScanDirectory (SlruCtl ctl, SlruScanCallback callback, void *data) |
void | SlruDeleteSegment (SlruCtl ctl, int segno) |
int | SlruSyncFileTag (SlruCtl ctl, const FileTag *ftag, char *path) |
bool | SlruScanDirCbReportPresence (SlruCtl ctl, char *filename, int segpage, void *data) |
bool | SlruScanDirCbDeleteAll (SlruCtl ctl, char *filename, int segpage, void *data) |
#define SlruPagePrecedesUnitTests | ( | ctl, | |
per_page | |||
) | do {} while (0) |
typedef SlruCtlData* SlruCtl |
typedef struct SlruCtlData SlruCtlData |
typedef SlruSharedData* SlruShared |
typedef struct SlruSharedData SlruSharedData |
enum SlruPageStatus |
Definition at line 627 of file slru.c.
References CloseTransientFile(), endpos, fd(), MAXPGPATH, OpenTransientFile(), PG_BINARY, pgstat_count_slru_page_exists(), SlruWriteAllData::segno, SlruCtlData::shared, SLRU_CLOSE_FAILED, slru_errcause, slru_errno, SLRU_OPEN_FAILED, SLRU_PAGES_PER_SEGMENT, SLRU_SEEK_FAILED, SlruSharedData::slru_stats_idx, SlruFileName, and SlruReportIOError().
Referenced by ActivateCommitTs(), find_multixact_start(), MaybeExtendOffsetSlru(), and test_slru_page_exists().
void SimpleLruInit | ( | SlruCtl | ctl, |
const char * | name, | ||
int | nslots, | ||
int | nlsns, | ||
LWLock * | ctllock, | ||
const char * | subdir, | ||
int | tranche_id, | ||
SyncRequestHandler | sync_handler | ||
) |
Definition at line 188 of file slru.c.
References Assert(), SlruSharedData::buffer_locks, BUFFERALIGN, SlruSharedData::ControlLock, SlruSharedData::cur_lru_count, SlruCtlData::Dir, SlruSharedData::group_lsn, IsUnderPostmaster, LWLockPadded::lock, SlruSharedData::lsn_groups_per_page, LWLockInitialize(), MAXALIGN, name, SlruSharedData::num_slots, SlruSharedData::page_buffer, SlruSharedData::page_dirty, SlruSharedData::page_lru_count, SlruSharedData::page_number, SlruSharedData::page_status, pgstat_get_slru_index(), SlruCtlData::shared, ShmemInitStruct(), SimpleLruShmemSize(), SLRU_PAGE_EMPTY, SlruSharedData::slru_stats_idx, strlcpy(), and SlruCtlData::sync_handler.
Referenced by AsyncShmemInit(), CLOGShmemInit(), CommitTsShmemInit(), MultiXactShmemInit(), SerialInit(), SUBTRANSShmemInit(), and test_slru_shmem_startup().
int SimpleLruReadPage | ( | SlruCtl | ctl, |
int | pageno, | ||
bool | write_ok, | ||
TransactionId | xid | ||
) |
Definition at line 396 of file slru.c.
References Assert(), SlruSharedData::buffer_locks, SlruSharedData::ControlLock, LWLockPadded::lock, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SlruSharedData::page_dirty, SlruSharedData::page_number, SlruSharedData::page_status, pgstat_count_slru_page_hit(), pgstat_count_slru_page_read(), SlruCtlData::shared, SimpleLruWaitIO(), SimpleLruZeroLSNs(), SLRU_PAGE_EMPTY, SLRU_PAGE_READ_IN_PROGRESS, SLRU_PAGE_VALID, SLRU_PAGE_WRITE_IN_PROGRESS, SlruSharedData::slru_stats_idx, SlruPhysicalReadPage(), SlruRecentlyUsed, SlruReportIOError(), and SlruSelectLRUPage().
Referenced by asyncQueueAddEntries(), GetMultiXactIdMembers(), RecordNewMultiXact(), SerialAdd(), SetXidCommitTsInPage(), SimpleLruReadPage_ReadOnly(), SubTransSetParent(), test_slru_page_read(), TransactionIdSetPageStatusInternal(), TrimCLOG(), and TrimMultiXact().
int SimpleLruReadPage_ReadOnly | ( | SlruCtl | ctl, |
int | pageno, | ||
TransactionId | xid | ||
) |
Definition at line 496 of file slru.c.
References SlruSharedData::ControlLock, LW_EXCLUSIVE, LW_SHARED, LWLockAcquire(), LWLockRelease(), SlruSharedData::num_slots, SlruSharedData::page_number, SlruSharedData::page_status, pgstat_count_slru_page_hit(), SlruCtlData::shared, SimpleLruReadPage(), SLRU_PAGE_EMPTY, SLRU_PAGE_READ_IN_PROGRESS, SlruSharedData::slru_stats_idx, and SlruRecentlyUsed.
Referenced by asyncQueueReadAllNotifications(), find_multixact_start(), SerialGetMinConflictCommitSeqNo(), SubTransGetParent(), test_slru_page_readonly(), TransactionIdGetCommitTsData(), and TransactionIdGetStatus().
Size SimpleLruShmemSize | ( | int | nslots, |
int | nlsns | ||
) |
Definition at line 156 of file slru.c.
References BUFFERALIGN, and MAXALIGN.
Referenced by AsyncShmemSize(), CLOGShmemSize(), CommitTsShmemSize(), MultiXactShmemSize(), PredicateLockShmemSize(), SimpleLruInit(), SUBTRANSShmemSize(), and test_slru_shmem_request().
void SimpleLruTruncate | ( | SlruCtl | ctl, |
int | cutoffPage | ||
) |
Definition at line 1227 of file slru.c.
References SlruSharedData::ControlLock, SlruCtlData::Dir, ereport, errmsg(), SlruSharedData::latest_page_number, LOG, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SlruSharedData::num_slots, SlruSharedData::page_dirty, SlruSharedData::page_number, SlruSharedData::page_status, SlruCtlData::PagePrecedes, pgstat_count_slru_truncate(), SlruCtlData::shared, SimpleLruWaitIO(), SLRU_PAGE_EMPTY, SLRU_PAGE_VALID, SlruSharedData::slru_stats_idx, SlruInternalWritePage(), SlruScanDirCbDeleteCutoff(), and SlruScanDirectory().
Referenced by asyncQueueAdvanceTail(), CheckPointPredicate(), clog_redo(), commit_ts_redo(), PerformOffsetsTruncation(), test_slru_page_truncate(), TruncateCLOG(), TruncateCommitTs(), and TruncateSUBTRANS().
Definition at line 1157 of file slru.c.
References Assert(), CloseTransientFile(), SlruSharedData::ControlLock, SlruCtlData::Dir, SlruWriteAllData::fd, fsync_fname(), i, InvalidTransactionId, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SlruWriteAllData::num_files, SlruSharedData::num_slots, SlruSharedData::page_dirty, SlruSharedData::page_status, pgstat_count_slru_flush(), SlruWriteAllData::segno, SlruCtlData::shared, SLRU_CLOSE_FAILED, slru_errcause, slru_errno, SLRU_PAGE_EMPTY, SLRU_PAGE_VALID, SLRU_PAGES_PER_SEGMENT, SlruSharedData::slru_stats_idx, SlruInternalWritePage(), SlruReportIOError(), SlruCtlData::sync_handler, and SYNC_HANDLER_NONE.
Referenced by CheckPointCLOG(), CheckPointCommitTs(), CheckPointMultiXact(), CheckPointPredicate(), CheckPointSUBTRANS(), find_multixact_start(), and test_slru_page_writeall().
void SimpleLruWritePage | ( | SlruCtl | ctl, |
int | slotno | ||
) |
Definition at line 615 of file slru.c.
References SlruInternalWritePage().
Referenced by ActivateCommitTs(), BootStrapCLOG(), BootStrapMultiXact(), BootStrapSUBTRANS(), clog_redo(), commit_ts_redo(), MaybeExtendOffsetSlru(), multixact_redo(), and test_slru_page_write().
int SimpleLruZeroPage | ( | SlruCtl | ctl, |
int | pageno | ||
) |
Definition at line 281 of file slru.c.
References Assert(), SlruSharedData::latest_page_number, MemSet, SlruSharedData::page_buffer, SlruSharedData::page_dirty, SlruSharedData::page_number, SlruSharedData::page_status, pgstat_count_slru_page_zeroed(), SlruCtlData::shared, SimpleLruZeroLSNs(), SLRU_PAGE_EMPTY, SLRU_PAGE_VALID, SlruSharedData::slru_stats_idx, SlruRecentlyUsed, and SlruSelectLRUPage().
Referenced by asyncQueueAddEntries(), SerialAdd(), test_slru_page_write(), ZeroCLOGPage(), ZeroCommitTsPage(), ZeroMultiXactMemberPage(), ZeroMultiXactOffsetPage(), and ZeroSUBTRANSPage().
void SlruDeleteSegment | ( | SlruCtl | ctl, |
int | segno | ||
) |
Definition at line 1328 of file slru.c.
References SlruSharedData::ControlLock, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SlruSharedData::num_slots, SlruSharedData::page_dirty, SlruSharedData::page_number, SlruSharedData::page_status, SlruWriteAllData::segno, SlruCtlData::shared, SimpleLruWaitIO(), SLRU_PAGE_EMPTY, SLRU_PAGE_VALID, SLRU_PAGES_PER_SEGMENT, SlruInternalDeleteSegment(), and SlruInternalWritePage().
Referenced by PerformMembersTruncation(), and test_slru_page_delete().
Definition at line 1531 of file slru.c.
References SLRU_PAGES_PER_SEGMENT, and SlruInternalDeleteSegment().
Referenced by AsyncShmemInit(), DeactivateCommitTs(), and test_slru_scan_cb().
Definition at line 1501 of file slru.c.
References data, and SlruMayDeleteSegment().
Referenced by TruncateCLOG(), and TruncateCommitTs().
bool SlruScanDirectory | ( | SlruCtl | ctl, |
SlruScanCallback | callback, | ||
void * | data | ||
) |
Definition at line 1554 of file slru.c.
References AllocateDir(), callback(), dirent::d_name, data, DEBUG2, SlruCtlData::Dir, elog(), FreeDir(), len, ReadDir(), and SLRU_PAGES_PER_SEGMENT.
Referenced by AsyncShmemInit(), DeactivateCommitTs(), SimpleLruTruncate(), test_slru_delete_all(), TruncateCLOG(), TruncateCommitTs(), and TruncateMultiXact().
Definition at line 1594 of file slru.c.
References CloseTransientFile(), fd(), OpenTransientFile(), PG_BINARY, pg_fsync(), pgstat_report_wait_end(), pgstat_report_wait_start(), FileTag::segno, SlruFileName, and WAIT_EVENT_SLRU_FLUSH_SYNC.
Referenced by clogsyncfiletag(), committssyncfiletag(), multixactmemberssyncfiletag(), multixactoffsetssyncfiletag(), and test_slru_page_sync().