(self)
| 401 | TestCase.tearDown(self) |
| 402 | |
| 403 | def testFakeSrcProbeOnceKeep(self): |
| 404 | self.fakesrc.set_property('num-buffers', 1) |
| 405 | |
| 406 | self.fakesink.set_property('signal-handoffs', True) |
| 407 | self.fakesink.connect('handoff', self._handoff_callback_fakesink) |
| 408 | |
| 409 | pad = self.fakesrc.get_pad('src') |
| 410 | id = pad.add_buffer_probe(self._probe_callback_fakesrc) |
| 411 | self._got_fakesrc_buffer = 0 |
| 412 | self._got_fakesink_buffer = 0 |
| 413 | self.pipeline.set_state(gst.STATE_PLAYING) |
| 414 | while not self._got_fakesrc_buffer: |
| 415 | gst.debug('waiting for fakesrc buffer') |
| 416 | pass |
| 417 | while not self._got_fakesink_buffer: |
| 418 | gst.debug('waiting for fakesink buffer') |
| 419 | pass |
| 420 | |
| 421 | gst.debug('got buffers from fakesrc and fakesink') |
| 422 | self.assertEquals(self._got_fakesink_buffer, 1) |
| 423 | pad.remove_buffer_probe(id) |
| 424 | |
| 425 | self.pipeline.set_state(gst.STATE_NULL) |
| 426 | |
| 427 | def testFakeSrcProbeMany(self): |
| 428 | self.fakesrc.set_property('num-buffers', 1000) |
nothing calls this directly
no test coverage detected