diff --git a/derp/derp_server.go b/derp/derp_server.go index 08df9b724..12eb01240 100644 --- a/derp/derp_server.go +++ b/derp/derp_server.go @@ -235,7 +235,7 @@ func (s *Server) accept(nc Conn, brw *bufio.ReadWriter, remoteAddr string) error done: ctx.Done(), remoteAddr: remoteAddr, connectedAt: time.Now(), - sendQueue: make(chan sendMsg, perClientSendQueueDepth), + sendQueue: make(chan pkt, perClientSendQueueDepth), } if clientInfo != nil { c.info = *clientInfo @@ -311,11 +311,11 @@ func (c *sclient) handleFrameSendPacket(ft frameType, fl uint32) error { return nil } - msg := sendMsg{ + p := pkt{ bs: contents, } if dst.info.Version >= protocolSrcAddrs { - msg.src = c.key + p.src = c.key } // Attempt to queue for sending up to 3 times. On each attempt, if // the queue is full, try to drop from queue head to prioritize @@ -332,7 +332,7 @@ func (c *sclient) handleFrameSendPacket(ft frameType, fl uint32) error { default: } select { - case dst.sendQueue <- msg: + case dst.sendQueue <- p: return nil default: } @@ -471,7 +471,7 @@ type sclient struct { logf logger.Logf done <-chan struct{} // closed when connection closes remoteAddr string // usually ip:port from net.Conn.RemoteAddr().String() - sendQueue chan sendMsg // messages (packets) queued to this client; never closed + sendQueue chan pkt // packets queued to this client; never closed // Owned by run, not thread-safe. br *bufio.Reader @@ -482,13 +482,13 @@ type sclient struct { bw *bufio.Writer } -// sendMsg is a request to write a frame to an sclient (usually a data packet). -type sendMsg struct { +// pkt is a request to write a data frame to an sclient. +type pkt struct { // src is the who's the sender of the packet. src key.Public // bs is the data packet bytes. - // The memory is owned by sendMsg. + // The memory is owned by pkt. bs []byte // TODO(danderson): enqueue time, to measure queue latency?