This should get you going:
def _installBusListener(self):
self.bus = self.elementPipeline.get_bus()
self.bus.add_signal_watch()
self.bus.enable_sync_message_emission()
self.bus.connect('message', self._cbBusMessage)
self.bus.connect('message::eos', self._cbEos)
def _cbEos(self, argElement, argInfo):
if argInfo and (argInfo.type == Gst.MessageType.EOS ):
print "End of stream (EOS) received. Stopping pipeline."
self.bus.remove_signal_watch()
# clean-up/close your program.
return Gst.PadProbeReturn.OK
def _cbBusMessage(self, argGstElement, argGstMessageInstance):
gstStructureInstance = argGstMessageInstance.get_structure()
if(gstStructureInstance == None):
return Gst.PadProbeReturn.OK
messageName = gstStructureInstance.get_name()
messageType = argGstMessageInstance.type
if(messageType == Gst.MessageType.ERROR):
gErrorInstance, debugString = Gst.Message.parse_error(argGstMessageInstance)
if(gErrorInstance.code == 3):
if(gErrorInstance.message.find("Resource not found") > -1):
pass # handle file not found error
As you can see, I use string matching and error code matching to figure out what went wrong. Perhaps there is a more elegant way of doing this but I am unaware of that.
Locked
