@@ -97,7 +97,7 @@ public void activate(final DiscoveryNodes lastAcceptedNodes) {
97
97
active = true ;
98
98
this .lastAcceptedNodes = lastAcceptedNodes ;
99
99
leader = Optional .empty ();
100
- handleWakeUpUnderLock ();
100
+ handleWakeUp ();
101
101
}
102
102
}
103
103
@@ -106,7 +106,7 @@ public void deactivate(DiscoveryNode leader) {
106
106
logger .trace ("deactivating PeerFinder and setting leader to {}" , leader );
107
107
if (active ) {
108
108
active = false ;
109
- handleWakeUpUnderLock ();
109
+ handleWakeUp ();
110
110
}
111
111
this .leader = Optional .of (leader );
112
112
assert assertInactiveWithNoKnownPeers ();
@@ -159,12 +159,6 @@ public interface TransportAddressConnector {
159
159
void connectToRemoteMasterNode (TransportAddress transportAddress , ActionListener <DiscoveryNode > listener );
160
160
}
161
161
162
- private void handleWakeUp () {
163
- synchronized (mutex ) {
164
- handleWakeUpUnderLock ();
165
- }
166
- }
167
-
168
162
private List <DiscoveryNode > getKnownPeers () {
169
163
assert active ;
170
164
assert holdsLock () : "PeerFinder mutex not held" ;
@@ -184,7 +178,7 @@ private Peer createConnectingPeer(TransportAddress transportAddress) {
184
178
return peer ;
185
179
}
186
180
187
- private void handleWakeUpUnderLock () {
181
+ private void handleWakeUp () {
188
182
assert holdsLock () : "PeerFinder mutex not held" ;
189
183
190
184
for (final Peer peer : peersByAddress .values ()) {
@@ -210,7 +204,9 @@ private void handleWakeUpUnderLock() {
210
204
futureExecutor .schedule (new Runnable () {
211
205
@ Override
212
206
public void run () {
213
- handleWakeUp ();
207
+ synchronized (mutex ) {
208
+ handleWakeUp ();
209
+ }
214
210
}
215
211
216
212
@ Override
0 commit comments