Changeset 587

Timestamp:

12-07-12 11:38:59 (11 months ago)

Author:

thomas

Message:

add new file

Location:

trunk/morituri/common

Files:

• checksum.py (modified) (3 diffs)
• encode.py (modified) (4 diffs)
• task.py (added)

trunk/morituri/common/checksum.py

@@ -7 +7 @@
 
 # This file is part of morituri.
-# 
+#
 # morituri is free software: you can redistribute it and/or modify
 # it under the terms of the GNU General Public License as published by
 # the Free Software Foundation, either version 3 of the License, or
 # (at your option) any later version.
-# 
+#
 # morituri is distributed in the hope that it will be useful,
 # but WITHOUT ANY WARRANTY; without even the implied warranty of
 # MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 # GNU General Public License for more details.
-# 
+#
 # You should have received a copy of the GNU General Public License
 # along with morituri.  If not, see <http://www.gnu.org/licenses/>.
@@ -144 +144 @@
 
     def stopped(self):
+        self.debug('stopped')
         if not self._last:
+            self.debug('raising EmptyError')
             # see http://bugzilla.gnome.org/show_bug.cgi?id=578612
             self.debug('not a single buffer gotten, raising')
@@ -270 +272 @@
         return checksum
 
-class TRMTask(gstreamer.GstPipelineTask):
+class TRMTask(task.GstPipelineTask):
     """
     I calculate a MusicBrainz TRM fingerprint.

trunk/morituri/common/encode.py

@@ -27 +27 @@
 
 from morituri.common import common, log
+from morituri.common import task as ctask
 
 from morituri.extern.task import task, gstreamer
@@ -125 +126 @@
 ALL_PROFILES.update(LOSSY_PROFILES)
 
-class EncodeTask(gstreamer.GstPipelineTask):
+class EncodeTask(ctask.GstPipelineTask):
     """
     I am a task that encodes a .wav file.
@@ -219 +220 @@
         bus.connect('message::element', self._message_element_cb)
         self._level = self.pipeline.get_by_name('level')
+
+        # set an interval that is smaller than the duration
+        # FIXME: check level and make sure it emits level up to the last
+        # sample, even if input is small
+        interval = 1000000000L
+        if interval < duration:
+            interval = duration / 2
+        self._level.set_property('interval', interval)
         # add a probe so we can track progress
         # we connect to level because this gives us offset in samples
@@ -269 +278 @@
         else:
             self.warning('No peak found, something went wrong!')
+            # workaround for when the file is too short to have volume ?
+            # self.peak = 0.0
 
 class TagReadTask(gstreamer.GstPipelineTask):