public class LocalChannelReference extends Object
Constructor and Description |
---|
LocalChannelReference()
Special empty LCR constructor
|
LocalChannelReference(NetworkChannelReference networkChannelRef,
Integer remoteId,
R66Future futureRequest) |
public LocalChannelReference(NetworkChannelReference networkChannelRef, Integer remoteId, R66Future futureRequest) throws OpenR66ProtocolRemoteShutdownException
networkChannelRef
- remoteId
- futureRequest
- OpenR66ProtocolRemoteShutdownException
public LocalChannelReference()
public final void close()
public final io.netty.channel.Channel getNetworkChannel()
public final Integer getLocalId()
public final Integer getRemoteId()
public final io.netty.handler.traffic.ChannelTrafficShapingHandler getChannelTrafficShapingHandler()
public final NetworkChannelReference getNetworkChannelObject()
public final NetworkServerHandler getNetworkServerHandler()
public final TransferActions getServerHandler()
public final DbSession getDbSession()
public final void setRemoteId(Integer remoteId)
remoteId
- the remoteId to setpublic final R66Session getSession()
public final void setSession(R66Session session)
session
- the session to setpublic final String getErrorMessage()
public final void setErrorMessage(String errorMessage, ErrorCode code)
errorMessage
- the errorMessage to setpublic final ErrorCode getCurrentCode()
public final void validateStartup(boolean validate)
validate
- public final R66Future getFutureValidateStartup()
public final boolean isConnectionValidate()
public final void validateConnection(boolean validate, R66Result result)
validate
- public final R66Future getFutureValidateConnection()
public final void validateEndTransfer(R66Result finalValue)
finalValue
- public final R66Future getFutureEndTransfer()
public final void waitReadyForSendThrough() throws OpenR66Exception
OpenR66Exception
public final R66Future getFutureValidRequest()
public final R66Future getFutureRequest()
public final void invalidateRequest(R66Result finalvalue)
finalvalue
- public final void validateRequest(R66Result finalValue)
finalValue
- public final void setChannelLimit(boolean isSender, long limit)
public final long getChannelLimit(boolean isSender)
public final RecvThroughHandler getRecvThroughHandler()
public final boolean isRecvThroughMode()
public final void setRecvThroughHandler(RecvThroughHandler recvThroughHandler)
recvThroughHandler
- the recvThroughHandler to setpublic final boolean isSendThroughMode()
public final void setSendThroughMode(boolean isSendThroughMode)
isSendThroughMode
- the isSendThroughMode to setpublic final ClientRunner getClientRunner()
public final void setClientRunner(ClientRunner clientRunner)
clientRunner
- the clientRunner to setpublic final void sessionNewState(R66FiniteDualStates desiredState)
desiredState
- public final R66FiniteDualStates getSessionState()
public final String getHashComputeDuringTransfer()
public final void setHashComputeDuringTransfer(String hashComputeDuringTransfer)
hashComputeDuringTransfer
- the hashComputeDuringTransfer to
setpublic final void setPartialHash()
public final boolean isPartialHash()
public final PartnerConfiguration getPartner()
public final void setPartner(String hostId)
hostId
- the partner to setpublic final String getRequestId()
public final void setRequestId(String requestId)
requestId
- the requestId to setCopyright © 2009–2022 Waarp. All rights reserved.