(boolean isMove)
| 467 | } |
| 468 | |
| 469 | public void tryStartSplit(boolean isMove) throws Exception { |
| 470 | if (!raft.isLeader()) |
| 471 | return; |
| 472 | |
| 473 | var bucket = stateMachine.getBucket(); |
| 474 | var splitting = bucket.getSplittingMeta(); |
| 475 | if (null != splitting) { |
| 476 | logger.info("start but in splitting or ending. {}->{}", formatMeta(bucket.getBucketMeta()), formatMeta(splitting)); |
| 477 | return; // splitting |
| 478 | } |
| 479 | |
| 480 | startSplit(isMove); |
| 481 | } |
| 482 | |
| 483 | private void onFollowerReceiveKeepAlive() { |
| 484 | // 集群中的leader已经开始工作。自己是follower. |
no test coverage detected