25 #include "wine/unicode.h" 26 #include "wine/list.h" 46 return This->pFuncsTable->pfnThreadProc(
This);
76 if (!pInputPin || !pFuncsTable || !ppOutputQueue)
83 This = *ppOutputQueue;
84 This->pFuncsTable = pFuncsTable;
85 This->lBatchSize = lBatchSize;
86 This->bBatchExact = bBatchExact;
88 This->csQueue.DebugInfo->Spare[0] = (
DWORD_PTR)(__FILE__
": OutputQueue.csQueue");
91 This->pInputPin = pInputPin;
142 hr = IMemInputPin_ReceiveMultiple(pOutputQueue->
pInputPin->
pMemInputPin,ppSamples, nSamples, nSamplesProcessed);
148 *nSamplesProcessed = 0;
150 for (
i = 0;
i < nSamples;
i++)
155 ERR(
"Out of Memory\n");
161 IMediaSample_AddRef(ppSamples[
i]);
163 (*nSamplesProcessed)++;
201 ERR(
"Out of Memory\n");
215 IPin_EndOfStream(ppin);
240 LONG nSamplesProcessed;
252 ppSamples[nSamples++] = qev->
pSample;
263 IMemInputPin_ReceiveMultiple(pOutputQueue->
pInputPin->
pMemInputPin, ppSamples, nSamples, &nSamplesProcessed);
267 for (
i = 0;
i < nSamples;
i++)
268 IMediaSample_Release(ppSamples[
i]);
281 IPin_EndOfStream(ppin);
288 FIXME(
"Unhandled Event type %i\n",qev->
type);
#define LIST_FOR_EACH_SAFE(cursor, cursor2, list)
static DWORD WINAPI OutputQueue_InitialThreadProc(LPVOID data)
VOID WINAPI OutputQueue_SendAnyway(OutputQueue *pOutputQueue)
struct tagQueuedEvent QueuedEvent
BOOL WINAPI DECLSPEC_HOTPATCH SetEvent(IN HANDLE hEvent)
HRESULT WINAPI OutputQueue_Receive(OutputQueue *pOutputQueue, IMediaSample *pSample)
void WINAPI EnterCriticalSection(LPCRITICAL_SECTION)
HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventW(IN LPSECURITY_ATTRIBUTES lpEventAttributes OPTIONAL, IN BOOL bManualReset, IN BOOL bInitialState, IN LPCWSTR lpName OPTIONAL)
__WINE_SERVER_LIST_INLINE void list_add_tail(struct list *list, struct list *elem)
DWORD WINAPI WaitForSingleObject(IN HANDLE hHandle, IN DWORD dwMilliseconds)
HRESULT WINAPI OutputQueue_Construct(BaseOutputPin *pInputPin, BOOL bAuto, BOOL bQueue, LONG lBatchSize, BOOL bBatchExact, DWORD dwPriority, const OutputQueueFuncTable *pFuncsTable, OutputQueue **ppOutputQueue)
__WINE_SERVER_LIST_INLINE unsigned int list_count(const struct list *list)
HRESULT WINAPI OutputQueue_Destroy(OutputQueue *pOutputQueue)
HANDLE WINAPI DECLSPEC_HOTPATCH CreateThread(IN LPSECURITY_ATTRIBUTES lpThreadAttributes, IN DWORD dwStackSize, IN LPTHREAD_START_ROUTINE lpStartAddress, IN LPVOID lpParameter, IN DWORD dwCreationFlags, OUT LPDWORD lpThreadId)
VOID WINAPI InitializeCriticalSection(OUT LPCRITICAL_SECTION lpCriticalSection)
#define VFW_E_NOT_CONNECTED
VOID WINAPI OutputQueue_EOS(OutputQueue *pOutputQueue)
BOOL WINAPI SetThreadPriority(IN HANDLE hThread, IN int nPriority)
WINE_DEFAULT_DEBUG_CHANNEL(strmbase)
__WINE_SERVER_LIST_INLINE void list_remove(struct list *elem)
PVOID WINAPI HeapAlloc(HANDLE, DWORD, SIZE_T)
void WINAPI DeleteCriticalSection(PCRITICAL_SECTION)
GLint GLenum GLsizei GLsizei GLsizei GLint GLsizei const GLvoid * data
PCRITICAL_SECTION_DEBUG DebugInfo
BaseOutputPin * pInputPin
IMemInputPin * pMemInputPin
__WINE_SERVER_LIST_INLINE int list_empty(const struct list *list)
DWORD WINAPI OutputQueueImpl_ThreadProc(OutputQueue *pOutputQueue)
HRESULT WINAPI OutputQueue_ReceiveMultiple(OutputQueue *pOutputQueue, IMediaSample **ppSamples, LONG nSamples, LONG *nSamplesProcessed)
GLsizei GLenum const GLvoid GLsizei GLenum GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLint GLint GLint GLshort GLshort GLshort GLubyte GLubyte GLubyte GLuint GLuint GLuint GLushort GLushort GLushort GLbyte GLbyte GLbyte GLbyte GLdouble GLdouble GLdouble GLdouble GLfloat GLfloat GLfloat GLfloat GLint GLint GLint GLint GLshort GLshort GLshort GLshort GLubyte GLubyte GLubyte GLubyte GLuint GLuint GLuint GLuint GLushort GLushort GLushort GLushort GLboolean const GLdouble const GLfloat const GLint const GLshort const GLbyte const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLdouble const GLfloat const GLfloat const GLint const GLint const GLshort const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort const GLdouble const GLfloat const GLint const GLshort GLenum GLenum GLenum GLfloat GLenum GLint GLenum GLenum GLenum GLfloat GLenum GLenum GLint GLenum GLfloat GLenum GLint GLint GLushort GLenum GLenum GLfloat GLenum GLenum GLint GLfloat const GLubyte GLenum GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLint GLint GLsizei GLsizei GLint GLenum GLenum const GLvoid GLenum GLenum const GLfloat GLenum GLenum const GLint GLenum GLenum const GLdouble GLenum GLenum const GLfloat GLenum GLenum const GLint GLsizei GLuint GLfloat GLuint GLbitfield GLfloat GLint GLuint GLboolean GLenum GLfloat GLenum GLbitfield GLenum GLfloat GLfloat GLint GLint const GLfloat GLenum GLfloat GLfloat GLint GLint GLfloat GLfloat GLint GLint const GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat GLint GLfloat GLfloat const GLdouble const GLfloat const GLdouble const GLfloat GLint i
static void OutputQueue_FreeSamples(OutputQueue *pOutputQueue)
static int processed(const type_t *type)
__WINE_SERVER_LIST_INLINE void list_init(struct list *list)
void WINAPI LeaveCriticalSection(LPCRITICAL_SECTION)
#define HeapFree(x, y, z)
DWORD_PTR Spare[8/sizeof(DWORD_PTR)]