File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
cluster/src/main/java/io/scalecube/cluster/gossip Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change @@ -203,13 +203,15 @@ private void onGossipRequest(Message message) {
203203 final long period = this .currentPeriod ;
204204 final GossipRequest gossipRequest = message .data ();
205205 for (Gossip gossip : gossipRequest .gossips ()) {
206+ GossipState gossipState = gossips .get (gossip .gossipId ());
206207 if (ensureSequence (gossip .gossiperId ()).add (gossip .sequenceId ())) {
207- GossipState gossipState = gossips .get (gossip .gossipId ());
208208 if (gossipState == null ) { // new gossip
209209 gossipState = new GossipState (gossip , period );
210210 gossips .put (gossip .gossipId (), gossipState );
211211 sink .emitNext (gossip .message (), RETRY_NON_SERIALIZED );
212212 }
213+ }
214+ if (gossipState != null ) {
213215 gossipState .addToInfected (gossipRequest .from ());
214216 }
215217 }
You can’t perform that action at this time.
0 commit comments