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/01/15 08:45:23 UTC
svn commit: r612034 - in
/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes:
MembershipManager.java TribesClusterManager.java
Author: azeez
Date: Mon Jan 14 23:45:20 2008
New Revision: 612034
URL: http://svn.apache.org/viewvc?rev=612034&view=rev
Log:
Few minor changes
Modified:
webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
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/MembershipManager.java
URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=612034&r1=612033&r2=612034&view=diff
==============================================================================
--- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java (original)
+++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java Mon Jan 14 23:45:20 2008
@@ -56,10 +56,6 @@
return longestLivingMember;
}
- public synchronized void removeAllMembers() {
- members.clear();
- }
-
public synchronized Member getRandomMember() {
if (members.size() == 0) {
return null;
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=612034&r1=612033&r2=612034&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 Jan 14 23:45:20 2008
@@ -52,6 +52,7 @@
import org.apache.catalina.tribes.group.interceptors.OrderInterceptor;
import org.apache.catalina.tribes.transport.ReceiverBase;
import org.apache.catalina.tribes.transport.ReplicationTransmitter;
+import org.apache.catalina.tribes.transport.MultiPointSender;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
@@ -140,8 +141,10 @@
if (maxRetriesParam != null) {
maxRetries = Integer.parseInt((String) maxRetriesParam.getValue());
}
- ((ReplicationTransmitter) channel.getChannelSender()).
- getTransport().setMaxRetryAttempts(maxRetries);
+ ReplicationTransmitter replicationTransmitter =
+ (ReplicationTransmitter) channel.getChannelSender();
+ MultiPointSender multiPointSender = replicationTransmitter.getTransport();
+ multiPointSender.setMaxRetryAttempts(maxRetries);
// Set the IP address that will be advertised by this node
String localIP = System.getProperty(ClusteringConstants.LOCAL_IP_ADDRESS);
@@ -197,6 +200,7 @@
// Add a reliable failure detector
TcpFailureDetector tcpFailureDetector = new TcpFailureDetector();
+ tcpFailureDetector.setPrevious(dfi);
channel.addInterceptor(tcpFailureDetector);
channel.addChannelListener(channelListener);
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-cvs-help@ws.apache.org
Re: svn commit: r612034 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes: MembershipManager.java TribesClusterManager.java
Posted by David Illsley <da...@gmail.com>.
Excellent. Thanks!
David
On Jan 16, 2008 5:54 AM, Afkham Azeez <af...@gmail.com> wrote:
> The test failure is not due to this commit. However, it seems like there are
> communication problems between nodes, may be due to some settings on that
> machine. So I've added a property, run.clustering.tests, which defaults to
> false.
>
> Thanks
> Azeez
>
>
>
> On Jan 15, 2008 2:10 PM, David Illsley <davidillsley@gmail.com > wrote:
> >
> >
> >
> > Azeez,
> > Is there any chance you could take a look at why the continuum
> > build[1] is failing?
> >
> > [1]
> http://ws.zones.apache.org:10000/continuum/servlet/continuum/target/ProjectBuild.vm?view=ProjectBuild&buildId=4789&id=61
> >
> >
> >
> >
> > On Jan 15, 2008 7:45 AM, <az...@apache.org> wrote:
> > > Author: azeez
> > > Date: Mon Jan 14 23:45:20 2008
> > > New Revision: 612034
> > >
> > > URL: http://svn.apache.org/viewvc?rev=612034&view=rev
> > > Log:
> > > Few minor changes
> > >
> > >
> > > Modified:
> > >
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> > >
> 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/MembershipManager.java
> > > URL:
> http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=612034&r1=612033&r2=612034&view=diff
> > >
> ==============================================================================
> > > ---
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> (original)
> > > +++
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> Mon Jan 14 23:45:20 2008
> > > @@ -56,10 +56,6 @@
> > > return longestLivingMember;
> > > }
> > >
> > > - public synchronized void removeAllMembers() {
> > > - members.clear();
> > > - }
> > > -
> > > public synchronized Member getRandomMember() {
> > > if (members.size() == 0) {
> > > return null;
> > >
> > > 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=612034&r1=612033&r2=612034&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 Jan 14 23:45:20 2008
> > > @@ -52,6 +52,7 @@
> > > import org.apache.catalina.tribes.group.interceptors.OrderInterceptor;
> > > import org.apache.catalina.tribes.transport.ReceiverBase;
> > > import org.apache.catalina.tribes.transport.ReplicationTransmitter ;
> > > +import org.apache.catalina.tribes.transport.MultiPointSender;
> > > import org.apache.commons.logging.Log;
> > > import org.apache.commons.logging.LogFactory;
> > >
> > > @@ -140,8 +141,10 @@
> > > if (maxRetriesParam != null) {
> > > maxRetries = Integer.parseInt((String)
> maxRetriesParam.getValue());
> > > }
> > > - ((ReplicationTransmitter) channel.getChannelSender()).
> > > - getTransport().setMaxRetryAttempts(maxRetries);
> > > + ReplicationTransmitter replicationTransmitter =
> > > + (ReplicationTransmitter) channel.getChannelSender();
> > > + MultiPointSender multiPointSender =
> replicationTransmitter.getTransport ();
> > > + multiPointSender.setMaxRetryAttempts(maxRetries);
> > >
> > > // Set the IP address that will be advertised by this node
> > > String localIP =
> System.getProperty(ClusteringConstants.LOCAL_IP_ADDRESS );
> > > @@ -197,6 +200,7 @@
> > >
> > > // Add a reliable failure detector
> > > TcpFailureDetector tcpFailureDetector = new
> TcpFailureDetector();
> > > + tcpFailureDetector.setPrevious (dfi);
> > > channel.addInterceptor(tcpFailureDetector);
> > >
> > > channel.addChannelListener(channelListener);
> > >
> > >
> > >
> > > ---------------------------------------------------------------------
> > > To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
> > > For additional commands, e-mail: axis-cvs-help@ws.apache.org
> > >
> > >
> >
> >
> >
> >
> >
> >
> > --
> > David Illsley - IBM Web Services Development
> >
> > ---------------------------------------------------------------------
> > To unsubscribe, e-mail: axis-dev-unsubscribe@ws.apache.org
> > For additional commands, e-mail: axis-dev-help@ws.apache.org
> >
> >
>
>
>
> --
> Thanks
> Afkham Azeez
>
> http://www.wso2.org
> GPG Fingerprint: 643F C2AF EB78 F886 40C9 B2A2 4AE2 C887 665E 0760
--
David Illsley - IBM Web Services Development
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-dev-help@ws.apache.org
Re: svn commit: r612034 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes: MembershipManager.java TribesClusterManager.java
Posted by Afkham Azeez <af...@gmail.com>.
The test failure is not due to this commit. However, it seems like there are
communication problems between nodes, may be due to some settings on that
machine. So I've added a property, run.clustering.tests, which defaults to
false.
Thanks
Azeez
On Jan 15, 2008 2:10 PM, David Illsley <davidillsley@gmail.com > wrote:
> Azeez,
> Is there any chance you could take a look at why the continuum
> build[1] is failing?
>
> [1] http://ws.zones.apache.org:10000/continuum/servlet/continuum/target/ProjectBuild.vm?view=ProjectBuild&buildId=4789&id=61
>
>
> On Jan 15, 2008 7:45 AM, <az...@apache.org> wrote:
> > Author: azeez
> > Date: Mon Jan 14 23:45:20 2008
> > New Revision: 612034
> >
> > URL: http://svn.apache.org/viewvc?rev=612034&view=rev
> > Log:
> > Few minor changes
> >
> >
> > Modified:
> >
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> >
> 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/MembershipManager.java
> > URL:
> http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=612034&r1=612033&r2=612034&view=diff
> >
> ==============================================================================
>
> > ---
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> (original)
> > +++
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> Mon Jan 14 23:45:20 2008
> > @@ -56,10 +56,6 @@
> > return longestLivingMember;
> > }
> >
> > - public synchronized void removeAllMembers() {
> > - members.clear();
> > - }
> > -
> > public synchronized Member getRandomMember() {
> > if (members.size() == 0) {
> > return null;
> >
> > 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=612034&r1=612033&r2=612034&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 Jan 14 23:45:20 2008
> > @@ -52,6 +52,7 @@
> > import org.apache.catalina.tribes.group.interceptors.OrderInterceptor;
> > import org.apache.catalina.tribes.transport.ReceiverBase;
> > import org.apache.catalina.tribes.transport.ReplicationTransmitter ;
> > +import org.apache.catalina.tribes.transport.MultiPointSender;
> > import org.apache.commons.logging.Log;
> > import org.apache.commons.logging.LogFactory;
> >
> > @@ -140,8 +141,10 @@
> > if (maxRetriesParam != null) {
> > maxRetries = Integer.parseInt((String)
> maxRetriesParam.getValue());
> > }
> > - ((ReplicationTransmitter) channel.getChannelSender()).
> > - getTransport().setMaxRetryAttempts(maxRetries);
> > + ReplicationTransmitter replicationTransmitter =
> > + (ReplicationTransmitter) channel.getChannelSender();
> > + MultiPointSender multiPointSender =
> replicationTransmitter.getTransport ();
> > + multiPointSender.setMaxRetryAttempts(maxRetries);
> >
> > // Set the IP address that will be advertised by this node
> > String localIP = System.getProperty(
> ClusteringConstants.LOCAL_IP_ADDRESS );
> > @@ -197,6 +200,7 @@
> >
> > // Add a reliable failure detector
> > TcpFailureDetector tcpFailureDetector = new
> TcpFailureDetector();
> > + tcpFailureDetector.setPrevious (dfi);
> > channel.addInterceptor(tcpFailureDetector);
> >
> > channel.addChannelListener(channelListener);
> >
> >
> >
> > ---------------------------------------------------------------------
> > To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
> > For additional commands, e-mail: axis-cvs-help@ws.apache.org
> >
> >
>
>
>
> --
> David Illsley - IBM Web Services Development
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: axis-dev-unsubscribe@ws.apache.org
> For additional commands, e-mail: axis-dev-help@ws.apache.org
>
>
--
Thanks
Afkham Azeez
http://www.wso2.org
GPG Fingerprint: 643F C2AF EB78 F886 40C9 B2A2 4AE2 C887 665E 0760
Re: svn commit: r612034 - in /webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes: MembershipManager.java TribesClusterManager.java
Posted by David Illsley <da...@gmail.com>.
Azeez,
Is there any chance you could take a look at why the continuum
build[1] is failing?
[1] http://ws.zones.apache.org:10000/continuum/servlet/continuum/target/ProjectBuild.vm?view=ProjectBuild&buildId=4789&id=61
On Jan 15, 2008 7:45 AM, <az...@apache.org> wrote:
> Author: azeez
> Date: Mon Jan 14 23:45:20 2008
> New Revision: 612034
>
> URL: http://svn.apache.org/viewvc?rev=612034&view=rev
> Log:
> Few minor changes
>
>
> Modified:
> webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java
> 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/MembershipManager.java
> URL: http://svn.apache.org/viewvc/webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java?rev=612034&r1=612033&r2=612034&view=diff
> ==============================================================================
> --- webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java (original)
> +++ webservices/axis2/trunk/java/modules/clustering/src/org/apache/axis2/clustering/tribes/MembershipManager.java Mon Jan 14 23:45:20 2008
> @@ -56,10 +56,6 @@
> return longestLivingMember;
> }
>
> - public synchronized void removeAllMembers() {
> - members.clear();
> - }
> -
> public synchronized Member getRandomMember() {
> if (members.size() == 0) {
> return null;
>
> 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=612034&r1=612033&r2=612034&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 Jan 14 23:45:20 2008
> @@ -52,6 +52,7 @@
> import org.apache.catalina.tribes.group.interceptors.OrderInterceptor;
> import org.apache.catalina.tribes.transport.ReceiverBase;
> import org.apache.catalina.tribes.transport.ReplicationTransmitter;
> +import org.apache.catalina.tribes.transport.MultiPointSender;
> import org.apache.commons.logging.Log;
> import org.apache.commons.logging.LogFactory;
>
> @@ -140,8 +141,10 @@
> if (maxRetriesParam != null) {
> maxRetries = Integer.parseInt((String) maxRetriesParam.getValue());
> }
> - ((ReplicationTransmitter) channel.getChannelSender()).
> - getTransport().setMaxRetryAttempts(maxRetries);
> + ReplicationTransmitter replicationTransmitter =
> + (ReplicationTransmitter) channel.getChannelSender();
> + MultiPointSender multiPointSender = replicationTransmitter.getTransport();
> + multiPointSender.setMaxRetryAttempts(maxRetries);
>
> // Set the IP address that will be advertised by this node
> String localIP = System.getProperty(ClusteringConstants.LOCAL_IP_ADDRESS);
> @@ -197,6 +200,7 @@
>
> // Add a reliable failure detector
> TcpFailureDetector tcpFailureDetector = new TcpFailureDetector();
> + tcpFailureDetector.setPrevious(dfi);
> channel.addInterceptor(tcpFailureDetector);
>
> channel.addChannelListener(channelListener);
>
>
>
> ---------------------------------------------------------------------
> To unsubscribe, e-mail: axis-cvs-unsubscribe@ws.apache.org
> For additional commands, e-mail: axis-cvs-help@ws.apache.org
>
>
--
David Illsley - IBM Web Services Development
---------------------------------------------------------------------
To unsubscribe, e-mail: axis-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: axis-dev-help@ws.apache.org