OSDN Git Service

Remove the set cpu count option as it doesn't do anything now
[handbrake-jp/handbrake-jp-git.git] / libhb / encx264.c
index 57a2fe2..270692c 100644 (file)
@@ -30,16 +30,16 @@ hb_work_object_t hb_encx264 =
  * to x264_encoder_encode. Since frames are uniquely identified by their
  * timestamp, we use some bits of the timestamp as an index. The LSB is
  * chosen so that two successive frames will have different values in the
- * bits over any plausible range of frame rates. (Starting with bit 9 allows
- * any frame rate slower than 175fps.) The MSB determines the size of the array.
+ * bits over any plausible range of frame rates. (Starting with bit 8 allows
+ * any frame rate slower than 352fps.) The MSB determines the size of the array.
  * It is chosen so that two frames can't use the same slot during the
  * encoder's max frame delay (set by the standard as 16 frames) and so
  * that, up to some minimum frame rate, frames are guaranteed to map to
- * different slots. (An MSB of 16 which is 2^(16-9+1) = 256 slots guarantees
- * no collisions down to a rate of 1.4 fps).
+ * different slots. (An MSB of 17 which is 2^(17-8+1) = 1024 slots guarantees
+ * no collisions down to a rate of .7 fps).
  */
-#define FRAME_INFO_MAX2 (9)     // 2^9 = 512; 90000/512 = 175 frames/sec
-#define FRAME_INFO_MIN2 (16)    // 2^16 = 65536; 90000/65536 = 1.4 frames/sec
+#define FRAME_INFO_MAX2 (8)     // 2^8 = 256; 90000/256 = 352 frames/sec
+#define FRAME_INFO_MIN2 (17)    // 2^17 = 128K; 90000/131072 = 1.4 frames/sec
 #define FRAME_INFO_SIZE (1 << (FRAME_INFO_MIN2 - FRAME_INFO_MAX2 + 1))
 #define FRAME_INFO_MASK (FRAME_INFO_SIZE - 1)
 
@@ -48,13 +48,13 @@ struct hb_work_private_s
     hb_job_t       * job;
     x264_t         * x264;
     x264_picture_t   pic_in;
-    uint8_t         *x264_allocated_pic;
+    uint8_t        * grey_data;
 
+    uint32_t       frames_in;
+    uint32_t       frames_out;
+    uint32_t       frames_split; // number of frames we had to split
     int            chap_mark;   // saved chap mark when we're propagating it
-    int64_t        dts_next;    // DTS start time value for next output frame
     int64_t        last_stop;   // Debugging - stop time of previous input frame
