|
1234 | 1234 | <a href="#1233" id="1233">1233</a>
|
1235 | 1235 | <a href="#1234" id="1234">1234</a>
|
1236 | 1236 | <a href="#1235" id="1235">1235</a>
|
1237 |
| -<a href="#1236" id="1236">1236</a> |
1238 |
| -<a href="#1237" id="1237">1237</a></pre></div><pre class="rust"><code><span class="attr">#![allow(dead_code)] |
| 1237 | +<a href="#1236" id="1236">1236</a></pre></div><pre class="rust"><code><span class="attr">#![allow(dead_code)] |
1239 | 1238 | </span><span class="kw">use </span>std::{fmt::Debug, future::Future, hash::Hash};
|
1240 | 1239 |
|
1241 | 1240 | <span class="kw">use </span>n0_future::{future, FuturesUnordered};
|
|
2190 | 2189 | <span class="kw">let </span>global = <span class="self">self</span>.global.lock().unwrap();
|
2191 | 2190 | <span class="macro">assert_eq!</span>(global.data, values, <span class="string">"Data mismatch"</span>);
|
2192 | 2191 | <span class="kw">for </span>id <span class="kw">in </span>values.keys() {
|
2193 |
| - <span class="kw">let </span>log = global.log.get(<span class="kw-2">&</span>id).unwrap(); |
| 2192 | + <span class="kw">let </span>log = global.log.get(id).unwrap(); |
2194 | 2193 | <span class="macro">assert!</span>(
|
2195 | 2194 | log.len() % <span class="number">2 </span>== <span class="number">0</span>,
|
2196 | 2195 | <span class="string">"Log must contain alternating wakeup and shutdown events"
|
2197 | 2196 | </span>);
|
2198 |
| - <span class="kw">for </span>i <span class="kw">in </span><span class="number">0</span>..log.len() { |
| 2197 | + <span class="kw">for </span>(i, (event, <span class="kw">_</span>)) <span class="kw">in </span>log.iter().enumerate() { |
2199 | 2198 | <span class="macro">assert_eq!</span>(
|
2200 |
| - log[i].<span class="number">0</span>, |
| 2199 | + <span class="kw-2">*</span>event, |
2201 | 2200 | <span class="kw">if </span>i % <span class="number">2 </span>== <span class="number">0 </span>{
|
2202 | 2201 | Event::Wakeup
|
2203 | 2202 | } <span class="kw">else </span>{
|
|
2298 | 2297 | <span class="kw">if let </span><span class="prelude-val">Some</span>(value) = r.value {
|
2299 | 2298 | <span class="kw">let </span>path = get_path(<span class="kw-2">&</span>global.path, state.id);
|
2300 | 2299 | <span class="kw">let </span>value_bytes = value.to_be_bytes();
|
2301 |
| - std::fs::write(<span class="kw-2">&</span>path, <span class="kw-2">&</span>value_bytes).expect(<span class="string">"Failed to write disk state"</span>); |
| 2300 | + std::fs::write(<span class="kw-2">&</span>path, value_bytes).expect(<span class="string">"Failed to write disk state"</span>); |
2302 | 2301 | }
|
2303 | 2302 | global
|
2304 | 2303 | .log
|
|
2387 | 2386 | <span class="macro">assert_eq!</span>(disk_value, <span class="kw-2">*</span>value, <span class="string">"Disk value mismatch for id {id}"</span>);
|
2388 | 2387 | }
|
2389 | 2388 | <span class="kw">for </span>id <span class="kw">in </span>values.keys() {
|
2390 |
| - <span class="kw">let </span>log = global.log.get(<span class="kw-2">&</span>id).unwrap(); |
| 2389 | + <span class="kw">let </span>log = global.log.get(id).unwrap(); |
2391 | 2390 | <span class="macro">assert!</span>(
|
2392 | 2391 | log.len() % <span class="number">2 </span>== <span class="number">0</span>,
|
2393 | 2392 | <span class="string">"Log must contain alternating wakeup and shutdown events"
|
2394 | 2393 | </span>);
|
2395 |
| - <span class="kw">for </span>i <span class="kw">in </span><span class="number">0</span>..log.len() { |
| 2394 | + <span class="kw">for </span>(i, (event, <span class="kw">_</span>)) <span class="kw">in </span>log.iter().enumerate() { |
2396 | 2395 | <span class="macro">assert_eq!</span>(
|
2397 |
| - log[i].<span class="number">0</span>, |
| 2396 | + <span class="kw-2">*</span>event, |
2398 | 2397 | <span class="kw">if </span>i % <span class="number">2 </span>== <span class="number">0 </span>{
|
2399 | 2398 | Event::Wakeup
|
2400 | 2399 | } <span class="kw">else </span>{
|
|
2432 | 2431 | .<span class="kw">await</span>;
|
2433 | 2432 | <span class="macro">assert!</span>(
|
2434 | 2433 | errors.is_empty(),
|
2435 |
| - <span class="string">"Failed to add some entries: {:?}"</span>, |
2436 |
| - errors |
2437 |
| - ); |
| 2434 | + <span class="string">"Failed to add some entries: {errors:?}" |
| 2435 | + </span>); |
2438 | 2436 | <span class="comment">// check that the db contains the expected values
|
2439 | 2437 | </span><span class="kw">let </span>ids = reference.keys().copied().collect::<Vec<<span class="kw">_</span>>>();
|
2440 | 2438 | <span class="kw">for </span>id <span class="kw">in </span><span class="kw-2">&</span>ids {
|
|
0 commit comments