You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by gd...@apache.org on 2011/01/20 00:30:45 UTC
svn commit: r1061062 - in
/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra:
net/MessageDeliveryTask.java service/StorageService.java
Author: gdusbabek
Date: Wed Jan 19 23:30:45 2011
New Revision: 1061062
URL: http://svn.apache.org/viewvc?rev=1061062&view=rev
Log:
create some padder verb fields. patch by gdusbabek, reviewed by bwilliams. CASSANDRA-2011
Modified:
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/MessageDeliveryTask.java
cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/MessageDeliveryTask.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/MessageDeliveryTask.java?rev=1061062&r1=1061061&r2=1061062&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/MessageDeliveryTask.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/net/MessageDeliveryTask.java Wed Jan 19 23:30:45 2011
@@ -54,6 +54,13 @@ public class MessageDeliveryTask impleme
return;
}
break;
+
+ // don't bother.
+ case UNUSED_1:
+ case UNUSED_2:
+ case UNUSED_3:
+ return;
+
default:
break;
}
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java?rev=1061062&r1=1061061&r2=1061062&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java (original)
+++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/service/StorageService.java Wed Jan 19 23:30:45 2011
@@ -107,6 +107,10 @@ public class StorageService implements I
INDEX_SCAN,
REPLICATION_FINISHED,
INTERNAL_RESPONSE, // responses to internal calls
+ // use as padding for backwards compatability where a previous version needs to validate a verb from the future.
+ UNUSED_1,
+ UNUSED_2,
+ UNUSED_3,
;
// remember to add new verbs at the end, since we serialize by ordinal
}
@@ -135,6 +139,9 @@ public class StorageService implements I
put(Verb.INDEX_SCAN, Stage.READ);
put(Verb.REPLICATION_FINISHED, Stage.MISC);
put(Verb.INTERNAL_RESPONSE, Stage.INTERNAL_RESPONSE);
+ put(Verb.UNUSED_1, Stage.INTERNAL_RESPONSE);
+ put(Verb.UNUSED_2, Stage.INTERNAL_RESPONSE);
+ put(Verb.UNUSED_3, Stage.INTERNAL_RESPONSE);
}};