greenplumn cdbdistributedsnapshot 源码
greenplumn cdbdistributedsnapshot 代码
文件路径：/src/include/cdb/cdbdistributedsnapshot.h
/*-------------------------------------------------------------------------
*
* cdbdistributedsnapshot.h
*
* Portions Copyright (c) 2007-2008, Greenplum inc
* Portions Copyright (c) 2012-Present VMware, Inc. or its affiliates.
*
*
* IDENTIFICATION
* src/include/cdb/cdbdistributedsnapshot.h
*
*-------------------------------------------------------------------------
*/
#ifndef CDBDISTRIBUTEDSNAPSHOT_H
#define CDBDISTRIBUTEDSNAPSHOT_H
/* This is a shipped header, do not include other files under "cdb" */
#include "c.h" /* DistributedTransactionId */
#define DistributedSnapshot_StaticInit {0,0,0,0,0,0}
typedef struct DistributedSnapshot
{
/*
* The lowest distributed transaction being used for distributed snapshots.
*/
DistributedTransactionId xminAllDistributedSnapshots;
/*
* Unique number identifying this particular distributed snapshot.
*/
DistributedSnapshotId distribSnapshotId;
DistributedTransactionId xmin; /* XID < xmin are visible to me */
DistributedTransactionId xmax; /* XID >= xmax are invisible to me */
int32 count; /* # of distributed xids in inProgressXidArray */
/* Array of distributed transactions in progress. */
DistributedTransactionId *inProgressXidArray;
} DistributedSnapshot;
/*
* GPDB: Snapshot stores this information to check tuple visibility against
* distributed transactions.
*/
typedef struct DistributedSnapshotWithLocalMapping
{
DistributedSnapshot ds;
/*
* Cache to perform quick check for localXid, populated after reverse
* mapping distributed xid to local xid.
*/
TransactionId minCachedLocalXid;
TransactionId maxCachedLocalXid;
int32 currentLocalXidsCount;
TransactionId *inProgressMappedLocalXids;
} DistributedSnapshotWithLocalMapping;
typedef enum
{
DISTRIBUTEDSNAPSHOT_COMMITTED_NONE = 0,
DISTRIBUTEDSNAPSHOT_COMMITTED_INPROGRESS,
DISTRIBUTEDSNAPSHOT_COMMITTED_VISIBLE,
DISTRIBUTEDSNAPSHOT_COMMITTED_UNKNOWN,
DISTRIBUTEDSNAPSHOT_COMMITTED_IGNORE
} DistributedSnapshotCommitted;
extern int GetMaxSnapshotDistributedXidCount(void);
extern DistributedSnapshotCommitted DistributedSnapshotWithLocalMapping_CommittedTest(
DistributedSnapshotWithLocalMapping *dslm,
TransactionId localXid,
bool isVacuumCheck);
extern void DistributedSnapshot_Reset(
DistributedSnapshot *distributedSnapshot);
extern void DistributedSnapshot_Copy(
DistributedSnapshot *target,
DistributedSnapshot *source);
extern int
DistributedSnapshot_SerializeSize(DistributedSnapshot *ds);
extern int
DistributedSnapshot_Serialize(DistributedSnapshot *ds, char *buf);
extern int
DistributedSnapshot_Deserialize(const char *buf, DistributedSnapshot *ds);
#endif /* CDBDISTRIBUTEDSNAPSHOT_H */
相关信息
相关文章
greenplumn cdbappendonlyblockdirectory 源码
greenplumn cdbappendonlystorage 源码
greenplumn cdbappendonlystorage_int 源码
greenplumn cdbappendonlystorageformat 源码
greenplumn cdbappendonlystoragelayer 源码
greenplumn cdbappendonlystorageread 源码
0
赞
热门推荐
-
2、 - 优质文章
-
3、 gate.io
-
8、 golang
-
9、 openharmony
-
10、 Vue中input框自动聚焦