We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 162e58c commit df87667Copy full SHA for df87667
server/channel.go
@@ -3,8 +3,10 @@ package server
3
import (
4
"context"
5
"errors"
6
+ "runtime"
7
"sync"
8
"sync/atomic"
9
+ "time"
10
11
"github.com/zijiren233/gencontainer/rwmap"
12
"github.com/zijiren233/livelib/av"
@@ -182,8 +184,16 @@ func (c *Channel) InitHlsPlayer(conf ...hls.SourceConf) error {
182
184
go func() {
183
185
for {
186
if err := c.AddPlayer(p); err != nil {
- p.Close()
- return
187
+ if errors.Is(err, ErrClosed) {
188
+ p.Close()
189
+ return
190
+ }
191
+ if errors.Is(err, ErrPusherNotInPublication) {
192
+ time.Sleep(time.Second)
193
+ } else {
194
+ runtime.Gosched()
195
196
+ continue
197
}
198
_ = p.SendPacket(context.Background())
199
p.Close()
0 commit comments