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 corresponding RequestCallbacks, 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

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()

Methods inherited from class java.lang.Object

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

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)