| /dports/databases/pglogical/pglogical-REL2_4_0/pglogical_dump/ |
| H A D | parallel.c | 163 return &(pstate->parallelSlot[i]); in GetMyPSlot()
393 if (pstate->parallelSlot[j].pid == pid) in WaitForTerminatingWorkers()
394 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
413 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
498 pstate->parallelSlot = NULL; in ParallelBackupStart()
540 pstate->parallelSlot[i].args->AH = NULL; in ParallelBackupStart()
619 pstate->parallelSlot[i].pid = pid; in ParallelBackupStart()
660 free(pstate->parallelSlot); in ParallelBackupEnd()
973 pstate->parallelSlot[worker].status = in ListenToWorkers()
980 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-server/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-pltcl/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-plpython/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-docs/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-client/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-contrib/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql96-plperl/postgresql-9.6.24/src/bin/pg_dump/ |
| H A D | parallel.c | 242 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
244 return &(pstate->parallelSlot[i]); in GetMyPSlot()
384 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
430 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
460 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
876 pstate->parallelSlot = NULL; in ParallelBackupStart()
1062 free(pstate->parallelSlot); in ParallelBackupEnd()
1091 pstate->parallelSlot[worker].args->te = te; in DispatchJobForTocEntry()
1306 pstate->parallelSlot[worker].status = in ListenToWorkers()
1313 pstate->parallelSlot[worker].status = in ListenToWorkers()
[all …]
|
| /dports/databases/postgresql12-client/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 279 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
281 return &(pstate->parallelSlot[i]); in GetMyPSlot()
412 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
421 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
467 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
497 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
914 pstate->parallelSlot = NULL; in ParallelBackupStart()
922 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1095 free(pstate->parallelSlot); in ParallelBackupEnd()
1599 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-pltcl/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-docs/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-server/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-plpython/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-plperl/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql13-pltcl/postgresql-13.5/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-contrib/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql14-client/postgresql-14.1/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql13-server/postgresql-13.5/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql12-server/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 279 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
281 return &(pstate->parallelSlot[i]); in GetMyPSlot()
412 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
421 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
467 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
497 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
914 pstate->parallelSlot = NULL; in ParallelBackupStart()
922 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1095 free(pstate->parallelSlot); in ParallelBackupEnd()
1599 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql12-pltcl/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 279 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
281 return &(pstate->parallelSlot[i]); in GetMyPSlot()
412 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
421 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
467 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
497 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
914 pstate->parallelSlot = NULL; in ParallelBackupStart()
922 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1095 free(pstate->parallelSlot); in ParallelBackupEnd()
1599 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql13-client/postgresql-13.5/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql13-docs/postgresql-13.5/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
280 return &(pstate->parallelSlot[i]); in GetMyPSlot()
411 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
420 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
466 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
496 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
913 pstate->parallelSlot = NULL; in ParallelBackupStart()
921 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1094 free(pstate->parallelSlot); in ParallelBackupEnd()
1598 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql13-contrib/postgresql-13.5/src/bin/pg_dump/ |
| H A D | parallel.c | 278 if (pstate->parallelSlot[i].pid == getpid())
280 return &(pstate->parallelSlot[i]);
411 closesocket(pstate->parallelSlot[i].pipeWrite);
420 pid_t pid = pstate->parallelSlot[i].pid;
466 slot = &(pstate->parallelSlot[j]);
496 slot = &(pstate->parallelSlot[j]);
913 pstate->parallelSlot = NULL;
921 pstate->parallelSlot = (ParallelSlot *)
1094 free(pstate->parallelSlot);
1598 if (pstate->parallelSlot[i].pipeRead > maxFd)
[all …]
|
| /dports/databases/postgresql12-plperl/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 279 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
281 return &(pstate->parallelSlot[i]); in GetMyPSlot()
412 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
421 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
467 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
497 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
914 pstate->parallelSlot = NULL; in ParallelBackupStart()
922 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1095 free(pstate->parallelSlot); in ParallelBackupEnd()
1599 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|
| /dports/databases/postgresql12-contrib/postgresql-12.9/src/bin/pg_dump/ |
| H A D | parallel.c | 279 if (pstate->parallelSlot[i].pid == getpid()) in GetMyPSlot()
281 return &(pstate->parallelSlot[i]); in GetMyPSlot()
412 closesocket(pstate->parallelSlot[i].pipeWrite); in ShutdownWorkersHard()
421 pid_t pid = pstate->parallelSlot[i].pid; in ShutdownWorkersHard()
467 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
497 slot = &(pstate->parallelSlot[j]); in WaitForTerminatingWorkers()
914 pstate->parallelSlot = NULL; in ParallelBackupStart()
922 pstate->parallelSlot = (ParallelSlot *) in ParallelBackupStart()
1095 free(pstate->parallelSlot); in ParallelBackupEnd()
1599 if (pstate->parallelSlot[i].pipeRead > maxFd) in getMessageFromWorker()
[all …]
|