check if fromDiscordMap channel is full
This commit is contained in:
parent
d9d30929ff
commit
f8518176d5
16
discord.go
16
discord.go
@ -153,10 +153,22 @@ func discordReceivePCM(v *discordgo.VoiceConnection, die chan bool) {
|
|||||||
OnError("Error decoding opus data", err)
|
OnError("Error decoding opus data", err)
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
if len(p.PCM) != 960 {
|
||||||
|
log.Println("Opus size error")
|
||||||
|
continue
|
||||||
|
}
|
||||||
|
|
||||||
discordMutex.Lock()
|
discordMutex.Lock()
|
||||||
fromDiscordMap[p.SSRC].pcm <- p.PCM[0:480]
|
select {
|
||||||
fromDiscordMap[p.SSRC].pcm <- p.PCM[480:960]
|
case fromDiscordMap[p.SSRC].pcm <- p.PCM[0:480]:
|
||||||
|
default:
|
||||||
|
log.Println("fromDiscordMap buffer full. Dropping packet")
|
||||||
|
}
|
||||||
|
select {
|
||||||
|
case fromDiscordMap[p.SSRC].pcm <- p.PCM[480:960]:
|
||||||
|
default:
|
||||||
|
log.Println("fromDiscordMap buffer full. Dropping packet")
|
||||||
|
}
|
||||||
discordMutex.Unlock()
|
discordMutex.Unlock()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user