GossipDigestAck.java

public class GossipDigestAck {
    
    final List<GossipDigest> gDigestList;
    final Map<InetAddressAndPort, EndpointState> epStateMap;
    
    GossipDigestAck(List<GossipDigest> gDigestList, Map<InetAddressAndPort, EndpointState> epStateMap{
        this.gDigestList = gDigestList;
        this.epStateMap = epStateMap;
    }
}

GossipDigestAckVerbHandler.java

public class GossipDigestAckVerbHandler extends GossipVerbHandler<GossipDigestAck> {
    
    public static final GossipDigestAckVerbHandler instance = new GossipDigestAckVerbHandler();
    
    public void doVerb(Message<GossipDigestAck> message) {
    
        InetAddressAndPort from = message.from();
        GossipDigestAck gDigestAckMessage = message.payload;
        List<GossipDigest> gDigestList = gDigestAckMessage.getGossipDigestList();
        Map<InetAddressAndPort, EndpointState> epStateMap = gDigestAckMessage.getEndpointStateMap();
       
        Map<InetAddressAndPort, EndpointState> deltaEpStateMap = new HashMap<InetAddressAndPort, EndpointState>();
        for (GossipDigest gDigest : gDigestList)
        {
            InetAddressAndPort addr = gDigest.getEndpoint();
            EndpointState localEpStatePtr = Gossiper.instance.getStateForVersionBiggerThan(addr, gDigest.getMaxVersion());
            if (localEpStatePtr != null)
                deltaEpStateMap.put(addr, localEpStatePtr);
        }
        // construct GossipDigestAck2Message and send it
        Message<GossipDigestAck2> gDigestAck2Message = Message.out(GOSSIP_DIGEST_ACK2, new GossipDigestAck2(deltaEpStateMap));
        MessagingService.instance().send(gDigestAck2Message, from);
        super.doVerb(message);
    }
}