1 /*****************************************************************************
2 * transcode.c: transcoding stream output module
3 *****************************************************************************
4 * Copyright (C) 2003-2008 the VideoLAN team
7 * Authors: Laurent Aimar <fenrir@via.ecp.fr>
8 * Gildas Bazin <gbazin@videolan.org>
9 * Jean-Paul Saman <jpsaman #_at_# m2x dot nl>
11 * This program is free software; you can redistribute it and/or modify
12 * it under the terms of the GNU General Public License as published by
13 * the Free Software Foundation; either version 2 of the License, or
14 * (at your option) any later version.
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
21 * You should have received a copy of the GNU General Public License
22 * along with this program; if not, write to the Free Software
23 * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston MA 02110-1301, USA.
24 *****************************************************************************/
26 /*****************************************************************************
28 *****************************************************************************/
34 #include <vlc_plugin.h>
35 #include <vlc_input.h>
39 #include <vlc_codec.h>
40 #include <vlc_block.h>
41 #include <vlc_filter.h>
46 #define MASTER_SYNC_MAX_DRIFT 100000
48 /*****************************************************************************
50 *****************************************************************************/
51 #define VENC_TEXT N_("Video encoder")
52 #define VENC_LONGTEXT N_( \
53 "This is the video encoder module that will be used (and its associated "\
55 #define VCODEC_TEXT N_("Destination video codec")
56 #define VCODEC_LONGTEXT N_( \
57 "This is the video codec that will be used.")
58 #define VB_TEXT N_("Video bitrate")
59 #define VB_LONGTEXT N_( \
60 "Target bitrate of the transcoded video stream." )
61 #define SCALE_TEXT N_("Video scaling")
62 #define SCALE_LONGTEXT N_( \
63 "Scale factor to apply to the video while transcoding (eg: 0.25)")
64 #define FPS_TEXT N_("Video frame-rate")
65 #define FPS_LONGTEXT N_( \
66 "Target output frame rate for the video stream." )
67 #define DEINTERLACE_TEXT N_("Deinterlace video")
68 #define DEINTERLACE_LONGTEXT N_( \
69 "Deinterlace the video before encoding." )
70 #define DEINTERLACE_MODULE_TEXT N_("Deinterlace module")
71 #define DEINTERLACE_MODULE_LONGTEXT N_( \
72 "Specify the deinterlace module to use." )
73 #define WIDTH_TEXT N_("Video width")
74 #define WIDTH_LONGTEXT N_( \
75 "Output video width." )
76 #define HEIGHT_TEXT N_("Video height")
77 #define HEIGHT_LONGTEXT N_( \
78 "Output video height." )
79 #define MAXWIDTH_TEXT N_("Maximum video width")
80 #define MAXWIDTH_LONGTEXT N_( \
81 "Maximum output video width." )
82 #define MAXHEIGHT_TEXT N_("Maximum video height")
83 #define MAXHEIGHT_LONGTEXT N_( \
84 "Maximum output video height." )
85 #define VFILTER_TEXT N_("Video filter")
86 #define VFILTER_LONGTEXT N_( \
87 "Video filters will be applied to the video streams (after overlays " \
88 "are applied). You must enter a comma-separated list of filters." )
90 #define CROPTOP_TEXT N_("Video crop (top)")
91 #define CROPTOP_LONGTEXT N_( \
92 "Number of pixels to crop at the top of the video." )
93 #define CROPLEFT_TEXT N_("Video crop (left)")
94 #define CROPLEFT_LONGTEXT N_( \
95 "Number of pixels to crop at the left of the video." )
96 #define CROPBOTTOM_TEXT N_("Video crop (bottom)")
97 #define CROPBOTTOM_LONGTEXT N_( \
98 "Number of pixels to crop at the bottom of the video." )
99 #define CROPRIGHT_TEXT N_("Video crop (right)")
100 #define CROPRIGHT_LONGTEXT N_( \
101 "Number of pixels to crop at the right of the video." )
103 #define PADDTOP_TEXT N_("Video padding (top)")
104 #define PADDTOP_LONGTEXT N_( \
105 "Size of the black border to add at the top of the video." )
106 #define PADDLEFT_TEXT N_("Video padding (left)")
107 #define PADDLEFT_LONGTEXT N_( \
108 "Size of the black border to add at the left of the video." )
109 #define PADDBOTTOM_TEXT N_("Video padding (bottom)")
110 #define PADDBOTTOM_LONGTEXT N_( \
111 "Size of the black border to add at the bottom of the video." )
112 #define PADDRIGHT_TEXT N_("Video padding (right)")
113 #define PADDRIGHT_LONGTEXT N_( \
114 "Size of the black border to add at the right of the video." )
116 #define CANVAS_WIDTH_TEXT N_("Video canvas width")
117 #define CANVAS_WIDTH_LONGTEXT N_( \
118 "This will automatically crod and pad the video to a specified width." )
119 #define CANVAS_HEIGHT_TEXT N_("Video canvas height")
120 #define CANVAS_HEIGHT_LONGTEXT N_( \
121 "This will automatically crod and pad the video to a specified height." )
122 #define CANVAS_ASPECT_TEXT N_("Video canvas aspect ratio")
123 #define CANVAS_ASPECT_LONGTEXT N_( \
124 "This sets aspect (like 4:3) of the video canvas and letterbox the video "\
127 #define AENC_TEXT N_("Audio encoder")
128 #define AENC_LONGTEXT N_( \
129 "This is the audio encoder module that will be used (and its associated "\
131 #define ACODEC_TEXT N_("Destination audio codec")
132 #define ACODEC_LONGTEXT N_( \
133 "This is the audio codec that will be used.")
134 #define AB_TEXT N_("Audio bitrate")
135 #define AB_LONGTEXT N_( \
136 "Target bitrate of the transcoded audio stream." )
137 #define ARATE_TEXT N_("Audio sample rate")
138 #define ARATE_LONGTEXT N_( \
139 "Sample rate of the transcoded audio stream (11250, 22500, 44100 or 48000).")
140 #define ACHANS_TEXT N_("Audio channels")
141 #define ACHANS_LONGTEXT N_( \
142 "Number of audio channels in the transcoded streams." )
143 #define AFILTER_TEXT N_("Audio filter")
144 #define AFILTER_LONGTEXT N_( \
145 "Audio filters will be applied to the audio streams (after conversion " \
146 "filters are applied). You must enter a comma-separated list of filters." )
148 #define SENC_TEXT N_("Subtitles encoder")
149 #define SENC_LONGTEXT N_( \
150 "This is the subtitles encoder module that will be used (and its " \
151 "associated options)." )
152 #define SCODEC_TEXT N_("Destination subtitles codec")
153 #define SCODEC_LONGTEXT N_( \
154 "This is the subtitles codec that will be used." )
156 #define SFILTER_TEXT N_("Overlays")
157 #define SFILTER_LONGTEXT N_( \
158 "This allows you to add overlays (also known as \"subpictures\" on the "\
159 "transcoded video stream. The subpictures produced by the filters will "\
160 "be overlayed directly onto the video. You must specify a comma-separated "\
161 "list of subpicture modules" )
163 #define OSD_TEXT N_("OSD menu")
164 #define OSD_LONGTEXT N_(\
165 "Stream the On Screen Display menu (using the osdmenu subpicture module)." )
167 #define THREADS_TEXT N_("Number of threads")
168 #define THREADS_LONGTEXT N_( \
169 "Number of threads used for the transcoding." )
170 #define HP_TEXT N_("High priority")
171 #define HP_LONGTEXT N_( \
172 "Runs the optional encoder thread at the OUTPUT priority instead of " \
175 #define ASYNC_TEXT N_("Synchronise on audio track")
176 #define ASYNC_LONGTEXT N_( \
177 "This option will drop/duplicate video frames to synchronise the video " \
178 "track on the audio track." )
180 #define HURRYUP_TEXT N_( "Hurry up" )
181 #define HURRYUP_LONGTEXT N_( "The transcoder will drop frames if your CPU " \
182 "can't keep up with the encoding rate." )
184 static const char *ppsz_deinterlace_type[] =
186 "deinterlace", "ffmpeg-deinterlace"
189 static int Open ( vlc_object_t * );
190 static void Close( vlc_object_t * );
192 #define SOUT_CFG_PREFIX "sout-transcode-"
195 set_shortname( N_("Transcode"));
196 set_description( N_("Transcode stream output") );
197 set_capability( "sout stream", 50 );
198 add_shortcut( "transcode" );
199 set_callbacks( Open, Close );
200 set_category( CAT_SOUT );
201 set_subcategory( SUBCAT_SOUT_STREAM );
202 set_section( N_("Video"), NULL );
203 add_string( SOUT_CFG_PREFIX "venc", NULL, NULL, VENC_TEXT,
204 VENC_LONGTEXT, false );
205 add_string( SOUT_CFG_PREFIX "vcodec", NULL, NULL, VCODEC_TEXT,
206 VCODEC_LONGTEXT, false );
207 add_integer( SOUT_CFG_PREFIX "vb", 800 * 1000, NULL, VB_TEXT,
208 VB_LONGTEXT, false );
209 add_float( SOUT_CFG_PREFIX "scale", 1, NULL, SCALE_TEXT,
210 SCALE_LONGTEXT, false );
211 add_float( SOUT_CFG_PREFIX "fps", 0, NULL, FPS_TEXT,
212 FPS_LONGTEXT, false );
213 add_bool( SOUT_CFG_PREFIX "hurry-up", true, NULL, HURRYUP_TEXT,
214 HURRYUP_LONGTEXT, false );
215 add_bool( SOUT_CFG_PREFIX "deinterlace", 0, NULL, DEINTERLACE_TEXT,
216 DEINTERLACE_LONGTEXT, false );
217 add_string( SOUT_CFG_PREFIX "deinterlace-module", "deinterlace", NULL,
218 DEINTERLACE_MODULE_TEXT, DEINTERLACE_MODULE_LONGTEXT,
220 change_string_list( ppsz_deinterlace_type, 0, 0 );
221 add_integer( SOUT_CFG_PREFIX "width", 0, NULL, WIDTH_TEXT,
222 WIDTH_LONGTEXT, true );
223 add_integer( SOUT_CFG_PREFIX "height", 0, NULL, HEIGHT_TEXT,
224 HEIGHT_LONGTEXT, true );
225 add_integer( SOUT_CFG_PREFIX "maxwidth", 0, NULL, MAXWIDTH_TEXT,
226 MAXWIDTH_LONGTEXT, true );
227 add_integer( SOUT_CFG_PREFIX "maxheight", 0, NULL, MAXHEIGHT_TEXT,
228 MAXHEIGHT_LONGTEXT, true );
229 add_module_list( SOUT_CFG_PREFIX "vfilter", "video filter2",
231 VFILTER_TEXT, VFILTER_LONGTEXT, false );
233 add_integer( SOUT_CFG_PREFIX "croptop", 0, NULL, CROPTOP_TEXT,
234 CROPTOP_LONGTEXT, true );
235 add_integer( SOUT_CFG_PREFIX "cropleft", 0, NULL, CROPLEFT_TEXT,
236 CROPLEFT_LONGTEXT, true );
237 add_integer( SOUT_CFG_PREFIX "cropbottom", 0, NULL, CROPBOTTOM_TEXT,
238 CROPBOTTOM_LONGTEXT, true );
239 add_integer( SOUT_CFG_PREFIX "cropright", 0, NULL, CROPRIGHT_TEXT,
240 CROPRIGHT_LONGTEXT, true );
242 add_integer( SOUT_CFG_PREFIX "paddtop", 0, NULL, PADDTOP_TEXT,
243 PADDTOP_LONGTEXT, true );
244 add_integer( SOUT_CFG_PREFIX "paddleft", 0, NULL, PADDLEFT_TEXT,
245 PADDLEFT_LONGTEXT, true );
246 add_integer( SOUT_CFG_PREFIX "paddbottom", 0, NULL, PADDBOTTOM_TEXT,
247 PADDBOTTOM_LONGTEXT, true );
248 add_integer( SOUT_CFG_PREFIX "paddright", 0, NULL, PADDRIGHT_TEXT,
249 PADDRIGHT_LONGTEXT, true );
251 add_integer( SOUT_CFG_PREFIX "canvas-width", 0, NULL, CANVAS_WIDTH_TEXT,
252 CANVAS_WIDTH_LONGTEXT, true );
253 add_integer( SOUT_CFG_PREFIX "canvas-height", 0, NULL, CANVAS_HEIGHT_TEXT,
254 CANVAS_HEIGHT_LONGTEXT, true );
255 add_string( SOUT_CFG_PREFIX "canvas-aspect", NULL, NULL, CANVAS_ASPECT_TEXT,
256 CANVAS_ASPECT_LONGTEXT, false );
258 set_section( N_("Audio"), NULL );
259 add_string( SOUT_CFG_PREFIX "aenc", NULL, NULL, AENC_TEXT,
260 AENC_LONGTEXT, false );
261 add_string( SOUT_CFG_PREFIX "acodec", NULL, NULL, ACODEC_TEXT,
262 ACODEC_LONGTEXT, false );
263 add_integer( SOUT_CFG_PREFIX "ab", 0, NULL, AB_TEXT,
264 AB_LONGTEXT, false );
265 add_integer( SOUT_CFG_PREFIX "channels", 0, NULL, ACHANS_TEXT,
266 ACHANS_LONGTEXT, false );
267 add_integer( SOUT_CFG_PREFIX "samplerate", 0, NULL, ARATE_TEXT,
268 ARATE_LONGTEXT, true );
269 add_bool( SOUT_CFG_PREFIX "audio-sync", 0, NULL, ASYNC_TEXT,
270 ASYNC_LONGTEXT, false );
271 add_module_list( SOUT_CFG_PREFIX "afilter", "audio filter2",
273 AFILTER_TEXT, AFILTER_LONGTEXT, false );
275 set_section( N_("Overlays/Subtitles"), NULL );
276 add_string( SOUT_CFG_PREFIX "senc", NULL, NULL, SENC_TEXT,
277 SENC_LONGTEXT, false );
278 add_string( SOUT_CFG_PREFIX "scodec", NULL, NULL, SCODEC_TEXT,
279 SCODEC_LONGTEXT, false );
280 add_bool( SOUT_CFG_PREFIX "soverlay", 0, NULL, SCODEC_TEXT,
281 SCODEC_LONGTEXT, false );
282 add_module_list( SOUT_CFG_PREFIX "sfilter", "video filter",
284 SFILTER_TEXT, SFILTER_LONGTEXT, false );
286 set_section( N_("On Screen Display"), NULL );
287 add_bool( SOUT_CFG_PREFIX "osd", 0, NULL, OSD_TEXT,
288 OSD_LONGTEXT, false );
290 set_section( N_("Miscellaneous"), NULL );
291 add_integer( SOUT_CFG_PREFIX "threads", 0, NULL, THREADS_TEXT,
292 THREADS_LONGTEXT, true );
293 add_bool( SOUT_CFG_PREFIX "high-priority", 0, NULL, HP_TEXT, HP_LONGTEXT,
298 static const char *ppsz_sout_options[] = {
299 "venc", "vcodec", "vb", "croptop", "cropbottom", "cropleft", "cropright",
300 "paddtop", "paddbottom", "paddleft", "paddright",
301 "canvas-width", "canvas-height", "canvas-aspect",
302 "scale", "fps", "width", "height", "vfilter", "deinterlace",
303 "deinterlace-module", "threads", "hurry-up", "aenc", "acodec", "ab",
304 "afilter", "samplerate", "channels", "senc", "scodec", "soverlay",
305 "sfilter", "osd", "audio-sync", "high-priority", "maxwidth", "maxheight",
309 /*****************************************************************************
310 * Exported prototypes
311 *****************************************************************************/
312 static sout_stream_id_t *Add ( sout_stream_t *, es_format_t * );
313 static int Del ( sout_stream_t *, sout_stream_id_t * );
314 static int Send( sout_stream_t *, sout_stream_id_t *, block_t* );
316 static int transcode_audio_new ( sout_stream_t *, sout_stream_id_t * );
317 static void transcode_audio_close ( sout_stream_id_t * );
318 static int transcode_audio_process( sout_stream_t *, sout_stream_id_t *,
319 block_t *, block_t ** );
321 static aout_buffer_t *audio_new_buffer( decoder_t *, int );
322 static void audio_del_buffer( decoder_t *, aout_buffer_t * );
324 static int transcode_video_new ( sout_stream_t *, sout_stream_id_t * );
325 static void transcode_video_close ( sout_stream_t *, sout_stream_id_t * );
326 static int transcode_video_encoder_open( sout_stream_t *, sout_stream_id_t *);
327 static int transcode_video_process( sout_stream_t *, sout_stream_id_t *,
328 block_t *, block_t ** );
330 static void video_del_buffer( vlc_object_t *, picture_t * );
331 static picture_t *video_new_buffer_decoder( decoder_t * );
332 static void video_del_buffer_decoder( decoder_t *, picture_t * );
333 static void video_link_picture_decoder( decoder_t *, picture_t * );
334 static void video_unlink_picture_decoder( decoder_t *, picture_t * );
335 static picture_t *video_new_buffer_filter( filter_t * );
336 static void video_del_buffer_filter( filter_t *, picture_t * );
338 static int transcode_spu_new ( sout_stream_t *, sout_stream_id_t * );
339 static void transcode_spu_close ( sout_stream_id_t * );
340 static int transcode_spu_process( sout_stream_t *, sout_stream_id_t *,
341 block_t *, block_t ** );
343 static int transcode_osd_new ( sout_stream_t *, sout_stream_id_t * );
344 static void transcode_osd_close ( sout_stream_t *, sout_stream_id_t * );
345 static int transcode_osd_process( sout_stream_t *, sout_stream_id_t *,
346 block_t *, block_t ** );
348 static int EncoderThread( struct sout_stream_sys_t * p_sys );
350 static int pi_channels_maps[6] =
353 AOUT_CHAN_CENTER, AOUT_CHAN_LEFT | AOUT_CHAN_RIGHT,
354 AOUT_CHAN_CENTER | AOUT_CHAN_LEFT | AOUT_CHAN_RIGHT,
355 AOUT_CHAN_LEFT | AOUT_CHAN_RIGHT | AOUT_CHAN_REARLEFT
356 | AOUT_CHAN_REARRIGHT,
357 AOUT_CHAN_LEFT | AOUT_CHAN_RIGHT | AOUT_CHAN_CENTER
358 | AOUT_CHAN_REARLEFT | AOUT_CHAN_REARRIGHT
361 #define PICTURE_RING_SIZE 64
362 #define SUBPICTURE_RING_SIZE 20
363 #define TRANSCODE_FILTERS 10
365 #define ENC_FRAMERATE (25 * 1000 + .5)
366 #define ENC_FRAMERATE_BASE 1000
368 struct sout_stream_sys_t
372 sout_stream_t *p_out;
373 sout_stream_id_t *id_video;
375 vlc_mutex_t lock_out;
377 picture_t * pp_pics[PICTURE_RING_SIZE];
378 int i_first_pic, i_last_pic;
381 vlc_fourcc_t i_acodec; /* codec audio (0 if not transcode) */
383 config_chain_t *p_audio_cfg;
384 uint32_t i_sample_rate;
387 char *psz_afilters[TRANSCODE_FILTERS];
388 config_chain_t *p_afilters_cfg[TRANSCODE_FILTERS];
392 vlc_fourcc_t i_vcodec; /* codec video (0 if not transcode) */
394 config_chain_t *p_video_cfg;
398 unsigned int i_width, i_maxwidth;
399 unsigned int i_height, i_maxheight;
401 char *psz_deinterlace;
402 config_chain_t *p_deinterlace_cfg;
404 bool b_high_priority;
406 char *psz_vfilters[TRANSCODE_FILTERS];
407 config_chain_t *p_vfilters_cfg[TRANSCODE_FILTERS];
424 /* Video, calculated */
436 vlc_fourcc_t i_scodec; /* codec spu (0 if not transcode) */
439 config_chain_t *p_spu_cfg;
443 vlc_fourcc_t i_osdcodec; /* codec osd menu (0 if not transcode) */
445 config_chain_t *p_osd_cfg;
446 bool b_osd; /* true when osd es is registered */
450 mtime_t i_master_drift;
453 struct decoder_owner_sys_t
455 picture_t *pp_pics[PICTURE_RING_SIZE];
456 sout_stream_sys_t *p_sys;
458 struct filter_owner_sys_t
460 picture_t *pp_pics[PICTURE_RING_SIZE];
461 sout_stream_sys_t *p_sys;
464 /*****************************************************************************
466 *****************************************************************************/
467 static int Open( vlc_object_t *p_this )
469 sout_stream_t *p_stream = (sout_stream_t*)p_this;
470 sout_stream_sys_t *p_sys;
473 p_sys = vlc_object_create( p_this, sizeof( sout_stream_sys_t ) );
475 p_sys->p_out = sout_StreamNew( p_stream->p_sout, p_stream->psz_next );
478 msg_Err( p_stream, "cannot create chain" );
479 vlc_object_release( p_sys );
483 p_sys->i_master_drift = 0;
485 config_ChainParse( p_stream, SOUT_CFG_PREFIX, ppsz_sout_options,
488 /* Audio transcoding parameters */
489 var_Get( p_stream, SOUT_CFG_PREFIX "aenc", &val );
490 p_sys->psz_aenc = NULL;
491 p_sys->p_audio_cfg = NULL;
492 if( val.psz_string && *val.psz_string )
495 psz_next = config_ChainCreate( &p_sys->psz_aenc, &p_sys->p_audio_cfg,
499 free( val.psz_string );
501 var_Get( p_stream, SOUT_CFG_PREFIX "acodec", &val );
503 if( val.psz_string && *val.psz_string )
506 memcpy( fcc, val.psz_string, __MIN( strlen( val.psz_string ), 4 ) );
507 p_sys->i_acodec = VLC_FOURCC( fcc[0], fcc[1], fcc[2], fcc[3] );
509 free( val.psz_string );
511 var_Get( p_stream, SOUT_CFG_PREFIX "ab", &val );
512 p_sys->i_abitrate = val.i_int;
513 if( p_sys->i_abitrate < 4000 ) p_sys->i_abitrate *= 1000;
515 var_Get( p_stream, SOUT_CFG_PREFIX "samplerate", &val );
516 p_sys->i_sample_rate = val.i_int;
518 var_Get( p_stream, SOUT_CFG_PREFIX "channels", &val );
519 p_sys->i_channels = val.i_int;
521 if( p_sys->i_acodec )
523 if( p_sys->i_acodec == VLC_FOURCC('m','p','3',0) &&
524 p_sys->i_channels > 2 )
526 msg_Warn( p_stream, "%d channels invalid for mp3, forcing to 2",
528 p_sys->i_channels = 2;
530 msg_Dbg( p_stream, "codec audio=%4.4s %dHz %d channels %dKb/s",
531 (char *)&p_sys->i_acodec, p_sys->i_sample_rate,
532 p_sys->i_channels, p_sys->i_abitrate / 1000 );
535 var_Get( p_stream, SOUT_CFG_PREFIX "afilter", &val );
536 p_sys->i_afilters = 0;
537 if( val.psz_string && *val.psz_string )
539 char *psz_parser = val.psz_string;
541 while( (psz_parser != NULL) && (*psz_parser != '\0')
542 && (p_sys->i_afilters < TRANSCODE_FILTERS) )
544 psz_parser = config_ChainCreate(
545 &p_sys->psz_afilters[p_sys->i_afilters],
546 &p_sys->p_afilters_cfg[p_sys->i_afilters],
549 if( (psz_parser != NULL) && (*psz_parser != '\0') ) psz_parser++;
552 free( val.psz_string );
553 if( p_sys->i_afilters < TRANSCODE_FILTERS-1 )
555 p_sys->psz_afilters[p_sys->i_afilters] = NULL;
556 p_sys->p_afilters_cfg[p_sys->i_afilters] = NULL;
559 /* Video transcoding parameters */
560 var_Get( p_stream, SOUT_CFG_PREFIX "venc", &val );
561 p_sys->psz_venc = NULL;
562 p_sys->p_video_cfg = NULL;
563 if( val.psz_string && *val.psz_string )
566 psz_next = config_ChainCreate( &p_sys->psz_venc, &p_sys->p_video_cfg,
570 free( val.psz_string );
572 var_Get( p_stream, SOUT_CFG_PREFIX "vcodec", &val );
574 if( val.psz_string && *val.psz_string )
577 memcpy( fcc, val.psz_string, __MIN( strlen( val.psz_string ), 4 ) );
578 p_sys->i_vcodec = VLC_FOURCC( fcc[0], fcc[1], fcc[2], fcc[3] );
580 free( val.psz_string );
582 var_Get( p_stream, SOUT_CFG_PREFIX "vb", &val );
583 p_sys->i_vbitrate = val.i_int;
584 if( p_sys->i_vbitrate < 16000 ) p_sys->i_vbitrate *= 1000;
586 var_Get( p_stream, SOUT_CFG_PREFIX "scale", &val );
587 p_sys->f_scale = val.f_float;
589 var_Get( p_stream, SOUT_CFG_PREFIX "fps", &val );
590 p_sys->f_fps = val.f_float;
592 var_Get( p_stream, SOUT_CFG_PREFIX "hurry-up", &val );
593 p_sys->b_hurry_up = val.b_bool;
595 var_Get( p_stream, SOUT_CFG_PREFIX "width", &val );
596 p_sys->i_width = val.i_int;
598 var_Get( p_stream, SOUT_CFG_PREFIX "height", &val );
599 p_sys->i_height = val.i_int;
601 var_Get( p_stream, SOUT_CFG_PREFIX "maxwidth", &val );
602 p_sys->i_maxwidth = val.i_int;
604 var_Get( p_stream, SOUT_CFG_PREFIX "maxheight", &val );
605 p_sys->i_maxheight = val.i_int;
607 var_Get( p_stream, SOUT_CFG_PREFIX "vfilter", &val );
608 p_sys->i_vfilters = 0;
609 if( val.psz_string && *val.psz_string )
611 char *psz_parser = val.psz_string;
613 while( (psz_parser != NULL) && (*psz_parser != '\0')
614 && (p_sys->i_vfilters < TRANSCODE_FILTERS) )
616 psz_parser = config_ChainCreate(
617 &p_sys->psz_vfilters[p_sys->i_vfilters],
618 &p_sys->p_vfilters_cfg[p_sys->i_vfilters],
621 if( psz_parser != NULL && *psz_parser != '\0' ) psz_parser++;
624 free( val.psz_string );
625 if( p_sys->i_vfilters < TRANSCODE_FILTERS-1 )
627 p_sys->psz_vfilters[p_sys->i_vfilters] = NULL;
628 p_sys->p_vfilters_cfg[p_sys->i_vfilters] = NULL;
631 var_Get( p_stream, SOUT_CFG_PREFIX "deinterlace", &val );
632 p_sys->b_deinterlace = val.b_bool;
634 var_Get( p_stream, SOUT_CFG_PREFIX "deinterlace-module", &val );
635 p_sys->psz_deinterlace = NULL;
636 p_sys->p_deinterlace_cfg = NULL;
637 if( val.psz_string && *val.psz_string )
640 psz_next = config_ChainCreate( &p_sys->psz_deinterlace,
641 &p_sys->p_deinterlace_cfg,
645 free( val.psz_string );
647 var_Get( p_stream, SOUT_CFG_PREFIX "croptop", &val );
648 p_sys->i_crop_top = val.i_int;
649 var_Get( p_stream, SOUT_CFG_PREFIX "cropbottom", &val );
650 p_sys->i_crop_bottom = val.i_int;
651 var_Get( p_stream, SOUT_CFG_PREFIX "cropleft", &val );
652 p_sys->i_crop_left = val.i_int;
653 var_Get( p_stream, SOUT_CFG_PREFIX "cropright", &val );
654 p_sys->i_crop_right = val.i_int;
656 var_Get( p_stream, SOUT_CFG_PREFIX "paddtop", &val );
657 p_sys->i_padd_top = val.i_int;
658 var_Get( p_stream, SOUT_CFG_PREFIX "paddbottom", &val );
659 p_sys->i_padd_bottom = val.i_int;
660 var_Get( p_stream, SOUT_CFG_PREFIX "paddleft", &val );
661 p_sys->i_padd_left = val.i_int;
662 var_Get( p_stream, SOUT_CFG_PREFIX "paddright", &val );
663 p_sys->i_padd_right = val.i_int;
665 var_Get( p_stream, SOUT_CFG_PREFIX "canvas-width", &val );
666 p_sys->i_canvas_width = val.i_int;
667 var_Get( p_stream, SOUT_CFG_PREFIX "canvas-height", &val );
668 p_sys->i_canvas_height = val.i_int;
670 var_Get( p_stream, SOUT_CFG_PREFIX "canvas-aspect", &val );
671 p_sys->i_canvas_aspect = 0;
672 if( val.psz_string && *val.psz_string )
674 char *psz_parser = strchr( val.psz_string, ':' );
677 *psz_parser++ = '\0';
678 p_sys->i_canvas_aspect = atoi( val.psz_string ) *
679 VOUT_ASPECT_FACTOR / atoi( psz_parser );
681 else msg_Warn( p_stream, "bad aspect ratio %s", val.psz_string );
684 free( val.psz_string );
686 var_Get( p_stream, SOUT_CFG_PREFIX "threads", &val );
687 p_sys->i_threads = val.i_int;
688 var_Get( p_stream, SOUT_CFG_PREFIX "high-priority", &val );
689 p_sys->b_high_priority = val.b_bool;
691 if( p_sys->i_vcodec )
693 msg_Dbg( p_stream, "codec video=%4.4s %dx%d scaling: %f %dkb/s",
694 (char *)&p_sys->i_vcodec, p_sys->i_width, p_sys->i_height,
695 p_sys->f_scale, p_sys->i_vbitrate / 1000 );
698 /* Subpictures transcoding parameters */
700 p_sys->psz_senc = NULL;
701 p_sys->p_spu_cfg = NULL;
704 var_Get( p_stream, SOUT_CFG_PREFIX "senc", &val );
705 if( val.psz_string && *val.psz_string )
708 psz_next = config_ChainCreate( &p_sys->psz_senc, &p_sys->p_spu_cfg,
712 free( val.psz_string );
714 var_Get( p_stream, SOUT_CFG_PREFIX "scodec", &val );
715 if( val.psz_string && *val.psz_string )
718 memcpy( fcc, val.psz_string, __MIN( strlen( val.psz_string ), 4 ) );
719 p_sys->i_scodec = VLC_FOURCC( fcc[0], fcc[1], fcc[2], fcc[3] );
721 free( val.psz_string );
723 if( p_sys->i_scodec )
725 msg_Dbg( p_stream, "codec spu=%4.4s", (char *)&p_sys->i_scodec );
728 var_Get( p_stream, SOUT_CFG_PREFIX "soverlay", &val );
729 p_sys->b_soverlay = val.b_bool;
731 var_Get( p_stream, SOUT_CFG_PREFIX "sfilter", &val );
732 if( val.psz_string && *val.psz_string )
734 p_sys->p_spu = spu_Create( p_stream );
735 var_Create( p_sys->p_spu, "sub-filter", VLC_VAR_STRING );
736 var_Set( p_sys->p_spu, "sub-filter", val );
737 spu_Init( p_sys->p_spu );
739 free( val.psz_string );
741 /* OSD menu transcoding parameters */
742 p_sys->psz_osdenc = NULL;
743 p_sys->p_osd_cfg = NULL;
744 p_sys->i_osdcodec = 0;
745 p_sys->b_osd = false;
747 var_Get( p_stream, SOUT_CFG_PREFIX "osd", &val );
753 psz_next = config_ChainCreate( &p_sys->psz_osdenc,
754 &p_sys->p_osd_cfg, strdup( "dvbsub") );
757 p_sys->i_osdcodec = VLC_FOURCC('Y','U','V','P' );
759 msg_Dbg( p_stream, "codec osd=%4.4s", (char *)&p_sys->i_osdcodec );
763 osd_val.psz_string = strdup("osdmenu");
764 p_sys->p_spu = spu_Create( p_stream );
765 var_Create( p_sys->p_spu, "sub-filter", VLC_VAR_STRING );
766 var_Set( p_sys->p_spu, "sub-filter", osd_val );
767 spu_Init( p_sys->p_spu );
768 free( osd_val.psz_string );
772 osd_val.psz_string = strdup("osdmenu");
773 var_Set( p_sys->p_spu, "sub-filter", osd_val );
774 free( osd_val.psz_string );
779 var_Get( p_stream, SOUT_CFG_PREFIX "audio-sync", &val );
780 p_sys->b_master_sync = val.b_bool;
781 if( p_sys->f_fps > 0 ) p_sys->b_master_sync = true;
783 p_stream->pf_add = Add;
784 p_stream->pf_del = Del;
785 p_stream->pf_send = Send;
786 p_stream->p_sys = p_sys;
791 /*****************************************************************************
793 *****************************************************************************/
794 static void Close( vlc_object_t * p_this )
796 sout_stream_t *p_stream = (sout_stream_t*)p_this;
797 sout_stream_sys_t *p_sys = p_stream->p_sys;
799 sout_StreamDelete( p_sys->p_out );
801 while( p_sys->i_afilters )
804 free( p_sys->psz_afilters[p_sys->i_afilters] );
805 free( p_sys->p_afilters_cfg[p_sys->i_afilters] );
808 while( p_sys->p_audio_cfg != NULL )
810 config_chain_t *p_next = p_sys->p_audio_cfg->p_next;
812 free( p_sys->p_audio_cfg->psz_name );
813 free( p_sys->p_audio_cfg->psz_value );
814 free( p_sys->p_audio_cfg );
816 p_sys->p_audio_cfg = p_next;
818 free( p_sys->psz_aenc );
820 while( p_sys->i_vfilters )
823 free( p_sys->psz_vfilters[p_sys->i_vfilters] );
824 free( p_sys->p_vfilters_cfg[p_sys->i_vfilters] );
827 while( p_sys->p_video_cfg != NULL )
829 config_chain_t *p_next = p_sys->p_video_cfg->p_next;
831 free( p_sys->p_video_cfg->psz_name );
832 free( p_sys->p_video_cfg->psz_value );
833 free( p_sys->p_video_cfg );
835 p_sys->p_video_cfg = p_next;
837 free( p_sys->psz_venc );
839 while( p_sys->p_deinterlace_cfg != NULL )
841 config_chain_t *p_next = p_sys->p_deinterlace_cfg->p_next;
843 free( p_sys->p_deinterlace_cfg->psz_name );
844 free( p_sys->p_deinterlace_cfg->psz_value );
845 free( p_sys->p_deinterlace_cfg );
847 p_sys->p_deinterlace_cfg = p_next;
849 free( p_sys->psz_deinterlace );
851 while( p_sys->p_spu_cfg != NULL )
853 config_chain_t *p_next = p_sys->p_spu_cfg->p_next;
855 free( p_sys->p_spu_cfg->psz_name );
856 free( p_sys->p_spu_cfg->psz_value );
857 free( p_sys->p_spu_cfg );
859 p_sys->p_spu_cfg = p_next;
861 free( p_sys->psz_senc );
863 if( p_sys->p_spu ) spu_Destroy( p_sys->p_spu );
865 while( p_sys->p_osd_cfg != NULL )
867 config_chain_t *p_next = p_sys->p_osd_cfg->p_next;
869 free( p_sys->p_osd_cfg->psz_name );
870 free( p_sys->p_osd_cfg->psz_value );
871 free( p_sys->p_osd_cfg );
873 p_sys->p_osd_cfg = p_next;
875 free( p_sys->psz_osdenc );
877 vlc_object_release( p_sys );
880 struct sout_stream_id_t
882 vlc_fourcc_t b_transcode;
884 /* id of the out stream */
888 decoder_t *p_decoder;
891 filter_t *pp_filter[TRANSCODE_FILTERS];
893 /* User specified filters */
894 filter_t *pp_ufilter[TRANSCODE_FILTERS];
898 encoder_t *p_encoder;
901 date_t interpolated_pts;
904 static sout_stream_id_t *Add( sout_stream_t *p_stream, es_format_t *p_fmt )
906 sout_stream_sys_t *p_sys = p_stream->p_sys;
907 sout_stream_id_t *id;
909 id = malloc( sizeof( sout_stream_id_t ) );
912 msg_Err( p_stream, "out of memory" );
915 memset( id, 0, sizeof(sout_stream_id_t) );
918 id->p_decoder = NULL;
919 id->p_encoder = NULL;
921 /* Create decoder object */
922 id->p_decoder = vlc_object_create( p_stream, VLC_OBJECT_DECODER );
925 msg_Err( p_stream, "out of memory" );
928 vlc_object_attach( id->p_decoder, p_stream );
929 id->p_decoder->p_module = NULL;
930 id->p_decoder->fmt_in = *p_fmt;
931 id->p_decoder->b_pace_control = true;
933 /* Create encoder object */
934 id->p_encoder = vlc_object_create( p_stream, VLC_OBJECT_ENCODER );
937 msg_Err( p_stream, "out of memory" );
940 vlc_object_attach( id->p_encoder, p_stream );
941 id->p_encoder->p_module = NULL;
943 /* Create destination format */
944 es_format_Init( &id->p_encoder->fmt_out, p_fmt->i_cat, 0 );
945 id->p_encoder->fmt_out.i_id = p_fmt->i_id;
946 id->p_encoder->fmt_out.i_group = p_fmt->i_group;
947 if( p_fmt->psz_language )
948 id->p_encoder->fmt_out.psz_language = strdup( p_fmt->psz_language );
950 if( p_fmt->i_cat == AUDIO_ES && (p_sys->i_acodec || p_sys->psz_aenc) )
953 "creating audio transcoding from fcc=`%4.4s' to fcc=`%4.4s'",
954 (char*)&p_fmt->i_codec, (char*)&p_sys->i_acodec );
956 /* Complete destination format */
957 id->p_encoder->fmt_out.i_codec = p_sys->i_acodec;
958 id->p_encoder->fmt_out.audio.i_rate = p_sys->i_sample_rate > 0 ?
959 p_sys->i_sample_rate : p_fmt->audio.i_rate;
960 id->p_encoder->fmt_out.i_bitrate = p_sys->i_abitrate;
961 id->p_encoder->fmt_out.audio.i_bitspersample =
962 p_fmt->audio.i_bitspersample;
963 id->p_encoder->fmt_out.audio.i_channels = p_sys->i_channels > 0 ?
964 p_sys->i_channels : p_fmt->audio.i_channels;
965 /* Sanity check for audio channels */
966 id->p_encoder->fmt_out.audio.i_channels =
967 __MIN( id->p_encoder->fmt_out.audio.i_channels,
968 id->p_decoder->fmt_in.audio.i_channels );
969 id->p_encoder->fmt_out.audio.i_original_channels =
970 id->p_decoder->fmt_in.audio.i_physical_channels;
971 if( id->p_decoder->fmt_in.audio.i_channels ==
972 id->p_encoder->fmt_out.audio.i_channels )
974 id->p_encoder->fmt_out.audio.i_physical_channels =
975 id->p_decoder->fmt_in.audio.i_physical_channels;
979 id->p_encoder->fmt_out.audio.i_physical_channels =
980 pi_channels_maps[id->p_encoder->fmt_out.audio.i_channels];
983 /* Build decoder -> filter -> encoder chain */
984 if( transcode_audio_new( p_stream, id ) )
986 msg_Err( p_stream, "cannot create audio chain" );
990 /* Open output stream */
991 id->id = p_sys->p_out->pf_add( p_sys->p_out, &id->p_encoder->fmt_out );
992 id->b_transcode = true;
996 transcode_audio_close( id );
1000 date_Init( &id->interpolated_pts, p_fmt->audio.i_rate, 1 );
1002 else if( p_fmt->i_cat == VIDEO_ES &&
1003 (p_sys->i_vcodec != 0 || p_sys->psz_venc) )
1006 "creating video transcoding from fcc=`%4.4s' to fcc=`%4.4s'",
1007 (char*)&p_fmt->i_codec, (char*)&p_sys->i_vcodec );
1009 /* Complete destination format */
1010 id->p_encoder->fmt_out.i_codec = p_sys->i_vcodec;
1011 id->p_encoder->fmt_out.video.i_width = p_sys->i_width & ~1;
1012 id->p_encoder->fmt_out.video.i_height = p_sys->i_height & ~1;
1013 id->p_encoder->fmt_out.i_bitrate = p_sys->i_vbitrate;
1015 /* Build decoder -> filter -> encoder chain */
1016 if( transcode_video_new( p_stream, id ) )
1018 msg_Err( p_stream, "cannot create video chain" );
1022 /* Stream will be added later on because we don't know
1023 * all the characteristics of the decoded stream yet */
1024 id->b_transcode = true;
1026 if( p_sys->f_fps > 0 )
1028 id->p_encoder->fmt_out.video.i_frame_rate =
1029 (p_sys->f_fps * 1000) + 0.5;
1030 id->p_encoder->fmt_out.video.i_frame_rate_base =
1034 else if( ( p_fmt->i_cat == SPU_ES ) &&
1035 ( p_sys->i_scodec || p_sys->psz_senc ) )
1037 msg_Dbg( p_stream, "creating subtitles transcoding from fcc=`%4.4s' "
1038 "to fcc=`%4.4s'", (char*)&p_fmt->i_codec,
1039 (char*)&p_sys->i_scodec );
1041 /* Complete destination format */
1042 id->p_encoder->fmt_out.i_codec = p_sys->i_scodec;
1044 /* build decoder -> filter -> encoder */
1045 if( transcode_spu_new( p_stream, id ) )
1047 msg_Err( p_stream, "cannot create subtitles chain" );
1051 /* open output stream */
1052 id->id = p_sys->p_out->pf_add( p_sys->p_out, &id->p_encoder->fmt_out );
1053 id->b_transcode = true;
1057 transcode_spu_close( id );
1061 else if( p_fmt->i_cat == SPU_ES && p_sys->b_soverlay )
1063 msg_Dbg( p_stream, "subtitles (fcc=`%4.4s') overlaying",
1064 (char*)&p_fmt->i_codec );
1066 id->b_transcode = true;
1068 /* Build decoder -> filter -> overlaying chain */
1069 if( transcode_spu_new( p_stream, id ) )
1071 msg_Err( p_stream, "cannot create subtitles chain" );
1075 else if( !p_sys->b_osd && (p_sys->i_osdcodec != 0 || p_sys->psz_osdenc) )
1077 msg_Dbg( p_stream, "creating osd transcoding from fcc=`%4.4s' "
1078 "to fcc=`%4.4s'", (char*)&p_fmt->i_codec,
1079 (char*)&p_sys->i_scodec );
1081 id->b_transcode = true;
1083 /* Create a fake OSD menu elementary stream */
1084 if( transcode_osd_new( p_stream, id ) )
1086 msg_Err( p_stream, "cannot create osd chain" );
1089 p_sys->b_osd = true;
1093 msg_Dbg( p_stream, "not transcoding a stream (fcc=`%4.4s')",
1094 (char*)&p_fmt->i_codec );
1095 id->id = p_sys->p_out->pf_add( p_sys->p_out, p_fmt );
1096 id->b_transcode = false;
1098 if( !id->id ) goto error;
1106 vlc_object_detach( id->p_decoder );
1107 vlc_object_release( id->p_decoder );
1108 id->p_decoder = NULL;
1113 vlc_object_detach( id->p_encoder );
1114 es_format_Clean( &id->p_encoder->fmt_out );
1115 vlc_object_release( id->p_encoder );
1116 id->p_encoder = NULL;
1123 static int Del( sout_stream_t *p_stream, sout_stream_id_t *id )
1125 sout_stream_sys_t *p_sys = p_stream->p_sys;
1127 if( id->b_transcode )
1129 switch( id->p_decoder->fmt_in.i_cat )
1132 transcode_audio_close( id );
1135 transcode_video_close( p_stream, id );
1139 transcode_osd_close( p_stream, id );
1141 transcode_spu_close( id );
1146 if( id->id ) p_sys->p_out->pf_del( p_sys->p_out, id->id );
1150 vlc_object_detach( id->p_decoder );
1151 vlc_object_release( id->p_decoder );
1152 id->p_decoder = NULL;
1157 vlc_object_detach( id->p_encoder );
1158 es_format_Clean( &id->p_encoder->fmt_out );
1159 vlc_object_release( id->p_encoder );
1160 id->p_encoder = NULL;
1167 static int Send( sout_stream_t *p_stream, sout_stream_id_t *id,
1170 sout_stream_sys_t *p_sys = p_stream->p_sys;
1171 block_t *p_out = NULL;
1173 if( !id->b_transcode && id->id )
1175 return p_sys->p_out->pf_send( p_sys->p_out, id->id, p_buffer );
1177 else if( !id->b_transcode )
1179 block_Release( p_buffer );
1180 return VLC_EGENERIC;
1183 switch( id->p_decoder->fmt_in.i_cat )
1186 transcode_audio_process( p_stream, id, p_buffer, &p_out );
1190 if( transcode_video_process( p_stream, id, p_buffer, &p_out )
1193 return VLC_EGENERIC;
1198 /* Transcode OSD menu pictures. */
1201 if( transcode_osd_process( p_stream, id, p_buffer, &p_out ) !=
1204 return VLC_EGENERIC;
1207 else if ( transcode_spu_process( p_stream, id, p_buffer, &p_out ) !=
1210 return VLC_EGENERIC;
1216 block_Release( p_buffer );
1220 if( p_out ) return p_sys->p_out->pf_send( p_sys->p_out, id->id, p_out );
1224 /****************************************************************************
1226 ****************************************************************************/
1227 static inline void video_timer_start( encoder_t * p_encoder )
1229 stats_TimerStart( p_encoder, "encoding video frame",
1230 STATS_TIMER_VIDEO_FRAME_ENCODING );
1233 static inline void video_timer_stop( encoder_t * p_encoder )
1235 stats_TimerStop( p_encoder, STATS_TIMER_VIDEO_FRAME_ENCODING );
1238 static inline void video_timer_close( encoder_t * p_encoder )
1240 stats_TimerDump( p_encoder, STATS_TIMER_VIDEO_FRAME_ENCODING );
1241 stats_TimerClean( p_encoder, STATS_TIMER_VIDEO_FRAME_ENCODING );
1244 static inline void audio_timer_start( encoder_t * p_encoder )
1246 stats_TimerStart( p_encoder, "encoding audio frame",
1247 STATS_TIMER_AUDIO_FRAME_ENCODING );
1250 static inline void audio_timer_stop( encoder_t * p_encoder )
1252 stats_TimerStop( p_encoder, STATS_TIMER_AUDIO_FRAME_ENCODING );
1255 static inline void audio_timer_close( encoder_t * p_encoder )
1257 stats_TimerDump( p_encoder, STATS_TIMER_AUDIO_FRAME_ENCODING );
1258 stats_TimerClean( p_encoder, STATS_TIMER_AUDIO_FRAME_ENCODING );
1261 /****************************************************************************
1262 * decoder reencoder part
1263 ****************************************************************************/
1265 static int audio_BitsPerSample( vlc_fourcc_t i_format )
1269 case VLC_FOURCC('u','8',' ',' '):
1270 case VLC_FOURCC('s','8',' ',' '):
1273 case VLC_FOURCC('u','1','6','l'):
1274 case VLC_FOURCC('s','1','6','l'):
1275 case VLC_FOURCC('u','1','6','b'):
1276 case VLC_FOURCC('s','1','6','b'):
1279 case VLC_FOURCC('u','2','4','l'):
1280 case VLC_FOURCC('s','2','4','l'):
1281 case VLC_FOURCC('u','2','4','b'):
1282 case VLC_FOURCC('s','2','4','b'):
1285 case VLC_FOURCC('u','3','2','l'):
1286 case VLC_FOURCC('s','3','2','l'):
1287 case VLC_FOURCC('u','3','2','b'):
1288 case VLC_FOURCC('s','3','2','b'):
1289 case VLC_FOURCC('f','l','3','2'):
1290 case VLC_FOURCC('f','i','3','2'):
1293 case VLC_FOURCC('f','l','6','4'):
1300 static block_t *transcode_audio_alloc (filter_t *filter, int size)
1302 return block_New (filter, size);
1305 static filter_t *transcode_audio_filter_new( sout_stream_t *p_stream,
1306 sout_stream_id_t *id,
1307 es_format_t *p_fmt_in,
1308 es_format_t *p_fmt_out,
1311 sout_stream_sys_t *p_sys = p_stream->p_sys;
1312 filter_t *p_filter = vlc_object_create( p_stream, VLC_OBJECT_FILTER );
1314 vlc_object_attach( p_filter, p_stream );
1315 p_filter->pf_audio_buffer_new = transcode_audio_alloc;
1317 p_filter->fmt_in = *p_fmt_in;
1318 p_filter->fmt_out = *p_fmt_out;
1320 p_filter->p_cfg = p_sys->p_afilters_cfg[id->i_ufilter];
1322 p_filter->p_module = module_Need( p_filter, "audio filter2", psz_name,
1324 if( p_filter->p_module )
1326 p_filter->fmt_out.audio.i_bitspersample =
1327 audio_BitsPerSample( p_filter->fmt_out.i_codec );
1328 *p_fmt_in = p_filter->fmt_out;
1332 vlc_object_detach( p_filter );
1333 vlc_object_release( p_filter );
1340 static int transcode_audio_new( sout_stream_t *p_stream,
1341 sout_stream_id_t *id )
1343 sout_stream_sys_t *p_sys = p_stream->p_sys;
1344 es_format_t fmt_last;
1351 /* Initialization of decoder structures */
1352 id->p_decoder->fmt_out = id->p_decoder->fmt_in;
1353 id->p_decoder->fmt_out.i_extra = 0;
1354 id->p_decoder->fmt_out.p_extra = 0;
1355 id->p_decoder->pf_decode_audio = NULL;
1356 id->p_decoder->pf_aout_buffer_new = audio_new_buffer;
1357 id->p_decoder->pf_aout_buffer_del = audio_del_buffer;
1358 /* id->p_decoder->p_cfg = p_sys->p_audio_cfg; */
1360 id->p_decoder->p_module =
1361 module_Need( id->p_decoder, "decoder", "$codec", 0 );
1362 if( !id->p_decoder->p_module )
1364 msg_Err( p_stream, "cannot find decoder" );
1365 return VLC_EGENERIC;
1367 id->p_decoder->fmt_out.audio.i_bitspersample =
1368 audio_BitsPerSample( id->p_decoder->fmt_out.i_codec );
1369 fmt_last = id->p_decoder->fmt_out;
1370 /* Fix AAC SBR changing number of channels and sampling rate */
1371 if( !(id->p_decoder->fmt_in.i_codec == VLC_FOURCC('m','p','4','a') &&
1372 fmt_last.audio.i_rate != id->p_encoder->fmt_in.audio.i_rate &&
1373 fmt_last.audio.i_channels != id->p_encoder->fmt_in.audio.i_channels) )
1374 fmt_last.audio.i_rate = id->p_decoder->fmt_in.audio.i_rate;
1380 /* Initialization of encoder format structures */
1381 es_format_Init( &id->p_encoder->fmt_in, id->p_decoder->fmt_in.i_cat,
1382 id->p_decoder->fmt_out.i_codec );
1383 id->p_encoder->fmt_in.audio.i_format = id->p_decoder->fmt_out.i_codec;
1385 if( ( id->p_encoder->fmt_out.i_codec == VLC_FOURCC('s','a','m','r') ) ||
1386 ( id->p_encoder->fmt_out.i_codec == VLC_FOURCC('s','a','w','b') ) )
1387 id->p_encoder->fmt_in.audio.i_rate = id->p_encoder->fmt_out.audio.i_rate;
1389 id->p_encoder->fmt_in.audio.i_rate = fmt_last.audio.i_rate;
1390 id->p_encoder->fmt_in.audio.i_physical_channels =
1391 id->p_encoder->fmt_out.audio.i_physical_channels;
1392 id->p_encoder->fmt_in.audio.i_original_channels =
1393 id->p_encoder->fmt_out.audio.i_original_channels;
1394 id->p_encoder->fmt_in.audio.i_channels =
1395 id->p_encoder->fmt_out.audio.i_channels;
1396 id->p_encoder->fmt_in.audio.i_bitspersample =
1397 audio_BitsPerSample( id->p_encoder->fmt_in.i_codec );
1399 id->p_encoder->p_cfg = p_stream->p_sys->p_audio_cfg;
1400 id->p_encoder->p_module =
1401 module_Need( id->p_encoder, "encoder", p_sys->psz_aenc, true );
1402 if( !id->p_encoder->p_module )
1404 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_aenc );
1405 module_Unneed( id->p_decoder, id->p_decoder->p_module );
1406 id->p_decoder->p_module = NULL;
1407 return VLC_EGENERIC;
1409 id->p_encoder->fmt_in.audio.i_format = id->p_encoder->fmt_in.i_codec;
1410 id->p_encoder->fmt_in.audio.i_bitspersample =
1411 audio_BitsPerSample( id->p_encoder->fmt_in.i_codec );
1413 /* Load conversion filters */
1414 if( fmt_last.audio.i_channels != id->p_encoder->fmt_in.audio.i_channels ||
1415 fmt_last.audio.i_rate != id->p_encoder->fmt_in.audio.i_rate )
1417 /* We'll have to go through fl32 first */
1418 es_format_t fmt_out = id->p_encoder->fmt_in;
1419 fmt_out.i_codec = fmt_out.audio.i_format = VLC_FOURCC('f','l','3','2');
1421 id->pp_filter[id->i_filter] =
1422 transcode_audio_filter_new( p_stream, id, &fmt_last, &fmt_out, NULL );
1424 if( id->pp_filter[id->i_filter] ) id->i_filter++;
1427 for( i = 0; i < TRANSCODE_FILTERS; i++ )
1429 if( (fmt_last.audio.i_channels !=
1430 id->p_encoder->fmt_in.audio.i_channels) ||
1431 (fmt_last.audio.i_rate != id->p_encoder->fmt_in.audio.i_rate) ||
1432 (fmt_last.i_codec != id->p_encoder->fmt_in.i_codec) )
1434 id->pp_filter[id->i_filter] =
1435 transcode_audio_filter_new( p_stream, id, &fmt_last,
1436 &id->p_encoder->fmt_in, NULL );
1438 if( id->pp_filter[id->i_filter] )
1445 /* Final checks to see if conversions were successful */
1446 if( fmt_last.i_codec != id->p_encoder->fmt_in.i_codec )
1448 msg_Err( p_stream, "no audio filter found (%4.4s->%4.4s)",
1449 (char *)&fmt_last.i_codec,
1450 (char *)&id->p_encoder->fmt_in.i_codec );
1451 transcode_audio_close( id );
1452 return VLC_EGENERIC;
1455 /* Load user specified audio filters now */
1456 for( i = 0; (i < p_sys->i_afilters) &&
1457 (id->i_ufilter < TRANSCODE_FILTERS); i++ )
1459 id->pp_ufilter[id->i_ufilter] =
1460 transcode_audio_filter_new( p_stream, id, &fmt_last,
1461 &id->p_encoder->fmt_in,
1462 p_sys->psz_afilters[i] );
1464 if( id->pp_ufilter[id->i_ufilter] )
1470 if( fmt_last.audio.i_channels != id->p_encoder->fmt_in.audio.i_channels )
1473 module_Unneed( id->p_encoder, id->p_encoder->p_module );
1474 id->p_encoder->p_module = NULL;
1476 /* This might work, but only if the encoder is restarted */
1477 id->p_encoder->fmt_in.audio.i_channels = fmt_last.audio.i_channels;
1478 id->p_encoder->fmt_out.audio.i_channels = fmt_last.audio.i_channels;
1480 id->p_encoder->fmt_in.audio.i_physical_channels =
1481 id->p_encoder->fmt_in.audio.i_original_channels =
1482 fmt_last.audio.i_physical_channels;
1483 id->p_encoder->fmt_out.audio.i_physical_channels =
1484 id->p_encoder->fmt_out.audio.i_original_channels =
1485 fmt_last.audio.i_physical_channels;
1487 msg_Dbg( p_stream, "number of audio channels for mixing changed, "
1488 "trying to reopen the encoder for mixing %i to %i channels",
1489 fmt_last.audio.i_channels,
1490 id->p_encoder->fmt_in.audio.i_channels );
1492 /* reload encoder */
1493 id->p_encoder->p_cfg = p_stream->p_sys->p_audio_cfg;
1494 id->p_encoder->p_module =
1495 module_Need( id->p_encoder, "encoder", p_sys->psz_aenc, true );
1496 if( !id->p_encoder->p_module )
1498 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_aenc );
1499 transcode_audio_close( id );
1500 return VLC_EGENERIC;
1502 id->p_encoder->fmt_in.audio.i_format = id->p_encoder->fmt_in.i_codec;
1503 id->p_encoder->fmt_in.audio.i_bitspersample =
1504 audio_BitsPerSample( id->p_encoder->fmt_in.i_codec );
1506 msg_Err( p_stream, "no audio filter found for mixing from"
1507 " %i to %i channels", fmt_last.audio.i_channels,
1508 id->p_encoder->fmt_in.audio.i_channels );
1510 transcode_audio_close( id );
1511 return VLC_EGENERIC;
1515 if( fmt_last.audio.i_rate != id->p_encoder->fmt_in.audio.i_rate )
1517 msg_Err( p_stream, "no audio filter found for resampling from"
1518 " %iHz to %iHz", fmt_last.audio.i_rate,
1519 id->p_encoder->fmt_in.audio.i_rate );
1521 /* FIXME : this might work, but only if the encoder is restarted */
1522 id->p_encoder->fmt_in.audio.i_rate = fmt_last.audio.i_rate;
1523 id->p_encoder->fmt_out.audio.i_rate = fmt_last.audio.i_rate;
1525 transcode_audio_close( id );
1526 return VLC_EGENERIC;
1530 /* FIXME: Hack for mp3 transcoding support */
1531 if( id->p_encoder->fmt_out.i_codec == VLC_FOURCC( 'm','p','3',' ' ) )
1532 id->p_encoder->fmt_out.i_codec = VLC_FOURCC( 'm','p','g','a' );
1537 static void transcode_audio_close( sout_stream_id_t *id )
1541 audio_timer_close( id->p_encoder );
1544 if( id->p_decoder->p_module )
1545 module_Unneed( id->p_decoder, id->p_decoder->p_module );
1546 id->p_decoder->p_module = NULL;
1549 if( id->p_encoder->p_module )
1550 module_Unneed( id->p_encoder, id->p_encoder->p_module );
1551 id->p_encoder->p_module = NULL;
1554 for( i = 0; i < id->i_filter; i++ )
1556 vlc_object_detach( id->pp_filter[i] );
1557 if( id->pp_filter[i]->p_module )
1558 module_Unneed( id->pp_filter[i], id->pp_filter[i]->p_module );
1559 vlc_object_release( id->pp_filter[i] );
1563 for( i = 0; i < id->i_ufilter; i++ )
1565 vlc_object_detach( id->pp_ufilter[i] );
1566 if( id->pp_ufilter[i]->p_module )
1567 module_Unneed( id->pp_ufilter[i], id->pp_ufilter[i]->p_module );
1568 vlc_object_release( id->pp_ufilter[i] );
1573 static int transcode_audio_process( sout_stream_t *p_stream,
1574 sout_stream_id_t *id,
1575 block_t *in, block_t **out )
1577 sout_stream_sys_t *p_sys = p_stream->p_sys;
1578 aout_buffer_t *p_audio_buf;
1579 block_t *p_block, *p_audio_block;
1583 while( (p_audio_buf = id->p_decoder->pf_decode_audio( id->p_decoder,
1586 sout_UpdateStatistic( p_stream->p_sout, SOUT_STATISTIC_DECODED_AUDIO, 1 );
1587 if( p_sys->b_master_sync )
1589 mtime_t i_dts = date_Get( &id->interpolated_pts ) + 1;
1590 if ( p_audio_buf->start_date - i_dts > MASTER_SYNC_MAX_DRIFT
1591 || p_audio_buf->start_date - i_dts < -MASTER_SYNC_MAX_DRIFT )
1593 msg_Dbg( p_stream, "drift is too high, resetting master sync" );
1594 date_Set( &id->interpolated_pts, p_audio_buf->start_date );
1595 i_dts = p_audio_buf->start_date + 1;
1597 p_sys->i_master_drift = p_audio_buf->start_date - i_dts;
1598 date_Increment( &id->interpolated_pts, p_audio_buf->i_nb_samples );
1599 p_audio_buf->start_date -= p_sys->i_master_drift;
1600 p_audio_buf->end_date -= p_sys->i_master_drift;
1603 p_audio_block = p_audio_buf->p_sys;
1604 p_audio_block->i_buffer = p_audio_buf->i_nb_bytes;
1605 p_audio_block->i_dts = p_audio_block->i_pts =
1606 p_audio_buf->start_date;
1607 p_audio_block->i_length = p_audio_buf->end_date -
1608 p_audio_buf->start_date;
1609 p_audio_block->i_samples = p_audio_buf->i_nb_samples;
1611 /* Run filter chain */
1612 for( i = 0; i < id->i_filter; i++ )
1615 id->pp_filter[i]->pf_audio_filter( id->pp_filter[i],
1619 /* Run user specified filter chain */
1620 for( i = 0; i < id->i_ufilter; i++ )
1623 id->pp_ufilter[i]->pf_audio_filter( id->pp_ufilter[i],
1627 assert( p_audio_block );
1629 p_audio_buf->p_buffer = p_audio_block->p_buffer;
1630 p_audio_buf->i_nb_bytes = p_audio_block->i_buffer;
1631 p_audio_buf->i_nb_samples = p_audio_block->i_samples;
1632 p_audio_buf->start_date = p_audio_block->i_dts;
1633 p_audio_buf->end_date = p_audio_block->i_dts + p_audio_block->i_length;
1635 audio_timer_start( id->p_encoder );
1636 p_block = id->p_encoder->pf_encode_audio( id->p_encoder, p_audio_buf );
1637 audio_timer_stop( id->p_encoder );
1639 block_ChainAppend( out, p_block );
1640 block_Release( p_audio_block );
1641 free( p_audio_buf );
1647 static void audio_release_buffer( aout_buffer_t *p_buffer )
1649 if( p_buffer && p_buffer->p_sys ) block_Release( p_buffer->p_sys );
1653 static aout_buffer_t *audio_new_buffer( decoder_t *p_dec, int i_samples )
1655 aout_buffer_t *p_buffer;
1659 if( p_dec->fmt_out.audio.i_bitspersample )
1661 i_size = i_samples * p_dec->fmt_out.audio.i_bitspersample / 8 *
1662 p_dec->fmt_out.audio.i_channels;
1664 else if( p_dec->fmt_out.audio.i_bytes_per_frame &&
1665 p_dec->fmt_out.audio.i_frame_length )
1667 i_size = i_samples * p_dec->fmt_out.audio.i_bytes_per_frame /
1668 p_dec->fmt_out.audio.i_frame_length;
1672 i_size = i_samples * 4 * p_dec->fmt_out.audio.i_channels;
1675 p_buffer = malloc( sizeof(aout_buffer_t) );
1676 if( !p_buffer ) return NULL;
1677 p_buffer->b_discontinuity = false;
1678 p_buffer->pf_release = audio_release_buffer;
1679 p_buffer->p_sys = p_block = block_New( p_dec, i_size );
1681 p_buffer->p_buffer = p_block->p_buffer;
1682 p_buffer->i_size = p_buffer->i_nb_bytes = p_block->i_buffer;
1683 p_buffer->i_nb_samples = i_samples;
1684 p_block->i_samples = i_samples;
1689 static void audio_del_buffer( decoder_t *p_dec, aout_buffer_t *p_buffer )
1692 if( p_buffer && p_buffer->p_sys ) block_Release( p_buffer->p_sys );
1700 static filter_t *transcode_video_filter_new( sout_stream_t *p_stream,
1701 es_format_t *p_fmt_in,
1702 es_format_t *p_fmt_out,
1703 config_chain_t *p_cfg,
1704 const char *psz_name )
1706 sout_stream_sys_t *p_sys = p_stream->p_sys;
1710 if( !p_stream || !p_fmt_in || !p_fmt_out ) return NULL;
1712 p_filter = vlc_object_create( p_stream, VLC_OBJECT_FILTER );
1713 vlc_object_attach( p_filter, p_stream );
1715 p_filter->pf_vout_buffer_new = video_new_buffer_filter;
1716 p_filter->pf_vout_buffer_del = video_del_buffer_filter;
1718 es_format_Copy( &p_filter->fmt_in, p_fmt_in );
1719 es_format_Copy( &p_filter->fmt_out, p_fmt_out );
1720 p_filter->p_cfg = p_cfg;
1722 p_filter->p_module = module_Need( p_filter, "video filter2",
1724 if( !p_filter->p_module )
1726 msg_Dbg( p_stream, "no video filter found" );
1727 vlc_object_detach( p_filter );
1728 vlc_object_release( p_filter );
1732 p_filter->p_owner = malloc( sizeof(filter_owner_sys_t) );
1733 if( !p_filter->p_owner )
1735 module_Unneed( p_filter,p_filter->p_module );
1736 vlc_object_detach( p_filter );
1737 vlc_object_release( p_filter );
1741 for( i = 0; i < PICTURE_RING_SIZE; i++ )
1742 p_filter->p_owner->pp_pics[i] = 0;
1743 p_filter->p_owner->p_sys = p_sys;
1748 static void transcode_video_filter_close( sout_stream_t *p_stream,
1749 filter_t *p_filter )
1753 if( !p_stream || !p_filter ) return;
1755 vlc_object_detach( p_filter );
1756 if( p_filter->p_module )
1757 module_Unneed( p_filter, p_filter->p_module );
1759 /* Clean-up pictures ring buffer */
1760 for( j = 0; j < PICTURE_RING_SIZE; j++ )
1762 if( p_filter->p_owner->pp_pics[j] )
1763 video_del_buffer( VLC_OBJECT(p_filter),
1764 p_filter->p_owner->pp_pics[j] );
1766 free( p_filter->p_owner );
1767 vlc_object_release( p_filter );
1771 static int transcode_video_new( sout_stream_t *p_stream, sout_stream_id_t *id )
1773 sout_stream_sys_t *p_sys = p_stream->p_sys;
1777 * Initialization of decoder structures
1779 id->p_decoder->fmt_out = id->p_decoder->fmt_in;
1780 id->p_decoder->fmt_out.i_extra = 0;
1781 id->p_decoder->fmt_out.p_extra = 0;
1782 id->p_decoder->pf_decode_video = NULL;
1783 id->p_decoder->pf_get_cc = NULL;
1784 id->p_decoder->pf_get_cc = 0;
1785 id->p_decoder->pf_vout_buffer_new = video_new_buffer_decoder;
1786 id->p_decoder->pf_vout_buffer_del = video_del_buffer_decoder;
1787 id->p_decoder->pf_picture_link = video_link_picture_decoder;
1788 id->p_decoder->pf_picture_unlink = video_unlink_picture_decoder;
1789 id->p_decoder->p_owner = malloc( sizeof(decoder_owner_sys_t) );
1790 for( i = 0; i < PICTURE_RING_SIZE; i++ )
1791 id->p_decoder->p_owner->pp_pics[i] = 0;
1792 id->p_decoder->p_owner->p_sys = p_sys;
1793 /* id->p_decoder->p_cfg = p_sys->p_video_cfg; */
1795 id->p_decoder->p_module =
1796 module_Need( id->p_decoder, "decoder", "$codec", 0 );
1798 if( !id->p_decoder->p_module )
1800 msg_Err( p_stream, "cannot find decoder" );
1801 return VLC_EGENERIC;
1806 * Because some info about the decoded input will only be available
1807 * once the first frame is decoded, we actually only test the availability
1808 * of the encoder here.
1811 /* Initialization of encoder format structures */
1812 es_format_Init( &id->p_encoder->fmt_in, id->p_decoder->fmt_in.i_cat,
1813 id->p_decoder->fmt_out.i_codec );
1814 id->p_encoder->fmt_in.video.i_chroma = id->p_decoder->fmt_out.i_codec;
1816 /* The dimensions will be set properly later on.
1817 * Just put sensible values so we can test an encoder is available. */
1818 id->p_encoder->fmt_in.video.i_width =
1819 id->p_encoder->fmt_out.video.i_width ?
1820 id->p_encoder->fmt_out.video.i_width :
1821 id->p_decoder->fmt_in.video.i_width ?
1822 id->p_decoder->fmt_in.video.i_width : 16;
1823 id->p_encoder->fmt_in.video.i_height =
1824 id->p_encoder->fmt_out.video.i_height ?
1825 id->p_encoder->fmt_out.video.i_height :
1826 id->p_decoder->fmt_in.video.i_height ?
1827 id->p_decoder->fmt_in.video.i_height : 16;
1828 id->p_encoder->fmt_in.video.i_frame_rate = ENC_FRAMERATE;
1829 id->p_encoder->fmt_in.video.i_frame_rate_base = ENC_FRAMERATE_BASE;
1831 id->p_encoder->i_threads = p_sys->i_threads;
1832 id->p_encoder->p_cfg = p_sys->p_video_cfg;
1834 id->p_encoder->p_module =
1835 module_Need( id->p_encoder, "encoder", p_sys->psz_venc, true );
1836 if( !id->p_encoder->p_module )
1838 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_venc );
1839 module_Unneed( id->p_decoder, id->p_decoder->p_module );
1840 id->p_decoder->p_module = 0;
1841 return VLC_EGENERIC;
1844 /* Close the encoder.
1845 * We'll open it only when we have the first frame. */
1846 module_Unneed( id->p_encoder, id->p_encoder->p_module );
1847 if( id->p_encoder->fmt_out.p_extra )
1849 free( id->p_encoder->fmt_out.p_extra );
1850 id->p_encoder->fmt_out.p_extra = NULL;
1851 id->p_encoder->fmt_out.i_extra = 0;
1853 id->p_encoder->p_module = NULL;
1855 if( p_sys->i_threads >= 1 )
1857 int i_priority = p_sys->b_high_priority ? VLC_THREAD_PRIORITY_OUTPUT :
1858 VLC_THREAD_PRIORITY_VIDEO;
1859 p_sys->id_video = id;
1860 vlc_mutex_init( &p_sys->lock_out );
1861 vlc_cond_init( p_stream, &p_sys->cond );
1862 memset( p_sys->pp_pics, 0, sizeof(p_sys->pp_pics) );
1863 p_sys->i_first_pic = 0;
1864 p_sys->i_last_pic = 0;
1865 p_sys->p_buffers = NULL;
1866 p_sys->b_die = p_sys->b_error = 0;
1867 if( vlc_thread_create( p_sys, "encoder", EncoderThread, i_priority,
1870 msg_Err( p_stream, "cannot spawn encoder thread" );
1871 module_Unneed( id->p_decoder, id->p_decoder->p_module );
1872 id->p_decoder->p_module = 0;
1873 return VLC_EGENERIC;
1880 static int transcode_video_encoder_open( sout_stream_t *p_stream,
1881 sout_stream_id_t *id )
1883 sout_stream_sys_t *p_sys = p_stream->p_sys;
1885 /* Calculate scaling, padding, cropping etc.
1886 * width/height of source */
1887 int i_src_width = id->p_decoder->fmt_out.video.i_width;
1888 int i_src_height = id->p_decoder->fmt_out.video.i_height;
1890 /* with/height scaling */
1891 float f_scale_width = 1;
1892 float f_scale_height = 1;
1894 /* width/height of output stream */
1899 float f_aspect = (float)id->p_decoder->fmt_out.video.i_aspect /
1902 msg_Dbg( p_stream, "decoder aspect is %i:%i",
1903 id->p_decoder->fmt_out.video.i_aspect, VOUT_ASPECT_FACTOR );
1905 /* Change f_aspect from source frame to source pixel */
1906 f_aspect = f_aspect * i_src_height / i_src_width;
1907 msg_Dbg( p_stream, "source pixel aspect is %f:1", f_aspect );
1909 /* width/height after cropping */
1910 p_sys->i_src_x_offset = p_sys->i_crop_left & ~1;
1911 p_sys->i_src_y_offset = p_sys->i_crop_top & ~1;
1912 p_sys->i_crop_width = i_src_width - ( p_sys->i_crop_left & ~1 ) -
1913 ( p_sys->i_crop_right & ~1 );
1914 p_sys->i_crop_height = i_src_height - ( p_sys->i_crop_top & ~1 ) -
1915 ( p_sys->i_crop_bottom & ~1 );
1917 /* Calculate scaling factor for specified parameters */
1918 if( id->p_encoder->fmt_out.video.i_width <= 0 &&
1919 id->p_encoder->fmt_out.video.i_height <= 0 && p_sys->f_scale )
1921 /* Global scaling. Make sure width will remain a factor of 16 */
1924 int i_new_width = i_src_width * p_sys->f_scale;
1926 if( i_new_width % 16 <= 7 && i_new_width >= 16 )
1927 i_new_width -= i_new_width % 16;
1929 i_new_width += 16 - i_new_width % 16;
1931 f_real_scale = (float)( i_new_width ) / (float) i_src_width;
1933 i_new_height = __MAX( 16, i_src_height * (float)f_real_scale );
1935 f_scale_width = f_real_scale;
1936 f_scale_height = (float) i_new_height / (float) i_src_height;
1938 else if( id->p_encoder->fmt_out.video.i_width > 0 &&
1939 id->p_encoder->fmt_out.video.i_height <= 0 )
1941 /* Only width specified */
1942 f_scale_width = (float)id->p_encoder->fmt_out.video.i_width /
1943 p_sys->i_crop_width;
1944 f_scale_height = f_scale_width;
1946 else if( id->p_encoder->fmt_out.video.i_width <= 0 &&
1947 id->p_encoder->fmt_out.video.i_height > 0 )
1949 /* Only height specified */
1950 f_scale_height = (float)id->p_encoder->fmt_out.video.i_height /
1951 p_sys->i_crop_height;
1952 f_scale_width = f_scale_height;
1954 else if( id->p_encoder->fmt_out.video.i_width > 0 &&
1955 id->p_encoder->fmt_out.video.i_height > 0 )
1957 /* Width and height specified */
1958 f_scale_width = (float)id->p_encoder->fmt_out.video.i_width
1959 / p_sys->i_crop_width;
1960 f_scale_height = (float)id->p_encoder->fmt_out.video.i_height
1961 / p_sys->i_crop_height;
1964 /* check maxwidth and maxheight
1965 * note: maxwidth and maxheight currently does not handle
1966 * canvas and padding, just scaling and cropping.
1968 if( p_sys->i_maxwidth && f_scale_width > (float)p_sys->i_maxwidth /
1969 p_sys->i_crop_width )
1971 f_scale_width = (float)p_sys->i_maxwidth / p_sys->i_crop_width;
1974 if( p_sys->i_maxheight && f_scale_height > (float)p_sys->i_maxheight /
1975 p_sys->i_crop_height )
1977 f_scale_height = (float)p_sys->i_maxheight / p_sys->i_crop_height;
1980 /* Change aspect ratio from source pixel to scaled pixel */
1981 f_aspect = f_aspect * f_scale_height / f_scale_width;
1982 msg_Dbg( p_stream, "scaled pixel aspect is %f:1", f_aspect );
1984 /* Correct scaling for target aspect ratio
1985 * Shrink video if necessary
1987 if ( p_sys->i_canvas_aspect > 0 )
1989 float f_target_aspect = (float)p_sys->i_canvas_aspect /
1992 if( p_sys->i_canvas_width > 0 && p_sys->i_canvas_height > 0)
1994 /* Calculate pixel aspect of canvas */
1995 f_target_aspect = f_target_aspect / p_sys->i_canvas_width *
1996 p_sys->i_canvas_height;
1998 if( f_target_aspect > f_aspect )
2000 /* Reduce width scale to increase aspect */
2001 f_scale_width = f_scale_width * f_aspect / f_target_aspect;
2005 /* Reduce height scale to decrease aspect */
2006 f_scale_height = f_scale_height * f_target_aspect / f_aspect;
2008 f_aspect = f_target_aspect;
2009 msg_Dbg( p_stream, "canvas scaled pixel aspect is %f:1", f_aspect );
2012 /* f_scale_width and f_scale_height are now final */
2013 /* Calculate width, height from scaling
2014 * Make sure its multiple of 2
2016 i_dst_width = 2 * (int)( p_sys->i_crop_width * f_scale_width / 2 + 0.5 );
2018 (int)( p_sys->i_crop_height * f_scale_height / 2 + 0.5 );
2020 p_sys->i_nopadd_width = i_dst_width;
2021 p_sys->i_nopadd_height = i_dst_height;
2022 p_sys->i_dst_x_offset = 0;
2023 p_sys->i_dst_y_offset = 0;
2025 /* Handle canvas and padding */
2026 if( p_sys->i_canvas_width <= 0 )
2028 /* No canvas width set, add explicit padding border */
2029 i_dst_width = p_sys->i_nopadd_width + ( p_sys->i_padd_left & ~1 ) +
2030 ( p_sys->i_padd_right & ~1 );
2031 p_sys->i_dst_x_offset = ( p_sys->i_padd_left & ~1 );
2035 /* Canvas set, check if we have to padd or crop */
2036 if( p_sys->i_canvas_width < p_sys->i_nopadd_width )
2038 /* need to crop more, but keep same scaling */
2039 int i_crop = 2 * (int)( ( p_sys->i_canvas_width & ~1 ) /
2040 f_scale_width / 2 + 0.5 );
2042 p_sys->i_src_x_offset += ( ( p_sys->i_crop_width - i_crop ) / 2 )
2044 p_sys->i_crop_width = i_crop;
2045 i_dst_width = p_sys->i_canvas_width & ~1;
2046 p_sys->i_nopadd_width = i_dst_width;
2048 else if( p_sys->i_canvas_width > p_sys->i_nopadd_width )
2051 i_dst_width = p_sys->i_canvas_width & ~1;
2052 p_sys->i_dst_x_offset = ( i_dst_width - p_sys->i_nopadd_width )/2;
2053 p_sys->i_dst_x_offset = p_sys->i_dst_x_offset & ~1;
2057 if( p_sys->i_canvas_height <= 0 )
2059 /* No canvas set, add padding border */
2060 i_dst_height = p_sys->i_nopadd_height + ( p_sys->i_padd_top & ~1 ) +
2061 ( p_sys->i_padd_bottom & ~1 );
2062 p_sys->i_dst_y_offset = ( p_sys->i_padd_top & ~1 );
2066 /* Canvas set, check if we have to padd or crop */
2067 if( p_sys->i_canvas_height < p_sys->i_nopadd_height )
2069 /* need to crop more, but keep same scaling */
2070 int i_crop = 2 * (int)( ( p_sys->i_canvas_height & ~1 ) /
2071 f_scale_height / 2 + 0.5 );
2073 p_sys->i_src_y_offset += ( ( p_sys->i_crop_height - i_crop ) / 2 )
2075 p_sys->i_crop_height = i_crop;
2076 i_dst_height = p_sys->i_canvas_height & ~1;
2077 p_sys->i_nopadd_height = i_dst_height;
2079 else if( p_sys->i_canvas_height > p_sys->i_nopadd_height )
2082 i_dst_height = p_sys->i_canvas_height & ~1;
2083 p_sys->i_dst_y_offset = ( i_dst_height - p_sys->i_nopadd_height )
2085 p_sys->i_dst_y_offset = p_sys->i_dst_y_offset & ~1;
2089 /* Change aspect ratio from scaled pixel to output frame */
2090 f_aspect = f_aspect * i_dst_width / i_dst_height;
2092 /* Store calculated values */
2093 id->p_encoder->fmt_out.video.i_width = i_dst_width;
2094 id->p_encoder->fmt_out.video.i_height = i_dst_height;
2096 id->p_encoder->fmt_in.video.i_width = i_dst_width;
2097 id->p_encoder->fmt_in.video.i_height = i_dst_height;
2099 msg_Dbg( p_stream, "source %ix%i, crop %ix%i, "
2100 "destination %ix%i, padding %ix%i",
2101 i_src_width, i_src_height,
2102 p_sys->i_crop_width, p_sys->i_crop_height,
2103 p_sys->i_nopadd_width, p_sys->i_nopadd_height,
2104 i_dst_width, i_dst_height
2107 /* Handle frame rate conversion */
2108 if( !id->p_encoder->fmt_out.video.i_frame_rate ||
2109 !id->p_encoder->fmt_out.video.i_frame_rate_base )
2111 if( id->p_decoder->fmt_out.video.i_frame_rate &&
2112 id->p_decoder->fmt_out.video.i_frame_rate_base )
2114 id->p_encoder->fmt_out.video.i_frame_rate =
2115 id->p_decoder->fmt_out.video.i_frame_rate;
2116 id->p_encoder->fmt_out.video.i_frame_rate_base =
2117 id->p_decoder->fmt_out.video.i_frame_rate_base;
2121 /* Pick a sensible default value */
2122 id->p_encoder->fmt_out.video.i_frame_rate = ENC_FRAMERATE;
2123 id->p_encoder->fmt_out.video.i_frame_rate_base = ENC_FRAMERATE_BASE;
2127 id->p_encoder->fmt_in.video.i_frame_rate =
2128 id->p_encoder->fmt_out.video.i_frame_rate;
2129 id->p_encoder->fmt_in.video.i_frame_rate_base =
2130 id->p_encoder->fmt_out.video.i_frame_rate_base;
2132 date_Init( &id->interpolated_pts,
2133 id->p_encoder->fmt_out.video.i_frame_rate,
2134 id->p_encoder->fmt_out.video.i_frame_rate_base );
2136 /* Check whether a particular aspect ratio was requested */
2137 if( !id->p_encoder->fmt_out.video.i_aspect )
2139 id->p_encoder->fmt_out.video.i_aspect =
2140 (int)( f_aspect * VOUT_ASPECT_FACTOR + 0.5 );
2142 id->p_encoder->fmt_in.video.i_aspect =
2143 id->p_encoder->fmt_out.video.i_aspect;
2145 msg_Dbg( p_stream, "encoder aspect is %i:%i",
2146 id->p_encoder->fmt_out.video.i_aspect, VOUT_ASPECT_FACTOR );
2148 id->p_encoder->p_module =
2149 module_Need( id->p_encoder, "encoder", p_sys->psz_venc, true );
2150 if( !id->p_encoder->p_module )
2152 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_venc );
2153 return VLC_EGENERIC;
2156 id->p_encoder->fmt_in.video.i_chroma = id->p_encoder->fmt_in.i_codec;
2158 /* Hack for mp2v/mp1v transcoding support */
2159 if( id->p_encoder->fmt_out.i_codec == VLC_FOURCC('m','p','1','v') ||
2160 id->p_encoder->fmt_out.i_codec == VLC_FOURCC('m','p','2','v') )
2162 id->p_encoder->fmt_out.i_codec = VLC_FOURCC('m','p','g','v');
2165 id->id = p_stream->p_sys->p_out->pf_add( p_stream->p_sys->p_out,
2166 &id->p_encoder->fmt_out );
2169 msg_Err( p_stream, "cannot add this stream" );
2170 return VLC_EGENERIC;
2176 static void transcode_video_close( sout_stream_t *p_stream,
2177 sout_stream_id_t *id )
2181 if( p_stream->p_sys->i_threads >= 1 )
2183 vlc_mutex_lock( &p_stream->p_sys->lock_out );
2184 vlc_object_kill( p_stream->p_sys );
2185 vlc_cond_signal( &p_stream->p_sys->cond );
2186 vlc_mutex_unlock( &p_stream->p_sys->lock_out );
2187 vlc_thread_join( p_stream->p_sys );
2188 vlc_mutex_destroy( &p_stream->p_sys->lock_out );
2189 vlc_cond_destroy( &p_stream->p_sys->cond );
2192 video_timer_close( id->p_encoder );
2195 if( id->p_decoder->p_module )
2196 module_Unneed( id->p_decoder, id->p_decoder->p_module );
2198 if( id->p_decoder->p_owner )
2200 /* Clean-up pictures ring buffer */
2201 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2203 if( id->p_decoder->p_owner->pp_pics[i] )
2204 video_del_buffer( VLC_OBJECT(id->p_decoder),
2205 id->p_decoder->p_owner->pp_pics[i] );
2207 free( id->p_decoder->p_owner );
2211 if( id->p_encoder->p_module )
2212 module_Unneed( id->p_encoder, id->p_encoder->p_module );
2215 for( i = 0; i < id->i_filter; i++ )
2217 transcode_video_filter_close( p_stream, id->pp_filter[i] );
2218 id->pp_filter[i] = NULL;
2222 for( i = 0; i < id->i_ufilter; i++ )
2224 transcode_video_filter_close( p_stream, id->pp_ufilter[i] );
2225 id->pp_ufilter[i] = NULL;
2230 static int transcode_video_process( sout_stream_t *p_stream,
2231 sout_stream_id_t *id,
2232 block_t *in, block_t **out )
2234 sout_stream_sys_t *p_sys = p_stream->p_sys;
2235 int i_duplicate = 1, i;
2236 picture_t *p_pic, *p_pic2 = NULL;
2239 while( (p_pic = id->p_decoder->pf_decode_video( id->p_decoder, &in )) )
2241 subpicture_t *p_subpic = NULL;
2243 sout_UpdateStatistic( p_stream->p_sout, SOUT_STATISTIC_DECODED_VIDEO, 1 );
2245 if( p_stream->p_sout->i_out_pace_nocontrol && p_sys->b_hurry_up )
2247 mtime_t current_date = mdate();
2248 if( current_date + 50000 > p_pic->date )
2250 msg_Dbg( p_stream, "late picture skipped (%"PRId64")",
2251 current_date + 50000 - p_pic->date );
2252 p_pic->pf_release( p_pic );
2257 if( p_sys->b_master_sync )
2259 mtime_t i_video_drift;
2260 mtime_t i_master_drift = p_sys->i_master_drift;
2263 i_pts = date_Get( &id->interpolated_pts ) + 1;
2264 if ( p_pic->date - i_pts > MASTER_SYNC_MAX_DRIFT
2265 || p_pic->date - i_pts < -MASTER_SYNC_MAX_DRIFT )
2267 msg_Dbg( p_stream, "drift is too high, resetting master sync" );
2268 date_Set( &id->interpolated_pts, p_pic->date );
2269 i_pts = p_pic->date + 1;
2271 i_video_drift = p_pic->date - i_pts;
2274 /* Set the pts of the frame being encoded */
2275 p_pic->date = i_pts;
2277 if( i_video_drift < (i_master_drift - 50000) )
2280 msg_Dbg( p_stream, "dropping frame (%i)",
2281 (int)(i_video_drift - i_master_drift) );
2283 p_pic->pf_release( p_pic );
2286 else if( i_video_drift > (i_master_drift + 50000) )
2289 msg_Dbg( p_stream, "adding frame (%i)",
2290 (int)(i_video_drift - i_master_drift) );
2296 if( !id->p_encoder->p_module )
2298 if( transcode_video_encoder_open( p_stream, id ) != VLC_SUCCESS )
2300 p_pic->pf_release( p_pic );
2301 transcode_video_close( p_stream, id );
2302 id->b_transcode = false;
2303 return VLC_EGENERIC;
2307 if( p_stream->p_sys->b_deinterlace )
2309 id->pp_filter[id->i_filter] =
2310 transcode_video_filter_new( p_stream,
2311 &id->p_decoder->fmt_out,
2312 &id->p_decoder->fmt_out,
2313 p_sys->p_deinterlace_cfg,
2314 p_sys->psz_deinterlace );
2316 if( id->pp_filter[id->i_filter] )
2320 #if (defined(HAVE_FFMPEG_SWSCALE_H) || defined(HAVE_LIBSWSCALE_TREE)) || defined(HAVE_LIBSWSCALE_SWSCALE_H)
2321 if( ( id->p_decoder->fmt_out.video.i_chroma !=
2322 id->p_encoder->fmt_in.video.i_chroma ) ||
2323 ( id->p_decoder->fmt_out.video.i_width !=
2324 id->p_encoder->fmt_in.video.i_width ) ||
2325 ( id->p_decoder->fmt_out.video.i_height !=
2326 id->p_encoder->fmt_in.video.i_height ) )
2328 id->pp_filter[id->i_filter] =
2329 transcode_video_filter_new( p_stream,
2330 &id->p_decoder->fmt_out,
2331 &id->p_encoder->fmt_in,
2333 if( !id->pp_filter[id->i_filter] )
2335 p_pic->pf_release( p_pic );
2336 transcode_video_close( p_stream, id );
2337 id->b_transcode = false;
2338 return VLC_EGENERIC;
2343 /* we don't do chroma conversion or scaling in croppad */
2344 // es_format_t fmt_in, fmt_out;
2345 // es_format_Copy( &fmt_out, &id->p_encoder->fmt_in );
2346 // es_format_Copy( &fmt_in, &id->p_encoder->fmt_in );
2348 if( ( id->p_decoder->fmt_out.video.i_chroma ==
2349 id->p_encoder->fmt_in.video.i_chroma ) &&
2351 ( ( (int)id->p_decoder->fmt_out.video.i_width !=
2352 p_sys->i_crop_width ) ||
2353 ( p_sys->i_crop_width != p_sys->i_nopadd_width ) ||
2354 ( p_sys->i_nopadd_width !=
2355 (int)id->p_encoder->fmt_out.video.i_width ) ||
2357 ( (int)id->p_decoder->fmt_out.video.i_height !=
2358 p_sys->i_crop_height ) ||
2359 ( p_sys->i_crop_height != p_sys->i_nopadd_height ) ||
2360 ( p_sys->i_nopadd_height !=
2361 (int)id->p_encoder->fmt_out.video.i_height ) ) )
2363 id->pp_filter[id->i_filter] =
2364 transcode_video_filter_new( p_stream,
2365 &id->p_decoder->fmt_out,
2366 &id->p_encoder->fmt_in,
2368 if( id->pp_filter[id->i_filter] )
2370 /* Set crop and padding information */
2371 id->pp_filter[id->i_filter]->fmt_in.video.i_x_offset = p_sys->i_src_x_offset;
2372 id->pp_filter[id->i_filter]->fmt_in.video.i_y_offset = p_sys->i_src_y_offset;
2373 id->pp_filter[id->i_filter]->fmt_in.video.i_visible_width = p_sys->i_crop_width;
2374 id->pp_filter[id->i_filter]->fmt_in.video.i_visible_height = p_sys->i_crop_height;
2376 id->pp_filter[id->i_filter]->fmt_out.video.i_x_offset = p_sys->i_dst_x_offset;
2377 id->pp_filter[id->i_filter]->fmt_out.video.i_y_offset = p_sys->i_dst_y_offset;
2378 id->pp_filter[id->i_filter]->fmt_out.video.i_visible_width = p_sys->i_nopadd_width;
2379 id->pp_filter[id->i_filter]->fmt_out.video.i_visible_height = p_sys->i_nopadd_height;
2386 /* Check if we need a filter for chroma conversion or resizing */
2387 if( id->p_decoder->fmt_out.video.i_chroma !=
2388 id->p_encoder->fmt_in.video.i_chroma ||
2390 (int)id->p_decoder->fmt_out.video.i_width != p_sys->i_crop_width ||
2391 p_sys->i_crop_width != p_sys->i_nopadd_width ||
2392 p_sys->i_nopadd_width != (int)id->p_encoder->fmt_out.video.i_width ||
2394 (int)id->p_decoder->fmt_out.video.i_height != p_sys->i_crop_height ||
2395 p_sys->i_crop_height != p_sys->i_nopadd_height ||
2396 p_sys->i_nopadd_height != (int)id->p_encoder->fmt_out.video.i_height)
2398 id->pp_filter[id->i_filter] =
2399 transcode_video_filter_new( p_stream,
2400 &id->p_decoder->fmt_out,
2401 &id->p_encoder->fmt_in,
2402 NULL, "crop padd" );
2403 if( !id->pp_filter[id->i_filter] )
2405 p_pic->pf_release( p_pic );
2406 transcode_video_close( p_stream, id );
2407 id->b_transcode = false;
2408 return VLC_EGENERIC;
2411 /* Set crop and padding information */
2412 id->pp_filter[id->i_filter]->fmt_in.video.i_x_offset = p_sys->i_src_x_offset;
2413 id->pp_filter[id->i_filter]->fmt_in.video.i_y_offset = p_sys->i_src_y_offset;
2414 id->pp_filter[id->i_filter]->fmt_in.video.i_visible_width = p_sys->i_crop_width;
2415 id->pp_filter[id->i_filter]->fmt_in.video.i_visible_height = p_sys->i_crop_height;
2417 id->pp_filter[id->i_filter]->fmt_out.video.i_x_offset = p_sys->i_dst_x_offset;
2418 id->pp_filter[id->i_filter]->fmt_out.video.i_y_offset = p_sys->i_dst_y_offset;
2419 id->pp_filter[id->i_filter]->fmt_out.video.i_visible_width = p_sys->i_nopadd_width;
2420 id->pp_filter[id->i_filter]->fmt_out.video.i_visible_height = p_sys->i_nopadd_height;
2425 for( i = 0; (i < p_sys->i_vfilters) && (id->i_ufilter < TRANSCODE_FILTERS); i++ )
2427 id->pp_ufilter[id->i_ufilter] =
2428 transcode_video_filter_new( p_stream,
2429 &id->p_decoder->fmt_out, &id->p_encoder->fmt_in,
2430 p_sys->p_vfilters_cfg[i], p_sys->psz_vfilters[i] );
2431 if( id->pp_ufilter[id->i_filter] )
2434 id->pp_ufilter[id->i_ufilter] = NULL;
2438 /* Run filter chain */
2439 for( i = 0; i < id->i_filter; i++ )
2441 p_pic = id->pp_filter[i]->pf_video_filter(id->pp_filter[i], p_pic);
2448 /* Check if we have a subpicture to overlay */
2451 p_subpic = spu_SortSubpictures( p_sys->p_spu, p_pic->date,
2452 false /* Fixme: check if stream is paused */ );
2453 /* TODO: get another pic */
2456 /* Overlay subpicture */
2459 int i_scale_width, i_scale_height;
2460 video_format_t *p_fmt;
2462 i_scale_width = id->p_encoder->fmt_in.video.i_width * 1000 /
2463 id->p_decoder->fmt_out.video.i_width;
2464 i_scale_height = id->p_encoder->fmt_in.video.i_height * 1000 /
2465 id->p_decoder->fmt_out.video.i_height;
2467 if( p_pic->i_refcount && !id->i_filter )
2469 /* We can't modify the picture, we need to duplicate it */
2470 picture_t *p_tmp = video_new_buffer_decoder( id->p_decoder );
2473 vout_CopyPicture( p_stream, p_tmp, p_pic );
2474 p_pic->pf_release( p_pic );
2480 p_fmt = &id->pp_filter[id->i_filter -1]->fmt_out.video;
2482 p_fmt = &id->p_decoder->fmt_out.video;
2484 /* FIXME (shouldn't have to be done here) */
2485 p_fmt->i_sar_num = p_fmt->i_aspect *
2486 p_fmt->i_height / p_fmt->i_width;
2487 p_fmt->i_sar_den = VOUT_ASPECT_FACTOR;
2489 spu_RenderSubpictures( p_sys->p_spu, p_fmt, p_pic, p_pic, p_subpic,
2490 i_scale_width, i_scale_height );
2493 /* Run user specified filter chain */
2494 for( i = 0; i < id->i_ufilter; i++ )
2496 p_pic = id->pp_ufilter[i]->pf_video_filter( id->pp_ufilter[i],
2500 if( p_sys->i_threads == 0 )
2504 video_timer_start( id->p_encoder );
2505 p_block = id->p_encoder->pf_encode_video( id->p_encoder, p_pic );
2506 video_timer_stop( id->p_encoder );
2508 block_ChainAppend( out, p_block );
2511 if( p_sys->b_master_sync )
2513 mtime_t i_pts = date_Get( &id->interpolated_pts ) + 1;
2514 if ( p_pic->date - i_pts > MASTER_SYNC_MAX_DRIFT
2515 || p_pic->date - i_pts < -MASTER_SYNC_MAX_DRIFT )
2517 msg_Dbg( p_stream, "drift is too high, resetting master sync" );
2518 date_Set( &id->interpolated_pts, p_pic->date );
2519 i_pts = p_pic->date + 1;
2521 date_Increment( &id->interpolated_pts, 1 );
2524 if( p_sys->b_master_sync && i_duplicate > 1 )
2526 mtime_t i_pts = date_Get( &id->interpolated_pts ) + 1;
2527 if( (p_pic->date - i_pts > MASTER_SYNC_MAX_DRIFT)
2528 || ((p_pic->date - i_pts) < -MASTER_SYNC_MAX_DRIFT) )
2530 msg_Dbg( p_stream, "drift is too high, resetting master sync" );
2531 date_Set( &id->interpolated_pts, p_pic->date );
2532 i_pts = p_pic->date + 1;
2534 date_Increment( &id->interpolated_pts, 1 );
2536 if( p_sys->i_threads >= 1 )
2538 /* We can't modify the picture, we need to duplicate it */
2539 p_pic2 = video_new_buffer_decoder( id->p_decoder );
2540 if( p_pic2 != NULL )
2542 vout_CopyPicture( p_stream, p_pic2, p_pic );
2543 p_pic2->date = i_pts;
2549 p_pic->date = i_pts;
2550 p_block = id->p_encoder->pf_encode_video(id->p_encoder, p_pic);
2551 block_ChainAppend( out, p_block );
2555 if( p_sys->i_threads == 0 )
2557 p_pic->pf_release( p_pic );
2561 vlc_mutex_lock( &p_sys->lock_out );
2562 p_sys->pp_pics[p_sys->i_last_pic++] = p_pic;
2563 p_sys->i_last_pic %= PICTURE_RING_SIZE;
2564 *out = p_sys->p_buffers;
2565 p_sys->p_buffers = NULL;
2566 if( p_pic2 != NULL )
2568 p_sys->pp_pics[p_sys->i_last_pic++] = p_pic2;
2569 p_sys->i_last_pic %= PICTURE_RING_SIZE;
2571 vlc_cond_signal( &p_sys->cond );
2572 vlc_mutex_unlock( &p_sys->lock_out );
2579 static int EncoderThread( sout_stream_sys_t *p_sys )
2581 sout_stream_id_t *id = p_sys->id_video;
2584 while( !p_sys->b_die && !p_sys->b_error )
2588 vlc_mutex_lock( &p_sys->lock_out );
2589 while( p_sys->i_last_pic == p_sys->i_first_pic )
2591 vlc_cond_wait( &p_sys->cond, &p_sys->lock_out );
2592 if( p_sys->b_die || p_sys->b_error ) break;
2594 if( p_sys->b_die || p_sys->b_error )
2596 vlc_mutex_unlock( &p_sys->lock_out );
2600 p_pic = p_sys->pp_pics[p_sys->i_first_pic++];
2601 p_sys->i_first_pic %= PICTURE_RING_SIZE;
2602 vlc_mutex_unlock( &p_sys->lock_out );
2604 video_timer_start( id->p_encoder );
2605 p_block = id->p_encoder->pf_encode_video( id->p_encoder, p_pic );
2606 video_timer_stop( id->p_encoder );
2608 vlc_mutex_lock( &p_sys->lock_out );
2609 block_ChainAppend( &p_sys->p_buffers, p_block );
2611 vlc_mutex_unlock( &p_sys->lock_out );
2612 p_pic->pf_release( p_pic );
2615 while( p_sys->i_last_pic != p_sys->i_first_pic )
2617 p_pic = p_sys->pp_pics[p_sys->i_first_pic++];
2618 p_sys->i_first_pic %= PICTURE_RING_SIZE;
2619 p_pic->pf_release( p_pic );
2621 block_ChainRelease( p_sys->p_buffers );
2626 struct picture_sys_t
2628 vlc_object_t *p_owner;
2631 static void video_release_buffer( picture_t *p_pic )
2633 if( p_pic && !p_pic->i_refcount && p_pic->pf_release && p_pic->p_sys )
2635 video_del_buffer_decoder( (decoder_t *)p_pic->p_sys->p_owner, p_pic );
2637 else if( p_pic && p_pic->i_refcount > 0 ) p_pic->i_refcount--;
2640 static picture_t *video_new_buffer( vlc_object_t *p_this, picture_t **pp_ring,
2641 sout_stream_sys_t *p_sys )
2643 decoder_t *p_dec = (decoder_t *)p_this;
2647 /* Find an empty space in the picture ring buffer */
2648 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2650 if( pp_ring[i] != 0 && pp_ring[i]->i_status == DESTROYED_PICTURE )
2652 pp_ring[i]->i_status = RESERVED_PICTURE;
2656 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2658 if( pp_ring[i] == 0 ) break;
2661 if( i == PICTURE_RING_SIZE && p_sys->i_threads >= 1 )
2663 int i_first_pic = p_sys->i_first_pic;
2665 if( p_sys->i_first_pic != p_sys->i_last_pic )
2667 /* Encoder still has stuff to encode, wait to clear-up the list */
2668 while( p_sys->i_first_pic == i_first_pic )
2672 /* Find an empty space in the picture ring buffer */
2673 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2675 if( pp_ring[i] != 0 && pp_ring[i]->i_status == DESTROYED_PICTURE )
2677 pp_ring[i]->i_status = RESERVED_PICTURE;
2681 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2683 if( pp_ring[i] == 0 ) break;
2687 if( i == PICTURE_RING_SIZE )
2689 msg_Err( p_this, "decoder/filter is leaking pictures, "
2690 "resetting its ring buffer" );
2692 for( i = 0; i < PICTURE_RING_SIZE; i++ )
2694 pp_ring[i]->pf_release( pp_ring[i] );
2700 p_pic = malloc( sizeof(picture_t) );
2701 if( !p_pic ) return NULL;
2702 p_dec->fmt_out.video.i_chroma = p_dec->fmt_out.i_codec;
2703 vout_AllocatePicture( VLC_OBJECT(p_dec), p_pic,
2704 p_dec->fmt_out.video.i_chroma,
2705 p_dec->fmt_out.video.i_width,
2706 p_dec->fmt_out.video.i_height,
2707 p_dec->fmt_out.video.i_aspect );
2709 if( !p_pic->i_planes )
2715 p_pic->pf_release = video_release_buffer;
2716 p_pic->p_sys = malloc( sizeof(picture_sys_t) );
2723 p_pic->p_sys->p_owner = p_this;
2724 p_pic->i_status = RESERVED_PICTURE;
2730 static picture_t *video_new_buffer_decoder( decoder_t *p_dec )
2732 return video_new_buffer( VLC_OBJECT(p_dec),
2733 p_dec->p_owner->pp_pics, p_dec->p_owner->p_sys );
2736 static picture_t *video_new_buffer_filter( filter_t *p_filter )
2738 return video_new_buffer( VLC_OBJECT(p_filter),
2739 p_filter->p_owner->pp_pics,
2740 p_filter->p_owner->p_sys );
2743 static void video_del_buffer( vlc_object_t *p_this, picture_t *p_pic )
2748 free( p_pic->p_data_orig );
2749 free( p_pic->p_sys );
2754 static void video_del_buffer_decoder( decoder_t *p_decoder, picture_t *p_pic )
2756 VLC_UNUSED(p_decoder);
2757 p_pic->i_refcount = 0;
2758 p_pic->i_status = DESTROYED_PICTURE;
2761 static void video_del_buffer_filter( filter_t *p_filter, picture_t *p_pic )
2763 VLC_UNUSED(p_filter);
2764 p_pic->i_refcount = 0;
2765 p_pic->i_status = DESTROYED_PICTURE;
2768 static void video_link_picture_decoder( decoder_t *p_dec, picture_t *p_pic )
2771 p_pic->i_refcount++;
2774 static void video_unlink_picture_decoder( decoder_t *p_dec, picture_t *p_pic )
2777 video_release_buffer( p_pic );
2783 static subpicture_t *spu_new_buffer( decoder_t * );
2784 static void spu_del_buffer( decoder_t *, subpicture_t * );
2786 static int transcode_spu_new( sout_stream_t *p_stream, sout_stream_id_t *id )
2788 sout_stream_sys_t *p_sys = p_stream->p_sys;
2794 /* Initialization of decoder structures */
2795 id->p_decoder->pf_decode_sub = NULL;
2796 id->p_decoder->pf_spu_buffer_new = spu_new_buffer;
2797 id->p_decoder->pf_spu_buffer_del = spu_del_buffer;
2798 id->p_decoder->p_owner = (decoder_owner_sys_t *)p_stream;
2799 /* id->p_decoder->p_cfg = p_sys->p_spu_cfg; */
2801 id->p_decoder->p_module =
2802 module_Need( id->p_decoder, "decoder", "$codec", 0 );
2804 if( !id->p_decoder->p_module )
2806 msg_Err( p_stream, "cannot find decoder" );
2807 return VLC_EGENERIC;
2810 if( !p_sys->b_soverlay )
2813 /* Initialization of encoder format structures */
2814 es_format_Init( &id->p_encoder->fmt_in, id->p_decoder->fmt_in.i_cat,
2815 id->p_decoder->fmt_in.i_codec );
2817 id->p_encoder->p_cfg = p_sys->p_spu_cfg;
2819 id->p_encoder->p_module =
2820 module_Need( id->p_encoder, "encoder", p_sys->psz_senc, true );
2822 if( !id->p_encoder->p_module )
2824 module_Unneed( id->p_decoder, id->p_decoder->p_module );
2825 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_senc );
2826 return VLC_EGENERIC;
2832 p_sys->p_spu = spu_Create( p_stream );
2833 spu_Init( p_sys->p_spu );
2839 static void transcode_spu_close( sout_stream_id_t *id)
2842 if( id->p_decoder->p_module )
2843 module_Unneed( id->p_decoder, id->p_decoder->p_module );
2846 if( id->p_encoder->p_module )
2847 module_Unneed( id->p_encoder, id->p_encoder->p_module );
2850 static int transcode_spu_process( sout_stream_t *p_stream,
2851 sout_stream_id_t *id,
2852 block_t *in, block_t **out )
2854 sout_stream_sys_t *p_sys = p_stream->p_sys;
2855 subpicture_t *p_subpic;
2858 p_subpic = id->p_decoder->pf_decode_sub( id->p_decoder, &in );
2860 return VLC_EGENERIC;
2862 sout_UpdateStatistic( p_stream->p_sout, SOUT_STATISTIC_DECODED_SUBTITLE, 1 );
2864 if( p_sys->b_master_sync && p_sys->i_master_drift )
2866 p_subpic->i_start -= p_sys->i_master_drift;
2867 if( p_subpic->i_stop ) p_subpic->i_stop -= p_sys->i_master_drift;
2870 if( p_sys->b_soverlay )
2872 spu_DisplaySubpicture( p_sys->p_spu, p_subpic );
2878 p_block = id->p_encoder->pf_encode_sub( id->p_encoder, p_subpic );
2879 spu_del_buffer( id->p_decoder, p_subpic );
2882 block_ChainAppend( out, p_block );
2887 return VLC_EGENERIC;
2890 static subpicture_t *spu_new_buffer( decoder_t *p_dec )
2892 sout_stream_t *p_stream = (sout_stream_t *)p_dec->p_owner;
2893 return spu_CreateSubpicture( p_stream->p_sys->p_spu );
2896 static void spu_del_buffer( decoder_t *p_dec, subpicture_t *p_subpic )
2898 sout_stream_t *p_stream = (sout_stream_t *)p_dec->p_owner;
2899 spu_DestroySubpicture( p_stream->p_sys->p_spu, p_subpic );
2905 static int transcode_osd_new( sout_stream_t *p_stream, sout_stream_id_t *id )
2907 sout_stream_sys_t *p_sys = p_stream->p_sys;
2909 id->p_decoder->fmt_in.i_cat = SPU_ES;
2910 id->p_encoder->fmt_out.psz_language = strdup( "osd" );
2912 if( p_sys->i_osdcodec != 0 || p_sys->psz_osdenc )
2914 msg_Dbg( p_stream, "creating osdmenu transcoding from fcc=`%4.4s' "
2915 "to fcc=`%4.4s'", (char*)&id->p_encoder->fmt_out.i_codec,
2916 (char*)&p_sys->i_osdcodec );
2918 /* Complete destination format */
2919 id->p_encoder->fmt_out.i_codec = p_sys->i_osdcodec;
2922 es_format_Init( &id->p_encoder->fmt_in, id->p_decoder->fmt_in.i_cat,
2923 VLC_FOURCC('Y','U','V','A') );
2924 id->p_encoder->fmt_in.psz_language = strdup( "osd" );
2926 id->p_encoder->p_cfg = p_sys->p_osd_cfg;
2928 id->p_encoder->p_module =
2929 module_Need( id->p_encoder, "encoder", p_sys->psz_osdenc, true );
2931 if( !id->p_encoder->p_module )
2933 msg_Err( p_stream, "cannot find encoder (%s)", p_sys->psz_osdenc );
2937 /* open output stream */
2938 id->id = p_sys->p_out->pf_add( p_sys->p_out, &id->p_encoder->fmt_out );
2939 id->b_transcode = true;
2941 if( !id->id ) goto error;
2945 msg_Dbg( p_stream, "not transcoding a stream (fcc=`%4.4s')",
2946 (char*)&id->p_decoder->fmt_out.i_codec );
2947 id->id = p_sys->p_out->pf_add( p_sys->p_out, &id->p_decoder->fmt_out );
2948 id->b_transcode = false;
2950 if( !id->id ) goto error;
2955 p_sys->p_spu = spu_Create( p_stream );
2956 spu_Init( p_sys->p_spu );
2962 msg_Err( p_stream, "starting osd encoding thread failed" );
2963 if( id->p_encoder->p_module )
2964 module_Unneed( id->p_encoder, id->p_encoder->p_module );
2965 p_sys->b_osd = false;
2966 return VLC_EGENERIC;
2969 static void transcode_osd_close( sout_stream_t *p_stream, sout_stream_id_t *id)
2971 sout_stream_sys_t *p_sys = p_stream->p_sys;
2974 if( p_sys->b_osd && id )
2976 if( id->p_encoder->p_module )
2977 module_Unneed( id->p_encoder, id->p_encoder->p_module );
2979 p_sys->b_osd = false;
2982 static int transcode_osd_process( sout_stream_t *p_stream,
2983 sout_stream_id_t *id,
2984 block_t *in, block_t **out )
2986 sout_stream_sys_t *p_sys = p_stream->p_sys;
2987 subpicture_t *p_subpic = NULL;
2989 /* Check if we have a subpicture to send */
2990 if( p_sys->p_spu && in->i_dts > 0)
2992 p_subpic = spu_SortSubpictures( p_sys->p_spu, in->i_dts, false );
2996 msg_Warn( p_stream, "spu channel not initialized, doing it now" );
2999 p_sys->p_spu = spu_Create( p_stream );
3000 spu_Init( p_sys->p_spu );
3006 block_t *p_block = NULL;
3008 if( p_sys->b_master_sync && p_sys->i_master_drift )
3010 p_subpic->i_start -= p_sys->i_master_drift;
3011 if( p_subpic->i_stop ) p_subpic->i_stop -= p_sys->i_master_drift;
3014 p_block = id->p_encoder->pf_encode_sub( id->p_encoder, p_subpic );
3015 spu_DestroySubpicture( p_sys->p_spu, p_subpic );
3018 p_block->i_dts = p_block->i_pts = in->i_dts;
3019 block_ChainAppend( out, p_block );
3023 return VLC_EGENERIC;