[patch] diff to use Socket.connect with timeout parameter

DataSender.java.diff (text/plain), 1001 bytes, created by Casey Lucas on 2007-06-18 06:50:37 UTC

(hide)

Description: diff to use Socket.connect with timeout parameter

Filename:

MIME Type:

Creator: Casey Lucas

Created: 2007-06-18 06:50:37 UTC

Size: 1001 bytes

patch

obsolete

>Index: tcp/DataSender.java >=================================================================== >--- tcp/DataSender.java (revision 3540) >+++ tcp/DataSender.java (working copy) >@@ -19,7 +19,9 @@ > import java.io.IOException; > import java.io.OutputStream; > import java.net.InetAddress; >+import java.net.InetSocketAddress; > import java.net.Socket; >+import java.net.SocketAddress; > import java.net.SocketException; > > import org.apache.catalina.cluster.ClusterMessage; >@@ -713,7 +715,17 @@ > * @throws SocketException > */ > protected void createSocket() throws IOException, SocketException { >- socket = new Socket(getAddress(), getPort()); >+ SocketAddress sockAddr = new InetSocketAddress(getAddress(), getPort()); >+ socket = new Socket(); >+ int timeout = (int) getAckTimeout(); >+ if (timeout > 0) >+ { >+ socket.connect(sockAddr, timeout); >+ } >+ else >+ { >+ socket.connect(sockAddr); >+ } > } > > /** View Attachment As Diff View Attachment As Raw

This is ASF Bugzilla: the Apache Software Foundation bug system. In case of problems with the functioning of ASF Bugzilla, please contact bugzilla-admin@apache.org. Please Note: this e-mail address is only for reporting problems with ASF Bugzilla. Mail about any other subject will be silently ignored.

• • Home
  • | New
  • | Browse
  • | Search
  • |
    [?]
  • | Reports
  • | Help
  • | New Account
  • | Log In
    Remember [x]
  • | Forgot Password
    Login: [x]