Permalink
Browse files

Broadcast operations only send to specified nodes

This was causing observe replica broadcast to always have a positive
countdown latch and timeout.

Change-Id: I4b49cb094ede8875757eb4b09d7b5a5ee50e848a
Reviewed-on: http://review.couchbase.org/20655
Reviewed-by: Matt Ingenthron <matt@couchbase.com>
Reviewed-by: Raghavan N. Srinivas <raghavan.srinivas@gmail.com>
Tested-by: Matt Ingenthron <matt@couchbase.com>
  • Loading branch information...
1 parent c1acdae commit aae7719bb6ef36c5d7b2579bff0d8ff2262b5340 @mikewied mikewied committed with ingenthr Sep 7, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 src/main/java/net/spy/memcached/MemcachedConnection.java
@@ -729,7 +729,7 @@ public CountDownLatch broadcastOperation(BroadcastOpFactory of) {
*/
public CountDownLatch broadcastOperation(final BroadcastOpFactory of,
Collection<MemcachedNode> nodes) {
- final CountDownLatch latch = new CountDownLatch(locator.getAll().size());
+ final CountDownLatch latch = new CountDownLatch(nodes.size());
for (MemcachedNode node : nodes) {
getLogger().debug("broadcast Operation: node = " + node);
Operation op = of.newOp(node, latch);

0 comments on commit aae7719

Please sign in to comment.