Commit 6e938434 authored by madengji's avatar madengji Committed by 33cn

bls with sync

parent ac298e42
...@@ -157,6 +157,10 @@ func (b *blsClient) rcvLeaderSyncTx(sync *pt.LeaderSyncInfo) error { ...@@ -157,6 +157,10 @@ func (b *blsClient) rcvLeaderSyncTx(sync *pt.LeaderSyncInfo) error {
} }
func (b *blsClient) getLeaderInfo() ([]string, int32, int32, int32, bool) { func (b *blsClient) getLeaderInfo() ([]string, int32, int32, int32, bool) {
//在未同步前 不处理聚合消息
if !b.paraClient.commitMsgClient.isSync() {
return nil, 0, 0, 0, false
}
nodes, _ := b.getSuperNodes() nodes, _ := b.getSuperNodes()
if len(nodes) <= 0 { if len(nodes) <= 0 {
return nil, 0, 0, 0, false return nil, 0, 0, 0, false
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment