|| || || || || || || ||

---

LavcProtocolImpl.h

Go to the documentation of this file.

#ifndef Impala_Core_Stream_LavcProtocolImpl_h
#define Impala_Core_Stream_LavcProtocolImpl_h

// The file below contains our one and only entry point into libavcodec
#include "Link/Lavc/Lavc.h" // 

namespace Impala
{
namespace Core
{
namespace Stream
{

class LavcProtocolImpl
{

public:

    virtual int Read(unsigned char* buffer, int size)
    {
        ILOG_DEBUG("Read: buffer = " << (void*) buffer << ", size = " << size);
        int nrRead = mIOBuffer->Read(buffer, size);
        ILOG_DEBUG("Read: nrRead = " << nrRead);
        return nrRead;
    }

    virtual int64_t Seek(int64_t offset, int whence)
    {
        ILOG_DEBUG("Seek: offset = " << offset << ", whence = " << whence);

        if (whence == 65536) // see AVSEEK_SIZE in libavformat/avio.h
        {
            int64_t fileLen = (int64_t) mIOBuffer->Size();
            ILOG_DEBUG("Seek: file length = " << fileLen);
            return fileLen;
        }

        int64_t newPos = (int64_t) mIOBuffer->Seek(offset, whence);
        ILOG_DEBUG("Seek: new position = " << newPos);
        return newPos;
    }

    virtual int Close(URLContext* h)
    {
        ILOG_DEBUG("Closing target");
        delete mIOBuffer;
        h->priv_data = 0;
        return 0;
    }

protected:
    
    LavcProtocolImpl() : mIOBuffer(0)
    {
    }
    
    ~LavcProtocolImpl()
    {
    }

    int OpenTarget(URLContext* h, const char* url, int flags)
    {
        ILOG_DEBUG("OpenTarget: url = " << url);
        String urlStr = url;
        int protocolLastPos = urlStr.find_first_of(':');
        String protocol = urlStr.substr(0, protocolLastPos + 1);
        String target = urlStr.substr(protocolLastPos + 1);
        ILOG_DEBUG("OpenTarget: target = " << target);
        Util::IOBuffer* ioBuf = this->CreateIOBuffer(target);
        if (!ioBuf->Valid())
        {
            delete ioBuf;
            return -1;
        }

        h->priv_data = (void*) new LavcProtocolImpl(ioBuf);
        return 0;
    }

    virtual Util::IOBuffer* CreateIOBuffer(String target)
    {
        return 0;
    }

private:
    
    LavcProtocolImpl(Util::IOBuffer* ioBuf) : mIOBuffer(ioBuf)
    {
    }

    Util::IOBuffer* mIOBuffer;

    ILOG_VAR_DECL;

};

ILOG_VAR_INIT(LavcProtocolImpl, Impala.Core.Stream);


static int
LavcProtocolImpl_read(URLContext* h, unsigned char* buffer, int size)
{
    return ((LavcProtocolImpl*) h->priv_data)->Read(buffer, size);
}

static int64_t
LavcProtocolImpl_seek(URLContext* h, int64_t offset, int whence)
{
    return ((LavcProtocolImpl*) h->priv_data)->Seek(offset, whence);
}

static int
LavcProtocolImpl_close(URLContext* h)
{
    return ((LavcProtocolImpl*) h->priv_data)->Close(h);
}

} // namespace Stream
} // namespace Core
} // namespace Impala

#endif

---