Subversion Repositories Kolibri OS

#include 

#include 

#include 

#include 

#include 

#include 

#include 

#include "winlib/winlib.h"

#include "fplay.h"

volatile enum player_state decoder_state = PREPARE;

volatile enum player_state sound_state   = STOP;

extern int resampler_size;

extern int sample_rate;

{

    static vst_t vst;

    int i, ret;

    char *file_name, *dot;

    {

        vst.input_file = get_moviefile();

        if(vst.input_file == NULL)

        {

            printf("Please provide a movie file\n");

            return -1;

        }

    }

    else vst.input_file = argv[1];

    avdevice_register_all();

    av_register_all();

    {

        printf("Cannot open file %s\n\r", vst.input_file);

        return -1; // Couldn't open file

    };

    {

        printf("Cannot find streams\n\r");

        return -1;

    };

    dot = strrchr(file_name,'.');

    if(dot)

    {

        vst.input_name = malloc(dot-file_name+1);

        memcpy(vst.input_name, file_name, dot-file_name);

        vst.input_name[dot-file_name] = 0;

    }

    else vst.input_name = file_name;

    vst.aStream = -1;

    {

        if(vst.fCtx->streams[i]->codec->codec_type==AVMEDIA_TYPE_VIDEO

            && vst.vStream < 0)

        {

            vst.vStream = i;

            vst.video_time_base = vst.fCtx->streams[i]->time_base;

            if(stream_duration == 0)

               stream_duration = vst.fCtx->streams[i]->duration;

        }

           vst.aStream < 0)

        {

            vst.aStream = i;

            if(stream_duration == 0)

               stream_duration = vst.fCtx->streams[i]->duration;

        }

    }

    {

        printf("Video stream not detected\n\r");

        return -1; // Didn't find a video stream

    };

    INIT_LIST_HEAD(&vst.output_list);

    mutex_init(&vst.q_video.lock);

    mutex_init(&vst.q_audio.lock);

    mutex_init(&vst.gpu_lock);

    mutex_init(&vst.decoder_lock);

    mutex_init(&vst.input_lock);

    mutex_init(&vst.output_lock);

    vst.aCtx = vst.fCtx->streams[vst.aStream]->codec;

        return -1;

    vst.aCodec = avcodec_find_decoder(vst.aCtx->codec_id);

    if(vst.aCodec)

    {

        if(avcodec_open2(vst.aCtx, vst.aCodec, NULL) >= 0 )

        {

            WAVEHEADER       whdr;

            int fmt;

            int channels;

            vst.aCtx->sample_rate, vst.aCtx->channels, vst.aCtx->sample_fmt );

            whdr.riff_id = 0x46464952;

            whdr.riff_format = 0x45564157;

            whdr.wFormatTag = 0x01;

            whdr.nSamplesPerSec = vst.aCtx->sample_rate;

            whdr.nChannels = 2;

            whdr.wBitsPerSample = 16;

            {

                decoder_buffer = (uint8_t*)av_mallocz(192000*2+64);

                if( decoder_buffer != NULL )

                {

                    mutex_init(&astream.lock);

                    astream.count  = 0;

                    astream.buffer = (char *)av_mallocz(192000*3);

                    if( astream.buffer != NULL )

                        vst.has_sound = 1;

                    else

                        av_free(decoder_buffer);

                }

                if( vst.has_sound == 0)

                {

                        printf("Not enough memory for audio buffers\n");

                }

            }

        }

        else printf("Cannot open audio codec\n\r");

    }

    else printf("Unsupported audio codec!\n");

    create_thread(video_thread, &vst, 1024*1024);

    if(mutex_lock_timeout(&vst.decoder_lock, 3000) == 0)

        return -1;

           (AUDIO_THREAD | VIDEO_THREAD))

           delay(1);

        mutex_destroy(&astream.lock);

    mutex_destroy(&vst.q_video.lock);

    mutex_destroy(&vst.q_audio.lock);

    mutex_destroy(&vst.decoder_lock);

}

{

    AVPacket  packet;

    int err;

    if( err == 0)

    {

        if(packet.stream_index == vst->vStream)

            put_packet(&vst->q_video, &packet);

        else if( (packet.stream_index == vst->aStream) &&

                  (vst->has_sound != 0) )

        {

            put_packet(&vst->q_audio, &packet);

            if(vst->audio_timer_valid == 0 &&

               packet.pts != AV_NOPTS_VALUE )

            {

                vst->audio_timer_base = get_audio_base(vst) * packet.pts;

                vst->audio_timer_valid = 1;

            };

        }

        else av_free_packet(&packet);

    }

    else if (err != AVERROR_EOF)

        printf("av_read_frame: error %x\n", err);

}

{

    int err = 0;

    AVPacket  packet;

        err = load_frame(vst);

};

{

    AVPacket  packet;

    avcodec_flush_buffers(vst->aCtx);

    while( get_packet(&vst->q_video, &packet) != 0)

        av_free_packet(&packet);

        av_free_packet(&packet);

};

{

    int       eof;

    AVPacket  packet;

    int       ret, vret, aret;

    {

        int err;

        {

            case PREPARE:

                eof = fill_queue(vst);

                {

                    if( (vst->q_video.size < 4*1024*1024) &&

                        (eof == 0) )

                    {

                        eof = load_frame(vst);

                    }

                    decode_video(vst);

                    ret = decode_audio(vst->aCtx, &vst->q_audio);

                }while(astream.count < resampler_size*2 && ret == 1);

                decoder_state = PLAY;

                player_state  = PLAY;

                if( (vst->q_video.size < 4*1024*1024) &&

                    (eof == 0) )

                {

                    eof = load_frame(vst);

                }

                vret = decode_video(vst);

                aret = decode_audio(vst->aCtx, &vst->q_audio);

                ret = vret | aret;

                {

                    decoder_state = STOP;

                    continue;

                };

                {

                    if( (vst->q_video.size < 4*1024*1024) &&

                        (eof == 0) )

                    {

                        eof = load_frame(vst);

                        yield();

                        continue;

                    };

                    delay(1);

                    continue;

                }

                yield();

                continue;

                delay(1);

                continue;

                while(sound_state != STOP)

                    delay(1);

                    rewind_pos = vst->fCtx->start_time;

                else

                    rewind_pos = 0;

                                         rewind_pos, INT64_MAX, 0);

                break;

                while(sound_state != STOP)

                    yield();

                int opts = 0;

                if(rewind_pos < 0)

                {

                    rewind_pos = -rewind_pos;

                    opts = AVSEEK_FLAG_BACKWARD;

                };

                    rewind_pos += vst->fCtx->start_time;

                min_pos = rewind_pos - 1000000;

                max_pos = rewind_pos + 1000000;

                                         rewind_pos, INT64_MAX, 0);

                if (ret < 0)

                {

                    printf("could not seek to position %f\n",

                            (double)rewind_pos / AV_TIME_BASE);

                }

                decoder_state = PREPARE;

                break;

        }

    };

};