-    int64_t        init_delay;
-    int64_t        max_delay;   // if init_delay too small, delay really needed
     int64_t        next_chap;
 
     struct {
@@ -74,7 +74,6 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
     x264_param_t       param;
     x264_nal_t       * nal;
     int                nal_count;
-    int                nal_size;
 
     hb_work_private_t * pv = calloc( 1, sizeof( hb_work_private_t ) );
     w->private_data = pv;
@@ -85,34 +84,60 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
     hb_get_tempory_filename( job->h, pv->filename, "x264.log" );
 
     x264_param_default( &param );
-
+    
+    /* Enable metrics */
+    param.analyse.b_psnr = 1;
+    param.analyse.b_ssim = 1;
+
+    /* QuickTime has trouble with very low QPs (resulting in visual artifacts).
+     * Known to affect QuickTime 7, QuickTime X and iTunes.
+     * Testing shows that a qpmin of 3 works.
+     */
+    param.rc.i_qp_min = 3;
+    
     param.i_threads    = ( hb_get_cpu_count() * 3 / 2 );
     param.i_width      = job->width;
     param.i_height     = job->height;
     param.i_fps_num    = job->vrate;
     param.i_fps_den    = job->vrate_base;
-
-    if (job->vrate_base != 1080000)
+    if ( job->cfr == 1 )
     {
-        /* If the fps isn't 25, adjust the key intervals. Add 1 because
-           we want 24, not 23 with a truncated remainder.               */
-        param.i_keyint_min     = (job->vrate / job->vrate_base) + 1;
-        param.i_keyint_max = (10 * job->vrate / job->vrate_base) + 1;
-        hb_log("encx264: keyint-min: %i, keyint-max: %i", param.i_keyint_min, param.i_keyint_max);
+        param.i_timebase_num   = 0;
+        param.i_timebase_den   = 0;
+        param.b_vfr_input = 0;
     }
-
-    param.i_log_level  = X264_LOG_INFO;
-    if( job->h264_level )
+    else
     {
-        param.b_cabac     = 0;
-        param.i_level_idc = job->h264_level;
-        hb_log( "encx264: encoding at level %i",
-                param.i_level_idc );
+        param.i_timebase_num   = 1;
+        param.i_timebase_den   = 90000;
     }
 
-    /* Slightly faster with minimal quality lost */
-    param.analyse.i_subpel_refine = 4;
+    /* Disable annexb. Inserts size into nal header instead of start code */
+    param.b_annexb     = 0;
+
+    /* Set min:max key intervals ratio to 1:10 of fps.
+     * This section is skipped if fps=25 (default).
+     */
+    if (job->vrate_base != 1080000)
+    {
+        if (job->pass == 2 && !job->cfr )
+        {
+            /* Even though the framerate might be different due to VFR,
+               we still want the same keyframe intervals as the 1st pass,
+               so the 1st pass stats won't conflict on frame decisions.    */
+            hb_interjob_t * interjob = hb_interjob_get( job->h );
+            param.i_keyint_max = 10 * (int)( (double)interjob->vrate / (double)interjob->vrate_base + 0.5 );
+        }
+        else
+        {
+            /* adjust +0.5 for when fps has remainder to bump
+               { 23.976, 29.976, 59.94 } to { 24, 30, 60 } */
+            param.i_keyint_max = 10 * (int)( (double)job->vrate / (double)job->vrate_base + 0.5 );
+        }
+    }
 
+    param.i_log_level  = X264_LOG_INFO;
+    
     /*
                This section passes the string x264opts to libx264 for parsing into
         parameter names and values.
@@ -154,38 +179,6 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
                 value++;
             }
 
-            /*
-               When B-frames are enabled, the max frame count increments
-               by 1 (regardless of the number of B-frames). If you don't
-               change the duration of the video track when you mux, libmp4
-               barfs.  So, check if the x264opts are using B-frames, and
-               when they are, set the boolean job->areBframes as true.
-             */
-
-            if( !( strcmp( name, "bframes" ) ) )
-            {
-                if( atoi( value ) > 0 )
-                {
-                    job->areBframes = 1;
-                }
-            }
-
-            /* Note b-pyramid here, so the initial delay can be doubled */
-            if( !( strcmp( name, "b-pyramid" ) ) )
-            {
-                if( value != NULL )
-                {
-                    if( atoi( value ) > 0 )
-                    {
-                        job->areBframes = 2;
-                    }
-                }
-                else
-                {
-                    job->areBframes = 2;
-                }
-            }
-
             /* Here's where the strings are passed to libx264 for parsing. */
             ret = x264_param_parse( &param, name, value );
 
@@ -197,11 +190,65 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
         }
         free(x264opts_start);
     }
+    
+    /* B-frames are on by default.*/
+    job->areBframes = 1;
+    
+    if( param.i_bframe && param.i_bframe_pyramid )
+    {
+        /* Note b-pyramid here, so the initial delay can be doubled */
+        job->areBframes = 2;
+    }
+    else if( !param.i_bframe )
+    {
+        /*
+         When B-frames are enabled, the max frame count increments
+         by 1 (regardless of the number of B-frames). If you don't
+         change the duration of the video track when you mux, libmp4
+         barfs.  So, check if the x264opts aren't using B-frames, and
+         when they aren't, set the boolean job->areBframes as false.
+         */
+        job->areBframes = 0;
+    }
+    
+    if( param.i_keyint_min != X264_KEYINT_MIN_AUTO || param.i_keyint_max != 250 )
+    {
+        int min_auto;
+
+        if ( param.i_fps_num / param.i_fps_den < param.i_keyint_max / 10 )
+            min_auto = param.i_fps_num / param.i_fps_den;
+        else
+            min_auto = param.i_keyint_max / 10;
+
+        char min[40], max[40];
+        param.i_keyint_min == X264_KEYINT_MIN_AUTO ? 
+            snprintf( min, 40, "auto (%d)", min_auto ) : 
+            snprintf( min, 40, "%d", param.i_keyint_min );
+
+        param.i_keyint_max == X264_KEYINT_MAX_INFINITE ? 
+            snprintf( max, 40, "infinite" ) : 
+            snprintf( max, 40, "%d", param.i_keyint_max );
+
+        hb_log( "encx264: min-keyint: %s, keyint: %s", min, max );
+    }
 
     /* set up the VUI color model & gamma to match what the COLR atom
      * set in muxmp4.c says. See libhb/muxmp4.c for notes. */
