Progressively draw the debug level distribution into the timeline widget

diff --git a/debug-viewer/GstDebugViewer/Plugins/Timeline.py b/debug-viewer/GstDebugViewer/Plugins/Timeline.py
index e3f8300fbff4337bb989211d11d07389d08c85e4..85b81386289523360711d96d29bda6d266314b1c 100644 (file)
--- a/debug-viewer/GstDebugViewer/Plugins/Timeline.py
+++ b/debug-viewer/GstDebugViewer/Plugins/Timeline.py
@@ -126,7 +126,8 @@ class LevelDistributionSentinel (object):
         model_next = self.model.iter_next
         id_time = self.model.COL_TIME
         id_level = self.model.COL_LEVEL
-        result = []
+        del self.data[:]
+        data = self.data
         i = 0
         partitions_i = 0
         partitions = self.freq_sentinel.partitions
@@ -139,7 +140,7 @@ class LevelDistributionSentinel (object):
                 yield True
             level = model_get (tree_iter, id_level)
             if i > partitions[partitions_i]:
-                result.append (tuple (counts))
+                data.append (tuple (counts))
                 counts = [0] * 6
                 partitions_i += 1
                 if partitions_i == len (partitions):
@@ -151,8 +152,6 @@ class LevelDistributionSentinel (object):
 
         # FIXME: We lose the last partition here!
 
-        self.data = result
-
         yield False
 
 class UpdateProcess (object):
@@ -175,6 +174,7 @@ class UpdateProcess (object):
 
         for x in self.dist_sentinel.process ():
             yield True
+            self.handle_sentinel_progress (self.dist_sentinel)
 
         self.is_running = False
 
@@ -198,6 +198,10 @@ class UpdateProcess (object):
         self.dispatcher.cancel ()
         self.is_running = False
 
+    def handle_sentinel_progress (self, sentinel):
+
+        pass
+
     def handle_sentinel_finished (self, sentinel):
 
         pass
@@ -222,11 +226,16 @@ class TimelineWidget (gtk.DrawingArea):
         self.connect ("expose-event", self.__handle_expose_event)
         self.connect ("configure-event", self.__handle_configure_event)
         self.connect ("size-request", self.__handle_size_request)
+        self.process.handle_sentinel_progress = self.handle_sentinel_progress
         self.process.handle_sentinel_finished = self.handle_sentinel_finished
         self.process.handle_process_finished = self.handle_process_finished
 
         self.__offscreen = None
 
+    def handle_sentinel_progress (self, sentinel):
+
+        self.__redraw ()
+
     def handle_sentinel_finished (self, sentinel):
 
         if sentinel == self.freq_sentinel: