Subversion Repositories Kolibri OS

#include 

#include 

#include 

#include 

#include "sound.h"

#include "fplay.h"

int sample_rate;

{

    int    err;

    int    version =-1;

    char  *errstr;

    {

        mutex_unlock(&driver_lock);

        errstr = "Sound service not installed\n\r";

        goto exit_whith_error;

    };

        (SOUND_VERSION<(version >> 16)))

    {

        errstr = "Sound service version mismatch\n\r";

        goto exit_whith_error;

    }

    return 0;

};

static double  audio_delta;

{

    double tstamp;

    return tstamp - audio_delta;

};

{

    AVPacket   pkt;

    AVPacket    pkt_tmp;

    int         audio_size;

    int         len;

    int         data_size=0;

        return 1;

        return 0;

    {

        data_size = AVCODEC_MAX_AUDIO_FRAME_SIZE;

                                   &data_size, &pkt_tmp);

        {

            pkt_tmp.data += len;

            pkt_tmp.size -= len;

            memcpy(astream.buffer+astream.count, decoder_buffer, data_size);

            astream.count += data_size;

            mutex_unlock(&astream.lock);

       }

       else pkt_tmp.size = 0;

    }

    av_free_packet(&pkt);

    return 1;

};

{

    SND_EVENT evnt;

    int       buffsize;

    int      samples;

    int       err;

    char     *errstr;

    {

        errstr = "Cannot create sound buffer\n\r";

        goto exit_whith_error;

    };

    {

        errstr = "Cannot get buffer size\n\r";

        goto exit_whith_error;

    };

               (status != 0) )

        yield();

    {

        SetBuffer(hBuff, astream.buffer, 0, buffsize);

        astream.count -= buffsize;

        if(astream.count)

            memcpy(astream.buffer, astream.buffer+buffsize, astream.count);

        mutex_unlock(&astream.lock);

    };

    {

        errstr = "Cannot play buffer\n\r";

        goto exit_whith_error;

    };

    {

        uint32_t  offset;

        {

            printf("invalid event code %d\n\r", evnt.code);

            continue;

        }

        {

            printf("invalid stream %x hBuff= %x\n\r",

                    evnt.stream, hBuff);

            continue;

        }

        samples_lost = audio_delta*sample_rate/1000;

        {

            SetBuffer(hBuff, astream.buffer, offset, buffsize);

            astream.count -= buffsize;

            if(astream.count)

                memcpy(astream.buffer, astream.buffer+buffsize, astream.count);

            mutex_unlock(&astream.lock);

        };

        break;

    };

#endif

    {

        uint32_t  offset;

        double    event_stamp, wait_stamp;

        int       too_late = 0;

        {

            printf("invalid event code %d\n\r", evnt.code);

            continue;

        }

        {

            printf("invalid stream %x hBuff= %x\n\r",

                    evnt.stream, hBuff);

            continue;

        };

               (status != 0) )

        {

            yield();

            GetTimeStamp(hBuff, &wait_stamp);

            if( (wait_stamp - event_stamp) >

                 samples*1500/sample_rate )

            {

                samples_lost+= samples;

                audio_delta = (double)samples_lost*1000/sample_rate;

//                printf("audio delta %f\n", audio_delta);

                too_late = 1;

                break;

            }

        };

            continue;

        SetBuffer(hBuff, astream.buffer, offset, buffsize);

        astream.count -= buffsize;

        if(astream.count)

            memcpy(astream.buffer, astream.buffer+buffsize, astream.count);

        mutex_unlock(&astream.lock);

    }

    DestroyBuffer(hBuff);

    return -1;