MCPcopy Create free account
hub / github.com/apache/cloudberry / ProcessNotifyInterrupt

Function ProcessNotifyInterrupt

src/backend/commands/async.c:1898–1907  ·  view source on GitHub ↗

* ProcessNotifyInterrupt * * This is called if we see notifyInterruptPending set, just before * transmitting ReadyForQuery at the end of a frontend command, and * also if a notify signal occurs while reading from the frontend. * HandleNotifyInterrupt() will cause the read to be interrupted * via the process's latch, and this routine will get called. * If we are truly idle (ie, *not* i

Source from the content-addressed store, hash-verified

1896 * since we'll flush after sending ReadyForQuery.
1897 */
1898void
1899ProcessNotifyInterrupt(bool flush)
1900{
1901 if (IsTransactionOrTransactionBlock())
1902 return; /* not really idle */
1903
1904 /* Loop in case another signal arrives while sending messages */
1905 while (notifyInterruptPending)
1906 ProcessIncomingNotify(flush);
1907}
1908
1909
1910/*

Callers 2

PostgresMainFunction · 0.85

Calls 2

ProcessIncomingNotifyFunction · 0.85

Tested by

no test coverage detected