From 49cb73af81d6932f2b64f95b173cae6414d509ca Mon Sep 17 00:00:00 2001 From: xtaci Date: Mon, 13 May 2019 21:50:55 +0800 Subject: [PATCH] rename var --- readloop_linux.go | 10 +++++----- sess.go | 6 +++--- tx_linux.go | 2 +- 3 files changed, 9 insertions(+), 9 deletions(-) diff --git a/readloop_linux.go b/readloop_linux.go index 5e0338b..5ce3999 100644 --- a/readloop_linux.go +++ b/readloop_linux.go @@ -20,7 +20,7 @@ func (s *UDPSession) readLoop() { } for { - if count, err := s.bconn.ReadBatch(msgs, 0); err == nil { + if count, err := s.xconn.ReadBatch(msgs, 0); err == nil { for i := 0; i < count; i++ { msg := &msgs[i] // make sure the packet is from the same source @@ -49,11 +49,11 @@ func (s *UDPSession) readLoop() { // monitor incoming data for all connections of server func (l *Listener) monitor() { addr, _ := net.ResolveUDPAddr("udp", l.conn.LocalAddr().String()) - var conn batchConn + var xconn batchConn if addr.IP.To4() != nil { - conn = ipv4.NewPacketConn(l.conn) + xconn = ipv4.NewPacketConn(l.conn) } else { - conn = ipv6.NewPacketConn(l.conn) + xconn = ipv6.NewPacketConn(l.conn) } msgs := make([]ipv4.Message, batchSize) @@ -62,7 +62,7 @@ func (l *Listener) monitor() { } for { - if count, err := conn.ReadBatch(msgs, 0); err == nil { + if count, err := xconn.ReadBatch(msgs, 0); err == nil { for i := 0; i < count; i++ { msg := &msgs[i] if msg.N >= l.headerSize+IKCP_OVERHEAD { diff --git a/sess.go b/sess.go index 72901fc..87fcc90 100644 --- a/sess.go +++ b/sess.go @@ -98,7 +98,7 @@ type ( // packets waiting to be sent on wire txqueue []ipv4.Message - bconn batchConn // for casting of batchConn + xconn batchConn // for x/net mu sync.Mutex } @@ -131,9 +131,9 @@ func newUDPSession(conv uint32, dataShards, parityShards int, l *Listener, conn // cast to writebatch conn addr, _ := net.ResolveUDPAddr("udp", conn.LocalAddr().String()) if addr.IP.To4() != nil { - sess.bconn = ipv4.NewPacketConn(conn) + sess.xconn = ipv4.NewPacketConn(conn) } else { - sess.bconn = ipv6.NewPacketConn(conn) + sess.xconn = ipv6.NewPacketConn(conn) } // FEC codec initialization diff --git a/tx_linux.go b/tx_linux.go index 0b4c031..6e03971 100644 --- a/tx_linux.go +++ b/tx_linux.go @@ -13,7 +13,7 @@ func (s *UDPSession) tx(txqueue []ipv4.Message) { nbytes := 0 npkts := 0 for len(txqueue) > 0 { - if n, err := s.bconn.WriteBatch(txqueue, 0); err == nil { + if n, err := s.xconn.WriteBatch(txqueue, 0); err == nil { for k := range txqueue[:n] { nbytes += len(txqueue[k].Buffers[0]) xmitBuf.Put(txqueue[k].Buffers[0])