mirror of
https://github.com/AlexxIT/go2rtc.git
synced 2025-09-26 20:31:11 +08:00
Compare commits
4 Commits
3e1b01073b
...
699a995e8c
Author | SHA1 | Date | |
---|---|---|---|
![]() |
699a995e8c | ||
![]() |
ce02b03a73 | ||
![]() |
487527f5a5 | ||
![]() |
0669cfbebf |
@@ -97,13 +97,17 @@ func NewSender(media *Media, codec *Codec) *Sender {
|
|||||||
buf: buf,
|
buf: buf,
|
||||||
}
|
}
|
||||||
s.Input = func(packet *Packet) {
|
s.Input = func(packet *Packet) {
|
||||||
// writing to nil chan - OK, writing to closed chan - panic
|
|
||||||
s.mu.Lock()
|
s.mu.Lock()
|
||||||
select {
|
if s.buf != nil {
|
||||||
case s.buf <- packet:
|
// unblocked write to channel
|
||||||
s.Bytes += len(packet.Payload)
|
select {
|
||||||
s.Packets++
|
case s.buf <- packet:
|
||||||
default:
|
s.Bytes += len(packet.Payload)
|
||||||
|
s.Packets++
|
||||||
|
default:
|
||||||
|
s.Drops++
|
||||||
|
}
|
||||||
|
} else {
|
||||||
s.Drops++
|
s.Drops++
|
||||||
}
|
}
|
||||||
s.mu.Unlock()
|
s.mu.Unlock()
|
||||||
@@ -139,13 +143,13 @@ func (s *Sender) Start() {
|
|||||||
}
|
}
|
||||||
s.done = make(chan struct{})
|
s.done = make(chan struct{})
|
||||||
|
|
||||||
go func() {
|
// pass buf directly so that it's impossible for buf to be nil
|
||||||
// for range on nil chan is OK
|
go func(buf chan *Packet) {
|
||||||
for packet := range s.buf {
|
for packet := range buf {
|
||||||
s.Output(packet)
|
s.Output(packet)
|
||||||
}
|
}
|
||||||
close(s.done)
|
close(s.done)
|
||||||
}()
|
}(s.buf)
|
||||||
}
|
}
|
||||||
|
|
||||||
func (s *Sender) Wait() {
|
func (s *Sender) Wait() {
|
||||||
|
Reference in New Issue
Block a user