1 import gi
   2 gi.require_version('Gst', '1.0')
   3 from gi.repository import GObject, Gst
   4 GObject.threads_init()
   5 Gst.init(None)
   6 
   7 from gstlal import pipeparts         as pp
   8 from gstlal import calibration_parts as cp
   9 from gstlal import simplehandler
  10 from gstlal import datasource

   1 pipeline = Gst.Pipeline(name=pname)
   2 mainloop = GObject.MainLoop()
   3 handler  = simplehandler.Handler(mainloop, pipeline)

   1 print >>sys.stderr, "seeking GPS start and stop times ..."
   2 if pipeline.set_state(Gst.State.READY) != Gst.StateChangeReturn.SUCCESS:
   3         raise RuntimeError("pipeline failed to enter READY state")
   4 datasource.pipeline_seek_for_gps(pipeline, gps_start_time, gps_end_time)
   5 
   6 print >>sys.stderr, "setting pipeline state to playing ..."
   7 if pipeline.set_state(Gst.State.PLAYING) != Gst.StateChangeReturn.SUCCESS:
   8         raise RuntimeError("pipeline failed to enter PLAYING state")
   9 else:
  10         print >>sys.stderr, "set to playing successfully"
  11 
  12 print >>sys.stderr, "running pipeline ..."
  13 
  14 mainloop.run()
  15 
  16 if pipeline.set_state(Gst.State.NULL) != Gst.StateChangeReturn.SUCCESS:
  17         raise RuntimeError("pipeline could not be set to NULL")