From fdf2e3f8a50c8436e2309ec7d376388392750d5f Mon Sep 17 00:00:00 2001 From: David Florness Date: Fri, 5 Jun 2020 03:24:04 -0600 Subject: [PATCH] Private var names start with lowercase letter --- main.go | 24 ++++++++++++------------ master.go | 2 +- 2 files changed, 13 insertions(+), 13 deletions(-) diff --git a/main.go b/main.go index ea9beea..082282f 100644 --- a/main.go +++ b/main.go @@ -27,7 +27,7 @@ import ( type ElectionOption string var ( - Logger = log.Logger("tallyard") + logger = log.Logger("tallyard") ProtocolID = protocol.ID("/tallyard/0.0.0") electionOptions []ElectionOption @@ -107,13 +107,13 @@ func joinElection() { if err != nil { panic(err) } - Logger.Info("merkle root:", merkleRoot) + logger.Info("merkle root:", merkleRoot) masterID, err = peer.Decode(electionKey[zeroi+1:]) if err != nil { panic(err) } - Logger.Info("master ID:", masterID) + logger.Info("master ID:", masterID) }) if err := app.SetRoot(form, true).EnableMouse(true).Run(); err != nil { panic(err) @@ -150,7 +150,7 @@ func bootstrap() { if err != nil { return kdht, err } - Logger.Info("boostrapping the DHT") + logger.Info("boostrapping the DHT") if err = kdht.Bootstrap(ctx); err != nil { panic(err) } @@ -161,8 +161,8 @@ func bootstrap() { panic(err) } - Logger.Info("host:", h.ID()) - Logger.Info(h.Addrs()) + logger.Info("host:", h.ID()) + logger.Info(h.Addrs()) var wg sync.WaitGroup for _, peerAddr := range dht.DefaultBootstrapPeers { @@ -171,9 +171,9 @@ func bootstrap() { go func() { defer wg.Done() if err := h.Connect(ctx, *peerInfo); err != nil { - Logger.Warning(err) + logger.Warning(err) } else { - Logger.Info("connection established with bootstrap node:", *peerInfo) + logger.Info("connection established with bootstrap node:", *peerInfo) } }() } @@ -184,16 +184,16 @@ func bootstrap() { fmt.Printf("%s0%s\n", base58.Encode(optionsMerkle.MerkleRoot()), h.ID()) - Logger.Info("waiting for incoming streams...") + logger.Info("waiting for incoming streams...") h.SetStreamHandler(ProtocolID, masterStreamHandler) } else { // we are a slave - Logger.Info("attempting to open stream with master peer...") + logger.Info("attempting to open stream with master peer...") stream, err := h.NewStream(ctx, masterID, ProtocolID) rw := bufio.NewReadWriter(bufio.NewReader(stream), bufio.NewWriter(stream)) if err != nil { panic(err) } - Logger.Info("opened stream with master peer") + logger.Info("opened stream with master peer") _, err = rw.WriteString("options\n") if err != nil { panic(err) @@ -213,7 +213,7 @@ func bootstrap() { fmt.Println(str) } stream.Close() - Logger.Info("stream with master peer closed") + logger.Info("stream with master peer closed") checkMerkle() } } diff --git a/master.go b/master.go index d64a8cd..33f2f21 100644 --- a/master.go +++ b/master.go @@ -20,7 +20,7 @@ func handleMasterCmd(cmd string, writer *bufio.Writer) { } func masterStreamHandler(stream network.Stream) { - Logger.Info("got a new stream!") + logger.Info("got a new stream!") rw := bufio.NewReadWriter(bufio.NewReader(stream), bufio.NewWriter(stream)) cmd, err := rw.ReadString('\n') -- 2.38.4