mirror of
https://github.com/livekit/livekit.git
synced 2026-10-23 21:44:29 +00:00
Update go deps (#1402)
* Update go deps Generated by renovateBot * use generics with Deque --------- Co-authored-by: renovate[bot] <29139614+renovate[bot]@users.noreply.github.com> Co-authored-by: David Zhao <dz@livekit.io>
This commit is contained in:
1 parent
576eb7abbd
commit
2fce780ce8
5 files changed
+24
-24
No files matched your search
@@ -34,7 +34,7 @@ type PublicationMonitor struct {
|
||||
params PublicationMonitorParams
|
||||
|
||||
lock sync.RWMutex
|
||||
desiredPublishes deque.Deque
|
||||
desiredPublishes deque.Deque[*publish]
|
||||
|
||||
isConnected bool
|
||||
|
||||
@@ -128,7 +128,7 @@ func (p *PublicationMonitor) Check() error {
|
||||
p.lock.RLock()
|
||||
var pub *publish
|
||||
if p.desiredPublishes.Len() > 0 {
|
||||
pub = p.desiredPublishes.Front().(*publish)
|
||||
pub = p.desiredPublishes.Front()
|
||||
}
|
||||
|
||||
isMuted := p.isMuted
|
||||
@@ -160,7 +160,7 @@ func (p *PublicationMonitor) update() {
|
||||
for {
|
||||
var pub *publish
|
||||
if p.desiredPublishes.Len() > 0 {
|
||||
pub = p.desiredPublishes.PopFront().(*publish)
|
||||
pub = p.desiredPublishes.PopFront()
|
||||
}
|
||||
|
||||
if pub == nil {
|
||||
|
||||
@@ -52,7 +52,7 @@ type Buffer struct {
|
||||
videoPool *sync.Pool
|
||||
audioPool *sync.Pool
|
||||
codecType webrtc.RTPCodecType
|
||||
extPackets deque.Deque
|
||||
extPackets deque.Deque[*ExtPacket]
|
||||
pPackets []pendingPacket
|
||||
closeOnce sync.Once
|
||||
mediaSSRC uint32
|
||||
@@ -290,7 +290,7 @@ func (b *Buffer) ReadExtended(buf []byte) (*ExtPacket, error) {
|
||||
}
|
||||
b.Lock()
|
||||
if b.extPackets.Len() > 0 {
|
||||
ep := b.extPackets.PopFront().(*ExtPacket)
|
||||
ep := b.extPackets.PopFront()
|
||||
ep = b.patchExtPacket(ep, buf)
|
||||
if ep == nil {
|
||||
b.Unlock()
|
||||
|
||||
+3
-3
@@ -132,7 +132,7 @@ type Prober struct {
|
||||
clusterId atomic.Uint32
|
||||
|
||||
clustersMu sync.RWMutex
|
||||
clusters deque.Deque
|
||||
clusters deque.Deque[*Cluster]
|
||||
activeCluster *Cluster
|
||||
activeStateQueue []bool
|
||||
activeStateQueueInProcess atomic.Bool
|
||||
@@ -238,7 +238,7 @@ func (p *Prober) getFrontCluster() *Cluster {
|
||||
if p.clusters.Len() == 0 {
|
||||
p.activeCluster = nil
|
||||
} else {
|
||||
p.activeCluster = p.clusters.Front().(*Cluster)
|
||||
p.activeCluster = p.clusters.Front()
|
||||
p.activeCluster.Start()
|
||||
}
|
||||
return p.activeCluster
|
||||
@@ -253,7 +253,7 @@ func (p *Prober) popFrontCluster(cluster *Cluster) {
|
||||
return
|
||||
}
|
||||
|
||||
if p.clusters.Front().(*Cluster) == cluster {
|
||||
if p.clusters.Front() == cluster {
|
||||
p.clusters.PopFront()
|
||||
}
|
||||
|
||||
|
||||
Reference in new issue
Block a user