summaryrefslogtreecommitdiff
path: root/src/decoder.cc
diff options
context:
space:
mode:
Diffstat (limited to 'src/decoder.cc')
-rw-r--r--src/decoder.cc166
1 files changed, 145 insertions, 21 deletions
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 <config.h>
#ifdef USE_GUI
-
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <fcntl.h>
+#include <errno.h>
+#include <libraw1394/raw1394.h>
#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 */