Merge pull request #1577 from adamcik/fix/1553-mms-scanning-take-three

Improve duration workaround and change how we handle mms scanning again

docs/changelog.rst

@@ -38,9 +38,9 @@ Feature release.
 - MPD: Fix inconsistent playlist state after playlist is emptied with repeat
   and consume mode turned on. (Fixes: :issue:`1512`, PR: :issue:`1549`)
 
-- Audio: Fix handling of MMS (and any other streams) that can't switch to
+- Audio: Improve handling of duration in scanning. VBR tracks should fail less
-  playing ``ASYNC``. Previously we would time out trying to get a duration from
+  frequently and MMS works again. (Fixes: :issue:`1553`, PR :issue:`1575`,
-  these. (Fixes: :issue:`1553`, PR :issue:`1575`, :issue:`1576`)
+  :issue:`1576`, :issue:`1577`)
 
 
 v2.0.1 (2016-08-16)

mopidy/audio/scan.py

@@ -194,14 +194,13 @@ def _process(pipeline, timeout_ms):
     missing_message = None
     duration = None
 
-    # TODO: Turn this into a callback table to cleanup code.
     types = (
-        Gst.MessageType.APPLICATION |
-        Gst.MessageType.DURATION_CHANGED |
         Gst.MessageType.ELEMENT |
-        Gst.MessageType.EOS |
+        Gst.MessageType.APPLICATION |
         Gst.MessageType.ERROR |
-        Gst.MessageType.STATE_CHANGED |
+        Gst.MessageType.EOS |
+        Gst.MessageType.ASYNC_DONE |
+        Gst.MessageType.DURATION_CHANGED |
         Gst.MessageType.TAG
     )
 
@@ -213,8 +212,10 @@ def _process(pipeline, timeout_ms):
             break
 
         if logger.isEnabledFor(log.TRACE_LOG_LEVEL) and msg.get_structure():
-            _trace('element %s: %s', msg.src.get_name(),
+            debug_text = msg.get_structure().to_string()
-                   msg.get_structure().to_string())
+            if len(debug_text) > 77:
+                debug_text = debug_text[:77] + '...'
+            _trace('element %s: %s', msg.src.get_name(), debug_text)
 
         if msg.type == Gst.MessageType.ELEMENT:
             if GstPbutils.is_missing_plugin_message(msg):
@@ -236,30 +237,31 @@ def _process(pipeline, timeout_ms):
             raise exceptions.ScannerError(error)
         elif msg.type == Gst.MessageType.EOS:
             return tags, mime, have_audio, duration
-        elif msg.type == Gst.MessageType.STATE_CHANGED and msg.src == pipeline:
+        elif msg.type == Gst.MessageType.ASYNC_DONE:
-            old_state, new_state, pending = msg.parse_state_changed()
+            success, duration = _query_duration(pipeline)
+            if tags and success:
+                return tags, mime, have_audio, duration
 
-            if pending == Gst.State.VOID_PENDING:
+            # Don't try workaround for non-seekable sources such as mmssrc:
-                success, duration = _query_duration(pipeline)
+            if not _query_seekable(pipeline):
-                if tags and success:
+                return tags, mime, have_audio, duration
-                    return tags, mime, have_audio, duration
 
-                if new_state == Gst.State.PAUSED:
+            # Workaround for upstream bug which causes tags/duration to arrive
-                    # Workaround for upstream bug which causes tags/duration to
+            # after pre-roll. We get around this by starting to play the track
-                    # arrive after pre-roll. We get around this by starting to
+            # and then waiting for a duration change.
-                    # play the track and then waiting for a duration change.
+            # https://bugzilla.gnome.org/show_bug.cgi?id=763553
-                    # https://bugzilla.gnome.org/show_bug.cgi?id=763553
+            logger.debug('Using workaround for duration missing before play.')
-                    logger.debug('Using workaround for duration missing.')
+            result = pipeline.set_state(Gst.State.PLAYING)
-                    result = pipeline.set_state(Gst.State.PLAYING)
+            if result == Gst.StateChangeReturn.FAILURE:
-                    if result == Gst.StateChangeReturn.FAILURE:
+                return tags, mime, have_audio, duration
-                        return tags, mime, have_audio, duration
-                else:
-                    return tags, mime, have_audio, duration
 
-        elif msg.type == Gst.MessageType.DURATION_CHANGED:
+        elif msg.type == Gst.MessageType.DURATION_CHANGED and tags:
-            # duration will be read after ASYNC_DONE received; for now
+            # VBR formats sometimes seem to not have a duration by the time we
-            # just give it a non-None value to flag that we have a duration:
+            # go back to paused. So just try to get it right away.
-            duration = 0
+            success, duration = _query_duration(pipeline)
+            pipeline.set_state(Gst.State.PAUSED)
+            if success:
+                return tags, mime, have_audio, duration
         elif msg.type == Gst.MessageType.TAG:
             taglist = msg.parse_tag()
             # Note that this will only keep the last tag.
@@ -267,11 +269,6 @@ def _process(pipeline, timeout_ms):
 
         timeout = timeout_ms - (int(time.time() * 1000) - start)
 
-        # workaround for https://bugzilla.gnome.org/show_bug.cgi?id=763553:
-        # if we got what we want then stop playing (and wait for ASYNC_DONE)
-        if tags and duration is not None:
-            pipeline.set_state(Gst.State.PAUSED)
-
     raise exceptions.ScannerError('Timeout after %dms' % timeout_ms)
 
 
@@ -294,6 +291,9 @@ if __name__ == '__main__':
                 print('%-20s   %s' % (key, getattr(result, key)))
             print('tags')
             for tag, value in result.tags.items():
-                print('%-20s   %s' % (tag, value))
+                line = '%-20s   %s' % (tag, value)
+                if len(line) > 77:
+                    line = line[:77] + '...'
+                print(line)
         except exceptions.ScannerError as error:
             print('%s: %s' % (uri, error))