| /dports/databases/postgresql11-client/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql11-plperl/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql11-plpython/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */
274 accessor->read_participant = accessor->participant; in start_worker_in_sub_thread()
535 p = &accessor->sts->participants[accessor->read_participant];
562 sts_filename(name, accessor, accessor->read_participant);
610 accessor->read_participant = (accessor->read_participant + 1) %
612 if (accessor->read_participant == accessor->participant)
|
| /dports/databases/postgresql11-docs/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql11-server/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql11-contrib/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql11-pltcl/postgresql-11.14/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql12-docs/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */
274 accessor->read_participant = accessor->participant;
535 p = &accessor->sts->participants[accessor->read_participant];
562 sts_filename(name, accessor, accessor->read_participant);
610 accessor->read_participant = (accessor->read_participant + 1) %
612 if (accessor->read_participant == accessor->participant)
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */ member
272 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
533 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
560 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
608 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
610 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 80 int read_participant; /* The current participant to read from. */
272 accessor->read_participant = accessor->participant;
533 p = &accessor->sts->participants[accessor->read_participant];
560 sts_filename(name, accessor, accessor->read_participant);
608 accessor->read_participant = (accessor->read_participant + 1) %
610 if (accessor->read_participant == accessor->participant)
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */
274 accessor->read_participant = accessor->participant;
535 p = &accessor->sts->participants[accessor->read_participant];
562 sts_filename(name, accessor, accessor->read_participant);
610 accessor->read_participant = (accessor->read_participant + 1) %
612 if (accessor->read_participant == accessor->participant)
|
| /dports/databases/postgresql12-plpython/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/backend/utils/sort/ |
| H A D | sharedtuplestore.c | 82 int read_participant; /* The current participant to read from. */ member
274 accessor->read_participant = accessor->participant; in sts_begin_parallel_scan()
535 p = &accessor->sts->participants[accessor->read_participant]; in sts_parallel_scan_next()
562 sts_filename(name, accessor, accessor->read_participant); in sts_parallel_scan_next()
610 accessor->read_participant = (accessor->read_participant + 1) % in sts_parallel_scan_next()
612 if (accessor->read_participant == accessor->participant) in sts_parallel_scan_next()
|