diff --git a/go.mod b/go.mod index b25822cf9..771be199c 100644 --- a/go.mod +++ b/go.mod @@ -59,6 +59,7 @@ require ( github.com/multiformats/go-multiaddr-dns v0.0.3 github.com/multiformats/go-multiaddr-net v0.0.1 github.com/multiformats/go-multihash v0.0.6 + github.com/opentracing/opentracing-go v1.1.0 github.com/pkg/errors v0.8.1 github.com/polydawn/refmt v0.0.0-20190809202753-05966cbd336a github.com/smartystreets/assertions v1.0.1 // indirect diff --git a/lotuspond/main.go b/lotuspond/main.go index ef61d6e7a..2bd1ea3dd 100644 --- a/lotuspond/main.go +++ b/lotuspond/main.go @@ -19,7 +19,7 @@ type runningNode struct { cmd *exec.Cmd meta nodeInfo - mux *outmux + mux *outmux stop func() } diff --git a/lotuspond/outmux.go b/lotuspond/outmux.go index 831c41412..41dd655f5 100644 --- a/lotuspond/outmux.go +++ b/lotuspond/outmux.go @@ -19,19 +19,19 @@ type outmux struct { errpr *io.PipeReader outpr *io.PipeReader - n uint64 + n uint64 outs map[uint64]*websocket.Conn - new chan *websocket.Conn + new chan *websocket.Conn stop chan struct{} } func newWsMux() *outmux { out := &outmux{ - n: 0, + n: 0, outs: map[uint64]*websocket.Conn{}, - new: make(chan *websocket.Conn), - stop: make(chan struct{}), + new: make(chan *websocket.Conn), + stop: make(chan struct{}), } out.outpr, out.outpw = io.Pipe() @@ -121,4 +121,4 @@ func (m *outmux) ServeHTTP(w http.ResponseWriter, r *http.Request) { m.new <- c return -} \ No newline at end of file +}