|
|
@ -143,7 +143,6 @@ func main() { |
|
|
|
// h := log.CallerFileHandler(log.StdoutHandler)
|
|
|
|
// h := log.CallerFileHandler(log.StdoutHandler)
|
|
|
|
log.Root().SetHandler(h) |
|
|
|
log.Root().SetHandler(h) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Client server setup
|
|
|
|
// Client server setup
|
|
|
|
clientPort := getClientPort(&config) |
|
|
|
clientPort := getClientPort(&config) |
|
|
|
if clientPort != "" { |
|
|
|
if clientPort != "" { |
|
|
@ -156,7 +155,6 @@ func main() { |
|
|
|
}() |
|
|
|
}() |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Testing node to mirror the node data in consensus
|
|
|
|
// Testing node to mirror the node data in consensus
|
|
|
|
nodes := []node.Node{} |
|
|
|
nodes := []node.Node{} |
|
|
|
for _, shardId := range shardIds { |
|
|
|
for _, shardId := range shardIds { |
|
|
@ -192,7 +190,6 @@ func main() { |
|
|
|
time.Sleep(500 * time.Millisecond) // Send a batch of transactions periodically
|
|
|
|
time.Sleep(500 * time.Millisecond) // Send a batch of transactions periodically
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
// Send a stop message to stop the nodes at the end
|
|
|
|
// Send a stop message to stop the nodes at the end
|
|
|
|
msg := node.ConstructStopMessage() |
|
|
|
msg := node.ConstructStopMessage() |
|
|
|
peers := append(getValidators(*configFile), leaders...) |
|
|
|
peers := append(getValidators(*configFile), leaders...) |
|
|
|