From 067f68c8c6118e9f9241e4f0eb872aad4888dba0 Mon Sep 17 00:00:00 2001 From: deva Date: Wed, 13 Apr 2005 14:05:29 +0000 Subject: decoder rewritten for input throgh raw1394 instead of dv1394 (kernel bug in 2.6.x) --- src/decoder.cc | 166 +++++++++++++++++++++++++++++++++++++++++++++++++-------- 1 file changed, 145 insertions(+), 21 deletions(-) (limited to 'src/decoder.cc') diff --git a/src/decoder.cc b/src/decoder.cc index c7a4e50..fcbf136 100644 --- a/src/decoder.cc +++ b/src/decoder.cc @@ -22,8 +22,15 @@ */ #include #ifdef USE_GUI - +#include +#include +#include +#include +#include #include "decoder.h" +#include "debug.h" + +static AVCodecContext mycodec; Decoder::Decoder(Error* err, char *device, @@ -36,7 +43,7 @@ Decoder::Decoder(Error* err, volatile int *grunning) { errobj = err; - +device = ""; encode_sem = gencode_sem; player_sem = gplayer_sem; encode_queue = gencode_queue; @@ -49,6 +56,7 @@ Decoder::Decoder(Error* err, AVInputFormat *iformat; AVCodec *dec_codec; +/* memset(&dvpars, 0, sizeof(dvpars)); if(!(iformat = av_find_input_format("dv1394"))) { @@ -57,30 +65,33 @@ Decoder::Decoder(Error* err, return; } - dvpars.device = device; /* "/dev/dv1394"; */ + dvpars.device = device; // "/dev/dv1394"; dvpars.channel = channel; dvpars.standard = "pal"; - - if(av_open_input_file(&ifc, "", iformat, 0, &dvpars) < 0) { + memset(&dvpars, 0, sizeof(dvpars)); + dvpars.device = ""; + int err1; + if((err1 = av_open_input_file(&ifc, "file:///root/dvgrab-001.dv", iformat, 0, &dvpars)) < 0) { +fprintf(stderr, "Error in open: %d\n", err1); errobj->pushError("Device is in use."); fc = NULL; - return; +// return; } if(av_find_stream_info(ifc) < 0) { errobj->pushError("Could not find enough parameters."); fc = NULL; - return; +// return; } dump_format(ifc, 1, "", 0); - - if(!(dec_codec = avcodec_find_decoder(ifc->streams[0]->codec.codec_id))) { +*/ + if(!(dec_codec = avcodec_find_decoder(CODEC_ID_DVVIDEO/*ifc->streams[0]->codec.codec_id*/))) { errobj->pushError("Unsupported codec for input stream."); fc = NULL; return; } - if(avcodec_open(&ifc->streams[0]->codec, dec_codec) < 0) { + if(avcodec_open(&mycodec/*&ifc->streams[0]->codec*/, dec_codec) < 0) { errobj->pushError("Error while opening codec for input stream."); fc = NULL; return; @@ -95,22 +106,134 @@ Decoder::~Decoder() av_close_input_file(fc); } +static int raw_reader( raw1394handle_t handle, int channel, size_t length, quadlet_t *data ) +{ + /* skip empty packets */ + static char *framedata = NULL; +//printf("raw_reader\n"); fflush(stdout); + if ( length > 16 ) + { + unsigned char * p = ( unsigned char* ) & data[ 3 ]; + int section_type = p[ 0 ] >> 5; /* section type is in bits 5 - 7 */ + int dif_sequence = p[ 1 ] >> 4; /* dif sequence number is in bits 4 - 7 */ + int dif_block = p[ 2 ]; + + /* if we are at the beginning of a frame, we put the previous + frame in our output_queue. Then we try to get an unused + frame_buffer from the buffer_queue for the current frame. + We must lock the queues because they are shared between + this thread and the main thread. */ + if ( section_type == 0 && dif_sequence == 0 ) + { + if ( framedata != NULL ) + { + raw1394_set_userdata(handle, (void *)framedata); + framedata = NULL; + } + } + + if(!framedata) + { + framedata = (char *)malloc(DVPACKAGE_SIZE); // dvframe.h + if(!framedata) + { + /* We're fucked */ + exit(1); + } + } + + switch ( section_type ) + { + case 0: /* 1 Header block */ + /* p[3] |= 0x80; // hack to force PAL data */ + memcpy( framedata + dif_sequence * 150 * 80, p, 480 ); + break; + + case 1: /* 2 Subcode blocks */ + memcpy( framedata + dif_sequence * 150 * 80 + ( 1 + dif_block ) * 80, p, 480 ); + break; + + case 2: /* 3 VAUX blocks */ + memcpy( framedata + dif_sequence * 150 * 80 + ( 3 + dif_block ) * 80, p, 480 ); + break; + + case 3: /* 9 Audio blocks interleaved with video */ + memcpy( framedata + dif_sequence * 150 * 80 + ( 6 + dif_block * 16 ) * 80, p, 480 ); + break; + + case 4: /* 135 Video blocks interleaved with audio */ + memcpy( framedata + dif_sequence * 150 * 80 + ( 7 + ( dif_block / 15 ) + dif_block ) * 80, p, 480 ); + break; + + default: /* we can´t handle any other data */ + break; + } + } + return 0; +} + + void Decoder::decode() { + int port = 0; + int channel = 63; + int n_ports; + struct raw1394_portinfo pinf[ 16 ]; + raw1394handle_t handle; + handle = raw1394_new_handle(); + if ( !handle ) + { + fprintf( stderr, "raw1394 - failed to get handle: %s.\n", strerror( errno ) ); + exit( EXIT_FAILURE ); + } + + if ( ( n_ports = raw1394_get_port_info( handle, pinf, 16 ) ) < 0 ) + { + fprintf( stderr, "raw1394 - failed to get port info: %s.\n", strerror( errno ) ); + raw1394_destroy_handle( handle ); + exit( EXIT_FAILURE ); + } +printf("n_ports: %d\n", n_ports); + /* tell raw1394 which host adapter to use */ + if ( raw1394_set_port( handle, port ) < 0 ) + { + fprintf( stderr, "raw1394 - failed to set set port: %s.\n", strerror( errno ) ); + exit( EXIT_FAILURE ); + } + + raw1394_set_iso_handler( handle, channel, raw_reader); // 63 is default channel... sucks. + raw1394_set_userdata( handle, ( void* ) NULL); + printf("fisk: %d\n", raw1394_start_iso_rcv( handle, channel)); fflush(stdout); + +/* if(fc == NULL) { errobj->pushError("Decoder not initialized."); return; } - +*/ while(*running) { AVPacket pkt; uint8_t *ptr; int len; SDL_Event user_event; - av_read_packet(fc, &pkt); - len = pkt.size; +// av_read_packet(fc, &pkt); + + while(1) + { + raw1394_loop_iterate(handle); +//printf("-"); fflush(stdout); + pkt.data = (uint8_t *)raw1394_get_userdata(handle); + if(pkt.data) + { + raw1394_set_userdata(handle, NULL); + break; + } + } +printf("."); fflush(stdout); + len = pkt.size = DVPACKAGE_SIZE; ptr = pkt.data; + pkt.stream_index = 0; // NOTE: we only decode video, we only need the data from stream_index 0 // (stream 0: video, stream 1: audio) @@ -119,15 +242,15 @@ void Decoder::decode() int ret; int got_picture; // buf_t *buf = buf_alloc(); - FFFrame *fff = new FFFrame(); - DVFrame *dvf = new DVFrame(); - dvf->type = DVF_VIDEO; + FFFrame *fff = new FFFrame(); ALLOC(fff, "FFFrame in decode"); +// DVFrame *dvf = new DVFrame(); ALLOC(dvf, "DVFrame in decode"); +// dvf->type = DVF_VIDEO; - memcpy(dvf->frame, ptr, len); +// memcpy(dvf->frame, ptr, len); //printf("DVBufferSize: [%d]bytes\n", len); - ret = avcodec_decode_video(&fc->streams[0]->codec, + ret = avcodec_decode_video(&mycodec/*&fc->streams[0]->codec*/, fff->frame, &got_picture, ptr, len); if(ret < 0) { @@ -139,7 +262,7 @@ void Decoder::decode() ptr += ret; pthread_mutex_lock(mutex); - encode_queue->push(dvf); +// encode_queue->push(dvf); player_queue->push(fff); pthread_mutex_unlock(mutex); @@ -149,8 +272,9 @@ void Decoder::decode() user_event.user.code = 0; user_event.user.data1 = NULL; user_event.user.data2 = NULL; - SDL_PushEvent(&user_event); +// SDL_PushEvent(&user_event); } +free(ptr); /* // For later use, when audio must be implemented while(pkt.stream_index == 1 && len > 0) { @@ -169,7 +293,7 @@ void Decoder::decode() sem_post(encode_sem); } */ - av_free_packet(&pkt); +// av_free_packet(&pkt); FREE(&pkt); } /* Kick the others so they wake up with empty queues */ -- cgit v1.2.3