deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

Send updated load synchronously, assert on errors while waiting.

Browse source
This commit is contained in:
Joachim Bauch 2025-12-17 11:22:41 +01:00
commit f517e554fe
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
mcu_proxy_test.go
View file

@ -717,7 +717,7 @@ func (h *TestProxyServerHandler) updateLoad(delta int64) {
msg := h.getLoadMessage(load)
for _, c := range h.clients {
go c.sendMessage(msg)
c.sendMessage(msg)
}
}
@ -1292,7 +1292,7 @@ func Test_ProxyPublisherBandwidth(t *testing.T) {
}
// Wait until proxy has been updated
for ctx.Err() == nil {
for assert.NoError(t, ctx.Err()) {
mcu.connectionsMu.RLock()
connections := mcu.connections
mcu.connectionsMu.RUnlock()
@ -1364,7 +1364,7 @@ func Test_ProxyPublisherBandwidthOverload(t *testing.T) {
}
// Wait until proxy has been updated
for ctx.Err() == nil {
for assert.NoError(t, ctx.Err()) {
mcu.connectionsMu.RLock()
connections := mcu.connections
mcu.connectionsMu.RUnlock()
@ -1660,7 +1660,7 @@ func Test_ProxySubscriberBandwidth(t *testing.T) {
serverDE.UpdateBandwidth(0, 100)
// Wait until proxy has been updated
for ctx.Err() == nil {
for assert.NoError(t, ctx.Err()) {
mcu.connectionsMu.RLock()
connections := mcu.connections
mcu.connectionsMu.RUnlock()
@ -1724,7 +1724,7 @@ func Test_ProxySubscriberBandwidthOverload(t *testing.T) {
serverUS.UpdateBandwidth(0, 102)
// Wait until proxy has been updated
for ctx.Err() == nil {
for assert.NoError(t, ctx.Err()) {
mcu.connectionsMu.RLock()
connections := mcu.connections
mcu.connectionsMu.RUnlock()