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) {
203
203
final long period = this .currentPeriod ;
204
204
final GossipRequest gossipRequest = message .data ();
205
205
for (Gossip gossip : gossipRequest .gossips ()) {
206
+ GossipState gossipState = gossips .get (gossip .gossipId ());
206
207
if (ensureSequence (gossip .gossiperId ()).add (gossip .sequenceId ())) {
207
- GossipState gossipState = gossips .get (gossip .gossipId ());
208
208
if (gossipState == null ) { // new gossip
209
209
gossipState = new GossipState (gossip , period );
210
210
gossips .put (gossip .gossipId (), gossipState );
211
211
sink .emitNext (gossip .message (), RETRY_NON_SERIALIZED );
212
212
}
213
+ }
214
+ if (gossipState != null ) {
213
215
gossipState .addToInfected (gossipRequest .from ());
214
216
}
215
217
}
You can’t perform that action at this time.
0 commit comments