584dc1891041f9ab029acb91086ecf049afe72e8
[goodguy/history.git] / cinelerra-5.0 / cinelerra / filempeg.C
1
2 /*
3  * CINELERRA
4  * Copyright (C) 2008 Adam Williams <broadcast at earthling dot net>
5  * 
6  * This program is free software; you can redistribute it and/or modify
7  * it under the terms of the GNU General Public License as published by
8  * the Free Software Foundation; either version 2 of the License, or
9  * (at your option) any later version.
10  * 
11  * This program is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
14  * GNU General Public License for more details.
15  * 
16  * You should have received a copy of the GNU General Public License
17  * along with this program; if not, write to the Free Software
18  * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
19  * 
20  */
21
22 #include "asset.h"
23 #include "bcprogressbox.h"
24 #include "bcsignals.h"
25 #include "bitspopup.h"
26 #include "byteorder.h"
27 #include "clip.h"
28 #include "commercials.h"
29 #include "condition.h"
30 #include "cstrdup.h"
31 #include "edit.h"
32 #include "file.h"
33 #include "filempeg.h"
34 #include "filesystem.h"
35 #include "format.inc"
36 #include "guicast.h"
37 #include "indexfile.h"
38 #include "indexstate.h"
39 #include "language.h"
40 #include "mainerror.h"
41 #include "mwindow.h"
42 #include "pipe.h"
43 #include "preferences.h"
44 #include "removefile.h"
45 #include "vframe.h"
46 #include "videodevice.inc"
47
48 #include <stdio.h>
49 #include <string.h>
50 #include <unistd.h>
51
52
53 #define HVPEG_EXE "/hveg2enc.plugin"
54 #define MJPEG_EXE "/mpeg2enc.plugin"
55
56
57 // M JPEG dependancies
58 static double frame_rate_codes[] = 
59 {
60         0,
61         24000.0/1001.0,
62         24.0,
63         25.0,
64         30000.0/1001.0,
65         30.0,
66         50.0,
67         60000.0/1001.0,
68         60.0
69 };
70
71 static double aspect_ratio_codes[] =
72 {
73         0,
74         1.0,
75         1.333,
76         1.777,
77         2.21
78 };
79
80
81
82
83
84
85
86
87 FileMPEG::FileMPEG(Asset *asset, File *file)
88  : FileBase(asset, file)
89 {
90         reset_parameters();
91 // May also be VMPEG or AMPEG if write status.
92         if(asset->format == FILE_UNKNOWN) asset->format = FILE_MPEG;
93         asset->byte_order = 0;
94         next_frame_lock = new Condition(0, "FileMPEG::next_frame_lock");
95         next_frame_done = new Condition(0, "FileMPEG::next_frame_done");
96         vcommand_line.set_array_delete();
97 }
98
99 FileMPEG::~FileMPEG()
100 {
101         close_file();
102         delete next_frame_lock;
103         delete next_frame_done;
104         vcommand_line.remove_all_objects();
105 }
106
107 void FileMPEG::get_parameters(BC_WindowBase *parent_window, 
108         Asset *asset, 
109         BC_WindowBase* &format_window,
110         int audio_options,
111         int video_options)
112 {
113         if(audio_options && asset->format == FILE_AMPEG)
114         {
115                 MPEGConfigAudio *window = new MPEGConfigAudio(parent_window, asset);
116                 format_window = window;
117                 window->create_objects();
118                 window->run_window();
119                 delete window;
120         }
121         else
122         if(video_options && asset->format == FILE_VMPEG)
123         {
124                 MPEGConfigVideo *window = new MPEGConfigVideo(parent_window, asset);
125                 format_window = window;
126                 window->create_objects();
127                 window->run_window();
128                 delete window;
129         }
130 }
131
132 int FileMPEG::check_sig(Asset *asset)
133 {
134         return mpeg3_check_sig(asset->path);
135 }
136
137 void FileMPEG::get_info(char *title_path, char *path, char *text)
138 {
139         mpeg3_t *fd;
140         *text = 0;
141
142         int result = 0;
143         int zio_access = ZIO_UNBUFFERED+ZIO_SINGLE_ACCESS;
144         if( !(fd=mpeg3_zopen(title_path, path, &result,zio_access)) ) result = 1;
145         if( !result ) result = mpeg3_create_title(fd, 0);
146         if( result ) return;
147
148         char *cp = text;
149         if( mpeg3_has_toc(fd) ) {
150                 cp += sprintf(cp, _("toc path:%s\n"), path);
151                 cp += sprintf(cp, _("title path:\n"));
152                 for( int i=0; i<100; ++i ) {
153                         char *title_path = mpeg3_title_path(fd,i);
154                         if( !title_path ) break;
155                         cp += sprintf(cp, " %2d. %s\n", i+1, title_path);
156                 }
157         }
158         else
159                 cp += sprintf(cp, _("file path:%s\n"), path);
160         int64_t bytes = mpeg3_get_bytes(fd);
161         char string[BCTEXTLEN];
162         sprintf(string,"%ld",bytes);
163         Units::punctuate(string);
164         cp += sprintf(cp, _("size: %s"), string);
165
166         if( mpeg3_is_program_stream(fd) )
167           cp += sprintf(cp, _("  program stream\n"));
168         else if( mpeg3_is_transport_stream(fd) )
169           cp += sprintf(cp, _("  transport stream\n"));
170         else if( mpeg3_is_video_stream(fd) )
171           cp += sprintf(cp, _("  video stream\n"));
172         else if( mpeg3_is_audio_stream(fd) )
173           cp += sprintf(cp, _("  audio stream\n"));
174
175         int64_t sdate = mpeg3_get_source_date(fd);
176         if( !sdate ) {
177                 struct stat64 ostat;
178                 memset(&ostat,0,sizeof(struct stat64));
179                 sdate = stat64(path, &ostat) < 0 ? 0 : ostat.st_mtime;
180         }
181         time_t tm = (time_t)sdate;
182         cp += sprintf(cp, _("date: %s\n"), ctime(&tm));
183
184         int vtrks = mpeg3_total_vstreams(fd);
185         cp += sprintf(cp, _("%d video tracks\n"), vtrks);
186         for( int vtrk=0; vtrk<vtrks; ++vtrk ) {
187                 int cmdl = mpeg3_colormodel(fd, vtrk);
188                 int color_model = bc_colormodel(cmdl);
189                 char *cmodel = MPEGColorModel::cmodel_to_string(color_model);
190                 int width = mpeg3_video_width(fd, vtrk);
191                 int height = mpeg3_video_height(fd, vtrk);
192                 cp += sprintf(cp, _("  v%d %s %dx%d"), vtrk, cmodel, width, height);
193                 double frame_rate = mpeg3_frame_rate(fd, vtrk);
194                 int64_t frames = mpeg3_video_frames(fd, vtrk);
195                 cp += sprintf(cp, _(" (%5.2f), %ld frames"), frame_rate, frames);
196                 if( frame_rate > 0 ) {
197                         double secs = (double)frames / frame_rate;
198                         cp += sprintf(cp, _(" (%0.3f secs)"),secs);
199                 }
200                 *cp++ = '\n';
201         }
202         int atrks = mpeg3_total_astreams(fd);
203         cp += sprintf(cp, _("%d audio tracks\n"), atrks);
204         for( int atrk=0; atrk<atrks; ++atrk) {
205                 const char *format = mpeg3_audio_format(fd, atrk);
206                 cp += sprintf(cp, _(" a%d %s"), atrk, format);
207                 int channels = mpeg3_audio_channels(fd, atrk);
208                 int sample_rate = mpeg3_sample_rate(fd, atrk);
209                 cp += sprintf(cp, _(" ch%d (%d)"), channels, sample_rate);
210                 int64_t samples = mpeg3_audio_samples(fd, atrk);
211                 cp += sprintf(cp, " %ld",samples);
212                 int64_t nudge = mpeg3_get_audio_nudge(fd, atrk);
213                 *cp++ = nudge >= 0 ? '+' : (nudge=-nudge, '-');
214                 cp += sprintf(cp, _("%ld samples"),nudge);
215                 if( sample_rate > 0 ) {
216                         double secs = (double)(samples+nudge) / sample_rate;
217                         cp += sprintf(cp, _(" (%0.3f secs)"),secs);
218                 }
219                 *cp++ = '\n';
220         }
221         int stracks = mpeg3_subtitle_tracks(fd);
222         if( stracks > 0 ) {
223                 cp += sprintf(cp, _("%d subtitles\n"), stracks);
224         }
225         int vts_titles = mpeg3_get_total_vts_titles(fd);
226         if( vts_titles > 0 )
227                 cp += sprintf(cp, _("%d title sets, "), vts_titles);
228         int interleaves = mpeg3_get_total_interleaves(fd);
229         if( interleaves > 0 )
230                 cp += sprintf(cp, _("%d interleaves\n"), interleaves);
231         int vts_title = mpeg3_set_vts_title(fd, -1);
232         int angle = mpeg3_set_angle(fd, -1);
233         int interleave = mpeg3_set_interleave(fd, -1);
234         int program = mpeg3_set_program(fd, -1);
235         cp += sprintf(cp, _("current program %d = title %d, angle %d, interleave %d\n\n"),
236                 program, vts_title, angle, interleave);
237
238         ArrayList<double> cell_times;
239         int cell_no = 0; double cell_time;
240         while( !mpeg3_get_cell_time(fd, cell_no++, &cell_time) ) {
241                 cell_times.append(cell_time);
242         }
243         if( cell_times.size() > 1 ) {
244                 cp += sprintf(cp, _("cell times:"));
245                 for( int i=0; i<cell_times.size(); ++i ) {
246                         if( (i%4) == 0 ) *cp++ = '\n';
247                         cp += sprintf(cp,_("  %3d.  %8.3f"),i,cell_times.get(i));
248                 }
249                 cp += sprintf(cp, "\n");
250         }
251
252         int elements = mpeg3_dvb_channel_count(fd);
253         if( elements <= 0 ) return;
254         if( !mpeg3_dvb_get_system_time(fd, &sdate) ) {
255                 tm = (time_t)sdate;
256                 cp += sprintf(cp, _("\nsystem time: %s"), ctime_r(&tm,string));
257         }
258         cp += sprintf(cp, _("elements %d\n"), elements);
259
260         for( int n=0; n<elements; ++n ) {
261                 char name[16], enc[8];  int vstream, astream;
262                 int major, minor, total_astreams, total_vstreams;
263                 if( mpeg3_dvb_get_channel(fd,n, &major, &minor) ||
264                     mpeg3_dvb_get_station_id(fd,n,&name[0]) ||
265                     mpeg3_dvb_total_vstreams(fd,n,&total_vstreams) ||
266                     mpeg3_dvb_total_astreams(fd,n,&total_astreams) )    continue;
267                 cp += sprintf(cp, " %3d.%-3d %s", major, minor, &name[0]);
268                 for( int vidx=0; vidx<total_vstreams; ++vidx ) {
269                         if( mpeg3_dvb_vstream_number(fd,n,vidx,&vstream) ) continue;
270                         if( vstream < 0 ) continue;
271                         cp += sprintf(cp, " v%d", vstream);
272                 }
273                 for( int aidx=0; aidx<total_astreams; ++aidx ) {
274                         if( mpeg3_dvb_astream_number(fd,n,aidx,&astream,&enc[0]) ) continue;
275                         if( astream < 0 ) continue;
276                         cp += sprintf(cp, "    a%d %s", astream, &enc[0]);
277                         int atrack = 0;
278                         for(int i=0; i<astream; ++i )
279                                 atrack += mpeg3_audio_channels(fd, i);
280                         int channels = mpeg3_audio_channels(fd, astream);
281                         cp += sprintf(cp, " trk %d-%d", atrack+1, atrack+channels);
282                         if( enc[0] ) cp += sprintf(cp," (%s)",enc);
283                 }
284                 cp += sprintf(cp, "\n");
285         }
286
287         for( int n=0; n<elements; ++n ) {
288                 int major, minor;
289                 if( mpeg3_dvb_get_channel(fd,n, &major, &minor) ) continue;
290                 cp += sprintf(cp, "\n**chan %3d.%-3d\n", major, minor);
291                 int len = mpeg3_dvb_get_chan_info(fd, n, -1, 0, cp, 1023);
292                 if( len < 0 ) len = sprintf(cp,_("no info"));
293                 cp += len;  *cp++ = '*';  *cp++ = '*';  *cp++ = '\n';
294                 for( int ord=0; ord<0x80; ++ord ) {
295                         for( int i=0; (len=mpeg3_dvb_get_chan_info(fd,n,ord,i,cp,1023)) >= 0; ++i ) {
296                                 char *bp = cp;  cp += len;
297                                 for( int k=2; --k>=0; ) {  // skip 2 lines
298                                         while( bp<cp && *bp++!='\n' );
299                                 }
300                                 for( char *lp=bp; bp<cp; ++bp ) {  // add new lines
301                                         if( *bp == '\n' || ((bp-lp)>=60 && *bp==' ') )
302                                                 *(lp=bp) = '\n';
303                                 }
304                                 *cp++ = '\n';  *cp = 0;  // trailing new line
305                         }
306                 }
307         }
308
309         mpeg3_close(fd);
310         return;
311 }
312
313 int FileMPEG::get_audio_for_video(int vstream, int astream, int64_t &channel_mask)
314 {
315         channel_mask = 0;
316         if( !fd ) return -1;
317         int elements = mpeg3_dvb_channel_count(fd);
318         if( elements <= 0 ) return -1;
319
320         int pidx = -1;
321         int total_astreams = 0, total_vstreams = 0;
322         for( int n=0; pidx<0 && n<elements; ++n ) {
323                 total_astreams = total_vstreams = 0;
324                 if( mpeg3_dvb_total_vstreams(fd,n,&total_vstreams) ||
325                     mpeg3_dvb_total_astreams(fd,n,&total_astreams) ) continue;
326                 if( !total_vstreams || !total_astreams ) continue;
327                 for( int i=0; pidx<0 && i<total_vstreams; ++i ) {
328                         int vstrm = -1;
329                         if( mpeg3_dvb_vstream_number(fd,n,i,&vstrm) ) continue;
330                         if( vstrm == vstream ) pidx = n;
331                 }
332         }
333         if( pidx < 0 ) return -1;
334         int ret = -1;
335         int64_t channels = 0;
336         for( int i=0; i<total_astreams; ++i ) {
337                 int astrm = -1;
338                 if( mpeg3_dvb_astream_number(fd,pidx,i,&astrm,0) ) continue;
339                 if( astrm < 0 ) continue;
340                 if( ret < 0 ) ret = astrm;
341                 if( astream > 0 ) { --astream;  continue; }
342                 int atrack = 0;
343                 for(int i=0; i<astrm; ++i )
344                         atrack += mpeg3_audio_channels(fd, i);
345                 int64_t mask = (1 << mpeg3_audio_channels(fd, astrm)) - 1;
346                 channels |= mask << atrack;
347                 if( !astream ) break;
348         }
349         channel_mask = channels;
350         return ret;
351 }
352
353 int FileMPEG::reset_parameters_derived()
354 {
355         wrote_header = 0;
356         mjpeg_out = 0;
357         mjpeg_eof = 0;
358         mjpeg_error = 0;
359         recd_fd = -1;
360         fd = 0;
361         video_out = 0;
362         prev_track = 0;
363         temp_frame = 0;
364         twolame_temp = 0;
365         twolame_out = 0;
366         twolame_allocation = 0;
367         twolame_result = 0;
368         twofp = 0;
369         twopts = 0;
370         lame_temp[0] = 0;
371         lame_temp[1] = 0;
372         lame_allocation = 0;
373         lame_global = 0;
374         lame_output = 0;
375         lame_output_allocation = 0;
376         lame_fd = 0;
377         lame_started = 0;
378         return 0;
379 }
380
381
382 int FileMPEG::open_file(int rd, int wr)
383 {
384         int result = 0;
385
386         if(rd) {
387                 char toc_name[BCTEXTLEN];
388                 result = file->preferences->get_asset_file_path(asset, toc_name);
389                 int error = 0;
390                 fd = mpeg3_open_title(asset->path, toc_name, &error);
391                 if( !fd ) {
392                         result = 1;
393                         if(error == zmpeg3_t::ERR_INVALID_TOC_VERSION) {
394                                 eprintf(_("Couldn't open %s: invalid table of contents version.\n"
395                                         "Rebuilding the table of contents."), asset->path);
396                         }
397                         else if(error == zmpeg3_t::ERR_TOC_DATE_MISMATCH) {
398                                 eprintf(_("Couldn't open %s: table of contents out of date.\n"
399                                         "Rebuilding the table of contents."), asset->path);
400                         }
401                         else {
402                                 eprintf(_("Couldn't open %s: table of contents corrupt.\n"
403                                         "Rebuilding the table of contents."), asset->path);
404                         }
405                         char filename[BCTEXTLEN];
406                         strcpy(filename, toc_name);
407                         char *sfx = strrchr(filename,'.');
408                         if( sfx && !strcmp(sfx+1,"toc") ) {
409                                 remove(filename);
410                                 strcpy(sfx+1,"idx");
411                                 remove(filename);
412                                 strcpy(toc_name, asset->path);
413                                 fd = mpeg3_open_title(asset->path, toc_name, &error);
414                                 if( fd ) result = 0;
415                         }
416                         if( result )
417                                 eprintf(_("Couldn't open %s: rebuild failed.\n"), asset->path);
418                 }
419                 if(!result) {
420 // Determine if the file needs a table of contents and create one if needed.
421 // If it has video it must be scanned since video has keyframes.
422                         if(mpeg3_total_vstreams(fd) || mpeg3_total_astreams(fd)) {
423                                 if(create_index()) return 1;
424                         }
425
426 // more than 4 doesnt help much
427                         mpeg3_set_cpus(fd, file->cpus < 4 ? file->cpus : 4);
428                         file->current_program = mpeg3_set_program(fd, -1);
429                         if( asset->program < 0 )
430                                 asset->program = file->current_program;
431
432                         asset->audio_data = mpeg3_has_audio(fd);
433                         if(asset->audio_data) {
434                                 asset->channels = 0;
435                                 for(int i = 0; i < mpeg3_total_astreams(fd); i++) {
436                                         asset->channels += mpeg3_audio_channels(fd, i);
437                                 }
438                                 if(!asset->sample_rate)
439                                         asset->sample_rate = mpeg3_sample_rate(fd, 0);
440                                 asset->audio_length = mpeg3_audio_samples(fd, 0);
441                                 if(!asset->channels || 
442                                         !asset->sample_rate)
443                                         result = 1;
444                         }
445
446                         asset->video_data = mpeg3_has_video(fd);
447                         if(asset->video_data) {
448                                 if( !asset->layers ) {
449                                         asset->layers = mpeg3_total_vstreams(fd);
450                                 }
451                                 asset->actual_width = mpeg3_video_width(fd, 0);
452                                 if( !asset->width )
453                                         asset->width = asset->actual_width;
454                                 asset->actual_height = mpeg3_video_height(fd, 0);
455                                 if( !asset->height )
456                                         asset->height = asset->actual_height;
457                                 if( !asset->video_length )
458                                         asset->video_length = mpeg3_video_frames(fd, 0);
459                                 if( !asset->vmpeg_cmodel )
460                                         asset->vmpeg_cmodel = bc_colormodel(mpeg3_colormodel(fd, 0));
461                                 if( !asset->frame_rate )
462                                         asset->frame_rate = mpeg3_frame_rate(fd, 0);
463                         }
464                 }
465         }
466
467
468         
469         if(!result && wr && asset->format == FILE_VMPEG)
470         {
471 // Heroine Virtual encoder
472 //  this one is cinelerra-x.x.x/mpeg2enc
473                 if(asset->vmpeg_cmodel == BC_YUV422P)
474                 {
475                         char bitrate_string[BCTEXTLEN];
476                         char quant_string[BCTEXTLEN];
477                         char iframe_string[BCTEXTLEN];
478
479                         sprintf(bitrate_string, "%d", asset->vmpeg_bitrate);
480                         sprintf(quant_string, "%d", asset->vmpeg_quantization);
481                         sprintf(iframe_string, "%d", asset->vmpeg_iframe_distance);
482
483 // Construct command line
484                         if(!result)
485                         {
486                                 char string[BCTEXTLEN];  string[0] = 0;
487                                 sprintf(mjpeg_command, "%s%s", 
488                                         file->preferences->plugin_dir, HVPEG_EXE);
489                                 append_vcommand_line(string);
490
491                                 if(asset->aspect_ratio > 0)
492                                 {
493                                         append_vcommand_line("-a");
494 // Square pixels
495                                         if(EQUIV((double)asset->width / asset->height,
496                                                 asset->aspect_ratio))
497                                                 append_vcommand_line("1");
498                                         else
499                                         if(EQUIV(asset->aspect_ratio, 1.333))
500                                                 append_vcommand_line("2");
501                                         else
502                                         if(EQUIV(asset->aspect_ratio, 1.777))
503                                                 append_vcommand_line("3");
504                                         else
505                                         if(EQUIV(asset->aspect_ratio, 2.11))
506                                                 append_vcommand_line("4");
507                                 }
508
509                                 append_vcommand_line(asset->vmpeg_derivative == 1 ? "-1" : "");
510                                 append_vcommand_line(asset->vmpeg_cmodel == BC_YUV422P ? "-422" : "");
511                                 if(asset->vmpeg_fix_bitrate)
512                                 {
513                                         append_vcommand_line("-b");
514                                         append_vcommand_line(bitrate_string);
515                                 }
516                                 else
517                                 {
518                                         append_vcommand_line("-q");
519                                         append_vcommand_line(quant_string);
520                                 }
521                                 append_vcommand_line("-n");
522                                 append_vcommand_line(iframe_string);
523                                 append_vcommand_line(asset->vmpeg_progressive ? "-p" : "");
524                                 append_vcommand_line(asset->vmpeg_denoise ? "-d" : "");
525                                 append_vcommand_line(file->cpus <= 1 ? "-u" : "");
526                                 append_vcommand_line(asset->vmpeg_seq_codes ? "-g" : "");
527                                 append_vcommand_line(asset->path);
528
529                                 video_out = new FileMPEGVideo(this);
530                                 video_out->start();
531                         }
532                 }
533                 else
534 // mjpegtools encoder
535 //  this one is cinelerra-x.x.x/thirdparty/mjpegtools/mpeg2enc
536                 {
537                         sprintf(mjpeg_command, "%s%s -v 0 ", 
538                                 file->preferences->plugin_dir, MJPEG_EXE);
539
540 // Must disable interlacing if MPEG-1
541                         switch (asset->vmpeg_preset)
542                         {
543                                 case 0: asset->vmpeg_progressive = 1; break;
544                                 case 1: asset->vmpeg_progressive = 1; break;
545                                 case 2: asset->vmpeg_progressive = 1; break;
546                         }
547
548
549
550 // The current usage of mpeg2enc requires bitrate of 0 when quantization is fixed and
551 // quantization of 1 when bitrate is fixed.  Perfectly intuitive.
552                         char string[BCTEXTLEN];
553                         if(asset->vmpeg_fix_bitrate)
554                         {
555                                 sprintf(string, " -b %d -q 1", asset->vmpeg_bitrate / 1000);
556                         }
557                         else
558                         {
559                                 sprintf(string, " -b 0 -q %d", asset->vmpeg_quantization);
560                         }
561                         strcat(mjpeg_command, string);
562
563
564
565
566
567
568 // Aspect ratio
569                         int aspect_ratio_code = -1;
570                         if(asset->aspect_ratio > 0)
571                         {
572                                 int ncodes = sizeof(aspect_ratio_codes) / sizeof(double);
573                                 for(int i = 1; i < ncodes; i++)
574                                 {
575                                         if(EQUIV(aspect_ratio_codes[i], asset->aspect_ratio))
576                                         {
577                                                 aspect_ratio_code = i;
578                                                 break;
579                                         }
580                                 }
581                         }
582
583
584 // Square pixels
585                         if(EQUIV((double)asset->width / asset->height, asset->aspect_ratio))
586                                 aspect_ratio_code = 1;
587                         
588                         if(aspect_ratio_code < 0)
589                         {
590                                 eprintf(_("Unsupported aspect ratio %f\n"), asset->aspect_ratio);
591                                 aspect_ratio_code = 2;
592                         }
593                         sprintf(string, " -a %d", aspect_ratio_code);
594                         strcat(mjpeg_command, string);
595
596
597
598
599
600
601 // Frame rate
602                         int frame_rate_code = -1;
603                         int ncodes = sizeof(frame_rate_codes) / sizeof(double);
604                         for(int i = 1; i < ncodes; ++i)
605                         {
606                                 if(EQUIV(asset->frame_rate, frame_rate_codes[i]))
607                                 {
608                                         frame_rate_code = i;
609                                         break;
610                                 }
611                         }
612                         if(frame_rate_code < 0)
613                         {
614                                 frame_rate_code = 4;
615                                 eprintf(_("Unsupported frame rate %f\n"), asset->frame_rate);
616                         }
617                         sprintf(string, " -F %d", frame_rate_code);
618                         strcat(mjpeg_command, string);
619
620
621
622
623
624                         strcat(mjpeg_command, 
625                                 asset->vmpeg_progressive ? " -I 0" : " -I 1");
626                         
627
628
629                         sprintf(string, " -M %d", file->cpus);
630                         strcat(mjpeg_command, string);
631
632
633                         if(!asset->vmpeg_progressive)
634                         {
635                                 strcat(mjpeg_command, asset->vmpeg_field_order ? " -z b" : " -z t");
636                         }
637
638
639                         sprintf(string, " -f %d", asset->vmpeg_preset);
640                         strcat(mjpeg_command, string);
641
642
643                         sprintf(string, " -g %d -G %d", asset->vmpeg_iframe_distance, asset->vmpeg_iframe_distance);
644                         strcat(mjpeg_command, string);
645
646
647                         if(asset->vmpeg_seq_codes) strcat(mjpeg_command, " -s");
648
649
650                         sprintf(string, " -R %d", CLAMP(asset->vmpeg_pframe_distance, 0, 2));
651                         strcat(mjpeg_command, string);
652
653                         sprintf(string, " -o '%s'", asset->path);
654                         strcat(mjpeg_command, string);
655
656
657
658                         printf("FileMPEG::open_file: Running %s\n", mjpeg_command);
659                         if(!(mjpeg_out = popen(mjpeg_command, "w")))
660                         {
661                                 perror("FileMPEG::open_file");
662                                 eprintf(_("Error while opening \"%s\" for writing\n%m\n"), mjpeg_command);
663                                 return 1;
664                         }
665
666                         video_out = new FileMPEGVideo(this);
667                         video_out->start();
668                 }
669         }
670         else
671         if(wr && asset->format == FILE_AMPEG)
672         {
673                 //char encoder_string[BCTEXTLEN]; encoder_string[0] = 0;
674 //printf("FileMPEG::open_file 1 %d\n", asset->ampeg_derivative);
675
676                 if(asset->ampeg_derivative == 2)
677                 {
678                         twofp = fopen(asset->path, "w" );
679                         if( !twofp ) return 1;
680                         twopts = twolame_init();
681                         int channels = asset->channels >= 2 ? 2 : 1;
682                         twolame_set_num_channels(twopts, channels);
683                         twolame_set_in_samplerate(twopts, asset->sample_rate);
684                         twolame_set_mode(twopts, channels >= 2 ?
685                                 TWOLAME_JOINT_STEREO : TWOLAME_MONO);
686                         twolame_set_bitrate(twopts, asset->ampeg_bitrate);
687                         twolame_init_params(twopts);
688                 }
689                 else
690                 if(asset->ampeg_derivative == 3)
691                 {
692                         lame_global = lame_init();
693 //                      lame_set_brate(lame_global, asset->ampeg_bitrate / 1000);
694                         lame_set_brate(lame_global, asset->ampeg_bitrate);
695                         lame_set_quality(lame_global, 0);
696                         lame_set_in_samplerate(lame_global, 
697                                 asset->sample_rate);
698                         lame_set_num_channels(lame_global,
699                                 asset->channels);
700                         if((result = lame_init_params(lame_global)) < 0)
701                         {
702                                 eprintf(_("encode: lame_init_params returned %d\n"), result);
703                                 lame_close(lame_global);
704                                 lame_global = 0;
705                         }
706                         else
707                         if(!(lame_fd = fopen(asset->path, "w")))
708                         {
709                                 perror("FileMPEG::open_file");
710                                 eprintf(_("Error while opening \"%s\" for writing\n%m\n"), asset->path);
711                                 lame_close(lame_global);
712                                 lame_global = 0;
713                                 result = 1;
714                         }
715                 }
716                 else
717                 {
718                         eprintf(_("ampeg_derivative=%d\n"), asset->ampeg_derivative);
719                         result = 1;
720                 }
721         }
722
723 // Transport stream for DVB capture
724         if(!result && !rd && !wr && asset->format == FILE_MPEG)
725         {
726                 if( (recd_fd = open(asset->path, O_CREAT+O_TRUNC+O_WRONLY,
727                         S_IRUSR+S_IWUSR + S_IRGRP+S_IWGRP)) < 0 )
728                 {
729                         perror("FileMPEG::open_file");
730                         eprintf(_("Error while opening \"%s\" for writing\n%m\n"), asset->path);
731                         result = 1;
732                 }
733         }
734
735
736 //asset->dump();
737         return result;
738 }
739
740
741
742
743
744 int FileMPEG::set_skimming(int track, int skim, skim_fn fn, void *vp)
745 {
746         return !fn ? mpeg3_set_thumbnail_callback(fd, track, 0, 0, 0, 0) :
747                 mpeg3_set_thumbnail_callback(fd, track, skim, 1, fn, vp);
748 }
749
750 int FileMPEG::skimming(void *vp, int track)
751 {
752         File *file = (File *)vp;
753         FileMPEG *mpeg = (FileMPEG *)file->file;
754         return mpeg->skim_result = mpeg->skim_callback(mpeg->skim_data, track);
755 }
756
757 int FileMPEG::skim_video(int track, void *vp, skim_fn fn)
758 {
759         skim_callback = fn;  skim_data = vp;
760         mpeg3_set_thumbnail_callback(fd, track, 1, 1, skimming, (void*)file);
761         skim_result = -1;
762         while( skim_result < 0 && !mpeg3_end_of_video(fd, track) )
763                 mpeg3_drop_frames(fd, 1, track);
764         mpeg3_set_thumbnail_callback(fd, track, 0, 0, 0, 0);
765         return skim_result;
766 }
767
768
769
770 int FileMPEG::toc_nail(void *vp, int track)
771 {
772         File *file = (File *)vp;
773         FileMPEG *mpeg = (FileMPEG *)file->file;
774         int64_t framenum; uint8_t *tdat; int mw, mh;
775         if( mpeg->get_thumbnail(track, framenum, tdat, mw, mh) ) return 1;
776         int pid, width, height;  double framerate;
777         if( mpeg->get_video_info(track, pid, framerate, width, height) ) return 1;
778         if( pid < 0 || framerate <= 0 ) return 1;
779         double position = framenum / framerate;
780 //printf("t%d/%03x f"_LD", %dx%d %dx%d\n",track,pid,framenum,mw,mh,width,height);
781         MWindow::commercials->get_frame(file, pid, position, tdat, mw, mh, width, height);
782         return 0;
783 }
784
785
786 int FileMPEG::create_index()
787 {
788 // Calculate TOC path
789         char index_filename[BCTEXTLEN];
790         char source_filename[BCTEXTLEN];
791
792         IndexFile::get_index_filename(source_filename, 
793                 file->preferences->index_directory, 
794                 index_filename, 
795                 asset->path);
796         char *ptr = strrchr(index_filename, '.');
797         int error = 0;
798
799         if(!ptr) return 1;
800
801 // File is a table of contents.
802         if(fd && mpeg3_has_toc(fd)) return 0;
803
804         sprintf(ptr, ".toc");
805
806         int need_toc = 1;
807
808         if(fd) mpeg3_close(fd);
809         fd = 0;
810
811 // Test existing copy of TOC
812         if((fd = mpeg3_open_title(asset->path, index_filename, &error)))
813                 need_toc = 0;
814
815         if(need_toc)
816         {
817                 int result = 0;
818 // Create progress window.
819 // This gets around the fact that MWindowGUI is locked.
820                 int64_t total_bytes = 0, last_bytes = -1;
821                 fd = mpeg3_start_toc( asset->path, index_filename,
822                                 file->current_program, &total_bytes);
823                 if( !fd ) {
824                         eprintf(_("cant init toc index\n"));
825                         result = 1;
826                 }
827
828                 struct timeval new_time, prev_time, start_time, current_time;
829                 gettimeofday(&prev_time, 0);  gettimeofday(&start_time, 0);
830
831                 if( !result && file->preferences->scan_commercials ) {
832                         set_skimming(-1, 1, toc_nail, file);
833                         if( (result=MWindow::commercials->resetDb() ) != 0 )
834                                 eprintf(_("cant access commercials database"));
835                 }
836
837                 char progress_title[BCTEXTLEN];  progress_title[0] = 0;
838                 BC_ProgressBox *progress = 0;
839                 if( !result ) {
840                         sprintf(progress_title, _("Creating %s\n"), index_filename);
841                         progress = new BC_ProgressBox(-1, -1,
842                                         progress_title, total_bytes);
843                         progress->start();
844                 }
845
846                 while( !result ) {
847                         int64_t bytes_processed = 0;
848                         if( mpeg3_do_toc(fd, &bytes_processed) ) break;
849                         gettimeofday(&new_time, 0);
850
851                         if(new_time.tv_sec - prev_time.tv_sec >= 1)
852                         {
853                                 gettimeofday(&current_time, 0);
854                                 int64_t elapsed_seconds = current_time.tv_sec - start_time.tv_sec;
855                                 int64_t total_seconds = !bytes_processed ? 0 :
856                                   elapsed_seconds * total_bytes / bytes_processed;
857                                 int64_t eta = total_seconds - elapsed_seconds;
858                                 progress->update(bytes_processed, 1);
859                                 char string[BCTEXTLEN];
860                                 sprintf(string, "%sETA: " _LD "m" _LD "s",
861                                         progress_title, eta / 60, eta % 60);
862                                 progress->update_title(string, 1);
863 //                              fprintf(stderr, "ETA: %dm%ds        \r", 
864 //                                      bytes_processed * 100 / total_bytes,
865 //                                      eta / 60, eta % 60);
866 //                              fflush(stdout);
867                                 prev_time = new_time;
868                         }
869                         if(bytes_processed >= total_bytes) break;
870                         if(progress->is_cancelled()) result = 1;
871                         if( bytes_processed == last_bytes ) {
872                                 eprintf(_("toc scan stopped before eof"));
873                                 break;
874                         }
875                         last_bytes = bytes_processed;
876                 }
877
878                 // record scan results
879                 if( file->preferences->scan_commercials ) {
880                         if( !result ) MWindow::commercials->write_ads(asset->path);
881                         MWindow::commercials->closeDb();
882                 }
883
884                 if( fd ) { mpeg3_stop_toc(fd);  fd = 0; }
885                 if( progress ) { progress->stop_progress(); delete progress; }
886                 if( result ) { remove_file(index_filename); return 1; }
887         }
888
889
890
891 // Reopen file from index path instead of asset path.
892         if(!fd)
893         {
894                 if(!(fd = mpeg3_open(index_filename, &error)))
895                 {
896                         return 1;
897                 }
898         }
899
900         return 0;
901 }
902
903
904
905
906
907
908 void FileMPEG::append_vcommand_line(const char *string)
909 {
910         if(string[0])
911         {
912                 char *argv = cstrdup(string);
913                 vcommand_line.append(argv);
914         }
915 }
916
917 int FileMPEG::close_file()
918 {
919         mjpeg_eof = 1;
920         next_frame_lock->unlock();
921
922         if(fd)
923         {
924                 mpeg3_close(fd);
925         }
926
927         if(video_out)
928         {
929 // End of sequence signal
930                 if(file->asset->vmpeg_cmodel == BC_YUV422P)
931                 {
932                         mpeg2enc_set_input_buffers(1, 0, 0, 0);
933                 }
934                 delete video_out;
935                 video_out = 0;
936         }
937
938         vcommand_line.remove_all_objects();
939
940         if(twofp) {
941                 unsigned char opkt[1152*2]; 
942                 int ret = twolame_encode_flush(twopts, opkt, sizeof(opkt));
943                 if( ret > 0 )
944                         fwrite(opkt, 1, ret, twofp);
945                 else if( ret < 0 )
946                         fprintf(stderr, _("twolame error encoding audio: %d\n"), ret);
947                 fclose(twofp);  twofp = 0;
948         }
949         if( twopts ) { twolame_close(&twopts); twopts = 0; }
950
951         if(lame_global)
952                 lame_close(lame_global);
953
954         if(temp_frame) delete temp_frame;
955         if(twolame_temp) delete [] twolame_temp;
956
957         if(lame_temp[0]) delete [] lame_temp[0];
958         if(lame_temp[1]) delete [] lame_temp[1];
959         if(lame_output) delete [] lame_output;
960         if(lame_fd) fclose(lame_fd);
961
962         if(mjpeg_out) pclose(mjpeg_out);
963
964         if( recd_fd >= 0 ) {
965                 close(recd_fd);
966                 recd_fd = -1;
967         }
968
969         reset_parameters();
970
971         FileBase::close_file();
972         return 0;
973 }
974
975 int FileMPEG::get_best_colormodel(Asset *asset, int driver)
976 {
977 //printf("FileMPEG::get_best_colormodel 1\n");
978         switch(driver)
979         {
980                 case PLAYBACK_X11:
981                         return BC_RGB888;
982                 case PLAYBACK_X11_XV:
983                 case PLAYBACK_ASYNCHRONOUS:
984                         return zmpeg3_cmdl(asset->vmpeg_cmodel) > 0 ?
985                                 asset->vmpeg_cmodel : BC_RGB888;
986                 case PLAYBACK_X11_GL:
987                         return BC_YUV888;
988                 case PLAYBACK_LML:
989                 case PLAYBACK_BUZ:
990                         return BC_YUV422P;
991                 case PLAYBACK_DV1394:
992                 case PLAYBACK_FIREWIRE:
993                         return BC_YUV422P;
994                 case VIDEO4LINUX:
995                 case VIDEO4LINUX2:
996                         return zmpeg3_cmdl(asset->vmpeg_cmodel) > 0 ?
997                                 asset->vmpeg_cmodel : BC_RGB888;
998                 case VIDEO4LINUX2JPEG:
999                         return BC_COMPRESSED;
1000                 case CAPTURE_DVB:
1001                 case VIDEO4LINUX2MPEG:
1002                         return BC_YUV422P;
1003                 case CAPTURE_JPEG_WEBCAM:
1004                         return BC_COMPRESSED;
1005                 case CAPTURE_YUYV_WEBCAM:
1006                         return BC_YUV422;
1007                 case CAPTURE_BUZ:
1008                 case CAPTURE_LML:
1009                         return BC_YUV422;
1010                 case CAPTURE_FIREWIRE:
1011                 case CAPTURE_IEC61883:
1012                         return BC_YUV422P;
1013         }
1014         eprintf(_("unknown driver %d\n"),driver);
1015         return BC_RGB888;
1016 }
1017
1018 int FileMPEG::colormodel_supported(int colormodel)
1019 {
1020         return colormodel;
1021 }
1022
1023 int FileMPEG::get_index(char *index_path)
1024 {
1025         if(!fd) return 1;
1026
1027
1028 // Convert the index tables from tracks to channels.
1029         if(mpeg3_index_tracks(fd))
1030         {
1031 // Calculate size of buffer needed for all channels
1032                 int buffer_size = 0;
1033                 for(int i = 0; i < mpeg3_index_tracks(fd); i++)
1034                 {
1035                         buffer_size += mpeg3_index_size(fd, i) *
1036                                 mpeg3_index_channels(fd, i) *
1037                                 2;
1038                 }
1039
1040                 IndexState *index_state = asset->index_state;
1041                 index_state->index_buffer = new float[buffer_size];
1042
1043                 int index_channels = 0;
1044                 for(int i = 0; i < mpeg3_index_tracks(fd); i++)
1045                         index_channels += mpeg3_index_channels(fd, i);
1046 // Size of index buffer in floats
1047                 int current_offset = 0;
1048 // Current asset channel
1049                 int current_channel = 0;
1050                 index_state->channels = index_channels;
1051                 index_state->index_zoom = mpeg3_index_zoom(fd);
1052                 index_state->index_offsets = new int64_t[index_channels];
1053                 index_state->index_sizes = new int64_t[index_channels];
1054                 for(int i = 0; i < mpeg3_index_tracks(fd); i++)
1055                 {
1056                         for(int j = 0; j < mpeg3_index_channels(fd, i); j++)
1057                         {
1058                                 index_state->index_offsets[current_channel] = current_offset;
1059                                 index_state->index_sizes[current_channel] = mpeg3_index_size(fd, i) * 2;
1060                                 memcpy(index_state->index_buffer + current_offset,
1061                                         mpeg3_index_data(fd, i, j),
1062                                         mpeg3_index_size(fd, i) * sizeof(float) * 2);
1063
1064                                 current_offset += mpeg3_index_size(fd, i) * 2;
1065                                 current_channel++;
1066                         }
1067                 }
1068
1069                 FileSystem fs;
1070                 index_state->index_bytes = fs.get_size(asset->path);
1071
1072                 index_state->write_index(index_path, 
1073                         buffer_size * sizeof(float),
1074                         asset,
1075                         asset->audio_length);
1076                 delete [] index_state->index_buffer;
1077
1078                 return 0;
1079         }
1080
1081         return 1;
1082 }
1083
1084
1085 int FileMPEG::can_copy_from(Asset *asset, int64_t position)
1086 {
1087         if(!fd) return 0;
1088         return 0;
1089 }
1090
1091 int FileMPEG::set_audio_position(int64_t sample)
1092 {
1093 #if 0
1094         if(!fd) return 1;
1095         
1096         int channel, stream;
1097         to_streamchannel(file->current_channel, stream, channel);
1098
1099 //printf("FileMPEG::set_audio_position %d %d %d\n", sample, mpeg3_get_sample(fd, stream), last_sample);
1100         if(sample != mpeg3_get_sample(fd, stream) &&
1101                 sample != last_sample)
1102         {
1103                 if(sample >= 0 && sample < asset->audio_length)
1104                 {
1105 //printf("FileMPEG::set_audio_position seeking stream %d\n", sample);
1106                         return mpeg3_set_sample(fd, sample, stream);
1107                 }
1108                 else
1109                         return 1;
1110         }
1111 #endif
1112         return 0;
1113 }
1114
1115 int FileMPEG::set_video_position(int64_t pos)
1116 {
1117         if( !fd || pos < 0 || pos >= asset->video_length )
1118                 return 1;
1119 //printf("FileMPEG::set_video_position 1 " _LD "\n", x);
1120         mpeg3_set_frame(fd, pos, file->current_layer);
1121         return 0;
1122 }
1123
1124 int64_t FileMPEG::get_memory_usage()
1125 {
1126         int64_t result = file->rd && fd ? mpeg3_memory_usage(fd) : 0;
1127 //printf("FileMPEG::get_memory_usage %d  " _LD "\n", __LINE__, result);
1128         return result;
1129 }
1130
1131 int FileMPEG::set_program(int no)
1132 {
1133         return fd ? mpeg3_set_program(fd, no) : -1;
1134 }
1135
1136 int FileMPEG::get_cell_time(int no, double &time)
1137 {
1138         return fd ? mpeg3_get_cell_time(fd, no, &time) : -1;
1139 }
1140
1141 int FileMPEG::get_system_time(int64_t &tm)
1142 {
1143         return fd ? mpeg3_dvb_get_system_time(fd, &tm) : -1;
1144 }
1145
1146 int FileMPEG::get_video_pid(int track)
1147 {
1148         return fd ? mpeg3_video_pid(fd, track) : -1;
1149 }
1150
1151 int FileMPEG::get_video_info(int track, int &pid,
1152                 double &framerate, int &width, int &height, char *title)
1153 {
1154         if( !fd ) return -1;
1155         pid = mpeg3_video_pid(fd, track);
1156         framerate = mpeg3_frame_rate(fd, track);
1157         width = mpeg3_video_width(fd, track);
1158         height = mpeg3_video_height(fd, track);
1159         if( !title ) return 0;
1160         *title = 0;
1161
1162         int elements = mpeg3_dvb_channel_count(fd);
1163         for( int n=0; n<elements; ++n ) {
1164                 int major, minor, total_vstreams, vstream, vidx;
1165                 if( mpeg3_dvb_get_channel(fd,n, &major, &minor) ||
1166                     mpeg3_dvb_total_vstreams(fd,n,&total_vstreams) ) continue;
1167                 for( vidx=0; vidx<total_vstreams; ++vidx ) {
1168                         if( mpeg3_dvb_vstream_number(fd,n,vidx,&vstream) ) continue;
1169                         if( vstream < 0 ) continue;
1170                         if( vstream == track ) {
1171                                 sprintf(title, "%3d.%-3d", major, minor);
1172                                 return 0;
1173                         }
1174                 }
1175         }
1176         return 0;
1177 }
1178
1179 int FileMPEG::select_video_stream(Asset *asset, int vstream)
1180 {
1181         if( !fd ) return -1;
1182         asset->width = mpeg3_video_width(fd, vstream);
1183         asset->height = mpeg3_video_height(fd, vstream);
1184         asset->video_length = mpeg3_video_frames(fd, vstream);
1185         asset->frame_rate = mpeg3_frame_rate(fd, vstream);
1186         return 0;
1187 }
1188
1189 int FileMPEG::select_audio_stream(Asset *asset, int astream)
1190 {
1191         if( !fd ) return -1;
1192         asset->channels = mpeg3_audio_channels(fd, astream);
1193         asset->sample_rate = mpeg3_sample_rate(fd, astream);
1194         asset->audio_length = mpeg3_audio_samples(fd, astream);
1195         return 0;
1196 }
1197
1198 int FileMPEG::get_thumbnail(int stream,
1199         int64_t &position, unsigned char *&thumbnail, int &ww, int &hh)
1200 {
1201         return !fd ? -1 :
1202                 mpeg3_get_thumbnail(fd, stream, &position, &thumbnail, &ww, &hh);
1203 }
1204
1205 int FileMPEG::write_samples(double **buffer, int64_t len)
1206 {
1207         int result = 0;
1208
1209 //printf("FileMPEG::write_samples 1\n");
1210         if(asset->ampeg_derivative == 2) {
1211 // Convert to int16
1212                 int channels = MIN(asset->channels, 2);
1213                 int64_t audio_size = len * channels * 2;
1214                 if(twolame_allocation < audio_size) {
1215                         if(twolame_temp) delete [] twolame_temp;
1216                         twolame_temp = new unsigned char[audio_size];
1217                         twolame_allocation = audio_size;
1218                         if(twolame_out) delete [] twolame_out;
1219                         twolame_out = new unsigned char[audio_size + 1152];
1220                 }
1221
1222                 for(int i = 0; i < channels; i++) {
1223                         int16_t *output = ((int16_t*)twolame_temp) + i;
1224                         double *input = buffer[i];
1225                         for(int j = 0; j < len; j++) {
1226                                 int sample = (int)(*input * 0x7fff);
1227                                 *output = (int16_t)(CLIP(sample, -0x8000, 0x7fff));
1228                                 output += channels;
1229                                 input++;
1230                         }
1231                 }
1232                 int ret = twolame_encode_buffer_interleaved(twopts,
1233                                 (int16_t*)twolame_temp, len,
1234                                 twolame_out, twolame_allocation+1152);
1235                 if( ret > 0 )
1236                         fwrite(twolame_out, 1, ret, twofp);
1237                 else if( ret < 0 )
1238                         fprintf(stderr, _("twolame error encoding audio: %d\n"), ret);
1239         }
1240         else
1241         if(asset->ampeg_derivative == 3)
1242         {
1243                 int channels = MIN(asset->channels, 2);
1244                 int64_t audio_size = len * channels;
1245                 if(!lame_global) return 1;
1246                 if(!lame_fd) return 1;
1247                 if(lame_allocation < audio_size)
1248                 {
1249                         if(lame_temp[0]) delete [] lame_temp[0];
1250                         if(lame_temp[1]) delete [] lame_temp[1];
1251                         lame_temp[0] = new float[audio_size];
1252                         lame_temp[1] = new float[audio_size];
1253                         lame_allocation = audio_size;
1254                 }
1255
1256                 if(lame_output_allocation < audio_size * 4)
1257                 {
1258                         if(lame_output) delete [] lame_output;
1259                         lame_output_allocation = audio_size * 4;
1260                         lame_output = new char[lame_output_allocation];
1261                 }
1262
1263                 for(int i = 0; i < channels; i++)
1264                 {
1265                         float *output = lame_temp[i];
1266                         double *input = buffer[i];
1267                         for(int j = 0; j < len; j++)
1268                         {
1269                                 *output++ = *input++ * (float)32768;
1270                         }
1271                 }
1272
1273                 result = lame_encode_buffer_float(lame_global,
1274                         lame_temp[0],
1275                         (channels > 1) ? lame_temp[1] : lame_temp[0],
1276                         len,
1277                         (unsigned char*)lame_output,
1278                         lame_output_allocation);
1279                 if(result > 0)
1280                 {
1281                         char *real_output = lame_output;
1282                         int bytes = result;
1283                         if(!lame_started)
1284                         {
1285                                 for(int i = 0; i < bytes; i++)
1286                                         if(lame_output[i])
1287                                         {
1288                                                 real_output = &lame_output[i];
1289                                                 lame_started = 1;
1290                                                 bytes -= i;
1291                                                 break;
1292                                         }
1293                         }
1294                         if(bytes > 0 && lame_started)
1295                         {
1296                                 result = !fwrite(real_output, 1, bytes, lame_fd);
1297                                 if(result) {
1298                                         perror("FileMPEG::write_samples");
1299                                         eprintf(_("write failed: %m"));
1300                                 }
1301                         }
1302                         else
1303                                 result = 0;
1304                 }
1305                 else
1306                         result = 1;
1307         }
1308
1309         return result;
1310 }
1311
1312 int FileMPEG::write_frames(VFrame ***frames, int len)
1313 {
1314         int result = 0;
1315
1316         if(video_out)
1317         {
1318                 int temp_w = (int)((asset->width + 15) / 16) * 16;
1319                 int temp_h;
1320
1321                 int output_cmodel = asset->vmpeg_cmodel;
1322 // verify colormodel supported in MPEG output
1323                 switch( output_cmodel ) {
1324                 case BC_YUV420P:
1325                 case BC_YUV422P:
1326                         break;
1327                 default:
1328                         return 1;
1329                 }
1330                 
1331 // Height depends on progressiveness
1332                 if(asset->vmpeg_progressive || asset->vmpeg_derivative == 1)
1333                         temp_h = (int)((asset->height + 15) / 16) * 16;
1334                 else
1335                         temp_h = (int)((asset->height + 31) / 32) * 32;
1336
1337 //printf("FileMPEG::write_frames 1\n");
1338                 
1339 // Only 1 layer is supported in MPEG output
1340                 for(int i = 0; i < 1; i++)
1341                 {
1342                         for(int j = 0; j < len && !result; j++)
1343                         {
1344                                 VFrame *frame = frames[i][j];
1345                                 
1346                                 
1347                                 
1348                                 if(asset->vmpeg_cmodel == BC_YUV422P)
1349                                 {
1350                                         if(frame->get_w() == temp_w &&
1351                                                 frame->get_h() == temp_h &&
1352                                                 frame->get_color_model() == output_cmodel)
1353                                         {
1354                                                 mpeg2enc_set_input_buffers(0, 
1355                                                         (char*)frame->get_y(),
1356                                                         (char*)frame->get_u(),
1357                                                         (char*)frame->get_v());
1358                                         }
1359                                         else
1360                                         {
1361                                                 if(temp_frame &&
1362                                                         (temp_frame->get_w() != temp_w ||
1363                                                         temp_frame->get_h() != temp_h ||
1364                                                         temp_frame->get_color_model() || output_cmodel))
1365                                                 {
1366                                                         delete temp_frame;
1367                                                         temp_frame = 0;
1368                                                 }
1369
1370
1371                                                 if(!temp_frame)
1372                                                 {
1373                                                         temp_frame = new VFrame(0, 
1374                                                                 -1,
1375                                                                 temp_w, 
1376                                                                 temp_h, 
1377                                                                 output_cmodel,
1378                                                                 -1);
1379                                                 }
1380
1381                                                 BC_CModels::transfer(temp_frame->get_rows(), 
1382                                                         frame->get_rows(),
1383                                                         temp_frame->get_y(),
1384                                                         temp_frame->get_u(),
1385                                                         temp_frame->get_v(),
1386                                                         frame->get_y(),
1387                                                         frame->get_u(),
1388                                                         frame->get_v(),
1389                                                         0,
1390                                                         0,
1391                                                         frame->get_w(),
1392                                                         frame->get_h(),
1393                                                         0,
1394                                                         0,
1395                                                         temp_frame->get_w(),
1396                                                         temp_frame->get_h(),
1397                                                         frame->get_color_model(), 
1398                                                         temp_frame->get_color_model(),
1399                                                         0, 
1400                                                         frame->get_w(),
1401                                                         temp_frame->get_w());
1402
1403                                                 mpeg2enc_set_input_buffers(0, 
1404                                                         (char*)temp_frame->get_y(),
1405                                                         (char*)temp_frame->get_u(),
1406                                                         (char*)temp_frame->get_v());
1407                                         }
1408                                 }
1409                                 else
1410                                 {
1411 // MJPEG uses the same dimensions as the input
1412 //printf("FileMPEG::write_frames %d\n", __LINE__);sleep(1);
1413                                         if(frame->get_color_model() == output_cmodel)
1414                                         {
1415                                                 mjpeg_y = frame->get_y();
1416                                                 mjpeg_u = frame->get_u();
1417                                                 mjpeg_v = frame->get_v();
1418                                         }
1419                                         else
1420                                         {
1421 //printf("FileMPEG::write_frames %d\n", __LINE__);sleep(1);
1422                                                 if(!temp_frame)
1423                                                 {
1424                                                         temp_frame = new VFrame(0, 
1425                                                                 -1,
1426                                                                 asset->width, 
1427                                                                 asset->height, 
1428                                                                 output_cmodel,
1429                                                                 -1);
1430                                                 }
1431
1432 // printf("FileMPEG::write_frames %d temp_frame=%p %p %p %p frame=%p %p %p %p color_model=%p %p\n", 
1433 // __LINE__,
1434 // temp_frame,
1435 // temp_frame->get_w(),
1436 // temp_frame->get_h(),
1437 // frame,
1438 // frame->get_w(),
1439 // frame->get_h(),
1440 // temp_frame->get_color_model(),
1441 // frame->get_color_model()); sleep(1);
1442                                                 BC_CModels::transfer(temp_frame->get_rows(), 
1443                                                         frame->get_rows(),
1444                                                         temp_frame->get_y(),
1445                                                         temp_frame->get_u(),
1446                                                         temp_frame->get_v(),
1447                                                         frame->get_y(),
1448                                                         frame->get_u(),
1449                                                         frame->get_v(),
1450                                                         0,
1451                                                         0,
1452                                                         frame->get_w(),
1453                                                         frame->get_h(),
1454                                                         0,
1455                                                         0,
1456                                                         temp_frame->get_w(),
1457                                                         temp_frame->get_h(),
1458                                                         frame->get_color_model(), 
1459                                                         temp_frame->get_color_model(),
1460                                                         0, 
1461                                                         frame->get_w(),
1462                                                         temp_frame->get_w());
1463 //printf("FileMPEG::write_frames %d\n", __LINE__);sleep(1);
1464
1465                                                 mjpeg_y = temp_frame->get_y();
1466                                                 mjpeg_u = temp_frame->get_u();
1467                                                 mjpeg_v = temp_frame->get_v();
1468                                         }
1469
1470
1471
1472
1473                                         next_frame_lock->unlock();
1474                                         next_frame_done->lock("FileMPEG::write_frames");
1475                                         if(mjpeg_error) result = 1;
1476                                 }
1477
1478
1479
1480
1481
1482                         }
1483                 }
1484         }
1485
1486
1487
1488         return result;
1489 }
1490
1491 int FileMPEG::zmpeg3_cmdl(int colormodel)
1492 {   
1493         switch( colormodel ) {
1494         case BC_BGR888:       return zmpeg3_t::cmdl_BGR888;
1495         case BC_BGR8888:      return zmpeg3_t::cmdl_BGRA8888;
1496         case BC_RGB565:       return zmpeg3_t::cmdl_RGB565;
1497         case BC_RGB888:       return zmpeg3_t::cmdl_RGB888;
1498         case BC_RGBA8888:     return zmpeg3_t::cmdl_RGBA8888;
1499         case BC_RGBA16161616: return zmpeg3_t::cmdl_RGBA16161616;
1500         case BC_YUV420P:      return zmpeg3_t::cmdl_YUV420P;
1501         case BC_YUV422P:      return zmpeg3_t::cmdl_YUV422P;
1502         case BC_YUV422:       return zmpeg3_t::cmdl_YUYV;
1503         case BC_YUV888:       return zmpeg3_t::cmdl_YUV888;
1504         case BC_YUVA8888:     return zmpeg3_t::cmdl_YUVA8888;
1505         }
1506         return -1;
1507 }   
1508
1509 int FileMPEG::bc_colormodel(int cmdl)
1510 {
1511         switch( cmdl ) {
1512         case zmpeg3_t::cmdl_BGR888:       return BC_BGR888;
1513         case zmpeg3_t::cmdl_BGRA8888:     return BC_BGR8888;
1514         case zmpeg3_t::cmdl_RGB565:       return BC_RGB565;
1515         case zmpeg3_t::cmdl_RGB888:       return BC_RGB888;
1516         case zmpeg3_t::cmdl_RGBA8888:     return BC_RGBA8888;
1517         case zmpeg3_t::cmdl_RGBA16161616: return BC_RGBA16161616;
1518         case zmpeg3_t::cmdl_YUV420P:      return BC_YUV420P;
1519         case zmpeg3_t::cmdl_YUV422P:      return BC_YUV422P;
1520         case zmpeg3_t::cmdl_YUYV:         return BC_YUV422;
1521         case zmpeg3_t::cmdl_YUV888:       return BC_YUV888;
1522         case zmpeg3_t::cmdl_YUVA8888:     return BC_YUVA8888;
1523         }
1524         return -1;
1525 }
1526
1527 const char *FileMPEG::zmpeg3_cmdl_name(int cmdl)
1528 {
1529 # define CMDL(nm) #nm
1530   static const char *cmdl_name[] = {
1531     CMDL(BGR888),
1532     CMDL(BGRA8888),
1533     CMDL(RGB565),
1534     CMDL(RGB888),
1535     CMDL(RGBA8888),
1536     CMDL(RGBA16161616),
1537     CMDL(UNKNOWN),
1538     CMDL(601_BGR888),
1539     CMDL(601_BGRA8888),
1540     CMDL(601_RGB888),
1541     CMDL(601_RGBA8888),
1542     CMDL(601_RGB565),
1543     CMDL(YUV420P),
1544     CMDL(YUV422P),
1545     CMDL(601_YUV420P),
1546     CMDL(601_YUV422P),
1547     CMDL(UYVY),
1548     CMDL(YUYV),
1549     CMDL(601_UYVY),
1550     CMDL(601_YUYV),
1551     CMDL(YUV888),
1552     CMDL(YUVA8888),
1553     CMDL(601_YUV888),
1554     CMDL(601_YUVA8888),
1555   };
1556   return cmdl>=0 && cmdl<lengthof(cmdl_name) ? cmdl_name[cmdl] : cmdl_name[6];
1557 }
1558
1559
1560 int FileMPEG::read_frame(VFrame *frame)
1561 {
1562         if(!fd) return 1;
1563         int result = 0;
1564         int width = mpeg3_video_width(fd,file->current_layer);
1565         int height = mpeg3_video_height(fd,file->current_layer);
1566         int stream_cmdl = mpeg3_colormodel(fd,file->current_layer);
1567         int stream_color_model = bc_colormodel(stream_cmdl);
1568         int frame_color_model = frame->get_color_model();
1569         int frame_cmdl = zmpeg3_cmdl(frame_color_model);
1570         mpeg3_show_subtitle(fd, file->current_layer, file->playback_subtitle);
1571
1572
1573         switch( frame_color_model ) { // check for direct copy
1574         case BC_YUV420P:
1575         case BC_YUV422P:
1576                 if( stream_color_model == frame_color_model &&
1577                         width == frame->get_w() && height == frame->get_h() ) {
1578                         mpeg3_read_yuvframe(fd,
1579                                 (char*)frame->get_y(),
1580                                 (char*)frame->get_u(),
1581                                 (char*)frame->get_v(),
1582                                 0, 0, width, height,
1583                                 file->current_layer);
1584                         return result;
1585                 }
1586         }
1587
1588         if( frame_cmdl >= 0 ) {        // supported by read_frame
1589                 // cant rely on frame->get_rows(), format may not support it
1590                 int uvs = 0;
1591                 switch( frame_color_model ) {
1592                 case BC_YUV420P: uvs = 2;  break;
1593                 case BC_YUV422P: uvs = 1;  break;
1594                 }
1595                 //int w = frame->get_w();
1596                 int h = frame->get_h();
1597                 int bpl = frame->get_bytes_per_line();
1598                 int uvw = !uvs ? 0 : bpl / 2;
1599                 int uvh = !uvs ? 0 : h / uvs;
1600                 uint8_t *rows[h + 2*uvh], *rp;
1601                 int n = 0;
1602                 if( (rp=frame->get_y()) ) {
1603                         for( int i=0; i<h; ++i, rp+=bpl ) rows[n++] = rp;
1604                         rp = frame->get_u();
1605                         for( int i=0; i<uvh; ++i, rp+=uvw ) rows[n++] = rp;
1606                         rp = frame->get_v();
1607                         for( int i=0; i<uvh; ++i, rp+=uvw ) rows[n++] = rp;
1608                 }
1609                 else {
1610                         rp = frame->get_data();  uvh *= 2;
1611                         for( int i=0; i<h; ++i, rp+=bpl ) rows[n++] = rp;
1612                         for( int i=0; i<uvh; ++i, rp+=uvw ) rows[n++] = rp;
1613                 }
1614
1615                 mpeg3_read_frame(fd, 
1616                                 rows,                /* start of each output row */
1617                                 0, 0, width, height, /* input box */
1618                                 frame->get_w(),      /* Dimensions of output_rows */
1619                                 frame->get_h(), 
1620                                 frame_cmdl,
1621                                 file->current_layer);
1622                 return result;
1623         }
1624
1625         char *y, *u, *v;
1626         mpeg3_read_yuvframe_ptr(fd, &y, &u, &v, file->current_layer);
1627         if( y && u && v ) {
1628                 BC_CModels::transfer(frame->get_rows(), 0,
1629                         frame->get_y(),
1630                         frame->get_u(),
1631                         frame->get_v(),
1632                         (unsigned char*)y,
1633                         (unsigned char*)u,
1634                         (unsigned char*)v,
1635                         0, 0, width, height,
1636                         0, 0, frame->get_w(), frame->get_h(),
1637                         stream_color_model, 
1638                         frame_color_model,
1639                         0, 
1640                         width,
1641                         frame->get_w());
1642         }
1643
1644         return result;
1645 }
1646
1647
1648 void FileMPEG::to_streamchannel(int channel, int &stream_out, int &channel_out)
1649 {
1650         int total_astreams = mpeg3_total_astreams(fd);
1651         for(stream_out = 0; stream_out < total_astreams; ++stream_out )
1652         {
1653                 int stream_channels = mpeg3_audio_channels(fd, stream_out);
1654                 if( channel < stream_channels ) break;
1655                 channel -= stream_channels;
1656         }
1657         channel_out = channel;
1658 }
1659
1660 int FileMPEG::read_samples(double *buffer, int64_t len)
1661 {
1662         if(!fd) return 0;
1663         if(len < 0) return 0;
1664
1665 // Translate pure channel to a stream and a channel in the mpeg stream
1666         int stream, channel;
1667         to_streamchannel(file->current_channel, stream, channel);
1668
1669 //printf("FileMPEG::read_samples 1 current_sample=" _LD " len=" _LD " channel=%d\n", file->current_sample, len, channel);
1670
1671         mpeg3_set_sample(fd, 
1672                 file->current_sample,
1673                 stream);
1674         mpeg3_read_audio_d(fd, 
1675                 buffer, /* Pointer to pre-allocated buffer of doubles */
1676                 channel,          /* Channel to decode */
1677                 len,         /* Number of samples to decode */
1678                 stream);          /* Stream containing the channel */
1679
1680 //      last_sample = file->current_sample;
1681         return 0;
1682 }
1683
1684
1685
1686
1687
1688
1689 FileMPEGVideo::FileMPEGVideo(FileMPEG *file)
1690  : Thread(1, 0, 0)
1691 {
1692         this->file = file;
1693         
1694         
1695         if(file->asset->vmpeg_cmodel == BC_YUV422P)
1696         {
1697                 mpeg2enc_init_buffers();
1698                 mpeg2enc_set_w(file->asset->width);
1699                 mpeg2enc_set_h(file->asset->height);
1700                 mpeg2enc_set_rate(file->asset->frame_rate);
1701         }
1702 }
1703
1704 FileMPEGVideo::~FileMPEGVideo()
1705 {
1706         Thread::join();
1707 }
1708
1709 void FileMPEGVideo::run()
1710 {
1711         if(file->asset->vmpeg_cmodel == BC_YUV422P)
1712         {
1713                 printf("FileMPEGVideo::run ");
1714                 for(int i = 0; i < file->vcommand_line.total; i++)
1715                 printf("%s ", file->vcommand_line.values[i]);
1716                 printf("\n");
1717                 mpeg2enc(file->vcommand_line.total, file->vcommand_line.values);
1718         }
1719         else
1720         {
1721                 while(1)
1722                 {
1723 //printf("FileMPEGVideo::run %d\n", __LINE__);
1724                         file->next_frame_lock->lock("FileMPEGVideo::run");
1725 //printf("FileMPEGVideo::run %d\n", __LINE__);
1726                         if(file->mjpeg_eof) 
1727                         {
1728                                 file->next_frame_done->unlock();
1729                                 break;
1730                         }
1731
1732
1733
1734 //printf("FileMPEGVideo::run %d\n", __LINE__);
1735 // YUV4 sequence header
1736                         if(!file->wrote_header)
1737                         {
1738                                 file->wrote_header = 1;
1739
1740                                 char interlace_string[BCTEXTLEN];
1741                                 if(!file->asset->vmpeg_progressive)
1742                                 {
1743                                         sprintf(interlace_string, file->asset->vmpeg_field_order ? "b" : "t");
1744                                 }
1745                                 else
1746                                 {
1747                                         sprintf(interlace_string, "p");
1748                                 }
1749                                 double aspect_ratio = file->asset->aspect_ratio >= 0 ?
1750                                         file->asset->aspect_ratio : 1.0;
1751 //printf("FileMPEGVideo::run %d\n", __LINE__);
1752                                 fprintf(file->mjpeg_out, "YUV4MPEG2 W%d H%d F%d:%d I%s A%d:%d C%s\n",
1753                                         file->asset->width, file->asset->height,
1754                                         (int)(file->asset->frame_rate * 1001),
1755                                         1001, interlace_string,
1756                                         (int)(aspect_ratio * 1000), 1000,
1757                                         "420mpeg2");
1758 //printf("FileMPEGVideo::run %d\n", __LINE__);
1759                         }
1760
1761 // YUV4 frame header
1762 //printf("FileMPEGVideo::run %d\n", __LINE__);
1763                         fprintf(file->mjpeg_out, "FRAME\n");
1764
1765 // YUV data
1766 //printf("FileMPEGVideo::run %d\n", __LINE__);
1767                         if(!fwrite(file->mjpeg_y, file->asset->width * file->asset->height, 1, file->mjpeg_out))
1768                                 file->mjpeg_error = 1;
1769 //printf("FileMPEGVideo::run %d\n", __LINE__);
1770                         if(!fwrite(file->mjpeg_u, file->asset->width * file->asset->height / 4, 1, file->mjpeg_out))
1771                                 file->mjpeg_error = 1;
1772 //printf("FileMPEGVideo::run %d\n", __LINE__);
1773                         if(!fwrite(file->mjpeg_v, file->asset->width * file->asset->height / 4, 1, file->mjpeg_out))
1774                                 file->mjpeg_error = 1;
1775 //printf("FileMPEGVideo::run %d\n", __LINE__);
1776                         fflush(file->mjpeg_out);
1777
1778 //printf("FileMPEGVideo::run %d\n", __LINE__);
1779                         file->next_frame_done->unlock();
1780 //printf("FileMPEGVideo::run %d\n", __LINE__);
1781                 }
1782                 pclose(file->mjpeg_out);
1783                 file->mjpeg_out = 0;
1784         }
1785 }
1786
1787
1788
1789
1790
1791
1792
1793
1794
1795
1796
1797
1798 MPEGConfigAudio::MPEGConfigAudio(BC_WindowBase *parent_window, Asset *asset)
1799  : BC_Window(_(PROGRAM_NAME ": Audio Compression"),
1800         parent_window->get_abs_cursor_x(1),
1801         parent_window->get_abs_cursor_y(1),
1802         310,
1803         120,
1804         -1,
1805         -1,
1806         0,
1807         0,
1808         1)
1809 {
1810         this->parent_window = parent_window;
1811         this->asset = asset;
1812 }
1813
1814 MPEGConfigAudio::~MPEGConfigAudio()
1815 {
1816 }
1817
1818 void MPEGConfigAudio::create_objects()
1819 {
1820         int x = 10, y = 10;
1821         int x1 = 150;
1822         MPEGLayer *layer;
1823
1824         lock_window("MPEGConfigAudio::create_objects");
1825         if(asset->format == FILE_MPEG)
1826         {
1827                 add_subwindow(new BC_Title(x, y, _("No options for MPEG transport stream.")));
1828                 unlock_window();
1829                 return;
1830         }
1831
1832
1833         add_tool(new BC_Title(x, y, _("Layer:")));
1834         add_tool(layer = new MPEGLayer(x1, y, this));
1835         layer->create_objects();
1836
1837         y += 30;
1838         add_tool(new BC_Title(x, y, _("Kbits per second:")));
1839         add_tool(bitrate = new MPEGABitrate(x1, y, this));
1840         bitrate->create_objects();
1841         
1842         
1843         add_subwindow(new BC_OKButton(this));
1844         show_window(1);
1845         unlock_window();
1846 }
1847
1848 int MPEGConfigAudio::close_event()
1849 {
1850         set_done(0);
1851         return 1;
1852 }
1853
1854
1855
1856
1857
1858
1859
1860 MPEGLayer::MPEGLayer(int x, int y, MPEGConfigAudio *gui)
1861  : BC_PopupMenu(x, y, 100, layer_to_string(gui->asset->ampeg_derivative))
1862 {
1863         this->gui = gui;
1864 }
1865
1866 void MPEGLayer::create_objects()
1867 {
1868         add_item(new BC_MenuItem(layer_to_string(2)));
1869         add_item(new BC_MenuItem(layer_to_string(3)));
1870 }
1871
1872 int MPEGLayer::handle_event()
1873 {
1874         gui->asset->ampeg_derivative = string_to_layer(get_text());
1875         gui->bitrate->set_layer(gui->asset->ampeg_derivative);
1876         return 1;
1877 };
1878
1879 int MPEGLayer::string_to_layer(char *string)
1880 {
1881         if(!strcasecmp(layer_to_string(2), string))
1882                 return 2;
1883         if(!strcasecmp(layer_to_string(3), string))
1884                 return 3;
1885
1886         return 2;
1887 }
1888
1889 char* MPEGLayer::layer_to_string(int layer)
1890 {
1891         switch(layer)
1892         {
1893                 case 2:
1894                         return _("II");
1895                         break;
1896                 
1897                 case 3:
1898                         return _("III");
1899                         break;
1900                         
1901                 default:
1902                         return _("II");
1903                         break;
1904         }
1905 }
1906
1907
1908
1909
1910
1911
1912
1913 MPEGABitrate::MPEGABitrate(int x, int y, MPEGConfigAudio *gui)
1914  : BC_PopupMenu(x, 
1915         y, 
1916         100, 
1917         bitrate_to_string(gui->string, gui->asset->ampeg_bitrate))
1918 {
1919         this->gui = gui;
1920 }
1921
1922 void MPEGABitrate::create_objects()
1923 {
1924         set_layer(gui->asset->ampeg_derivative);
1925 }
1926
1927 void MPEGABitrate::set_layer(int layer)
1928 {
1929         while(total_items())
1930         {
1931                 remove_item(0);
1932         }
1933
1934         if(layer == 2)
1935         {
1936                 add_item(new BC_MenuItem("160"));
1937                 add_item(new BC_MenuItem("192"));
1938                 add_item(new BC_MenuItem("224"));
1939                 add_item(new BC_MenuItem("256"));
1940                 add_item(new BC_MenuItem("320"));
1941                 add_item(new BC_MenuItem("384"));
1942         }
1943         else
1944         {
1945                 add_item(new BC_MenuItem("8"));
1946                 add_item(new BC_MenuItem("16"));
1947                 add_item(new BC_MenuItem("24"));
1948                 add_item(new BC_MenuItem("32"));
1949                 add_item(new BC_MenuItem("40"));
1950                 add_item(new BC_MenuItem("48"));
1951                 add_item(new BC_MenuItem("56"));
1952                 add_item(new BC_MenuItem("64"));
1953                 add_item(new BC_MenuItem("80"));
1954                 add_item(new BC_MenuItem("96"));
1955                 add_item(new BC_MenuItem("112"));
1956                 add_item(new BC_MenuItem("128"));
1957                 add_item(new BC_MenuItem("144"));
1958                 add_item(new BC_MenuItem("160"));
1959                 add_item(new BC_MenuItem("192"));
1960                 add_item(new BC_MenuItem("224"));
1961                 add_item(new BC_MenuItem("256"));
1962                 add_item(new BC_MenuItem("320"));
1963         }
1964 }
1965
1966 int MPEGABitrate::handle_event()
1967 {
1968         gui->asset->ampeg_bitrate = string_to_bitrate(get_text());
1969         return 1;
1970 };
1971
1972 int MPEGABitrate::string_to_bitrate(char *string)
1973 {
1974         return atol(string);
1975 }
1976
1977
1978 char* MPEGABitrate::bitrate_to_string(char *string, int bitrate)
1979 {
1980         sprintf(string, "%d", bitrate);
1981         return string;
1982 }
1983
1984
1985
1986
1987
1988
1989
1990
1991
1992 MPEGConfigVideo::MPEGConfigVideo(BC_WindowBase *parent_window, 
1993         Asset *asset)
1994  : BC_Window(_(PROGRAM_NAME ": Video Compression"),
1995         parent_window->get_abs_cursor_x(1),
1996         parent_window->get_abs_cursor_y(1),
1997         500,
1998         400,
1999         -1,
2000         -1,
2001         0,
2002         0,
2003         1)
2004 {
2005         this->parent_window = parent_window;
2006         this->asset = asset;
2007         reset_cmodel();
2008 }
2009
2010 MPEGConfigVideo::~MPEGConfigVideo()
2011 {
2012 }
2013
2014 void MPEGConfigVideo::create_objects()
2015 {
2016         int x = 10, y = 10;
2017         int x1 = x + 150;
2018         //int x2 = x + 300;
2019
2020         lock_window("MPEGConfigVideo::create_objects");
2021         if(asset->format == FILE_MPEG)
2022         {
2023                 add_subwindow(new BC_Title(x, y, _("No options for MPEG transport stream.")));
2024                 unlock_window();
2025                 return;
2026         }
2027
2028         add_subwindow(new BC_Title(x, y, _("Color model:")));
2029         add_subwindow(cmodel = new MPEGColorModel(x1, y, this));
2030         cmodel->create_objects();
2031         y += 30;
2032
2033         update_cmodel_objs();
2034
2035         add_subwindow(new BC_OKButton(this));
2036         show_window(1);
2037         unlock_window();
2038 }
2039
2040 int MPEGConfigVideo::close_event()
2041 {
2042         set_done(0);
2043         return 1;
2044 }
2045
2046
2047 void MPEGConfigVideo::delete_cmodel_objs()
2048 {
2049         delete preset;
2050         delete derivative;
2051         delete bitrate;
2052         delete fixed_bitrate;
2053         delete quant;
2054         delete fixed_quant;
2055         delete iframe_distance;
2056         delete pframe_distance;
2057         delete top_field_first;
2058         delete progressive;
2059         delete denoise;
2060         delete seq_codes;
2061         titles.remove_all_objects();
2062         reset_cmodel();
2063 }
2064
2065 void MPEGConfigVideo::reset_cmodel()
2066 {
2067         preset = 0;
2068         derivative = 0;
2069         bitrate = 0;
2070         fixed_bitrate = 0;
2071         quant = 0;
2072         fixed_quant = 0;
2073         iframe_distance = 0;
2074         pframe_distance = 0;
2075         top_field_first = 0;
2076         progressive = 0;
2077         denoise = 0;
2078         seq_codes = 0;
2079 }
2080
2081 void MPEGConfigVideo::update_cmodel_objs()
2082 {
2083         BC_Title *title;
2084         int x = 10;
2085         int y = 40;
2086         int x1 = x + 150;
2087         int x2 = x + 280;
2088
2089         delete_cmodel_objs();
2090
2091         if(asset->vmpeg_cmodel == BC_YUV420P)
2092         {
2093                 add_subwindow(title = new BC_Title(x, y + 5, _("Format Preset:")));
2094                 titles.append(title);
2095                 add_subwindow(preset = new MPEGPreset(x1, y, this));
2096                 preset->create_objects();
2097                 y += 30;
2098         }
2099
2100         add_subwindow(title = new BC_Title(x, y + 5, _("Derivative:")));
2101         titles.append(title);
2102         add_subwindow(derivative = new MPEGDerivative(x1, y, this));
2103         derivative->create_objects();
2104         y += 30;
2105
2106         add_subwindow(title = new BC_Title(x, y + 5, _("Bitrate:")));
2107         titles.append(title);
2108         add_subwindow(bitrate = new MPEGBitrate(x1, y, this));
2109         add_subwindow(fixed_bitrate = new MPEGFixedBitrate(x2, y, this));
2110         y += 30;
2111
2112         add_subwindow(title = new BC_Title(x, y, _("Quantization:")));
2113         titles.append(title);
2114         quant = new MPEGQuant(x1, y, this);
2115         quant->create_objects();
2116         add_subwindow(fixed_quant = new MPEGFixedQuant(x2, y, this));
2117         y += 30;
2118
2119         add_subwindow(title = new BC_Title(x, y, _("I frame distance:")));
2120         titles.append(title);
2121         iframe_distance = new MPEGIFrameDistance(x1, y, this);
2122         iframe_distance->create_objects();
2123         y += 30;
2124
2125         if(asset->vmpeg_cmodel == BC_YUV420P)
2126         {
2127                 add_subwindow(title = new BC_Title(x, y, _("P frame distance:")));
2128                 titles.append(title);
2129                 pframe_distance = new MPEGPFrameDistance(x1, y, this);
2130                 pframe_distance->create_objects();
2131                 y += 30;
2132
2133                 add_subwindow(top_field_first = new BC_CheckBox(x, y, &asset->vmpeg_field_order, _("Bottom field first")));
2134                 y += 30;
2135         }
2136
2137         add_subwindow(progressive = new BC_CheckBox(x, y, &asset->vmpeg_progressive, _("Progressive frames")));
2138         y += 30;
2139         add_subwindow(denoise = new BC_CheckBox(x, y, &asset->vmpeg_denoise, _("Denoise")));
2140         y += 30;
2141         add_subwindow(seq_codes = new BC_CheckBox(x, y, &asset->vmpeg_seq_codes, _("Sequence start codes in every GOP")));
2142
2143 }
2144
2145
2146
2147
2148
2149
2150
2151
2152
2153
2154
2155
2156
2157 MPEGDerivative::MPEGDerivative(int x, int y, MPEGConfigVideo *gui)
2158  : BC_PopupMenu(x, y, 150, derivative_to_string(gui->asset->vmpeg_derivative))
2159 {
2160         this->gui = gui;
2161 }
2162
2163 void MPEGDerivative::create_objects()
2164 {
2165         add_item(new BC_MenuItem(derivative_to_string(1)));
2166         add_item(new BC_MenuItem(derivative_to_string(2)));
2167 }
2168
2169 int MPEGDerivative::handle_event()
2170 {
2171         gui->asset->vmpeg_derivative = string_to_derivative(get_text());
2172         return 1;
2173 };
2174
2175 int MPEGDerivative::string_to_derivative(char *string)
2176 {
2177         if(!strcasecmp(derivative_to_string(1), string))
2178                 return 1;
2179         if(!strcasecmp(derivative_to_string(2), string))
2180                 return 2;
2181
2182         return 1;
2183 }
2184
2185 char* MPEGDerivative::derivative_to_string(int derivative)
2186 {
2187         switch(derivative)
2188         {
2189                 case 1:
2190                         return _("MPEG-1");
2191                         break;
2192                 
2193                 case 2:
2194                         return _("MPEG-2");
2195                         break;
2196                         
2197                 default:
2198                         return _("MPEG-1");
2199                         break;
2200         }
2201 }
2202
2203
2204
2205
2206
2207
2208
2209
2210
2211
2212
2213 MPEGPreset::MPEGPreset(int x, int y, MPEGConfigVideo *gui)
2214  : BC_PopupMenu(x, y, 200, value_to_string(gui->asset->vmpeg_preset))
2215 {
2216         this->gui = gui;
2217 }
2218
2219 void MPEGPreset::create_objects()
2220 {
2221         for(int i = 0; i < 10; i++)
2222         {
2223                 add_item(new BC_MenuItem(value_to_string(i)));
2224         }
2225 }
2226
2227 int MPEGPreset::handle_event()
2228 {
2229         gui->asset->vmpeg_preset = string_to_value(get_text());
2230         return 1;
2231 }
2232
2233 int MPEGPreset::string_to_value(char *string)
2234 {
2235         for(int i = 0; i < 10; i++)
2236         {
2237                 if(!strcasecmp(value_to_string(i), string))
2238                         return i;
2239         }
2240         return 0;
2241 }
2242
2243 char* MPEGPreset::value_to_string(int derivative)
2244 {
2245         switch(derivative)
2246         {
2247                 case 0: return _("Generic MPEG-1"); break;
2248                 case 1: return _("standard VCD"); break;
2249                 case 2: return _("user VCD"); break;
2250                 case 3: return _("Generic MPEG-2"); break;
2251                 case 4: return _("standard SVCD"); break;
2252                 case 5: return _("user SVCD"); break;
2253                 case 6: return _("VCD Still sequence"); break;
2254                 case 7: return _("SVCD Still sequence"); break;
2255                 case 8: return _("DVD NAV"); break;
2256                 case 9: return _("DVD"); break;
2257                 default: return _("Generic MPEG-1"); break;
2258         }
2259 }
2260
2261
2262
2263
2264
2265
2266
2267
2268
2269
2270
2271 MPEGBitrate::MPEGBitrate(int x, int y, MPEGConfigVideo *gui)
2272  : BC_TextBox(x, y, 100, 1, gui->asset->vmpeg_bitrate)
2273 {
2274         this->gui = gui;
2275 }
2276
2277
2278 int MPEGBitrate::handle_event()
2279 {
2280         gui->asset->vmpeg_bitrate = atol(get_text());
2281         return 1;
2282 };
2283
2284
2285
2286
2287
2288 MPEGQuant::MPEGQuant(int x, int y, MPEGConfigVideo *gui)
2289  : BC_TumbleTextBox(gui, 
2290         (int64_t)gui->asset->vmpeg_quantization, 
2291         (int64_t)1,
2292         (int64_t)100,
2293         x, 
2294         y,
2295         100)
2296 {
2297         this->gui = gui;
2298 }
2299
2300 int MPEGQuant::handle_event()
2301 {
2302         gui->asset->vmpeg_quantization = atol(get_text());
2303         return 1;
2304 };
2305
2306 MPEGFixedBitrate::MPEGFixedBitrate(int x, int y, MPEGConfigVideo *gui)
2307  : BC_Radial(x, y, gui->asset->vmpeg_fix_bitrate, _("Fixed bitrate"))
2308 {
2309         this->gui = gui;
2310 }
2311
2312 int MPEGFixedBitrate::handle_event()
2313 {
2314         update(1);
2315         gui->asset->vmpeg_fix_bitrate = 1;
2316         gui->fixed_quant->update(0);
2317         return 1;
2318 };
2319
2320 MPEGFixedQuant::MPEGFixedQuant(int x, int y, MPEGConfigVideo *gui)
2321  : BC_Radial(x, y, !gui->asset->vmpeg_fix_bitrate, _("Fixed quantization"))
2322 {
2323         this->gui = gui;
2324 }
2325
2326 int MPEGFixedQuant::handle_event()
2327 {
2328         update(1);
2329         gui->asset->vmpeg_fix_bitrate = 0;
2330         gui->fixed_bitrate->update(0);
2331         return 1;
2332 };
2333
2334
2335
2336
2337
2338
2339
2340
2341
2342 MPEGIFrameDistance::MPEGIFrameDistance(int x, int y, MPEGConfigVideo *gui)
2343  : BC_TumbleTextBox(gui, 
2344         (int64_t)gui->asset->vmpeg_iframe_distance, 
2345         (int64_t)1,
2346         (int64_t)100,
2347         x, 
2348         y,
2349         50)
2350 {
2351         this->gui = gui;
2352 }
2353
2354 int MPEGIFrameDistance::handle_event()
2355 {
2356         gui->asset->vmpeg_iframe_distance = atoi(get_text());
2357         return 1;
2358 }
2359
2360
2361
2362
2363
2364
2365
2366 MPEGPFrameDistance::MPEGPFrameDistance(int x, int y, MPEGConfigVideo *gui)
2367  : BC_TumbleTextBox(gui, 
2368         (int64_t)gui->asset->vmpeg_pframe_distance, 
2369         (int64_t)0,
2370         (int64_t)2,
2371         x, 
2372         y,
2373         50)
2374 {
2375         this->gui = gui;
2376 }
2377
2378 int MPEGPFrameDistance::handle_event()
2379 {
2380         gui->asset->vmpeg_pframe_distance = atoi(get_text());
2381         return 1;
2382 }
2383
2384
2385
2386
2387
2388
2389
2390
2391 MPEGColorModel::MPEGColorModel(int x, int y, MPEGConfigVideo *gui)
2392  : BC_PopupMenu(x, y, 150, cmodel_to_string(gui->asset->vmpeg_cmodel))
2393 {
2394         this->gui = gui;
2395 }
2396
2397 void MPEGColorModel::create_objects()
2398 {
2399         add_item(new BC_MenuItem(cmodel_to_string(BC_YUV420P)));
2400         add_item(new BC_MenuItem(cmodel_to_string(BC_YUV422P)));
2401 }
2402
2403 int MPEGColorModel::handle_event()
2404 {
2405         gui->asset->vmpeg_cmodel = string_to_cmodel(get_text());
2406         gui->update_cmodel_objs();
2407         gui->show_window(1);
2408         return 1;
2409 };
2410
2411 int MPEGColorModel::string_to_cmodel(char *string)
2412 {
2413         if(!strcasecmp(cmodel_to_string(BC_YUV420P), string))
2414                 return BC_YUV420P;
2415         if(!strcasecmp(cmodel_to_string(BC_YUV422P), string))
2416                 return BC_YUV422P;
2417         return BC_YUV420P;
2418 }
2419
2420 char* MPEGColorModel::cmodel_to_string(int cmodel)
2421 {
2422         switch(cmodel)
2423         {
2424                 case BC_YUV420P: return _("YUV 4:2:0");
2425                 case BC_YUV422P: return _("YUV 4:2:2");
2426                 default: return _("YUV 4:2:0");
2427         }
2428 }
2429
2430
2431
2432
2433
2434