dandri/livekit
1
0
Fork 0
mirror of https://github.com/livekit/livekit.git synced 2026-03-29 09:19:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix data channel slow reader test (#3453)

Browse Source
This commit is contained in:
cnderrauber
2025-02-20 10:40:25 +08:00
committed by GitHub
parent f49103a003
commit 4b04b26a73
2 changed files with 14 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
test/client/datachannel_reader.go
View File

@@ -20,7 +20,7 @@ func NewDataChannelReader(bitrate int) *DataChannelReader {
func (d *DataChannelReader) Read(p []byte, sid string) {
for {
if bitrate, ok := d.bitrate.Bitrate(time.Now()); ok && bitrate > 0 && bitrate > d.target {
if bitrate, ok := d.bitrate.ForceBitrate(time.Now()); ok && bitrate > 0 && bitrate > d.target {
time.Sleep(10 * time.Millisecond)
d.bitrate.AddBytes(0, 0, time.Now())
continue
@@ -29,8 +29,3 @@ func (d *DataChannelReader) Read(p []byte, sid string) {
}
d.bitrate.AddBytes(len(p), 0, time.Now())
}
func (d *DataChannelReader) Bitrate() int {
b, _ := d.bitrate.Bitrate(time.Now())
return b
}