Count WAL flushes in walreceiver (#139)

neondatabase · Nov 21, 2022 · 4a9cee9 · 4a9cee9
1 parent d3ccbc1
commit 4a9cee9
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/src/backend/replication/walreceiver.c b/src/backend/replication/walreceiver.c
@@ -494,6 +494,13 @@ WalReceiverMain(void)
 				if (endofwal)
 					break;
 
+				/*
+				 * Update WAL statistics, which are produced inside
+				 * issue_xlog_fsync function. This is useful for counting
+				 * WAL flushes, by querying pg_stat_wal.
+				 */
+				pgstat_send_wal(true);
+
 				/*
 				 * Ideally we would reuse a WaitEventSet object repeatedly
 				 * here to avoid the overheads of WaitLatchOrSocket on epoll