GossipDigestSynVerbHandler.java

public class GossipDigestSynVerbHandler extends GossipVerbHandler<GossipDigestSyn> {
    
    public static final GossipDigestSynVerbHandler instance = new GossipDigestSynVerbHandler();

    public void doVerb(Message<GossipDigestSyn> message) {
    
        InetAddressAndPort from = message.from();
        GossipDigestSyn gDigestMessage = message.payload;
        List<GossipDigest> gDigestList = gDigestMessage.getGossipDigests();

        List<GossipDigest> deltaGossipDigestList = new ArrayList<GossipDigest>();
        Map<InetAddressAndPort, EndpointState> deltaEpStateMap = new HashMap<InetAddressAndPort, EndpointState>();
        Gossiper.instance.examineGossiper(gDigestList, deltaGossipDigestList, deltaEpStateMap);
        // construct and send the GOSSIP_DIGEST_ACK msg
        Message<GossipDigestAck> gDigestAckMessage = Message.out(GOSSIP_DIGEST_ACK, new GossipDigestAck(deltaGossipDigestList, deltaEpStateMap));
        MessagingService.instance().send(gDigestAckMessage, from);

        super.doVerb(message);
    }
}