Java Doc for TCP.java in  » Net » JGroups-2.4.1-sp3 » org » jgroups » protocols » 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.protocols   Source Cross Reference   Class Diagram   Java Document (Java Doc)   org.jgroups.protocols.TP    org.jgroups.protocols.BasicTCP       org.jgroups.protocols.TCP TCP public class TCP extends BasicTCP implements ConnectionTable.Receiver(Code) TCP based protocol. Creates a server socket, which gives us the local address of this group member. For each accept() on the server socket, a new thread is created that listens on the socket. For each outgoing message m, if m.dest is in the ougoing hashtable, the associated socket will be reused to send message, otherwise a new socket is created and put in the hashtable. When a socket connection breaks or a member is removed from the group, the corresponding items in the incoming and outgoing hashtables will be removed as well. This functionality is in ConnectionTable, which isT used by TCP. TCP sends messages using ct.send() and registers with the connection table to receive all incoming messages. author:    Bela Ban Constructor Summary public   TCP()      Method Summary protected  ConnectionTable getConnectionTable(long reaperInterval, long connExpireTime, InetAddress bindAddress, InetAddress externalAddress, int startPort, int endPort)      public  String getName()      public  int getOpenConnections()      public  String printConnections()      public  void retainAll(Collection members)      public  void send(Address dest, byte[] data, int offset, int length)      public  boolean setProperties(Properties props)      public  void start()      public  void stop()      Constructor Detail TCP public TCP()(Code) Method Detail getConnectionTable protected ConnectionTable getConnectionTable(long reaperInterval, long connExpireTime, InetAddress bindAddress, InetAddress externalAddress, int startPort, int endPort) throws Exception(Code) Parameters:   reaperInterval - Parameters:   connExpireTime - Parameters:   bindAddress - Parameters:   startPort - throws:   Exception - ConnectionTableSub classes overrides this method to initialize a different version ofConnectionTable. getName public String getName()(Code) getOpenConnections public int getOpenConnections()(Code) printConnections public String printConnections()(Code) retainAll public void retainAll(Collection members)(Code) send public void send(Address dest, byte[] data, int offset, int length) throws Exception(Code) setProperties public boolean setProperties(Properties props)(Code) Setup the Protocol instance acording to the configuration string start public void start() throws Exception(Code) stop public void stop()(Code) Fields inherited from org.jgroups.protocols.BasicTCP protected long conn_expire_time(Code)(Java Doc) protected int end_port(Code)(Java Doc) protected InetAddress external_addr(Code)(Java Doc) int linger(Code)(Java Doc) protected long reaper_interval(Code)(Java Doc) int recv_buf_size(Code)(Java Doc) int send_buf_size(Code)(Java Doc) boolean skip_suspected_members(Code)(Java Doc) int sock_conn_timeout(Code)(Java Doc) protected int start_port(Code)(Java Doc) boolean suspect_on_send_failure(Code)(Java Doc) final BoundedList suspected_mbrs(Code)(Java Doc) boolean tcp_nodelay(Code)(Java Doc) boolean use_send_queues(Code)(Java Doc) 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) Fields inherited from org.jgroups.protocols.TP final static byte LIST(Code)(Java Doc) final static byte MULTICAST(Code)(Java Doc) byte[] additional_data(Code)(Java Doc) HashMap addr_translation_table(Code)(Java Doc) protected InetAddress bind_addr(Code)(Java Doc) int bind_port(Code)(Java Doc) boolean bind_to_all_interfaces(Code)(Java Doc) final ExposedBufferedInputStream buf_in_stream(Code)(Java Doc) final ExposedBufferedOutputStream buf_out_stream(Code)(Java Doc) protected String channel_name(Code)(Java Doc) String diagnostics_addr(Code)(Java Doc) int diagnostics_port(Code)(Java Doc) final DataInputStream dis(Code)(Java Doc) boolean discard_incompatible_packets(Code)(Java Doc) final ExposedDataOutputStream dos(Code)(Java Doc) boolean enable_bundling(Code)(Java Doc) boolean enable_diagnostics(Code)(Java Doc) static NumberFormat f(Code)(Java Doc) TpHeader header(Code)(Java Doc) final ExposedByteArrayInputStream in_stream(Code)(Java Doc) IncomingMessageHandler incoming_msg_handler(Code)(Java Doc) Queue incoming_msg_queue(Code)(Java Doc) IncomingPacketHandler incoming_packet_handler(Code)(Java Doc) Queue incoming_packet_queue(Code)(Java Doc) protected Address local_addr(Code)(Java Doc) boolean loopback(Code)(Java Doc) int max_bundle_size(Code)(Java Doc) long max_bundle_timeout(Code)(Java Doc) final protected Vector members(Code)(Java Doc) final String name(Code)(Java Doc) long num_msgs_sentnum_msgs_receivednum_bytes_sentnum_bytes_received(Code)(Java Doc) final ExposedByteArrayOutputStream out_stream(Code)(Java Doc) OutgoingPacketHandler outgoing_packet_handler(Code)(Java Doc) BoundedLinkedQueue outgoing_queue(Code)(Java Doc) int outgoing_queue_max_size(Code)(Java Doc) int port_range(Code)(Java Doc) java.util.List receive_interfaces(Code)(Java Doc) boolean receive_on_all_interfaces(Code)(Java Doc) java.util.List send_interfaces(Code)(Java Doc) boolean send_on_all_interfaces(Code)(Java Doc) protected TimeScheduler timer(Code)(Java Doc) boolean use_addr_translation(Code)(Java Doc) boolean use_incoming_packet_handler(Code)(Java Doc) boolean use_local_host(Code)(Java Doc) boolean use_outgoing_packet_handler(Code)(Java Doc) protected View view(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)