-
-    if ( job->title->height >= 720 )
+    if( job->color_matrix == 1 )
+    {
+        // ITU BT.601 DVD or SD TV content
+        param.vui.i_colorprim = 6;
+        param.vui.i_transfer = 1;
+        param.vui.i_colmatrix = 6;
+    }
+    else if( job->color_matrix == 2 )
+    {
+        // ITU BT.709 HD content
+        param.vui.i_colorprim = 1;
+        param.vui.i_transfer = 1;
+        param.vui.i_colmatrix = 1;
+    }
+    else if ( job->title->width >= 1280 || job->title->height >= 720 )
     {
         // we guess that 720p or above is ITU BT.709 HD content
         param.vui.i_colorprim = 1;
@@ -216,10 +263,10 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
         param.vui.i_colmatrix = 6;
     }
 
-    if( job->pixel_ratio )
+    if( job->anamorphic.mode )
     {
-        param.vui.i_sar_width = job->pixel_aspect_width;
-        param.vui.i_sar_height = job->pixel_aspect_height;
+        param.vui.i_sar_width  = job->anamorphic.par_width;
+        param.vui.i_sar_height = job->anamorphic.par_height;
 
         hb_log( "encx264: encoding with stored aspect %d/%d",
                 param.vui.i_sar_width, param.vui.i_sar_height );
@@ -228,47 +275,19 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
 
     if( job->vquality > 0.0 && job->vquality < 1.0 )
     {
-        switch( job->crf )
-        {
-            case 1:
-                /*Constant RF*/
-                param.rc.i_rc_method = X264_RC_CRF;
-                param.rc.f_rf_constant = 51 - job->vquality * 51;
-                hb_log( "encx264: Encoding at constant RF %f",
-                        param.rc.f_rf_constant );
-                break;
-
-            case 0:
-                /*Constant QP*/
-                param.rc.i_rc_method = X264_RC_CQP;
-                param.rc.i_qp_constant = 51 - job->vquality * 51;
-                hb_log( "encx264: encoding at constant QP %d",
-                        param.rc.i_qp_constant );
-                break;
-        }
+        /*Constant RF*/
+        param.rc.i_rc_method = X264_RC_CRF;
+        param.rc.f_rf_constant = 51 - job->vquality * 51;
+        hb_log( "encx264: Encoding at constant RF %f", param.rc.f_rf_constant );
     }
     else if( job->vquality == 0 || job->vquality >= 1.0 )
     {
         /* Use the vquality as a raw RF or QP
           instead of treating it like a percentage. */
-        switch( job->crf )
-        {
-            case 1:
-                /*Constant RF*/
-                param.rc.i_rc_method = X264_RC_CRF;
-                param.rc.f_rf_constant = job->vquality;
-                hb_log( "encx264: Encoding at constant RF %f",
-                        param.rc.f_rf_constant );
-                break;
-
-            case 0:
-                /*Constant QP*/
-                param.rc.i_rc_method = X264_RC_CQP;
-                param.rc.i_qp_constant = job->vquality;
-                hb_log( "encx264: encoding at constant QP %d",
-                        param.rc.i_qp_constant );
-                break;
-        }        
+        /*Constant RF*/
+        param.rc.i_rc_method = X264_RC_CRF;
+        param.rc.f_rf_constant = job->vquality;
+        hb_log( "encx264: Encoding at constant RF %f", param.rc.f_rf_constant );
     }
     else
     {
@@ -288,58 +307,32 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
         }
     }
 
