8000
We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 660fbec commit a959c67Copy full SHA for a959c67
src/backend/commands/async.c
@@ -2090,7 +2090,10 @@ ProcessIncomingNotify(void)
2090
{
2091
bool catchup_enabled;
2092
2093
- /* Do nothing if we aren't actively listening */
+ /* We *must* reset the flag */
2094
+ notifyInterruptOccurred = 0;
2095
+
2096
+ /* Do nothing else if we aren't actively listening */
2097
if (listenChannels == NIL)
2098
return;
2099
@@ -2102,8 +2105,6 @@ ProcessIncomingNotify(void)
2102
2105
2103
2106
set_ps_display("notify interrupt", false);
2104
2107
- notifyInterruptOccurred = 0;
-
2108
/*
2109
* We must run asyncQueueReadAllNotifications inside a transaction, else
2110
* bad things happen if it gets an error.
0 commit comments