diff --git a/xfer/publisher.go b/xfer/publisher.go index 7dc8758f6..183841ccf 100644 --- a/xfer/publisher.go +++ b/xfer/publisher.go @@ -53,6 +53,11 @@ func (p *TCPPublisher) Publish(msg report.Report) { } func (p *TCPPublisher) loop(incoming <-chan net.Conn) { + type connEncoder struct { + net.Conn + *gob.Encoder + } + activeConns := map[string]connEncoder{} // host: connEncoder for { @@ -94,11 +99,6 @@ func (p *TCPPublisher) loop(incoming <-chan net.Conn) { } } -type connEncoder struct { - net.Conn - *gob.Encoder -} - func fwd(ln net.Listener) chan net.Conn { c := make(chan net.Conn)