PostgreSQL Source Code git master
|
#include "postgres.h"
#include "access/commit_ts.h"
#include "access/htup_details.h"
#include "access/slru.h"
#include "access/transam.h"
#include "access/xloginsert.h"
#include "access/xlogutils.h"
#include "funcapi.h"
#include "miscadmin.h"
#include "storage/shmem.h"
#include "utils/fmgrprotos.h"
#include "utils/guc_hooks.h"
#include "utils/timestamp.h"
Go to the source code of this file.
Data Structures | |
struct | CommitTimestampEntry |
struct | CommitTimestampShared |
Macros | |
#define | SizeOfCommitTimestampEntry |
#define | COMMIT_TS_XACTS_PER_PAGE (BLCKSZ / SizeOfCommitTimestampEntry) |
#define | TransactionIdToCTsEntry(xid) ((xid) % (TransactionId) COMMIT_TS_XACTS_PER_PAGE) |
#define | CommitTsCtl (&CommitTsCtlData) |
Typedefs | |
typedef struct CommitTimestampEntry | CommitTimestampEntry |
typedef struct CommitTimestampShared | CommitTimestampShared |
Variables | |
static SlruCtlData | CommitTsCtlData |
static CommitTimestampShared * | commitTsShared |
bool | track_commit_timestamp |
#define COMMIT_TS_XACTS_PER_PAGE (BLCKSZ / SizeOfCommitTimestampEntry) |
Definition at line 63 of file commit_ts.c.
#define CommitTsCtl (&CommitTsCtlData) |
Definition at line 85 of file commit_ts.c.
#define SizeOfCommitTimestampEntry |
Definition at line 60 of file commit_ts.c.
#define TransactionIdToCTsEntry | ( | xid | ) | ((xid) % (TransactionId) COMMIT_TS_XACTS_PER_PAGE) |
Definition at line 77 of file commit_ts.c.
typedef struct CommitTimestampEntry CommitTimestampEntry |
typedef struct CommitTimestampShared CommitTimestampShared |
|
static |
Definition at line 705 of file commit_ts.c.
References Assert, CommitTimestampShared::commitTsActive, CommitTsCtl, commitTsShared, InvalidTransactionId, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), TransamVariablesData::newestCommitTsXid, TransamVariablesData::nextXid, TransamVariablesData::oldestCommitTsXid, pg_atomic_write_u64(), ReadNextTransactionId(), SimpleLruDoesPhysicalPageExist(), SimpleLruGetBankLock(), SimpleLruWritePage(), TransactionIdToCTsPage(), TransamVariables, XidFromFullTransactionId, and ZeroCommitTsPage().
Referenced by CommitTsParameterChange(), CompleteCommitTsInitialization(), and StartupCommitTs().
void AdvanceOldestCommitTsXid | ( | TransactionId | oldestXact | ) |
Definition at line 936 of file commit_ts.c.
References InvalidTransactionId, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), TransamVariablesData::oldestCommitTsXid, TransactionIdPrecedes(), and TransamVariables.
Referenced by commit_ts_redo(), and vac_truncate_clog().
void BootStrapCommitTs | ( | void | ) |
Definition at line 596 of file commit_ts.c.
Referenced by BootStrapXLOG().
bool check_commit_ts_buffers | ( | int * | newval, |
void ** | extra, | ||
GucSource | source | ||
) |
Definition at line 584 of file commit_ts.c.
References check_slru_buffers(), and newval.
void CheckPointCommitTs | ( | void | ) |
Definition at line 820 of file commit_ts.c.
References CommitTsCtl, and SimpleLruWriteAll().
Referenced by CheckPointGuts().
void commit_ts_redo | ( | XLogReaderState * | record | ) |
Definition at line 1016 of file commit_ts.c.
References AdvanceOldestCommitTsXid(), Assert, COMMIT_TS_TRUNCATE, COMMIT_TS_ZEROPAGE, CommitTsCtl, elog, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), xl_commit_ts_truncate::oldestXid, xl_commit_ts_truncate::pageno, PANIC, pg_atomic_write_u64(), SimpleLruGetBankLock(), SimpleLruTruncate(), SimpleLruWritePage(), XLogRecGetData, XLogRecGetInfo, XLogRecHasAnyBlockRefs, and ZeroCommitTsPage().
Definition at line 970 of file commit_ts.c.
References COMMIT_TS_XACTS_PER_PAGE, FirstNormalTransactionId, and TransactionIdPrecedes().
Referenced by CommitTsShmemInit().
void CommitTsParameterChange | ( | bool | newvalue, |
bool | oldvalue | ||
) |
Definition at line 664 of file commit_ts.c.
References ActivateCommitTs(), CommitTimestampShared::commitTsActive, commitTsShared, and DeactivateCommitTs().
Referenced by xlog_redo().
|
static |
Definition at line 506 of file commit_ts.c.
References commit_timestamp_buffers, Max, Min, SimpleLruAutotuneBuffers(), and SLRU_MAX_ALLOWED_BUFFERS.
Referenced by CommitTsShmemInit(), and CommitTsShmemSize().
void CommitTsShmemInit | ( | void | ) |
Definition at line 530 of file commit_ts.c.
References Assert, buf, commit_timestamp_buffers, COMMIT_TS_XACTS_PER_PAGE, CommitTimestampShared::commitTsActive, CommitTsCtl, CommitTsPagePrecedes(), commitTsShared, CommitTsShmemBuffers(), CommitTimestampShared::dataLastCommit, InvalidRepOriginId, InvalidTransactionId, IsUnderPostmaster, LWTRANCHE_COMMITTS_BUFFER, LWTRANCHE_COMMITTS_SLRU, CommitTimestampEntry::nodeid, PGC_POSTMASTER, PGC_S_DYNAMIC_DEFAULT, PGC_S_OVERRIDE, SetConfigOption(), ShmemInitStruct(), SimpleLruInit(), SlruPagePrecedesUnitTests, snprintf, SYNC_HANDLER_COMMIT_TS, CommitTimestampEntry::time, TIMESTAMP_NOBEGIN, and CommitTimestampShared::xidLastCommit.
Referenced by CreateOrAttachShmemStructs().
Size CommitTsShmemSize | ( | void | ) |
Definition at line 519 of file commit_ts.c.
References CommitTsShmemBuffers(), and SimpleLruShmemSize().
Referenced by CalculateShmemSize().
int committssyncfiletag | ( | const FileTag * | ftag, |
char * | path | ||
) |
Definition at line 1063 of file commit_ts.c.
References CommitTsCtl, and SlruSyncFileTag().
void CompleteCommitTsInitialization | ( | void | ) |
Definition at line 642 of file commit_ts.c.
References ActivateCommitTs(), DeactivateCommitTs(), and track_commit_timestamp.
Referenced by StartupXLOG().
|
static |
Definition at line 778 of file commit_ts.c.
References CommitTimestampShared::commitTsActive, CommitTsCtl, commitTsShared, CommitTimestampShared::dataLastCommit, InvalidRepOriginId, InvalidTransactionId, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), TransamVariablesData::newestCommitTsXid, CommitTimestampEntry::nodeid, TransamVariablesData::oldestCommitTsXid, SlruScanDirCbDeleteAll(), SlruScanDirectory(), CommitTimestampEntry::time, TIMESTAMP_NOBEGIN, TransamVariables, and CommitTimestampShared::xidLastCommit.
Referenced by CommitTsParameterChange(), and CompleteCommitTsInitialization().
|
static |
Definition at line 381 of file commit_ts.c.
References ereport, errcode(), errhint(), errmsg(), ERROR, and RecoveryInProgress().
Referenced by GetLatestCommitTsData(), and TransactionIdGetCommitTsData().
void ExtendCommitTs | ( | TransactionId | newestXact | ) |
Definition at line 842 of file commit_ts.c.
References Assert, CommitTimestampShared::commitTsActive, CommitTsCtl, commitTsShared, FirstNormalTransactionId, InRecovery, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SimpleLruGetBankLock(), TransactionIdEquals, TransactionIdToCTsEntry, TransactionIdToCTsPage(), and ZeroCommitTsPage().
Referenced by GetNewTransactionId().
TransactionId GetLatestCommitTsData | ( | TimestampTz * | ts, |
RepOriginId * | nodeid | ||
) |
Definition at line 360 of file commit_ts.c.
References CommitTimestampShared::commitTsActive, commitTsShared, CommitTimestampShared::dataLastCommit, error_commit_ts_disabled(), LW_SHARED, LWLockAcquire(), LWLockRelease(), CommitTimestampEntry::nodeid, CommitTimestampEntry::time, and CommitTimestampShared::xidLastCommit.
Referenced by pg_last_committed_xact().
Datum pg_last_committed_xact | ( | PG_FUNCTION_ARGS | ) |
Definition at line 420 of file commit_ts.c.
References elog, ERROR, get_call_result_type(), GetLatestCommitTsData(), heap_form_tuple(), HeapTupleGetDatum(), ObjectIdGetDatum(), PG_RETURN_DATUM, TimestampTzGetDatum(), TransactionIdGetDatum(), TransactionIdIsNormal, TYPEFUNC_COMPOSITE, and values.
Datum pg_xact_commit_timestamp | ( | PG_FUNCTION_ARGS | ) |
Definition at line 397 of file commit_ts.c.
References PG_GETARG_TRANSACTIONID, PG_RETURN_NULL, PG_RETURN_TIMESTAMPTZ, and TransactionIdGetCommitTsData().
Datum pg_xact_commit_timestamp_origin | ( | PG_FUNCTION_ARGS | ) |
Definition at line 464 of file commit_ts.c.
References elog, ERROR, get_call_result_type(), heap_form_tuple(), HeapTupleGetDatum(), ObjectIdGetDatum(), PG_GETARG_TRANSACTIONID, PG_RETURN_DATUM, TimestampTzGetDatum(), TransactionIdGetCommitTsData(), TYPEFUNC_COMPOSITE, and values.
void SetCommitTsLimit | ( | TransactionId | oldestXact, |
TransactionId | newestXact | ||
) |
Definition at line 909 of file commit_ts.c.
References Assert, InvalidTransactionId, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), TransamVariablesData::newestCommitTsXid, TransamVariablesData::oldestCommitTsXid, TransactionIdPrecedes(), and TransamVariables.
Referenced by BootStrapXLOG(), and StartupXLOG().
|
static |
Definition at line 222 of file commit_ts.c.
References CommitTsCtl, i, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), SimpleLruGetBankLock(), SimpleLruReadPage(), and TransactionIdSetCommitTs().
Referenced by TransactionTreeSetCommitTsData().
void StartupCommitTs | ( | void | ) |
Definition at line 632 of file commit_ts.c.
References ActivateCommitTs().
Referenced by StartupXLOG().
bool TransactionIdGetCommitTsData | ( | TransactionId | xid, |
TimestampTz * | ts, | ||
RepOriginId * | nodeid | ||
) |
Definition at line 274 of file commit_ts.c.
References Assert, CommitTimestampShared::commitTsActive, CommitTsCtl, commitTsShared, CommitTimestampShared::dataLastCommit, ereport, errcode(), errmsg(), ERROR, error_commit_ts_disabled(), InvalidRepOriginId, LW_SHARED, LWLockAcquire(), LWLockRelease(), TransamVariablesData::newestCommitTsXid, CommitTimestampEntry::nodeid, TransamVariablesData::oldestCommitTsXid, SimpleLruGetBankLock(), SimpleLruReadPage_ReadOnly(), SizeOfCommitTimestampEntry, CommitTimestampEntry::time, TransactionIdIsNormal, TransactionIdIsValid, TransactionIdPrecedes(), TransactionIdToCTsEntry, TransactionIdToCTsPage(), TransamVariables, and CommitTimestampShared::xidLastCommit.
Referenced by GetTupleTransactionInfo(), pg_xact_commit_timestamp(), and pg_xact_commit_timestamp_origin().
|
static |
Definition at line 249 of file commit_ts.c.
References Assert, CommitTsCtl, CommitTimestampEntry::nodeid, SizeOfCommitTimestampEntry, CommitTimestampEntry::time, TransactionIdIsNormal, and TransactionIdToCTsEntry.
Referenced by SetXidCommitTsInPage().
|
inlinestatic |
Definition at line 72 of file commit_ts.c.
References COMMIT_TS_XACTS_PER_PAGE.
Referenced by ActivateCommitTs(), ExtendCommitTs(), TransactionIdGetCommitTsData(), TransactionTreeSetCommitTsData(), and TruncateCommitTs().
void TransactionTreeSetCommitTsData | ( | TransactionId | xid, |
int | nsubxids, | ||
TransactionId * | subxids, | ||
TimestampTz | timestamp, | ||
RepOriginId | nodeid | ||
) |
Definition at line 141 of file commit_ts.c.
References CommitTimestampShared::commitTsActive, commitTsShared, CommitTimestampShared::dataLastCommit, i, j, LW_EXCLUSIVE, LWLockAcquire(), LWLockRelease(), TransamVariablesData::newestCommitTsXid, CommitTimestampEntry::nodeid, SetXidCommitTsInPage(), CommitTimestampEntry::time, TransactionIdPrecedes(), TransactionIdToCTsPage(), TransamVariables, and CommitTimestampShared::xidLastCommit.
Referenced by RecordTransactionCommit(), RecordTransactionCommitPrepared(), and xact_redo_commit().
void TruncateCommitTs | ( | TransactionId | oldestXact | ) |
Definition at line 883 of file commit_ts.c.
References CommitTsCtl, SimpleLruTruncate(), SlruScanDirCbReportPresence(), SlruScanDirectory(), TransactionIdToCTsPage(), and WriteTruncateXlogRec().
Referenced by vac_truncate_clog().
|
static |
Definition at line 1000 of file commit_ts.c.
References COMMIT_TS_TRUNCATE, xl_commit_ts_truncate::oldestXid, xl_commit_ts_truncate::pageno, SizeOfCommitTsTruncate, XLogBeginInsert(), XLogInsert(), and XLogRegisterData().
Referenced by TruncateCommitTs().
|
static |
Definition at line 989 of file commit_ts.c.
References COMMIT_TS_ZEROPAGE, XLogBeginInsert(), XLogInsert(), and XLogRegisterData().
Referenced by ZeroCommitTsPage().
|
static |
Definition at line 615 of file commit_ts.c.
References CommitTsCtl, SimpleLruZeroPage(), and WriteZeroPageXlogRec().
Referenced by ActivateCommitTs(), commit_ts_redo(), and ExtendCommitTs().
|
static |
Definition at line 83 of file commit_ts.c.
|
static |
Definition at line 105 of file commit_ts.c.
Referenced by ActivateCommitTs(), CommitTsParameterChange(), CommitTsShmemInit(), DeactivateCommitTs(), ExtendCommitTs(), GetLatestCommitTsData(), TransactionIdGetCommitTsData(), and TransactionTreeSetCommitTsData().
bool track_commit_timestamp |
Definition at line 109 of file commit_ts.c.
Referenced by CompleteCommitTsInitialization(), GetTupleTransactionInfo(), InitControlFile(), and XLogReportParameters().