Add recv/send counters to xiaomi source
This commit is contained in:
@@ -31,6 +31,7 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
|
|||||||
buf = append(buf, transcode(pkt.Payload)...)
|
buf = append(buf, transcode(pkt.Payload)...)
|
||||||
const size = 2 * 8000 * 0.040 // 16bit 40ms
|
const size = 2 * 8000 * 0.040 // 16bit 40ms
|
||||||
for len(buf) >= size {
|
for len(buf) >= size {
|
||||||
|
p.Send += size
|
||||||
_ = p.client.WriteAudio(miss.CodecPCM, buf[:size])
|
_ = p.client.WriteAudio(miss.CodecPCM, buf[:size])
|
||||||
buf = buf[size:]
|
buf = buf[size:]
|
||||||
}
|
}
|
||||||
@@ -40,6 +41,7 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
|
|||||||
buf = append(buf, pkt.Payload...)
|
buf = append(buf, pkt.Payload...)
|
||||||
const size = 8000 * 0.040 // 8bit 40 ms
|
const size = 8000 * 0.040 // 8bit 40 ms
|
||||||
for len(buf) >= size {
|
for len(buf) >= size {
|
||||||
|
p.Send += size
|
||||||
_ = p.client.WriteAudio(miss.CodecPCMA, buf[:size])
|
_ = p.client.WriteAudio(miss.CodecPCMA, buf[:size])
|
||||||
buf = buf[size:]
|
buf = buf[size:]
|
||||||
}
|
}
|
||||||
@@ -54,12 +56,14 @@ func (p *Producer) AddTrack(media *core.Media, _ *core.Codec, track *core.Receiv
|
|||||||
} else {
|
} else {
|
||||||
// convert two 20ms to one 40ms
|
// convert two 20ms to one 40ms
|
||||||
buf = opus.JoinFrames(buf, pkt.Payload)
|
buf = opus.JoinFrames(buf, pkt.Payload)
|
||||||
|
p.Send += len(buf)
|
||||||
_ = p.client.WriteAudio(miss.CodecOPUS, buf)
|
_ = p.client.WriteAudio(miss.CodecOPUS, buf)
|
||||||
buf = nil
|
buf = nil
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
sender.Handler = func(pkt *rtp.Packet) {
|
sender.Handler = func(pkt *rtp.Packet) {
|
||||||
|
p.Send += len(pkt.Payload)
|
||||||
_ = p.client.WriteAudio(miss.CodecOPUS, pkt.Payload)
|
_ = p.client.WriteAudio(miss.CodecOPUS, pkt.Payload)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -164,6 +164,8 @@ func (p *Producer) Start() error {
|
|||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
p.Recv += len(pkt.Payload)
|
||||||
|
|
||||||
// TODO: rewrite this
|
// TODO: rewrite this
|
||||||
var name string
|
var name string
|
||||||
var pkt2 *core.Packet
|
var pkt2 *core.Packet
|
||||||
|
|||||||
Reference in New Issue
Block a user