Permalink
Browse files

JCBC-110: Observe operations return their handling node in gotData

Change-Id: I56f5f1844f0388a750ab5b5b4703e616b1e2aa10
Reviewed-on: http://review.couchbase.org/20851
Reviewed-by: Matt Ingenthron <matt@couchbase.com>
Tested-by: Matt Ingenthron <matt@couchbase.com>
  • Loading branch information...
mikewied authored and ingenthr committed Sep 14, 2012
1 parent 217c9af commit 7d35d126c6473dd74f63ede0371f21672f92eef9
@@ -39,6 +39,6 @@
* @param cas the CAS value for this record
* @param or the ObserveResponse
*/
- void gotData(String key, long cas, ObserveResponse or);
+ void gotData(String key, long cas, MemcachedNode node, ObserveResponse or);
}
}
@@ -62,7 +62,8 @@ protected void decodePayload(byte[] pl) {
keystate = (byte) decodeByte(pl, keylen+4);
retCas = (long) decodeLong(pl, keylen+5);
ObserveResponse r = ObserveResponse.valueOf(keystate);
- ((ObserveOperation.Callback) getCallback()).gotData(key, retCas, r);
+ ((ObserveOperation.Callback) getCallback()).gotData(key, retCas,
+ getHandlingNode(), r);
getCallback().receivedStatus(STATUS_OK);
}
}

0 comments on commit 7d35d12

Please sign in to comment.