Author: fhanik
Date: Thu Aug 9 12:45:53 2007
New Revision: 564356
URL: http://svn.apache.org/viewvc?view=rev&rev=564356
Log:
If there is no primary node, then let the expiration time apply to the backup
node
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
URL:
http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java?view=diff&rev=564356&r1=564355&r2=564356
==============================================================================
---
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
(original)
+++
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
Thu Aug 9 12:45:53 2007
@@ -978,7 +978,8 @@
Map.Entry e = (Map.Entry)i.next();
Object key = e.getKey();
MapEntry entry = (MapEntry)super.get(key);
- if ( entry.isPrimary() ) set.add(entry.getValue());
+ if ( entry != null && entry.isPrimary() )
set.add(entry.getValue());
+ else if ( entry != null && entry.getPrimary() == null &&
entry.isBackup() ) set.add(entry.getValue());
}
return Collections.unmodifiableSet(set);
}
@@ -992,7 +993,8 @@
Map.Entry e = (Map.Entry)i.next();
Object key = e.getKey();
MapEntry entry = (MapEntry)super.get(key);
- if ( entry.isPrimary() ) set.add(key);
+ if ( entry!=null && entry.isPrimary() ) set.add(key);
+ else if ( entry != null && entry.getPrimary() == null &&
entry.isBackup() ) set.add(key);
}
return Collections.unmodifiableSet(set);
@@ -1009,6 +1011,7 @@
if ( e != null ) {
MapEntry entry = (MapEntry) super.get(e.getKey());
if (entry!=null && entry.isPrimary() && entry.getValue()
!= null) counter++;
+ else if ( entry != null && entry.getPrimary() == null &&
entry.isBackup() ) counter++;
}
}
return counter;
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]