postgres
diff --git a/Collapse file
‎src/backend/replication/walsender.c‎
Copy file name to clipboardExpand all lines: src/backend/replication/walsender.c
+4-6Lines changed: 4 additions & 6 deletions b/Collapse file
‎src/backend/replication/walsender.c‎
Copy file name to clipboardExpand all lines: src/backend/replication/walsender.c
+4-6Lines changed: 4 additions & 6 deletions
@@ -3685,17 +3685,15 @@ UpdateSpillStats(LogicalDecodingContext *ctx)
 {
 	ReorderBuffer *rb = ctx->reorder;
 
-	SpinLockAcquire(&MyWalSnd->mutex);
-
-	MyWalSnd->spillTxns = rb->spillTxns;
-	MyWalSnd->spillCount = rb->spillCount;
-	MyWalSnd->spillBytes = rb->spillBytes;
-
 	elog(DEBUG2, "UpdateSpillStats: updating stats %p %lld %lld %lld",
 		 rb,
 		 (long long) rb->spillTxns,
 		 (long long) rb->spillCount,
 		 (long long) rb->spillBytes);
 
+	SpinLockAcquire(&MyWalSnd->mutex);
+	MyWalSnd->spillTxns = rb->spillTxns;
+	MyWalSnd->spillCount = rb->spillCount;
+	MyWalSnd->spillBytes = rb->spillBytes;
 	SpinLockRelease(&MyWalSnd->mutex);
 }