Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Fixed another problem getting elements from all zones (issue 367)

  • Loading branch information...
commit 957aba5a45757656bb1261eba3e4431435be7e70 1 parent 2254e41
@ctasada authored
View
3  src/java/voldemort/store/routed/action/PerformParallelGetAllRequests.java
@@ -34,8 +34,8 @@
import voldemort.store.nonblockingstore.NonblockingStoreCallback;
import voldemort.store.routed.GetAllPipelineData;
import voldemort.store.routed.Pipeline;
-import voldemort.store.routed.Response;
import voldemort.store.routed.Pipeline.Event;
+import voldemort.store.routed.Response;
import voldemort.utils.ByteArray;
import voldemort.versioning.Versioned;
@@ -154,6 +154,7 @@ public void requestComplete(Object result, long requestTime) {
zoneResponses = pipelineData.getKeyToZoneResponse().get(key);
} else {
zoneResponses = new HashSet<Integer>();
+ pipelineData.getKeyToZoneResponse().put(key, zoneResponses);
}
zoneResponses.add(response.getNode().getZoneId());
}
View
1  src/java/voldemort/store/routed/action/PerformSerialGetAllRequests.java
@@ -132,6 +132,7 @@ public void execute(Pipeline pipeline) {
zoneResponses = pipelineData.getKeyToZoneResponse().get(key);
} else {
zoneResponses = new HashSet<Integer>();
+ pipelineData.getKeyToZoneResponse().put(key, zoneResponses);
}
zoneResponses.add(response.getNode().getZoneId());
Please sign in to comment.
Something went wrong with that request. Please try again.