Commit3f1787c

committed

Minor but necessary improvements to WAL keepalives

Fujii Masao

1 parent21b446d commit3f1787cCopy full SHA for 3f1787c

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -750,7 +750,8 @@ ProcessWalSndrMessage(XLogRecPtr walEnd, TimestampTz sendTime)`
`750`	`750`	`walrcv->lastMsgReceiptTime=lastMsgReceiptTime;`
`751`	`751`	`SpinLockRelease(&walrcv->mutex);`
`752`	`752`
`753`		`-elog(DEBUG2,"sendtime %s receipttime %s replication apply delay %d transfer latency %d",`
	`753`	`+if (log_min_mesages <=DEBUG2)`
	`754`	`+elog(DEBUG2,"sendtime %s receipttime %s replication apply delay %d ms transfer latency %d ms",`
`754`	`755`	`timestamptz_to_str(sendTime),`
`755`	`756`	`timestamptz_to_str(lastMsgReceiptTime),`
`756`	`757`	`GetReplicationApplyDelay(),`

Lines changed: 5 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -834,7 +834,12 @@ WalSndLoop(void)`
`834`	`834`	`if (pq_is_send_pending())`
`835`	`835`	`wakeEvents \|=WL_SOCKET_WRITEABLE;`
`836`	`836`	`else`
	`837`	`+{`
`837`	`838`	`WalSndKeepalive(output_message);`
	`839`	`+/* Try to flush pending output to the client */`
	`840`	`+if (pq_flush_if_writable()!=0)`
	`841`	`+break;`
	`842`	`+}`
`838`	`843`
`839`	`844`	`/* Determine time until replication timeout */`
`840`	`845`	`if (replication_timeout>0)`

Comments

(0)