+++ /dev/null
-#include "libzmpeg3.h"
-
-#define PUT_INT32(x) do { \
- uint32_t be = htobe32(x); \
- fwrite((uint8_t*)&be,1,sizeof(be),toc_fp); \
-} while(0)
-
-#define PUT_INT64(x) do { \
- uint64_t be = htobe64(x); \
- fwrite((uint8_t*)&be,1,sizeof(be),toc_fp); \
-} while(0)
-
-
-//#define DATA_DUMP
-#ifdef DATA_DUMP
-#include <stdio.h>
-static FILE **video_fp = 0;
-static FILE **audio_fp = 0;
-#endif
-
-static inline void read_data(uint8_t *bfr, int &pos, uint8_t *out, int len)
-{
- memcpy(out, bfr + pos, len);
- pos += len;
-}
-
-/* Concatenate title and toc directory if title is not absolute and */
-/* toc path has a directory section. */
-static inline void concat_path(char *full_path, char *toc_path, char *path)
-{
- if( path[0] != '/' ) {
- char *ptr = strrchr(toc_path, '/');
- if( ptr ) {
- strcpy(full_path, toc_path);
- strcpy(&full_path[ptr - toc_path + 1], path);
- }
- }
- else
- strcpy(full_path, path);
-}
-
-int zmpeg3_t::
-read_toc(int *atracks_return, int *vtracks_return, const char *title_path)
-{
- int i, j;
- int64_t current_byte = 0;
- int debug = 0;
- /* Fix title paths for Cinelerra VFS */
- int vfs_len = strlen(ZRENDERFARM_FS_PREFIX);
- int is_vfs = !strncmp(fs->path,ZRENDERFARM_FS_PREFIX, vfs_len) ? 1 : 0;
- fs->seek(0);
- /* Test version */
- fs->read_uint32();
- uint32_t toc_version = fs->read_uint32();
- if( toc_version != TOC_VERSION ) {
- zerrs("invalid TOC version %08x (should be %08x)\n",
- toc_version, TOC_VERSION);
- return ERR_INVALID_TOC_VERSION;
- }
- /* File type */
- while( !fs->eof() ) {
- /* Get section type */
- int section_type = fs->read_uint32();
-//zmsgs("section_type=%d position="_LX"\n", section_type, fs->tell());
- switch( section_type ) {
- case toc_FILE_TYPE_PROGRAM:
- file_type = FT_PROGRAM_STREAM;
- break;
- case toc_FILE_TYPE_TRANSPORT:
- file_type = FT_TRANSPORT_STREAM;
- break;
- case toc_FILE_TYPE_AUDIO:
- file_type = FT_AUDIO_STREAM;
- break;
- case toc_FILE_TYPE_VIDEO:
- file_type = FT_VIDEO_STREAM;
- break;
-
- case toc_FILE_INFO: {
- char string[STRLEN];
- char string2[STRLEN];
- fs->read_data((uint8_t*)&string[0],STRLEN);
- if( title_path )
- strcpy(string2, title_path);
- else
- concat_path(string2, fs->path, string);
- source_date = fs->read_uint64();
- int64_t current_date = calculate_source_date(string2);
-//zmsgs("zsrc=%s source_date="_LD" current_date="_LD"\n",
-// string2, source_date, current_date);
- if( current_date != source_date ) {
- zerrs("date mismatch "_LX" (should be "_LX")\n",
- current_date, source_date);
- return ERR_TOC_DATE_MISMATCH;
- }
- break; }
-
- case toc_STREAM_AUDIO: {
- int n = fs->read_uint32();
- demuxer->astream_table[n] = fs->read_uint32();
- break; }
-
- case toc_STREAM_VIDEO: {
- int n = fs->read_uint32();
- demuxer->vstream_table[n] = fs->read_uint32();
- break; }
-
-
- case toc_ATRACK_COUNT: {
- int atracks = fs->read_uint32();
- *atracks_return = atracks;
- channel_counts = znew(int,atracks);
- nudging = znew(int,atracks);
- sample_offsets = znew(int64_t*,atracks);
- total_sample_offsets = znew(int,atracks);
- audio_eof = znew(int64_t,atracks);
- total_samples = znew(int64_t,atracks);
- indexes = znew(index_t*,atracks);
- total_indexes = atracks;
- for( i=0; i < atracks; ++i ) {
- audio_eof[i] = fs->read_uint64();
- channel_counts[i] = fs->read_uint32();
- nudging[i] = fs->read_uint32();
- total_sample_offsets[i] = fs->read_uint32();
- total_samples[i] = fs->read_uint64();
-
- if(total_samples[i] < 1) total_samples[i] = 1;
- sample_offsets[i] = znew(int64_t,total_sample_offsets[i]);
- for( j=0; j < total_sample_offsets[i]; ++j ) {
- sample_offsets[i][j] = fs->read_uint64();
- }
-
- index_t *index = indexes[i] = new index_t();
- index->index_size = fs->read_uint32();
- index->index_zoom = fs->read_uint32();
-//zmsgs("%d %d %d\n", i, index->index_size, index->index_zoom);
- int channels = index->index_channels = channel_counts[i];
- if( channels ) {
- index->index_data = znew(float*,channels);
- for( j=0; j < channels; ++j ) {
- index->index_data[j] = znew(float,index->index_size*2);
- fs->read_data((uint8_t*)index->index_data[j],
- sizeof(float) * index->index_size * 2);
- }
- }
- }
- break; }
-
- case toc_VTRACK_COUNT: {
- int vtracks = fs->read_uint32();
- *vtracks_return = vtracks;
- frame_offsets = znew(int64_t*,vtracks);
- total_frame_offsets = znew(int,vtracks);
- keyframe_numbers = znew(int*,vtracks);
- total_keyframe_numbers = znew(int,vtracks);
- video_eof = znew(int64_t,vtracks);
- for( i=0; i < vtracks; ++i ) {
- video_eof[i] = fs->read_uint64();
- total_frame_offsets[i] = fs->read_uint32();
- frame_offsets[i] = new int64_t[total_frame_offsets[i]];
- if( debug ) zmsgs("62 %d "_LX" "_LX"\n",
- total_frame_offsets[i], fs->tell(), fs->ztotal_bytes());
- for( j=0; j < total_frame_offsets[i]; ++j ) {
- frame_offsets[i][j] = fs->read_uint64();
-//zmsgs("frame %llx\n", frame_offsets[i][j]);
- }
- if(debug) zmsg("64\n");
- total_keyframe_numbers[i] = fs->read_uint32();
- keyframe_numbers[i] = new int[total_keyframe_numbers[i]];
- for( j=0; j < total_keyframe_numbers[i]; ++j ) {
- keyframe_numbers[i][j] = fs->read_uint32();
- }
- }
- break; }
-
- case toc_STRACK_COUNT: {
- total_stracks = fs->read_uint32();
- for( i=0; i < total_stracks; ++i ) {
- int id = fs->read_uint32();
- strack_t *strk = new strack_t(id);
- strack[i] = strk;
- strk->total_offsets = fs->read_uint32();
- strk->offsets = znew(int64_t,strk->total_offsets);
- strk->allocated_offsets = strk->total_offsets;
- for( j=0; j < strk->total_offsets; ++j ) {
- strk->offsets[j] = fs->read_uint64();
- }
- }
- break; }
-
- case toc_TITLE_PATH: {
- if(debug) zmsg("11\n");
- char string[STRLEN];
- fs->read_data((uint8_t*)string, STRLEN);
- /* Detect Blu-Ray */
- if( debug ) printf("11 position="_LX"\n", fs->tell());
- char *ext = strrchr(string, '.');
- if( ext ) {
- if( !strncasecmp(ext, ".m2ts", 5) ||
- !strncasecmp(ext, ".mts", 4) ) file_type |= FT_BD_FILE;
- }
- if(debug) printf("12\n");
- // if title_path concatenate dirname title_path and basename path
- if( title_path ) {
- char string2[STRLEN], *bp = string2, *cp = string2;
- for( const char *tp=title_path; (*cp++=*tp) != 0; ++tp )
- if( *tp == '/' ) bp = cp;
- for( char *sp=cp=string; *sp != 0; ++sp )
- if( *sp == '/' ) cp = sp+1;
- while( (*bp++=*cp++)!=0 );
- strcpy(string, string2);
- }
- // Test title availability
- if( access(string,R_OK) ) {
- /* Concatenate title and toc directory if title is not absolute and */
- /* toc path has a directory section. */
- if( (!is_vfs && string[0] != '/') ||
- (is_vfs && string[vfs_len] != '/') ) {
- /* Get toc filename without path */
- char *ptr = strrchr(fs->path, '/');
- if( ptr ) {
- char string2[STRLEN];
- /* Stack filename on toc path */
- strcpy(string2, fs->path);
- if( !is_vfs )
- strcpy(&string2[ptr - fs->path + 1], string);
- else
- strcpy(&string2[ptr - fs->path + 1], string + vfs_len);
- if( access(string2,R_OK) ) {
- zerrs("failed to open %s or %s\n", string, string2);
- return 1;
- }
- strcpy(string, string2);
- }
- else {
- zerrs("failed to open %s\n", string);
- return 1;
- }
- }
- else {
- zerrs("failed to open %s\n", string);
- return 1;
- }
- }
-
- if(debug) zmsg("30\n");
- demuxer_t::title_t *title = new demuxer_t::title_t(this, string);
- demuxer->titles[demuxer->total_titles++] = title;
- title->total_bytes = fs->read_uint64();
- title->start_byte = current_byte;
- title->end_byte = title->start_byte + title->total_bytes;
- current_byte = title->end_byte;
- /* Cells */
- title->cell_table_allocation = fs->read_uint32();
- title->cell_table_size = title->cell_table_allocation;
-//zmsgs("40 %llx %d\n", title->total_bytes, title->cell_table_size);
- title->cell_table =
- new demuxer_t::title_t::cell_t[title->cell_table_size];
- for( i=0; i < title->cell_table_size; ++i ) {
- demuxer_t::title_t::cell_t *cell = &title->cell_table[i];
- cell->title_start = fs->read_uint64();
- cell->title_end = fs->read_uint64();
- cell->program_start = fs->read_uint64();
- cell->program_end = fs->read_uint64();
- union { double d; uint64_t u; } cell_time;
- cell_time.u = fs->read_uint64();
- cell->cell_time = cell_time.d;
- cell->cell_no = fs->read_uint32();
- cell->discontinuity = fs->read_uint32();
-//zmsgs("50 %"_LX"-"_LX" "_LX"-_LX" %d %d\n",
-// cell->title_start, cell->title_end, cell->program_start,
-// cell->program_end, cell->cell_no, cell->discontinuity);
- }
- break; }
-
- case toc_IFO_PALETTE:
- for(i = 0; i < 16; i++) {
- int k = i*4;
- palette[k + 0] = fs->read_char();
- palette[k + 1] = fs->read_char();
- palette[k + 2] = fs->read_char();
- palette[k + 3] = fs->read_char();
-//zmsgs("color %02d: 0x%02x 0x%02x 0x%02x 0x%02x\n",
-// i, palette[k+0], palette[k+1], palette[k+2], palette[k+3]);
- }
- have_palette = 1;
- break;
- case toc_IFO_PLAYINFO: {
- int ncells = fs->read_uint32();
- icell_table_t *cells = new icell_table_t();
- if( playinfo ) delete playinfo;
- playinfo = cells;
- while( --ncells >= 0 ) {
- icell_t *cell = cells->append_cell();
- cell->start_byte = fs->read_uint64();
- cell->end_byte = fs->read_uint64();
- cell->vob_id = fs->read_uint32();
- cell->cell_id = fs->read_uint32();
- cell->inlv = fs->read_uint32();
- cell->discon = fs->read_uint32();
- }
- break;
- }
- case toc_SRC_PROGRAM: {
- vts_title = fs->read_uint32();
- total_vts_titles = fs->read_uint32();
- int inlv = fs->read_uint32();
- angle = inlv / 10; interleave = inlv % 10;
- total_interleaves = fs->read_uint32();
- break;
- }
- }
- }
- if(debug) zmsg("90\n");
- demuxer->open_title(0);
- if(debug) zmsg("100\n");
-
- return 0;
-}
-
-
-zmpeg3_t* zmpeg3_t::
-start_toc(const char *path, const char *toc_path,
- int program, int64_t *total_bytes)
-{
- if( total_bytes ) *total_bytes = 0;
- zmpeg3_t *zsrc = new zmpeg3_t(path);
- zsrc->toc_fp = fopen(toc_path, "w");
- if(!zsrc->toc_fp) {
- perrs("%s",toc_path);
- delete zsrc;
- return 0;
- }
-
- zsrc->set_vts_title(program / 100);
- zsrc->set_angle((program / 10) % 10);
- zsrc->set_interleave(program % 10);
- zsrc->last_cell_no = 0;
-
- if( !total_bytes ) {
- zsrc->fs->sequential();
- zsrc->file_type = FT_TRANSPORT_STREAM;
- zsrc->packet_size = zsrc->calculate_packet_size();
- }
-
- /* Authenticate encryption before reading a single byte */
- /* and Determine file type */
- int toc_atracks = 0, toc_vtracks = 0;
- if( zsrc->fs->open_file() ||
- (!zsrc->file_type &&
- zsrc->get_file_type(&toc_atracks, &toc_vtracks, 0) ) ) {
- fclose(zsrc->toc_fp); zsrc->toc_fp = 0;
- delete zsrc;
- return 0;
- }
-
- demuxer_t *demux = zsrc->demuxer;
- /* Create title without scanning for tracks */
- if( !demux->total_titles ) {
- demuxer_t::title_t *title = new demuxer_t::title_t(zsrc);
- demux->titles[0] = title;
- demux->total_titles = 1;
- demux->open_title(0);
- title->total_bytes = title->fs->ztotal_bytes();
- title->start_byte = 0;
- title->end_byte = title->total_bytes;
- title->new_cell(title->end_byte);
- }
-
- /* mpeg3demux_seek_byte(zsrc->demuxer, 0x1734e4800LL); */
- demux->seek_byte(0);
- demux->read_all = -1;
- int64_t bytes = demux->movie_size();
- if( total_bytes ) *total_bytes = bytes;
-
-//*total_bytes = 500000000;
- zsrc->allocate_slice_decoders();
- return zsrc;
-}
-
-void zmpeg3_t::
-divide_index(int track_number)
-{
- if( total_indexes <= track_number ) return;
- index_t *idx = indexes[track_number];
- idx->index_size /= 2;
- idx->index_zoom *= 2;
- for( int i=0; i < idx->index_channels; ++i ) {
- float *current_channel = idx->index_data[i];
- float *out = current_channel;
- float *in = current_channel;
- for( int j=0; j < idx->index_size; ++j ) {
- float max = ZMAX(in[0], in[2]);
- float min = ZMIN(in[1], in[3]);
- *out++ = max;
- *out++ = min;
- in += 4;
- }
- }
-}
-
-int zmpeg3_t::
-update_index(int track_number, int flush)
-{
- int i, j, k, n;
- int result = 0;
- atrack_t *atrk = atrack[track_number];
- if( track_number >= total_indexes ) {
- /* Create index table */
- int new_allocation = track_number + 1;
- index_t **new_indexes = new index_t*[new_allocation];
- for( i=0; i<total_indexes; ++i )
- new_indexes[i] = indexes[i];
- while( i < new_allocation )
- new_indexes[i++] = new index_t();
- delete [] indexes;
- indexes = new_indexes;
- total_indexes = new_allocation;
- }
- index_t *idx = indexes[track_number];
- audio_t *aud = atrk->audio;
-//zmsgs("%d atrk->audio->output_size=%d\n", __LINE__, aud->output_size);
- while( ( flush && aud->output_size) ||
- (!flush && aud->output_size > AUDIO_CHUNKSIZE) ) {
- int fragment = AUDIO_CHUNKSIZE;
- if( aud->output_size < fragment ) fragment = aud->output_size;
- int index_fragments = fragment / idx->index_zoom;
- if( flush ) ++index_fragments;
- int new_index_samples = index_fragments + idx->index_size;
- /* Update number of channels */
- if( idx->index_allocated && idx->index_channels < atrk->channels ) {
- float **new_index_data = znew(float*,atrk->channels);
- for( i=0; i < idx->index_channels; ++i )
- new_index_data[i] = idx->index_data[i];
- for( i=idx->index_channels; i < atrk->channels; ++i )
- new_index_data[i] = znew(float,idx->index_allocated*2);
- idx->index_channels = atrk->channels;
- delete [] idx->index_data;
- idx->index_data = new_index_data;
- }
-
- /* Allocate index buffer */
- if( new_index_samples > idx->index_allocated ) {
- /* Double current number of samples */
- idx->index_allocated = new_index_samples * 2;
- if( !idx->index_data ) {
- idx->index_data = znew(float*,atrk->channels);
- }
- /* Allocate new size in high and low pairs */
- k = idx->index_allocated * sizeof(float*) * 2;
- for( i=0; i < atrk->channels; ++i ) {
- float *old_data = idx->index_data[i];
- float *new_data = new float[k];
- n = idx->index_size*2;
- for( j=0; j<n; ++j ) new_data[j] = old_data[j];
- while( j < k ) new_data[j++] = 0.;
- delete [] idx->index_data[i];
- idx->index_data[i] = new_data;
- }
- idx->index_channels = atrk->channels;
- }
-
- /* Calculate new index chunk */
- for( i=0; i<atrk->channels; ++i ) {
- float *in_channel = i < aud->output_channels ? aud->output[i] : 0;
- float *out_channel = idx->index_data[i] + idx->index_size*2;
- /* Calculate index frames */
- for( j=0; j < index_fragments; ++j ) {
- float min = 0;
- float max = 0;
- int remaining_fragment = fragment - j*idx->index_zoom;
- int len = remaining_fragment < idx->index_zoom ?
- remaining_fragment : idx->index_zoom;
- if( in_channel && len > 0 ) {
- min = max = *in_channel++;
- for( k=1; k < len; ++k ) {
- if( *in_channel > max ) max = *in_channel;
- else if( *in_channel < min ) min = *in_channel;
- ++in_channel;
- }
- }
- *out_channel++ = max;
- *out_channel++ = min;
- }
- }
-
- idx->index_size = new_index_samples;
- /* Shift audio buffer */
- aud->shift_audio(fragment);
- /* Create new toc entry */
- atrk->append_samples(atrk->prev_offset);
- atrk->current_position += fragment;
- result = 1;
- }
- /* Divide index by 2 and increase zoom */
- k = idx->index_size * atrk->channels * sizeof(float) * 2;
- if( k > index_bytes && !(idx->index_size % 2) )
- divide_index(track_number);
- return result;
-}
-
-
-int zatrack_t::
-handle_audio_data(int track_number)
-{
- zmpeg3_t *zsrc = audio->src;
- /* Decode samples */
- while( !audio->decode_audio(0, atyp_NONE, 0, AUDIO_HISTORY) ) {
- /* add downsampled samples to the index buffer and create toc entry. */
- if( !zsrc->update_index(track_number, 0) ) break;
- prev_offset = curr_offset;
- }
- return 0;
-}
-
-int zatrack_t::
-handle_audio(int track_number)
-{
-#ifdef DATA_DUMP
-if( !audio_fp ) {
- audio_fp = new FILE*[65536];
- memset(audio_fp,0,65536*sizeof(FILE*));
-}
-if( !audio_fp[pid] ) {
- char fn[512];
- sprintf(fn,"/tmp/dat/a%04x.mpg",pid);
- audio_fp[pid] = fopen(fn,"w");
-}
-if( audio_fp[pid] ) {
- zmpeg3_t *zsrc = audio->src;
- demuxer_t *demux = zsrc->demuxer;
- if( demux->zaudio.size )
- fwrite(demux->zaudio.buffer, demux->zaudio.size, 1, audio_fp[pid]);
- else if( demux->zdata.size )
- fwrite(demux->zdata.buffer, demux->zdata.size, 1, audio_fp[pid]);
-}
-#endif
-
- int result = 0;
- if( format != afmt_IGNORE ) {
- zmpeg3_t *zsrc = audio->src;
- demuxer_t *demux = zsrc->demuxer;
- /* Assume last packet of stream */
- audio_eof = demux->tell_byte();
- /* Append demuxed data to track buffer */
- if( demux->zaudio.size )
- demuxer->append_data(demux->zaudio.buffer,demux->zaudio.size);
- else if( demux->zdata.size )
- demuxer->append_data(demux->zdata.buffer,demux->zdata.size);
- if( demux->pes_audio_pid == pid && demux->pes_audio_time >= 0 ) {
- demuxer->pes_audio_time = demux->pes_audio_time;
- demux->pes_audio_time = -1.;
- }
- if( !sample_rate ) {
- /* check for audio starting past first cell */
- if( zsrc->pts_padding > 0 && zsrc->cell_time >= 0. ) {
- audio_time = zsrc->cell_time;
- pts_position = 0;
- if( pts_starttime < 0. ) {
- pts_offset = zsrc->cell_time;
- pts_starttime = 0.;
- }
- }
- }
-//zmsgs("%d pid=%p zaudio.size=%d zdata.size=%d\n", __LINE__,
-// demux->pid, demux->zaudio.size, demux->zdata.size);
-#if 0
- if( pid == 0x1100 ) {
- static FILE *test = 0;
- if( !test ) test = fopen("/hmov/test.ac3", "w");
- fwrite(demux->zaudio.buffer,
- demux->zaudio.size, 1, test);
- }
-#endif
- result = handle_audio_data(track_number);
- demuxer->shift_data();
- }
- return result;
-}
-
-int zvtrack_t::
-handle_video_data(int track_number, int prev_data_size)
-{
- zmpeg3_t *zsrc = video->src;
- /* Scan for a start code a certain number of bytes from the end of the */
- /* buffer. Then scan the header using the video decoder to get the */
- /* repeat count. */
- while( demuxer->zdata.length() >= VIDEO_STREAM_SIZE ) {
- if( !demuxer->last_code ) {
- if( video->thumb && video->pict_type == video_t::pic_type_I ) {
- if( tcode >= SLICE_MIN_START && tcode <= SLICE_MAX_START ) {
- // start a new slice
- slice = video->get_slice_buffer();
-//int vtrk, sbfr = slice - &video->slice_buffers[0];
-//for( vtrk=0; vtrk<zsrc->total_vtracks && video!=zsrc->vtrack[vtrk]->video; ++vtrk );
-//printf("get_slice_buffer %p vtrk=%d, sbfr=%d\n",slice,vtrk,sbfr);
- sbp = slice->data;
- for( int i=32; i>0; ) *sbp++ = (tcode>>(i-=8));
- sb_size = slice->buffer_allocation-4-4;
- tcode = ~0;
- }
- }
-
- if( !slice ) {
- for(;;) {
- if( (uint8_t)tcode != 0 ) {
- tcode = (tcode<<8) | demuxer->read_char();
- tcode = (tcode<<8) | demuxer->read_char();
- }
- tcode = (tcode<<8) | demuxer->read_char();
- if( (tcode&0xffffff) == PACKET_START_CODE_PREFIX ) break;
- if( demuxer->zdata.length() < VIDEO_STREAM_SIZE ) return 0;
- }
- tcode = (tcode<<8) | demuxer->read_char();
- }
- else {
- for(;;) {
- if( sb_size <= 0 ) {
- sbp = slice->expand_buffer(sbp - slice->data);
- sb_size = slice->buffer_size;
- }
- if( (uint8_t)tcode != 0 ) {
- sb_size -= 3;
- tcode = (tcode<<8) | (*sbp++ = demuxer->read_char());
- tcode = (tcode<<8) | (*sbp++ = demuxer->read_char());
- }
- else
- --sb_size;
- tcode = (tcode<<8) | (*sbp++ = demuxer->read_char());
- if( (tcode&0xffffff) == PACKET_START_CODE_PREFIX ) break;
- if( demuxer->zdata.length() < VIDEO_STREAM_SIZE ) return 0;
- }
- tcode = (tcode<<8) | (*sbp++ = demuxer->read_char());
- // finish slice
- slice->buffer_size = sbp - slice->data;
- *--sbp = 0; sbp = 0;
-//#define MULTI_THREADED
-#ifdef MULTI_THREADED
-// this is actually slower than single threaded
- zsrc->decode_slice(slice);
-#else
- slice_decoder_t *decoder = &zsrc->slice_decoders[0];
- decoder->slice_buffer = slice;
- decoder->video = video;
- decoder->decode_slice();
- video->put_slice_buffer(slice);
-#endif
- slice = 0;
- }
-//zmsgs("trk=%d, pos=0x%04x,size=0x%04x,length=0x%04x, cur_pos 0x%012lx/0x%012lx, tcode=0x%08x\n",
-// track_number, demuxer->zdata.position, demuxer->zdata.size, demuxer->zdata.length(),
-// prev_offset, curr_offset, tcode);
- switch( tcode ) {
- case GOP_START_CODE:
- case PICTURE_START_CODE:
- if( !video->found_seqhdr ) continue;
- /* else fall through */
- case SEQUENCE_START_CODE:
- /* save start of packet, data before prev_data_size from prev_offset */
- if( prev_frame_offset == -1 )
- prev_frame_offset = demuxer->zdata.position < prev_data_size ?
- prev_offset : curr_offset;
- video->vstream->reset(tcode);
- break;
- default:
- continue;
- }
-
- /* Wait for decoders to finish */
- if( video->slice_active_locked ) {
- video->slice_active.lock();
- video->slice_active.unlock();
- }
-
- if( total_frame_offsets-1 > video->framenum ) {
- video->framenum = total_frame_offsets-1;
- update_video_time();
- if( video->framenum >= 0 ) {
- int64_t last_frame_offset = frame_offsets[video->framenum];
- while( video->video_pts_padding() ) {
- append_frame(last_frame_offset, 0);
- video->framenum = total_frame_offsets-1;
- }
- }
- if( video->video_pts_skipping() )
- continue;
- update_frame_pts();
- }
- /* if last frame was P-Frame after I-Frame show thumbnail */
- if( video->thumb && video->decoder_initted ) {
- switch( video->pict_type ) {
- case video_t::pic_type_P:
- if( !video->ithumb ) break;
- video->ithumb = 0;
- zsrc->thumbnail_fn(zsrc->thumbnail_priv, track_number);
- break;
- case video_t::pic_type_I:
- video->ithumb = 1;
- break;
- }
- }
- }
-
- /* Use video decoder to get repeat count and field type. */
- /* Should never hit EOF in here. This rereads up to the current ptr */
- /* since zdata.position isn't updated by handle_video. */
- /* if get_header fails, try this offset again with more data */
- int data_position = demuxer->zdata.position;
- int have_seqhdr = video->found_seqhdr;
- int32_t repeat_data = video->repeat_data;
- if( video->get_header() ) {
- if( video->found_seqhdr ) {
- /* try again with more data */
- demuxer->last_code = tcode;
- demuxer->zdata.position = data_position;
- }
- video->found_seqhdr = have_seqhdr;
- video->repeat_data = repeat_data;
- break;
- }
-
- if( !video->decoder_initted ) {
- video->init_decoder();
- width = video->horizontal_size;
- height = video->vertical_size;
- frame_rate = video->frame_rate;
- }
-
- /* check for video starting past first cell */
- if( !have_seqhdr && zsrc->pts_padding > 0 &&
- video_time < 0 && zsrc->cell_time >= 0. ) {
- video_time = zsrc->cell_time;
- pts_position = 0;
- if( pts_starttime < 0. ) {
- pts_offset = zsrc->cell_time;
- pts_starttime = 0.;
- }
- }
-
- video->secondfield = 0;
- if( video->pict_struct != video_t::pics_FRAME_PICTURE ) {
- if( video->got_top || video->got_bottom )
- video->secondfield = 1;
- }
-
- int field = video->secondfield ? 2 : 1;
- if( video->pict_struct == video_t::pics_TOP_FIELD )
- video->got_top = field;
- else if( video->pict_struct == video_t::pics_BOTTOM_FIELD )
- video->got_bottom = field;
-
- if( video->pict_struct == video_t::pics_FRAME_PICTURE ||
- video->secondfield || !video->pict_struct ) {
-//zmsgs("video pid %02x framenum %d video_time %12.5f %c 0x%012lx rep %d\n",
-// pid, video->framenum, get_video_time(), "XIPBD"[video->pict_type],
-// prev_frame_offset, video->repeat_fields-2);
- if( video->pict_type == video_t::pic_type_I )
- got_keyframe = 1;
- append_frame(prev_frame_offset, got_keyframe);
- /* Add entry for every repeat count. */
- video->current_field += 2;
- while( video->repeat_fields-video->current_field >= 2 ) {
- append_frame(prev_frame_offset, 0);
- video->current_field += 2;
- }
- if( (video->repeat_fields-=video->current_field) < 0 )
- video->repeat_fields = 0;
- /* Shift out data from before frame */
- prev_frame_offset = -1;
- got_keyframe = 0;
- }
- else {
- // This was a TOP/BOTTOM FIELD and was not secondfield
- // Shift out data from this field
- if( video->pict_type == video_t::pic_type_I )
- got_keyframe = 1;
- video->current_field += 2;
- }
- tcode = video->vstream->show_bits(32);
- if( !video->repeat_fields ) video->current_field = 0;
- demuxer->last_code = 0;
- }
- return 0;
-}
-
-int zvtrack_t::
-handle_video(int track_number)
-{
- zmpeg3_t *zsrc = video->src;
- demuxer_t *demux = zsrc->demuxer;
- /* Assume last packet of stream */
- video_eof = demux->tell_byte();
- int prev_data_size = demuxer->zdata.size;
-//zmsgs("%d %d %02x %02x %02x %02x %02x %02x %02x %02x\n",
-// demux->zvideo.size, demux->zdata.size,
-// demux->zvideo.buffer[0], demux->zvideo.buffer[1],
-// demux->zvideo.buffer[2], demux->zvideo.buffer[3],
-// demux->zvideo.buffer[4], demux->zvideo.buffer[5],
-// demux->zvideo.buffer[6], demux->zvideo.buffer[7]);
-
-#ifdef DATA_DUMP
-if( !video_fp ) {
- video_fp = new FILE*[65536];
- memset(video_fp,0,65536*sizeof(FILE*));
-}
-if( !video_fp[pid] ) {
- char fn[512];
- sprintf(fn,"/tmp/dat/v%04x.mpg",pid);
- video_fp[pid] = fopen(fn,"w");
-}
-if( video_fp[pid] ) {
- if( demux->zvideo.size )
- fwrite(demux->zvideo.buffer, demux->zvideo.size, 1, video_fp[pid]);
- else if( demux->zdata.size )
- fwrite(demux->zdata.buffer, demux->zdata.size, 1, video_fp[pid]);
-}
-#endif
-
- /* Append demuxed data to track buffer */
- if( demux->zvideo.size )
- demuxer->append_data(demux->zvideo.buffer, demux->zvideo.size);
- else if( demux->zdata.size )
- demuxer->append_data(demux->zdata.buffer, demux->zdata.size);
- if( demux->pes_video_pid == pid && demux->pes_video_time >= 0 ) {
- demuxer->pes_video_time = demux->pes_video_time;
- demux->pes_video_time = -1.;
- }
-#if 0
- if( !test_file ) test_file = fopen("/tmp/test.m2v", "w");
- if( demuxer->zdata.position > 0 ) fwrite(demuxer->zdata.buffer,
- demuxer->zdata.position, 1, test_file);
-#endif
-
- handle_video_data(track_number, prev_data_size);
- demuxer->shift_data();
- return 0;
-}
-
-void zmpeg3_t::
-handle_subtitle()
-{
- for( int i=0; i<total_stracks; ++i ) {
- strack_t *strk = get_strack(i);
- while( strk->total_subtitles ) {
- subtitle_t *subtitle = strk->subtitles[0];
- strk->append_subtitle_offset(subtitle->offset);
- strk->del_subtitle(subtitle);
- }
- }
-}
-
-void zmpeg3_t::
-handle_cell(int cell_no)
-{
- int idx;
- cell_time = -1.;
-
-//zmsgs("cell %d\n", cell_no);
- for( idx=0; idx<total_vtracks; ++idx ) {
- zvtrack_t *vtrk = vtrack[idx];
- zvideo_t *vid = vtrk->video;
- if( !vid ) continue;
- double pts = vtrk->get_video_time();
-//zmsgs(" vtrack %d = %f\n", idx, pts);
- if( cell_time < pts ) cell_time = pts;
- }
- for( idx=0; idx<total_atracks; ++idx ) {
- zatrack_t *atrk = atrack[idx];
- zaudio_t *aud = atrk->audio;
- if( !aud ) continue;
- double pts = atrk->get_audio_time();
-//zmsgs(" atrack %d = %f\n", idx, pts);
- if( cell_time < pts ) cell_time = pts;
- }
-
- zcell_t *cell = 0;
- if( !demuxer->get_cell(cell_no, cell) )
- cell->cell_time = cell_time;
- if( pts_padding <= 0 ) return;
-
- int discon = cell ? cell->discontinuity : 0;
-//zmsgs("cell %d cell_time=%f pos="_LX" discon %d\n",
-// cell_no, cell_time, !cell? -1 : cell->program_start, discon);
- if( !discon ) return;
-
- for( idx=0; idx<total_vtracks; ++idx ) {
- zvtrack_t *vtrk = vtrack[idx];
- zvideo_t *vid = vtrk->video;
- if( !vid ) continue;
- if( !vtrk->total_frame_offsets ) continue;
- vtrk->video_time = cell_time;
- vid->framenum = vtrk->pts_position = vtrk->total_frame_offsets-1;
- if( vid->framenum >= 0 ) {
- int64_t prev_frame_offset = vtrk->frame_offsets[vid->framenum];
- while( vid->video_pts_padding() ) {
- vtrk->append_frame(prev_frame_offset, 0);
- vid->framenum = vtrk->total_frame_offsets-1;
- }
- }
- if( discon ) {
- vtrk->reset_pts();
- vtrk->pts_offset = cell_time;
- if( discon < 0 ) vtrk->pts_starttime = 0.;
- }
- }
-
- for( idx=0; idx<total_atracks; ++idx ) {
- zatrack_t *atrk = atrack[idx];
- zaudio_t *aud = atrk->audio;
- if( !aud ) continue;
- atrk->audio_time = cell_time;
- atrk->pts_position = aud->audio_position();
- while( aud->audio_pts_padding() ) {
- if( update_index(idx, 0) )
- atrk->prev_offset = atrk->curr_offset;
- }
- if( discon ) {
- atrk->reset_pts();
- atrk->pts_offset = cell_time;
- if( discon < 0 ) atrk->pts_starttime = 0.;
- }
- }
-}
-
-int zmpeg3_t::
-handle_nudging()
-{
- int i, n, atrk, vtrk;
- int ret = 0;
- for( i=0; i<total_atracks; ++i )
- atrack[i]->nudge = 0;
-
- int total_channels = dvb.channel_count();
-#if 1
-// lines up first apts/vpts
- for( n=0; n<total_channels; ++n ) {
- int astreams, vstreams;
- dvb.total_vstreams(n, vstreams);
- double apts = -1., vpts = -1.;
- for( i=0; i<vstreams; ++i ) {
- dvb.vstream_number(n, i, vtrk);
- if( vtrack[vtrk]->pts_origin > vpts )
- vpts = vtrack[vtrk]->pts_origin;
- }
- dvb.total_astreams(n, astreams);
- for( i=0; i<astreams; ++i ) {
- dvb.astream_number(n, i, atrk);
- double samplerate = sample_rate(atrk);
- if( samplerate < 0. ) samplerate = 0.;
- apts = atrack[atrk]->pts_origin;
- if( apts >= 0. && vpts >= 0. ) {
- atrack[atrk]->nudge = (long)((vpts - apts) * samplerate);
- ++ret;
- }
- }
- }
-#else
-// lines up nearest apts/vpts
- class elem_t {
- public:
- elem_t *next; int vtrk, atrk;
- double apts, vpts, pts_nudge;
- uint64_t apos, vpos, pts_dist;
- elem_t(elem_t *p, int vtrk, int atrk)
- : next(p), vtrk(vtrk), atrk(atrk) {
- apos = vpos = 0; apts = vpts = 0.;
- pts_dist = ~0; pts_nudge = 0;
- }
- } *ep, *elems = 0;
- // collect all vtrk[0]-atrk[i] associations
- for( n=0; n<total_channels; ++n ) {
- int astreams, vstreams;
- dvb.total_vstreams(n, vstreams);
- if( vstreams <= 0 ) continue;
- dvb.vstream_number(n, 0, vtrk);
- if( vtrk < 0 || vtrk >= total_vtracks ) continue;
- dvb.total_astreams(n, astreams);
- for( i=0; i<astreams; ++i ) {
- dvb.astream_number(n, i, atrk);
- if( atrk < 0 || atrk >= total_atracks ) continue;
- elems = new elem_t(elems, vtrk, atrk);
- }
- }
-
- demuxer->pes_audio_time = -1.;
- demuxer->pes_video_time = -1.;
- demuxer->seek_byte(START_BYTE);
-
- // probe for atrk/vtrk pts nearest to each other in file
- while( !demuxer->titles[0]->fs->eof() ) {
- int64_t pos = demuxer->absolute_position();
- if( pos > START_BYTE + MAX_TS_PROBE ) break;
- if( demuxer->read_next_packet() ) break;
- ep = 0;
- if( demuxer->pes_audio_time >= 0 ) {
- for( ep=elems; ep && atrack[ep->atrk]->pid!=demuxer->pid; ep=ep->next );
- if( ep ) { ep->apos = pos; ep->apts = demuxer->pes_audio_time; }
- demuxer->pes_audio_time = -1.;
- }
- if( demuxer->pes_video_time >= 0 ) {
- for( ep=elems; ep && vtrack[ep->vtrk]->pid!=demuxer->pid; ep=ep->next );
- if( ep ) { ep->vpos = pos; ep->vpts = demuxer->pes_video_time; }
- demuxer->pes_video_time = -1.;
- }
- if( !ep || !ep->apos || !ep->vpos ) continue;
- int64_t dist = ep->apos - ep->vpos;
- if( dist < 0 ) dist = -dist;
- if( (uint64_t)dist < ep->pts_dist ) {
- ep->pts_dist = dist;
- ep->pts_nudge = ep->vpts - ep->apts;
- }
- }
-
- // nudge audio to align timestamps
- while( elems ) {
- ep = elems; elems = elems->next;
-//zmsgs("v/atrk %d/%d, dist " _LD "\n", ep->vtrk, ep->atrk, ep->pts_dist);
-//zmsgs(" v/apts %f/%f, nudge %f\n", ep->vpts, ep->apts, ep->pts_nudge);
-//zmsgs(" v/aorg %f/%f, nudge %f\n",
-// vtrack[ep->vtrk]->pts_origin, atrack[ep->atrk]->pts_origin,
-// vtrack[ep->vtrk]->pts_origin-atrack[ep->atrk]->pts_origin);
- double samplerate = sample_rate(ep->atrk);
- if( samplerate < 0. ) samplerate = 0.;
- if( ep->apts >= 0. && ep->vpts >= 0. ) {
- atrack[ep->atrk]->nudge = (long)(ep->pts_nudge * samplerate);
- ++ret;
- }
- delete ep;
- }
-#endif
- return ret;
-}
-
-int zmpeg3_t::
-do_toc(int64_t *bytes_processed)
-{
- /* Starting byte before our packet read */
- int64_t start_byte = demuxer->tell_byte();
-//zmsgs("%d offset=%llx file_type=%x\n", __LINE__,
-// start_byte, file_type);
- int result = demuxer->seek_phys();
- if( !result ) {
- int cell_no = demuxer->current_cell_no();
- if( last_cell_no != cell_no )
- handle_cell(last_cell_no=cell_no);
- result = demuxer->read_next_packet();
- }
-//zmsgs("%d %d %llx\n", __LINE__, result, demuxer->tell_byte());
- /* if(start_byte > 0x1b0000 && start_byte < 0x1c0000) */
-//zmsgs("1 start_byte=%llx custum_id=%x got_audio=%d got_video=%d"
-// " zaudio.size=%d zvideo.size=%d zdata.size=%d\n", start_byte,
-// demuxer->custom_id, demuxer->got_audio, demuxer->got_video,
-// demuxer->zaudio.size, demuxer->zvideo.size, demuxer->zdata.size);
- if( !result ) {
- int idx = 0;
- /* Find current PID in tracks. */
- int custom_id = demuxer->custom_id;
- /* Got subtitle */
- if( demuxer->got_subtitle )
- handle_subtitle();
- if( is_transport_stream() )
- dvb.atsc_tables(demuxer, custom_id);
- /* In a transport stream the audio or video is determined by the PID. */
- /* In other streams the data type is determined by stream ID. */
- if( demuxer->got_audio || is_transport_stream() || is_audio_stream() ) {
- atrack_t *atrk = 0;
- for( idx=0; idx < total_atracks; ++idx ) {
- if( atrack[idx]->pid == custom_id ) { /* Update an audio track */
- atrk = atrack[idx];
- break;
- }
- }
- if( !atrk ) {
- if( is_audio_stream() ||
- (demuxer->got_audio && demuxer->astream_table[custom_id]) ) {
- int format = demuxer->astream_table[custom_id];
- atrk = new_atrack_t(custom_id, format, demuxer, total_atracks);
- if( atrk ) {
- atrack[idx=total_atracks++] = atrk;
- atrk->prev_offset = start_byte;
- }
- }
- }
- if( atrk ) {
- atrk->curr_offset = start_byte;
- atrk->handle_audio(idx);
- }
- }
- if( demuxer->got_video || is_transport_stream() || is_video_stream() ) {
- vtrack_t *vtrk = 0;
- for( idx=0; idx < total_vtracks; ++idx ) {
- if( vtrack[idx]->pid == custom_id ) { /* Update a video track */
- vtrk = vtrack[idx];
- break;
- }
- }
- if( !vtrk ) {
- if( is_video_stream() ||
- (demuxer->got_video && demuxer->vstream_table[custom_id]) ) {
- vtrk = new_vtrack_t(custom_id, demuxer, total_vtracks);
- /* Make the first offset correspond to the */
- /* start of the first packet. */
- if( vtrk ) {
- vtrack[total_vtracks++] = vtrk;
- vtrk->tcode = ~0;
- vtrk->prev_frame_offset = -1;
- vtrk->curr_offset = start_byte;
- if( thumbnail_fn )
- vtrk->video->thumb = vtrk->video->skim = 1;
- }
- }
- }
- if( vtrk ) {
- vtrk->prev_offset = vtrk->curr_offset;
- vtrk->curr_offset = start_byte;
- vtrk->handle_video(idx);
- }
- }
- }
- /* Make user value independant of data type in packet */
- *bytes_processed = demuxer->tell_byte();
-//zmsgs("1000 "_LX"\n", *bytes_processed);
- return 0;
-}
-
-void zmpeg3_t::
-stop_toc()
-{
- delete_slice_decoders();
- if( !is_ifo_file() ) {
- int64_t total_bytes = demuxer->tell_byte();
- demuxer->end_title(total_bytes);
- }
- /* Create final chunk for audio tracks to count the last samples. */
- int i, j, k;
- atrack_t *atrk;
- index_t *idx;
- /* Flush audio indexes */
- for( i=0; i < total_atracks; ++i )
- update_index(i, 1);
- for( i=0; i < total_atracks; ++i ) {
- atrk = atrack[i];
- atrk->append_samples(atrk->curr_offset);
- }
-
- /* Make all indexes the same scale */
- int max_scale = 1;
- for( i=0; i < total_atracks; ++i ) {
- atrk = atrack[i];
- idx = indexes[i];
- if( idx->index_data && idx->index_zoom > max_scale )
- max_scale = idx->index_zoom;
- }
- for( i=0; i < total_atracks; ++i ) {
- atrk = atrack[i];
- idx = indexes[i];
- if( idx->index_data && idx->index_zoom < max_scale ) {
- while( idx->index_zoom < max_scale )
- divide_index(i);
- }
- }
- /* delete vtracks with no frames */
- for( i=0; i < total_vtracks; ) {
- if( !vtrack[i]->total_frame_offsets ) {
- demuxer->vstream_table[vtrack[i]->pid] = 0;
- delete vtrack[i];
- --total_vtracks;
- for( j=i; j < total_vtracks; ++j )
- vtrack[j] = vtrack[j+1];
- continue;
- }
- ++i;
- }
- for( i=0; i < MAX_STREAMZ; ++i ) {
- if( demuxer->vstream_table[i] ) {
- for( j=total_vtracks; --j>=0; )
- if( vtrack[j]->pid == i ) break;
- if( j < 0 )
- demuxer->vstream_table[i] = 0;
- }
- }
- /* delete atracks with no samples */
- for( i=0; i < total_atracks; ) {
- if( !atrack[i]->total_sample_offsets || atrack[i]->format == afmt_IGNORE ) {
- demuxer->astream_table[atrack[i]->pid] = 0;
- delete atrack[i]; delete indexes[i];
- --total_atracks; --total_indexes;
- for( j=i; j < total_atracks; ++j ) {
- indexes[j] = indexes[j+1];
- atrack[j] = atrack[j+1];
- }
- continue;
- }
- ++i;
- }
- for( i=0; i < MAX_STREAMZ; ++i ) {
- if( demuxer->astream_table[i] ) {
- for( j=total_atracks; --j>=0; )
- if( atrack[j]->pid == i ) break;
- if( j < 0 )
- demuxer->astream_table[i] = 0;
- }
- }
- /* Sort tracks by PID */
- int done = 0;
- while( !done ) {
- done = 1;
- for( i=1; i < total_atracks; ++i ) {
- atrack_t *atrk0 = atrack[i - 0];
- atrack_t *atrk1 = atrack[i - 1];
- if( atrk1->pid > atrk0->pid ) {
- atrack[i - 1] = atrk0;
- atrack[i - 0] = atrk1;
- index_t *idx0 = indexes[i - 0];
- index_t *idx1 = indexes[i - 1];
- indexes[i - 1] = idx0;
- indexes[i - 0] = idx1;
- done = 0;
- }
- }
- }
- for( i=0; i < total_atracks; ++i )
- atrack[i]->number = i;
- done = 0;
- while( !done ) {
- done = 1;
- for( i=1; i < total_vtracks; ++i ) {
- vtrack_t *vtrk0 = vtrack[i - 0];
- vtrack_t *vtrk1 = vtrack[i - 1];
- if( vtrk1->pid > vtrk0->pid ) {
- vtrack[i - 1] = vtrk0;
- vtrack[i - 0] = vtrk1;
- done = 0;
- }
- }
- }
- for( i=0; i < total_vtracks; ++i )
- vtrack[i]->number = i;
-
- if( is_transport_stream() )
- handle_nudging();
-
- demuxer->read_all = 0;
-
- /* Output toc to file */
- /* Write file type */
- fputc('T', toc_fp);
- fputc('O', toc_fp);
- fputc('C', toc_fp);
- fputc(' ', toc_fp);
- /* Write version */
- PUT_INT32(TOC_VERSION);
- /* Write program */
- PUT_INT32(toc_SRC_PROGRAM);
- PUT_INT32(vts_title);
- PUT_INT32(total_vts_titles);
- PUT_INT32(angle*10 + interleave);
- PUT_INT32(total_interleaves);
- /* Write stream type */
- if( is_program_stream() )
- PUT_INT32(toc_FILE_TYPE_PROGRAM);
- else if( is_transport_stream() )
- PUT_INT32(toc_FILE_TYPE_TRANSPORT);
- else if( is_audio_stream() )
- PUT_INT32(toc_FILE_TYPE_AUDIO);
- else if( is_video_stream() )
- PUT_INT32(toc_FILE_TYPE_VIDEO);
- /* Store file information */
- PUT_INT32(toc_FILE_INFO);
- char *path = fs->path;
- fprintf(toc_fp, "%s", path);
- for( j=strlen(path); j < STRLEN; ++j ) fputc(0, toc_fp);
- source_date = calculate_source_date(path);
- PUT_INT64(source_date);
- /* Write stream ID's */
- /* Only program and transport streams have these */
- for( i=0; i < MAX_STREAMZ; ++i ) {
- if( demuxer->astream_table[i] ) {
- PUT_INT32(toc_STREAM_AUDIO);
- PUT_INT32(i);
- PUT_INT32(demuxer->astream_table[i]);
- }
- if( demuxer->vstream_table[i] ) {
- PUT_INT32(toc_STREAM_VIDEO);
- PUT_INT32(i);
- PUT_INT32(demuxer->vstream_table[i]);
- }
- }
- /* Write titles */
- for( i=0; i < demuxer->total_titles; ++i ) {
- demuxer_t::title_t *title = demuxer->titles[i];
- /* Path */
- PUT_INT32(toc_TITLE_PATH);
- path = !is_program_stream() ? path : title->fs->path;
- fprintf(toc_fp, "%s", path);
- for( j=strlen(path); j < STRLEN; ++j ) fputc(0, toc_fp);
- /* Total bytes */
- PUT_INT64(title->total_bytes);
- /* Total cells in title */
- PUT_INT32(demuxer->titles[i]->cell_table_size);
- for( j=0; j < title->cell_table_size; ++j ) {
- demuxer_t::title_t::cell_t *cell = &title->cell_table[j];
-//zmsgs("%x: %llx-%llx %llx-%llx %d %d %d\n",
-// ftell(toc_fp), cell->title_start, cell->title_end,
-// cell->program_start, cell->program_end, cell->cell_no,
-// cell->program, cell->discontinuity);
- PUT_INT64(cell->title_start);
- PUT_INT64(cell->title_end);
- PUT_INT64(cell->program_start);
- PUT_INT64(cell->program_end);
- union { double d; uint64_t u; } cell_time;
- cell_time.d = cell->cell_time;
- PUT_INT64(cell_time.u);
- PUT_INT32(cell->cell_no);
- PUT_INT32(cell->discontinuity);
- }
- }
- PUT_INT32(toc_ATRACK_COUNT);
- PUT_INT32(total_atracks);
- /* Audio streams */
- for( j=0; j < total_atracks; ++j ) {
- atrack_t *atrk = atrack[j];
- PUT_INT64(atrk->audio_eof);
- PUT_INT32(atrk->channels);
- PUT_INT32(atrk->nudge);
- PUT_INT32(atrk->total_sample_offsets);
- /* Total samples */
- PUT_INT64(atrk->current_position);
- /* Sample offsets */
- for( i=0; i < atrk->total_sample_offsets; ++i )
- PUT_INT64(atrk->sample_offsets[i]);
- /* Index */
- index_t *idx = indexes[j];
- if( idx->index_data ) {
- PUT_INT32(idx->index_size);
- PUT_INT32(idx->index_zoom);
- for( k=0; k < atrk->channels; ++k ) {
- fwrite(idx->index_data[k], 2*sizeof(float),
- idx->index_size, toc_fp);
- }
- }
- else {
- PUT_INT32(0);
- PUT_INT32(1);
- }
- }
- PUT_INT32(toc_VTRACK_COUNT);
- PUT_INT32(total_vtracks);
- /* Video streams */
- for( j=0; j < total_vtracks; ++j ) {
- vtrack_t *vtrk = vtrack[j];
- PUT_INT64(vtrk->video_eof);
- PUT_INT32(vtrk->total_frame_offsets);
- for( i=0; i < vtrk->total_frame_offsets; ++i )
- PUT_INT64(vtrk->frame_offsets[i]);
- PUT_INT32(vtrk->total_keyframe_numbers);
- for( i=0; i < vtrk->total_keyframe_numbers; ++i )
- PUT_INT32(vtrk->keyframe_numbers[i]);
- }
- PUT_INT32(toc_STRACK_COUNT);
- PUT_INT32(total_stracks);
- /* Subtitle tracks */
- for( i=0; i < total_stracks; ++i ) {
- strack_t *strk = strack[i];
- PUT_INT32(strk->id);
- PUT_INT32(strk->total_offsets);
- for(j = 0; j < strk->total_offsets; j++)
- PUT_INT64(strk->offsets[j]);
- }
- PUT_INT32(toc_IFO_PALETTE);
- for( i=0; i < 16*4; ++i )
- fputc(palette[i], toc_fp);
- if( playinfo ) {
- PUT_INT32(toc_IFO_PLAYINFO);
- PUT_INT32(playinfo->total_cells);
- icell_t *cell = &playinfo->cells[0];
- for( i=playinfo->total_cells; --i>=0; ++cell ) {
- PUT_INT64(cell->start_byte);
- PUT_INT64(cell->end_byte);
- PUT_INT32(cell->vob_id);
- PUT_INT32(cell->cell_id);
- PUT_INT32(cell->inlv);
- PUT_INT32(cell->discon);
- }
- }
-
- fs->close_file();
- fclose(toc_fp);
- delete this;
-}
-
-int zmpeg3_t::
-show_toc(int flags)
-{
- int i, j, k;
- int64_t current_byte = 0;
-
- fs->seek(0);
- fs->read_uint32();
- uint32_t toc_version = fs->read_uint32();
- if( toc_version != TOC_VERSION ) {
- zmsgs("invalid TOC version %08x (should be %08x)\n",
- toc_version, TOC_VERSION);
- return ERR_INVALID_TOC_VERSION;
- }
-
- while( !fs->eof() ) {
- /* Get section type */
- int section_type = fs->read_uint32();
- switch( section_type ) {
- case toc_FILE_TYPE_PROGRAM:
- zmsg("is_program_stream\n");
- break;
-
- case toc_FILE_TYPE_TRANSPORT:
- zmsg("is_transport_stream\n");
- break;
-
- case toc_FILE_TYPE_AUDIO:
- zmsg("is_audio_stream\n");
- break;
-
- case toc_FILE_TYPE_VIDEO:
- zmsg("is_video_stream\n");
- break;
-
- case toc_FILE_INFO: {
- char string[STRLEN];
- char string2[STRLEN];
- fs->read_data((uint8_t*)&string[0],STRLEN);
- concat_path(string2, fs->path, string);
- int64_t sdate = fs->read_uint64();
- zmsgs("zsrc=%s source_date="_LD"\n", string2, sdate);
- break; }
-
- case toc_STREAM_AUDIO: {
- static const char *afmts[] = {
- "unknown", "mpeg", "ac3", "pcm", "aac", "jesus",
- };
- int n = fs->read_uint32();
- int fmt = fs->read_uint32();
- if( fmt < 0 || fmt >= lengthof(afmts) ) fmt = 0;
- zmsgs(" audio stream 0x%04x is %s\n", n, afmts[fmt]);
- break; }
-
- case toc_STREAM_VIDEO: {
- int n = fs->read_uint32();
- fs->read_uint32();
- zmsgs(" video stream 0x%04x\n", n);
- break; }
-
-
- case toc_ATRACK_COUNT: {
- zmsg("\n");
- int atracks = fs->read_uint32();
- zmsgs("audio tracks = %d\n", atracks);
- for( i=0; i < atracks; ++i ) {
- int64_t eof = fs->read_uint64();
- int channels = fs->read_uint32();
- int nudge = fs->read_uint32();
- int total_sample_offsets = fs->read_uint32();
- int64_t total_samples = fs->read_uint64();
- zmsgs(" audio %d, eof=0x" _LXv(012) " ch=%d, offsets=%d samples=" _LD " nudge=%d\n",
- i, eof, channels, total_sample_offsets, total_samples, nudge);
- if( flags & show_toc_SAMPLE_OFFSETS ) {
- for( j=0; j < total_sample_offsets; ) {
- if( !(j&7) ) zmsgs(" %8d: ",j*AUDIO_CHUNKSIZE);
- printf(" " _LXv(08), fs->read_uint64());
- if( !(++j&7) ) printf("\n");
- }
- if( (j&7) ) printf("\n");
- }
- else
- fs->seek_relative(sizeof(int64_t) * total_sample_offsets);
- int index_size = fs->read_uint32();
- int index_zoom = fs->read_uint32();
- zmsgs(" index_size=%d index_zoom=%d\n", index_size, index_zoom);
- for( j=0; j < channels; ++j ) {
- if( flags & show_toc_AUDIO_INDEX ) {
- zmsgs("audio track %d, channel %d\n",i,j);
- for( k=0; k<index_size; ) {
- union { int i; float f; } min, max;
- min.i = bswap_32(fs->read_uint32());
- max.i = bswap_32(fs->read_uint32());
- if( !(k&3) ) zmsgs(" %08x: ",k*index_zoom);
- printf(" %5.3f/%-5.3f",min.f,max.f);
- if( !(++k&3) ) printf("\n");
- }
- if( (k&3) ) printf("\n");
- }
- else
- fs->seek_relative(sizeof(float) * index_size * 2);
- }
- }
- break; }
-
- case toc_VTRACK_COUNT: {
- zmsg("\n");
- int vtracks = fs->read_uint32();
- zmsgs("video tracks = %d\n", vtracks);
- for( i=0; i < vtracks; ++i ) {
- int64_t eof = fs->read_uint64();
- int total_frame_offsets = fs->read_uint32();
- if( flags & show_toc_FRAME_OFFSETS ) {
- int64_t *frame_offsets = new int64_t[total_frame_offsets];
- for( k=0; k<total_frame_offsets; ++k ) {
- frame_offsets[k] = fs->read_uint64();
- }
- int total_keyframes = fs->read_uint32();
- zmsgs(" video %d, eof=0x" _LXv(012) " offsets=%d keyframes=%d\n",
- i, eof, total_frame_offsets, total_keyframes);
- int *keyframe_numbers = new int[total_keyframes];
- for( j=0; j<total_keyframes; ++j ) {
- keyframe_numbers[j] = fs->read_uint32();
- }
- for( j=k=0; k<total_frame_offsets; ) {
- if( !(k&7) ) zmsgs(" %8d: ",k);
- if( k >= keyframe_numbers[j] ) {
- printf(" *"); ++j;
- }
- else
- printf(" ");
- printf(_LXv(08),frame_offsets[k]);
- if( !(++k&7) ) printf("\n");
- }
- if( (k&7) ) printf("\n");
- delete [] keyframe_numbers;
- delete [] frame_offsets;
- }
- else {
- fs->seek_relative(sizeof(int64_t) * total_frame_offsets);
- int total_keyframes = fs->read_uint32();
- zmsgs(" video %d, eof=0x" _LXv(012) " offsets=%d keyframes=%d\n",
- i, eof, total_frame_offsets, total_keyframes);
- fs->seek_relative(sizeof(int) * total_keyframes);
- }
- }
- break; }
-
- case toc_STRACK_COUNT: {
- total_stracks = fs->read_uint32();
- for( i=0; i < total_stracks; ++i ) {
- int id = fs->read_uint32();
- int total_offsets = fs->read_uint32();
- for( j=0; j < total_offsets; ++j ) {
- fs->read_uint64();
- }
- zmsgs(" subtitle %d, id=0x%04x offsets=%d\n",
- i, id, total_offsets);
- }
- break; }
-
- case toc_TITLE_PATH: {
- char string[STRLEN];
- fs->read_data((uint8_t*)string, STRLEN);
- int64_t total_bytes = fs->read_uint64();
- int64_t start_byte = current_byte;
- int64_t end_byte = start_byte + total_bytes;
- current_byte = end_byte;
- zmsgs("title %s,\n", &string[0]);
- zmsgs(" bytes=0x" _LXv(012) ", start=0x" _LXv(012) ", end=0x" _LXv(012) "\n",
- total_bytes, start_byte, end_byte);
- int cell_table_size = fs->read_uint32();
- for( i=0; i < cell_table_size; ++i ) {
- int64_t title_start = fs->read_uint64();
- int64_t title_end = fs->read_uint64();
- int64_t program_start = fs->read_uint64();
- int64_t program_end = fs->read_uint64();
- union { double d; uint64_t u; } cell_time;
- cell_time.u = fs->read_uint64();
- int cell_no = fs->read_uint32();
- int discontinuity = fs->read_uint32();
- zmsgs(" cell[%2d], title 0x" _LXv(012) "-0x" _LXv(012) ", cell_no %2d, cell_time %5.3f\n",
- i, title_start, title_end, cell_no, cell_time.d);
- zmsgs(" discon %d program 0x" _LXv(012) "-0x" _LXv(012) "\n",
- discontinuity, program_start, program_end);
- }
- break; }
-
- case toc_IFO_PALETTE:
- zmsg("\n");
- zmsg("palette\n");
- for( i=0; i<16/4; ++i ) {
- uint32_t rgb0 = fs->read_uint32();
- uint32_t rgb1 = fs->read_uint32();
- uint32_t rgb2 = fs->read_uint32();
- uint32_t rgb3 = fs->read_uint32();
- zmsgs(" 0x%08x 0x%08x 0x%08x 0x%08x\n", rgb0, rgb1, rgb2, rgb3);
- }
- break;
-
- case toc_IFO_PLAYINFO: {
- zmsg("\n");
- int ncells = fs->read_uint32();
- zmsgs("playcells %d\n", ncells);
- for( i=0; i<ncells; ++i) {
- int64_t start_byte = fs->read_uint64();
- int64_t end_byte = fs->read_uint64();
- int vob_id = fs->read_uint32();
- int cell_id = fs->read_uint32();
- int inlv = fs->read_uint32();
- int discon = fs->read_uint32();
- zmsgs(" cell[%2d], start=0x" _LXv(012) ", end=0x" _LXv(012) " discon %d\n",
- i, start_byte, end_byte, discon);
- zmsgs(" vob_id %d, cell_id %d, inlv %d\n",
- vob_id, cell_id, inlv);
- }
- break;
- }
-
- case toc_SRC_PROGRAM: {
- int vtitl = fs->read_uint32();
- int vtotl = fs->read_uint32();
- int inlv = fs->read_uint32();
- int tinlv = fs->read_uint32();
- zmsgs("vts_title %d\n",vtitl);
- zmsgs("total_vts_title %d\n",vtotl);
- zmsgs("interleave/angle %d/%d\n",inlv%10,inlv/10);
- zmsgs("total_interleaves %d\n",tinlv);
- break;
- }
- }
- }
-
- return 0;
-}
-
projects / goodguy / history.git / blobdiff