src/java/org/apache/cassandra/db/HintedHandOffManager.java
/**
     * Attempt delivery to any node for which we have hints.  Necessary since we can generate hints even for
     * nodes which are never officially down/failed.
     */
Attempt delivery to any node for which we have hints.  Necessary since we can generate hints even for
nodes which are never officially down/failed.
Attempt delivery to any node for which we have hints . Necessary since we can generate hints even for nodes which are never officially down / failed .
private void scheduleAllDeliveries()
    {
        if (logger_.isDebugEnabled())
          logger_.debug("Started scheduleAllDeliveries");
        ColumnFamilyStore hintStore = Table.open(Table.SYSTEM_TABLE).getColumnFamilyStore(HINTS_CF);
        IPartitioner p = StorageService.getPartitioner();
        RowPosition minPos = p.getMinimumToken().minKeyBound();
        Range<RowPosition> range = new Range<RowPosition>(minPos, minPos, p);
        IFilter filter = new NamesQueryFilter(ImmutableSortedSet.<ByteBuffer>of());
        List<Row> rows = hintStore.getRangeSlice(null, range, Integer.MAX_VALUE, filter, null);
        for (Row row : rows)
        {
            Token<?> token = StorageService.getPartitioner().getTokenFactory().fromByteArray(row.key.key);
            InetAddress target = StorageService.instance.getTokenMetadata().getEndpoint(token);
            scheduleHintDelivery(target);
        }
        if (logger_.isDebugEnabled())
          logger_.debug("Finished scheduleAllDeliveries");
    }
private void scheduleAllDeliveries ( ) { if ( logger_ . isDebugEnabled ( ) ) logger_ . debug ( "Started scheduleAllDeliveries" ) ; ColumnFamilyStore hintStore = Table . open ( Table . SYSTEM_TABLE ) . getColumnFamilyStore ( HINTS_CF ) ; IPartitioner p = StorageService . getPartitioner ( ) ; RowPosition minPos = p . getMinimumToken ( ) . minKeyBound ( ) ; Range < RowPosition > range = new Range < RowPosition > ( minPos , minPos , p ) ; IFilter filter = new NamesQueryFilter ( ImmutableSortedSet . < ByteBuffer > of ( ) ) ; List < Row > rows = hintStore . getRangeSlice ( null , range , Integer . MAX_VALUE , filter , null ) ; for ( Row row : rows ) { Token < ? > token = StorageService . getPartitioner ( ) . getTokenFactory ( ) . fromByteArray ( row . key . key ) ; InetAddress target = StorageService . instance . getTokenMetadata ( ) . getEndpoint ( token ) ; scheduleHintDelivery ( target ) ; } if ( logger_ . isDebugEnabled ( ) ) logger_ . debug ( "Finished scheduleAllDeliveries" ) ; }
Attempt delivery to any node for which we have hints.
Attempt delivery to any node for which we have hints .