91 lines
2.7 KiB
C
91 lines
2.7 KiB
C
|
/*-------------------------------------------------------------------------
|
||
|
|
* conflict.h
|
||
|
|
* Exports for conflicts logging.
|
||
|
|
*
|
||
|
|
* Copyright (c) 2024-2025, PostgreSQL Global Development Group
|
||
|
|
*
|
||
|
|
*-------------------------------------------------------------------------
|
||
|
|
*/
|
||
|
|
#ifndef CONFLICT_H
|
||
|
|
#define CONFLICT_H
|
||
|
|
|
||
|
|
#include "access/xlogdefs.h"
|
||
|
|
#include "nodes/pg_list.h"
|
||
|
|
#include "utils/timestamp.h"
|
||
|
|
|
||
|
|
/* Avoid including execnodes.h here */
|
||
|
|
struct EState;
|
||
|
|
struct ResultRelInfo;
|
||
|
|
struct TupleTableSlot;
|
||
|
|
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Conflict types that could occur while applying remote changes.
|
||
|
|
*
|
||
|
|
* This enum is used in statistics collection (see
|
||
|
|
* PgStat_StatSubEntry::conflict_count and
|
||
|
|
* PgStat_BackendSubEntry::conflict_count) as well, therefore, when adding new
|
||
|
|
* values or reordering existing ones, ensure to review and potentially adjust
|
||
|
|
* the corresponding statistics collection codes.
|
||
|
|
*/
|
||
|
|
typedef enum
|
||
|
|
{
|
||
|
|
/* The row to be inserted violates unique constraint */
|
||
|
|
CT_INSERT_EXISTS,
|
||
|
|
|
||
|
|
/* The row to be updated was modified by a different origin */
|
||
|
|
CT_UPDATE_ORIGIN_DIFFERS,
|
||
|
|
|
||
|
|
/* The updated row value violates unique constraint */
|
||
|
|
CT_UPDATE_EXISTS,
|
||
|
|
|
||
|
|
/* The row to be updated is missing */
|
||
|
|
CT_UPDATE_MISSING,
|
||
|
|
|
||
|
|
/* The row to be deleted was modified by a different origin */
|
||
|
|
CT_DELETE_ORIGIN_DIFFERS,
|
||
|
|
|
||
|
|
/* The row to be deleted is missing */
|
||
|
|
CT_DELETE_MISSING,
|
||
|
|
|
||
|
|
/* The row to be inserted/updated violates multiple unique constraint */
|
||
|
|
CT_MULTIPLE_UNIQUE_CONFLICTS,
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Other conflicts, such as exclusion constraint violations, involve more
|
||
|
|
* complex rules than simple equality checks. These conflicts are left for
|
||
|
|
* future improvements.
|
||
|
|
*/
|
||
|
|
} ConflictType;
|
||
|
|
|
||
|
|
#define CONFLICT_NUM_TYPES (CT_MULTIPLE_UNIQUE_CONFLICTS + 1)
|
||
|
|
|
||
|
|
/*
|
||
|
|
* Information for the existing local row that caused the conflict.
|
||
|
|
*/
|
||
|
|
typedef struct ConflictTupleInfo
|
||
|
|
{
|
||
|
|
struct TupleTableSlot *slot; /* tuple slot holding the conflicting
|
||
|
|
* local tuple */
|
||
|
|
Oid indexoid; /* OID of the index where the conflict
|
||
|
|
* occurred */
|
||
|
|
TransactionId xmin; /* transaction ID of the modification causing
|
||
|
|
* the conflict */
|
||
|
|
RepOriginId origin; /* origin identifier of the modification */
|
||
|
|
TimestampTz ts; /* timestamp of when the modification on the
|
||
|
|
* conflicting local row occurred */
|
||
|
|
} ConflictTupleInfo;
|
||
|
|
|
||
|
|
extern bool GetTupleTransactionInfo(struct TupleTableSlot *localslot,
|
||
|
|
TransactionId *xmin,
|
||
|
|
RepOriginId *localorigin,
|
||
|
|
TimestampTz *localts);
|
||
|
|
extern void ReportApplyConflict(struct EState *estate, struct ResultRelInfo *relinfo,
|
||
|
|
int elevel, ConflictType type,
|
||
|
|
struct TupleTableSlot *searchslot,
|
||
|
|
struct TupleTableSlot *remoteslot,
|
||
|
|
List *conflicttuples);
|
||
|
|
extern void InitConflictIndexes(struct ResultRelInfo *relInfo);
|
||
|
|
|
||
|
|
#endif
|