com.fr.third.jgroups.stack

类 RouterStub

java.lang.Object

com.fr.third.jgroups.stack.RouterStub

所有已实现的接口:

java.lang.Comparable<RouterStub>

public class RouterStub
extends java.lang.Object
implements java.lang.Comparable<RouterStub>

Client stub that talks to a remote GossipRouter

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
static interface	RouterStub.ConnectionListener
static class	RouterStub.ConnectionStatus

字段概要

字段

限定符和类型	字段和说明
protected java.net.InetAddress	bind_addr
protected RouterStub.ConnectionListener	conn_listener
protected RouterStub.ConnectionStatus	connectionState
protected java.io.DataInputStream	input
protected java.util.concurrent.locks.ReentrantLock	lock
protected static Log	log
protected java.io.DataOutputStream	output
protected TUNNEL.StubReceiver	receiver
protected java.lang.String	router_host
protected int	router_port
protected java.net.Socket	sock
protected int	sock_conn_timeout
protected int	sock_read_timeout
protected boolean	tcp_nodelay

构造器概要

构造器

构造器和说明
RouterStub(java.net.InetSocketAddress addr)
RouterStub(java.lang.String routerHost, int routerPort, java.net.InetAddress bindAddress, RouterStub.ConnectionListener l) Creates a stub for a remote Router object.

方法概要

方法

限定符和类型	方法和说明
protected void	_doConnect()
void	checkConnection() Checks whether the connection is open
int	compareTo(RouterStub o)
void	connect(java.lang.String group, Address addr, java.lang.String logical_name, PhysicalAddress phys_addr) Register this process with the router under group.
protected void	connectionStateChanged(RouterStub.ConnectionStatus newState)
void	destroy()
void	disconnect(java.lang.String group, Address addr)
void	doConnect()
boolean	equals(java.lang.Object obj)
RouterStub.ConnectionStatus	getConnectionStatus()
java.net.InetSocketAddress	getGossipRouterAddress()
java.io.DataInputStream	getInputStream()
void	getMembers(java.lang.String group, Responses rsps)
TUNNEL.StubReceiver	getReceiver()
java.net.Socket	getSocket()
int	getSocketConnectionTimeout()
int	getSocketReadTimeout()
int	hashCode()
void	interrupt()
boolean	isConnected()
boolean	isTcpNoDelay()
void	join(long wait)
void	sendToAllMembers(java.lang.String group, byte[] data, int offset, int length)
void	sendToMember(java.lang.String group, Address dest, byte[] data, int offset, int length)
void	setReceiver(TUNNEL.StubReceiver receiver)
void	setSocketConnectionTimeout(int sock_conn_timeout)
void	setSocketReadTimeout(int sock_read_timeout)
void	setTcpNoDelay(boolean tcp_nodelay)
java.lang.String	toString()

从类继承的方法 java.lang.Object

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

字段详细资料

router_host

protected final java.lang.String router_host

router_port

protected final int router_port

sock

protected java.net.Socket sock

output

protected java.io.DataOutputStream output

input

protected java.io.DataInputStream input

connectionState

protected volatile RouterStub.ConnectionStatus connectionState

log

protected static final Log log

conn_listener

protected final RouterStub.ConnectionListener conn_listener

bind_addr

protected final java.net.InetAddress bind_addr

sock_conn_timeout

protected int sock_conn_timeout

sock_read_timeout

protected int sock_read_timeout

tcp_nodelay

protected boolean tcp_nodelay

receiver

protected volatile TUNNEL.StubReceiver receiver

lock

protected final java.util.concurrent.locks.ReentrantLock lock

构造器详细资料

RouterStub

public RouterStub(java.lang.String routerHost,
          int routerPort,
          java.net.InetAddress bindAddress,
          RouterStub.ConnectionListener l)

Creates a stub for a remote Router object.

参数:

routerHost - The name of the router's host

routerPort - The router's port

抛出:

java.net.SocketException

RouterStub

public RouterStub(java.net.InetSocketAddress addr)

方法详细资料

setReceiver

public void setReceiver(TUNNEL.StubReceiver receiver)

getReceiver

public TUNNEL.StubReceiver getReceiver()

isTcpNoDelay

public boolean isTcpNoDelay()

setTcpNoDelay

public void setTcpNoDelay(boolean tcp_nodelay)

compareTo

public int compareTo(RouterStub o)

指定者:

compareTo 在接口中 java.lang.Comparable<RouterStub>

equals

public boolean equals(java.lang.Object obj)

覆盖:

equals 在类中 java.lang.Object

hashCode

public int hashCode()

覆盖:

hashCode 在类中 java.lang.Object

interrupt

public void interrupt()

join

public void join(long wait)
          throws java.lang.InterruptedException

抛出:

java.lang.InterruptedException

getSocketConnectionTimeout

public int getSocketConnectionTimeout()

setSocketConnectionTimeout

public void setSocketConnectionTimeout(int sock_conn_timeout)

getSocketReadTimeout

public int getSocketReadTimeout()

setSocketReadTimeout

public void setSocketReadTimeout(int sock_read_timeout)

isConnected

public boolean isConnected()

getConnectionStatus

public RouterStub.ConnectionStatus getConnectionStatus()

connect

public void connect(java.lang.String group,
           Address addr,
           java.lang.String logical_name,
           PhysicalAddress phys_addr)
             throws java.lang.Exception

Register this process with the router under group.

参数:

group - The name of the group under which to register

抛出:

java.lang.Exception

doConnect

public void doConnect()
               throws java.lang.Exception

抛出:

java.lang.Exception

_doConnect

protected void _doConnect()
                   throws java.lang.Exception

抛出:

java.lang.Exception

checkConnection

public void checkConnection()

Checks whether the connection is open

disconnect

public void disconnect(java.lang.String group,
              Address addr)

destroy

public void destroy()

getSocket

public java.net.Socket getSocket()

getMembers

public void getMembers(java.lang.String group,
              Responses rsps)
                throws java.lang.Exception

抛出:

java.lang.Exception

getGossipRouterAddress

public java.net.InetSocketAddress getGossipRouterAddress()

toString

public java.lang.String toString()

覆盖:

toString 在类中 java.lang.Object

sendToAllMembers

public void sendToAllMembers(java.lang.String group,
                    byte[] data,
                    int offset,
                    int length)
                      throws java.lang.Exception

抛出:

java.lang.Exception

sendToMember

public void sendToMember(java.lang.String group,
                Address dest,
                byte[] data,
                int offset,
                int length)
                  throws java.lang.Exception

抛出:

java.lang.Exception

getInputStream

public java.io.DataInputStream getInputStream()

connectionStateChanged

protected void connectionStateChanged(RouterStub.ConnectionStatus newState)