PostgreSQL Source Code git master
|
#include "postgres.h"
#include "access/xact.h"
#include "miscadmin.h"
#include "storage/latch.h"
#include "storage/sinvaladt.h"
#include "utils/inval.h"
Go to the source code of this file.
Macros | |
#define | MAXINVALMSGS 32 |
Functions | |
void | SendSharedInvalidMessages (const SharedInvalidationMessage *msgs, int n) |
void | ReceiveSharedInvalidMessages (void(*invalFunction)(SharedInvalidationMessage *msg), void(*resetFunction)(void)) |
void | HandleCatchupInterrupt (void) |
void | ProcessCatchupInterrupt (void) |
Variables | |
uint64 | SharedInvalidMessageCounter |
volatile sig_atomic_t | catchupInterruptPending = false |
#define MAXINVALMSGS 32 |
void HandleCatchupInterrupt | ( | void | ) |
Definition at line 154 of file sinval.c.
References catchupInterruptPending, MyLatch, and SetLatch().
Referenced by procsignal_sigusr1_handler().
void ProcessCatchupInterrupt | ( | void | ) |
Definition at line 174 of file sinval.c.
References AcceptInvalidationMessages(), catchupInterruptPending, CommitTransactionCommand(), DEBUG4, elog, IsTransactionOrTransactionBlock(), and StartTransactionCommand().
Referenced by HandleAutoVacLauncherInterrupts(), and ProcessClientReadInterrupt().
void ReceiveSharedInvalidMessages | ( | void(*)(SharedInvalidationMessage *msg) | invalFunction, |
void(*)(void) | resetFunction | ||
) |
Definition at line 69 of file sinval.c.
References catchupInterruptPending, DEBUG4, elog, MAXINVALMSGS, SharedInvalidMessageCounter, SICleanupQueue(), and SIGetDataEntries().
Referenced by AcceptInvalidationMessages().
void SendSharedInvalidMessages | ( | const SharedInvalidationMessage * | msgs, |
int | n | ||
) |
Definition at line 47 of file sinval.c.
References SIInsertDataEntries().
Referenced by AtEOXact_Inval(), AtInplace_Inval(), CacheInvalidateRelmap(), CacheInvalidateSmgr(), FinishPreparedTransaction(), and ProcessCommittedInvalidationMessages().
volatile sig_atomic_t catchupInterruptPending = false |
Definition at line 39 of file sinval.c.
Referenced by HandleCatchupInterrupt(), ProcessCatchupInterrupt(), ProcessClientReadInterrupt(), and ReceiveSharedInvalidMessages().
uint64 SharedInvalidMessageCounter |
Definition at line 24 of file sinval.c.
Referenced by get_object_address(), RangeVarGetAndCheckCreationNamespace(), RangeVarGetRelidExtended(), and ReceiveSharedInvalidMessages().