72 void (*resetFunction) (
void))
74 #define MAXINVALMSGS 32
81 static volatile int nextmsg = 0;
82 static volatile int nummsgs = 0;
85 while (nextmsg < nummsgs)
97 nextmsg = nummsgs = 0;
115 while (nextmsg < nummsgs)
140 elog(
DEBUG4,
"sinval catchup complete, cleaning queue");
195 elog(
DEBUG4,
"ProcessCatchupEvent inside transaction");
200 elog(
DEBUG4,
"ProcessCatchupEvent outside transaction");
elog(ERROR, "%s: %s", p2, msg)
void AcceptInvalidationMessages(void)
void SetLatch(Latch *latch)
void HandleCatchupInterrupt(void)
void SendSharedInvalidMessages(const SharedInvalidationMessage *msgs, int n)
void ReceiveSharedInvalidMessages(void(*invalFunction)(SharedInvalidationMessage *msg), void(*resetFunction)(void))
void ProcessCatchupInterrupt(void)
volatile sig_atomic_t catchupInterruptPending
uint64 SharedInvalidMessageCounter
void SICleanupQueue(bool callerHasWriteLock, int minFree)
int SIGetDataEntries(SharedInvalidationMessage *data, int datasize)
void SIInsertDataEntries(const SharedInvalidationMessage *data, int n)
bool IsTransactionOrTransactionBlock(void)
void StartTransactionCommand(void)
void CommitTransactionCommand(void)