|
|
@ -156,7 +156,7 @@ func main() { |
|
|
|
go func() { |
|
|
|
go func() { |
|
|
|
// wait for 3 seconds for client to send ping message to leader
|
|
|
|
// wait for 3 seconds for client to send ping message to leader
|
|
|
|
// FIXME (leo) the readySignal should be set once we really sent ping message to leader
|
|
|
|
// FIXME (leo) the readySignal should be set once we really sent ping message to leader
|
|
|
|
time.Sleep(3 * time.Second) // wait for nodes to be ready
|
|
|
|
time.Sleep(1 * time.Second) // wait for nodes to be ready
|
|
|
|
for _, i := range shardIDs { |
|
|
|
for _, i := range shardIDs { |
|
|
|
readySignal <- i |
|
|
|
readySignal <- i |
|
|
|
} |
|
|
|
} |
|
|
|