|
33 | 33 | import java.util.concurrent.CountDownLatch;
|
34 | 34 | import java.util.concurrent.ExecutorService;
|
35 | 35 | import java.util.function.Consumer;
|
36 |
| -import java.util.function.Function; |
37 | 36 |
|
38 | 37 | import com.jcraft.jzlib.JZlib;
|
39 | 38 |
|
@@ -81,58 +80,58 @@ public ClusterStateChecksum(ClusterState clusterState, ThreadPool threadpool) {
|
81 | 80 | executeChecksumTask((stream) -> {
|
82 | 81 | clusterState.routingTable().writeVerifiableTo(stream);
|
83 | 82 | return null;
|
84 |
| - }, checksum -> routingTableChecksum = checksum, executorService, latch); |
| 83 | + }, checksum -> routingTableChecksum = checksum, executorService, latch); |
85 | 84 |
|
86 | 85 | executeChecksumTask((stream) -> {
|
87 |
| - clusterState.nodes().writeVerifiableTo(stream); |
| 86 | + clusterState.nodes().writeVerifiableTo(stream); |
88 | 87 | return null;
|
89 | 88 | }, checksum -> nodesChecksum = checksum, executorService, latch);
|
90 | 89 |
|
91 | 90 | executeChecksumTask((stream) -> {
|
92 |
| - clusterState.coordinationMetadata().writeVerifiableTo(stream); |
| 91 | + clusterState.coordinationMetadata().writeVerifiableTo(stream); |
93 | 92 | return null;
|
94 | 93 | }, checksum -> coordinationMetadataChecksum = checksum, executorService, latch);
|
95 | 94 |
|
96 | 95 | executeChecksumTask((stream) -> {
|
97 |
| - Settings.writeSettingsToStream(clusterState.metadata().persistentSettings(), stream); |
| 96 | + Settings.writeSettingsToStream(clusterState.metadata().persistentSettings(), stream); |
98 | 97 | return null;
|
99 | 98 | }, checksum -> settingMetadataChecksum = checksum, executorService, latch);
|
100 | 99 |
|
101 | 100 | executeChecksumTask((stream) -> {
|
102 |
| - Settings.writeSettingsToStream(clusterState.metadata().transientSettings(), stream); |
| 101 | + Settings.writeSettingsToStream(clusterState.metadata().transientSettings(), stream); |
103 | 102 | return null;
|
104 | 103 | }, checksum -> transientSettingsMetadataChecksum = checksum, executorService, latch);
|
105 | 104 |
|
106 | 105 | executeChecksumTask((stream) -> {
|
107 |
| - clusterState.metadata().templatesMetadata().writeVerifiableTo(stream); |
| 106 | + clusterState.metadata().templatesMetadata().writeVerifiableTo(stream); |
108 | 107 | return null;
|
109 | 108 | }, checksum -> templatesMetadataChecksum = checksum, executorService, latch);
|
110 | 109 |
|
111 | 110 | executeChecksumTask((stream) -> {
|
112 |
| - stream.writeStringCollection(clusterState.metadata().customs().keySet()); |
| 111 | + stream.writeStringCollection(clusterState.metadata().customs().keySet()); |
113 | 112 | return null;
|
114 | 113 | }, checksum -> customMetadataMapChecksum = checksum, executorService, latch);
|
115 | 114 |
|
116 | 115 | executeChecksumTask((stream) -> {
|
117 |
| - ((DiffableStringMap) clusterState.metadata().hashesOfConsistentSettings()).writeTo(stream); |
| 116 | + ((DiffableStringMap) clusterState.metadata().hashesOfConsistentSettings()).writeTo(stream); |
118 | 117 | return null;
|
119 | 118 | }, checksum -> hashesOfConsistentSettingsChecksum = checksum, executorService, latch);
|
120 | 119 |
|
121 | 120 | executeChecksumTask((stream) -> {
|
122 |
| - stream.writeMapValues( |
123 |
| - clusterState.metadata().indices(), |
124 |
| - (checksumStream, value) -> value.writeVerifiableTo((BufferedChecksumStreamOutput) checksumStream) |
125 |
| - ); |
| 121 | + stream.writeMapValues( |
| 122 | + clusterState.metadata().indices(), |
| 123 | + (checksumStream, value) -> value.writeVerifiableTo((BufferedChecksumStreamOutput) checksumStream) |
| 124 | + ); |
126 | 125 | return null;
|
127 | 126 | }, checksum -> indicesChecksum = checksum, executorService, latch);
|
128 | 127 |
|
129 | 128 | executeChecksumTask((stream) -> {
|
130 |
| - clusterState.blocks().writeVerifiableTo(stream); |
| 129 | + clusterState.blocks().writeVerifiableTo(stream); |
131 | 130 | return null;
|
132 | 131 | }, checksum -> blocksChecksum = checksum, executorService, latch);
|
133 | 132 |
|
134 | 133 | executeChecksumTask((stream) -> {
|
135 |
| - stream.writeStringCollection(clusterState.customs().keySet()); |
| 134 | + stream.writeStringCollection(clusterState.customs().keySet()); |
136 | 135 | return null;
|
137 | 136 | }, checksum -> clusterStateCustomsChecksum = checksum, executorService, latch);
|
138 | 137 |
|
|
0 commit comments