@@ 194,11 194,12 @@ func bootstrap() {
panic(err)
}
logger.Info("opened stream with master peer")
- _, err = rw.WriteString("options\n")
+ _, err = rw.WriteString("options")
if err != nil {
panic(err)
}
rw.Flush()
+ stream.Close() // only stops writing
for {
str, err := rw.ReadString('\n')
if err == io.EOF {
@@ 212,7 213,6 @@ func bootstrap() {
electionOptions = append(electionOptions, ElectionOption(str))
fmt.Println(str)
}
- stream.Close()
logger.Info("stream with master peer closed")
checkMerkle()
}