You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by jb...@apache.org on 2011/11/07 20:48:09 UTC
svn commit: r1198898 -
/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java
Author: jbellis
Date: Mon Nov 7 19:48:09 2011
New Revision: 1198898
URL: http://svn.apache.org/viewvc?rev=1198898&view=rev
Log:
update Header comments
Modified:
cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java
Modified: cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java?rev=1198898&r1=1198897&r2=1198898&view=diff
==============================================================================
--- cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java (original)
+++ cassandra/branches/cassandra-1.0/src/java/org/apache/cassandra/net/Header.java Mon Nov 7 19:48:09 2011
@@ -41,8 +41,10 @@ public class Header
return serializer_;
}
+ // "from" is the ultimate origin of this request (the coordinator), which in a multi-DC setup
+ // is not necessarily the same as the node that forwards us the request (see StorageProxy.sendMessages
+ // and RowMutationVerbHandler.forwardToLocalNodes)
private final InetAddress from_;
- // TODO STAGE can be determined from verb
private final StorageService.Verb verb_;
protected Map<String, byte[]> details_ = new Hashtable<String, byte[]>();