Searched refs:shutdownTimer (Results 1 – 2 of 2) sorted by relevance
61 entry.shutdownTimer.cancel(false); in takeOrCreateSubchannel()79 ScheduledFuture<?> shutdownTimer = in returnSubchannel() local83 shutdownTask.timer = shutdownTimer; in returnSubchannel()84 CacheEntry entry = new CacheEntry(subchannel, shutdownTimer); in returnSubchannel()91 entry.shutdownTimer.cancel(false); in clear()135 final ScheduledFuture<?> shutdownTimer; field in CachedSubchannelPool.CacheEntry137 CacheEntry(Subchannel subchannel, ScheduledFuture<?> shutdownTimer) { in CacheEntry() argument139 this.shutdownTimer = checkNotNull(shutdownTimer, "shutdownTimer"); in CacheEntry()
492 shutdownTimer *time.Timer // nil until used member741 if t := sc.shutdownTimer; t != nil {865 …if sentGoAway && sc.shutdownTimer == nil && (sc.goAwayCode != ErrCodeNo || gracefulShutdownComplet…1266 sc.shutdownTimer = time.AfterFunc(d, sc.onShutdownTimer)