Java Doc for BasicConnectionTable.java in  » Net » JGroups-2.4.1-sp3 » org » jgroups » blocks » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation 1.  6.0 JDK Core 2.  6.0 JDK Modules 3.  6.0 JDK Modules com.sun 4.  6.0 JDK Modules com.sun.java 5.  6.0 JDK Modules sun 6.  6.0 JDK Platform 7.  Ajax 8.  Apache Harmony Java SE 9.  Aspect oriented 10.  Authentication Authorization 11.  Blogger System 12.  Build 13.  Byte Code 14.  Cache 15.  Chart 16.  Chat 17.  Code Analyzer 18.  Collaboration 19.  Content Management System 20.  Database Client 21.  Database DBMS 22.  Database JDBC Connection Pool 23.  Database ORM 24.  Development 25.  EJB Server geronimo 26.  EJB Server GlassFish 27.  EJB Server JBoss 4.2.1 28.  EJB Server resin 3.1.5 29.  ERP CRM Financial 30.  ESB 31.  Forum 32.  GIS 33.  Graphic Library 34.  Groupware 35.  HTML Parser 36.  IDE 37.  IDE Eclipse 38.  IDE Netbeans 39.  Installer 40.  Internationalization Localization 41.  Inversion of Control 42.  Issue Tracking 43.  J2EE 44.  JBoss 45.  JMS 46.  JMX 47.  Library 48.  Mail Clients 49.  Net 50.  Parser 51.  PDF 52.  Portal 53.  Profiler 54.  Project Management 55.  Report 56.  RSS RDF 57.  Rule Engine 58.  Science 59.  Scripting 60.  Search Engine 61.  Security 62.  Sevlet Container 63.  Source Control 64.  Swing Library 65.  Template Engine 66.  Test Coverage 67.  Testing 68.  UML 69.  Web Crawler 70.  Web Framework 71.  Web Mail 72.  Web Server 73.  Web Services 74.  Web Services apache cxf 2.0.1 75.  Web Services AXIS2 76.  Wiki Engine 77.  Workflow Engines 78.  XML 79.  XML UI Java Java Tutorial Java Open Source Jar File Download Java Articles Java Products Java by API Photoshop Tutorials Maya Tutorials Flash Tutorials 3ds-Max Tutorials Illustrator Tutorials GIMP Tutorials C# / C Sharp C# / CSharp Tutorial C# / CSharp Open Source ASP.Net ASP.NET Tutorial JavaScript DHTML JavaScript Tutorial JavaScript Reference HTML / CSS HTML CSS Reference C / ANSI-C C Tutorial C++ C++ Tutorial Ruby PHP Python Python Tutorial Python Open Source SQL Server / T-SQL SQL Server / T-SQL Tutorial Oracle PL / SQL Oracle PL/SQL Tutorial PostgreSQL SQL / MySQL MySQL Tutorial VB.Net VB.Net Tutorial Flash / Flex / ActionScript VBA / Excel / Access / Word XML XML Tutorial Microsoft Office PowerPoint 2007 Tutorial Microsoft Office Excel 2007 Tutorial Microsoft Office Word 2007 Tutorial

