org.jgroups.protocols

Class TCP_NIO

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

Method Summary

protected ConnectionTable
getConnectionTable(long ri, long cet, InetAddress b_addr, InetAddress bc_addr, int s_port, int e_port)
String
getName()
int
getProcessorKeepAliveTime()
int
getProcessorMaxThreads()
int
getProcessorMinThreads()
int
getProcessorQueueSize()
int
getProcessorThreads()
int
getReaderThreads()
int
getWriterThreads()
boolean
setProperties(Properties props)
Setup the Protocol instance acording to the configuration string

Methods inherited from class org.jgroups.protocols.TCP

getBindAddr, getConnExpireTime, getConnectionTable, getEndPort, getInfo, getName, getOpenConnections, getReaperInterval, getStartPort, handleDownEvent, isLoopback, postUnmarshalling, postUnmarshallingList, printConnections, receive, sendToAllMembers, sendToSingleMember, setBindAddr, setConnExpireTime, setEndPort, setLoopback, setProperties, setReaperInterval, setStartPort, start, stop

Methods inherited from class org.jgroups.protocols.TP

down, dumpStats, getBindAddress, getBindToAllInterfaces, getChannelName, getIncomingQueueSize, getInfo, getLocalAddress, getMaxBundleSize, getMaxBundleTimeout, getNumBytesReceived, getNumBytesSent, getNumMessagesReceived, getNumMessagesSent, getOutgoingQueueMaxSize, getOutgoingQueueSize, getReceiveInterfaces, getSendInterfaces, handleConfigEvent, handleDownEvent, isDiscardIncompatiblePackets, isEnableBundling, isLoopback, isReceiveOnAllInterfaces, isSendOnAllInterfaces, isUseIncomingPacketHandler, isUseOutgoingPacketHandler, postUnmarshalling, postUnmarshallingList, receive, resetStats, sendToAllMembers, sendToSingleMember, setBindAddress, setBindToAllInterfaces, setDiscardIncompatiblePackets, setEnableBundling, setLoopback, setMaxBundleSize, setMaxBundleTimeout, setOutgoingQueueMaxSize, setProperties, start, startUpHandler, stop, toString, up

Methods inherited from class org.jgroups.stack.Protocol

destroy, down, downThreadEnabled, dumpStats, enableStats, getDownProtocol, getDownQueue, getName, getProperties, getUpProtocol, getUpQueue, handleSpecialDownEvent, init, isTrace, isWarn, passDown, passUp, printStats, providedDownServices, providedUpServices, receiveDownEvent, receiveUpEvent, requiredDownServices, requiredUpServices, resetStats, setDownProtocol, setObserver, setProperties, setPropertiesInternal, setProtocolStack, setTrace, setUpProtocol, setWarn, start, startDownHandler, startUpHandler, statsEnabled, stop, stopInternal, up, upThreadEnabled

Method Details

getConnectionTable

protected ConnectionTable getConnectionTable(long ri,
                                             long cet,
                                             InetAddress b_addr,
                                             InetAddress bc_addr,
                                             int s_port,
                                             int e_port)
            throws Exception
Overrides:
getConnectionTable in interface TCP
Parameters:
Returns:
ConnectionTable Sub classes overrides this method to initialize a different version of ConnectionTable.

getName

public String getName()
Overrides:
getName in interface TCP

getProcessorKeepAliveTime

public int getProcessorKeepAliveTime()

getProcessorMaxThreads

public int getProcessorMaxThreads()

getProcessorMinThreads

public int getProcessorMinThreads()

getProcessorQueueSize

public int getProcessorQueueSize()

getProcessorThreads

public int getProcessorThreads()

getReaderThreads

public int getReaderThreads()

getWriterThreads

public int getWriterThreads()

setProperties

public boolean setProperties(Properties props)
Setup the Protocol instance acording to the configuration string
Overrides:
setProperties in interface TCP

Copyright B) 1998-2005 Bela Ban. All Rights Reserved.