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

client: rename frameBuffer into readBuffer

Browse Source
This commit is contained in:
aler9
2021-12-05 13:12:09 +01:00
parent 1a55cd6abf
commit 1878a72fd9
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
clientudpl.go
View File

@@ -33,7 +33,7 @@ type clientUDPListener struct {
trackID int trackID int
isRTP bool isRTP bool
running bool running bool
frameBuffer *multibuffer.MultiBuffer readBuffer *multibuffer.MultiBuffer
lastFrameTime *int64 lastFrameTime *int64
writeMutex sync.Mutex writeMutex sync.Mutex
processFunc func(time.Time, []byte) processFunc func(time.Time, []byte)
@@ -109,9 +109,9 @@ func newClientUDPListener(c *Client, multicast bool, address string) (*clientUDP
} }
return &clientUDPListener{ return &clientUDPListener{
c: c, c: c,
pc: pc, pc: pc,
frameBuffer: multibuffer.New(uint64(c.ReadBufferCount), uint64(c.ReadBufferSize)), readBuffer: multibuffer.New(uint64(c.ReadBufferCount), uint64(c.ReadBufferSize)),
lastFrameTime: func() *int64 { lastFrameTime: func() *int64 {
v := int64(0) v := int64(0)
return &v return &v
@@ -156,7 +156,7 @@ func (l *clientUDPListener) runReader() {
defer close(l.readerDone) defer close(l.readerDone)
for { for {
buf := l.frameBuffer.Next() buf := l.readBuffer.Next()
n, addr, err := l.pc.ReadFrom(buf) n, addr, err := l.pc.ReadFrom(buf)
if err != nil { if err != nil {
return return