Package io.deephaven.enterprise.comm.impl.nio

Class RoundTripTracker

java.lang.Object

io.deephaven.enterprise.comm.impl.nio.RoundTripTracker

public class RoundTripTracker
extends Object

Constructor Summary

Constructors

Constructor	Description
RoundTripTracker(com.fishlib.io.logger.Logger log, String logPrefix, Scheduler sched)

Method Summary

Modifier and Type	Method	Description
void	abortRoundtrips()	Abort all the pending round trips after losing the connection
void	addRoundTrip(com.fishlib.base.Command cmd, AsyncCommandHandler handler, long timeoutMillis, ClientEntry conn)
void	matchResponse(ClientEntry centry, com.fishlib.base.Command cmd)	Match a response to a pending command

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RoundTripTracker

public RoundTripTracker(com.fishlib.io.logger.Logger log,
 String logPrefix,
 Scheduler sched)

Method Details

matchResponse

public void matchResponse(ClientEntry centry,
 com.fishlib.base.Command cmd)

Match a response to a pending command

abortRoundtrips

public void abortRoundtrips()

Abort all the pending round trips after losing the connection

addRoundTrip

public void addRoundTrip(com.fishlib.base.Command cmd,
 AsyncCommandHandler handler,
 long timeoutMillis,
 ClientEntry conn)