-    hb_log( "encx264: opening libx264 (pass %d)", job->pass );
+    hb_deep_log( 2, "encx264: opening libx264 (pass %d)", job->pass );
     pv->x264 = x264_encoder_open( &param );
 
     x264_encoder_headers( pv->x264, &nal, &nal_count );
 
     /* Sequence Parameter Set */
-    x264_nal_encode( w->config->h264.sps, &nal_size, 0, &nal[1] );
-    w->config->h264.sps_length = nal_size;
+    memcpy(w->config->h264.sps, nal[0].p_payload + 4, nal[0].i_payload - 4);
+    w->config->h264.sps_length = nal[0].i_payload - 4;
 
     /* Picture Parameter Set */
-    x264_nal_encode( w->config->h264.pps, &nal_size, 0, &nal[2] );
-    w->config->h264.pps_length = nal_size;
-
-    x264_picture_alloc( &pv->pic_in, X264_CSP_I420,
-                        job->width, job->height );
+    memcpy(w->config->h264.pps, nal[1].p_payload + 4, nal[1].i_payload - 4);
+    w->config->h264.pps_length = nal[1].i_payload - 4;
 
-    pv->x264_allocated_pic = pv->pic_in.img.plane[0];
+    x264_picture_init( &pv->pic_in );
 
-    pv->dts_next = -1;
-    pv->next_chap = 0;
+    pv->pic_in.img.i_csp = X264_CSP_I420;
+    pv->pic_in.img.i_plane = 3;
+    pv->pic_in.img.i_stride[0] = job->width;
+    pv->pic_in.img.i_stride[2] = pv->pic_in.img.i_stride[1] = ( ( job->width + 1 ) >> 1 );
 
-    if (job->areBframes)
+    if( job->grayscale )
     {
-        /* Basic initDelay value is the clockrate divided by the FPS
-           -- the length of one frame in clockticks.                  */
-        pv->init_delay = 90000. / ((double)job->vrate / (double)job->vrate_base);
-
-        /* 23.976-length frames are 3753.75 ticks long on average but the DVD
-           creates that average rate by repeating 59.95 fields so the max
-           frame size is actually 4504.5 (3 field times). The field durations
-           are computed based on quantized times (see below) so we need an extra
-           two ticks to account for the rounding. */
-        if (pv->init_delay == 3753)
-            pv->init_delay = 4507;
-
-        /* frame rates are not exact in the DVD 90KHz PTS clock (they are
-           exact in the DVD 27MHz system clock but we never see that) so the
-           rates computed above are all +-1 due to quantization. Worst case
-           is when a clock-rounded-down frame is adjacent to a rounded-up frame
-           which makes one of the frames 2 ticks longer than the nominal
-           frame time. */
-        pv->init_delay += 2;
-
-        /* For VFR, libhb sees the FPS as 29.97, but the longest frames
-           will use the duration of frames running at 23.976fps instead.. */
-        if (job->vfr)
-        {
-            pv->init_delay = 7506;
-        }
-
-        /* The delay is 1 frames for regular b-frames, 2 for b-pyramid. */
-        pv->init_delay *= job->areBframes;
+        int uvsize = ( (job->width + 1) >> 1 ) * ( (job->height + 1) >> 1 );
+        pv->grey_data = malloc( uvsize );
+        memset( pv->grey_data, 0x80, uvsize );
+        pv->pic_in.img.plane[1] = pv->pic_in.img.plane[2] = pv->grey_data;
     }
 
     return 0;
@@ -348,12 +341,13 @@ int encx264Init( hb_work_object_t * w, hb_job_t * job )
 void encx264Close( hb_work_object_t * w )
 {
     hb_work_private_t * pv = w->private_data;
-    /*
-     * Patch the x264 allocated data back in so that x264 can free it
-     * we have been using our own buffers during the encode to avoid copying.
-     */
-    pv->pic_in.img.plane[0] = pv->x264_allocated_pic;
-    x264_picture_clean( &pv->pic_in );
+
+    if ( pv->frames_split )
+    {
+        hb_log( "encx264: %u frames had to be split (%u in, %u out)",
+                pv->frames_split, pv->frames_in, pv->frames_out );
+    }
+    free( pv->grey_data );
     x264_encoder_close( pv->x264 );
     free( pv );
     w->private_data = NULL;
@@ -377,228 +371,239 @@ static int64_t get_frame_duration( hb_work_private_t * pv, int64_t pts )
     return pv->frame_info[i].duration;
 }
 
