(Rocks rocks)
| 440 | } |
| 441 | |
| 442 | private static void runLeader(Rocks rocks) throws Exception { |
| 443 | var table = rocks.<Integer, Bean1>getTableTemplate("tRocksRaft").openTable(0); |
| 444 | remove1(rocks, table); |
| 445 | |
| 446 | putAndEdit(rocks, table); |
| 447 | verifyData(rocks, table, "Bean1(0 I=1 L=0 Map1={3:3} Bean2=Bean2(I=2) Map2={4:Bean1(4 I=5 L=0 Map1={} Bean2=Bean2(I=0) Map2={})})"); |
| 448 | |
| 449 | edit(rocks, table); |
| 450 | verifyData(rocks, table, "Bean1(0 I=11 L=0 Map1={3:3,13:13} Bean2=Bean2(I=12) Map2={4:Bean1(4 I=5 L=0 Map1={} Bean2=Bean2(I=0) Map2={}),14:Bean1(14 I=15 L=0 Map1={} Bean2=Bean2(I=0) Map2={})})"); |
| 451 | |
| 452 | editInContainer(rocks, table); |
| 453 | verifyData(rocks, table, "Bean1(0 I=11 L=0 Map1={3:3,13:13} Bean2=Bean2(I=12) Map2={4:Bean1(4 I=5 L=0 Map1={} Bean2=Bean2(I=0) Map2={}),14:Bean1(14 I=15 L=0 Map1={} Bean2=Bean2(I=2222) Map2={})})"); |
| 454 | |
| 455 | nestProcedure(rocks, table); |
| 456 | verifyData(rocks, table, "Bean1(0 I=11 L=0 Map1={3:3,13:13} Bean2=Bean2(I=3333) Map2={4:Bean1(4 I=5 L=0 Map1={} Bean2=Bean2(I=0) Map2={}),14:Bean1(14 I=15 L=0 Map1={} Bean2=Bean2(I=2222) Map2={})})"); |
| 457 | |
| 458 | nestProcedureContainer(rocks, table); |
| 459 | verifyData(rocks, table, "Bean1(0 I=11 L=0 Map1={13:13,4444:4444} Bean2=Bean2(I=3333) Map2={14:Bean1(14 I=15 L=0 Map1={} Bean2=Bean2(I=2222) Map2={}),4444:Bean1(4444 I=0 L=0 Map1={} Bean2=Bean2(I=0) Map2={})})"); |
| 460 | |
| 461 | editAndPut(rocks, table); |
| 462 | verifyData(rocks, table, "Bean1(0 I=0 L=0 Map1={} Bean2=Bean2(I=0) Map2={})"); |
| 463 | |
| 464 | // 再次运行本测试，才会执行到 LoadSnapshot。 |
| 465 | // rocks.getRaft().getLogSequence().Snapshot(true); |
| 466 | } |
| 467 | |
| 468 | public static void main(String[] args) throws Exception { |
| 469 | Task.initThreadPool(Task.newFixedThreadPool(5, "test"), |
no test coverage detected