PostgreSQL Source Code
git master
|
#include "postgres.h"
#include "access/xact.h"
#include "commands/async.h"
#include "miscadmin.h"
#include "storage/ipc.h"
#include "storage/proc.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 156 of file sinval.c.
References catchupInterruptPending, MyLatch, and SetLatch().
Referenced by procsignal_sigusr1_handler().
void ProcessCatchupInterrupt | ( | void | ) |
Definition at line 176 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 71 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 49 of file sinval.c.
References SIInsertDataEntries().
Referenced by AtEOXact_Inval(), CacheInvalidateRelmap(), CacheInvalidateSmgr(), FinishPreparedTransaction(), and ProcessCommittedInvalidationMessages().
volatile sig_atomic_t catchupInterruptPending = false |
Definition at line 41 of file sinval.c.
Referenced by HandleCatchupInterrupt(), ProcessCatchupInterrupt(), ProcessClientReadInterrupt(), and ReceiveSharedInvalidMessages().
uint64 SharedInvalidMessageCounter |
Definition at line 26 of file sinval.c.
Referenced by get_object_address(), RangeVarGetAndCheckCreationNamespace(), RangeVarGetRelidExtended(), and ReceiveSharedInvalidMessages().