org.jgroups.protocols
Class TCP_NIO
java.lang.Object
org.jgroups.stack.Protocol
org.jgroups.protocols.TP
org.jgroups.protocols.TCP
org.jgroups.protocols.TCP_NIO
- All Implemented Interfaces:
- ConnectionTable.Receiver
- public class TCP_NIO
- extends TCP
Fields inherited from class org.jgroups.stack.Protocol |
down_handler, down_prot, down_queue, down_thread, down_thread_prio, log, observer, props, stack, stats, trace, up_handler, up_prot, up_queue, up_thread, up_thread_prio, warn |
Methods inherited from class org.jgroups.protocols.TCP |
getBindAddr, getConnExpireTime, getEndPort, getInfo, getOpenConnections, getReaperInterval, getStartPort, handleDownEvent, isLoopback, postUnmarshalling, postUnmarshallingList, printConnections, receive, sendToAllMembers, sendToSingleMember, setBindAddr, setConnExpireTime, setEndPort, setLoopback, setReaperInterval, setStartPort, start, stop |
Methods inherited from class org.jgroups.protocols.TP |
down, dumpStats, getBindAddress, getBindToAllInterfaces, getChannelName, getIncomingQueueSize, getLocalAddress, getMaxBundleSize, getMaxBundleTimeout, getNumBytesReceived, getNumBytesSent, getNumMessagesReceived, getNumMessagesSent, getOutgoingQueueMaxSize, getOutgoingQueueSize, getReceiveInterfaces, getSendInterfaces, handleConfigEvent, isDiscardIncompatiblePackets, isEnableBundling, isReceiveOnAllInterfaces, isSendOnAllInterfaces, isUseIncomingPacketHandler, isUseOutgoingPacketHandler, receive, resetStats, setBindAddress, setBindToAllInterfaces, setDiscardIncompatiblePackets, setEnableBundling, setMaxBundleSize, setMaxBundleTimeout, setOutgoingQueueMaxSize, startUpHandler, toString, up |
Methods inherited from class org.jgroups.stack.Protocol |
destroy, downThreadEnabled, enableStats, getDownProtocol, getDownQueue, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, setDownProtocol, setObserver, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, startDownHandler, statsEnabled, stopInternal, upThreadEnabled |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
TCP_NIO
public TCP_NIO()
getConnectionTable
protected ConnectionTable getConnectionTable(long ri,
long cet,
java.net.InetAddress b_addr,
java.net.InetAddress bc_addr,
int s_port,
int e_port)
throws java.lang.Exception
- Overrides:
getConnectionTable
in class TCP
- Parameters:
ri
- cet
- b_addr
- s_port
-
- Returns:
- ConnectionTable
Sub classes overrides this method to initialize a different version of
ConnectionTable.
- Throws:
java.lang.Exception
getName
public java.lang.String getName()
- Overrides:
getName
in class TCP
getReaderThreads
public int getReaderThreads()
getWriterThreads
public int getWriterThreads()
getProcessorThreads
public int getProcessorThreads()
getProcessorMinThreads
public int getProcessorMinThreads()
getProcessorMaxThreads
public int getProcessorMaxThreads()
getProcessorQueueSize
public int getProcessorQueueSize()
getProcessorKeepAliveTime
public int getProcessorKeepAliveTime()
setProperties
public boolean setProperties(java.util.Properties props)
- Setup the Protocol instance acording to the configuration string
- Overrides:
setProperties
in class TCP
Copyright ? 1998-2005 Bela Ban. All Rights Reserved.