# HG changeset patch # User arpi # Date 997923002 0 # Node ID da26060c81ef4212eb71f06e47ce9ee2b9f921c1 # Parent 558c1b03b8d053c080e82813f97136128c893ee4 big avifile sync - from now we have common code diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_AudioDec.c --- a/loader/dshow/DS_AudioDec.c Thu Aug 16 00:44:40 2001 +0000 +++ b/loader/dshow/DS_AudioDec.c Thu Aug 16 00:50:02 2001 +0000 @@ -1,188 +1,63 @@ -/******************************************************** - - DirectShow Audio decoder implementation - Copyright 2000 Eugene Kuznetsov (divx@euro.ru) - Converted C++ --> C :) by A'rpi/ESP-team - -*********************************************************/ - -//#include - -//#include "DS_AudioDecoder.h" -//#include -using namespace std; -#include -#include -#define __MODULE__ "DirectShow_AudioDecoder" - -#include -#ifdef HAVE_MALLOC_H -#include -#endif -//#include -//#include -#include -#include -#include -#include -#include -#include -#include - -#include -#include #include "guids.h" #include "interfaces.h" -#include "DS_Filter.h" + +#include "DS_AudioDecoder.h" +#include +#include +//#include -#include "BitmapInfo.h" - -#include -#include +#include +#include +#include +#include +#include +#include +#include +#include #include "DS_AudioDec.h" -const GUID FORMAT_WaveFormatEx={ -0x05589f81, 0xc356, 0x11ce, 0xbf, 0x01, 0x00, 0xaa, 0x00, 0x55, 0x59, 0x5a}; -const GUID MEDIATYPE_Audio={ -0x73647561, 0x0000, 0x0010, 0x80, 0x00, 0x00, 0xaa, 0x00, 0x38, 0x9b, 0x71}; -const GUID MEDIASUBTYPE_PCM={ -0x00000001, 0x0000, 0x0010, 0x80, 0x00, 0x00, 0xAA, 0x00, 0x38, 0x9B, 0x71}; - - -extern "C" char* def_path; - - static DS_Filter* dsf=0; - - static AM_MEDIA_TYPE m_sOurType, m_sDestType; -// static void* m_pCust; - static char* m_sVhdr; - static char* m_sVhdr2; +// DS_Decoder(const CodecInfo& info, const WAVEFORMATEX*); +// virtual ~DS_Decoder(); +// virtual int Convert(const void*, size_t, void*, size_t, size_t*, size_t*); +// virtual int GetSrcSize(int); - static WAVEFORMATEX in_fmt; - -// int m_iState=0; - -extern "C" int DS_AudioDecoder_Open(char* dllname, GUID* guid, WAVEFORMATEX* wf) -{ +static void* _handle; - m_sVhdr=new char[18+wf->cbSize]; - memcpy(m_sVhdr, wf, 18+wf->cbSize); - m_sVhdr2=new char[18]; - memcpy(m_sVhdr2, m_sVhdr, 18); - WAVEFORMATEX* pWF=(WAVEFORMATEX*)m_sVhdr2; - pWF->wFormatTag=1; - pWF->wBitsPerSample=16; - pWF->nBlockAlign=2*pWF->nChannels; - pWF->cbSize=0; - in_fmt=*wf; +extern "C" void Setup_LDT_Keeper(); +extern "C" void setup_FS_Segment(); - memset(&m_sOurType, 0, sizeof m_sOurType); - m_sOurType.majortype=MEDIATYPE_Audio; - m_sOurType.subtype=MEDIASUBTYPE_PCM; - m_sOurType.subtype.f1=wf->wFormatTag; - m_sOurType.formattype=FORMAT_WaveFormatEx; - m_sOurType.lSampleSize=wf->nBlockAlign; - m_sOurType.bFixedSizeSamples=true; - m_sOurType.bTemporalCompression=false; - m_sOurType.pUnk=0; - m_sOurType.cbFormat=18+wf->cbSize; - m_sOurType.pbFormat=m_sVhdr; +extern "C" int DS_AudioDecoder_Open(char* dllname, GUID* guid, WAVEFORMATEX* wf){ + + Setup_LDT_Keeper(); + setup_FS_Segment(); - memset(&m_sDestType, 0, sizeof m_sDestType); - m_sDestType.majortype=MEDIATYPE_Audio; - m_sDestType.subtype=MEDIASUBTYPE_PCM; - m_sDestType.formattype=FORMAT_WaveFormatEx; - m_sDestType.bFixedSizeSamples=true; - m_sDestType.bTemporalCompression=false; - m_sDestType.lSampleSize=2*wf->nChannels; - m_sDestType.pUnk=0; - m_sDestType.cbFormat=18; - m_sDestType.pbFormat=m_sVhdr2; - - try - { + CodecInfo ci; + ci.dll=dllname; + ci.guid=*guid; - dsf=new DS_Filter(); - dsf->Create(dllname, guid, &m_sOurType, &m_sDestType); - dsf->Start(); - - ALLOCATOR_PROPERTIES props, props1; - props.cBuffers=1; - props.cbBuffer=m_sOurType.lSampleSize; - props.cbAlign=props.cbPrefix=0; - dsf->m_pAll->vt->SetProperties(dsf->m_pAll, &props, &props1); - dsf->m_pAll->vt->Commit(dsf->m_pAll); - } - catch(FatalError e) - { - e.PrintAll(); - delete[] m_sVhdr; - delete[] m_sVhdr2; - return 1; - } + DS_AudioDecoder* dec=new DS_AudioDecoder(ci, wf); + _handle=(void*)dec; return 0; } extern "C" void DS_AudioDecoder_Close(){ - delete[] m_sVhdr; - delete[] m_sVhdr2; } -extern "C" int DS_AudioDecoder_GetSrcSize(int dest_size) -{ - double efficiency=in_fmt.nAvgBytesPerSec/double(in_fmt.nSamplesPerSec*in_fmt.nBlockAlign); - int frames=(int)(dest_size*efficiency); - if(frames<1)frames=1; - return frames*in_fmt.nBlockAlign; +extern "C" int DS_AudioDecoder_GetSrcSize(int dest_size){ + DS_AudioDecoder* dec=(DS_AudioDecoder*)_handle; + return dec->GetSrcSize(dest_size); } - extern "C" int DS_AudioDecoder_Convert(unsigned char* in_data, unsigned in_size, unsigned char* out_data, unsigned out_size, - unsigned* size_read, unsigned* size_written) -{ - if(in_data==0)return -1; - if(out_data==0)return -1; - int written=0; - int read=0; - in_size-=in_size%in_fmt.nBlockAlign; - while(in_size>0) - { - long frame_size=0; - char* frame_pointer; -// m_pOurOutput->SetFramePointer(out_data+written); - dsf->m_pOurOutput->SetFramePointer(&frame_pointer); - dsf->m_pOurOutput->SetFrameSizePointer(&frame_size); - IMediaSample* sample=0; - dsf->m_pAll->vt->GetBuffer(dsf->m_pAll, &sample, 0, 0, 0); - if(!sample) - { - cerr<<"ERROR: null sample"<vt->GetPointer(sample, (BYTE **)&ptr); - memcpy(ptr, in_data+read, in_fmt.nBlockAlign); - sample->vt->SetActualDataLength(sample, in_fmt.nBlockAlign); - sample->vt->SetSyncPoint(sample, true); - sample->vt->SetPreroll(sample, 0); - int result=dsf->m_pImp->vt->Receive(dsf->m_pImp, sample); - if(result) printf("Error putting data into input pin %x\n", result); - if(written+frame_size>out_size) - { - sample->vt->Release((IUnknown*)sample); - break; - } - memcpy(out_data+written, frame_pointer, frame_size); - sample->vt->Release((IUnknown*)sample); - read+=in_fmt.nBlockAlign; - written+=frame_size; - } - if(size_read) *size_read=read; - if(size_written) *size_written=written; - return 0; + unsigned* size_read, unsigned* size_written){ + DS_AudioDecoder* dec=(DS_AudioDecoder*)_handle; + setup_FS_Segment(); + return dec->Convert( (void*)in_data,(size_t)in_size, + (void*)out_data,(size_t)out_size, + (size_t*)size_read, (size_t*)size_written ); } diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_AudioDecoder.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/loader/dshow/DS_AudioDecoder.c Thu Aug 16 00:50:02 2001 +0000 @@ -0,0 +1,156 @@ +/******************************************************** + + DirectShow audio decoder + Copyright 2001 Eugene Kuznetsov (divx@euro.ru) + +*********************************************************/ +#include "DS_AudioDecoder.h" + +#include +#include +#include +#include +#define __MODULE__ "DirectShow audio decoder" +const GUID FORMAT_WaveFormatEx = { + 0x05589f81, 0xc356, 0x11CE, + { 0xBF, 0x01, 0x00, 0xAA, 0x00, 0x55, 0x59, 0x5A } +}; +const GUID MEDIATYPE_Audio = { + 0x73647561, 0x0000, 0x0010, + { 0x80, 0x00, 0x00, 0xAA, 0x00, 0x38, 0x9B, 0x71 } +}; +const GUID MEDIASUBTYPE_PCM = { + 0x00000001, 0x0000, 0x0010, + { 0x80, 0x00, 0x00, 0xAA, 0x00, 0x38, 0x9B, 0x71 } +}; + +using namespace std; + +typedef long STDCALL (*GETCLASS) (GUID*, GUID*, void**); + +DS_AudioDecoder::DS_AudioDecoder(const CodecInfo& info, const WAVEFORMATEX* wf) + : IAudioDecoder(info, wf), m_pDS_Filter(0), m_sVhdr(0), m_sVhdr2(0) +{ + m_sVhdr=new char[18 + wf->cbSize]; + memcpy(m_sVhdr, wf, 18 + wf->cbSize); + m_sVhdr2=new char[18 + wf->cbSize]; + memcpy(m_sVhdr2, m_sVhdr, 18 + wf->cbSize); + WAVEFORMATEX* pWF=(WAVEFORMATEX*)m_sVhdr2; + pWF->wFormatTag=1; + pWF->wBitsPerSample=16; + pWF->nBlockAlign=2*pWF->nChannels; + pWF->cbSize=0; + in_fmt=*wf; + + memset(&m_sOurType, 0, sizeof(m_sOurType)); + m_sOurType.majortype=MEDIATYPE_Audio; + m_sOurType.subtype=MEDIASUBTYPE_PCM; + m_sOurType.subtype.f1=wf->wFormatTag; + m_sOurType.formattype=FORMAT_WaveFormatEx; + m_sOurType.lSampleSize=wf->nBlockAlign; + m_sOurType.bFixedSizeSamples=true; + m_sOurType.bTemporalCompression=false; + m_sOurType.pUnk=0; + m_sOurType.cbFormat=18+wf->cbSize; + m_sOurType.pbFormat=m_sVhdr; + + memset(&m_sDestType, 0, sizeof(m_sDestType)); + m_sDestType.majortype=MEDIATYPE_Audio; + m_sDestType.subtype=MEDIASUBTYPE_PCM; + m_sDestType.formattype=FORMAT_WaveFormatEx; + m_sDestType.bFixedSizeSamples=true; + m_sDestType.bTemporalCompression=false; + m_sDestType.lSampleSize=2*wf->nChannels; + m_sDestType.pUnk=0; + m_sDestType.cbFormat=18; + m_sDestType.pbFormat=m_sVhdr2; + + try + { + m_pDS_Filter = new DS_Filter(); + m_pDS_Filter->Create(info.dll.c_str(), &info.guid, &m_sOurType, &m_sDestType); + m_pDS_Filter->Start(); + + ALLOCATOR_PROPERTIES props, props1; + props.cBuffers=1; + props.cbBuffer=m_sOurType.lSampleSize; + props.cbAlign=props.cbPrefix=0; + m_pDS_Filter->m_pAll->vt->SetProperties(m_pDS_Filter->m_pAll, &props, &props1); + m_pDS_Filter->m_pAll->vt->Commit(m_pDS_Filter->m_pAll); + } + catch (FatalError e) + { + e.PrintAll(); + delete[] m_sVhdr; + delete[] m_sVhdr2; + delete m_pDS_Filter; + throw; + } +} + +DS_AudioDecoder::~DS_AudioDecoder() +{ + delete[] m_sVhdr; + delete[] m_sVhdr2; + delete m_pDS_Filter; +} + +int DS_AudioDecoder::Convert(const void* in_data, size_t in_size, + void* out_data, size_t out_size, + size_t* size_read, size_t* size_written) +{ + if (!in_data || !out_data) + return -1; + + size_t written = 0; + size_t read = 0; + in_size -= in_size%in_fmt.nBlockAlign; + while (in_size>0) + { + size_t frame_size=0; + char* frame_pointer; +// m_pOurOutput->SetFramePointer(out_data+written); + m_pDS_Filter->m_pOurOutput->SetFramePointer(&frame_pointer); + m_pDS_Filter->m_pOurOutput->SetFrameSizePointer((long*)&frame_size); + IMediaSample* sample=0; + m_pDS_Filter->m_pAll->vt->GetBuffer(m_pDS_Filter->m_pAll, &sample, 0, 0, 0); + if(!sample) + { + Debug cerr<<"DS_AudioDecoder::Convert() Error: null sample"<vt->GetPointer(sample, (BYTE **)&ptr); + memcpy(ptr, (const uint8_t*)in_data + read, in_fmt.nBlockAlign); + sample->vt->SetActualDataLength(sample, in_fmt.nBlockAlign); + sample->vt->SetSyncPoint(sample, true); + sample->vt->SetPreroll(sample, 0); + int result = m_pDS_Filter->m_pImp->vt->Receive(m_pDS_Filter->m_pImp, sample); + if (result) + Debug printf("DS_AudioDecoder::Convert() Error: putting data into input pin %x\n", result); + if ((written + frame_size) > out_size) + { + sample->vt->Release((IUnknown*)sample); + break; + } + memcpy((uint8_t*)out_data + written, frame_pointer, frame_size); + sample->vt->Release((IUnknown*)sample); + read+=in_fmt.nBlockAlign; + written+=frame_size; + } + if (size_read) + *size_read = read; + if (size_written) + *size_written = written; + return 0; +} + +int DS_AudioDecoder::GetSrcSize(int dest_size) +{ + double efficiency = (double) in_fmt.nAvgBytesPerSec + / (in_fmt.nSamplesPerSec*in_fmt.nBlockAlign); + int frames = int(dest_size*efficiency); + if (frames < 1) + frames = 1; + return frames * in_fmt.nBlockAlign; +} diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_AudioDecoder.h --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/loader/dshow/DS_AudioDecoder.h Thu Aug 16 00:50:02 2001 +0000 @@ -0,0 +1,21 @@ +#ifndef AVIFILE_DSHOW_H +#define AVIFILE_DSHOW_H + +#include +#include "DS_Filter.h" + +class DS_AudioDecoder : public IAudioDecoder +{ +public: + DS_AudioDecoder(const CodecInfo& info, const WAVEFORMATEX*); + virtual ~DS_AudioDecoder(); + virtual int Convert(const void*, size_t, void*, size_t, size_t*, size_t*); + virtual int GetSrcSize(int); +protected: + AM_MEDIA_TYPE m_sOurType, m_sDestType; + DS_Filter* m_pDS_Filter; + char* m_sVhdr; + char* m_sVhdr2; +}; + +#endif diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_Filter.c --- a/loader/dshow/DS_Filter.c Thu Aug 16 00:44:40 2001 +0000 +++ b/loader/dshow/DS_Filter.c Thu Aug 16 00:50:02 2001 +0000 @@ -1,34 +1,49 @@ +#include "DS_Filter.h" +//#include "../loader/loader.h" +#include +#include #include #include -#include "DS_Filter.h" -#include -//#include "../loader/loader.h" -#include -#include + #define __MODULE__ "DirectShow generic filter" using namespace std; +extern "C" int STDCALL expLoadLibraryA(const char*); + typedef long STDCALL (*GETCLASS) (const GUID*, const GUID*, void**); -extern "C" char* def_path; -extern "C" int STDCALL expLoadLibraryA(const char*); -extern "C" STDCALL void* GetProcAddress(int, const char*); -extern "C" int STDCALL FreeLibrary(int); - -extern "C" void Setup_LDT_Keeper(); -extern "C" void setup_FS_Segment(); +//extern "C" int STDCALL LoadLibraryA(const char*); +//extern "C" STDCALL void* GetProcAddress(int, const char*); // STDCALL has to be first NetBSD +//extern "C" int STDCALL FreeLibrary(int); DS_Filter::DS_Filter() - :m_iHandle(0), m_pFilter(0), m_pInputPin(0), - m_pOutputPin(0), m_pSrcFilter(0), m_pParentFilter(0), - m_pOurInput(0), m_pOurOutput(0), m_pAll(0), m_pImp(0), - m_iState(0) { + m_iHandle = 0; + m_pFilter = 0; + m_pInputPin = 0; + m_pOutputPin = 0; + m_pSrcFilter = 0; + m_pParentFilter = 0; + m_pOurInput = 0; + m_pOurOutput = 0; + m_pAll = 0; + m_pImp = 0; + m_iState = 0; } -void DS_Filter::clean() +DS_Filter::~DS_Filter() { + //cout << "Destruction of DS_FILTER" << endl; + Stop(); + destroy(); + //cout << "Destruction of DS_FILTER done" << endl; +} + +void DS_Filter::destroy() +{ + if (m_iState == 0) + return; m_iState = 0; if (m_pOurInput) @@ -53,67 +68,56 @@ // FIXME - we are still leaving few things allocated! if (m_iHandle) FreeLibrary(m_iHandle); - -} - -DS_Filter::~DS_Filter() -{ - //cout << "Destruction of DS_FILTER" << endl; - Stop(); - if (m_iState == 1) - clean(); - //cout << "Destruction of DS_FILTER done" << endl; } -void DS_Filter::Create(char* dllname, const GUID* id, AM_MEDIA_TYPE* in_fmt, AM_MEDIA_TYPE* out_fmt) +void DS_Filter::Create(const char* dllname, const GUID* id, + AM_MEDIA_TYPE* in_fmt, + AM_MEDIA_TYPE* out_fmt) { - - Setup_LDT_Keeper(); - try { -// string _fullname=def_path; -// _fullname+="/"; -// _fullname+=dllname; - m_iHandle= expLoadLibraryA(dllname); + m_iHandle = expLoadLibraryA(dllname); if (!m_iHandle) { - char e[1024]; - snprintf(e, 1024, "Could not open DirectShow DLL: %s", dllname); + char e[256]; + printf("Could not open DirectShow DLL: %.200s", dllname); throw FATAL(e); } - GETCLASS func=(GETCLASS)GetProcAddress(m_iHandle, "DllGetClassObject"); + GETCLASS func = (GETCLASS)GetProcAddress(m_iHandle, "DllGetClassObject"); if (!func) { - char e[1024]; - snprintf(e, 1024, "Illegal or corrupt DirectShow DLL: %s", dllname); + char e[256]; + printf("Illegal or corrupt DirectShow DLL: %.200s", dllname); throw FATAL(e); } HRESULT result; - IClassFactory* factory=0; - result=func(id, &IID_IClassFactory, (void**)&factory); - if(result || (!factory)) throw FATAL("No such class object");; + IClassFactory* factory = 0; + result = func(id, &IID_IClassFactory, (void**)&factory); + if (result || !factory) + throw FATAL("No such class object");; - setup_FS_Segment(); - - IUnknown* object=0; - result=factory->vt->CreateInstance(factory, 0, &IID_IUnknown, (void**)&object); + IUnknown* object = 0; + result = factory->vt->CreateInstance(factory, 0, &IID_IUnknown, (void**)&object); factory->vt->Release((IUnknown*)factory); - if(result || (!object)) throw FATAL("Class factory failure"); + if (result || !object) + throw FATAL("Class factory failure"); - result=object->vt->QueryInterface(object, &IID_IBaseFilter, (void**)&m_pFilter); + result = object->vt->QueryInterface(object, &IID_IBaseFilter, (void**)&m_pFilter); object->vt->Release((IUnknown*)object); - if(result || (!m_pFilter)) throw FATAL("Object does not have IBaseFilter interface"); + if (result || !m_pFilter) + throw FATAL("Object does not have IBaseFilter interface"); - IEnumPins* enum_pins=0; - // enumerate pins - result=m_pFilter->vt->EnumPins(m_pFilter, &enum_pins); - if(result || (!enum_pins)) throw FATAL("Could not enumerate pins"); + IEnumPins* enum_pins = 0; + // enumerate pins + result = m_pFilter->vt->EnumPins(m_pFilter, &enum_pins); + if (result || !enum_pins) + throw FATAL("Could not enumerate pins"); + IPin* array[256]; ULONG fetched; enum_pins->vt->Reset(enum_pins); - result=enum_pins->vt->Next(enum_pins, (ULONG)256, (IPin**)array, &fetched); + result = enum_pins->vt->Next(enum_pins, (ULONG)256, (IPin**)array, &fetched); Debug printf("Pins enumeration returned %ld pins, error is %x\n", fetched, (int)result); for (unsigned i = 0; i < fetched; i++) @@ -140,38 +144,45 @@ result = m_pInputPin->vt->QueryInterface((IUnknown*)m_pInputPin, &IID_IMemInputPin, (void**)&m_pImp); - if(result) + if (result) throw FATAL("Error getting IMemInputPin interface"); - m_pOurType=in_fmt; - m_pDestType=out_fmt; - result=m_pInputPin->vt->QueryAccept(m_pInputPin, m_pOurType); + m_pOurType = in_fmt; + m_pDestType = out_fmt; + result = m_pInputPin->vt->QueryAccept(m_pInputPin, m_pOurType); if (result) throw FATAL("Source format is not accepted"); - m_pParentFilter=new CBaseFilter2; - m_pSrcFilter=new CBaseFilter(*m_pOurType, m_pParentFilter); - m_pOurInput=m_pSrcFilter->GetPin(); + m_pParentFilter = new CBaseFilter2; + m_pSrcFilter = new CBaseFilter(*m_pOurType, m_pParentFilter); + m_pOurInput = m_pSrcFilter->GetPin(); m_pOurInput->vt->AddRef((IUnknown*)m_pOurInput); - result=m_pInputPin->vt->ReceiveConnection(m_pInputPin, m_pOurInput, - m_pOurType); + result = m_pInputPin->vt->ReceiveConnection(m_pInputPin, + m_pOurInput, + m_pOurType); if (result) throw FATAL("Error connecting to input pin"); m_pOurOutput = new COutputPin(*m_pDestType); + //extern void trapbug(); + //trapbug(); result = m_pOutputPin->vt->ReceiveConnection(m_pOutputPin, m_pOurOutput, m_pDestType); if (result) + { + //printf("Tracking ACELP %d 0%x\n", result); throw FATAL("Error connecting to output pin"); - cout << "Using DirectShow codec: " << dllname << endl; + } + + printf("Using DirectShow codec: %s\n", dllname); m_iState = 1; } - catch(FatalError e) + catch (FatalError e) { - e.PrintAll(); - clean(); + //e.PrintAll(); + destroy(); throw; } } @@ -181,22 +192,19 @@ if (m_iState != 1) return; - m_pFilter->vt->Pause(m_pFilter); - HRESULT hr=m_pFilter->vt->Run(m_pFilter, 0); if (hr != 0) { - Debug cerr<<"WARNING: m_Filter->Run() failed, error code "<Run() failed, error code %x\n", (int)hr); } - hr=m_pImp->vt->GetAllocator(m_pImp, &m_pAll); + hr = m_pImp->vt->GetAllocator(m_pImp, &m_pAll); if (hr) { - Debug cerr<<"Error getting IMemAllocator interface "<vt->Release((IUnknown*)m_pImp); return; } m_pImp->vt->NotifyAllocator(m_pImp, m_pAll, 0); - m_iState = 2; } @@ -205,8 +213,8 @@ if (m_iState == 2) { m_pAll->vt->Release((IUnknown*)m_pAll); - m_pAll=0; - m_pFilter->vt->Stop(m_pFilter); - m_iState=1; + m_pFilter->vt->Stop(m_pFilter); // causes weird crash ??? FIXME + m_pAll = 0; + m_iState = 1; } } diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_Filter.h --- a/loader/dshow/DS_Filter.h Thu Aug 16 00:44:40 2001 +0000 +++ b/loader/dshow/DS_Filter.h Thu Aug 16 00:50:02 2001 +0000 @@ -1,22 +1,22 @@ -#ifndef DS_Filter_H -#define DS_Filter_H +#ifndef DS_FILTER_H +#define DS_FILTER_H #include "interfaces.h" #include "inputpin.h" #include "outputpin.h" -#include /** - User will allocate and fill format structures, call Create(), - and then set up m_pAll. -**/ -class DS_Filter + User will allocate and fill format structures, call Create(), + and then set up m_pAll. + **/ + +struct DS_Filter { -public: DS_Filter(); virtual ~DS_Filter(); void Start(); void Stop(); + int m_iHandle; IBaseFilter* m_pFilter; IPin* m_pInputPin; @@ -32,10 +32,10 @@ IMemInputPin* m_pImp; int m_iState; - void Create(char* dllname, const GUID* id, AM_MEDIA_TYPE* in_fmt, AM_MEDIA_TYPE* out_fmt); + void Create(const char* dllname, const GUID* id, AM_MEDIA_TYPE* in_fmt, AM_MEDIA_TYPE* out_fmt); void SetPointer(char* pointer); -private: - void clean(); + + void destroy(); }; -#endif +#endif /* DS_FILTER_H */ diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_VideoDec.c --- a/loader/dshow/DS_VideoDec.c Thu Aug 16 00:44:40 2001 +0000 +++ b/loader/dshow/DS_VideoDec.c Thu Aug 16 00:50:02 2001 +0000 @@ -1,414 +1,78 @@ -/******************************************************** - - DirectShow Video decoder implementation - Copyright 2000 Eugene Kuznetsov (divx@euro.ru) - Converted C++ --> C :) by A'rpi/ESP-team - -*********************************************************/ - -//#include +#include "guids.h" +#include "interfaces.h" -//#include "DS_VideoDecoder.h" -//#include -using namespace std; -#include -#include -#define __MODULE__ "DirectShow_VideoDecoder" - +#include "DS_VideoDecoder.h" +#include +#include +//#include -#include -#ifdef HAVE_MALLOC_H -#include -#endif -//#include -//#include -#include #include #include -#include -#include +#include #include #include +#include +#include +#include #include -#include - -#include "guids.h" -#include "interfaces.h" -#include "DS_Filter.h" - -#include "BitmapInfo.h" - -#include -#include +//#include #include "DS_VideoDec.h" - -extern "C" char* def_path; - - static char** m_destptr=0; - - static DS_Filter* dsf=0; - - static AM_MEDIA_TYPE m_sOurType, m_sDestType; - static VIDEOINFOHEADER *m_sVhdr; - static VIDEOINFOHEADER *m_sVhdr2; - static void* m_pCust; - - static BITMAPINFOHEADER *m_bh;//format of input data - static BitmapInfo m_decoder;//format of decoder output - static BitmapInfo m_obh; //format of returned frames -// CImage* m_outFrame; - -// int m_iState=0; - -extern "C" int DS_VideoDecoder_Open(char* dllname, GUID* guid, BITMAPINFOHEADER* format, int flip,char** d_ptr) -// :IVideoDecoder(info), m_sVhdr2(0) -{ +static void* _handle; // will be parameter later... +static char** _d_ptr; // will be parameter later... - m_destptr=d_ptr; - - //m_outFrame=0; - //decpos = 0; - //playpos = 0; - //realtime = 0; +extern "C" void Setup_LDT_Keeper(); +extern "C" void setup_FS_Segment(); - try - { - m_bh=format; - memset(&m_obh, 0, sizeof(m_obh)); - m_obh.biSize=sizeof(m_obh); +extern "C" int DS_VideoDecoder_Open(char* dllname, GUID* guid, BITMAPINFOHEADER* format, int flip,char** d_ptr){ -#if 0 - memset(&m_sVhdr, 0, sizeof(m_sVhdr)); - m_sVhdr.bmiHeader=m_bh; - m_sVhdr.rcSource.left=m_sVhdr.rcSource.top=0; - m_sVhdr.rcSource.right=m_sVhdr.bmiHeader.biWidth; - m_sVhdr.rcSource.bottom=m_sVhdr.bmiHeader.biHeight; - m_sVhdr.rcTarget=m_sVhdr.rcSource; -#else - unsigned bihs = (format->biSize < (int) sizeof(BITMAPINFOHEADER)) ? - sizeof(BITMAPINFOHEADER) : format->biSize; - bihs = sizeof(VIDEOINFOHEADER) - sizeof(BITMAPINFOHEADER) + bihs; + Setup_LDT_Keeper(); - m_sVhdr = (VIDEOINFOHEADER*) new char[bihs]; - memset(m_sVhdr, 0, bihs); - memcpy(&m_sVhdr->bmiHeader, m_bh, m_bh->biSize); - - m_sVhdr->rcSource.left = m_sVhdr->rcSource.top = 0; - m_sVhdr->rcSource.right = m_sVhdr->bmiHeader.biWidth; - m_sVhdr->rcSource.bottom = m_sVhdr->bmiHeader.biHeight; - m_sVhdr->rcTarget = m_sVhdr->rcSource; -#endif - m_sOurType.majortype=MEDIATYPE_Video; - m_sOurType.subtype=MEDIATYPE_Video; - m_sOurType.subtype.f1=m_sVhdr->bmiHeader.biCompression; - m_sOurType.formattype=FORMAT_VideoInfo; - m_sOurType.bFixedSizeSamples=false; - m_sOurType.bTemporalCompression=true; - m_sOurType.pUnk=0; -// m_sOurType.cbFormat=sizeof(m_sVhdr); -// m_sOurType.pbFormat=(char*)&m_sVhdr; - m_sOurType.cbFormat = bihs; - m_sOurType.pbFormat = (char*)m_sVhdr; - - m_sVhdr2=(VIDEOINFOHEADER*)(new char[sizeof(VIDEOINFOHEADER)+12]); -// *m_sVhdr2=m_sVhdr; - memcpy(m_sVhdr2, m_sVhdr, sizeof(VIDEOINFOHEADER)+12); - m_sVhdr2->bmiHeader.biCompression=0; - m_sVhdr2->bmiHeader.biBitCount=24; + CodecInfo ci; + ci.dll=dllname; + ci.guid=*guid; + + DS_VideoDecoder* dec=new DS_VideoDecoder(ci, *format, flip); + + _d_ptr=d_ptr; + _handle=(void*)dec; - memset(&m_sDestType, 0, sizeof(m_sDestType)); - m_sDestType.majortype=MEDIATYPE_Video; - m_sDestType.subtype=MEDIASUBTYPE_RGB24; - m_sDestType.formattype=FORMAT_VideoInfo; - m_sDestType.bFixedSizeSamples=true; - m_sDestType.bTemporalCompression=false; - m_sDestType.lSampleSize=abs(m_sVhdr2->bmiHeader.biWidth*m_sVhdr2->bmiHeader.biHeight* - ((m_sVhdr2->bmiHeader.biBitCount+7)/8)); - m_sVhdr2->bmiHeader.biSizeImage=m_sDestType.lSampleSize; - m_sDestType.pUnk=0; - m_sDestType.cbFormat=sizeof(VIDEOINFOHEADER); - m_sDestType.pbFormat=(char*)m_sVhdr2; - m_obh = *m_bh; - m_obh.setBits(24); - - HRESULT result; - - dsf=new DS_Filter(); - dsf->Create(dllname, guid, &m_sOurType, &m_sDestType); - - if(!flip) - { - m_sVhdr2->bmiHeader.biHeight*=-1; - m_obh.biHeight*=-1; - result=dsf->m_pOutputPin->vt->QueryAccept(dsf->m_pOutputPin, &m_sDestType); - if(result){ - printf("DShow: Decoder does not support upside-down frames"); - m_obh.biHeight*=-1; - } - } - -#if 0 - m_sVhdr2->bmiHeader.biBitCount=16; - m_sVhdr2->bmiHeader.biCompression=fccYUY2; - m_sDestType.subtype=MEDIASUBTYPE_YUY2; - result=dsf->m_pOutputPin->vt->QueryAccept(dsf->m_pOutputPin, &m_sDestType); -// if(!result) caps=(CAPS)(caps | CAP_YUY2); -#endif - - m_sVhdr2->bmiHeader.biBitCount=24; - m_sVhdr2->bmiHeader.biCompression=0; - m_sDestType.subtype=MEDIASUBTYPE_RGB24; - m_decoder=m_obh; - //qual = 0-1; - } - catch(FatalError& error) - { - delete[] m_sVhdr2; - return 1; - } return 0; } extern "C" void DS_VideoDecoder_Start(){ - if(dsf->m_iState!=1) return; - dsf->Start(); - - ALLOCATOR_PROPERTIES props, props1; - props.cBuffers=1; - props.cbBuffer=1024*1024; //m_sDestType.lSampleSize;//don't know how to do this correctly - props.cbAlign=props.cbPrefix=0; - dsf->m_pAll->vt->SetProperties(dsf->m_pAll, &props, &props1); - dsf->m_pAll->vt->Commit(dsf->m_pAll); - -// m_outFrame=new CImage(&m_decoder,(unsigned char *)malloc(m_sDestType.lSampleSize),false); - //m_outFrame=new CImage(&m_decoder, 0, false); -// printf("Datap %x\n",m_outFrame->getaddr()); - - -// dsf->m_pOurOutput->SetFramePointer((char **)m_outFrame->getaddr()); //!FIXME! - dsf->m_pOurOutput->SetFramePointer(m_destptr); //!FIXME! - -// filling = realtime; - - dsf->m_iState=2; - return; + DS_VideoDecoder* dec=(DS_VideoDecoder*) _handle; + dec->StartInternal(); } extern "C" void DS_VideoDecoder_Stop(){ - if(dsf->m_iState!=2) return; - dsf->Stop(); -// dsf->m_pOurOutput->SetFramePointer(0); -// free(m_outFrame->data()); - //m_outFrame->release();//just in case - //m_outFrame=0; -// FlushCache(); - dsf->m_iState=1; - return; + DS_VideoDecoder* dec=(DS_VideoDecoder*) _handle; + dec->StopInternal(); } extern "C" void DS_VideoDecoder_Restart(){ - if(dsf->m_iState!=2) return; - - dsf->Stop(); - dsf->Start(); - - ALLOCATOR_PROPERTIES props, props1; - props.cBuffers=1; - props.cbBuffer=m_sDestType.lSampleSize;//don't know how to do this correctly - props.cbAlign=props.cbPrefix=0; - dsf->m_pAll->vt->SetProperties(dsf->m_pAll, &props, &props1); - dsf->m_pAll->vt->Commit(dsf->m_pAll); } extern "C" void DS_VideoDecoder_Close(){ - if(dsf->m_iState==0) return; - if(dsf->m_iState==2) DS_VideoDecoder_Stop(); - delete[] m_sVhdr2; -// delete m_outFrame; } extern "C" int DS_VideoDecoder_DecodeFrame(char* src, int size, int is_keyframe, int render){ - - if(!size)return 0; - - m_bh->biSizeImage=size; - - IMediaSample* sample=0; - //printf("GetBuffer... (m_pAll=%X) ",dsf->m_pAll);fflush(stdout); - dsf->m_pAll->vt->GetBuffer(dsf->m_pAll, &sample, 0, 0, 0); - //printf("OK!\n"); - if(!sample) - { - Debug cerr<<"ERROR: null sample"<vt->GetPointer(sample, (BYTE **)&ptr); - //printf("OK!\n"); - memcpy(ptr, src, size); - //printf("memcpy OK!\n"); - sample->vt->SetActualDataLength(sample, size); - //printf("SetActualDataLength OK!\n"); - sample->vt->SetSyncPoint(sample, is_keyframe); - //printf("SetSyncPoint OK!\n"); - sample->vt->SetPreroll(sample, !render); -// sample->vt->SetMediaType(sample, &m_sOurType); - int result=dsf->m_pImp->vt->Receive(dsf->m_pImp, sample); - if(result) - printf("Error putting data into input pin %x\n", result); - - sample->vt->Release((IUnknown*)sample); - - return 0; + DS_VideoDecoder* dec=(DS_VideoDecoder*) _handle; + CImage image; + image.ptr=*_d_ptr; + return dec->DecodeInternal((void*)src,(size_t)size,is_keyframe,&image); } extern "C" int DS_VideoDecoder_SetDestFmt(int bits, int csp){ - if(dsf->m_iState==0) return -1; -// if(!CImage::supported(csp, bits)) return -1; - HRESULT result; -// BitmapInfo temp=m_obh; - if(csp==0) - { - switch(bits) - { - case 15: - m_sDestType.subtype=MEDIASUBTYPE_RGB555; - break; - case 16: - m_sDestType.subtype=MEDIASUBTYPE_RGB565; - break; - case 24: - m_sDestType.subtype=MEDIASUBTYPE_RGB24; - break; - case 32: - m_sDestType.subtype=MEDIASUBTYPE_RGB32; - break; - default: - break; - } - m_obh.setBits(bits); -// .biSizeImage=abs(temp.biWidth*temp.biHeight*((temp.biBitCount+7)/8)); - } - else - { - m_obh.setSpace(csp,bits); - switch(csp) - { - case fccYUY2: - m_sDestType.subtype=MEDIASUBTYPE_YUY2; - printf("DShow: using YUY2 colorspace\n"); - break; - case fccYV12: - m_sDestType.subtype=MEDIASUBTYPE_YV12; - printf("DShow: using YV12 colorspace\n"); - break; - case fccIYUV: - m_sDestType.subtype=MEDIASUBTYPE_IYUV; - printf("DShow: using IYUV colorspace\n"); - break; - case fccUYVY: - m_sDestType.subtype=MEDIASUBTYPE_UYVY; - printf("DShow: using UYVY colorspace\n"); - break; - case fccYVYU: - m_sDestType.subtype=MEDIASUBTYPE_YVYU; - printf("DShow: using YVYU colorspace\n"); - break; - } - } - - m_sDestType.lSampleSize=m_obh.biSizeImage; - memcpy(&(m_sVhdr2->bmiHeader), &m_obh, sizeof(m_obh)); - m_sVhdr2->bmiHeader.biSize=sizeof(BITMAPINFOHEADER); - if(m_sVhdr2->bmiHeader.biCompression==3) - m_sDestType.cbFormat=sizeof(VIDEOINFOHEADER)+12; - else - m_sDestType.cbFormat=sizeof(VIDEOINFOHEADER); - - result=dsf->m_pOutputPin->vt->QueryAccept(dsf->m_pOutputPin, &m_sDestType); - - if(result!=0) - { - if(csp) - cerr<<"Warning: unsupported color space"<bmiHeader), &m_decoder, sizeof(m_decoder)); - m_sVhdr2->bmiHeader.biSize=sizeof(BITMAPINFOHEADER); - if(m_sVhdr2->bmiHeader.biCompression==3) - m_sDestType.cbFormat=sizeof(VIDEOINFOHEADER)+12; - else - m_sDestType.cbFormat=sizeof(VIDEOINFOHEADER); - return 1; - } - - m_decoder=m_obh; -// m_obh=temp; -// if(csp) -// m_obh.biBitCount=BitmapInfo::BitCount(csp); - m_bh->biBitCount=bits; - if(dsf->m_iState>0) - { - int old_state=dsf->m_iState; - if(dsf->m_iState==2) DS_VideoDecoder_Stop(); - dsf->m_pInputPin->vt->Disconnect(dsf->m_pInputPin); - dsf->m_pOutputPin->vt->Disconnect(dsf->m_pOutputPin); - dsf->m_pOurOutput->SetNewFormat(m_sDestType); - result=dsf->m_pInputPin->vt->ReceiveConnection(dsf->m_pInputPin, dsf->m_pOurInput, &m_sOurType); - if(result) - { - cerr<<"Error reconnecting input pin "<m_pOutputPin->vt->ReceiveConnection(dsf->m_pOutputPin, - dsf->m_pOurOutput, &m_sDestType); - if(result) - { - cerr<<"Error reconnecting output pin "<SetDestFmt(bits,(fourcc_t)csp); } - extern "C" int DS_SetValue_DivX(char* name, int value){ - int temp; - if(dsf->m_iState!=2) return VFW_E_NOT_RUNNING; -// brightness 87 -// contrast 74 -// hue 23 -// saturation 20 -// post process mode 0 -// get1 0x01 -// get2 10 -// get3=set2 86 -// get4=set3 73 -// get5=set4 19 -// get6=set5 23 -// printf("DivX setting: %s = %d\n",name,value); - - IHidden* hidden=(IHidden*)((int)dsf->m_pFilter+0xb8); - if(strcmp(name, "Brightness")==0) - return hidden->vt->SetSmth2(hidden, value, 0); - if(strcmp(name, "Contrast")==0) - return hidden->vt->SetSmth3(hidden, value, 0); - if(strcmp(name, "Hue")==0) - return hidden->vt->SetSmth5(hidden, value, 0); - if(strcmp(name, "Saturation")==0) - return hidden->vt->SetSmth4(hidden, value, 0); - if(strcmp(name, "Quality")==0) - return hidden->vt->SetSmth(hidden, value, 0); - - printf("Invalid setting!\n"); - return -200; + DS_VideoDecoder* dec=(DS_VideoDecoder*) _handle; + return (int) dec->SetValue(name,value); } extern "C" int DS_SetAttr_DivX(char* attribute, int value){ diff -r 558c1b03b8d0 -r da26060c81ef loader/dshow/DS_VideoDecoder.c --- /dev/null Thu Jan 01 00:00:00 1970 +0000 +++ b/loader/dshow/DS_VideoDecoder.c Thu Aug 16 00:50:02 2001 +0000 @@ -0,0 +1,625 @@ +/******************************************************** + + DirectShow Video decoder implementation + Copyright 2000 Eugene Kuznetsov (divx@euro.ru) + +*********************************************************/ + +#include "guids.h" +#include "interfaces.h" + +#include "DS_VideoDecoder.h" +#include +#include +//#include + +#include +#include +#include +#include +#include +#include +#include +#include + +#define __MODULE__ "DirectShow_VideoDecoder" + +extern "C" char* def_path; +extern "C" void setup_FS_Segment(); + +using namespace std; + +DS_VideoDecoder::DS_VideoDecoder(const CodecInfo& info, const BITMAPINFOHEADER& format, int flip) + :IVideoDecoder(info, format) +{ + m_sVhdr2 = 0; + m_iLastQuality = -1; + //memset(&m_obh, 0, sizeof(m_obh)); + //m_obh.biSize = sizeof(m_obh); + try + { + m_pDS_Filter = new DS_Filter(); + + unsigned bihs = (format.biSize < (int) sizeof(BITMAPINFOHEADER)) ? + sizeof(BITMAPINFOHEADER) : format.biSize; + bihs = sizeof(VIDEOINFOHEADER) - sizeof(BITMAPINFOHEADER) + bihs; + + m_sVhdr = (VIDEOINFOHEADER*) new char[bihs]; + memset(m_sVhdr, 0, bihs); + memcpy(&m_sVhdr->bmiHeader, m_bh, m_bh->biSize); + m_sVhdr->rcSource.left = m_sVhdr->rcSource.top = 0; + m_sVhdr->rcSource.right = m_sVhdr->bmiHeader.biWidth; + m_sVhdr->rcSource.bottom = m_sVhdr->bmiHeader.biHeight; + m_sVhdr->rcTarget = m_sVhdr->rcSource; + + m_sOurType.majortype = MEDIATYPE_Video; + m_sOurType.subtype = MEDIATYPE_Video; + m_sOurType.subtype.f1 = m_sVhdr->bmiHeader.biCompression; + m_sOurType.formattype = FORMAT_VideoInfo; + m_sOurType.bFixedSizeSamples = false; + m_sOurType.bTemporalCompression = true; + m_sOurType.pUnk = 0; + m_sOurType.cbFormat = bihs; + m_sOurType.pbFormat = (char*)m_sVhdr; + + m_sVhdr2 = (VIDEOINFOHEADER*)(new char[sizeof(VIDEOINFOHEADER)+12]); + memcpy(m_sVhdr2, m_sVhdr, sizeof(VIDEOINFOHEADER)+12); + m_sVhdr2->bmiHeader.biCompression = 0; + m_sVhdr2->bmiHeader.biBitCount = 24; + + memset(&m_sDestType, 0, sizeof(m_sDestType)); + m_sDestType.majortype = MEDIATYPE_Video; + m_sDestType.subtype = MEDIASUBTYPE_RGB24; + m_sDestType.formattype = FORMAT_VideoInfo; + m_sDestType.bFixedSizeSamples = true; + m_sDestType.bTemporalCompression = false; + m_sDestType.lSampleSize = abs(m_sVhdr2->bmiHeader.biWidth*m_sVhdr2->bmiHeader.biHeight + * ((m_sVhdr2->bmiHeader.biBitCount + 7) / 8)); + m_sVhdr2->bmiHeader.biSizeImage = m_sDestType.lSampleSize; + m_sDestType.pUnk = 0; + m_sDestType.cbFormat = sizeof(VIDEOINFOHEADER); + m_sDestType.pbFormat = (char*)m_sVhdr2; + memcpy(&m_obh, m_bh, sizeof(m_obh)); + m_obh.SetBits(24); + + HRESULT result; + + m_pDS_Filter->Create(info.dll.c_str(), &info.guid, &m_sOurType, &m_sDestType); + + if (!flip) + { + m_sVhdr2->bmiHeader.biHeight *= -1; + m_obh.biHeight *= -1; + result = m_pDS_Filter->m_pOutputPin->vt->QueryAccept(m_pDS_Filter->m_pOutputPin, &m_sDestType); + if (result) + { + cerr << "Decoder does not support upside-down frames" << endl; + m_sVhdr2->bmiHeader.biHeight *= -1; + m_obh.biHeight *= -1; + } + } + + m_decoder = m_obh; + + switch (m_bh->biCompression) + { + case fccDIV3: + case fccDIV4: + case fccDIV5: + case fccMP42: + case fccWMV2: + //YV12 seems to be broken for DivX :-) codec + case fccIV50: + //produces incorrect picture + //m_Caps = (CAPS) (m_Caps & ~CAP_YV12); + m_Caps = CAP_YUY2; // | CAP_I420; + break; + default: + struct ct { + unsigned int bits; + fourcc_t fcc; + GUID subtype; + CAPS cap; + } check[] = { + {16, fccYUY2, MEDIASUBTYPE_YUY2, CAP_YUY2}, + {12, fccIYUV, MEDIASUBTYPE_IYUV, CAP_IYUV}, + {16, fccUYVY, MEDIASUBTYPE_UYVY, CAP_UYVY}, + {12, fccYV12, MEDIASUBTYPE_YV12, CAP_YV12}, + {16, fccYV12, MEDIASUBTYPE_YV12, CAP_YV12}, + {16, fccYVYU, MEDIASUBTYPE_YVYU, CAP_YVYU}, + //{12, fccI420, MEDIASUBTYPE_I420, CAP_I420}, + {0}, + }; + + m_Caps = CAP_NONE; + + for (ct* c = check; c->bits; c++) + { + m_sVhdr2->bmiHeader.biBitCount = c->bits; + m_sVhdr2->bmiHeader.biCompression = c->fcc; + m_sDestType.subtype = c->subtype; + result = m_pDS_Filter->m_pOutputPin->vt->QueryAccept(m_pDS_Filter->m_pOutputPin, &m_sDestType); + if (!result) + m_Caps = (CAPS)(m_Caps | c->cap); + } + } + + if (m_Caps != CAP_NONE) + cout << "Decoder is capable of YUV output ( flags 0x"<bmiHeader.biBitCount = 24; + m_sVhdr2->bmiHeader.biCompression = 0; + m_sDestType.subtype = MEDIASUBTYPE_RGB24; + + m_bIsDivX = ((info.dll == string("divxcvki.ax")) + || (info.dll == string("divx_c32.ax")) + || (info.dll == string("wmvds32.ax")) + || (info.dll == string("wmv8ds32.ax"))); + } + catch (FatalError& error) + { + delete[] m_sVhdr2; + delete m_pDS_Filter; + throw; + } +} + +DS_VideoDecoder::~DS_VideoDecoder() +{ + Stop(); + delete[] m_sVhdr2; + delete m_pDS_Filter; +} + +void DS_VideoDecoder::StartInternal() +{ + //cout << "DSSTART" << endl; + m_pDS_Filter->Start(); + ALLOCATOR_PROPERTIES props, props1; + props.cBuffers = 1; + props.cbBuffer = m_sDestType.lSampleSize; + //don't know how to do this correctly + props.cbAlign = props.cbPrefix = 0; + m_pDS_Filter->m_pAll->vt->SetProperties(m_pDS_Filter->m_pAll, &props, &props1); + m_pDS_Filter->m_pAll->vt->Commit(m_pDS_Filter->m_pAll); +} + +void DS_VideoDecoder::StopInternal() +{ + //cout << "DSSTOP" << endl; + m_pDS_Filter->Stop(); + //??? why was this here ??? m_pOurOutput->SetFramePointer(0); +} + +int DS_VideoDecoder::DecodeInternal(void* src, size_t size, int is_keyframe, CImage* pImage) +{ + IMediaSample* sample = 0; + + m_pDS_Filter->m_pAll->vt->GetBuffer(m_pDS_Filter->m_pAll, &sample, 0, 0, 0); + + if (!sample) + { + Debug cerr << "ERROR: null sample" << endl; + return -1; + } + + //cout << "DECODE " << (void*) pImage << " d: " << (void*) pImage->Data() << endl; + if (pImage) + { + if (!(pImage->Data())) + { + Debug cout << "no m_outFrame??" << endl; + } + else + m_pDS_Filter->m_pOurOutput->SetPointer2((char*)pImage->Data()); + } + + char* ptr; + sample->vt->GetPointer(sample, (BYTE **)&ptr); + memcpy(ptr, src, size); + sample->vt->SetActualDataLength(sample, size); + sample->vt->SetSyncPoint(sample, is_keyframe); + sample->vt->SetPreroll(sample, pImage ? 0 : 1); + // sample->vt->SetMediaType(sample, &m_sOurType); + + // FIXME: - crashing with YV12 at this place decoder will crash + // while doing this call + // %FS register was not setup for calling into win32 dll. Are all + // crashes inside ...->Receive() fixed now? + // + // nope - but this is surely helpfull - I'll try some more experiments + setup_FS_Segment(); +#if 0 + if (!m_pDS_Filter || !m_pDS_Filter->m_pImp + || !m_pDS_Filter->m_pImp->vt + || !m_pDS_Filter->m_pImp->vt->Receive) + printf("DecodeInternal ERROR???\n"); +#endif + int result = m_pDS_Filter->m_pImp->vt->Receive(m_pDS_Filter->m_pImp, sample); + if (result) + { + Debug printf("DS_VideoDecoder::DecodeInternal() error putting data into input pin %x\n", result); + } + + sample->vt->Release((IUnknown*)sample); + + if (m_bIsDivX) + { + int q; + IHidden* hidden=(IHidden*)((int)m_pDS_Filter->m_pFilter + 0xb8); + // always check for actual value + // this seems to be the only way to know the actual value + hidden->vt->GetSmth2(hidden, &m_iLastQuality); + if (m_iLastQuality > 9) + m_iLastQuality -= 10; + + if (m_iLastQuality < 0) + m_iLastQuality = 0; + else if (m_iLastQuality > 4) + m_iLastQuality = 4; + + //cout << " Qual: " << m_iLastQuality << endl; + m_fQuality = m_iLastQuality / 4.0; + } + + // FIXME: last_quality currently works only for DivX movies + // more general approach is needed here + // cout << "Q: " << m_iLastQuality << " rt: " << m_Mode << " dp: " << decpos << endl; + // also accesing vbuf doesn't look very nice at this place + // FIXME later - do it as a virtual method + + if (m_Mode == IVideoDecoder::REALTIME_QUALITY_AUTO) + { + // adjust Quality - depends on how many cached frames we have + int buffered = m_iDecpos - m_iPlaypos; + + if (m_bIsDivX) + { + //cout << "qual " << q << " " << buffered << endl; + if (buffered < (m_iLastQuality * 2 + QMARKLO - 1) + || buffered > ((m_iLastQuality + 1) * 2 + QMARKLO)) + { + // removed old code which was present here + // and replaced with this new uptodate one + + int to = (buffered - QMARKLO) / 2; + if (to < 0) + to = 0; + else if (to > 4) + to = 4; + if (m_iLastQuality != to) + { + IHidden* hidden=(IHidden*)((int)m_pDS_Filter->m_pFilter + 0xb8); + hidden->vt->SetSmth(hidden, to, 0); +#ifndef QUIET + //cout << "Switching quality " << m_iLastQuality << " -> " << to << " b:" << buffered << endl; +#endif + } + } + } + } + + + return 0; +} + +/* + * bits == 0 - leave unchanged + */ +int DS_VideoDecoder::SetDestFmt(int bits, fourcc_t csp) +{ + if (!CImage::Supported(csp, bits)) + return -1; + + // BitmapInfo temp = m_obh; + if (bits != 0) + { + bool ok = true; + + switch (bits) + { + case 15: + m_sDestType.subtype = MEDIASUBTYPE_RGB555; + break; + case 16: + m_sDestType.subtype = MEDIASUBTYPE_RGB565; + break; + case 24: + m_sDestType.subtype = MEDIASUBTYPE_RGB24; + break; + case 32: + m_sDestType.subtype = MEDIASUBTYPE_RGB32; + break; + default: + ok = false; + break; + } + + if (ok) + m_obh.SetBits(bits); + //.biSizeImage=abs(temp.biWidth*temp.biHeight*((temp.biBitCount+7)/8)); + } + + if (csp != 0) + { + bool ok = true; + switch (csp) + { + case fccYUY2: + m_sDestType.subtype = MEDIASUBTYPE_YUY2; + break; + case fccYV12: + m_sDestType.subtype = MEDIASUBTYPE_YV12; + break; + case fccIYUV: + m_sDestType.subtype = MEDIASUBTYPE_IYUV; + break; + case fccUYVY: + m_sDestType.subtype = MEDIASUBTYPE_UYVY; + break; + case fccYVYU: + m_sDestType.subtype = MEDIASUBTYPE_YVYU; + break; + default: + ok = false; + break; + } + + if (ok) + m_obh.SetSpace(csp); + } + m_sDestType.lSampleSize = m_obh.biSizeImage; + memcpy(&(m_sVhdr2->bmiHeader), &m_obh, sizeof(m_obh)); + m_sVhdr2->bmiHeader.biSize = sizeof(BITMAPINFOHEADER); + if (m_sVhdr2->bmiHeader.biCompression == 3) + m_sDestType.cbFormat = sizeof(VIDEOINFOHEADER) + 12; + else + m_sDestType.cbFormat = sizeof(VIDEOINFOHEADER); + + HRESULT result; + bool should_test=true; + switch(csp) + { + case fccYUY2: + if(!(m_Caps & CAP_YUY2)) + should_test=false; + break; + case fccYV12: + if(!(m_Caps & CAP_YV12)) + should_test=false; + break; + case fccIYUV: + if(!(m_Caps & CAP_IYUV)) + should_test=false; + break; + case fccUYVY: + if(!(m_Caps & CAP_UYVY)) + should_test=false; + break; + case fccYVYU: + if(!(m_Caps & CAP_YVYU)) + should_test=false; + break; + } + if(should_test) + result = m_pDS_Filter->m_pOutputPin->vt->QueryAccept(m_pDS_Filter->m_pOutputPin, &m_sDestType); + else + result = -1; + + if (result != 0) + { + if (csp) + cerr << "Warning: unsupported color space" << endl; + else + cerr << "Warning: unsupported bit depth" << endl; + + m_sDestType.lSampleSize = m_decoder.biSizeImage; + memcpy(&(m_sVhdr2->bmiHeader), &m_decoder, sizeof(m_decoder)); + m_sVhdr2->bmiHeader.biSize = sizeof(BITMAPINFOHEADER); + if(m_sVhdr2->bmiHeader.biCompression == 3) + m_sDestType.cbFormat = sizeof(VIDEOINFOHEADER) + 12; + else + m_sDestType.cbFormat = sizeof(VIDEOINFOHEADER); + + return 1; + } + + m_decoder = m_obh; + +// m_obh=temp; +// if(csp) +// m_obh.biBitCount=BitmapInfo::BitCount(csp); + m_bh->biBitCount = bits; + + //Restart(); + bool stoped = false; + if (m_State == START) + { + Stop(); + stoped = true; + } + + m_pDS_Filter->m_pInputPin->vt->Disconnect(m_pDS_Filter->m_pInputPin); + m_pDS_Filter->m_pOutputPin->vt->Disconnect(m_pDS_Filter->m_pOutputPin); + m_pDS_Filter->m_pOurOutput->SetNewFormat(m_sDestType); + result = m_pDS_Filter->m_pInputPin->vt->ReceiveConnection(m_pDS_Filter->m_pInputPin, + m_pDS_Filter->m_pOurInput, + &m_sOurType); + if (result) + { + cerr<<"Error reconnecting input pin "<m_pOutputPin->vt->ReceiveConnection(m_pDS_Filter->m_pOutputPin, + m_pDS_Filter->m_pOurOutput, + &m_sDestType); + if (result) + { + cerr<<"Error reconnecting output pin "<