| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn)
267 if (sublsn != InvalidXLogRecPtr)
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
288 XLogRecPtr sublsn)
317 if (sublsn != InvalidXLogRecPtr)
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn,
359 *sublsn = InvalidXLogRecPtr;
375 *sublsn = InvalidXLogRecPtr;
377 *sublsn = DatumGetLSN(d);
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
267 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
288 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
317 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn)
261 if (sublsn != InvalidXLogRecPtr)
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
282 XLogRecPtr sublsn)
311 if (sublsn != InvalidXLogRecPtr)
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn,
353 *sublsn = InvalidXLogRecPtr;
369 *sublsn = InvalidXLogRecPtr;
371 *sublsn = DatumGetLSN(d);
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
261 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
282 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
311 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
353 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
369 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
371 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
267 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
288 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
317 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
261 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
282 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
311 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
353 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
369 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
371 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn)
267 if (sublsn != InvalidXLogRecPtr)
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
288 XLogRecPtr sublsn)
317 if (sublsn != InvalidXLogRecPtr)
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn,
359 *sublsn = InvalidXLogRecPtr;
375 *sublsn = InvalidXLogRecPtr;
377 *sublsn = DatumGetLSN(d);
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn)
261 if (sublsn != InvalidXLogRecPtr)
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
282 XLogRecPtr sublsn)
311 if (sublsn != InvalidXLogRecPtr)
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn);
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn,
353 *sublsn = InvalidXLogRecPtr;
369 *sublsn = InvalidXLogRecPtr;
371 *sublsn = DatumGetLSN(d);
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
261 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
282 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
311 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
353 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
369 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
371 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
267 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
288 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
317 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
267 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
288 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
317 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/catalog/ |
| H A D | pg_subscription.c | 242 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
267 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
268 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
288 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
317 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
318 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql13-plperl/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
261 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
282 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
311 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
353 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
369 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
371 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql13-plpython/postgresql-13.5/src/backend/catalog/ |
| H A D | pg_subscription.c | 236 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
261 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
262 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
282 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
311 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
312 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
332 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
353 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
369 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
371 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/catalog/ |
| H A D | pg_subscription.c | 234 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
260 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
261 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
283 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
313 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
314 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
338 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn, in GetSubscriptionRelState() argument
359 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
375 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
377 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/catalog/ |
| H A D | pg_subscription.c | 239 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
264 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
265 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
285 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
314 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
315 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
335 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn) in GetSubscriptionRelState() argument
357 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
368 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
370 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/catalog/ |
| H A D | pg_subscription.c | 239 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
264 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
265 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
285 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
314 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
315 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
335 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn) in GetSubscriptionRelState() argument
357 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
368 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
370 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/catalog/ |
| H A D | pg_subscription.c | 239 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
264 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
265 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
285 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
314 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
315 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
335 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn) in GetSubscriptionRelState() argument
357 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
368 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
370 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/catalog/ |
| H A D | pg_subscription.c | 239 XLogRecPtr sublsn) in AddSubscriptionRelState() argument
264 if (sublsn != InvalidXLogRecPtr) in AddSubscriptionRelState()
265 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in AddSubscriptionRelState()
285 XLogRecPtr sublsn) in UpdateSubscriptionRelState() argument
314 if (sublsn != InvalidXLogRecPtr) in UpdateSubscriptionRelState()
315 values[Anum_pg_subscription_rel_srsublsn - 1] = LSNGetDatum(sublsn); in UpdateSubscriptionRelState()
335 GetSubscriptionRelState(Oid subid, Oid relid, XLogRecPtr *sublsn) in GetSubscriptionRelState() argument
357 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
368 *sublsn = InvalidXLogRecPtr; in GetSubscriptionRelState()
370 *sublsn = DatumGetLSN(d); in GetSubscriptionRelState()
|