| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
67 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
69 WalRcv->latch = NULL; in WalRcvShmemInit()
77 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
128 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
180 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
248 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
333 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
354 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL;
57 WalRcv = (WalRcvData *)
65 SpinLockInit(&WalRcv->mutex);
67 WalRcv->latch = NULL;
75 WalRcvData *walrcv = WalRcv; in fromNetworkByteStream()
120 WalRcvData *walrcv = WalRcv;
166 WalRcvData *walrcv = WalRcv; in toNetworkByteStream()
233 WalRcvData *walrcv = WalRcv; in toNetworkByteStream()
318 WalRcvData *walrcv = WalRcv; in containerToNetworkByteStream()
339 WalRcvData *walrcv = WalRcv;
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 WalRcv->latch = NULL; in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
233 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
318 WalRcvData *walrcv = WalRcv; in GetWalRcvFlushRecPtr()
339 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
[all …]
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
66 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 InitSharedLatch(&WalRcv->latch); in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
227 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
297 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
318 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
66 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 InitSharedLatch(&WalRcv->latch); in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
227 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
297 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
318 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 33 WalRcvData *WalRcv = NULL; variable
58 WalRcv = (WalRcvData *) in WalRcvShmemInit()
66 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
67 InitSharedLatch(&WalRcv->latch); in WalRcvShmemInit()
75 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
120 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
166 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
227 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
297 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
318 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-server/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/replication/ |
| H A D | walreceiverfuncs.c | 32 WalRcvData *WalRcv = NULL; variable
57 WalRcv = (WalRcvData *) in WalRcvShmemInit()
65 SpinLockInit(&WalRcv->mutex); in WalRcvShmemInit()
66 WalRcv->latch = NULL; in WalRcvShmemInit()
74 WalRcvData *walrcv = WalRcv; in WalRcvRunning()
119 WalRcvData *walrcv = WalRcv; in WalRcvStreaming()
165 WalRcvData *walrcv = WalRcv; in ShutdownWalRcv()
226 WalRcvData *walrcv = WalRcv; in RequestXLogStreaming()
299 WalRcvData *walrcv = WalRcv; in GetWalRcvWriteRecPtr()
320 WalRcvData *walrcv = WalRcv; in GetReplicationApplyDelay()
[all …]
|