-int encx264Work( hb_work_object_t * w, hb_buffer_t ** buf_in,
-                  hb_buffer_t ** buf_out )
+static hb_buffer_t *nal_encode( hb_work_object_t *w, x264_picture_t *pic_out,
+                                int i_nal, x264_nal_t *nal )
 {
-    hb_work_private_t * pv = w->private_data;
-    hb_job_t    * job = pv->job;
-    hb_buffer_t * in = *buf_in, * buf;
-    x264_picture_t   pic_out;
-    int           i_nal;
-    x264_nal_t  * nal;
-    int i;
-
-    if( in->data )
+    hb_buffer_t *buf = NULL;
+    hb_work_private_t *pv = w->private_data;
+    hb_job_t *job = pv->job;
+
+    /* Should be way too large */
+    buf = hb_video_buffer_init( job->width, job->height );
+    buf->size = 0;
+    buf->frametype = 0;
+
+    // use the pts to get the original frame's duration.
+    int64_t duration  = get_frame_duration( pv, pic_out->i_pts );
+    buf->start = pic_out->i_pts;
+    buf->stop  = pic_out->i_pts + duration;
+    buf->renderOffset = pic_out->i_dts;
+    if ( !w->config->h264.init_delay && pic_out->i_dts < 0 )
     {
-        /*
-         * Point x264 at our current buffers Y(UV) data.
-         */
-        pv->pic_in.img.plane[0] = in->data;
+        w->config->h264.init_delay = -pic_out->i_dts;
+    }
 
-        if( job->grayscale )
-        {
-            /* XXX x264 has currently no option for grayscale encoding */
-            memset( pv->pic_in.img.plane[1], 0x80, job->width * job->height / 4 );
-            memset( pv->pic_in.img.plane[2], 0x80, job->width * job->height / 4 );
-        }
-        else
+    /* Encode all the NALs we were given into buf.
+       NOTE: This code assumes one video frame per NAL (but there can
+             be other stuff like SPS and/or PPS). If there are multiple
+             frames we only get the duration of the first which will
+             eventually screw up the muxer & decoder. */
+    int i;
+    for( i = 0; i < i_nal; i++ )
+    {
+        int size = nal[i].i_payload;
+        memcpy(buf->data + buf->size, nal[i].p_payload, size);
+        if( size < 1 )
         {
-            /*
-             * Point x264 at our buffers (Y)UV data
-             */
-            pv->pic_in.img.plane[1] = in->data + job->width * job->height;
-            pv->pic_in.img.plane[2] = in->data + 5 * job->width *
-                job->height / 4;
+            continue;
         }
 
-        if( pv->dts_next == -1 )
+        /* H.264 in .mp4 or .mkv */
+        switch( nal[i].i_type )
         {
-            /* we don't have a start time yet so use the first frame's
-             * start. All other frame times will be determined by the
-             * sum of the prior output frame durations in *DTS* order
-             * (not by the order they arrive here). This timing change is
-             * essential for VFR with b-frames but a complete nop otherwise.
+            /* Sequence Parameter Set & Program Parameter Set go in the
+             * mp4 header so skip them here
              */
-            pv->dts_next = in->start;
+            case NAL_SPS:
+            case NAL_PPS:
+                continue;
+
+            case NAL_SLICE:
+            case NAL_SLICE_IDR:
+            case NAL_SEI:
+            default:
+                break;
         }
-        if( in->new_chap && job->chapter_markers )
+
+        /* Decide what type of frame we have. */
+        switch( pic_out->i_type )
         {
-            /* chapters have to start with an IDR frame so request that this
-               frame be coded as IDR. Since there may be up to 16 frames
-               currently buffered in the encoder remember the timestamp so
-               when this frame finally pops out of the encoder we'll mark
-               its buffer as the start of a chapter. */
-            pv->pic_in.i_type = X264_TYPE_IDR;
-            if( pv->next_chap == 0 )
-            {
-                pv->next_chap = in->start;
-                pv->chap_mark = in->new_chap;
-            }
-            /* don't let 'work_loop' put a chapter mark on the wrong buffer */
-            in->new_chap = 0;
+            case X264_TYPE_IDR:
+                buf->frametype = HB_FRAME_IDR;
+                /* if we have a chapter marker pending and this
+                   frame's presentation time stamp is at or after
+                   the marker's time stamp, use this as the
+                   chapter start. */
+                if( pv->next_chap != 0 && pv->next_chap <= pic_out->i_pts )
+                {
+                    pv->next_chap = 0;
+                    buf->new_chap = pv->chap_mark;
+                }
+                break;
+
+            case X264_TYPE_I:
+                buf->frametype = HB_FRAME_I;
+                break;
+
+            case X264_TYPE_P:
+                buf->frametype = HB_FRAME_P;
+                break;
+
+            case X264_TYPE_B:
+                buf->frametype = HB_FRAME_B;
+                break;
+
+        /*  This is for b-pyramid, which has reference b-frames
+            However, it doesn't seem to ever be used... */
+            case X264_TYPE_BREF:
+                buf->frametype = HB_FRAME_BREF;
+                break;
+
+            // If it isn't the above, what type of frame is it??
+            default:
+                buf->frametype = 0;
+                break;
         }
+
+        /* Since libx264 doesn't tell us when b-frames are
+           themselves reference frames, figure it out on our own. */
+        if( (buf->frametype == HB_FRAME_B) &&
+            (nal[i].i_ref_idc != NAL_PRIORITY_DISPOSABLE) )
+            buf->frametype = HB_FRAME_BREF;
+
+        /* Expose disposable bit to muxer. */
+        if( nal[i].i_ref_idc == NAL_PRIORITY_DISPOSABLE )
+            buf->flags &= ~HB_FRAME_REF;
         else
-        {
-            pv->pic_in.i_type = X264_TYPE_AUTO;
-        }
-        pv->pic_in.i_qpplus1 = 0;
+            buf->flags |= HB_FRAME_REF;
 
-        /* XXX this is temporary debugging code to check that the upstream
-         * modules (render & sync) have generated a continuous, self-consistent
-         * frame stream with the current frame's start time equal to the
-         * previous frame's stop time.
-         */
-        if( pv->last_stop != in->start )
-        {
-            hb_log("encx264 input continuity err: last stop %lld  start %lld",
-                    pv->last_stop, in->start);
-        }
-        pv->last_stop = in->stop;
+        buf->size += size;
+    }
+    // make sure we found at least one video frame
+    if ( buf->size <= 0 )
+    {
+        // no video - discard the buf
+        hb_buffer_close( &buf );
+    }
+    return buf;
+}
 
