honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

use the version to deserialize published cluster state

This commit is contained in:
Shay Banon 2012-09-22 19:47:50 +02:00
parent d5e11fdcd9
commit f73d684c76
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/org/elasticsearch/discovery/zen/publish/PublishClusterStateAction.java
View File

@ -112,6 +112,7 @@ public class PublishClusterStateAction extends AbstractComponent {
class PublishClusterStateRequest implements Streamable {
BytesReference clusterStateInBytes;
Version version = Version.CURRENT;
private PublishClusterStateRequest() {
}
@ -123,6 +124,7 @@ public class PublishClusterStateAction extends AbstractComponent {
@Override
public void readFrom(StreamInput in) throws IOException {
clusterStateInBytes = in.readBytesReference();
version = in.getVersion();
}
@Override
@ -149,6 +151,7 @@ public class PublishClusterStateAction extends AbstractComponent {
} else {
in = CachedStreamInput.cachedHandles(request.clusterStateInBytes.streamInput());
}
in.setVersion(request.version);
ClusterState clusterState = ClusterState.Builder.readFrom(in, nodesProvider.nodes().localNode());
listener.onNewClusterState(clusterState);
channel.sendResponse(VoidStreamable.INSTANCE);