|
|
@ -677,16 +677,6 @@ func createGlobalConfig(hc harmonyconfig.HarmonyConfig) (*nodeconfig.ConfigType, |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
func setupConsensusAndNode(hc harmonyconfig.HarmonyConfig, nodeConfig *nodeconfig.ConfigType, registry *registry.Registry) *node.Node { |
|
|
|
func setupConsensusAndNode(hc harmonyconfig.HarmonyConfig, nodeConfig *nodeconfig.ConfigType, registry *registry.Registry) *node.Node { |
|
|
|
// Consensus object.
|
|
|
|
|
|
|
|
// TODO: consensus object shouldn't start here
|
|
|
|
|
|
|
|
decider := quorum.NewDecider(quorum.SuperMajorityVote, uint32(hc.General.ShardID)) |
|
|
|
|
|
|
|
currentConsensus, err := consensus.New( |
|
|
|
|
|
|
|
myHost, nodeConfig.ShardID, nodeConfig.ConsensusPriKey, decider) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
if err != nil { |
|
|
|
|
|
|
|
_, _ = fmt.Fprintf(os.Stderr, "Error :%v \n", err) |
|
|
|
|
|
|
|
os.Exit(1) |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
// Parse minPeers from harmonyconfig.HarmonyConfig
|
|
|
|
// Parse minPeers from harmonyconfig.HarmonyConfig
|
|
|
|
var minPeers int |
|
|
|
var minPeers int |
|
|
|
var aggregateSig bool |
|
|
|
var aggregateSig bool |
|
|
|