(self, offset, size)
| 50 | self.fd = open(value, 'r') |
| 51 | |
| 52 | def do_create(self, offset, size): |
| 53 | if offset != self.curoffset: |
| 54 | self.fd.seek(offset, 0) |
| 55 | data = self.fd.read(self.blocksize) |
| 56 | if data: |
| 57 | self.curoffset += len(data) |
| 58 | return gst.FLOW_OK, gst.Buffer(data) |
| 59 | else: |
| 60 | return gst.FLOW_UNEXPECTED, None |
| 61 | gobject.type_register(FileSource) |
| 62 | |
| 63 | def main(args): |