mirror of
https://git.postgresql.org/git/postgresql.git
synced 2026-02-22 06:17:00 +08:00
d1e027221d
In addition, add support for a "payload" string to be passed along with each notify event. This implementation should be significantly more efficient than the old one, and is also more compatible with Hot Standby usage. There is not yet any facility for HS slaves to receive notifications generated on the master, although such a thing is possible in future. Joachim Wieland, reviewed by Jeff Davis; also hacked on by me.
60 lines
1.8 KiB
C
60 lines
1.8 KiB
C
/*-------------------------------------------------------------------------
|
|
*
|
|
* async.h
|
|
* Asynchronous notification: NOTIFY, LISTEN, UNLISTEN
|
|
*
|
|
* Portions Copyright (c) 1996-2010, PostgreSQL Global Development Group
|
|
* Portions Copyright (c) 1994, Regents of the University of California
|
|
*
|
|
* $PostgreSQL: pgsql/src/include/commands/async.h,v 1.40 2010/02/16 22:34:57 tgl Exp $
|
|
*
|
|
*-------------------------------------------------------------------------
|
|
*/
|
|
#ifndef ASYNC_H
|
|
#define ASYNC_H
|
|
|
|
#include "fmgr.h"
|
|
|
|
/*
|
|
* The number of SLRU page buffers we use for the notification queue.
|
|
*/
|
|
#define NUM_ASYNC_BUFFERS 8
|
|
|
|
extern bool Trace_notify;
|
|
|
|
extern Size AsyncShmemSize(void);
|
|
extern void AsyncShmemInit(void);
|
|
|
|
/* notify-related SQL statements */
|
|
extern void Async_Notify(const char *channel, const char *payload);
|
|
extern void Async_Listen(const char *channel);
|
|
extern void Async_Unlisten(const char *channel);
|
|
extern void Async_UnlistenAll(void);
|
|
|
|
/* notify-related SQL functions */
|
|
extern Datum pg_listening_channels(PG_FUNCTION_ARGS);
|
|
extern Datum pg_notify(PG_FUNCTION_ARGS);
|
|
|
|
/* perform (or cancel) outbound notify processing at transaction commit */
|
|
extern void PreCommit_Notify(void);
|
|
extern void AtCommit_Notify(void);
|
|
extern void AtAbort_Notify(void);
|
|
extern void AtSubStart_Notify(void);
|
|
extern void AtSubCommit_Notify(void);
|
|
extern void AtSubAbort_Notify(void);
|
|
extern void AtPrepare_Notify(void);
|
|
extern void ProcessCompletedNotifies(void);
|
|
|
|
/* signal handler for inbound notifies (PROCSIG_NOTIFY_INTERRUPT) */
|
|
extern void HandleNotifyInterrupt(void);
|
|
|
|
/*
|
|
* enable/disable processing of inbound notifies directly from signal handler.
|
|
* The enable routine first performs processing of any inbound notifies that
|
|
* have occurred since the last disable.
|
|
*/
|
|
extern void EnableNotifyInterrupt(void);
|
|
extern bool DisableNotifyInterrupt(void);
|
|
|
|
#endif /* ASYNC_H */
|