package/gortsplib
1
0
Fork 0
mirror of https://github.com/aler9/gortsplib synced 2025-10-05 07:06:58 +08:00
Code Issues Packages Projects Releases Wiki Activity

server: rename readBuf into readBuffer

Browse Source
This commit is contained in:
aler9
2021-12-04 22:45:09 +01:00
parent 4621d5f7be
commit 015cbf660d
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
serverudpl.go
View File

@@ -52,7 +52,7 @@ type serverUDPListener struct {
listenIP net.IP listenIP net.IP
isRTP bool isRTP bool
writeTimeout time.Duration writeTimeout time.Duration
readBuf *multibuffer.MultiBuffer readBuffer *multibuffer.MultiBuffer
clientsMutex sync.RWMutex clientsMutex sync.RWMutex
clients map[clientAddr]*clientData clients map[clientAddr]*clientData
ringBuffer *ringbuffer.RingBuffer ringBuffer *ringbuffer.RingBuffer
@@ -150,7 +150,7 @@ func newServerUDPListener(
clients: make(map[clientAddr]*clientData), clients: make(map[clientAddr]*clientData),
isRTP: isRTP, isRTP: isRTP,
writeTimeout: s.WriteTimeout, writeTimeout: s.WriteTimeout,
readBuf: multibuffer.New(uint64(s.ReadBufferCount), uint64(s.ReadBufferSize)), readBuffer: multibuffer.New(uint64(s.ReadBufferCount), uint64(s.ReadBufferSize)),
ringBuffer: ringbuffer.New(uint64(s.ReadBufferCount)), ringBuffer: ringbuffer.New(uint64(s.ReadBufferCount)),
} }
@@ -187,7 +187,7 @@ func (u *serverUDPListener) run() {
defer u.wg.Done() defer u.wg.Done()
for { for {
buf := u.readBuf.Next() buf := u.readBuffer.Next()
n, addr, err := u.pc.ReadFromUDP(buf) n, addr, err := u.pc.ReadFromUDP(buf)
if err != nil { if err != nil {
break break