#include "bdr.h"
-/* These are always necessary for a bgworker */
+#include "libpq-fe.h"
#include "miscadmin.h"
-#include "postmaster/bgworker.h"
-#include "storage/ipc.h"
-#include "storage/latch.h"
-#include "storage/lwlock.h"
-#include "storage/proc.h"
-#include "storage/shmem.h"
-
-/* these headers are used by this particular worker's code */
#include "pgstat.h"
-
#include "port.h"
+
#include "access/committs.h"
#include "access/heapam.h"
#include "access/xact.h"
+
+#include "catalog/catversion.h"
#include "catalog/namespace.h"
#include "catalog/pg_extension.h"
-#include "catalog/pg_index.h"
-#include "catalog/catversion.h"
+
#include "commands/extension.h"
+
#include "lib/stringinfo.h"
+
#include "libpq/pqformat.h"
+
#include "mb/pg_wchar.h"
-#include "postmaster/bgwriter.h"
+
+#include "postmaster/bgworker.h"
+
#include "replication/replication_identifier.h"
+
+#include "storage/ipc.h"
+#include "storage/latch.h"
+#include "storage/lwlock.h"
+#include "storage/proc.h"
+#include "storage/shmem.h"
+
#include "utils/builtins.h"
#include "utils/guc.h"
#include "utils/lsyscache.h"
#include "utils/syscache.h"
#include "utils/timestamp.h"
-/* sequencer */
-#include "commands/extension.h"
-
-/* apply */
-#include "libpq-fe.h"
-
-
#define MAXCONNINFO 1024
static bool exit_worker = false;
#include "bdr.h"
-/* These are always necessary for a bgworker */
+#include "funcapi.h"
+#include "libpq-fe.h"
#include "miscadmin.h"
-#include "postmaster/bgworker.h"
-#include "storage/ipc.h"
-#include "storage/latch.h"
-#include "storage/lwlock.h"
-#include "storage/proc.h"
-#include "storage/shmem.h"
-
#include "pgstat.h"
#include "access/committs.h"
#include "access/heapam.h"
#include "access/htup_details.h"
#include "access/relscan.h"
-#include "access/sysattr.h"
#include "access/xact.h"
#include "catalog/dependency.h"
#include "catalog/namespace.h"
#include "catalog/pg_type.h"
-#include "executor/spi.h"
#include "executor/executor.h"
-#include "funcapi.h"
-
#include "libpq/pqformat.h"
-#include "libpq-fe.h"
-
-#include "miscadmin.h"
#include "parser/parse_relation.h"
#include "parser/parse_type.h"
#include "storage/bufmgr.h"
#include "storage/lmgr.h"
+#include "storage/lwlock.h"
#include "tcop/pquery.h"
#include "tcop/tcopprot.h"
*/
#include "postgres.h"
-#include "access/heapam.h"
#include "bdr.h"
+
+#include "fmgr.h"
+
+#include "access/heapam.h"
+
#include "catalog/namespace.h"
+
#include "commands/dbcommands.h"
-#include "fmgr.h"
-#include "miscadmin.h"
+
#include "tcop/utility.h"
+
#include "utils/guc.h"
#include "utils/rel.h"
#include "storage/fd.h"
#include "storage/ipc.h"
-#include "storage/spin.h"
#include "storage/lwlock.h"
+#include "storage/spin.h"
#include "utils/builtins.h"
#include "utils/syscache.h"
*/
#include "postgres.h"
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/wait.h>
+#include <sys/errno.h>
+#include <sys/stat.h>
+
#include "bdr.h"
-/* These are always necessary for a bgworker */
+#include "libpq-fe.h"
#include "miscadmin.h"
-#include "postmaster/bgworker.h"
-#include "storage/ipc.h"
-#include "storage/latch.h"
-#include "storage/lwlock.h"
-#include "storage/proc.h"
-#include "storage/shmem.h"
#include "libpq/pqformat.h"
-#include "libpq-fe.h"
#include "access/heapam.h"
#include "access/xact.h"
-#include "replication/walreceiver.h"
#include "replication/replication_identifier.h"
+#include "replication/walreceiver.h"
+#include "postmaster/bgworker.h"
#include "postmaster/bgwriter.h"
+#include "storage/ipc.h"
+#include "storage/latch.h"
+#include "storage/lwlock.h"
+#include "storage/proc.h"
+#include "storage/shmem.h"
+
#include "utils/builtins.h"
#include "utils/syscache.h"
-/* bdr_init_replica */
-#include <unistd.h>
-#include <sys/types.h>
-#include <sys/wait.h>
-#include <sys/errno.h>
-#include <sys/stat.h>
-#include "postmaster/postmaster.h"
-
char *bdr_temp_dump_directory = NULL;
static void bdr_exec_init_replica(Name conn_name, char *snapshot);
*/
#include "postgres.h"
+#include "bdr.h"
+
#include "access/sysattr.h"
#include "access/tuptoaster.h"
-#include "bdr.h"
-
+#include "catalog/index.h"
#include "catalog/pg_class.h"
#include "catalog/pg_namespace.h"
#include "catalog/pg_type.h"
-#include "catalog/index.h"
#include "libpq/pqformat.h"
#include "nodes/parsenodes.h"
-#include "replication/output_plugin.h"
#include "replication/logical.h"
+#include "replication/output_plugin.h"
#include "utils/builtins.h"
#include "utils/lsyscache.h"
#include "utils/memutils.h"
#include "utils/rel.h"
-#include "utils/relcache.h"
#include "utils/syscache.h"
#include "utils/timestamp.h"
#include "utils/typcache.h"
#include "bdr.h"
-/* sequencer */
#include "miscadmin.h"
#include "pgstat.h"
#include "access/reloptions.h"
-#include "access/transam.h"
#include "access/seqam.h"
+#include "access/transam.h"
#include "access/xact.h"
-#include "catalog/pg_type.h"
+
#include "catalog/namespace.h"
+#include "catalog/pg_type.h"
+
#include "commands/sequence.h"
+
#include "executor/spi.h"
+
#include "utils/builtins.h"
-#include "utils/snapmgr.h"
#include "utils/lsyscache.h"
+#include "utils/snapmgr.h"
+
#include "storage/bufmgr.h"
#include "storage/ipc.h"
#include "storage/latch.h"