dev → main: Android UPnP/Sonos transport parity + server stream URL extension #79
+6
-3
@@ -353,11 +353,13 @@ class OutputPickerController @Inject constructor(
|
|||||||
)
|
)
|
||||||
var consecutiveFailures = 0
|
var consecutiveFailures = 0
|
||||||
var succeeded = 0
|
var succeeded = 0
|
||||||
|
var aborted = false
|
||||||
for ((i, ref) in tracks.withIndex()) {
|
for ((i, ref) in tracks.withIndex()) {
|
||||||
|
if (aborted) break
|
||||||
if (activeUpnpHolder.active.value?.routeId != route.id) {
|
if (activeUpnpHolder.active.value?.routeId != route.id) {
|
||||||
Timber.w("UPnP extend: cancelled at offset %d (route changed)", i)
|
Timber.w("UPnP extend: cancelled at offset %d (route changed)", i)
|
||||||
break
|
aborted = true
|
||||||
}
|
} else {
|
||||||
val outcome = runCatching {
|
val outcome = runCatching {
|
||||||
val token = streamTokens.mint(ref.id)
|
val token = streamTokens.mint(ref.id)
|
||||||
transport.addURIToQueue(
|
transport.addURIToQueue(
|
||||||
@@ -382,7 +384,8 @@ class OutputPickerController @Inject constructor(
|
|||||||
"UPnP extend: aborting after %d consecutive failures",
|
"UPnP extend: aborting after %d consecutive failures",
|
||||||
consecutiveFailures,
|
consecutiveFailures,
|
||||||
)
|
)
|
||||||
break
|
aborted = true
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user