From c60710b900ec583a9c076c9f25dc8ff302ebcf55 Mon Sep 17 00:00:00 2001 From: David Florness Date: Fri, 5 Jun 2020 13:39:27 -0600 Subject: [PATCH] Close stream on slave side as soon as command is sent --- main.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/main.go b/main.go index 082282f..495dd1b 100644 --- a/main.go +++ b/main.go @@ -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() } -- 2.38.4