public void registerInterestCompleted(){
  if (GemFireCacheImpl.this.isClosing) {
    return;
  }
  int cv=registerInterestsInProgress.decrementAndGet();
  if (logger.isDebugEnabled()) {
    logger.debug("registerInterestCompleted: new value = {}",cv);
  }
  if (cv == 0) {
synchronized (riWaiters) {
      cv=registerInterestsInProgress.get();
      if (cv == 0) {
        if (logger.isDebugEnabled()) {
          logger.debug("registerInterestCompleted: Signalling end of register-interest");
        }
        Iterator it=riWaiters.iterator();
        while (it.hasNext()) {
          SimpleWaiter sw=(SimpleWaiter)it.next();
          sw.doNotify();
        }
        riWaiters.clear();
      }
    }
  }
}

public void registerInterestCompleted ( ) { if ( GemFireCacheImpl . this . isClosing ) { return ; } int cv = registerInterestsInProgress . decrementAndGet ( ) ; if ( logger . isDebugEnabled ( ) ) { logger . debug ( "registerInterestCompleted: new value = {}" , cv ) ; } if ( cv == 0 ) { synchronized ( riWaiters ) { cv = registerInterestsInProgress . get ( ) ; if ( cv == 0 ) { if ( logger . isDebugEnabled ( ) ) { logger . debug ( "registerInterestCompleted: Signalling end of register-interest" ) ; } Iterator it = riWaiters . iterator ( ) ; while ( it . hasNext ( ) ) { SimpleWaiter sw = ( SimpleWaiter ) it . next ( ) ; sw . doNotify ( ) ; } riWaiters . clear ( ) ; } } } }
update stats for completion of a registerinterest operation
