Skip to content

Commit

Permalink
pgindent worker.c.
Browse files Browse the repository at this point in the history
This is a leftover from commit 0926e96. Changing this separately
because this file is being modified for upcoming patch logical replication
of 2PC.

Author: Peter Smith
Discussion: https://postgr.es/m/CAHut+Ps+EgG8KzcmAyAgBUi_vuTps6o9ZA8DG6SdnO0-YuOhPQ@mail.gmail.com
  • Loading branch information
Amit Kapila committed Jan 19, 2021
1 parent 9e7dbe3 commit ed43677
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions src/backend/replication/logical/worker.c
Original file line number Diff line number Diff line change
Expand Up @@ -225,7 +225,7 @@ static void maybe_reread_subscription(void);
static void apply_dispatch(StringInfo s);

static void apply_handle_commit_internal(StringInfo s,
LogicalRepCommitData* commit_data);
LogicalRepCommitData *commit_data);
static void apply_handle_insert_internal(ResultRelInfo *relinfo,
EState *estate, TupleTableSlot *remoteslot);
static void apply_handle_update_internal(ResultRelInfo *relinfo,
Expand Down Expand Up @@ -752,10 +752,10 @@ apply_handle_stream_start(StringInfo s)

/*
* Start a transaction on stream start, this transaction will be committed
* on the stream stop unless it is a tablesync worker in which case it will
* be committed after processing all the messages. We need the transaction
* for handling the buffile, used for serializing the streaming data and
* subxact info.
* on the stream stop unless it is a tablesync worker in which case it
* will be committed after processing all the messages. We need the
* transaction for handling the buffile, used for serializing the
* streaming data and subxact info.
*/
ensure_transaction();

Expand Down Expand Up @@ -1060,7 +1060,7 @@ apply_handle_stream_commit(StringInfo s)
* Helper function for apply_handle_commit and apply_handle_stream_commit.
*/
static void
apply_handle_commit_internal(StringInfo s, LogicalRepCommitData* commit_data)
apply_handle_commit_internal(StringInfo s, LogicalRepCommitData *commit_data)
{
/* The synchronization worker runs in single transaction. */
if (IsTransactionState() && !am_tablesync_worker())
Expand Down

0 comments on commit ed43677

Please sign in to comment.