git.sesse.net Git - x264/blob - input/ffms.c

   1 /*****************************************************************************
   2  * ffms.c: ffmpegsource input
   3  *****************************************************************************
   4  * Copyright (C) 2009-2011 x264 project
   5  *
   6  * Authors: Mike Gurlitz <mike.gurlitz@gmail.com>
   7  *          Steven Walters <kemuri9@gmail.com>
   8  *
   9  * This program is free software; you can redistribute it and/or modify
  10  * it under the terms of the GNU General Public License as published by
  11  * the Free Software Foundation; either version 2 of the License, or
  12  * (at your option) any later version.
  13  *
  14  * This program is distributed in the hope that it will be useful,
  15  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  16  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  17  * GNU General Public License for more details.
  18  *
  19  * You should have received a copy of the GNU General Public License
  20  * along with this program; if not, write to the Free Software
  21  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02111, USA.
  22  *
  23  * This program is also available under a commercial proprietary license.
  24  * For more information, contact us at licensing@x264.com.
  25  *****************************************************************************/
  26
  27 #include "input.h"
  28 #include <ffms.h>
  29 #define FAIL_IF_ERROR( cond, ... ) FAIL_IF_ERR( cond, "ffms", __VA_ARGS__ )
  30
  31 #undef DECLARE_ALIGNED
  32 #include <libavcodec/avcodec.h>
  33 #include <libswscale/swscale.h>
  34
  35 #ifdef _WIN32
  36 #include <windows.h>
  37 #else
  38 #define SetConsoleTitle(t)
  39 #endif
  40
  41 typedef struct
  42 {
  43     FFMS_VideoSource *video_source;
  44     FFMS_Track *track;
  45     int reduce_pts;
  46     int vfr_input;
  47     int num_frames;
  48     int64_t time;
  49 } ffms_hnd_t;
  50
  51 static int FFMS_CC update_progress( int64_t current, int64_t total, void *private )
  52 {
  53     int64_t *update_time = private;
  54     int64_t oldtime = *update_time;
  55     int64_t newtime = x264_mdate();
  56     if( oldtime && newtime - oldtime < UPDATE_INTERVAL )
  57         return 0;
  58     *update_time = newtime;
  59
  60     char buf[200];
  61     sprintf( buf, "ffms [info]: indexing input file [%.1f%%]", 100.0 * current / total );
  62     fprintf( stderr, "%s  \r", buf+5 );
  63     SetConsoleTitle( buf );
  64     fflush( stderr );
  65     return 0;
  66 }
  67
  68 static int open_file( char *psz_filename, hnd_t *p_handle, video_info_t *info, cli_input_opt_t *opt )
  69 {
  70     ffms_hnd_t *h = calloc( 1, sizeof(ffms_hnd_t) );
  71     if( !h )
  72         return -1;
  73     FFMS_Init( 0, 0 );
  74     FFMS_ErrorInfo e;
  75     e.BufferSize = 0;
  76     int seekmode = opt->seek ? FFMS_SEEK_NORMAL : FFMS_SEEK_LINEAR_NO_RW;
  77
  78     FFMS_Index *idx = NULL;
  79     if( opt->index_file )
  80     {
  81         struct stat index_s, input_s;
  82         if( !stat( opt->index_file, &index_s ) && !stat( psz_filename, &input_s ) &&
  83             input_s.st_mtime < index_s.st_mtime )
  84             idx = FFMS_ReadIndex( opt->index_file, &e );
  85     }
  86     if( !idx )
  87     {
  88         if( opt->progress )
  89         {
  90             idx = FFMS_MakeIndex( psz_filename, 0, 0, NULL, NULL, 0, update_progress, &h->time, &e );
  91             fprintf( stderr, "                                            \r" );
  92         }
  93         else
  94             idx = FFMS_MakeIndex( psz_filename, 0, 0, NULL, NULL, 0, NULL, NULL, &e );
  95         FAIL_IF_ERROR( !idx, "could not create index\n" )
  96         if( opt->index_file && FFMS_WriteIndex( opt->index_file, idx, &e ) )
  97             x264_cli_log( "ffms", X264_LOG_WARNING, "could not write index file\n" );
  98     }
  99
 100     int trackno = FFMS_GetFirstTrackOfType( idx, FFMS_TYPE_VIDEO, &e );
 101     FAIL_IF_ERROR( trackno < 0, "could not find video track\n" )
 102
 103     h->video_source = FFMS_CreateVideoSource( psz_filename, trackno, idx, 1, seekmode, &e );
 104     FAIL_IF_ERROR( !h->video_source, "could not create video source\n" )
 105
 106     h->track = FFMS_GetTrackFromVideo( h->video_source );
 107
 108     FFMS_DestroyIndex( idx );
 109     const FFMS_VideoProperties *videop = FFMS_GetVideoProperties( h->video_source );
 110     info->num_frames   = h->num_frames = videop->NumFrames;
 111     info->sar_height   = videop->SARDen;
 112     info->sar_width    = videop->SARNum;
 113     info->fps_den      = videop->FPSDenominator;
 114     info->fps_num      = videop->FPSNumerator;
 115     h->vfr_input       = info->vfr;
 116     /* ffms is thread unsafe as it uses a single frame buffer for all frame requests */
 117     info->thread_safe  = 0;
 118
 119     const FFMS_Frame *frame = FFMS_GetFrame( h->video_source, 0, &e );
 120     FAIL_IF_ERROR( !frame, "could not read frame 0\n" )
 121
 122     info->width      = frame->EncodedWidth;
 123     info->height     = frame->EncodedHeight;
 124     info->csp        = frame->EncodedPixelFormat | X264_CSP_OTHER;
 125     info->interlaced = frame->InterlacedFrame;
 126     info->tff        = frame->TopFieldFirst;
 127
 128     /* ffms timestamps are in milliseconds. ffms also uses int64_ts for timebase,
 129      * so we need to reduce large timebases to prevent overflow */
 130     if( h->vfr_input )
 131     {
 132         const FFMS_TrackTimeBase *timebase = FFMS_GetTimeBase( h->track );
 133         int64_t timebase_num = timebase->Num;
 134         int64_t timebase_den = timebase->Den * 1000;
 135         h->reduce_pts = 0;
 136
 137         while( timebase_num > UINT32_MAX || timebase_den > INT32_MAX )
 138         {
 139             timebase_num >>= 1;
 140             timebase_den >>= 1;
 141             h->reduce_pts++;
 142         }
 143         info->timebase_num = timebase_num;
 144         info->timebase_den = timebase_den;
 145     }
 146
 147     *p_handle = h;
 148     return 0;
 149 }
 150
 151 static int picture_alloc( cli_pic_t *pic, int csp, int width, int height )
 152 {
 153     if( x264_cli_pic_alloc( pic, csp, width, height ) )
 154         return -1;
 155     pic->img.planes = 4;
 156     return 0;
 157 }
 158
 159 static int read_frame( cli_pic_t *pic, hnd_t handle, int i_frame )
 160 {
 161     ffms_hnd_t *h = handle;
 162     if( i_frame >= h->num_frames )
 163         return -1;
 164     FFMS_ErrorInfo e;
 165     e.BufferSize = 0;
 166     const FFMS_Frame *frame = FFMS_GetFrame( h->video_source, i_frame, &e );
 167     FAIL_IF_ERROR( !frame, "could not read frame %d \n", i_frame )
 168
 169     memcpy( pic->img.stride, frame->Linesize, sizeof(pic->img.stride) );
 170     memcpy( pic->img.plane, frame->Data, sizeof(pic->img.plane) );
 171
 172     if( h->vfr_input )
 173     {
 174         const FFMS_FrameInfo *info = FFMS_GetFrameInfo( h->track, i_frame );
 175         FAIL_IF_ERROR( info->PTS == AV_NOPTS_VALUE, "invalid timestamp. "
 176                        "Use --force-cfr and specify a framerate with --fps\n" )
 177
 178         pic->pts = info->PTS >> h->reduce_pts;
 179         pic->duration = 0;
 180     }
 181     return 0;
 182 }
 183
 184 static void picture_clean( cli_pic_t *pic )
 185 {
 186     memset( pic, 0, sizeof(cli_pic_t) );
 187 }
 188
 189 static int close_file( hnd_t handle )
 190 {
 191     ffms_hnd_t *h = handle;
 192     FFMS_DestroyVideoSource( h->video_source );
 193     free( h );
 194     return 0;
 195 }
 196
 197 const cli_input_t ffms_input = { open_file, picture_alloc, read_frame, NULL, picture_clean, close_file };