void function ( Collection < Address > arg0 ) { for ( Address loc0 : arg0 ) { if ( interestedInAddress ( loc0 ) ) { address2key . put ( loc0 , new ArrayBlockingQueue < > ( bufferSize ) ) ; } else { log . tracef ( "srini_string" , loc0 ) ; } } }
important : this must be called with wl on #address2key . concode_field_sep Cache<? extends K,?> cache concode_elem_sep Log log concode_elem_sep ReclosableLatch keyProducerStartLatch concode_elem_sep int POLL_INTERVAL_MILLIS concode_elem_sep KeyGenerator<? extends K> keyGenerator concode_elem_sep AtomicInteger maxNumberOfKeys concode_elem_sep boolean started concode_elem_sep ListenerRegistration listenerRegistration concode_elem_sep boolean isActive concode_elem_sep float THRESHOLD concode_elem_sep Set<Address> filter concode_elem_sep boolean trace concode_elem_sep Executor executor concode_elem_sep boolean isStopped concode_elem_sep Map<Address,BlockingQueue<K>> address2key concode_elem_sep KeyGeneratorWorker keyGenWorker concode_elem_sep AtomicInteger existingKeyCount concode_elem_sep ReadWriteLock maxNumberInvariant concode_elem_sep int bufferSize concode_field_sep void generateKeys concode_elem_sep boolean interestedInAddress concode_elem_sep K getCollocatedKey concode_elem_sep boolean isStopped concode_elem_sep DistributionManager getDistributionManager concode_elem_sep boolean isKeyGeneratorThreadAlive concode_elem_sep void start concode_elem_sep void run concode_elem_sep boolean isStarted concode_elem_sep void handleCacheStopped concode_elem_sep boolean tryAddKey concode_elem_sep boolean isActive concode_elem_sep void resetNumberOfKeys concode_elem_sep Map<Address,BlockingQueue<K>> getAddress2KeysMapping concode_elem_sep int getMaxNumberOfKeys concode_elem_sep boolean isNodeInConsistentHash concode_elem_sep void stop concode_elem_sep void stop concode_elem_sep K getKeyForAddress concode_elem_sep void handleViewChange concode_elem_sep List<Address> getExistingNodes concode_elem_sep Address getAddressForKey concode_elem_sep boolean isKeyGeneratorThreadActive