arek - in flumotion/trunk: . flumotion/component/consumers/disker

[flumotion-commit at lists.fluendo.com]

Author: arek
Date: Wed Jul 25 18:50:56 2007
New Revision: 5359

Modified:
   flumotion/trunk/ChangeLog
   flumotion/trunk/flumotion/component/consumers/disker/disker.py
Log:
	* flumotion/component/consumers/disker/disker.py
	  (Disker._plug_recording_started, Disker._plug_recording_stopped):
	Add plug socket checks, fixes #730.



Modified: flumotion/trunk/ChangeLog
==============================================================================
--- flumotion/trunk/ChangeLog	(original)
+++ flumotion/trunk/ChangeLog	Wed Jul 25 18:50:56 2007
@@ -1,3 +1,9 @@
+2007-07-25  Arek Korbik  <arkadini at gmail.com>
+
+	* flumotion/component/consumers/disker/disker.py
+	  (Disker._plug_recording_started, Disker._plug_recording_stopped):
+	Add plug socket checks, fixes #730.
+
 2007-07-25  Andy Wingo  <wingo at pobox.com>
 
 	* flumotion/job/job.py (JobMedium.remote_bootstrap): Allow

Modified: flumotion/trunk/flumotion/component/consumers/disker/disker.py
==============================================================================
--- flumotion/trunk/flumotion/component/consumers/disker/disker.py	(original)
+++ flumotion/trunk/flumotion/component/consumers/disker/disker.py	Wed Jul 25 18:50:56 2007
@@ -391,6 +391,9 @@
 
     def _plug_recording_started(self, file, location):
         socket = 'flumotion.component.consumers.disker.disker_plug.DiskerPlug'
+        # make sure plugs are configured with our socket, see #732
+        if socket not in self.plugs:
+            return
         for plug in self.plugs[socket]:
             self.debug('invoking recording_started on '
                        'plug %r on socket %s', plug, socket)
@@ -398,6 +401,9 @@
 
     def _plug_recording_stopped(self, file, location):
         socket = 'flumotion.component.consumers.disker.disker_plug.DiskerPlug'
+        # make sure plugs are configured with our socket, see #732
+        if socket not in self.plugs:
+            return
         for plug in self.plugs[socket]:
             self.debug('invoking recording_stopped on '
                        'plug %r on socket %s', plug, socket)