diff options
author | prigaux <[email protected]> | 2007-02-11 20:00:15 +0000 |
---|---|---|
committer | prigaux <[email protected]> | 2007-02-11 20:00:15 +0000 |
commit | a74fd5a1ec37e53fe7008f022639af6ede0e82c9 (patch) | |
tree | 0a6a32640a840b72653149aa11efa264674df976 /libhb/work.c | |
parent | f45dfeb2afb1b0bf46054959e8ea9494f3b7d14f (diff) |
Merge the 0.8.0_mpeg4ip branch into the trunk
git-svn-id: svn://svn.handbrake.fr/HandBrake/trunk@285 b64f7644-9d1e-0410-96f1-a4d463321fa5
Diffstat (limited to 'libhb/work.c')
-rw-r--r-- | libhb/work.c | 350 |
1 files changed, 0 insertions, 350 deletions
diff --git a/libhb/work.c b/libhb/work.c deleted file mode 100644 index 6529e2fbb..000000000 --- a/libhb/work.c +++ /dev/null @@ -1,350 +0,0 @@ -/* $Id: work.c,v 1.43 2005/03/17 16:38:49 titer Exp $ - - This file is part of the HandBrake source code. - Homepage: <http://handbrake.m0k.org/>. - It may be used under the terms of the GNU General Public License. */ - -#include "hb.h" - -typedef struct -{ - hb_list_t * jobs; - int cpu_count; - int * error; - volatile int * die; - -} hb_work_t; - -static void work_func(); -static void do_job( hb_job_t *, int cpu_count ); -static void work_loop( void * ); - -/** - * Allocates work object and launches work thread with work_func. - * @param jobs Handle to hb_list_t. - * @param cpu_count Humber of CPUs found in system. - * @param die Handle to user inititated exit indicator. - * @param error Handle to error indicator. - */ -hb_thread_t * hb_work_init( hb_list_t * jobs, int cpu_count, - volatile int * die, int * error ) -{ - hb_work_t * work = calloc( sizeof( hb_work_t ), 1 ); - - work->jobs = jobs; - work->cpu_count = cpu_count; - work->die = die; - work->error = error; - - return hb_thread_init( "work", work_func, work, HB_LOW_PRIORITY ); -} - -/** - * Iterates through job list and calls do_job for each job. - * @param _work Handle work object. - */ -static void work_func( void * _work ) -{ - hb_work_t * work = _work; - hb_job_t * job; - - hb_log( "%d job(s) to process", hb_list_count( work->jobs ) ); - - while( !*work->die && ( job = hb_list_item( work->jobs, 0 ) ) ) - { - hb_list_rem( work->jobs, job ); - job->die = work->die; - do_job( job, work->cpu_count ); - } - - *(work->error) = HB_ERROR_NONE; - - free( work ); -} - -static hb_work_object_t * getWork( int id ) -{ - hb_work_object_t * w; - for( w = hb_objects; w; w = w->next ) - { - if( w->id == id ) - { - return w; - } - } - return NULL; -} - -/** - * Job initialization rountine. - * Initializes fifos. - * Creates work objects for synchronizer, video decoder, video renderer, video decoder, audio decoder, audio encoder, reader, muxer. - * Launches thread for each work object with work_loop. - * Loops while monitoring status of work threads and fifos. - * Exits loop when conversion is done and fifos are empty. - * Closes threads and frees fifos. - * @param job Handle work hb_job_t. - * @param cpu_count number of CPUs found in system. - */ -static void do_job( hb_job_t * job, int cpu_count ) -{ - hb_title_t * title; - int i; - hb_work_object_t * w; - hb_audio_t * audio; - hb_subtitle_t * subtitle; - int done; - - title = job->title; - - job->list_work = hb_list_init(); - - hb_log( "starting job" ); - hb_log( " + device %s", title->dvd ); - hb_log( " + title %d, chapter(s) %d to %d", title->index, - job->chapter_start, job->chapter_end ); - hb_log( " + %dx%d -> %dx%d, crop %d/%d/%d/%d", - title->width, title->height, job->width, job->height, - job->crop[0], job->crop[1], job->crop[2], job->crop[3] ); - hb_log( " + deinterlace %s", job->deinterlace ? "on" : "off" ); - hb_log( " + grayscale %s", job->grayscale ? "on" : "off" ); - if( job->vquality >= 0.0 && job->vquality <= 1.0 ) - { - hb_log( " + %.3f fps, video quality %.2f", (float) job->vrate / - (float) job->vrate_base, job->vquality ); - } - else - { - hb_log( " + %.3f fps, video bitrate %d kbps, pass %d", - (float) job->vrate / (float) job->vrate_base, - job->vbitrate, job->pass ); - } - - job->fifo_mpeg2 = hb_fifo_init( 2048 ); - job->fifo_raw = hb_fifo_init( 8 ); - job->fifo_sync = hb_fifo_init( 8 ); - job->fifo_render = hb_fifo_init( 8 ); - job->fifo_mpeg4 = hb_fifo_init( 8 ); - - /* Synchronization */ - hb_list_add( job->list_work, ( w = getWork( WORK_SYNC ) ) ); - w->fifo_in = NULL; - w->fifo_out = NULL; - - /* Video decoder */ - hb_list_add( job->list_work, ( w = getWork( WORK_DECMPEG2 ) ) ); - w->fifo_in = job->fifo_mpeg2; - w->fifo_out = job->fifo_raw; - - /* Video renderer */ - hb_list_add( job->list_work, ( w = getWork( WORK_RENDER ) ) ); - w->fifo_in = job->fifo_sync; - w->fifo_out = job->fifo_render; - - /* Video encoder */ - switch( job->vcodec ) - { - case HB_VCODEC_FFMPEG: - hb_log( " + encoder FFmpeg" ); - w = getWork( WORK_ENCAVCODEC ); - break; - case HB_VCODEC_XVID: - hb_log( " + encoder XviD" ); - w = getWork( WORK_ENCXVID ); - break; - case HB_VCODEC_X264: - hb_log( " + encoder x264" ); - w = getWork( WORK_ENCX264 ); - break; - } - w->fifo_in = job->fifo_render; - w->fifo_out = job->fifo_mpeg4; - w->config = &job->config; - hb_list_add( job->list_work, w ); - - subtitle = hb_list_item( title->list_subtitle, 0 ); - if( subtitle ) - { - hb_log( " + subtitle %x, %s", subtitle->id, subtitle->lang ); - - subtitle->fifo_in = hb_fifo_init( 8 ); - subtitle->fifo_raw = hb_fifo_init( 8 ); - - hb_list_add( job->list_work, ( w = getWork( WORK_DECSUB ) ) ); - w->fifo_in = subtitle->fifo_in; - w->fifo_out = subtitle->fifo_raw; - } - - if( job->acodec & HB_ACODEC_AC3 ) - { - hb_log( " + audio AC3 passthrough" ); - } - else - { - hb_log( " + audio %d kbps, %d Hz", job->abitrate, job->arate ); - hb_log( " + encoder %s", ( job->acodec & HB_ACODEC_FAAC ) ? - "faac" : ( ( job->acodec & HB_ACODEC_LAME ) ? "lame" : - "vorbis" ) ); - } - - for( i = 0; i < hb_list_count( title->list_audio ); i++ ) - { - audio = hb_list_item( title->list_audio, i ); - hb_log( " + %x, %s", audio->id, audio->lang ); - - audio->fifo_in = hb_fifo_init( 2048 ); - audio->fifo_raw = hb_fifo_init( 8 ); - audio->fifo_sync = hb_fifo_init( 8 ); - audio->fifo_out = hb_fifo_init( 8 ); - - switch( audio->codec ) - { - case HB_ACODEC_AC3: - w = getWork( WORK_DECA52 ); - break; - case HB_ACODEC_MPGA: - w = getWork( WORK_DECAVCODEC ); - break; - case HB_ACODEC_LPCM: - w = getWork( WORK_DECLPCM ); - break; - } - w->fifo_in = audio->fifo_in; - w->fifo_out = audio->fifo_raw; - hb_list_add( job->list_work, w ); - - switch( job->acodec ) - { - case HB_ACODEC_FAAC: - w = getWork( WORK_ENCFAAC ); - break; - case HB_ACODEC_LAME: - w = getWork( WORK_ENCLAME ); - break; - case HB_ACODEC_VORBIS: - w = getWork( WORK_ENCVORBIS ); - break; - } - if( job->acodec != HB_ACODEC_AC3 ) - { - w->fifo_in = audio->fifo_sync; - w->fifo_out = audio->fifo_out; - w->config = &audio->config; - hb_list_add( job->list_work, w ); - } - } - - /* Init read & write threads */ - job->reader = hb_reader_init( job ); - - hb_log( " + output: %s", job->file ); - job->muxer = hb_muxer_init( job ); - - job->done = 0; - - /* Launch processing threads */ - for( i = 1; i < hb_list_count( job->list_work ); i++ ) - { - w = hb_list_item( job->list_work, i ); - w->done = &job->done; - w->thread_sleep_interval = 10; - w->init( w, job ); - w->thread = hb_thread_init( w->name, work_loop, w, - HB_LOW_PRIORITY ); - } - - done = 0; - w = hb_list_item( job->list_work, 0 ); - w->thread_sleep_interval = 50; - w->init( w, job ); - while( !*job->die ) - { - if( w->work( w, NULL, NULL ) == HB_WORK_DONE ) - { - done = 1; - } - if( done && - !hb_fifo_size( job->fifo_sync ) && - !hb_fifo_size( job->fifo_render ) && - hb_fifo_size( job->fifo_mpeg4 ) < 2 ) - { - break; - } - hb_snooze( w->thread_sleep_interval ); - } - hb_list_rem( job->list_work, w ); - w->close( w ); - job->done = 1; - - /* Close work objects */ - while( ( w = hb_list_item( job->list_work, 0 ) ) ) - { - hb_list_rem( job->list_work, w ); - hb_thread_close( &w->thread ); - w->close( w ); - } - - /* Stop read & write threads */ - hb_thread_close( &job->reader ); - hb_thread_close( &job->muxer ); - - /* Close fifos */ - hb_fifo_close( &job->fifo_mpeg2 ); - hb_fifo_close( &job->fifo_raw ); - hb_fifo_close( &job->fifo_sync ); - hb_fifo_close( &job->fifo_render ); - hb_fifo_close( &job->fifo_mpeg4 ); - if( subtitle ) - { - hb_fifo_close( &subtitle->fifo_in ); - hb_fifo_close( &subtitle->fifo_raw ); - } - for( i = 0; i < hb_list_count( title->list_audio ); i++ ) - { - audio = hb_list_item( title->list_audio, i ); - hb_fifo_close( &audio->fifo_in ); - hb_fifo_close( &audio->fifo_raw ); - hb_fifo_close( &audio->fifo_sync ); - hb_fifo_close( &audio->fifo_out ); - } -} - -/** - * Performs the work objects specific work function. - * Loops calling work function for associated work object. Sleeps when fifo is full. - * Monitors work done indicator. - * Exits loop when work indiactor is set. - * @param _w Handle to work object. - */ -static void work_loop( void * _w ) -{ - hb_work_object_t * w = _w; - hb_buffer_t * buf_in, * buf_out; - - while( !*w->done ) - { -#if 0 - hb_lock( job->pause ); - hb_unlock( job->pause ); -#endif - if( hb_fifo_is_full( w->fifo_out ) || -// if( (hb_fifo_percent_full( w->fifo_out ) > 0.8) || - !( buf_in = hb_fifo_get( w->fifo_in ) ) ) - { - hb_snooze( w->thread_sleep_interval ); -// w->thread_sleep_interval += 1; - continue; - } -// w->thread_sleep_interval = MAX(1, (w->thread_sleep_interval - 1)); - - w->work( w, &buf_in, &buf_out ); - if( buf_in ) - { - hb_buffer_close( &buf_in ); - } - if( buf_out ) - { - hb_fifo_push( w->fifo_out, buf_out ); - } - } -} |