public class InsertTag extends UIDTag
accepted, noRecordUnlock, notRoutedOnwards, sourceRestarted, tracker, unlockedHandler
Modifier and Type | Method and Description |
---|---|
int |
expectedTransfersIn(boolean ignoreLocalVsRemote,
int outwardTransfersPerInsert,
boolean forAccept)
Add up the expected transfers in.
|
int |
expectedTransfersOut(boolean ignoreLocalVsRemote,
int outwardTransfersPerInsert,
boolean forAccept)
Add up the expected transfers out.
|
void |
finishedSender() |
void |
handlerThrew(java.lang.Throwable t) |
boolean |
isInsert() |
boolean |
isOfferReply() |
boolean |
isSSK() |
void |
logStillPresent(java.lang.Long uid) |
protected boolean |
mustUnlock()
Caller must call innerUnlock(noRecordUnlock) immediately if this returns true.
|
void |
startedSender() |
addRoutedTo, clearWaitingForSlot, countAsSourceRestarted, currentlyFetchingOfferedKeyFrom, currentlyRoutingTo, getSource, handlingTimeout, hasRoutedTo, hasSourceReallyRestarted, innerUnlock, isLocal, isSource, isWaitingForSlot, maybeLogStillPresent, onRestartOrDisconnectSource, postUnlock, reassignToSelf, removeFetchingOfferedKeyFrom, removeRoutingTo, setAccepted, setNotRoutedOnwards, setWaitingForSlot, shouldStop, timedOutToHandlerButContinued, toString, unlockHandler, unlockHandler, wasLocal
public void startedSender()
public void finishedSender()
protected boolean mustUnlock()
UIDTag
mustUnlock
in class UIDTag
public void handlerThrew(java.lang.Throwable t)
public void logStillPresent(java.lang.Long uid)
logStillPresent
in class UIDTag
public int expectedTransfersIn(boolean ignoreLocalVsRemote, int outwardTransfersPerInsert, boolean forAccept)
UIDTag
expectedTransfersIn
in class UIDTag
ignoreLocalVsRemote
- If true, pretend that the request is remote even if it's local.outwardTransfersPerInsert
- Expected number of outward transfers for an insert.forAccept
- If true, we are deciding whether to accept a request.
If false, we are deciding whether to SEND a request. We need to be more
careful for the latter than the former, to avoid unnecessary rejections
and mandatory backoffs.public int expectedTransfersOut(boolean ignoreLocalVsRemote, int outwardTransfersPerInsert, boolean forAccept)
UIDTag
expectedTransfersOut
in class UIDTag
ignoreLocalVsRemote
- If true, pretend that the request is remote even if it's local.outwardTransfersPerInsert
- Expected number of outward transfers for an insert.forAccept
- If true, we are deciding whether to accept a request.
If false, we are deciding whether to SEND a request. We need to be more
careful for the latter than the former, to avoid unnecessary rejections
and mandatory backoffs.public boolean isOfferReply()
isOfferReply
in class UIDTag