| org.jgroups.protocols.TP org.jgroups.protocols.BasicTCP org.jgroups.protocols.TCP_NIO
TCP_NIO | public class TCP_NIO extends BasicTCP implements BasicConnectionTable.Receiver(Code) | | Transport using NIO
author: Scott Marlow author: Alex Fu author: Bela Ban version: $Id: TCP_NIO.java,v 1.11.2.1 2007/04/27 08:03:51 belaban Exp $ |
getOpenConnections | public int getOpenConnections()(Code) | | |
getProcessorKeepAliveTime | public int getProcessorKeepAliveTime()(Code) | | |
getProcessorMaxThreads | public int getProcessorMaxThreads()(Code) | | |
getProcessorMinThreads | public int getProcessorMinThreads()(Code) | | |
getProcessorQueueSize | public int getProcessorQueueSize()(Code) | | |
getProcessorThreads | public int getProcessorThreads()(Code) | | |
getReaderThreads | public int getReaderThreads()(Code) | | |
getWriterThreads | public int getWriterThreads()(Code) | | |
setProperties | public boolean setProperties(Properties props)(Code) | | Setup the Protocol instance acording to the configuration string
|
Methods inherited from org.jgroups.protocols.BasicTCP | public long getConnExpireTime()(Code)(Java Doc) public int getEndPort()(Code)(Java Doc) public String getInfo()(Code)(Java Doc) public long getReaperInterval()(Code)(Java Doc) public int getStartPort()(Code)(Java Doc) protected void handleDownEvent(Event evt)(Code)(Java Doc) public void init() throws Exception(Code)(Java Doc) public void postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)(Code)(Java Doc) public void postUnmarshallingList(Message msg, Address dest, boolean multicast)(Code)(Java Doc) abstract public String printConnections()(Code)(Java Doc) public void receive(Address sender, byte[] data, int offset, int length)(Code)(Java Doc) abstract public void retainAll(Collection members)(Code)(Java Doc) abstract public void send(Address dest, byte[] data, int offset, int length) throws Exception(Code)(Java Doc) public void sendToAllMembers(byte[] data, int offset, int length) throws Exception(Code)(Java Doc) public void sendToSingleMember(Address dest, byte[] data, int offset, int length) throws Exception(Code)(Java Doc) public void setConnExpireTime(long conn_expire_time)(Code)(Java Doc) public void setEndPort(int end_port)(Code)(Java Doc) public boolean setProperties(Properties props)(Code)(Java Doc) public void setReaperInterval(long reaper_interval)(Code)(Java Doc) public void setStartPort(int start_port)(Code)(Java Doc)
|
Methods inherited from org.jgroups.protocols.TP | public void down(Event evt)(Code)(Java Doc) public Map dumpStats()(Code)(Java Doc) public String getBindAddress()(Code)(Java Doc) public boolean getBindToAllInterfaces()(Code)(Java Doc) public String getChannelName()(Code)(Java Doc) public int getIncomingQueueSize()(Code)(Java Doc) abstract public String getInfo()(Code)(Java Doc) public Address getLocalAddress()(Code)(Java Doc) public int getMaxBundleSize()(Code)(Java Doc) public long getMaxBundleTimeout()(Code)(Java Doc) public long getNumBytesReceived()(Code)(Java Doc) public long getNumBytesSent()(Code)(Java Doc) public long getNumMessagesReceived()(Code)(Java Doc) public long getNumMessagesSent()(Code)(Java Doc) public int getOutgoingQueueMaxSize()(Code)(Java Doc) public int getOutgoingQueueSize()(Code)(Java Doc) public java.util.List getReceiveInterfaces()(Code)(Java Doc) public java.util.List getSendInterfaces()(Code)(Java Doc) protected void handleConfigEvent(HashMap map)(Code)(Java Doc) protected void handleDownEvent(Event evt)(Code)(Java Doc) public void init() throws Exception(Code)(Java Doc) public boolean isDiscardIncompatiblePackets()(Code)(Java Doc) public boolean isEnableBundling()(Code)(Java Doc) public boolean isLoopback()(Code)(Java Doc) public boolean isReceiveOnAllInterfaces()(Code)(Java Doc) public boolean isSendOnAllInterfaces()(Code)(Java Doc) public boolean isUseIncomingPacketHandler()(Code)(Java Doc) public boolean isUseOutgoingPacketHandler()(Code)(Java Doc) abstract public void postUnmarshalling(Message msg, Address dest, Address src, boolean multicast)(Code)(Java Doc) abstract public void postUnmarshallingList(Message msg, Address dest, boolean multicast)(Code)(Java Doc) final protected void receive(Address dest, Address sender, byte[] data, int offset, int length)(Code)(Java Doc) public void resetStats()(Code)(Java Doc) abstract public void sendToAllMembers(byte[] data, int offset, int length) throws Exception(Code)(Java Doc) abstract public void sendToSingleMember(Address dest, byte[] data, int offset, int length) throws Exception(Code)(Java Doc) public void setBindAddress(String bind_addr) throws UnknownHostException(Code)(Java Doc) public void setBindToAllInterfaces(boolean flag)(Code)(Java Doc) public void setDiscardIncompatiblePackets(boolean flag)(Code)(Java Doc) public void setEnableBundling(boolean flag)(Code)(Java Doc) public void setLoopback(boolean b)(Code)(Java Doc) public void setMaxBundleSize(int size)(Code)(Java Doc) public void setMaxBundleTimeout(long timeout)(Code)(Java Doc) public void setOutgoingQueueMaxSize(int new_size)(Code)(Java Doc) public boolean setProperties(Properties props)(Code)(Java Doc) protected void setThreadNames()(Code)(Java Doc) public void start() throws Exception(Code)(Java Doc) public void startUpHandler()(Code)(Java Doc) public void stop()(Code)(Java Doc) public String toString()(Code)(Java Doc) protected void unsetThreadNames()(Code)(Java Doc) public void up(Event evt)(Code)(Java Doc)
|
|
|