postgresql/src/include/replication
Michael Paquier 9210afd3bc Move tracking of in_streaming to PGOutputData
"in_streaming" is a flag used to track if an instance of pgoutput is
streaming changes.  When pgoutput is started, the flag was always reset,
switched it back and forth in the stream start/stop callbacks.

Before this commit, it was a global variable, which is confusing as it
is actually attached to a state of PGOutputData.  Per my analysis, using
a global variable did not lead to an active bug like in 54ccfd6586,
but it makes the code more consistent.  Note that we cannot backpatch
this change anyway as it requires the addition of a new field to
PGOutputData, exposed in pgoutput.h.

Author: Hou Zhijie
Reviewed-by: Amit Kapila, Michael Paquier, Peter Smith
Discussion: https://postgr.es/m/OS0PR01MB571690EF24F51F51EFFCBB0E94FAA@OS0PR01MB5716.jpnprd01.prod.outlook.com
2023-09-28 09:33:51 +09:00
..
decode.h Update copyright for 2023 2023-01-02 15:00:37 -05:00
logical.h Update copyright for 2023 2023-01-02 15:00:37 -05:00
logicallauncher.h Track logrep apply workers' last start times to avoid useless waits. 2023-01-22 14:08:46 -05:00
logicalproto.h Fix the display of UNKNOWN message type in apply worker. 2023-07-25 09:12:29 +05:30
logicalrelation.h Remove unnecessary checks for indexes for REPLICA IDENTITY FULL tables. 2023-07-25 15:09:34 +09:00
logicalworker.h Refactor to split Apply and Tablesync Workers code. 2023-08-03 08:59:50 +05:30
message.h Update copyright for 2023 2023-01-02 15:00:37 -05:00
origin.h Perform apply of large transactions by parallel workers. 2023-01-09 07:52:45 +05:30
output_plugin.h Fix some typos and some incorrectly duplicated words 2023-04-18 14:03:49 +12:00
pgoutput.h Move tracking of in_streaming to PGOutputData 2023-09-28 09:33:51 +09:00
reorderbuffer.h Rename logical_replication_mode to debug_logical_replication_streaming 2023-08-29 15:19:56 +02:00
slot.h Flush logical slots to disk during a shutdown checkpoint if required. 2023-09-14 08:57:05 +05:30
snapbuild.h Update copyright for 2023 2023-01-02 15:00:37 -05:00
syncrep.h Update copyright for 2023 2023-01-02 15:00:37 -05:00
walreceiver.h Add new predefined role pg_create_subscription. 2023-03-30 11:37:19 -04:00
walsender.h For cascading replication, wake physical and logical walsenders separately 2023-04-08 01:06:00 -07:00
walsender_private.h Optimize walsender wake up logic using condition variables 2023-05-21 09:44:55 -07:00
worker_internal.h Reset the logical worker type while cleaning up other worker info. 2023-08-25 08:57:55 +05:30