[pitivi] pipeline: when not in RENDER, the pipeline can and must recover

[Mathieu Duponchelle <mathieudu src gnome org>]

commit 54dc09f5563c8274c513e4dd3ce6ec53f900affe
Author: Mathieu Duponchelle <mathieu duponchelle epitech eu>
Date:   Sun Aug 11 20:07:40 2013 +0200

    pipeline: when not in RENDER, the pipeline can and must recover
    
    ... from errors.

 pitivi/utils/pipeline.py |   15 +++++++++++++++
 1 files changed, 15 insertions(+), 0 deletions(-)
---
diff --git a/pitivi/utils/pipeline.py b/pitivi/utils/pipeline.py
index 3494899..c503e63 100644
--- a/pitivi/utils/pipeline.py
+++ b/pitivi/utils/pipeline.py
@@ -161,6 +161,8 @@ class SimplePipeline(Signallable, Loggable):
         self._listeningSigId = 0
         self._duration = Gst.CLOCK_TIME_NONE
         self.video_overlay = video_overlay
+        self.lastPosition = long(0 * Gst.SECOND)
+        self.pendingRecovery = False
 
     def release(self):
         """
@@ -326,6 +328,7 @@ class SimplePipeline(Signallable, Loggable):
             cur = self.getPosition()
             if cur != Gst.CLOCK_TIME_NONE:
                 self.emit('position', cur)
+                self.lastPosition = cur
         finally:
             return True
 
@@ -366,6 +369,8 @@ class SimplePipeline(Signallable, Loggable):
             self.debug("seeking failed")
             raise PipelineError("seek failed")
 
+        self.lastPosition = position
+
         self.debug("seeking successful")
         self.emit('position', position)
 
@@ -394,6 +399,9 @@ class SimplePipeline(Signallable, Loggable):
                     except PipelineError:
                         # no sinks??
                         pass
+                    if self.pendingRecovery:
+                        self.simple_seek(self.lastPosition)
+                        self.pendingRecovery = False
                 elif prev == Gst.State.PAUSED and new == Gst.State.PLAYING:
                     self._listenToPosition(True)
                 elif prev == Gst.State.PLAYING and new == Gst.State.PAUSED:
@@ -405,12 +413,19 @@ class SimplePipeline(Signallable, Loggable):
         elif message.type == Gst.MessageType.ERROR:
             error, detail = message.parse_error()
             self._handleErrorMessage(error, detail, message.src)
+            if not (self._pipeline.get_mode() & GES.PipelineFlags.RENDER):
+                self._recover()
         elif message.type == Gst.MessageType.DURATION_CHANGED:
             self.debug("Duration might have changed, querying it")
             GLib.idle_add(self._queryDurationAsync)
         else:
             self.log("%s [%r]" % (message.type, message.src))
 
+    def _recover(self):
+        self.pendingRecovery = True
+        self._pipeline.set_state(Gst.State.NULL)
+        self._pipeline.set_state(Gst.State.PAUSED)
+
     def _queryDurationAsync(self, *args, **kwargs):
         try:
             self.getDuration()