Skip to content
Browse files

Retry not my vbucket error for optimized sets. SPY-88

Change-Id: I729781636917f80714cf8d9460e4523e876e1258
Reviewed-on: http://review.couchbase.org/16251
Tested-by: Matt Ingenthron <matt@couchbase.com>
Reviewed-by: Matt Ingenthron <matt@couchbase.com>
  • Loading branch information...
1 parent abcb8b3 commit 52274c7668c7ffc70e3507b7b9b0cb0da856eab4 @mikewied mikewied committed with ingenthr May 20, 2012
Showing with 2 additions and 5 deletions.
  1. +2 −5 src/main/java/net/spy/memcached/protocol/binary/OptimizedSetImpl.java
View
7 src/main/java/net/spy/memcached/protocol/binary/OptimizedSetImpl.java
@@ -1,6 +1,6 @@
/**
* Copyright (C) 2006-2009 Dustin Sallings
- * Copyright (C) 2009-2011 Couchbase, Inc.
+ * Copyright (C) 2009-2012 Couchbase, Inc.
*
* Permission is hereby granted, free of charge, to any person obtaining a copy
* of this software and associated documentation files (the "Software"), to deal
@@ -161,10 +161,7 @@ protected void finishedPayload(byte[] pl) throws IOException {
OperationCallback cb = callbacks.remove(responseOpaque);
assert cb != null : "No callback for " + responseOpaque;
assert errorCode != 0 : "Got no error on a quiet mutation.";
- OperationStatus status = getStatusForErrorCode(errorCode, pl);
- assert status != null : "Got no status for a quiet mutation error";
- cb.receivedStatus(status);
- cb.complete();
+ super.finishedPayload(pl);
}
resetInput();
}

0 comments on commit 52274c7

Please sign in to comment.
Something went wrong with that request. Please try again.