Browse Source

decrease ram consumption

pull/97/head
aler9 5 years ago
parent
commit
b526330607
  1. 2
      client.go
  2. 2
      server-udp.go
  3. 6
      source.go

2
client.go

@ -1162,7 +1162,7 @@ func (c *client) runRecordUDP() {
func (c *client) runRecordTCP() { func (c *client) runRecordTCP() {
frame := &gortsplib.InterleavedFrame{} frame := &gortsplib.InterleavedFrame{}
readBuf := newMultiBuffer(3, clientTCPReadBufferSize) readBuf := newMultiBuffer(2, clientTCPReadBufferSize)
readRequest := make(chan readRequestPair) readRequest := make(chan readRequestPair)
defer close(readRequest) defer close(readRequest)

2
server-udp.go

@ -35,7 +35,7 @@ func newServerUDP(p *program, port int, streamType gortsplib.StreamType) (*serve
p: p, p: p,
pc: pc, pc: pc,
streamType: streamType, streamType: streamType,
readBuf: newMultiBuffer(3, clientUDPReadBufferSize), readBuf: newMultiBuffer(2, clientUDPReadBufferSize),
writec: make(chan udpBufAddrPair), writec: make(chan udpBufAddrPair),
done: make(chan struct{}), done: make(chan struct{}),
} }

6
source.go

@ -225,7 +225,7 @@ func (s *source) runUDP(conn *gortsplib.ConnClient) bool {
go func(trackId int, rtpRead gortsplib.UDPReadFunc) { go func(trackId int, rtpRead gortsplib.UDPReadFunc) {
defer wg.Done() defer wg.Done()
multiBuf := newMultiBuffer(3, sourceUDPReadBufferSize) multiBuf := newMultiBuffer(2, sourceUDPReadBufferSize)
for { for {
buf := multiBuf.next() buf := multiBuf.next()
@ -246,7 +246,7 @@ func (s *source) runUDP(conn *gortsplib.ConnClient) bool {
go func(trackId int, rtcpRead gortsplib.UDPReadFunc) { go func(trackId int, rtcpRead gortsplib.UDPReadFunc) {
defer wg.Done() defer wg.Done()
multiBuf := newMultiBuffer(3, sourceUDPReadBufferSize) multiBuf := newMultiBuffer(2, sourceUDPReadBufferSize)
for { for {
buf := multiBuf.next() buf := multiBuf.next()
@ -312,7 +312,7 @@ func (s *source) runTCP(conn *gortsplib.ConnClient) bool {
s.p.sourceReady <- s s.p.sourceReady <- s
frame := &gortsplib.InterleavedFrame{} frame := &gortsplib.InterleavedFrame{}
multiBuf := newMultiBuffer(3, sourceTCPReadBufferSize) multiBuf := newMultiBuffer(2, sourceTCPReadBufferSize)
tcpConnDone := make(chan error) tcpConnDone := make(chan error)
go func() { go func() {

Loading…
Cancel
Save