Dear Shi, Thank you for reviewing! PSA new version.
> + elog(DEBUG2, "time-delayed replication for txid %u, delay_time > = %d ms, remaining wait time: %ld ms", > + ctx->write_xid, (int) ctx->min_send_delay, > + remaining_wait_time_ms); > > I tried and saw that the xid here looks wrong, what it got is the xid of the > previous transaction. It seems `ctx->write_xid` has not been updated and we > can't use it. > Good catch. There are several approaches to fix that, I choose the simplest way. TransactionId was added as an argument of functions. Best Regards, Hayato Kuroda FUJITSU LIMITED
v7-0001-Time-delayed-logical-replication-on-publisher-sid.patch
Description: v7-0001-Time-delayed-logical-replication-on-publisher-sid.patch
