@@ -225,7 +225,7 @@ static void maybe_reread_subscription(void);
225225static void apply_dispatch (StringInfo s );
226226
227227static void apply_handle_commit_internal (StringInfo s ,
228- LogicalRepCommitData * commit_data );
228+ LogicalRepCommitData * commit_data );
229229static void apply_handle_insert_internal (ResultRelInfo * relinfo ,
230230EState * estate ,TupleTableSlot * remoteslot );
231231static void apply_handle_update_internal (ResultRelInfo * relinfo ,
@@ -752,10 +752,10 @@ apply_handle_stream_start(StringInfo s)
752752
753753/*
754754 * Start a transaction on stream start, this transaction will be committed
755- * on the stream stop unless it is a tablesync worker in which case it will
756- * be committed after processing all the messages. We need the transaction
757- * for handling the buffile, used for serializing the streaming data and
758- * subxact info.
755+ * on the stream stop unless it is a tablesync worker in which case it
756+ *will be committed after processing all the messages. We need the
757+ *transaction for handling the buffile, used for serializing the
758+ *streaming data and subxact info.
759759 */
760760ensure_transaction ();
761761
@@ -1060,7 +1060,7 @@ apply_handle_stream_commit(StringInfo s)
10601060 * Helper function for apply_handle_commit and apply_handle_stream_commit.
10611061 */
10621062static void
1063- apply_handle_commit_internal (StringInfo s ,LogicalRepCommitData * commit_data )
1063+ apply_handle_commit_internal (StringInfo s ,LogicalRepCommitData * commit_data )
10641064{
10651065/* The synchronization worker runs in single transaction. */
10661066if (IsTransactionState ()&& !am_tablesync_worker ())
