From 29819d3303711b61f189b0a8f263ee05665841af Mon Sep 17 00:00:00 2001 From: prigaux Date: Thu, 18 Jan 2007 10:31:48 +0000 Subject: [PATCH] Bad Copy... git-svn-id: svn://svn.handbrake.fr/HandBrake/branches/PixelRatioWorking@133 b64f7644-9d1e-0410-96f1-a4d463321fa5 --- work.c | 373 --------------------------------------------------------- 1 file changed, 373 deletions(-) delete mode 100644 work.c diff --git a/work.c b/work.c deleted file mode 100644 index 8afff0aec..000000000 --- a/work.c +++ /dev/null @@ -1,373 +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: . - 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 ); - if ( job->pixel_ratio == 1 ) - { - /* Correct the geometry of the output movie when using PixelRatio */ - job->height=title->height-job->crop[0]-job->crop[1]; - job->width=title->width-job->crop[2]-job->crop[3]; - } - 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 ); - } - hb_log ("PixelRatio: %d, width:%d, height: %d",job->pixel_ratio,job->width, job->height); - job->fifo_mpeg2 = hb_fifo_init( 2048, "mpeg2" ); - job->fifo_raw = hb_fifo_init( 8, "raw" ); - job->fifo_sync = hb_fifo_init( 8, "sync" ); - job->fifo_render = hb_fifo_init( 8, "render" ); - job->fifo_mpeg4 = hb_fifo_init( 8, "mpeg4" ); - - /* 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 in" ); - subtitle->fifo_raw = hb_fifo_init( 8, "subtitle raw" ); - - 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 in" ); - audio->fifo_raw = hb_fifo_init( 8, "audio raw" ); - audio->fifo_sync = hb_fifo_init( 8 , "audio sync" ); - audio->fifo_out = hb_fifo_init( 8, "audio out" ); - - 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 = 1000; - 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 = 1; - time_t last_debug_print = time( NULL ); - 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 ); - - if(getenv( "HB_DEBUG" )) - { - if(time(NULL) >= (last_debug_print + 5)) - { - int i; - hb_work_object_t * w; - last_debug_print = time(NULL); - for( i = 0; i < hb_list_count( job->list_work ); i++ ) - { - w = hb_list_item( job->list_work, i ); - hb_log("%s, thread sleep interval: %d", w->name, 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 )) - { - w->thread_sleep_interval += 1; - hb_snooze( w->thread_sleep_interval ); - continue; - } - w->thread_sleep_interval = MAX(0, (w->thread_sleep_interval - 1)); - - buf_in = hb_fifo_get( w->fifo_in ); - if(buf_in) - { - 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 ); - } - } - } -} -- 2.40.0