File tree 2 files changed +0
-10
lines changed 2 files changed +0
-10
lines changed Original file line number Diff line number Diff line change @@ -2935,7 +2935,6 @@ InitWalSenderSlot(void)
2935
2935
walsnd -> flushLag = -1 ;
2936
2936
walsnd -> applyLag = -1 ;
2937
2937
walsnd -> sync_standby_priority = 0 ;
2938
- walsnd -> latch = & MyProc -> procLatch ;
2939
2938
walsnd -> replyTime = 0 ;
2940
2939
2941
2940
/*
@@ -2979,8 +2978,6 @@ WalSndKill(int code, Datum arg)
2979
2978
MyWalSnd = NULL ;
2980
2979
2981
2980
SpinLockAcquire (& walsnd -> mutex );
2982
- /* clear latch while holding the spinlock, so it can safely be read */
2983
- walsnd -> latch = NULL ;
2984
2981
/* Mark WalSnd struct as no longer being in use. */
2985
2982
walsnd -> pid = 0 ;
2986
2983
SpinLockRelease (& walsnd -> mutex );
Original file line number Diff line number Diff line change 18
18
#include "nodes/replnodes.h"
19
19
#include "replication/syncrep.h"
20
20
#include "storage/condition_variable.h"
21
- #include "storage/latch.h"
22
21
#include "storage/shmem.h"
23
22
#include "storage/spin.h"
24
23
@@ -71,12 +70,6 @@ typedef struct WalSnd
71
70
/* Protects shared variables in this structure. */
72
71
slock_t mutex ;
73
72
74
- /*
75
- * Pointer to the walsender's latch. Used by backends to wake up this
76
- * walsender when it has work to do. NULL if the walsender isn't active.
77
- */
78
- Latch * latch ;
79
-
80
73
/*
81
74
* Timestamp of the last message received from standby.
82
75
*/
You can’t perform that action at this time.
0 commit comments