diff options
Diffstat (limited to 'src/backend/replication/logical/worker.c')
-rw-r--r-- | src/backend/replication/logical/worker.c | 27 |
1 files changed, 1 insertions, 26 deletions
diff --git a/src/backend/replication/logical/worker.c b/src/backend/replication/logical/worker.c index 9dd2446fbfd..b5a80fe3e84 100644 --- a/src/backend/replication/logical/worker.c +++ b/src/backend/replication/logical/worker.c @@ -147,65 +147,40 @@ #include <sys/stat.h> #include <unistd.h> -#include "access/genam.h" #include "access/table.h" #include "access/tableam.h" #include "access/twophase.h" #include "access/xact.h" -#include "access/xlog_internal.h" -#include "catalog/catalog.h" #include "catalog/indexing.h" -#include "catalog/namespace.h" -#include "catalog/partition.h" #include "catalog/pg_inherits.h" #include "catalog/pg_subscription.h" #include "catalog/pg_subscription_rel.h" -#include "catalog/pg_tablespace.h" #include "commands/tablecmds.h" -#include "commands/tablespace.h" #include "commands/trigger.h" #include "executor/executor.h" #include "executor/execPartition.h" -#include "executor/nodeModifyTable.h" -#include "funcapi.h" #include "libpq/pqformat.h" -#include "libpq/pqsignal.h" -#include "mb/pg_wchar.h" #include "miscadmin.h" -#include "nodes/makefuncs.h" #include "optimizer/optimizer.h" #include "parser/parse_relation.h" #include "pgstat.h" #include "postmaster/bgworker.h" #include "postmaster/interrupt.h" -#include "postmaster/postmaster.h" #include "postmaster/walwriter.h" -#include "replication/decode.h" -#include "replication/logical.h" #include "replication/logicallauncher.h" #include "replication/logicalproto.h" #include "replication/logicalrelation.h" #include "replication/logicalworker.h" #include "replication/origin.h" -#include "replication/reorderbuffer.h" -#include "replication/snapbuild.h" #include "replication/walreceiver.h" #include "replication/worker_internal.h" #include "rewrite/rewriteHandler.h" #include "storage/buffile.h" -#include "storage/bufmgr.h" -#include "storage/fd.h" #include "storage/ipc.h" #include "storage/lmgr.h" -#include "storage/proc.h" -#include "storage/procarray.h" #include "tcop/tcopprot.h" #include "utils/acl.h" -#include "utils/builtins.h" -#include "utils/catcache.h" #include "utils/dynahash.h" -#include "utils/datum.h" -#include "utils/fmgroids.h" #include "utils/guc.h" #include "utils/inval.h" #include "utils/lsyscache.h" @@ -213,8 +188,8 @@ #include "utils/pg_lsn.h" #include "utils/rel.h" #include "utils/rls.h" +#include "utils/snapmgr.h" #include "utils/syscache.h" -#include "utils/timeout.h" #include "utils/usercontext.h" #define NAPTIME_PER_CYCLE 1000 /* max sleep time between cycles (1s) */ |