You are viewing a plain text version of this content. The canonical link for it is here.
Posted to java-dev@axis.apache.org by az...@apache.org on 2008/06/23 20:48:39 UTC
svn commit: r670708 -
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
Author: azeez
Date: Mon Jun 23 11:48:39 2008
New Revision: 670708
URL: http://svn.apache.org/viewvc?rev=670708&view=rev
Log:
Reducing the timeout
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
Modified: webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java?rev=670708&r1=670707&r2=670708&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/TribesClusterManager.java Mon Jun 23 11:48:39 2008
@@ -540,12 +540,12 @@
* @return true, if the member can be contacted; false, otherwise.
*/
private boolean canConnect(org.apache.axis2.clustering.Member member) {
- for (int retries = 10; retries > 0; retries--) {
+ for (int retries = 5; retries > 0; retries--) {
try {
InetAddress addr = InetAddress.getByName(member.getHostName());
SocketAddress sockaddr = new InetSocketAddress(addr,
member.getPort());
- new Socket().connect(sockaddr, 10000);
+ new Socket().connect(sockaddr, 500);
return true;
} catch (IOException e) {
String msg = e.getMessage();
@@ -553,10 +553,6 @@
log.error("Cannot connect to member " +
member.getHostName() + ":" + member.getPort(), e);
}
- try {
- Thread.sleep(1000);
- } catch (InterruptedException ignored) {
- }
}
}
return false;