On Mon, Apr 20, 2020 at 02:30:08PM +0900, Fujii Masao wrote:
> + * Block if we have unsent data. XXX For logical replication, let
> + * WalSndWaitForWal(), handle any other blocking; idle receivers need
> + * its additional actions. For physical replication, also block if
> + * caught up; its send_data does not block.
>
> It might be better to s/WalSndWaitForWal()/send_data()? Because not only
> WalSndWaitForWal() but also WalSndWriteData() seems to handle the blocking.
> WalSndWriteData() is called also under send_data, i.e., XLogSendLogical().
Thanks for reviewing. WalSndWriteData() blocks when we have unsent data,
which is the same cause for blocking in WalSndLoop(). Since the comment you
quote says we let WalSndWaitForWal() "handle any other blocking", I don't
think your proposed change makes it more correct. Also, if someone wants to
refactor this, the place to look is WalSndWaitForWal(), not any other part of
send_data().