We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
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