@@ 161,16 161,6 @@ func handleCmd(cmd string, rw *bufio.ReadWriter, stream network.Stream) {
}
rw.WriteString(base58.Encode(me.sum.Bytes()))
rw.Flush()
- case "input":
- me.inputMu.RLock()
- defer me.inputMu.RLock()
- if me.input == nil {
- logger.Info("peer attempted to fetch input "+
- "before we had one:", stream.Conn().RemotePeer())
- return
- }
- rw.WriteString(base58.Encode(me.input.Bytes()))
- rw.Flush()
default:
logger.Warningf("uknown command %s", cmd)
}
@@ 337,17 327,6 @@ func startVoting() {
}
wg.Wait()
- // ensure we have everyone's inputs
- for _, voter := range election.remoteVoters {
- if voter.input == nil {
- wg.Add(1)
- go func(voter *Voter) {
- voter.input = voter.fetchNumber("input")
- }(voter)
- }
- }
- wg.Wait()
-
// temporary
select {}
}