com.tencent.tcaplus.net.impl

Class DirConnector

java.lang.Object

com.tencent.tcaplus.net.Connector

com.tencent.tcaplus.net.impl.DirConnector

public class DirConnector
extends Connector

Nested Class Summary

Nested classes/interfaces inherited from class com.tencent.tcaplus.net.Connector

Connector.PackageType

Field Summary

Fields inherited from class com.tencent.tcaplus.net.Connector

continualAbnormalTimes, healthy, id, reactor, requestProcessMetric, requestQueueMetric, router, sendMessageQueue, sendMessageQueueSize

Method Summary

Modifier and Type	Method and Description
protected boolean	canSendMessage()
protected void	clearMessageCache()
protected ByteBuffer	getPackageHeadBuffer() Dir 头最大 20，Proxy/CS 头最大 32，由子类提供对应大小的缓冲。
protected int	getWaitingMessageCount() 获取当前已发送，正在等待接收响应的请求个数
void	onCloseMessage(int seq)
protected void	onRecvMessageBuffer(MessageBuffer messageBuffer)
protected void	putMessageToCache(Message message)
int	update()

Methods inherited from class com.tencent.tcaplus.net.Connector

close, connect, getAddress, getConnectCount, getConnectErrorMessage, getConnectState, getDisconnectTime, getEstablishTime, getLastRecheckAvailableTime, getLastRecvTime, getLocalAddress, getSocketChannel, increaseErrorCount, increaseRequestCount, isHealth, onConnect, onConnectError, onRead, onWrite, reset4Reconnect, send, setConnectState, setInterestOperators, setReadyOperators, toString, toString4Tbl

Methods inherited from class java.lang.Object

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

Method Detail

getPackageHeadBuffer

protected ByteBuffer getPackageHeadBuffer()

Description copied from class: Connector

Dir 头最大 20，Proxy/CS 头最大 32，由子类提供对应大小的缓冲。

Specified by:

getPackageHeadBuffer in class Connector

getWaitingMessageCount

protected int getWaitingMessageCount()

Description copied from class: Connector

获取当前已发送，正在等待接收响应的请求个数

Specified by:

getWaitingMessageCount in class Connector

update

public int update()

Specified by:

update in class Connector

onRecvMessageBuffer

protected void onRecvMessageBuffer(MessageBuffer messageBuffer)

Specified by:

onRecvMessageBuffer in class Connector

onCloseMessage

public void onCloseMessage(int seq)

Specified by:

onCloseMessage in class Connector

canSendMessage

protected boolean canSendMessage()

Specified by:

canSendMessage in class Connector

putMessageToCache

protected void putMessageToCache(Message message)

Specified by:

putMessageToCache in class Connector

clearMessageCache

protected void clearMessageCache()

Specified by:

clearMessageCache in class Connector