1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
|
#ifndef __PIPE__
#define __PIPE__
#define LOCALMSGSZ (8*1024)
#define SHMEMMSGSZ (30*1024)
#define MAX_PIPES 30
#define MAX_EVENTS 30
#define MAX_LOCKS 256
typedef struct _message_item
{
char *message;
float8 timestamp;
struct _message_item *next_message;
struct _message_item *prev_message;
unsigned char message_id;
int *receivers; /* copy of array all registered receivers */
int receivers_number;
} message_item;
typedef struct _message_echo
{
struct _message_item *message;
unsigned char message_id;
struct _message_echo *next_echo;
} message_echo;
typedef struct
{
char *event_name;
unsigned char max_receivers;
int *receivers;
int receivers_number;
struct _message_item *messages;
} alert_event;
typedef struct
{
int sid;
int pid;
message_echo *echo;
} alert_lock;
bool ora_lock_shmem(size_t size, int max_pipes, int max_events, int max_locks, bool reset);
#define ERRCODE_ORA_PACKAGES_LOCK_REQUEST_ERROR MAKE_SQLSTATE('3','0', '0','0','1')
#define LOCK_ERROR() \
ereport(ERROR, \
(errcode(ERRCODE_ORA_PACKAGES_LOCK_REQUEST_ERROR), \
errmsg("lock request error"), \
errdetail("Failed exclusive locking of shared memory."), \
errhint("Restart PostgreSQL server.")));
#endif
extern alert_event *events;
extern alert_lock * locks;
extern int sid;
extern LWLockId shmem_lockid;
#if PG_VERSION_NUM >= 130000
#include "storage/condition_variable.h"
extern ConditionVariable *alert_cv;
#endif
|