Java Source Code / Java Documentation » Net » JGroups 2.4.1 sp3 » org.jgroups.blocks   Source Cross Reference   Class Diagram   Java Document (Java Doc)   java.lang.Object    org.jgroups.blocks.BasicConnectionTable All known Subclasses:   org.jgroups.blocks.ConnectionTableNIO,  org.jgroups.blocks.ConnectionTable,  org.jgroups.protocols.TCP_NIO, BasicConnectionTable abstract public class BasicConnectionTable (Code) Shared class for TCP connection tables. author:    Scott Marlow Inner Class :public interface Receiver Inner Class :public interface ConnectionListener Inner Class :class Connection implements Runnable Inner Class :class Reaper implements Runnable Field Summary final static  long MAX_JOIN_TIMEOUT       Thread acceptor      final static  int backlog       InetAddress bind_addr       long conn_expire_time      final  Vector conn_listeners      final  HashMap conns      final  byte[] cookie       InetAddress external_addr      The address which will be broadcast to the group (the externally visible address which this host should be contacted on).  int linger       Address local_addr      final protected  Log log       int max_port       Reaper reaper       long reaper_interval       Receiver receiver       int recv_buf_size      final  Object recv_mutex       boolean reuse_addr       boolean running       int send_buf_size       int sock_conn_timeout       int srv_port       ServerSocket srv_sock       boolean tcp_nodelay       ThreadGroup thread_group       boolean use_reaper       boolean use_send_queues      Method Summary  void addConnection(Address peer, Connection c)      public  void addConnectionListener(ConnectionListener l)      abstract  Connection getConnection(Address dest)      public  int getLinger()      public  Address getLocalAddress()      public  int getNumConnections()      public  int getReceiveBufferSize()      public  int getSendBufferSize()      public  int getSocketConnectionTimeout()      public  boolean getTcpNodelay()      public  boolean getUseSendQueues()       void notifyConnectionClosed(Address peer)       void notifyConnectionOpened(Address peer)      public  void receive(Address sender, byte[] data, int offset, int length)      Calls the receiver callback. public  void remove(Address addr)      Remove addrfrom connection table. public  void removeConnectionListener(ConnectionListener l)      public  void retainAll(Collection current_mbrs)      public  void send(Address dest, byte[] data, int offset, int length)      public  void setLinger(int linger)      public  void setReceiveBufferSize(int recv_buf_size)      final public  void setReceiver(Receiver r)      public  void setSendBufferSize(int send_buf_size)      public  void setSocketConnectionTimeout(int sock_conn_timeout)      public  void setTcpNodelay(boolean tcp_nodelay)      public  void setUseSendQueues(boolean flag)      public  void start()      public  void stop()      public  String toString()      Field Detail MAX_JOIN_TIMEOUT final static long MAX_JOIN_TIMEOUT(Code) acceptor Thread acceptor(Code) backlog final static int backlog(Code) bind_addr InetAddress bind_addr(Code) conn_expire_time long conn_expire_time(Code) conn_listeners final Vector conn_listeners(Code) conns final HashMap conns(Code) cookie final byte[] cookie(Code) external_addr InetAddress external_addr(Code) The address which will be broadcast to the group (the externally visible address which this host should be contacted on). If external_addr is null, it will default to the same address that the server socket is bound to. linger int linger(Code) local_addr Address local_addr(Code) log final protected Log log(Code) max_port int max_port(Code) reaper Reaper reaper(Code) reaper_interval long reaper_interval(Code) receiver Receiver receiver(Code) recv_buf_size int recv_buf_size(Code) recv_mutex final Object recv_mutex(Code) reuse_addr boolean reuse_addr(Code) running boolean running(Code) send_buf_size int send_buf_size(Code) sock_conn_timeout int sock_conn_timeout(Code) srv_port int srv_port(Code) srv_sock ServerSocket srv_sock(Code) tcp_nodelay boolean tcp_nodelay(Code) thread_group ThreadGroup thread_group(Code) use_reaper boolean use_reaper(Code) use_send_queues boolean use_send_queues(Code) Method Detail addConnection void addConnection(Address peer, Connection c)(Code) addConnectionListener public void addConnectionListener(ConnectionListener l)(Code) getConnection abstract Connection getConnection(Address dest) throws Exception(Code) getLinger public int getLinger()(Code) getLocalAddress public Address getLocalAddress()(Code) getNumConnections public int getNumConnections()(Code) getReceiveBufferSize public int getReceiveBufferSize()(Code) getSendBufferSize public int getSendBufferSize()(Code) getSocketConnectionTimeout public int getSocketConnectionTimeout()(Code) getTcpNodelay public boolean getTcpNodelay()(Code) getUseSendQueues public boolean getUseSendQueues()(Code) notifyConnectionClosed void notifyConnectionClosed(Address peer)(Code) notifyConnectionOpened void notifyConnectionOpened(Address peer)(Code) receive public void receive(Address sender, byte[] data, int offset, int length)(Code) Calls the receiver callback. We serialize access to this method because it may be called concurrently by several Connection handler threads. Therefore the receiver doesn't need to synchronize. remove public void remove(Address addr)(Code) Remove addrfrom connection table. This is typically triggered when a member is suspected. removeConnectionListener public void removeConnectionListener(ConnectionListener l)(Code) retainAll public void retainAll(Collection current_mbrs)(Code) Removes all connections from ConnectionTable which are not in current_mbrs Parameters:   current_mbrs - send public void send(Address dest, byte[] data, int offset, int length) throws Exception(Code) setLinger public void setLinger(int linger)(Code) setReceiveBufferSize public void setReceiveBufferSize(int recv_buf_size)(Code) setReceiver final public void setReceiver(Receiver r)(Code) setSendBufferSize public void setSendBufferSize(int send_buf_size)(Code) setSocketConnectionTimeout public void setSocketConnectionTimeout(int sock_conn_timeout)(Code) setTcpNodelay public void setTcpNodelay(boolean tcp_nodelay)(Code) setUseSendQueues public void setUseSendQueues(boolean flag)(Code) start public void start() throws Exception(Code) stop public void stop()(Code) toString public String toString()(Code) Methods inherited from java.lang.Object native protected Object clone() throws CloneNotSupportedException(Code)(Java Doc) public boolean equals(Object obj)(Code)(Java Doc) protected void finalize() throws Throwable(Code)(Java Doc) final native public Class getClass()(Code)(Java Doc) native public int hashCode()(Code)(Java Doc) final native public void notify()(Code)(Java Doc) final native public void notifyAll()(Code)(Java Doc) public String toString()(Code)(Java Doc) final native public void wait(long timeout) throws InterruptedException(Code)(Java Doc) final public void wait(long timeout, int nanos) throws InterruptedException(Code)(Java Doc) final public void wait() throws InterruptedException(Code)(Java Doc)