org.jgroups.protocols
Class TCP_NIO

java.lang.Object
  extended by org.jgroups.stack.Protocol
      extended by org.jgroups.protocols.TP
          extended by org.jgroups.protocols.TCP
              extended by org.jgroups.protocols.TCP_NIO
All Implemented Interfaces:
ConnectionTable.Receiver

public class TCP_NIO
extends TCP


Field Summary
 
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
 
Constructor Summary
TCP_NIO()
           
 
Method Summary
protected  ConnectionTable getConnectionTable(long ri, long cet, java.net.InetAddress b_addr, java.net.InetAddress bc_addr, int s_port, int e_port)
           
 java.lang.String getName()
           
 int getProcessorKeepAliveTime()
           
 int getProcessorMaxThreads()
           
 int getProcessorMinThreads()
           
 int getProcessorQueueSize()
           
 int getProcessorThreads()
           
 int getReaderThreads()
           
 int getWriterThreads()
           
 boolean setProperties(java.util.Properties props)
          Setup the Protocol instance acording to the configuration string
 
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
 

Constructor Detail

TCP_NIO

public TCP_NIO()
Method Detail

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
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
Returns:
true if no other properties are left. false if the properties still have data in them, ie , properties are left over and not handled by the protocol stack


Copyright ? 1998-2005 Bela Ban. All Rights Reserved.