private synchronized void computeRemainingTimeout() {
    if (startTimeSnapShot > 0) { // @todo this should be an assertion
      endTimeSnapShot = distributionManager.cacheTimeMillis();
      long delta = endTimeSnapShot - startTimeSnapShot;
      if (delta > 0) {
        remainingTimeout -= delta;
      }
      startTimeSnapShot = endTimeSnapShot;
    }
  }
This is the response from the accepted responder.
geode-core/src/main/java/org/apache/geode/internal/cache/SearchLoadAndWriteProcessor.java