diff options
Diffstat (limited to 'src/backend/tcop/postgres.c')
| -rw-r--r-- | src/backend/tcop/postgres.c | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/src/backend/tcop/postgres.c b/src/backend/tcop/postgres.c index 58b5960e27d..3f9ed549f92 100644 --- a/src/backend/tcop/postgres.c +++ b/src/backend/tcop/postgres.c @@ -504,7 +504,7 @@ ProcessClientReadInterrupt(bool blocked) /* Process notify interrupts, if any */ if (notifyInterruptPending) - ProcessNotifyInterrupt(); + ProcessNotifyInterrupt(true); } else if (ProcDiePending) { @@ -4373,17 +4373,15 @@ PostgresMain(int argc, char *argv[], } else { - /* Send out notify signals and transmit self-notifies */ - ProcessCompletedNotifies(); - /* - * Also process incoming notifies, if any. This is mostly to - * ensure stable behavior in tests: if any notifies were - * received during the just-finished transaction, they'll be - * seen by the client before ReadyForQuery is. + * Process incoming notifies (including self-notifies), if + * any, and send relevant messages to the client. Doing it + * here helps ensure stable behavior in tests: if any notifies + * were received during the just-finished transaction, they'll + * be seen by the client before ReadyForQuery is. */ if (notifyInterruptPending) - ProcessNotifyInterrupt(); + ProcessNotifyInterrupt(false); pgstat_report_stat(false); |