diff options
author | anon5 <anon5clam@protonmail.com> | 2021-03-22 18:37:36 +0000 |
---|---|---|
committer | anon5 <anon5clam@protonmail.com> | 2021-03-22 18:37:36 +0000 |
commit | 433955e45ef35476ab6863c4aff06b6ddd0bec67 (patch) | |
tree | 354f9f143c4ed56c79519519cf9d7af09802fd9a /rudp/net.go | |
parent | 1bae1f4f7ea371086d14b641d6a45aaa8feccb75 (diff) |
rudp: partial rewrite with new API supporting io.Readers
Diffstat (limited to 'rudp/net.go')
-rw-r--r-- | rudp/net.go | 41 |
1 files changed, 0 insertions, 41 deletions
diff --git a/rudp/net.go b/rudp/net.go deleted file mode 100644 index e2e7289..0000000 --- a/rudp/net.go +++ /dev/null @@ -1,41 +0,0 @@ -package rudp - -import ( - "errors" - "net" -) - -// ErrClosed is deprecated, use net.ErrClosed instead. -var ErrClosed = net.ErrClosed - -/* -netPkt.Data format (big endian): - - ProtoID - Src PeerID - ChNo uint8 // Must be < ChannelCount. - RawPkt.Data -*/ -type netPkt struct { - SrcAddr net.Addr - Data []byte -} - -func readNetPkts(conn net.PacketConn, pkts chan<- netPkt, errs chan<- error) { - for { - buf := make([]byte, MaxNetPktSize) - n, addr, err := conn.ReadFrom(buf) - if err != nil { - if errors.Is(err, net.ErrClosed) { - break - } - - errs <- err - continue - } - - pkts <- netPkt{addr, buf[:n]} - } - - close(pkts) -} |