(self, main_window)
| 476 | self.emit('done', response) |
| 477 | |
| 478 | def start(self, main_window): |
| 479 | self.window = main_window |
| 480 | self.touri = self.do_get_touri() |
| 481 | if not self.touri: |
| 482 | return False |
| 483 | self.do_setup_pipeline() |
| 484 | bus = self.get_bus() |
| 485 | bus.add_signal_watch() |
| 486 | bus.connect('message', self._bus_watch) |
| 487 | if self.window: |
| 488 | # can be None if we are debugging... |
| 489 | self.window.set_sensitive(False) |
| 490 | fromname = self.fromuri.split('/')[-1] |
| 491 | toname = self.touri.split('/')[-1] |
| 492 | self.pdialog = RemuxProgressDialog(main_window, self.start_time, |
| 493 | self.stop_time, fromname, toname) |
| 494 | self.pdialog.show() |
| 495 | self.pdialog.connect('response', lambda w, r: self.response(r)) |
| 496 | |
| 497 | self.set_state(gst.STATE_PAUSED) |
| 498 | return True |
| 499 | |
| 500 | def run(self, main_window): |
| 501 | if self.start(main_window): |
no test coverage detected