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