-        // Remember info about this frame that we need to pass across
-        // the x264_encoder_encode call (since it reorders frames).
-        save_frame_info( pv, in );
+static hb_buffer_t *x264_encode( hb_work_object_t *w, hb_buffer_t *in )
+{
+    hb_work_private_t *pv = w->private_data;
+    hb_job_t *job = pv->job;
 
-        /* Feed the input DTS to x264 so it can figure out proper output PTS */
-        pv->pic_in.i_pts = in->start;
+    /* Point x264 at our current buffers Y(UV) data.  */
+    pv->pic_in.img.plane[0] = in->data;
 
-        x264_encoder_encode( pv->x264, &nal, &i_nal,
-                             &pv->pic_in, &pic_out );
+    int uvsize = ( (job->width + 1) >> 1 ) * ( (job->height + 1) >> 1 );
+    if( !job->grayscale )
+    {
+        /* Point x264 at our buffers (Y)UV data */
+        pv->pic_in.img.plane[1] = in->data + job->width * job->height;
+        pv->pic_in.img.plane[2] = pv->pic_in.img.plane[1] + uvsize;
     }
-    else
+    if( in->new_chap && job->chapter_markers )
     {
-        x264_encoder_encode( pv->x264, &nal, &i_nal,
-                             NULL, &pic_out );
-        /* No more delayed B frames */
-        if( i_nal == 0 )
+        /* chapters have to start with an IDR frame so request that this
+           frame be coded as IDR. Since there may be up to 16 frames
+           currently buffered in the encoder remember the timestamp so
+           when this frame finally pops out of the encoder we'll mark
+           its buffer as the start of a chapter. */
+        pv->pic_in.i_type = X264_TYPE_IDR;
+        if( pv->next_chap == 0 )
         {
-            *buf_out = NULL;
-            return HB_WORK_DONE;
-        }
-        else
-        {
-        /*  Since we output at least one more frame, drop another empty
-            one onto our input fifo.  We'll keep doing this automatically
-            until we stop getting frames out of the encoder. */
-            hb_fifo_push(w->fifo_in, hb_buffer_init(0));
+            pv->next_chap = in->start;
+            pv->chap_mark = in->new_chap;
         }
+        /* don't let 'work_loop' put a chapter mark on the wrong buffer */
+        in->new_chap = 0;
+    }
+    else
+    {
+        pv->pic_in.i_type = X264_TYPE_AUTO;
     }
 
-    if( i_nal )
+    /* XXX this is temporary debugging code to check that the upstream
+     * modules (render & sync) have generated a continuous, self-consistent
+     * frame stream with the current frame's start time equal to the
+     * previous frame's stop time.
+     */
+    if( pv->last_stop != in->start )
     {
-        /* Should be way too large */
-        buf        = hb_buffer_init( 3 * job->width * job->height / 2 );
-        buf->size  = 0;
-        buf->frametype   = 0;
+        hb_log("encx264 input continuity err: last stop %"PRId64"  start %"PRId64,
+                pv->last_stop, in->start);
+    }
+    pv->last_stop = in->stop;
 
-        /* Get next DTS value to use */
-        int64_t dts_start = pv->dts_next;
+    // Remember info about this frame that we need to pass across
+    // the x264_encoder_encode call (since it reorders frames).
+    save_frame_info( pv, in );
 
-        /* compute the stop time based on the original frame's duration */
-        int64_t dts_stop  = dts_start + get_frame_duration( pv, pic_out.i_pts );
-        pv->dts_next = dts_stop;
+    /* Feed the input PTS to x264 so it can figure out proper output PTS */
+    pv->pic_in.i_pts = in->start;
 
-        for( i = 0; i < i_nal; i++ )
-        {
-            int size, data;
+    x264_picture_t pic_out;
+    int i_nal;
+    x264_nal_t *nal;
 
-            data = buf->alloc - buf->size;
-            if( ( size = x264_nal_encode( buf->data + buf->size, &data,
-                                          1, &nal[i] ) ) < 1 )
-            {
-                continue;
-            }
+    x264_encoder_encode( pv->x264, &nal, &i_nal, &pv->pic_in, &pic_out );
+    if ( i_nal > 0 )
+    {
+        return nal_encode( w, &pic_out, i_nal, nal );
+    }
+    return NULL;
+}
 
-            if( job->mux & HB_MUX_AVI )
-            {
-                if( nal[i].i_ref_idc == NAL_PRIORITY_HIGHEST )
-                {
-                    buf->frametype = HB_FRAME_KEY;
-                }
-                buf->size += size;
+int encx264Work( hb_work_object_t * w, hb_buffer_t ** buf_in,
+                  hb_buffer_t ** buf_out )
+{
+    hb_work_private_t *pv = w->private_data;
+    hb_buffer_t *in = *buf_in;
+
+    *buf_out = NULL;
+
+    if( in->size <= 0 )
+    {
+        // EOF on input. Flush any frames still in the decoder then
+        // send the eof downstream to tell the muxer we're done.
+        x264_picture_t pic_out;
+        int i_nal;
+        x264_nal_t *nal;
+        hb_buffer_t *last_buf = NULL;
+
+        while ( x264_encoder_delayed_frames( pv->x264 ) )
+        {
+            x264_encoder_encode( pv->x264, &nal, &i_nal, NULL, &pic_out );
+            if ( i_nal == 0 )
                 continue;
-            }
+            if ( i_nal < 0 )
+                break;
 
-            /* H.264 in .mp4 */
-            switch( buf->data[buf->size+4] & 0x1f )
+            hb_buffer_t *buf = nal_encode( w, &pic_out, i_nal, nal );
+            if ( buf )
             {
-                case 0x7:
-                case 0x8:
-                    /* SPS, PPS */
-                    break;
-
-                default:
-                    /* H.264 in mp4 (stolen from mp4creator) */
-                    buf->data[buf->size+0] = ( ( size - 4 ) >> 24 ) & 0xFF;
-                    buf->data[buf->size+1] = ( ( size - 4 ) >> 16 ) & 0xFF;
-                    buf->data[buf->size+2] = ( ( size - 4 ) >>  8 ) & 0xFF;
-                    buf->data[buf->size+3] = ( ( size - 4 ) >>  0 ) & 0xFF;
-                    switch( pic_out.i_type )
-                    {
-                    /*  Decide what type of frame we have. */
-                        case X264_TYPE_IDR:
-                            buf->frametype = HB_FRAME_IDR;
-                            /* if we have a chapter marker pending and this
-                               frame's presentation time stamp is at or after
-                               the marker's time stamp, use this as the
-                               chapter start. */
-                            if( pv->next_chap != 0 && pv->next_chap <= pic_out.i_pts )
-                            {
-                                pv->next_chap = 0;
-                                buf->new_chap = pv->chap_mark;
-                            }
-                            break;
-                        case X264_TYPE_I:
-                            buf->frametype = HB_FRAME_I;
-                            break;
-                        case X264_TYPE_P:
-                            buf->frametype = HB_FRAME_P;
-                            break;
-                        case X264_TYPE_B:
-                            buf->frametype = HB_FRAME_B;
-                            break;
-                    /*  This is for b-pyramid, which has reference b-frames
-                        However, it doesn't seem to ever be used... */
-                        case X264_TYPE_BREF:
-                            buf->frametype = HB_FRAME_BREF;
-                            break;
-                    /*  If it isn't the above, what type of frame is it?? */
-                        default:
-                            buf->frametype = 0;
-                    }
-
-                    /* Since libx264 doesn't tell us when b-frames are
-                       themselves reference frames, figure it out on our own. */
-                    if( (buf->frametype == HB_FRAME_B) && (nal[i].i_ref_idc != NAL_PRIORITY_DISPOSABLE) )
-                        buf->frametype = HB_FRAME_BREF;
-
-                    /* Store the output presentation time stamp
-                       from x264 for use by muxmp4 in off-setting
-                       b-frames with the CTTS atom. */
-                    buf->renderOffset = pic_out.i_pts - dts_start + pv->init_delay;
-                    if ( buf->renderOffset < 0 )
-                    {
-                        if ( dts_start - pic_out.i_pts > pv->max_delay )
-                        {
-                            pv->max_delay = dts_start - pic_out.i_pts;
-                            hb_log( "encx264: init_delay too small: "
-                                    "is %lld need %lld", pv->init_delay,
-                                    pv->max_delay );
-                        }
-                        buf->renderOffset = 0;
-                    }
-                    buf->size += size;
+                ++pv->frames_out;
+                if ( last_buf == NULL )
+                    *buf_out = buf;
+                else
+                    last_buf->next = buf;
+                last_buf = buf;
             }
         }
-        /* Send out the next dts values */
-        buf->start = dts_start;
-        buf->stop  = dts_stop;
-    }
-
-    else
-        buf = NULL;
+        // Flushed everything - add the eof to the end of the chain.
+        if ( last_buf == NULL )
+            *buf_out = in;
+        else
+            last_buf->next = in;
 
-    *buf_out = buf;
+        *buf_in = NULL;
+        return HB_WORK_DONE;
+    }
 
+    // Not EOF - encode the packet & wrap it in a NAL
+    ++pv->frames_in;
+    ++pv->frames_out;
+    *buf_out = x264_encode( w, in );
     return HB_WORK_OK;
 }