+++ /dev/null
-#include <stdio.h>
-#include <stdlib.h>
-
-
-#include "libzmpeg3.h"
-
-#define PACKET_SIZE 2048
-
-class multiplexer_t {
-public:
- int derivative;
- unsigned char packet_buffer[PACKET_SIZE];
- FILE *out_file;
-};
-
-class track_t {
-public:
- void *operator new(size_t n) {
- void *t = (void*) new char[n];
- memset(t,0,n);
- return t;
- }
- void operator delete(void *t,size_t n) {
- delete[](char*)t;
- }
- long bytes_decoded;
- long frames_decoded;
- long samples_decoded;
- mpeg3_t *file;
- FILE *raw_file;
- int stream_number;
- int end_of_data;
-};
-
-int write_pack_header(unsigned char *ptr,
- multiplexer_t *mplex,
- float seconds,
- int stream_id,
- int ac3)
-{
- int packet_length;
-// PACK START CODE
- *ptr++ = 0x00;
- *ptr++ = 0x00;
- *ptr++ = 0x01;
- *ptr++ = 0xba;
-
- if(mplex->derivative == 1)
- {
- unsigned long timestamp = (unsigned long)(seconds * 90000);
- *ptr = 0x20;
- *ptr++ |= ((timestamp & 0xc0000000) >> 29) | 1;
- *ptr++ = (timestamp & 0x3fc00000) >> 22;
- *ptr++ = ((timestamp & 0x003f8000) >> 14) | 1;
- *ptr++ = (timestamp & 0x00007f80) >> 7;
- *ptr++ = ((timestamp & 0x0000007f) << 1) | 1;
-
- *ptr++ = 0;
- *ptr++ = 0;
- *ptr++ = 0;
- }
- else
- if(mplex->derivative == 2)
- {
- *ptr = 0x40;
- }
-
- *ptr++ = 0x00;
- *ptr++ = 0x00;
- *ptr++ = 0x01;
- if(ac3)
- *ptr++ = 0xbd;
- else
- *ptr++ = stream_id;
-
-// Packet length
- packet_length = PACKET_SIZE - (ptr - mplex->packet_buffer) - 2;
- *ptr++ = (packet_length & 0xff00) >> 8;
- *ptr++ = packet_length & 0xff;
-
-// Pts/dts flags
- *ptr++ = 0x0f;
-
-// AC3 stream_id
- if(ac3)
- {
- *ptr++ = stream_id;
- *ptr++ = 0x00;
- *ptr++ = 0x00;
- *ptr++ = 0x00;
- }
-
- return PACKET_SIZE - (ptr - mplex->packet_buffer);
-}
-
-int write_packet(track_t *track,
- float start_time,
- float end_time,
- multiplexer_t *mplex,
- int stream_id,
- int ac3)
-{
- int result = 0;
-
- long bytes_needed = track->bytes_decoded - ftell(track->raw_file);
- long current_byte = 0;
-
- while(current_byte < bytes_needed)
- {
-// Write packet header
- float current_time = start_time + (float)current_byte / bytes_needed * (end_time - start_time);
- int packet_bytes = write_pack_header(mplex->packet_buffer,
- mplex,
- current_time,
- stream_id,
- ac3);
- unsigned char *ptr = mplex->packet_buffer + PACKET_SIZE - packet_bytes;
- /*int bytes_read =*/ fread(ptr, 1, packet_bytes, track->raw_file);
-
- result = !fwrite(mplex->packet_buffer, PACKET_SIZE, 1, mplex->out_file);
- current_byte += packet_bytes;
- }
- return result;
-}
-
-int main(int argc, char *argv[])
-{
- int streams = 0;
- int stream = 0;
- int result = 0;
- track_t *atracks[streams + 1];
- track_t *vtracks[streams + 1];
- int total_atracks = 0;
- int total_vtracks = 0;
- float frame_rate = 30000.0 / 1001.0;
- float sample_rate = 48000;
- long frames_decoded = 0;
- float *audio_temp = new float[1];
- long audio_temp_allocated = 0;
- float current_time = 0, previous_time = 0;
- int video_completed = 0;
- int audio_completed = 0;
- int i;
- int ac3 = 0;
- multiplexer_t mplex;
- char **path;
- char *output_path = 0;
- int old_percentage = 0;
-
- path = new char*[argc];
- mplex.derivative = 1;
- mplex.out_file = 0;
-
- if(argc < 4)
- {
- printf("Tiny MPLEX by Heroine Virtual Ltd.\n");
- printf("Usage: mplex [-a] <stream 1> <stream2> ... <output>\n");
- printf(" -a use ac3 packet headers\n");
- exit(1);
- }
-
- for(i = 1; i < argc; i++)
- {
- if(!strcmp(argv[i], "-a"))
- {
- ac3 = 1;
- }
- else
- if(i == argc - 1)
- {
- output_path = argv[i];
- }
- else
- {
- path[stream] = new char[strlen(argv[i])+1];
- strcpy(path[stream], argv[i]);
- streams++;
- stream++;
- }
- }
-
-// Open files
- for(stream = 0; stream < streams; stream++)
- {
- int is_audio, is_video;
- int error_return;
- mpeg3_t *file = mpeg3_open(path[stream], &error_return);
-
- if(!file)
- {
- printf("Couldn't open %s\n", path[stream]);
- result = 1;
- }
- else
- {
- is_audio = mpeg3_has_audio(file);
- is_video = mpeg3_has_video(file);
- mpeg3_set_cpus(file, 2);
-
- if(is_audio && is_video)
- {
- printf("%s: Can't multiplex a system stream.\n", path[stream]);
- result = 1;
- }
- else
- if(is_audio)
- {
- atracks[total_atracks] = new track_t();
- atracks[total_atracks]->file = file;
- sample_rate = mpeg3_sample_rate(file, 0);
- atracks[total_atracks]->raw_file = fopen(path[stream], "rb");
- atracks[total_atracks]->stream_number = total_atracks;
- total_atracks++;
- }
- else
- if(is_video)
- {
- vtracks[total_vtracks] = new track_t();
- vtracks[total_vtracks]->file = file;
- frame_rate = mpeg3_frame_rate(file, 0);
- vtracks[total_vtracks]->raw_file = fopen(path[stream], "rb");
- vtracks[total_vtracks]->stream_number = total_vtracks;
-// Get the first frame
- mpeg3_skip_video_frame(vtracks[total_vtracks]->file,0);
- total_vtracks++;
- }
- else
- {
- printf("%s: Has neither audio or video.\n", path[stream]);
- result = 1;
- }
- }
- }
-
- if(!result)
- {
- if(!total_vtracks)
- {
- printf("You must supply at least 1 video track.\n");
- result = 1;
- }
- }
-
-// Open output
- if(!result)
- if(!(mplex.out_file = fopen(output_path, "wb")))
- {
- printf("Couldn't open output file\n");
- result = 1;
- }
-
-// Write multiplexed stream
- if(!result)
- {
- while(!result && !(video_completed && audio_completed))
- {
- previous_time = current_time;
-// Want the frame to come before the audio that goes with it.
- for(stream = 0; stream < total_vtracks && !result; stream++)
- {
-// Decode a frame and write it
- track_t *track = vtracks[stream];
-
- if(!track->end_of_data)
- {
- int percentage;
- mpeg3_skip_video_frame(track->file,0);
- track->frames_decoded++;
- track->bytes_decoded = mpeg3_video_tell_byte(track->file,0);
- if(track->frames_decoded > frames_decoded)
- {
- frames_decoded = track->frames_decoded;
- current_time = (float)frames_decoded / frame_rate;
- }
-
- result = write_packet(track,
- previous_time,
- current_time,
- &mplex,
- 0xe0 | track->stream_number,
- 0);
- track->end_of_data = mpeg3_end_of_video(track->file, 0);
- percentage = (int)(mpeg3_video_tell_byte(track->file,0) * 100 /
- mpeg3_get_bytes(track->file));
- if(percentage - old_percentage >= 1)
- {
- printf("\t%d%% completed\r", percentage);
- old_percentage = percentage;
- }
- fflush(stdout);
- }
- }
-
-// Decode audio until the last frame is covered
- for(stream = 0; stream < total_atracks && !result; stream++)
- {
- track_t *track = atracks[stream];
-//printf("mplex decode audio 1\n");
- if(!track->end_of_data &&
- (track->samples_decoded < current_time * sample_rate ||
- video_completed))
- {
- if(!video_completed)
- {
- long samples_needed = (long)(current_time * sample_rate) - track->samples_decoded;
- if(audio_temp_allocated < samples_needed)
- {
- delete [] audio_temp;
- audio_temp = new float[samples_needed];
- audio_temp_allocated = samples_needed;
- }
-
- mpeg3_read_audio(track->file,
- audio_temp,
- 0,
- 0,
- samples_needed,
- 0);
- track->bytes_decoded = mpeg3_audio_tell_byte(track->file,0);
- if(!track->end_of_data) track->bytes_decoded -= 2048;
- track->samples_decoded += samples_needed;
- track->end_of_data = mpeg3_end_of_audio(track->file, 0);
- }
- else
- {
- track->bytes_decoded = mpeg3_get_bytes(track->file);
- track->end_of_data = 1;
- }
-
-//printf("mplex decode audio 2\n");
- result = write_packet(track,
- previous_time,
- current_time,
- &mplex,
- ac3 ? track->stream_number : (0xc0 | track->stream_number),
- ac3);
- }
- }
-
- for(stream = 0; stream < total_vtracks; stream++)
- {
- if(vtracks[stream]->end_of_data) video_completed++;
- }
- if(video_completed < total_vtracks) video_completed = 0;
-
- for(stream = 0; stream < total_atracks; stream++)
- {
- if(atracks[stream]->end_of_data) audio_completed++;
- }
- if(audio_completed < total_atracks) audio_completed = 0;
- }
- }
-
-// Close streams
- for(stream = 0; stream < total_atracks; stream++)
- {
- mpeg3_close(atracks[stream]->file);
- fclose(atracks[stream]->raw_file);
- delete atracks[stream];
- }
-
- for(stream = 0; stream < total_vtracks; stream++)
- {
- mpeg3_close(vtracks[stream]->file);
- fclose(vtracks[stream]->raw_file);
- delete vtracks[stream];
- }
-
- if(mplex.out_file) fclose(mplex.out_file);
-
- return result;
-}
-
-
projects / goodguy / history.git / blobdiff