You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@tomcat.apache.org by ma...@apache.org on 2008/12/24 17:18:10 UTC
svn commit: r729330 - in /tomcat/trunk/java/org/apache/catalina/tribes/tipis:
AbstractReplicatedMap.java LazyReplicatedMap.java ReplicatedMap.java
Author: markt
Date: Wed Dec 24 08:18:09 2008
New Revision: 729330
URL: http://svn.apache.org/viewvc?rev=729330&view=rev
Log:
Generics for o.a.c.tribes.tipis
- Note that there may be more to come but AbstractReplicatedMap is a tricky beast for generics so these are just the 'easy' ones
Fix various Eclipse warnings (unused code etc)
Modified:
tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java
tomcat/trunk/java/org/apache/catalina/tribes/tipis/LazyReplicatedMap.java
tomcat/trunk/java/org/apache/catalina/tribes/tipis/ReplicatedMap.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?rev=729330&r1=729329&r2=729330&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/AbstractReplicatedMap.java Wed Dec 24 08:18:09 2008
@@ -105,7 +105,7 @@
/**
* A list of members in our map
*/
- protected transient HashMap mapMembers = new HashMap();
+ protected transient HashMap<Member, Long> mapMembers = new HashMap<Member, Long>();
/**
* Our default send options
*/
@@ -251,7 +251,7 @@
if ( channel.getMembers().length > 0 ) {
//send a ping, wait for all nodes to reply
Response[] resp = rpcChannel.send(channel.getMembers(),
- msg, rpcChannel.ALL_REPLY,
+ msg, RpcChannel.ALL_REPLY,
(channelSendOptions),
(int) accessTimeout);
for (int i = 0; i < resp.length; i++) {
@@ -297,7 +297,7 @@
MapMessage msg = new MapMessage(this.mapContextName, msgtype,
false, null, null, null, channel.getLocalMember(false), null);
if ( rpc) {
- Response[] resp = rpcChannel.send(channel.getMembers(), msg, rpcChannel.FIRST_REPLY, (channelSendOptions),rpcTimeout);
+ Response[] resp = rpcChannel.send(channel.getMembers(), msg, RpcChannel.FIRST_REPLY, (channelSendOptions),rpcTimeout);
for (int i = 0; i < resp.length; i++) {
mapMemberAdded(resp[i].getSource());
messageReceived(resp[i].getMessage(), resp[i].getSource());
@@ -344,7 +344,7 @@
//------------------------------------------------------------------------------
// GROUP COM INTERFACES
//------------------------------------------------------------------------------
- public Member[] getMapMembers(HashMap members) {
+ public Member[] getMapMembers(HashMap<Member, Long> members) {
synchronized (members) {
Member[] result = new Member[members.size()];
members.keySet().toArray(result);
@@ -357,7 +357,7 @@
public Member[] getMapMembersExcl(Member[] exclude) {
synchronized (mapMembers) {
- HashMap list = (HashMap)mapMembers.clone();
+ HashMap<Member, Long> list = (HashMap<Member, Long>)mapMembers.clone();
for (int i=0; i<exclude.length;i++) list.remove(exclude[i]);
return getMapMembers(list);
}
@@ -449,7 +449,7 @@
if (backup != null) {
MapMessage msg = new MapMessage(mapContextName, getStateMessageType(), false,
null, null, null, null, null);
- Response[] resp = rpcChannel.send(new Member[] {backup}, msg, rpcChannel.FIRST_REPLY, channelSendOptions, rpcTimeout);
+ Response[] resp = rpcChannel.send(new Member[] {backup}, msg, RpcChannel.FIRST_REPLY, channelSendOptions, rpcTimeout);
if (resp.length > 0) {
synchronized (stateMutex) {
msg = (MapMessage) resp[0].getMessage();
@@ -483,20 +483,20 @@
MapMessage mapmsg = (MapMessage) msg;
//map init request
- if (mapmsg.getMsgType() == mapmsg.MSG_INIT) {
+ if (mapmsg.getMsgType() == MapMessage.MSG_INIT) {
mapmsg.setPrimary(channel.getLocalMember(false));
return mapmsg;
}
//map start request
- if (mapmsg.getMsgType() == mapmsg.MSG_START) {
+ if (mapmsg.getMsgType() == MapMessage.MSG_START) {
mapmsg.setPrimary(channel.getLocalMember(false));
mapMemberAdded(sender);
return mapmsg;
}
//backup request
- if (mapmsg.getMsgType() == mapmsg.MSG_RETRIEVE_BACKUP) {
+ if (mapmsg.getMsgType() == MapMessage.MSG_RETRIEVE_BACKUP) {
MapEntry entry = (MapEntry)super.get(mapmsg.getKey());
if (entry == null || (!entry.isSerializable()) )return null;
mapmsg.setValue( (Serializable) entry.getValue());
@@ -504,15 +504,15 @@
}
//state transfer request
- if (mapmsg.getMsgType() == mapmsg.MSG_STATE || mapmsg.getMsgType() == mapmsg.MSG_STATE_COPY) {
+ if (mapmsg.getMsgType() == MapMessage.MSG_STATE || mapmsg.getMsgType() == MapMessage.MSG_STATE_COPY) {
synchronized (stateMutex) { //make sure we dont do two things at the same time
- ArrayList list = new ArrayList();
+ ArrayList<MapMessage> list = new ArrayList<MapMessage>();
Iterator i = super.entrySet().iterator();
while (i.hasNext()) {
Map.Entry e = (Map.Entry) i.next();
MapEntry entry = (MapEntry) super.get(e.getKey());
if ( entry != null && entry.isSerializable() ) {
- boolean copy = (mapmsg.getMsgType() == mapmsg.MSG_STATE_COPY);
+ boolean copy = (mapmsg.getMsgType() == MapMessage.MSG_STATE_COPY);
MapMessage me = new MapMessage(mapContextName,
copy?MapMessage.MSG_COPY:MapMessage.MSG_PROXY,
false, (Serializable) entry.getKey(), copy?(Serializable) entry.getValue():null, null, entry.getPrimary(),entry.getBackupNodes());
@@ -695,14 +695,14 @@
}
public Member[] excludeFromSet(Member[] mbrs, Member[] set) {
- ArrayList result = new ArrayList();
+ ArrayList<Member> result = new ArrayList<Member>();
for (int i=0; i<set.length; i++ ) {
boolean include = true;
for (int j=0; j<mbrs.length; j++ )
if ( mbrs[j].equals(set[i]) ) include = false;
if ( include ) result.add(set[i]);
}
- return (Member[])result.toArray(new Member[result.size()]);
+ return result.toArray(new Member[result.size()]);
}
public void memberAdded(Member member) {
@@ -840,7 +840,7 @@
//make sure we don't retrieve from ourselves
msg = new MapMessage(getMapContextName(), MapMessage.MSG_RETRIEVE_BACKUP, false,
(Serializable) key, null, null, null,null);
- Response[] resp = getRpcChannel().send(entry.getBackupNodes(),msg, this.getRpcChannel().FIRST_REPLY, Channel.SEND_OPTIONS_DEFAULT, getRpcTimeout());
+ Response[] resp = getRpcChannel().send(entry.getBackupNodes(),msg, RpcChannel.FIRST_REPLY, Channel.SEND_OPTIONS_DEFAULT, getRpcTimeout());
if (resp == null || resp.length == 0) {
//no responses
log.warn("Unable to retrieve remote object for key:" + key);
@@ -966,7 +966,7 @@
public void clear(boolean notify) {
if ( notify ) {
//only delete active keys
- Iterator keys = keySet().iterator();
+ Iterator<Object> keys = keySet().iterator();
while (keys.hasNext())
remove(keys.next());
} else {
@@ -1010,8 +1010,8 @@
return super.size();
}
- public Set entrySet() {
- LinkedHashSet set = new LinkedHashSet(super.size());
+ public Set<MapEntry> entrySet() {
+ LinkedHashSet<MapEntry> set = new LinkedHashSet<MapEntry>(super.size());
Iterator i = super.entrySet().iterator();
while ( i.hasNext() ) {
Map.Entry e = (Map.Entry)i.next();
@@ -1024,10 +1024,10 @@
return Collections.unmodifiableSet(set);
}
- public Set keySet() {
+ public Set<Object> keySet() {
//todo implement
//should only return keys where this is active.
- LinkedHashSet set = new LinkedHashSet(super.size());
+ LinkedHashSet<Object> set = new LinkedHashSet<Object>(super.size());
Iterator i = super.entrySet().iterator();
while ( i.hasNext() ) {
Map.Entry e = (Map.Entry)i.next();
@@ -1063,8 +1063,8 @@
return size()==0;
}
- public Collection values() {
- ArrayList values = new ArrayList();
+ public Collection<Object> values() {
+ ArrayList<Object> values = new ArrayList<Object>();
Iterator i = super.entrySet().iterator();
while ( i.hasNext() ) {
Map.Entry e = (Map.Entry)i.next();
@@ -1330,7 +1330,7 @@
if ( value!=null ) return value;
if ( valuedata == null || valuedata.length == 0 ) return null;
value = XByteBuffer.deserialize(valuedata,0,valuedata.length,cls);
- valuedata = null;;
+ valuedata = null;
return value;
}
@@ -1346,10 +1346,6 @@
return nodes;
}
- private void setBackUpNodes(Member[] nodes) {
- this.nodes = nodes;
- }
-
public Member getPrimary() {
return primary;
}
Modified: tomcat/trunk/java/org/apache/catalina/tribes/tipis/LazyReplicatedMap.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/LazyReplicatedMap.java?rev=729330&r1=729329&r2=729330&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/LazyReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/LazyReplicatedMap.java Wed Dec 24 08:18:09 2008
@@ -26,7 +26,6 @@
import org.apache.catalina.tribes.group.RpcCallback;
import org.apache.catalina.tribes.util.Arrays;
import org.apache.catalina.tribes.UniqueId;
-import org.apache.catalina.tribes.tipis.AbstractReplicatedMap.MapOwner;
/**
* A smart implementation of a stateful replicated map. uses primary/secondary backup strategy.
Modified: tomcat/trunk/java/org/apache/catalina/tribes/tipis/ReplicatedMap.java
URL: http://svn.apache.org/viewvc/tomcat/trunk/java/org/apache/catalina/tribes/tipis/ReplicatedMap.java?rev=729330&r1=729329&r2=729330&view=diff
==============================================================================
--- tomcat/trunk/java/org/apache/catalina/tribes/tipis/ReplicatedMap.java (original)
+++ tomcat/trunk/java/org/apache/catalina/tribes/tipis/ReplicatedMap.java Wed Dec 24 08:18:09 2008
@@ -24,7 +24,6 @@
import org.apache.catalina.tribes.Member;
import org.apache.catalina.tribes.MembershipListener;
import org.apache.catalina.tribes.group.RpcCallback;
-import org.apache.catalina.tribes.tipis.AbstractReplicatedMap.MapOwner;
/**
* All-to-all replication for a hash map implementation. Each node in the cluster will carry an identical
---------------------------------------------------------------------
To unsubscribe, e-mail: dev-unsubscribe@tomcat.apache.org
For additional commands, e-mail: dev-help@tomcat.apache.org