src/java/org/apache/cassandra/gms/Gossiper.java
/**
     * Start the gossiper with the generation # retrieved from the System
     * table
     */
Start the gossiper with the generation # retrieved from the System
table
Start the gossiper with the generation # retrieved from the System table
public void start(int generationNbr)
    {
        /* Get the seeds from the config and initialize them. */
        Set<InetAddress> seedHosts = DatabaseDescriptor.getSeeds();
        for (InetAddress seed : seedHosts)
        {
            if (seed.equals(FBUtilities.getBroadcastAddress()))
                continue;
            seeds.add(seed);
        }
        /* initialize the heartbeat state for this localEndpoint */
        maybeInitializeLocalState(generationNbr);
        EndpointState localState = endpointStateMap.get(FBUtilities.getBroadcastAddress());
        DatabaseDescriptor.getEndpointSnitch().gossiperStarting();
        if (logger.isTraceEnabled())
            logger.trace("gossip started with generation " + localState.getHeartBeatState().getGeneration());
        scheduledGossipTask = executor.scheduleWithFixedDelay(new GossipTask(),
                                                              Gossiper.intervalInMillis,
                                                              Gossiper.intervalInMillis,
                                                              TimeUnit.MILLISECONDS);
    }
public void start ( int generationNbr ) { /* Get the seeds from the config and initialize them. */ Set < InetAddress > seedHosts = DatabaseDescriptor . getSeeds ( ) ; for ( InetAddress seed : seedHosts ) { if ( seed . equals ( FBUtilities . getBroadcastAddress ( ) ) ) continue ; seeds . add ( seed ) ; } /* initialize the heartbeat state for this localEndpoint */ maybeInitializeLocalState ( generationNbr ) ; EndpointState localState = endpointStateMap . get ( FBUtilities . getBroadcastAddress ( ) ) ; DatabaseDescriptor . getEndpointSnitch ( ) . gossiperStarting ( ) ; if ( logger . isTraceEnabled ( ) ) logger . trace ( "gossip started with generation " + localState . getHeartBeatState ( ) . getGeneration ( ) ) ; scheduledGossipTask = executor . scheduleWithFixedDelay ( new GossipTask ( ) , Gossiper . intervalInMillis , Gossiper . intervalInMillis , TimeUnit . MILLISECONDS ) ; }
Start the gossiper with the generation # retrieved from the System
 table
Start the gossiper with the generation # retrieved from the System table
//notify snitches that Gossiper is about to start