Permalink
Browse files

made is_server protected

  • Loading branch information...
1 parent 1fa94a9 commit 0fed905054b552b55506197233c92f9444093f04 @belaban committed Jul 21, 2011
Showing with 6 additions and 6 deletions.
  1. +6 −6 src/org/jgroups/protocols/Discovery.java
@@ -79,23 +79,23 @@
/** The largest cluster size found so far (gets reset on stop()) */
@ManagedAttribute
- private volatile int max_found_members=0;
+ protected volatile int max_found_members=0;
@ManagedAttribute
protected int rank=0;
/* --------------------------------------------- Fields ------------------------------------------------------ */
- private volatile boolean is_server=false;
+ protected volatile boolean is_server=false;
protected TimeScheduler timer=null;
protected View view;
protected final Vector<Address> members=new Vector<Address>(11);
protected Address local_addr=null;
protected String group_addr=null;
protected final Set<Responses> ping_responses=new HashSet<Responses>();
- private final PingSenderTask sender=new PingSenderTask();
+ protected final PingSenderTask sender=new PingSenderTask();
@@ -540,7 +540,7 @@ protected void sendDiscoveryResponse(Address logical_addr, List<PhysicalAddress>
protected class PingSenderTask {
- private Future<?> senderFuture;
+ protected Future<?> senderFuture;
public PingSenderTask() {}
@@ -652,7 +652,7 @@ else if(ping_rsps.size() >= num_expected_rsps) {
}
}
- private static int getNumServerResponses(Collection<PingData> rsps) {
+ protected static int getNumServerResponses(Collection<PingData> rsps) {
int cnt=0;
for(PingData rsp: rsps) {
if(rsp.isServer())
@@ -661,7 +661,7 @@ private static int getNumServerResponses(Collection<PingData> rsps) {
return cnt;
}
- private static boolean containsCoordinatorResponse(Collection<PingData> rsps) {
+ protected static boolean containsCoordinatorResponse(Collection<PingData> rsps) {
if(rsps == null || rsps.isEmpty())
return false;
for(PingData rsp: rsps) {

0 comments on commit 0fed905

Please sign in to comment.