com.baidu.brpc.client.channel

Class AbstractBrpcChannel

java.lang.Object

com.baidu.brpc.client.channel.AbstractBrpcChannel

All Implemented Interfaces:

BrpcChannel

Direct Known Subclasses:

BrpcPooledChannel, BrpcShortChannel, BrpcSingleChannel

public abstract class AbstractBrpcChannel
extends Object
implements BrpcChannel

Field Summary

Fields

Modifier and Type	Field and Description
protected io.netty.bootstrap.Bootstrap	bootstrap
protected BootstrapManager	bootstrapManager
protected CommunicationOptions	communicationOptions
protected ServiceInstance	serviceInstance

Constructor Summary

Constructors

Constructor and Description
AbstractBrpcChannel(ServiceInstance serviceInstance, CommunicationOptions communicationOptions)

Method Summary

Modifier and Type	Method and Description
void	close()
io.netty.channel.Channel	connect()
boolean	equals(Object object)
long	getFailedNum()
Queue<Integer>	getLatencyWindow()
Protocol	getProtocol()
ServiceInstance	getServiceInstance()
int	hashCode()
void	incFailedNum()
void	sendClientNameToServer(io.netty.channel.ChannelFuture channelFuture)
void	updateChannel(io.netty.channel.Channel channel)
void	updateLatency(int latency)
void	updateLatencyWithReadTimeOut()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.baidu.brpc.client.channel.BrpcChannel

getActiveConnectionNum, getChannel, getCurrentMaxConnection, getIdleConnectionNum, removeChannel, returnChannel, updateMaxConnection

Field Detail

serviceInstance

protected ServiceInstance serviceInstance

communicationOptions

protected CommunicationOptions communicationOptions

bootstrap

protected io.netty.bootstrap.Bootstrap bootstrap

bootstrapManager

protected BootstrapManager bootstrapManager

Constructor Detail

AbstractBrpcChannel

public AbstractBrpcChannel(ServiceInstance serviceInstance,
                           CommunicationOptions communicationOptions)

Method Detail

updateChannel

public void updateChannel(io.netty.channel.Channel channel)

Specified by:

updateChannel in interface BrpcChannel

sendClientNameToServer

public void sendClientNameToServer(io.netty.channel.ChannelFuture channelFuture)

connect

public io.netty.channel.Channel connect()

Specified by:

connect in interface BrpcChannel

getServiceInstance

public ServiceInstance getServiceInstance()

Specified by:

getServiceInstance in interface BrpcChannel

getFailedNum

public long getFailedNum()

Specified by:

getFailedNum in interface BrpcChannel

incFailedNum

public void incFailedNum()

Specified by:

incFailedNum in interface BrpcChannel

getLatencyWindow

public Queue<Integer> getLatencyWindow()

Specified by:

getLatencyWindow in interface BrpcChannel

updateLatency

public void updateLatency(int latency)

Specified by:

updateLatency in interface BrpcChannel

updateLatencyWithReadTimeOut

public void updateLatencyWithReadTimeOut()

Specified by:

updateLatencyWithReadTimeOut in interface BrpcChannel

getProtocol

public Protocol getProtocol()

Specified by:

getProtocol in interface BrpcChannel

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object object)

Overrides:

equals in class Object

close

public void close()

Specified by:

close in interface BrpcChannel