kcp-go-plus/tx.go at master · pirateXD/kcp-go-plus

History

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

package kcp

import (

"sync/atomic"

"github.com/pkg/errors"

"golang.org/x/net/ipv4"

)

func (s *UDPSession) defaultTx(txqueue []ipv4.Message) {

nbytes := 0

npkts := 0

for k := range txqueue {

if n, err := s.conn.WriteTo(txqueue[k].Buffers[0], txqueue[k].Addr); err == nil {

nbytes += n

npkts++

} else {

s.notifyWriteError(errors.WithStack(err))

break

}

atomic.AddUint64(&DefaultSnmp.OutPkts, uint64(npkts))

atomic.AddUint64(&DefaultSnmp.OutBytes, uint64(nbytes))

}

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

tx.go

tx.go

Files

tx.go

Latest commit

History

tx.go

File metadata and controls