postgres
diff --git a/‎src/backend/replication/walreceiver.c
Copy file name to clipboardExpand all lines: src/backend/replication/walreceiver.c
+9-2Lines changed: 9 additions & 2 deletions b/‎src/backend/replication/walreceiver.c
Copy file name to clipboardExpand all lines: src/backend/replication/walreceiver.c
+9-2Lines changed: 9 additions & 2 deletions
diff --git a/‎src/backend/replication/walreceiverfuncs.c
Copy file name to clipboardExpand all lines: src/backend/replication/walreceiverfuncs.c
+1Lines changed: 1 addition & 0 deletions b/‎src/backend/replication/walreceiverfuncs.c
Copy file name to clipboardExpand all lines: src/backend/replication/walreceiverfuncs.c
+1Lines changed: 1 addition & 0 deletions
diff --git a/‎src/test/regress/expected/sysviews.out
Copy file name to clipboardExpand all lines: src/test/regress/expected/sysviews.out
+7Lines changed: 7 additions & 0 deletions b/‎src/test/regress/expected/sysviews.out
Copy file name to clipboardExpand all lines: src/test/regress/expected/sysviews.out
+7Lines changed: 7 additions & 0 deletions
diff --git a/‎src/test/regress/sql/sysviews.sql
Copy file name to clipboardExpand all lines: src/test/regress/sql/sysviews.sql
+3Lines changed: 3 additions & 0 deletions b/‎src/test/regress/sql/sysviews.sql
Copy file name to clipboardExpand all lines: src/test/regress/sql/sysviews.sql
+3Lines changed: 3 additions & 0 deletions
@@ -249,7 +249,7 @@ WalReceiverMain(void)
 
 	SpinLockRelease(&walrcv->mutex);
 
-	pg_atomic_init_u64(&WalRcv->writtenUpto, 0);
+	pg_atomic_write_u64(&WalRcv->writtenUpto, 0);
 
 	/* Arrange to clean up at walreceiver exit */
 	on_shmem_exit(WalRcvDie, 0);
@@ -1325,7 +1325,6 @@ pg_stat_get_wal_receiver(PG_FUNCTION_ARGS)
 	state = WalRcv->walRcvState;
 	receive_start_lsn = WalRcv->receiveStart;
 	receive_start_tli = WalRcv->receiveStartTLI;
-	written_lsn = pg_atomic_read_u64(&WalRcv->writtenUpto);
 	flushed_lsn = WalRcv->flushedUpto;
 	received_tli = WalRcv->receivedTLI;
 	last_send_time = WalRcv->lastMsgSendTime;
@@ -1345,6 +1344,14 @@ pg_stat_get_wal_receiver(PG_FUNCTION_ARGS)
 	if (pid == 0 || !ready_to_display)
 		PG_RETURN_NULL();
 
+	/*
+	 * Read "writtenUpto" without holding a spinlock.  Note that it may not be
+	 * consistent with the other shared variables of the WAL receiver
+	 * protected by a spinlock, but this should not be used for data integrity
+	 * checks.
+	 */
+	written_lsn = pg_atomic_read_u64(&WalRcv->writtenUpto);
+
 	/* determine result type */
 	if (get_call_result_type(fcinfo, NULL, &tupdesc) != TYPEFUNC_COMPOSITE)
 		elog(ERROR, "return type must be a row type");
 
@@ -63,6 +63,7 @@ WalRcvShmemInit(void)
 		MemSet(WalRcv, 0, WalRcvShmemSize());
 		WalRcv->walRcvState = WALRCV_STOPPED;
 		SpinLockInit(&WalRcv->mutex);
+		pg_atomic_init_u64(&WalRcv->writtenUpto, 0);
 		WalRcv->latch = NULL;
 	}
 }
 
@@ -83,6 +83,13 @@ select count(*) = 1 as ok from pg_stat_wal;
  t
 (1 row)
 
+-- We expect no walreceiver running in this test
+select count(*) = 0 as ok from pg_stat_wal_receiver;
+ ok 
+----
+ t
+(1 row)
+
 -- This is to record the prevailing planner enable_foo settings during
 -- a regression test run.
 select name, setting from pg_settings where name like 'enable%';
 
@@ -40,6 +40,9 @@ select count(*) >= 0 as ok from pg_prepared_xacts;
 -- There must be only one record
 select count(*) = 1 as ok from pg_stat_wal;
 
+-- We expect no walreceiver running in this test
+select count(*) = 0 as ok from pg_stat_wal_receiver;
+
 -- This is to record the prevailing planner enable_foo settings during
 -- a regression test run.
 select name, setting from pg_settings where name like 'enable%';
Original file line number	Diff line number	Diff line change
`@@ -63,6 +63,7 @@ WalRcvShmemInit(void)`
`63`	`63`	`MemSet(WalRcv, 0, WalRcvShmemSize());`
`64`	`64`	`WalRcv->walRcvState = WALRCV_STOPPED;`
`65`	`65`	`SpinLockInit(&WalRcv->mutex);`
	`66`	`+ pg_atomic_init_u64(&WalRcv->writtenUpto, 0);`
`66`	`67`	`WalRcv->latch = NULL;`
`67`	`68`	`}`
`68`	`69`	`}`