On Wed, Apr 7, 2022 at 1:34 PM Amit Kapila <amit.kapil...@gmail.com> wrote: > Thanks for your comments.
> One comment:
> +static void
> +update_progress(LogicalDecodingContext *ctx, bool skipped_xact, bool
> end_xact)
> +{
> + static int changes_count = 0;
> +
> + if (end_xact)
> + {
> + /* Update progress tracking at xact end. */
> + OutputPluginUpdateProgress(ctx, skipped_xact);
> + changes_count = 0;
> + }
> + /*
> + * After continuously processing CHANGES_THRESHOLD changes, update
> progress
> + * which will also try to send a keepalive message if required.
>
> I think you can simply return after making changes_count = 0. There
> should be an empty line before starting the next comment.
Improve as suggested.
BTW, there is a conflict in current HEAD when applying v12 because of the
commit 2c7ea57. Also rebase it.
Attach the new patch.
1. Make some improvements to the new function update_progress. [suggestion by
Amit-San]
2. Rebase the patch because the commit 2c7ea57 in current HEAD.
Regards,
Wang wei
v13-0001-Fix-the-logical-replication-timeout-during-large.patch
Description: v13-0001-Fix-the-logical-replication-timeout-during-large.patch
