| /dports/databases/postgresql10-plperl/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-pltcl/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-docs/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-contrib/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-client/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-plpython/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql10-server/postgresql-10.19/src/backend/replication/logical/ |
| H A D | worker.c | 327 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
330 values[remoteattnum] != NULL) in slot_store_cstrings()
335 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
408 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
410 if (remoteattnum < 0) in slot_modify_cstrings()
413 if (!replaces[remoteattnum]) in slot_modify_cstrings()
416 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
421 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
734 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
736 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
359 values[remoteattnum] != NULL) in slot_store_cstrings()
364 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
437 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
439 if (remoteattnum < 0) in slot_modify_cstrings()
442 if (!replaces[remoteattnum]) in slot_modify_cstrings()
445 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
450 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
757 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
759 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
359 values[remoteattnum] != NULL) in slot_store_cstrings()
364 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
437 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
439 if (remoteattnum < 0) in slot_modify_cstrings()
442 if (!replaces[remoteattnum]) in slot_modify_cstrings()
445 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
450 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
757 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
759 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
359 values[remoteattnum] != NULL) in slot_store_cstrings()
364 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
437 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
439 if (remoteattnum < 0) in slot_modify_cstrings()
442 if (!replaces[remoteattnum]) in slot_modify_cstrings()
445 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
450 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
757 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
759 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i];
359 values[remoteattnum] != NULL)
364 errarg.remote_attnum = remoteattnum;
437 int remoteattnum = rel->attrmap[i];
439 if (remoteattnum < 0)
442 if (!replaces[remoteattnum])
445 if (values[remoteattnum] != NULL)
450 errarg.remote_attnum = remoteattnum;
757 int remoteattnum = rel->attrmap[i];
759 if (!att->attisdropped && remoteattnum >= 0)
[all …]
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i];
359 values[remoteattnum] != NULL)
364 errarg.remote_attnum = remoteattnum; in avlauncher_forkexec()
437 int remoteattnum = rel->attrmap[i]; in StartAutoVacLauncher()
439 if (remoteattnum < 0) in StartAutoVacLauncher()
442 if (!replaces[remoteattnum]) in StartAutoVacLauncher()
445 if (values[remoteattnum] != NULL) in StartAutoVacLauncher()
450 errarg.remote_attnum = remoteattnum; in StartAutoVacLauncher()
757 int remoteattnum = rel->attrmap[i];
759 if (!att->attisdropped && remoteattnum >= 0)
[all …]
|
| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
359 values[remoteattnum] != NULL) in slot_store_cstrings()
364 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
437 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
439 if (remoteattnum < 0) in slot_modify_cstrings()
442 if (!replaces[remoteattnum]) in slot_modify_cstrings()
445 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
450 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
757 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
759 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/replication/logical/ |
| H A D | worker.c | 356 int remoteattnum = rel->attrmap[i];
359 values[remoteattnum] != NULL)
364 errarg.remote_attnum = remoteattnum;
437 int remoteattnum = rel->attrmap[i];
439 if (remoteattnum < 0)
442 if (!replaces[remoteattnum])
445 if (values[remoteattnum] != NULL)
450 errarg.remote_attnum = remoteattnum;
757 int remoteattnum = rel->attrmap[i];
759 if (!att->attisdropped && remoteattnum >= 0)
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i];
340 values[remoteattnum] != NULL)
345 errarg.remote_attnum = remoteattnum;
418 int remoteattnum = rel->attrmap[i];
420 if (remoteattnum < 0)
423 if (!replaces[remoteattnum])
426 if (values[remoteattnum] != NULL)
431 errarg.remote_attnum = remoteattnum;
739 int remoteattnum = rel->attrmap[i];
741 if (!att->attisdropped && remoteattnum >= 0)
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/replication/logical/ |
| H A D | worker.c | 337 int remoteattnum = rel->attrmap[i]; in slot_store_cstrings() local
340 values[remoteattnum] != NULL) in slot_store_cstrings()
345 errarg.remote_attnum = remoteattnum; in slot_store_cstrings()
418 int remoteattnum = rel->attrmap[i]; in slot_modify_cstrings() local
420 if (remoteattnum < 0) in slot_modify_cstrings()
423 if (!replaces[remoteattnum]) in slot_modify_cstrings()
426 if (values[remoteattnum] != NULL) in slot_modify_cstrings()
431 errarg.remote_attnum = remoteattnum; in slot_modify_cstrings()
739 int remoteattnum = rel->attrmap[i]; in apply_handle_update() local
741 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/replication/logical/ |
| H A D | worker.c | 552 int remoteattnum = rel->attrmap->attnums[i]; in slot_store_data() local
554 if (!att->attisdropped && remoteattnum >= 0) in slot_store_data()
558 Assert(remoteattnum < tupleData->ncols); in slot_store_data()
560 errarg.remote_attnum = remoteattnum; in slot_store_data()
594 remoteattnum + 1))); in slot_store_data()
677 if (remoteattnum < 0) in slot_modify_data()
680 Assert(remoteattnum < tupleData->ncols); in slot_modify_data()
686 errarg.remote_attnum = remoteattnum; in slot_modify_data()
720 remoteattnum + 1))); in slot_modify_data()
1408 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/replication/logical/ |
| H A D | worker.c | 552 int remoteattnum = rel->attrmap->attnums[i]; in slot_store_data() local
554 if (!att->attisdropped && remoteattnum >= 0) in slot_store_data()
558 Assert(remoteattnum < tupleData->ncols); in slot_store_data()
560 errarg.remote_attnum = remoteattnum; in slot_store_data()
594 remoteattnum + 1))); in slot_store_data()
677 if (remoteattnum < 0) in slot_modify_data()
680 Assert(remoteattnum < tupleData->ncols); in slot_modify_data()
686 errarg.remote_attnum = remoteattnum; in slot_modify_data()
720 remoteattnum + 1))); in slot_modify_data()
1408 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/replication/logical/ |
| H A D | worker.c | 552 int remoteattnum = rel->attrmap->attnums[i]; in slot_store_data() local
554 if (!att->attisdropped && remoteattnum >= 0) in slot_store_data()
558 Assert(remoteattnum < tupleData->ncols); in slot_store_data()
560 errarg.remote_attnum = remoteattnum; in slot_store_data()
594 remoteattnum + 1))); in slot_store_data()
677 if (remoteattnum < 0) in slot_modify_data()
680 Assert(remoteattnum < tupleData->ncols); in slot_modify_data()
686 errarg.remote_attnum = remoteattnum; in slot_modify_data()
720 remoteattnum + 1))); in slot_modify_data()
1408 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/replication/logical/ |
| H A D | worker.c | 552 int remoteattnum = rel->attrmap->attnums[i]; in slot_store_data() local
554 if (!att->attisdropped && remoteattnum >= 0) in slot_store_data()
558 Assert(remoteattnum < tupleData->ncols); in slot_store_data()
560 errarg.remote_attnum = remoteattnum; in slot_store_data()
594 remoteattnum + 1))); in slot_store_data()
677 if (remoteattnum < 0) in slot_modify_data()
680 Assert(remoteattnum < tupleData->ncols); in slot_modify_data()
686 errarg.remote_attnum = remoteattnum; in slot_modify_data()
720 remoteattnum + 1))); in slot_modify_data()
1408 if (!att->attisdropped && remoteattnum >= 0) in apply_handle_update()
[all …]
|