drop the process markers from the remaining ceiling comments

This commit is contained in:
austinried
2026-10-04 00:30:05 +00:00
parent a79e05184d
commit d4f3b54574
3 changed files with 6 additions and 8 deletions
@@ -248,10 +248,9 @@ class DownloadRepository(
return@withContext
}
// Under one lock, so a cancel that lands mid-loop waits for the queue to be complete and
// then removes all of it, rather than missing the songs enqueued after it looked.
// ponytail: the lock is held for the whole insert pass, so cancel latency scales with the
// list length; the promote below hands over at most IN_FLIGHT_LIMIT, which is what keeps
// the platform's queue (and our poll writes) bounded.
// then removes all of it, rather than missing the songs enqueued after it looked. Holding
// it for the whole insert pass makes cancel latency scale with the list length; the promote
// below hands over at most IN_FLIGHT_LIMIT, which bounds the platform's queue.
val promoted =
mutex.withLock {
songIds.forEach { songId ->
@@ -93,8 +93,7 @@ class SyncService(
library.deleteOrphanPlaylistSongs(source.id)
}
// ponytail: one commit per batch means Room notifies paged observers once per batch; gate
// UI observation on SyncStatus.Running if that churn is ever noticeable.
// One commit per batch, so Room notifies paged observers once per batch rather than per row.
private suspend fun <T> write(
table: String,
columns: List<String>,
@@ -1465,8 +1465,8 @@ class PlaybackController(
const val SEED_PIN_TRIES = 1_000_000
const val FILE_SCHEME = "file:"
// ponytail: walks the queue one row at a time to find the next downloaded track; swap for a
// single query over the downloaded ids if a sparse queue ever makes the scan noticeable.
// The offline scan walks the queue one row at a time to find the next downloaded track, so
// this caps the work on a sparse queue.
const val OFFLINE_SCAN_LIMIT = 10_000L
}
}