hoelee/tubesync
1
0
Fork 0
mirror of https://github.com/meeb/tubesync.git synced 2025-06-25 06:26:37 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Handle unbalanced channels better

Browse Source
This commit is contained in:
tcely 2025-05-19 01:44:49 -04:00 committed by GitHub
parent c7c37b12d8
commit e84643b95e
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
tubesync/sync/models/source.py
View File

@ -544,10 +544,15 @@ class Source(db.models.Model):
if not self.is_playlist: if not self.is_playlist:
if self.index_streams: if self.index_streams:
streams = self.get_index('streams') streams = self.get_index('streams')
# do not allow streams to consume all of the queue if entries.maxlen is None or 0 == len(entries):
if entries.maxlen and entries.maxlen <= len(streams): entries.extend(streams)
streams = streams[-1 * ( entries.maxlen // 2 ) :] else:
entries.extend(reversed(streams)) # share the queue between streams and videos
allowed_streams = max(
entries.maxlen // 2,
entries.maxlen - len(entries),
)
entries.extend(streams[-1 * allowed_streams :])
return entries return entries