| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn)
297 MyLogicalRepWorker->relstate_lsn = current_lsn;
304 MyLogicalRepWorker->relstate_lsn);
452 rstate->lsn = syncworker->relstate_lsn;
460 syncworker->relstate_lsn =
461 Max(syncworker->relstate_lsn, current_lsn);
822 XLogRecPtr relstate_lsn;
828 &relstate_lsn, true);
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn;
879 MyLogicalRepWorker->relstate_lsn);
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn)
297 MyLogicalRepWorker->relstate_lsn = current_lsn;
304 MyLogicalRepWorker->relstate_lsn);
452 rstate->lsn = syncworker->relstate_lsn;
460 syncworker->relstate_lsn =
461 Max(syncworker->relstate_lsn, current_lsn);
822 XLogRecPtr relstate_lsn;
828 &relstate_lsn, true);
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn;
879 MyLogicalRepWorker->relstate_lsn);
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn)
297 MyLogicalRepWorker->relstate_lsn = current_lsn;
304 MyLogicalRepWorker->relstate_lsn);
452 rstate->lsn = syncworker->relstate_lsn;
460 syncworker->relstate_lsn =
461 Max(syncworker->relstate_lsn, current_lsn);
822 XLogRecPtr relstate_lsn;
828 &relstate_lsn, true);
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn;
879 MyLogicalRepWorker->relstate_lsn);
[all …]
|
| /dports/databases/postgresql10-server/postgresql-10.19/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn, in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn, in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/replication/logical/ |
| H A D | tablesync.c | 292 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
297 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
304 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
452 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
460 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
461 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
822 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
828 &relstate_lsn, true); in LogicalRepSyncTableStart()
833 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
879 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/replication/logical/ |
| H A D | tablesync.c | 277 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
282 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
437 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
445 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
446 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
824 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
830 &relstate_lsn, true); in LogicalRepSyncTableStart()
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
881 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/replication/logical/ |
| H A D | tablesync.c | 277 current_lsn >= MyLogicalRepWorker->relstate_lsn)
282 MyLogicalRepWorker->relstate_lsn = current_lsn;
289 MyLogicalRepWorker->relstate_lsn);
437 rstate->lsn = syncworker->relstate_lsn;
445 syncworker->relstate_lsn =
446 Max(syncworker->relstate_lsn, current_lsn);
824 XLogRecPtr relstate_lsn;
830 &relstate_lsn, true);
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn;
881 MyLogicalRepWorker->relstate_lsn);
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/replication/logical/ |
| H A D | tablesync.c | 277 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
282 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
437 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
445 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
446 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
824 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
830 &relstate_lsn, true); in LogicalRepSyncTableStart()
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
881 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/replication/logical/ |
| H A D | tablesync.c | 277 current_lsn >= MyLogicalRepWorker->relstate_lsn)
282 MyLogicalRepWorker->relstate_lsn = current_lsn;
289 MyLogicalRepWorker->relstate_lsn);
437 rstate->lsn = syncworker->relstate_lsn;
445 syncworker->relstate_lsn =
446 Max(syncworker->relstate_lsn, current_lsn);
824 XLogRecPtr relstate_lsn;
830 &relstate_lsn, true);
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn;
881 MyLogicalRepWorker->relstate_lsn);
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/replication/logical/ |
| H A D | tablesync.c | 277 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
282 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
437 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
445 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
446 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
824 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
830 &relstate_lsn, true); in LogicalRepSyncTableStart()
835 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
881 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/replication/logical/ |
| H A D | tablesync.c | 284 current_lsn >= MyLogicalRepWorker->relstate_lsn) in process_syncing_tables_for_sync()
289 MyLogicalRepWorker->relstate_lsn = current_lsn; in process_syncing_tables_for_sync()
296 MyLogicalRepWorker->relstate_lsn); in process_syncing_tables_for_sync()
444 rstate->lsn = syncworker->relstate_lsn; in process_syncing_tables_for_apply()
452 syncworker->relstate_lsn = in process_syncing_tables_for_apply()
453 Max(syncworker->relstate_lsn, current_lsn); in process_syncing_tables_for_apply()
813 XLogRecPtr relstate_lsn; in LogicalRepSyncTableStart() local
819 &relstate_lsn, true); in LogicalRepSyncTableStart()
824 MyLogicalRepWorker->relstate_lsn = relstate_lsn; in LogicalRepSyncTableStart()
870 MyLogicalRepWorker->relstate_lsn); in LogicalRepSyncTableStart()
[all …]
|