Merge remote-tracking branch 'origin/master' into master
[enigma2-plugins.git] / moviecut / src_cc / mcut.cc
1  /* Copyright (C) 2007, 2008, 2009 Anders Holst
2   *
3   * This program is free software; you can redistribute it and/or
4   * modify it under the terms of the GNU General Public License as
5   * published by the Free Software Foundation; either version 2, or
6   * (at your option) any later version.
7   * 
8   * This program is distributed in the hope that it will be useful,
9   * but WITHOUT ANY WARRANTY; without even the implied warranty of
10   * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
11   * GNU General Public License for more details.
12   * 
13   * You should have received a copy of the GNU General Public License
14   * along with this software; see the file COPYING.  If not, write to
15   * the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
16   * Boston, MA 02111-1307 USA
17   */
18
19 #define _LARGEFILE64_SOURCE
20 #include <sys/types.h>
21 #include <sys/stat.h>
22 #include <fcntl.h>
23 #include <unistd.h>
24 #include <stdio.h>
25 #include <stdlib.h>
26 #include <string.h>
27 #include <byteswap.h>
28
29 #define LEN 24064
30
31 static off64_t time_offset;
32 static off64_t size_offset;
33 static off64_t curr_size_offset;
34
35 int use_leadin = 1;
36 int use_leadout = 1;
37
38 inline int absless(long long int x, int lim)
39 {
40   return (x<lim && x>-lim);
41 }
42
43 double strtotime(char* str)
44 {
45   int i=0, t1, tt;
46   char *p1, *p2;
47   double tmp;
48   p1 = str;
49   tt = strtol(p1, &p2, 10);
50   if (p1==p2) return -1.0;
51   while (*p2 == ':' && i<2) {
52     i++;
53     if (p2-p1>2) return -1.0;
54     p1 = p2+1;
55     t1 = strtol(p1, &p2, 10);
56     if (p1==p2) return -1.0;
57     tt = 60*tt + t1;
58   }
59   if (i>0 && p2-p1>2) return -1.0;
60   if (*p2 == 0) return (double)tt;
61   if (*p2 != '.') return -1.0;
62   p1 = p2+1;
63   t1 = strtol(p1, &p2, 10);
64   for (i=0, tmp=1.0; i<(p2-p1); tmp*=0.1, i++);
65   return (double)tt + tmp*t1;
66 }
67
68 double inttotime(unsigned int t1, unsigned int t2)
69 {
70   return (bswap_32(t2)*1.1111111111111112e-05 + bswap_32(t1)*47721.858844444447);
71 }
72
73 double lltotime(long long int t)
74 {
75   return ((unsigned int)(t&0xffffffff)*1.1111111111111112e-05) + ((unsigned int)(t>>32)*47721.858844444447);
76 }
77
78 void timetoint(double tm, unsigned int& t1, unsigned int& t2)
79 {
80   double tmp=tm/47721.858844444447;
81   t1 = bswap_32((unsigned int)tmp);
82   t2 = bswap_32((unsigned int)((tm - t1*47721.858844444447)*90000));
83 }
84
85 void swapbuf(off64_t*& buf0, off64_t*& buf1)
86 {
87   off64_t* buf;
88   buf = buf0;
89   buf0 = buf1;
90   buf1 = buf;
91 }
92
93 int readbufinternal(int f, off64_t*& buf)
94 {
95   if (read(f, buf, 16) != 16)
96     return 0;
97   buf[0] = (off64_t)bswap_64((unsigned long long int)buf[0]);
98   buf[1] = (off64_t)bswap_64((unsigned long long int)buf[1]);
99   return 1;
100 }
101
102 void writebufinternal(int f, off64_t* buf)
103 {
104   off64_t tbuf[2];
105   tbuf[0] = (off64_t)bswap_64((unsigned long long int)buf[0] - curr_size_offset);
106   tbuf[1] = (off64_t)bswap_64((unsigned long long int)buf[1]);
107   write(f, tbuf, 16);
108 }
109
110 void movesc(int fs, int fso, off64_t off, int beg)
111 {
112   static off64_t* buf = 0;
113   static off64_t lastoff;
114   static int endp;
115   if (fs == -1 || fso == -1)
116     return;
117   if (!buf) {
118     buf = new off64_t[2];
119     lastoff = 0;
120     endp = 0;
121   }
122   if (off < lastoff) {
123     lseek(fs, 0, SEEK_SET);
124     lastoff = 0;
125     endp = 0;
126   }
127   if (off == lastoff || endp)
128     return;
129   lastoff = off;
130   if (!beg && !endp)
131     writebufinternal(fso, buf);
132   while (readbufinternal(fs, buf)) {
133     if (buf[0] >= off)
134       return;
135     if (!beg)
136       writebufinternal(fso, buf);
137   }
138   endp = 1;
139 }
140
141 off64_t readoff(int fa, int fao, int fs, int fso, double t, int beg, double& tr)
142 {
143   static off64_t* buf0 = 0;
144   static off64_t* buf1 = 0;
145   static off64_t lastreturn;
146   static double last;
147   static int endp;
148   off64_t sizetmp;
149   double tt, lt;
150   if (!buf0) {
151     buf0 = new off64_t[2];
152     buf1 = new off64_t[2];
153     if (!(readbufinternal(fa, buf0) && readbufinternal(fa, buf1))) {
154       printf("The corresponding \".ap\"-file is empty.\n");
155       exit(8);
156     }
157     time_offset = buf0[1];
158     if (buf1[1] > buf0[1] && buf1[1] - buf0[1] < 900000)
159       time_offset -= (buf1[1]-buf0[1])*buf0[0]/(buf1[0]-buf0[0]);
160     else if (buf1[1] > buf0[1] || buf0[1] - buf1[1] > 45000)
161       time_offset = buf1[1];
162     size_offset = buf0[0];
163     lastreturn = 0;
164     last = 0.0;
165     endp = 0;
166   }
167   if (t < last && t != -1.0) {
168     sizetmp = buf0[0];
169     lseek(fa, 0, SEEK_SET);
170     readbufinternal(fa, buf0);
171     readbufinternal(fa, buf1);
172     time_offset = buf0[1];
173     if (buf1[1] > buf0[1] && buf1[1] - buf0[1] < 900000)
174       time_offset -= (buf1[1]-buf0[1])*buf0[0]/(buf1[0]-buf0[0]);
175     else if (buf1[1] > buf0[1] || buf0[1] - buf1[1] > 45000)
176       time_offset = buf1[1];
177     size_offset += buf0[0] - sizetmp;
178     lastreturn = 0;
179     last = 0.0;
180     endp = 0;
181   }
182   if (t == last || endp == 1) {
183     return lastreturn;
184   }
185   if (!beg)
186     writebufinternal(fao, buf0);
187   last = t;
188   lt = lltotime(buf0[1] - time_offset);
189   if (buf0[1] - buf1[1] > 0 && buf0[1] - buf1[1] <= 45000)
190     tt = lt, buf1[1] = buf0[1];
191   else
192     tt = lltotime(buf1[1] - time_offset);
193   sizetmp = buf0[0];
194   while (tt < t || t == -1.0) {
195     swapbuf(buf0, buf1);
196     if (!readbufinternal(fa, buf1))
197       endp = 1;
198     if (!beg)
199       writebufinternal(fao, buf0);
200     if (endp)
201       break;
202     if (buf0[1] - buf1[1] > 45000 || buf1[1] - buf0[1] > 900000) {
203       if (absless(buf1[1] + ((long long int)1)<<33 - buf0[1], 900000))
204         time_offset -= ((long long int)1)<<33;
205       else
206         time_offset += buf1[1] - buf0[1];
207     }
208     lt = tt;
209     if (buf0[1] - buf1[1] > 0 && buf0[1] - buf1[1] <= 45000)
210       tt = lt, buf1[1] = buf0[1];
211     else
212       tt = lltotime(buf1[1] - time_offset);
213   }
214   if (endp) {
215     tr = tt;
216   } else if (beg ? (lt == tt || (t-lt > tt-t && tt-t<0.18)) : (t-lt >= tt-t || t-lt>0.18)) {
217     swapbuf(buf0, buf1);
218     if (!readbufinternal(fa, buf1))
219       endp = 1;
220     if (buf0[1] - buf1[1] > 0 && buf0[1] - buf1[1] <= 45000)
221       buf1[1] = buf0[1];
222     if (!beg)
223       writebufinternal(fao, buf0);
224     tr = tt;
225   } else {
226     tr = lt;
227   }
228   if (beg)
229     size_offset += buf0[0] - sizetmp;
230   lastreturn = buf0[0];
231   return lastreturn;
232 }
233
234 int framepid(char* buf, int pos)
235 {
236   return ((buf[pos+1] & 0x1f) << 8) + buf[pos+2];
237 }
238
239 int framesearch_f(char* buf, int start, int stop, int pid, int& tp)
240 {
241   char* p;
242   int pos = -1;
243   for (p = buf+start; p < buf+stop-5; p++)
244     if (p[0]==0 && p[1]==0 && p[2]==1) {
245       if (p[3]==0) {
246         pos = ((p - buf)/188)*188;
247         if (pid == -1 || framepid(buf, pos) == pid) {
248           tp = (p[5]>>3)&7;
249           return pos;
250         }
251       } else if (p[3]==0x09) {
252         pos = ((p - buf)/188)*188;
253         if ((buf[pos+1] & 0x40) && (pid == -1 || framepid(buf, pos) == pid)) {
254           tp = (p[4] >> 5) + 1;
255           return pos;
256         }
257       }
258     }
259   return -1;
260 }
261
262 int framesearch_b(char* buf, int start, int stop, int pid)
263 {
264   char* p;
265   int pos = -1;
266   for (p = buf+stop-1; p >= buf+start+3; p--)
267     if (p[-1]==1 && p[-2]==0 && p[-3]==0) {
268       if (p[0]==0) {
269         pos = ((p - buf)/188)*188;
270         if (pid == -1 || framepid(buf, pos) == pid)
271           return pos;
272       } else if (p[0]==0x09) {
273         pos = ((p - buf)/188)*188;
274         if ((buf[pos+1] & 0x40) && (pid == -1 || framepid(buf, pos) == pid))
275           return pos;
276       }
277     }
278   return -1;
279 }
280
281 int transfer_start(int f_ts, int f_out, off64_t n1, off64_t& n1ret)
282 {
283   off64_t num;
284   int pos, tmp;
285   char buf[LEN];
286   if (use_leadin) {
287     num = 0;
288     tmp = 0;
289     do {
290       num += LEN;
291       if (num > n1)
292         tmp = LEN - (int)(num - n1), num = n1;
293       else
294         tmp = LEN;
295       lseek64(f_ts, n1 - num, SEEK_SET);
296       if (read(f_ts, buf, tmp) != tmp) return 1;
297     } while ((pos = framesearch_b(buf, 0, tmp, -1)) == -1 && num < n1);
298     if (pos != -1) {
299       if (write(f_out, buf+pos, tmp-pos) != tmp-pos) return 1;
300       n1ret = n1 - (num - pos);
301       size_offset -= (num - pos);
302       num -= tmp;
303       while (num > 0) {
304         if (read(f_ts, buf, LEN) != LEN) return 1;
305         if (write(f_out, buf, LEN) != LEN) return 1;
306         num -= LEN;
307       }
308     } else {
309       n1ret = n1;
310     }
311     return 0;
312   }
313   else {
314     lseek64(f_ts, n1, SEEK_SET);
315     n1ret = n1;
316     return 0;
317   }
318 }
319
320 int transfer_rest(int f_ts, int f_out, off64_t n1, off64_t n2, off64_t& n2ret)
321 {
322   off64_t i;
323   int num, pos, st, pid, tp, tmp;
324   char buf[LEN];
325   static off64_t lastn2 = -1, lastn2ret;
326   if (n1 == lastn2) {
327     i = lastn2ret;
328     lseek64(f_ts, i, SEEK_SET);
329   } else
330     i = n1;
331   for (; i+LEN<=n2; i+=LEN) {
332     if (read(f_ts, buf, LEN) != LEN) return 1;
333     if (write(f_out, buf, LEN) != LEN) return 1;
334   }
335   if (use_leadout) {
336     num = read(f_ts, buf, LEN);
337     pid = framepid(buf, n2-i);
338     st = (i < n2 ? n2-i : 0);
339     tmp = -st;
340     st += 188;
341     while ((pos = framesearch_f(buf, st, num, pid, tp)) == -1 ? num == LEN : tp == 3) {
342       if (pos != -1) {
343         st = pos + 188;
344       } else {
345         if (write(f_out, buf, LEN) != LEN) return 1;
346         num = read(f_ts, buf, LEN);
347         st = 0;
348         tmp += LEN;
349       }
350     }
351     if (st && num < st)
352       return 1;
353     else if (pos == -1) {
354       if (write(f_out, buf, num) != num) return 1;
355       tmp += num;
356       size_offset -= tmp;
357     } else {
358       if (write(f_out, buf, pos) != pos) return 1;
359       tmp += pos;
360       size_offset -= tmp;
361     }
362     lastn2 = n2;
363     lastn2ret = n2ret = n2 + tmp;
364     return 0;
365   } else {
366     if (i < n2) {
367       if (read(f_ts, buf, n2-i) != n2-i) return 1;
368       if (write(f_out, buf, n2-i) != n2-i) return 1;
369     }
370     lastn2 = lastn2ret = n2ret = n2;
371     return 0;
372   }
373 }
374
375 int donextinterval1(int fc, int fco, int fa, int fao, int fs, int fso, int fts, int ftso)
376 {
377   static int n = -1;
378   static double tlast, toff = 0.0;
379   static off64_t c2;
380   off64_t c1, c1ret, c2ret;
381   double ttmp;
382   unsigned int buf[3];
383   unsigned int tmp, lcheck=0;
384   if (n==0)
385     return 0;
386   else if (n==-1) {
387     n = lseek(fc, 0, SEEK_END) / 12;
388     lseek(fc, 0, SEEK_SET);
389     while (1) {
390       if (n == 0)
391         return 0;
392       read(fc, buf, 12);
393       n--;
394       tmp = bswap_32(buf[2]);
395       if (tmp == 1) {
396         c1 = readoff(fa, fao, fs, fso, 0.0, 1, toff);
397         if (transfer_start(fts, ftso, c1, c1ret)) return -1;
398         curr_size_offset = size_offset;
399         movesc(fs, fso, c1ret, 1);
400         c2 = readoff(fa, fao, fs, fso, inttotime(buf[0], buf[1]), 0, tlast);
401         if (transfer_rest(fts, ftso, c1, c2, c2ret)) return -1;
402         movesc(fs, fso, c2ret, 0);
403         printf("Interval: %lld - %lld\n", c1ret, c2ret);
404         // move all passed marks
405         lseek(fc, 0, SEEK_SET);
406         read(fc, buf, 12);
407         while (bswap_32(buf[2]) != 1) {
408           write(fco, buf, 12);
409           read(fc, buf, 12);
410         }
411         return 1;
412       } else if (tmp == 0) {
413         c1 = readoff(fa, fao, fs, fso, inttotime(buf[0], buf[1]), 1, toff);
414         if (transfer_start(fts, ftso, c1, c1ret)) return -1;
415         curr_size_offset = size_offset;
416         movesc(fs, fso, c1ret, 1);
417         if (lcheck) {
418           buf[0] = buf[1] = 0;
419           write(fco, buf, 12);
420         }
421         break;
422       } else if (tmp == 3)
423         lcheck = 1;
424     }
425   } else {
426     while (1) {
427       read(fc, buf, 12);
428       n--;
429       tmp = bswap_32(buf[2]);
430       if (tmp == 0) {
431         c1 = readoff(fa, fao, fs, fso, inttotime(buf[0], buf[1]), 1, ttmp);
432         use_leadin = 0;
433         if (c1 != c2) {
434           if (transfer_start(fts, ftso, c1, c1ret)) return -1;
435           curr_size_offset = size_offset;
436         } else {
437           c1ret = c2ret;
438           size_offset = curr_size_offset;
439         }
440         movesc(fs, fso, c1ret, 1);
441         toff += ttmp - tlast;
442         break;
443       } else if (tmp == 3) {
444         timetoint(tlast-toff, buf[0], buf[1]);
445         write(fco, buf, 12);
446       }
447       if (n == 0)
448         return 0;
449     }
450   }
451   while (1) {
452     if (n == 0) {
453       c2 = readoff(fa, fao, fs, fso, -1.0, 0, tlast);
454       if (transfer_rest(fts, ftso, c1, c2, c2ret)) return -1;
455       movesc(fs, fso, c2ret, 0);
456       printf("Interval: %lld - %lld\n", c1ret, c2ret);
457       return 1;
458     }
459     read(fc, buf, 12);
460     n--;
461     tmp = bswap_32(buf[2]);
462     if (tmp == 1) {
463       c2 = readoff(fa, fao, fs, fso, inttotime(buf[0], buf[1]), 0, tlast);
464       if (transfer_rest(fts, ftso, c1, c2, c2ret)) return -1;
465       movesc(fs, fso, c2ret, 0);
466       printf("Interval: %lld - %lld\n", c1ret, c2ret);
467       return 1;
468     } else if (tmp != 0) {
469       timetoint(inttotime(buf[0], buf[1])-toff, buf[0], buf[1]);
470       write(fco, buf, 12);
471     }
472   }
473   return 0;
474 }
475
476 int donextinterval2(int barg, int earg, char* argv[], int fc, int fco, int fa, int fao, int fs, int fso, int fts, int ftso)
477 {
478   static int n = -1, i, lio = -1, lcheck=0;
479   static double tlast = 0.0, toff = 0.0;
480   static off64_t c2 = -1;
481   off64_t c1, c1ret, c2ret;
482   double ttmp, ttmp2;
483   int j, io = -1;
484   unsigned int buf[3];
485   unsigned int buff[3];
486   unsigned int tmp;
487   if (i>=earg) {
488     if (!lcheck && n>0) {
489       lseek(fc, 0, SEEK_SET);
490       for (j=0; j<n; j++) {
491         read(fc, buf, 12);
492         tmp = bswap_32(buf[2]);
493         if (tmp == 3) {
494           timetoint(tlast-toff, buf[0], buf[1]);
495           write(fco, buf, 12);
496           break;
497         }
498       }
499     }
500     return 0;
501   }
502   if (n==-1) {
503     i = barg;
504     n = (fc != -1 ? lseek(fc, 0, SEEK_END) / 12 : 0);
505   }
506   c1 = readoff(fa, fao, fs, fso, strtotime(argv[i]), 1, ttmp);
507   if (c1 != c2) {
508     if (transfer_start(fts, ftso, c1, c1ret)) return -1;
509     curr_size_offset = size_offset;
510   } else {
511     c1ret = c2ret;
512     size_offset = curr_size_offset;
513   }
514   movesc(fs, fso, c1ret, 1);
515   use_leadin = 0;
516   toff += ttmp - tlast;
517   c2 = readoff(fa, fao, fs, fso, strtotime(argv[i+1]), 0, tlast);
518   if (transfer_rest(fts, ftso, c1, c2, c2ret)) return -1;
519   movesc(fs, fso, c2ret, 0);
520   printf("Interval: %lld - %lld\n", c1ret, c2ret);
521   if (n > 0) lseek(fc, 0, SEEK_SET);
522   for (j=0; j<n; j++) {
523     read(fc, buf, 12);
524     tmp = bswap_32(buf[2]);
525     ttmp2=inttotime(buf[0], buf[1]);
526     if (tmp == 3) {
527       if (!lcheck) {
528         if (ttmp2 <= ttmp) {
529           timetoint(ttmp-toff, buf[0], buf[1]);
530           write(fco, buf, 12);
531           lcheck = 1;
532         } else if (ttmp2 <= tlast) {
533           timetoint(ttmp2-toff, buf[0], buf[1]);
534           write(fco, buf, 12);
535           lcheck = 1;
536         }
537       }
538     } else if (ttmp2 >= ttmp && ttmp2 <= tlast) {
539       if (tmp < 2) {
540         if (lio != io && lio != -1) {
541           buff[2] = bswap_32(io);
542           timetoint(ttmp-toff, buff[0], buff[1]);
543           write(fco, buff, 12);
544         }
545         lio = io = tmp;
546       }
547       timetoint(ttmp2-toff, buf[0], buf[1]);
548       write(fco, buf, 12);
549     } else if (tmp < 2) {
550       io = tmp;
551     }
552   }
553   i+=2;
554   return 1;
555 }
556
557 char* makefilename(const char* base, const char* pre, const char* ext, const char* post, int delext = 0)
558 {
559   static char buf[256];
560   int len1, len2, len3;
561   len1 = strlen(base);
562   len2 = (pre ? strlen(pre) : 0);
563   len3 = (ext ? strlen(ext) : 0);
564   strcpy(buf, base);
565   if (ext && len1>=len3 && !strcmp(base+len1-len3,ext))
566     len1 -= len3;
567   if (pre)
568     strcpy(buf+len1, pre);
569   if (ext && !delext)
570     strcpy(buf+len1+len2, ext);
571   if (post)
572     strcpy(buf+len1+len2+(delext ? 0 : len3), post);
573   return buf;
574 }
575
576 void copymeta(int n, int f1, int f2, const char* title, const char* suff, const char* descr)
577
578   int i, j, k;
579   char* buf = new char[n];
580   read(f1, buf, n);
581   for (i=0; i<n; i++)
582     if (buf[i] == 10)
583       break;
584   write(f2, buf, i);
585   if (i == n) return;
586   for (j=i+1; j<n; j++)
587     if (buf[j] == 10)
588       break;
589   if (title) {
590     write(f2, buf+i, 1);
591     for (k=0; title[k] && title[k] != 10; k++);
592     write(f2, title, k);
593   } else {
594     write(f2, buf+i, j-i);
595     if (suff && j-i>1)
596       write(f2, suff, strlen(suff));
597   }
598   if (j == n) return;
599   i = j;
600   for (j=i+1; j<n; j++)
601     if (buf[j] == 10)
602       break;
603   if (descr) {
604     write(f2, buf+i, 1);
605     for (k=0; descr[k] && descr[k] != 10; k++);
606     write(f2, descr, k);
607   } else {
608     write(f2, buf+i, j-i);
609   }
610   if (j < n)
611     write(f2, buf+j, n-j);
612   delete [] buf;
613 }
614
615 void copysmallfile(int n, int f1, int f2)
616
617   char* buf = new char[n];
618   read(f1, buf, n);
619   write(f2, buf, n);
620   delete [] buf;
621 }
622
623 int main(int argc, char* argv[])
624 {
625   int f_ts, f_out, f_cuts, f_cutsout, f_ap, f_apout, f_sc, f_scout, f_meta, f_metaout, f_eit, f_eitout;
626   char* tmpname;
627   const char* suff = 0;
628   char* inname = 0;
629   char* outname = 0;
630   char* title = 0;
631   char* descr = 0;
632   int cutarg = 0, cutargend = 0;
633   int replace = 0, metafailed = 0;
634   int i, j, ok, bad = 0;
635   double t1, t2;
636   struct stat statbuf;
637   struct stat64 statbuf64;
638
639   for (i=1; i<argc; i++) {
640     if (!strcmp(argv[i], "-r"))
641       replace = 1;
642     else if (!strcmp(argv[i], "-o")) {
643       if (i == argc-1) {
644         bad = 1;
645         break;
646       }
647       outname = argv[++i];
648     } else if (!strcmp(argv[i], "-n")) {
649       if (i == argc-1) {
650         bad = 1;
651         break;
652       }
653       title = argv[++i];
654     } else if (!strcmp(argv[i], "-d")) {
655       if (i == argc-1) {
656         bad = 1;
657         break;
658       }
659       descr = argv[++i];
660     } else if (!strcmp(argv[i], "-c")) {
661       cutarg = ++i;
662       for (j=i; j<argc; j+=2) {
663         t1 = strtotime(argv[j]);
664         t2 = (j+1<argc ? strtotime(argv[j+1]) : -1.0);
665         if (t1 < 0 || t2 < 0)
666           break;
667         else if (t1 > t2) {
668           printf("Bad time interval: %s - %s\n", argv[j], argv[j+1]);
669           bad = 1;
670           break;
671         }
672       }
673       cutargend = i = j;
674       if (bad)
675         break;
676     } else if (*argv[i] == '-' && (*(argv[i]+1) == 0 ||*(argv[i]+2) == 0)) {
677       bad = 1;
678       break;
679     } else if (!inname)
680       inname = argv[i];
681     else {
682       bad = 1;
683       break;
684     }
685   }
686   if (argc == 1 || bad) {
687     printf("Usage: mcut [-r] [-o output_ts_file] [-n title] [-d description] ts_file [-c start1 end1 [start2 end2] ... ]\n");
688     printf("   -r : Replace (= remove) the original movie.\n");
689     printf("   -o : Filename of resulting movie (defaults to the original name appended by \" cut\", unless -r is given).\n");
690     printf("   -n : Title of resulting movie.\n");
691     printf("   -d : Description of resulting movie.\n");
692     printf("   -c : A sequence of starttime and endtime pairs. Each time is given as hour:min:sec. The portion between start and end is retained (i.e. not cut away).\n");
693     exit(1);
694   }
695   if (outname) {
696     suff = 0;
697   } else {
698     outname = inname;
699     suff = (replace ? "_" : " cut");
700   }
701   tmpname = makefilename(inname, 0, ".ts", 0);
702   f_ts = open(tmpname, O_RDONLY | O_LARGEFILE);
703   if (f_ts == -1) {
704     printf("Failed to open input stream file \"%s\"\n", tmpname);
705     exit(2);
706   }
707   tmpname = makefilename(inname, 0, ".ts", ".cuts");
708   f_cuts = open(tmpname, O_RDONLY);
709   if (f_cuts == -1 && !cutarg) {
710     printf("Failed to open input cuts file \"%s\"\n", tmpname);
711     close(f_ts);
712     exit(3);
713   }
714   tmpname = makefilename(inname, 0, ".ts", ".ap");
715   f_ap = open(tmpname, O_RDONLY);
716   if (f_ap == -1) {
717     printf("Failed to open input ap file \"%s\"\n", tmpname);
718     close(f_ts);
719     if (f_cuts != -1) close(f_cuts);
720     exit(4);
721   }
722   tmpname = makefilename(inname, 0, ".ts", ".sc");
723   f_sc = open(tmpname, O_RDONLY);
724
725   if (fstat64(f_ts, &statbuf64)) {
726     printf("Failed to stat input stream file.\n");
727     close(f_ts);
728     close(f_ap);
729     if (f_sc != -1) close(f_sc);
730     if (f_cuts != -1) close(f_cuts);
731     exit(2);
732   }
733   tmpname = makefilename(outname, suff, ".ts", 0);
734   f_out = open(tmpname, O_WRONLY | O_CREAT | O_EXCL | O_LARGEFILE, statbuf64.st_mode & 0xfff);
735   if (f_out == -1) {
736     printf("Failed to open output stream file \"%s\"\n", tmpname);
737     close(f_ts);
738     close(f_ap);
739     if (f_sc != -1) close(f_sc);
740     if (f_cuts != -1) close(f_cuts);
741     exit(5);
742   }
743   if (f_cuts != -1 && fstat(f_cuts, &statbuf)) {
744     if (!cutarg) {
745       printf("Failed to stat input cuts file.\n");
746       close(f_ts);
747       close(f_out);
748       close(f_ap);
749       if (f_sc != -1) close(f_sc);
750       close(f_cuts);
751       unlink(makefilename(outname, suff, ".ts", 0));
752       exit(3);
753     } else {
754       close(f_cuts);
755       f_cuts = -1;
756     }
757   }
758   if (f_cuts != -1) {
759     tmpname = makefilename(outname, suff, ".ts", ".cuts");
760     f_cutsout = open(tmpname, O_WRONLY | O_CREAT | O_TRUNC, statbuf.st_mode & 0xfff);
761     if (f_cutsout == -1) {
762       printf("Failed to open output cuts file \"%s\"\n", tmpname);
763       close(f_ts);
764       close(f_out);
765       close(f_ap);
766       if (f_sc != -1) close(f_sc);
767       close(f_cuts);
768       unlink(makefilename(outname, suff, ".ts", 0));
769       exit(6);
770     }
771   } else
772     f_cutsout = -1;
773   if (fstat(f_ap, &statbuf)) {
774     printf("Failed to stat input ap file.\n");
775     close(f_ts);
776     close(f_out);
777     close(f_ap);
778     if (f_sc != -1) close(f_sc);
779     if (f_cuts != -1) {
780       close(f_cuts);
781       close(f_cutsout);
782       unlink(makefilename(outname, suff, ".ts", ".cuts"));
783     }
784     unlink(makefilename(outname, suff, ".ts", 0));
785     exit(4);
786   }
787   tmpname = makefilename(outname, suff, ".ts", ".ap");
788   f_apout = open(tmpname, O_WRONLY | O_CREAT | O_TRUNC, statbuf.st_mode & 0xfff);
789   if (f_apout == -1) {
790     printf("Failed to open output ap file \"%s\"\n", tmpname);
791     close(f_ts);
792     close(f_out);
793     close(f_ap);
794     if (f_sc != -1) close(f_sc);
795     if (f_cuts != -1) {
796       close(f_cuts);
797       close(f_cutsout);
798       unlink(makefilename(outname, suff, ".ts", ".cuts"));
799     }
800     unlink(makefilename(outname, suff, ".ts", 0));
801     exit(7);
802   }
803   if (f_sc != -1 && fstat(f_sc, &statbuf)) {
804     close(f_sc);
805     f_sc = -1;
806   }
807   if (f_sc != -1) {
808     tmpname = makefilename(outname, suff, ".ts", ".sc");
809     f_scout = open(tmpname, O_WRONLY | O_CREAT | O_TRUNC, statbuf.st_mode & 0xfff);
810     if (f_scout == -1) {
811       printf("Failed to open output sc file \"%s\"\n", tmpname);
812       close(f_ts);
813       close(f_out);
814       close(f_ap);
815       close(f_apout);
816       close(f_sc);
817       if (f_cuts != -1) {
818         close(f_cuts);
819         close(f_cutsout);
820         unlink(makefilename(outname, suff, ".ts", ".cuts"));
821       }
822       unlink(makefilename(outname, suff, ".ts", 0));
823       unlink(makefilename(outname, suff, ".ts", ".ap"));
824       exit(7);
825     }
826   }
827   if (cutarg)
828     ok = donextinterval2(cutarg, cutargend, argv, f_cuts, f_cutsout, f_ap, f_apout, f_sc, f_scout, f_ts, f_out);
829   else
830     ok = donextinterval1(f_cuts, f_cutsout, f_ap, f_apout, f_sc, f_scout, f_ts, f_out);
831   if (!ok) {
832     printf("There are no cuts specified. Leaving the movie as it is.\n");
833     close(f_ts);
834     close(f_out);
835     close(f_ap);
836     close(f_apout);
837     if (f_cuts != -1) {
838       close(f_cuts);
839       close(f_cutsout);
840       unlink(makefilename(outname, suff, ".ts", ".cuts"));
841     }
842     if (f_sc != -1) {
843       close(f_sc);
844       close(f_scout);
845       unlink(makefilename(outname, suff, ".ts", ".sc"));
846     }
847     unlink(makefilename(outname, suff, ".ts", 0));
848     unlink(makefilename(outname, suff, ".ts", ".ap"));
849     exit(9);
850   }
851
852   while (ok > 0) {
853     if (cutarg)
854       ok = donextinterval2(cutarg, cutargend, argv, f_cuts, f_cutsout, f_ap, f_apout, f_sc, f_scout, f_ts, f_out);
855     else
856       ok = donextinterval1(f_cuts, f_cutsout, f_ap, f_apout, f_sc, f_scout, f_ts, f_out);
857   }
858
859   close(f_ts);
860   close(f_out);
861   close(f_ap);
862   close(f_apout);
863   if (f_cuts != -1) {
864     close(f_cuts);
865     close(f_cutsout);
866   }
867   if (f_sc != -1) {
868     close(f_sc);
869     close(f_scout);
870   }
871   if (ok < 0) {
872     printf("Copying %s failed, read/write error.\n", makefilename(inname, 0, ".ts", 0));
873     unlink(makefilename(outname, suff, ".ts", 0));
874     unlink(makefilename(outname, suff, ".ts", ".ap"));
875     if (f_cuts != -1)
876       unlink(makefilename(outname, suff, ".ts", ".cuts"));
877     if (f_sc != -1)
878       unlink(makefilename(outname, suff, ".ts", ".sc"));
879     exit(10);
880   }
881
882   if (!replace) {
883     tmpname = makefilename(inname, 0, ".ts", ".eit", 1);
884     f_eit = open(tmpname, O_RDONLY);
885     if (f_eit != -1) {
886       if (fstat(f_eit, &statbuf))
887         close(f_eit);
888       else {
889         tmpname = makefilename(outname, suff, ".ts", ".eit", 1);
890         f_eitout = open(tmpname, O_WRONLY | O_CREAT | O_TRUNC, statbuf.st_mode & 0xfff);
891         if (f_eitout == -1)
892           close(f_eit);
893         else {
894           copysmallfile((int)statbuf.st_size, f_eit, f_eitout);
895           close(f_eit);
896           close(f_eitout);
897         }
898       }
899     }
900   }
901
902   metafailed = 0;
903   tmpname = makefilename(inname, 0, ".ts", ".meta");
904   f_meta = open(tmpname, O_RDONLY);
905   if (f_meta == -1) {
906     metafailed = 1;
907   } else if (fstat(f_meta, &statbuf)) {
908     metafailed = 1;
909     close(f_meta);
910   } else {
911     tmpname = makefilename(outname, suff, ".ts", ".meta");
912     f_metaout = open(tmpname, O_WRONLY | O_CREAT | O_TRUNC, statbuf.st_mode & 0xfff);
913     if (f_metaout == -1) {
914       metafailed = 1;
915       close(f_meta);
916     } else {
917       copymeta((int)statbuf.st_size, f_meta, f_metaout, title, (replace ? 0 : suff), descr);
918       close(f_meta);
919       close(f_metaout);
920     }
921   }
922
923   if (replace) {
924     if (suff) {
925       tmpname = makefilename(inname, 0, ".ts", 0);
926       tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
927       unlink(tmpname);
928       rename(makefilename(outname, suff, ".ts", 0), tmpname);
929       tmpname = makefilename(inname, 0, ".ts", ".ap");
930       tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
931       unlink(tmpname);
932       rename(makefilename(outname, suff, ".ts", ".ap"), tmpname);
933       if (f_sc != -1) {
934         tmpname = makefilename(inname, 0, ".ts", ".sc");
935         tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
936         unlink(tmpname);
937         rename(makefilename(outname, suff, ".ts", ".sc"), tmpname);
938       }
939       if (f_cuts != -1) {
940         tmpname = makefilename(inname, 0, ".ts", ".cuts");
941         tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
942         unlink(tmpname);
943         rename(makefilename(outname, suff, ".ts", ".cuts"), tmpname);
944       }
945       if (!metafailed) {
946         tmpname = makefilename(inname, 0, ".ts", ".meta");
947         tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
948         unlink(tmpname);
949         rename(makefilename(outname, suff, ".ts", ".meta"), tmpname);
950       }
951     } else {
952       unlink(makefilename(inname, 0, ".ts", 0));
953       unlink(makefilename(inname, 0, ".ts", ".ap"));
954       if (f_sc != -1)
955         unlink(makefilename(inname, 0, ".ts", ".sc"));
956       if (f_cuts != -1)
957         unlink(makefilename(inname, 0, ".ts", ".cuts"));
958       tmpname = makefilename(inname, 0, ".ts", ".eit", 1);
959       tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
960       rename(tmpname, makefilename(outname, 0, ".ts", ".eit", 1));
961       if (!metafailed) 
962         unlink(makefilename(inname, 0, ".ts", ".meta"));
963       else {
964         tmpname = makefilename(inname, 0, ".ts", ".meta");
965         tmpname = strcpy(new char[strlen(tmpname)+1], tmpname);
966         rename(tmpname, makefilename(outname, 0, ".ts", ".meta"));
967       }
968     }
969   }
970 }
971