1313
1414import org .threadly .concurrent .SubmitterScheduler ;
1515import org .threadly .concurrent .future .ListenableFuture ;
16- import org .threadly .concurrent .future .WatchdogCache ;
16+ import org .threadly .concurrent .future .watchdog . MixedTimeWatchdog ;
1717import org .threadly .litesockets .utils .IOUtils ;
1818import org .threadly .litesockets .utils .SimpleByteStats ;
1919import org .threadly .util .AbstractService ;
@@ -29,7 +29,7 @@ abstract class SocketExecuterCommonBase extends AbstractService implements Socke
2929 protected final ConcurrentHashMap <SocketChannel , Client > clients = new ConcurrentHashMap <>();
3030 protected final ConcurrentHashMap <SelectableChannel , Server > servers = new ConcurrentHashMap <>();
3131 protected final SocketExecuterByteStats stats = new SocketExecuterByteStats ();
32- protected final WatchdogCache dogCache ;
32+ protected final MixedTimeWatchdog dogCache ;
3333 protected volatile boolean perConnectionStatsEnabled = true ;
3434 protected Selector acceptSelector ;
3535
@@ -43,7 +43,7 @@ abstract class SocketExecuterCommonBase extends AbstractService implements Socke
4343 ArgumentVerifier .assertNotNull (acceptScheduler , "Accept Scheduler" );
4444
4545 schedulerPool = ssi ;
46- dogCache = new WatchdogCache (ssi , true );
46+ dogCache = new MixedTimeWatchdog (ssi , true );
4747 this .acceptScheduler = acceptScheduler ;
4848 }
4949
@@ -188,7 +188,7 @@ public SimpleByteStats getStats() {
188188
189189 @ Override
190190 public void watchFuture (final ListenableFuture <?> lf , final long delay ) {
191- dogCache .watch (lf , delay );
191+ dogCache .watch (delay , lf );
192192 }
193193
194194 protected static Selector openSelector () {
0 commit comments