Package org.apache.cassandra.net
Class RequestCallbacks
- java.lang.Object
-
- org.apache.cassandra.net.RequestCallbacks
-
public class RequestCallbacks extends java.lang.Object
An expiring map of request callbacks. Used to match response (id, peer) pairs to correspondingRequestCallback
s, or, if said responses don't arrive in a timely manner (within verb's timeout), to expire the callbacks. Since we reuse the same request id for multiple messages now, the map is keyed by (id, peer) tuples rather than just id as it used to before 4.0.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addWithExpiration(AbstractWriteResponseHandler<?> cb, Message<?> message, Replica to, ConsistencyLevel consistencyLevel, boolean allowHints)
void
onDiscardOnClose(Message<?> message, InetAddressAndPort peer)
void
onExpired(Message<?> message, InetAddressAndPort peer)
void
onFailedSerialize(Message<?> message, InetAddressAndPort peer, int messagingVersion, int bytesWrittenToNetwork, java.lang.Throwable failure)
void
onOverloaded(Message<?> message, InetAddressAndPort peer)
void
removeAndRespond(long id, InetAddressAndPort peer, Message message)
void
unsafeClear()
-
-
-
Method Detail
-
addWithExpiration
public void addWithExpiration(AbstractWriteResponseHandler<?> cb, Message<?> message, Replica to, ConsistencyLevel consistencyLevel, boolean allowHints)
-
removeAndRespond
public void removeAndRespond(long id, InetAddressAndPort peer, Message message)
-
unsafeClear
public void unsafeClear()
-
onOverloaded
public void onOverloaded(Message<?> message, InetAddressAndPort peer)
-
onExpired
public void onExpired(Message<?> message, InetAddressAndPort peer)
-
onFailedSerialize
public void onFailedSerialize(Message<?> message, InetAddressAndPort peer, int messagingVersion, int bytesWrittenToNetwork, java.lang.Throwable failure)
-
onDiscardOnClose
public void onDiscardOnClose(Message<?> message, InetAddressAndPort peer)
-
-