Changeset 83a6f690504ec768f30243ca1e1cb96a9ba23aa8
- Timestamp:
- 04/09/09 08:13:58 (4 years ago)
- Author:
- Guillaume Pellerin <yomguy@…>
- Children:
- 2f0cf70fca6033a9e88d64334697f656e32718fd
- Parents:
- 2d8d19b28d4fc67d7a76678cf54a0ad200b3e77f
- git-committer:
- Guillaume Pellerin <yomguy@parisson.com> / 2009-04-09T06:13:58Z+0000
- Message:
-
use read() to stream the media
- Files:
-
Legend:
- Unmodified
- Added
- Removed
-
|
r2d8d19b
|
r83a6f69
|
|
| 302 | 302 | return file_name, file_title, file_ext |
| 303 | 303 | |
| 304 | | def core_process(self, media): |
| | 304 | def core_process_stream(self, media): |
| 305 | 305 | """Read media and stream data through a generator. |
| 306 | 306 | Taken from Telemeta (see http://telemeta.org)""" |
| … |
… |
|
| 328 | 328 | break |
| 329 | 329 | yield __chunk |
| | 330 | |
| | 331 | def core_process_read(self, media): |
| | 332 | """Read media and stream data through a generator. |
| | 333 | Taken from Telemeta (see http://telemeta.org)""" |
| | 334 | |
| | 335 | __chunk = 0 |
| | 336 | m = open(media, 'r') |
| | 337 | # Core processing |
| | 338 | while True: |
| | 339 | __chunk = m.read(self.buffer_size) |
| | 340 | if len(__chunk) == 0: |
| | 341 | break |
| | 342 | yield __chunk |
| | 343 | m.close() |
| | 344 | |
| 330 | 345 | |
| 331 | 346 | def run(self): |
| … |
… |
|
| 357 | 372 | self.update_rss([media_obj], self.rss_current_file) |
| 358 | 373 | print 'DeeFuzzing this file on %s : id = %s, name = %s' % (self.short_name, self.id, file_name) |
| 359 | | stream = self.core_process(media) |
| | 374 | stream = self.core_process_read(media) |
| 360 | 375 | self.q.task_done() |
| 361 | 376 | #self.log_queue(it) |