WebSVN – Kolibri OS – Diff – /programs/media/Fplay/fplay.c

 #include "sound.h"
 #include "fplay.h"
+volatile enum player_state player_state  = STOP;
+volatile enum player_state decoder_state = PREPARE;
-volatile enum player_state player_state;
+volatile enum player_state sound_state   = STOP;
 int             have_sound = 0;
+uint8_t     *decoder_buffer;
+extern int resampler_size;
 uint8_t     *decoder_buffer;
 extern int sample_rate;
 char *movie_file;
     movie_file = argv[1];
     /* register all codecs, demux and protocols */
-//    av_log_set_level(AV_LOG_INFO);
+    av_log_set_level(AV_LOG_FATAL);
     avcodec_register_all();
         printf("Video stream not detected\n\r");
         return -1; // Didn't find a video stream
+    }
-    player_state = PLAY_INIT;
- //   __asm__ __volatile__("int3");
+  //   __asm__ __volatile__("int3");
     // Get a pointer to the codec context for the video stream
     pCodecCtx=pFormatCtx->streams[videoStream]->codec;
     return 0;
+}
-static int fill_queue()
 static int load_frame()
-    int eof = 0;
-    AVPacket  packet;
     while( !eof)
-    {
-        int err;
-//        __asm__ __volatile__("int3");
     AVPacket  packet;
-        if(q_video.size+q_audio.size < 2*1024*1024)
+    int err;
-            err = av_read_frame(pFormatCtx, &packet);
-            if( err < 0)
-            {
-                eof = 1;
-                if (err != AVERROR_EOF)
-                    printf("av_read_frame: error %x\n", err);
+    err = av_read_frame(pFormatCtx, &packet);
-                break;
     if( err == 0)
-            if(packet.stream_index==videoStream)
+    {
-                put_packet(&q_video, &packet);
+        if(packet.stream_index==videoStream)
             put_packet(&q_video, &packet);
-            else if( (packet.stream_index == audioStream) &&
+        else if( (packet.stream_index == audioStream) &&
-                 (have_sound != 0) )
+                  (have_sound != 0) )
+        {
-                put_packet(&q_audio, &packet);
+            put_packet(&q_audio, &packet);
-                if(audio_base == -1.0)
+            if(audio_base == -1.0)
+            {
-                    if (packet.dts != AV_NOPTS_VALUE)
+                if (packet.pts != AV_NOPTS_VALUE)
-                        audio_base = get_audio_base() * packet.dts;
+                    audio_base = get_audio_base() * packet.pts;
-//                    printf("audio base %f\n", audio_base);
-                };
-            }
+//                    printf("audio base %f\n", audio_base);
-            else
             };
-                av_free_packet(&packet);
+        }
-            };
+        else av_free_packet(&packet);
-        }
+    }
+    else if (err != AVERROR_EOF)
-        else break;
-    };
+        printf("av_read_frame: error %x\n", err);
-    return eof;
+    return err;
+}
-};
-void decoder()
-{
-    int       eof;
-    AVPacket  packet;
     int       ret;
-    eof = fill_queue();
-    while( player_state != CLOSED && !eof)
+static int fill_queue()
-    {
-        int err;
-//        __asm__ __volatile__("int3");
-        if( player_state == PAUSE )
-        {
-            delay(1);
-            continue;
-        };
+{
+    int err = 0;
-        if( player_state == REWIND )
-        {
- //           int64_t timestamp = 0;
- //           int stream_index = av_find_default_stream_index(pFormatCtx);
- //           __asm__ __volatile__("int3");
+    AVPacket  packet;
-            if (pFormatCtx->start_time != AV_NOPTS_VALUE)
-                rewind_pos += pFormatCtx->start_time;
-            printf("rewind %8"PRId64"\n", rewind_pos);
+//        __asm__ __volatile__("int3");
-            ret = avformat_seek_file(pFormatCtx, -1, INT64_MIN,
+    while( (q_video.size+q_audio.size < 2*1024*1024) &&
-                                     rewind_pos, INT64_MAX, 0);
+            !err )
-//            ret = avformat_seek_file(pFormatCtx, -1, 0,
-//                                 0, INT64_MAX, 0);
+        err = load_frame();
 //            __asm__ __volatile__("int3");
     return err;
             if (ret < 0)
-            {
-                printf("could not seek to position %f\n",
+};
-                        (double)rewind_pos / AV_TIME_BASE);
-            else
+static void flush_all()
+{
-            {
+    AVPacket  packet;
+    avcodec_flush_buffers(pCodecCtx);
+    avcodec_flush_buffers(aCodecCtx);
-                avcodec_flush_buffers(pCodecCtx);
+    while( get_packet(&q_video, &packet) != 0)
-                avcodec_flush_buffers(aCodecCtx);
+        av_free_packet(&packet);
-                while( get_packet(&q_video, &packet) != 0)
-                    av_free_packet(&packet);
+    while( get_packet(&q_audio, &packet)!= 0)
+        av_free_packet(&packet);
     flush_video();
-                while( get_packet(&q_audio, &packet)!= 0)
+    astream.count = 0;
+};
-                    av_free_packet(&packet);
-                audio_base = -1.0;
+void decoder()
-  //              __asm__ __volatile__("int3");
+{
-                eof = fill_queue();
+    int       eof;
-            };
-            yield();
     AVPacket  packet;
-            flush_video();
+    int       ret;
     int64_t   min_pos, max_pos;
+    while( player_state != CLOSED )
+    {
+        int err;
+//        __asm__ __volatile__("int3");
+        switch(decoder_state)
+        {
+            case PREPARE:
-            player_state = REWIND_2_PLAY;
+                eof = fill_queue();
-            printf("restart\n");
-            continue;
+                do
-        };
+                {
+                    if( (q_video.size+q_audio.size < 4*1024*1024) &&
                         (eof == 0) )
+                    {
+                        eof = load_frame();
+                    }
-        if(q_video.size+q_audio.size < 4*1024*1024)
+                    decode_video(pCodecCtx, &q_video);
                     ret = decode_audio(aCodecCtx, &q_audio);
-            err = av_read_frame(pFormatCtx, &packet);
+                }while(astream.count < resampler_size*2 &&
-            if( err < 0)
-            {
-                eof = 1;
+                       ret == 1);
-                if (err != AVERROR_EOF)
                     printf("av_read_frame: error %x\n", err);
-                continue;
+                sound_state   = PREPARE;
-            }
+                decoder_state = PLAY;
-            if(packet.stream_index==videoStream)
+                player_state  = PLAY;
+            case PLAY:
+                if( (q_video.size+q_audio.size < 4*1024*1024) &&
+                    (eof == 0) )
+                {
+                    eof = load_frame();
+                    if(eof) printf("eof\n");
+                }
+                ret = decode_video(pCodecCtx, &q_video);
+                ret|= decode_audio(aCodecCtx, &q_audio);
+                if( eof && !ret)
+                {
+                    decoder_state = STOP;
+//                    printf("stop decoder\n");
+                };
+            case STOP:
+                delay(1);
+                break;
+            case PLAY_2_STOP:
+                while(sound_state != STOP)
+                    delay(1);
+                flush_all();
+                if (pFormatCtx->start_time != AV_NOPTS_VALUE)
+                    rewind_pos = pFormatCtx->start_time;
+                else
+                    rewind_pos = 0;
+                ret = avformat_seek_file(pFormatCtx, -1, INT64_MIN,
+                                         rewind_pos, INT64_MAX, 0);
+                decoder_state = STOP;
+                break;
+            case REWIND:
+                while(sound_state != STOP)
+                    yield();
+                flush_all();
+                int opts = 0;
+                if(rewind_pos < 0)
+                {
+                    rewind_pos = -rewind_pos;
+                    opts = AVSEEK_FLAG_BACKWARD;
+                };
+                if (pFormatCtx->start_time != AV_NOPTS_VALUE)
+                    rewind_pos += pFormatCtx->start_time;
+//                printf("rewind %8"PRId64"\n", rewind_pos);
+                min_pos = rewind_pos - 1000000;
                 max_pos = rewind_pos + 1000000;
                 put_packet(&q_video, &packet);
                 ret = avformat_seek_file(pFormatCtx, -1, INT64_MIN,

Subversion Repositories Kolibri OS

(root)/programs/media/Fplay/fplay.c – Rev 2693 → 3068