audiostream.c File Reference

#include "amstream_private.h"
#include "wine/debug.h"
#include "wine/list.h"
#include "wine/strmbase.h"

Include dependency graph for audiostream.c:

Go to the source code of this file.

Classes
struct	queued_receive
struct	audio_stream
struct	audio_sample
struct	enum_media_types

Macros
#define	COBJMACROS

Functions
	WINE_DEFAULT_DEBUG_CHANNEL (quartz)
static void	remove_queued_receive (struct queued_receive *receive)
static void	remove_queued_update (struct audio_sample *sample)
static void	flush_receive_queue (struct audio_stream *stream)
static STREAM_TIME	stream_time_from_position (struct audio_stream *stream, struct queued_receive *receive)
static void	process_update (struct audio_sample *sample, struct queued_receive *receive)
static void	process_updates (struct audio_stream *stream)
static struct audio_sample *	impl_from_IAudioStreamSample (IAudioStreamSample *iface)
static HRESULT WINAPI	audio_sample_QueryInterface (IAudioStreamSample *iface, REFIID riid, void **ret_iface)
static ULONG WINAPI	audio_sample_AddRef (IAudioStreamSample *iface)
static ULONG WINAPI	audio_sample_Release (IAudioStreamSample *iface)
static HRESULT WINAPI	audio_sample_GetMediaStream (IAudioStreamSample *iface, IMediaStream **media_stream)
static HRESULT WINAPI	audio_sample_GetSampleTimes (IAudioStreamSample *iface, STREAM_TIME *start_time, STREAM_TIME *end_time, STREAM_TIME *current_time)
static HRESULT WINAPI	audio_sample_SetSampleTimes (IAudioStreamSample *iface, const STREAM_TIME *start_time, const STREAM_TIME *end_time)
static HRESULT WINAPI	audio_sample_Update (IAudioStreamSample *iface, DWORD flags, HANDLE event, PAPCFUNC apc_func, DWORD apc_data)
static HRESULT WINAPI	audio_sample_CompletionStatus (IAudioStreamSample *iface, DWORD flags, DWORD milliseconds)
static HRESULT WINAPI	audio_sample_GetAudioData (IAudioStreamSample *iface, IAudioData **audio_data)
static HRESULT	audiostreamsample_create (struct audio_stream *parent, IAudioData *audio_data, IAudioStreamSample **audio_stream_sample)
static struct audio_stream *	impl_from_IAMMediaStream (IAMMediaStream *iface)
static HRESULT WINAPI	audio_IAMMediaStream_QueryInterface (IAMMediaStream *iface, REFIID riid, void **ret_iface)
static ULONG WINAPI	audio_IAMMediaStream_AddRef (IAMMediaStream *iface)
static ULONG WINAPI	audio_IAMMediaStream_Release (IAMMediaStream *iface)
static HRESULT WINAPI	audio_IAMMediaStream_GetMultiMediaStream (IAMMediaStream *iface, IMultiMediaStream **mmstream)
static HRESULT WINAPI	audio_IAMMediaStream_GetInformation (IAMMediaStream *iface, MSPID *purpose_id, STREAM_TYPE *type)
static HRESULT WINAPI	audio_IAMMediaStream_SetSameFormat (IAMMediaStream *iface, IMediaStream *pStreamThatHasDesiredFormat, DWORD flags)
static HRESULT WINAPI	audio_IAMMediaStream_AllocateSample (IAMMediaStream *iface, DWORD flags, IStreamSample **sample)
static HRESULT WINAPI	audio_IAMMediaStream_CreateSharedSample (IAMMediaStream *iface, IStreamSample *existing_sample, DWORD flags, IStreamSample **sample)
static HRESULT WINAPI	audio_IAMMediaStream_SendEndOfStream (IAMMediaStream *iface, DWORD flags)
static HRESULT WINAPI	audio_IAMMediaStream_Initialize (IAMMediaStream *iface, IUnknown *source_object, DWORD flags, REFMSPID purpose_id, const STREAM_TYPE stream_type)
static HRESULT WINAPI	audio_IAMMediaStream_SetState (IAMMediaStream *iface, FILTER_STATE state)
static HRESULT WINAPI	audio_IAMMediaStream_JoinAMMultiMediaStream (IAMMediaStream *iface, IAMMultiMediaStream *mmstream)
static HRESULT WINAPI	audio_IAMMediaStream_JoinFilter (IAMMediaStream *iface, IMediaStreamFilter *filter)
static HRESULT WINAPI	audio_IAMMediaStream_JoinFilterGraph (IAMMediaStream *iface, IFilterGraph *filtergraph)
static struct audio_stream *	impl_from_IAudioMediaStream (IAudioMediaStream *iface)
static HRESULT WINAPI	audio_IAudioMediaStream_QueryInterface (IAudioMediaStream *iface, REFIID riid, void **ret_iface)
static ULONG WINAPI	audio_IAudioMediaStream_AddRef (IAudioMediaStream *iface)
static ULONG WINAPI	audio_IAudioMediaStream_Release (IAudioMediaStream *iface)
static HRESULT WINAPI	audio_IAudioMediaStream_GetMultiMediaStream (IAudioMediaStream *iface, IMultiMediaStream **mmstream)
static HRESULT WINAPI	audio_IAudioMediaStream_GetInformation (IAudioMediaStream *iface, MSPID *purpose_id, STREAM_TYPE *type)
static HRESULT WINAPI	audio_IAudioMediaStream_SetSameFormat (IAudioMediaStream *iface, IMediaStream *other, DWORD flags)
static HRESULT WINAPI	audio_IAudioMediaStream_AllocateSample (IAudioMediaStream *iface, DWORD flags, IStreamSample **sample)
static HRESULT WINAPI	audio_IAudioMediaStream_CreateSharedSample (IAudioMediaStream *iface, IStreamSample *existing_sample, DWORD flags, IStreamSample **sample)
static HRESULT WINAPI	audio_IAudioMediaStream_SendEndOfStream (IAudioMediaStream *iface, DWORD flags)
static HRESULT WINAPI	audio_IAudioMediaStream_GetFormat (IAudioMediaStream *iface, WAVEFORMATEX *format)
static HRESULT WINAPI	audio_IAudioMediaStream_SetFormat (IAudioMediaStream *iface, const WAVEFORMATEX *format)
static HRESULT WINAPI	audio_IAudioMediaStream_CreateSample (IAudioMediaStream *iface, IAudioData *audio_data, DWORD flags, IAudioStreamSample **sample)
static struct enum_media_types *	impl_from_IEnumMediaTypes (IEnumMediaTypes *iface)
static HRESULT WINAPI	enum_media_types_QueryInterface (IEnumMediaTypes *iface, REFIID iid, void **out)
static ULONG WINAPI	enum_media_types_AddRef (IEnumMediaTypes *iface)
static ULONG WINAPI	enum_media_types_Release (IEnumMediaTypes *iface)
static HRESULT WINAPI	enum_media_types_Next (IEnumMediaTypes *iface, ULONG count, AM_MEDIA_TYPE **mts, ULONG *ret_count)
static HRESULT WINAPI	enum_media_types_Skip (IEnumMediaTypes *iface, ULONG count)
static HRESULT WINAPI	enum_media_types_Reset (IEnumMediaTypes *iface)
static HRESULT WINAPI	enum_media_types_Clone (IEnumMediaTypes *iface, IEnumMediaTypes **out)
static struct audio_stream *	impl_from_IPin (IPin *iface)
static HRESULT WINAPI	audio_sink_QueryInterface (IPin *iface, REFIID iid, void **out)
static ULONG WINAPI	audio_sink_AddRef (IPin *iface)
static ULONG WINAPI	audio_sink_Release (IPin *iface)
static HRESULT WINAPI	audio_sink_Connect (IPin *iface, IPin *peer, const AM_MEDIA_TYPE *mt)
static HRESULT WINAPI	audio_sink_ReceiveConnection (IPin *iface, IPin *peer, const AM_MEDIA_TYPE *mt)
static HRESULT WINAPI	audio_sink_Disconnect (IPin *iface)
static HRESULT WINAPI	audio_sink_ConnectedTo (IPin *iface, IPin **peer)
static HRESULT WINAPI	audio_sink_ConnectionMediaType (IPin *iface, AM_MEDIA_TYPE *mt)
static HRESULT WINAPI	audio_sink_QueryPinInfo (IPin *iface, PIN_INFO *info)
static HRESULT WINAPI	audio_sink_QueryDirection (IPin *iface, PIN_DIRECTION *dir)
static HRESULT WINAPI	audio_sink_QueryId (IPin *iface, WCHAR **id)
static HRESULT WINAPI	audio_sink_QueryAccept (IPin *iface, const AM_MEDIA_TYPE *mt)
static HRESULT WINAPI	audio_sink_EnumMediaTypes (IPin *iface, IEnumMediaTypes **enum_media_types)
static HRESULT WINAPI	audio_sink_QueryInternalConnections (IPin *iface, IPin **pins, ULONG *count)
static HRESULT WINAPI	audio_sink_EndOfStream (IPin *iface)
static HRESULT WINAPI	audio_sink_BeginFlush (IPin *iface)
static HRESULT WINAPI	audio_sink_EndFlush (IPin *iface)
static HRESULT WINAPI	audio_sink_NewSegment (IPin *iface, REFERENCE_TIME start, REFERENCE_TIME stop, double rate)
static struct audio_stream *	impl_from_IMemInputPin (IMemInputPin *iface)
static HRESULT WINAPI	audio_meminput_QueryInterface (IMemInputPin *iface, REFIID iid, void **out)
static ULONG WINAPI	audio_meminput_AddRef (IMemInputPin *iface)
static ULONG WINAPI	audio_meminput_Release (IMemInputPin *iface)
static HRESULT WINAPI	audio_meminput_GetAllocator (IMemInputPin *iface, IMemAllocator **allocator)
static HRESULT WINAPI	audio_meminput_NotifyAllocator (IMemInputPin *iface, IMemAllocator *allocator, BOOL readonly)
static HRESULT WINAPI	audio_meminput_GetAllocatorRequirements (IMemInputPin *iface, ALLOCATOR_PROPERTIES *props)
static HRESULT WINAPI	audio_meminput_Receive (IMemInputPin *iface, IMediaSample *sample)
static HRESULT WINAPI	audio_meminput_ReceiveMultiple (IMemInputPin *iface, IMediaSample **samples, LONG count, LONG *processed)
static HRESULT WINAPI	audio_meminput_ReceiveCanBlock (IMemInputPin *iface)
HRESULT	audio_stream_create (IUnknown *outer, void **out)

Variables
static const WCHAR	sink_id [] = L"I{A35FF56B-9FDA-11D0-8FDF-00C04FD9189D}"
static const struct IAudioStreamSampleVtbl	AudioStreamSample_Vtbl
static const struct IAMMediaStreamVtbl	audio_IAMMediaStream_vtbl
static const struct IAudioMediaStreamVtbl	audio_IAudioMediaStream_vtbl
static const IEnumMediaTypesVtbl	enum_media_types_vtbl
static const IPinVtbl	audio_sink_vtbl
static const IMemInputPinVtbl	audio_meminput_vtbl

Macro Definition Documentation

COBJMACROS

#define COBJMACROS

Definition at line 21 of file audiostream.c.

Function Documentation

audio_IAMMediaStream_AddRef()

static ULONG WINAPI audio_IAMMediaStream_AddRef ( IAMMediaStream *  iface )

static

Definition at line 446 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
    ULONG ref = InterlockedIncrement(&This->ref);
 
    TRACE("(%p/%p)->(): new ref = %lu\n", iface, This, ref);
 
    return ref;
}

audio_IAMMediaStream_AllocateSample()

static HRESULT WINAPI audio_IAMMediaStream_AllocateSample ( IAMMediaStream *  iface, DWORD  flags, IStreamSample **  sample  )

static

Definition at line 514 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    FIXME("(%p/%p)->(%lx,%p) stub!\n", This, iface, flags, sample);
 
    return S_FALSE;
}

audio_IAMMediaStream_CreateSharedSample()

static HRESULT WINAPI audio_IAMMediaStream_CreateSharedSample ( IAMMediaStream *  iface, IStreamSample *  existing_sample, DWORD  flags, IStreamSample **  sample  )

static

Definition at line 524 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    FIXME("(%p/%p)->(%p,%lx,%p) stub!\n", This, iface, existing_sample, flags, sample);
 
    return S_FALSE;
}

audio_IAMMediaStream_GetInformation()

static HRESULT WINAPI audio_IAMMediaStream_GetInformation ( IAMMediaStream *  iface, MSPID *  purpose_id, STREAM_TYPE *  type  )

static

Definition at line 489 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    TRACE("(%p/%p)->(%p,%p)\n", This, iface, purpose_id, type);
 
    if (purpose_id)
        *purpose_id = This->purpose_id;
    if (type)
        *type = This->stream_type;
 
    return S_OK;
}

audio_IAMMediaStream_GetMultiMediaStream()

static HRESULT WINAPI audio_IAMMediaStream_GetMultiMediaStream ( IAMMediaStream *  iface, IMultiMediaStream **  mmstream  )

static

Definition at line 473 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, mmstream %p.\n", stream, mmstream);
 
    if (!mmstream)
        return E_POINTER;
 
    if (stream->parent)
        IMultiMediaStream_AddRef(stream->parent);
    *mmstream = stream->parent;
    return S_OK;
}

audio_IAMMediaStream_Initialize()

static HRESULT WINAPI audio_IAMMediaStream_Initialize ( IAMMediaStream *  iface, IUnknown *  source_object, DWORD  flags, REFMSPID  purpose_id, const STREAM_TYPE  stream_type  )

static

Definition at line 544 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, source_object %p, flags %lx, purpose_id %s, stream_type %u.\n", stream, source_object, flags,
            debugstr_guid(purpose_id), stream_type);
 
    if (!purpose_id)
        return E_POINTER;
 
    if (source_object)
        FIXME("Specifying a stream object is not yet supported.\n");
 
    if (flags & AMMSF_CREATEPEER)
        FIXME("AMMSF_CREATEPEER is not yet supported.\n");
 
    stream->purpose_id = *purpose_id;
    stream->stream_type = stream_type;
 
    return S_OK;
}

audio_IAMMediaStream_JoinAMMultiMediaStream()

static HRESULT WINAPI audio_IAMMediaStream_JoinAMMultiMediaStream ( IAMMediaStream *  iface, IAMMultiMediaStream *  mmstream  )

static

Definition at line 587 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, mmstream %p.\n", stream, mmstream);
 
    stream->parent = (IMultiMediaStream *)mmstream;
 
    return S_OK;
}

audio_IAMMediaStream_JoinFilter()

static HRESULT WINAPI audio_IAMMediaStream_JoinFilter ( IAMMediaStream *  iface, IMediaStreamFilter *  filter  )

static

Definition at line 599 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, filter %p.\n", stream, filter);
 
    stream->filter = filter;
 
    return S_OK;
}

audio_IAMMediaStream_JoinFilterGraph()

static HRESULT WINAPI audio_IAMMediaStream_JoinFilterGraph ( IAMMediaStream *  iface, IFilterGraph *  filtergraph  )

static

Definition at line 610 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, filtergraph %p.\n", stream, filtergraph);
 
    return S_OK;
}

audio_IAMMediaStream_QueryInterface()

static HRESULT WINAPI audio_IAMMediaStream_QueryInterface ( IAMMediaStream *  iface, REFIID  riid, void **  ret_iface  )

static

Definition at line 408 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    TRACE("(%p/%p)->(%s,%p)\n", iface, This, debugstr_guid(riid), ret_iface);
 
    if (IsEqualGUID(riid, &IID_IUnknown) ||
        IsEqualGUID(riid, &IID_IMediaStream) ||
        IsEqualGUID(riid, &IID_IAMMediaStream))
    {
        IAMMediaStream_AddRef(iface);
        *ret_iface = iface;
        return S_OK;
    }
    else if (IsEqualGUID(riid, &IID_IAudioMediaStream))
    {
        IAMMediaStream_AddRef(iface);
        *ret_iface = &This->IAudioMediaStream_iface;
        return S_OK;
    }
    else if (IsEqualGUID(riid, &IID_IPin))
    {
        IAMMediaStream_AddRef(iface);
        *ret_iface = &This->IPin_iface;
        return S_OK;
    }
    else if (IsEqualGUID(riid, &IID_IMemInputPin))
    {
        IAMMediaStream_AddRef(iface);
        *ret_iface = &This->IMemInputPin_iface;
        return S_OK;
    }
 
    ERR("(%p)->(%s,%p),not found\n", This, debugstr_guid(riid), ret_iface);
    return E_NOINTERFACE;
}

audio_IAMMediaStream_Release()

static ULONG WINAPI audio_IAMMediaStream_Release ( IAMMediaStream *  iface )

static

Definition at line 456 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
    ULONG ref = InterlockedDecrement(&stream->ref);
 
    TRACE("%p decreasing refcount to %lu.\n", stream, ref);
 
    if (!ref)
    {
        DeleteCriticalSection(&stream->cs);
        free(stream);
    }
 
    return ref;
}

audio_IAMMediaStream_SendEndOfStream()

static HRESULT WINAPI audio_IAMMediaStream_SendEndOfStream ( IAMMediaStream *  iface, DWORD  flags  )

static

Definition at line 534 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    FIXME("(%p/%p)->(%lx) stub!\n", This, iface, flags);
 
    return S_FALSE;
}

audio_IAMMediaStream_SetSameFormat()

static HRESULT WINAPI audio_IAMMediaStream_SetSameFormat ( IAMMediaStream *  iface, IMediaStream *  pStreamThatHasDesiredFormat, DWORD  flags  )

static

Definition at line 504 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAMMediaStream(iface);
 
    FIXME("(%p/%p)->(%p,%lx) stub!\n", This, iface, pStreamThatHasDesiredFormat, flags);
 
    return S_FALSE;
}

audio_IAMMediaStream_SetState()

static HRESULT WINAPI audio_IAMMediaStream_SetState ( IAMMediaStream *  iface, FILTER_STATE  state  )

static

Definition at line 567 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAMMediaStream(iface);
 
    TRACE("stream %p, state %u.\n", stream, state);
 
    EnterCriticalSection(&stream->cs);
 
    if (state == State_Stopped)
        flush_receive_queue(stream);
    if (stream->state == State_Stopped)
        stream->eos = FALSE;
 
    stream->state = state;
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_IAudioMediaStream_AddRef()

static ULONG WINAPI audio_IAudioMediaStream_AddRef ( IAudioMediaStream *  iface )

static

Definition at line 651 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAudioMediaStream(iface);
    TRACE("(%p/%p)\n", iface, This);
    return IAMMediaStream_AddRef(&This->IAMMediaStream_iface);
}

audio_IAudioMediaStream_AllocateSample()

static HRESULT WINAPI audio_IAudioMediaStream_AllocateSample ( IAudioMediaStream *  iface, DWORD  flags, IStreamSample **  sample  )

static

Definition at line 686 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_AllocateSample(&stream->IAMMediaStream_iface, flags, sample);
}

audio_IAudioMediaStream_CreateSample()

static HRESULT WINAPI audio_IAudioMediaStream_CreateSample ( IAudioMediaStream *  iface, IAudioData *  audio_data, DWORD  flags, IAudioStreamSample **  sample  )

static

Definition at line 759 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAudioMediaStream(iface);
 
    TRACE("(%p/%p)->(%p,%lu,%p)\n", iface, This, audio_data, flags, sample);
 
    if (!audio_data)
        return E_POINTER;
 
    return audiostreamsample_create(This, audio_data, sample);
}

audio_IAudioMediaStream_CreateSharedSample()

static HRESULT WINAPI audio_IAudioMediaStream_CreateSharedSample ( IAudioMediaStream *  iface, IStreamSample *  existing_sample, DWORD  flags, IStreamSample **  sample  )

static

Definition at line 693 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_CreateSharedSample(&stream->IAMMediaStream_iface, existing_sample, flags, sample);
}

audio_IAudioMediaStream_GetFormat()

static HRESULT WINAPI audio_IAudioMediaStream_GetFormat ( IAudioMediaStream *  iface, WAVEFORMATEX *  format  )

static

Definition at line 707 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
 
    TRACE("stream %p, format %p.\n", stream, format);
 
    if (!format)
        return E_POINTER;
 
    EnterCriticalSection(&stream->cs);
 
    if (!stream->peer)
    {
        LeaveCriticalSection(&stream->cs);
        return MS_E_NOSTREAM;
    }
 
    *format = *(WAVEFORMATEX *)stream->mt.pbFormat;
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_IAudioMediaStream_GetInformation()

static HRESULT WINAPI audio_IAudioMediaStream_GetInformation ( IAudioMediaStream *  iface, MSPID *  purpose_id, STREAM_TYPE *  type  )

static

Definition at line 672 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_GetInformation(&stream->IAMMediaStream_iface, purpose_id, type);
}

audio_IAudioMediaStream_GetMultiMediaStream()

static HRESULT WINAPI audio_IAudioMediaStream_GetMultiMediaStream ( IAudioMediaStream *  iface, IMultiMediaStream **  mmstream  )

static

Definition at line 665 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_GetMultiMediaStream(&stream->IAMMediaStream_iface, mmstream);
}

audio_IAudioMediaStream_QueryInterface()

static HRESULT WINAPI audio_IAudioMediaStream_QueryInterface ( IAudioMediaStream *  iface, REFIID  riid, void **  ret_iface  )

static

Definition at line 643 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAudioMediaStream(iface);
    TRACE("(%p/%p)->(%s,%p)\n", iface, This, debugstr_guid(riid), ret_iface);
    return IAMMediaStream_QueryInterface(&This->IAMMediaStream_iface, riid, ret_iface);
}

audio_IAudioMediaStream_Release()

static ULONG WINAPI audio_IAudioMediaStream_Release ( IAudioMediaStream *  iface )

static

Definition at line 658 of file audiostream.c.

{
    struct audio_stream *This = impl_from_IAudioMediaStream(iface);
    TRACE("(%p/%p)\n", iface, This);
    return IAMMediaStream_Release(&This->IAMMediaStream_iface);
}

audio_IAudioMediaStream_SendEndOfStream()

static HRESULT WINAPI audio_IAudioMediaStream_SendEndOfStream ( IAudioMediaStream *  iface, DWORD  flags  )

static

Definition at line 700 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_SendEndOfStream(&stream->IAMMediaStream_iface, flags);
}

audio_IAudioMediaStream_SetFormat()

static HRESULT WINAPI audio_IAudioMediaStream_SetFormat ( IAudioMediaStream *  iface, const WAVEFORMATEX *  format  )

static

Definition at line 731 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
 
    TRACE("stream %p, format %p.\n", stream, format);
 
    if (!format)
        return E_POINTER;
 
    if (format->wFormatTag != WAVE_FORMAT_PCM)
        return E_INVALIDARG;
 
    EnterCriticalSection(&stream->cs);
 
    if ((stream->peer && memcmp(format, stream->mt.pbFormat, sizeof(WAVEFORMATEX)))
            || (stream->format.wFormatTag && memcmp(format, &stream->format, sizeof(WAVEFORMATEX))))
    {
        LeaveCriticalSection(&stream->cs);
        return E_INVALIDARG;
    }
 
    stream->format = *format;
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_IAudioMediaStream_SetSameFormat()

static HRESULT WINAPI audio_IAudioMediaStream_SetSameFormat ( IAudioMediaStream *  iface, IMediaStream *  other, DWORD  flags  )

static

Definition at line 679 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IAudioMediaStream(iface);
    return IAMMediaStream_SetSameFormat(&stream->IAMMediaStream_iface, other, flags);
}

audio_meminput_AddRef()

static ULONG WINAPI audio_meminput_AddRef ( IMemInputPin *  iface )

static

Definition at line 1257 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
    return IAMMediaStream_AddRef(&stream->IAMMediaStream_iface);
}

audio_meminput_GetAllocator()

static HRESULT WINAPI audio_meminput_GetAllocator ( IMemInputPin *  iface, IMemAllocator **  allocator  )

static

Definition at line 1269 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
 
    TRACE("stream %p, allocator %p.\n", stream, allocator);
 
    if (stream->allocator)
    {
        IMemAllocator_AddRef(*allocator = stream->allocator);
        return S_OK;
    }
 
    *allocator = NULL;
    return VFW_E_NO_ALLOCATOR;
}

audio_meminput_GetAllocatorRequirements()

static HRESULT WINAPI audio_meminput_GetAllocatorRequirements ( IMemInputPin *  iface, ALLOCATOR_PROPERTIES *  props  )

static

Definition at line 1303 of file audiostream.c.

{
    TRACE("iface %p, props %p.\n", iface, props);
    return E_NOTIMPL;
}

audio_meminput_NotifyAllocator()

static HRESULT WINAPI audio_meminput_NotifyAllocator ( IMemInputPin *  iface, IMemAllocator *  allocator, BOOL  readonly  )

static

Definition at line 1285 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
 
    TRACE("stream %p, allocator %p, readonly %d.\n", stream, allocator, readonly);
 
    if (!allocator)
        return E_POINTER;
 
    if (allocator)
        IMemAllocator_AddRef(allocator);
    if (stream->allocator)
        IMemAllocator_Release(stream->allocator);
    stream->allocator = allocator;
 
    return S_OK;
}

audio_meminput_QueryInterface()

static HRESULT WINAPI audio_meminput_QueryInterface ( IMemInputPin *  iface, REFIID  iid, void **  out  )

static

Definition at line 1251 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
    return IAMMediaStream_QueryInterface(&stream->IAMMediaStream_iface, iid, out);
}

audio_meminput_Receive()

static HRESULT WINAPI audio_meminput_Receive ( IMemInputPin *  iface, IMediaSample *  sample  )

static

Definition at line 1309 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
    struct queued_receive *receive;
    REFERENCE_TIME start_time = 0;
    REFERENCE_TIME end_time = 0;
    BYTE *pointer;
    HRESULT hr;
 
    TRACE("stream %p, sample %p.\n", stream, sample);
 
    EnterCriticalSection(&stream->cs);
 
    if (stream->state == State_Stopped)
    {
        LeaveCriticalSection(&stream->cs);
        return VFW_E_WRONG_STATE;
    }
    if (stream->flushing)
    {
        LeaveCriticalSection(&stream->cs);
        return S_FALSE;
    }
 
    hr = IMediaSample_GetPointer(sample, &pointer);
    if (FAILED(hr))
    {
        LeaveCriticalSection(&stream->cs);
        return hr;
    }
 
    IMediaSample_GetTime(sample, &start_time, &end_time);
 
    receive = calloc(1, sizeof(*receive));
    if (!receive)
    {
        LeaveCriticalSection(&stream->cs);
        return E_OUTOFMEMORY;
    }
 
    receive->length = IMediaSample_GetActualDataLength(sample);
    receive->pointer = pointer;
    receive->sample = sample;
    receive->start_time = start_time + stream->segment_start;
    IMediaSample_AddRef(receive->sample);
    list_add_tail(&stream->receive_queue, &receive->entry);
 
    process_updates(stream);
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_meminput_ReceiveCanBlock()

static HRESULT WINAPI audio_meminput_ReceiveCanBlock ( IMemInputPin *  iface )

static

Definition at line 1370 of file audiostream.c.

{
    TRACE("iface %p.\n", iface);
    return S_OK;
}

audio_meminput_ReceiveMultiple()

static HRESULT WINAPI audio_meminput_ReceiveMultiple ( IMemInputPin *  iface, IMediaSample **  samples, LONG  count, LONG *  processed  )

static

Definition at line 1363 of file audiostream.c.

{
    FIXME("iface %p, samples %p, count %lu, processed %p, stub!\n", iface, samples, count, processed);
    return E_NOTIMPL;
}

audio_meminput_Release()

static ULONG WINAPI audio_meminput_Release ( IMemInputPin *  iface )

static

Definition at line 1263 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IMemInputPin(iface);
    return IAMMediaStream_Release(&stream->IAMMediaStream_iface);
}

audio_sample_AddRef()

static ULONG WINAPI audio_sample_AddRef ( IAudioStreamSample *  iface )

static

Definition at line 187 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
    ULONG refcount = InterlockedIncrement(&sample->ref);
    TRACE("%p increasing refcount to %lu.\n", sample, refcount);
    return refcount;
}

audio_sample_CompletionStatus()

static HRESULT WINAPI audio_sample_CompletionStatus ( IAudioStreamSample *  iface, DWORD  flags, DWORD  milliseconds  )

static

Definition at line 326 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
    HRESULT hr;
 
    TRACE("sample %p, flags %#lx, milliseconds %lu.\n", sample, flags, milliseconds);
 
    if (flags)
    {
        FIXME("Unhandled flags %#lx.\n", flags);
        return E_NOTIMPL;
    }
 
    EnterCriticalSection(&sample->parent->cs);
 
    hr = sample->update_hr;
 
    LeaveCriticalSection(&sample->parent->cs);
 
    return hr;
}

audio_sample_GetAudioData()

static HRESULT WINAPI audio_sample_GetAudioData ( IAudioStreamSample *  iface, IAudioData **  audio_data  )

static

Definition at line 349 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
 
    TRACE("sample %p, audio_data %p.\n", sample, audio_data);
 
    if (!audio_data)
        return E_POINTER;
 
    IAudioData_AddRef(sample->audio_data);
    *audio_data = sample->audio_data;
 
    return S_OK;
}

audio_sample_GetMediaStream()

static HRESULT WINAPI audio_sample_GetMediaStream ( IAudioStreamSample *  iface, IMediaStream **  media_stream  )

static

Definition at line 211 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
 
    TRACE("sample %p, media_stream %p.\n", iface, media_stream);
 
    if (!media_stream)
        return E_POINTER;
 
    IAMMediaStream_AddRef(&sample->parent->IAMMediaStream_iface);
    *media_stream = (IMediaStream *)&sample->parent->IAMMediaStream_iface;
 
    return S_OK;
}

audio_sample_GetSampleTimes()

static HRESULT WINAPI audio_sample_GetSampleTimes ( IAudioStreamSample *  iface, STREAM_TIME *  start_time, STREAM_TIME *  end_time, STREAM_TIME *  current_time  )

static

Definition at line 226 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
 
    TRACE("sample %p, start_time %p, end_time %p, current_time %p.\n", sample, start_time, end_time, current_time);
 
    if (current_time)
        IMediaStreamFilter_GetCurrentStreamTime(sample->parent->filter, current_time);
 
    if (start_time)
        *start_time = sample->start_time;
    if (end_time)
        *end_time = sample->end_time;
 
    return S_OK;
}

audio_sample_QueryInterface()

static HRESULT WINAPI audio_sample_QueryInterface ( IAudioStreamSample *  iface, REFIID  riid, void **  ret_iface  )

static

Definition at line 167 of file audiostream.c.

{
    TRACE("(%p)->(%s,%p)\n", iface, debugstr_guid(riid), ret_iface);
 
    if (IsEqualGUID(riid, &IID_IUnknown) ||
        IsEqualGUID(riid, &IID_IStreamSample) ||
        IsEqualGUID(riid, &IID_IAudioStreamSample))
    {
        IAudioStreamSample_AddRef(iface);
        *ret_iface = iface;
        return S_OK;
    }
 
    *ret_iface = NULL;
 
    ERR("(%p)->(%s,%p),not found\n", iface, debugstr_guid(riid), ret_iface);
    return E_NOINTERFACE;
}

audio_sample_Release()

static ULONG WINAPI audio_sample_Release ( IAudioStreamSample *  iface )

static

Definition at line 195 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
    ULONG refcount = InterlockedDecrement(&sample->ref);
    TRACE("%p decreasing refcount to %lu.\n", sample, refcount);
    if (!refcount)
    {
        IAMMediaStream_Release(&sample->parent->IAMMediaStream_iface);
        IAudioData_Release(sample->audio_data);
        CloseHandle(sample->update_event);
        free(sample);
    }
    return refcount;
}

audio_sample_SetSampleTimes()

static HRESULT WINAPI audio_sample_SetSampleTimes ( IAudioStreamSample *  iface, const STREAM_TIME *  start_time, const STREAM_TIME *  end_time  )

static

Definition at line 244 of file audiostream.c.

{
    FIXME("(%p)->(%p,%p): stub\n", iface, start_time, end_time);
 
    return E_NOTIMPL;
}

audio_sample_Update()

static HRESULT WINAPI audio_sample_Update ( IAudioStreamSample *  iface, DWORD  flags, HANDLE  event, PAPCFUNC  apc_func, DWORD  apc_data  )

static

Definition at line 252 of file audiostream.c.

{
    struct audio_sample *sample = impl_from_IAudioStreamSample(iface);
    BYTE *pointer;
    DWORD length;
    HRESULT hr;
 
    TRACE("sample %p, flags %#lx, event %p, apc_func %p, apc_data %#lx.\n",
            sample, flags, event, apc_func, apc_data);
 
    hr = IAudioData_GetInfo(sample->audio_data, &length, &pointer, NULL);
    if (FAILED(hr))
        return hr;
 
    if (event && apc_func)
        return E_INVALIDARG;
 
    if (apc_func)
    {
        FIXME("APC support is not implemented!\n");
        return E_NOTIMPL;
    }
 
    if (event)
    {
        FIXME("Event parameter support is not implemented!\n");
        return E_NOTIMPL;
    }
 
    if (flags & ~SSUPDATE_ASYNC)
    {
        FIXME("Unsupported flags %#lx.\n", flags);
        return E_NOTIMPL;
    }
 
    EnterCriticalSection(&sample->parent->cs);
 
    if (sample->parent->state != State_Running)
    {
        LeaveCriticalSection(&sample->parent->cs);
        return MS_E_NOTRUNNING;
    }
    if (!sample->parent->peer)
    {
        LeaveCriticalSection(&sample->parent->cs);
        return MS_S_ENDOFSTREAM;
    }
    if (MS_S_PENDING == sample->update_hr)
    {
        LeaveCriticalSection(&sample->parent->cs);
        return MS_E_BUSY;
    }
 
    sample->length = length;
    sample->pointer = pointer;
    sample->position = 0;
    sample->update_hr = MS_S_PENDING;
    ResetEvent(sample->update_event);
    list_add_tail(&sample->parent->update_queue, &sample->entry);
 
    process_updates(sample->parent);
    hr = sample->update_hr;
 
    LeaveCriticalSection(&sample->parent->cs);
 
    if (hr != MS_S_PENDING || (flags & SSUPDATE_ASYNC))
        return hr;
 
    WaitForSingleObject(sample->update_event, INFINITE);
 
    return sample->update_hr;
}

audio_sink_AddRef()

static ULONG WINAPI audio_sink_AddRef ( IPin *  iface )

static

Definition at line 939 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    return IAMMediaStream_AddRef(&stream->IAMMediaStream_iface);
}

audio_sink_BeginFlush()

static HRESULT WINAPI audio_sink_BeginFlush ( IPin *  iface )

static

Definition at line 1168 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    BOOL cancel_eos;
 
    TRACE("stream %p.\n", stream);
 
    EnterCriticalSection(&stream->cs);
 
    cancel_eos = stream->eos;
 
    stream->flushing = TRUE;
    stream->eos = FALSE;
    flush_receive_queue(stream);
 
    LeaveCriticalSection(&stream->cs);
 
    /* Calling IMediaStreamFilter::Flush() inside the critical section would
     * invert the locking order, so we must leave it first to avoid the
     * application thread deadlocking on the filter's critical section. */
    IMediaStreamFilter_Flush(stream->filter, cancel_eos);
 
    return S_OK;
}

audio_sink_Connect()

static HRESULT WINAPI audio_sink_Connect ( IPin *  iface, IPin *  peer, const AM_MEDIA_TYPE *  mt  )

static

Definition at line 951 of file audiostream.c.

{
    WARN("iface %p, peer %p, mt %p, unexpected call!\n", iface, peer, mt);
    return E_UNEXPECTED;
}

audio_sink_ConnectedTo()

static HRESULT WINAPI audio_sink_ConnectedTo ( IPin *  iface, IPin **  peer  )

static

Definition at line 1026 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    HRESULT hr;
 
    TRACE("stream %p, peer %p.\n", stream, peer);
 
    EnterCriticalSection(&stream->cs);
 
    if (stream->peer)
    {
        IPin_AddRef(*peer = stream->peer);
        hr = S_OK;
    }
    else
    {
        *peer = NULL;
        hr = VFW_E_NOT_CONNECTED;
    }
 
    LeaveCriticalSection(&stream->cs);
 
    return hr;
}

audio_sink_ConnectionMediaType()

static HRESULT WINAPI audio_sink_ConnectionMediaType ( IPin *  iface, AM_MEDIA_TYPE *  mt  )

static

Definition at line 1051 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    HRESULT hr;
 
    TRACE("stream %p, mt %p.\n", stream, mt);
 
    EnterCriticalSection(&stream->cs);
 
    if (stream->peer)
    {
        CopyMediaType(mt, &stream->mt);
        hr = S_OK;
    }
    else
    {
        memset(mt, 0, sizeof(AM_MEDIA_TYPE));
        hr = VFW_E_NOT_CONNECTED;
    }
 
    LeaveCriticalSection(&stream->cs);
 
    return hr;
}

audio_sink_Disconnect()

static HRESULT WINAPI audio_sink_Disconnect ( IPin *  iface )

static

Definition at line 1002 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
 
    TRACE("stream %p.\n", stream);
 
    EnterCriticalSection(&stream->cs);
 
    if (!stream->peer)
    {
        LeaveCriticalSection(&stream->cs);
        return S_FALSE;
    }
 
    IPin_Release(stream->peer);
    stream->peer = NULL;
    FreeMediaType(&stream->mt);
    memset(&stream->mt, 0, sizeof(AM_MEDIA_TYPE));
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_sink_EndFlush()

static HRESULT WINAPI audio_sink_EndFlush ( IPin *  iface )

static

Definition at line 1193 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
 
    TRACE("stream %p.\n", stream);
 
    EnterCriticalSection(&stream->cs);
 
    stream->flushing = FALSE;
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_sink_EndOfStream()

static HRESULT WINAPI audio_sink_EndOfStream ( IPin *  iface )

static

Definition at line 1140 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
 
    TRACE("stream %p.\n", stream);
 
    EnterCriticalSection(&stream->cs);
 
    if (stream->eos || stream->flushing)
    {
        LeaveCriticalSection(&stream->cs);
        return E_FAIL;
    }
 
    stream->eos = TRUE;
 
    process_updates(stream);
 
    LeaveCriticalSection(&stream->cs);
 
    /* Calling IMediaStreamFilter::EndOfStream() inside the critical section
     * would invert the locking order, so we must leave it first to avoid
     * the streaming thread deadlocking on the filter's critical section. */
    IMediaStreamFilter_EndOfStream(stream->filter);
 
    return S_OK;
}

audio_sink_EnumMediaTypes()

static HRESULT WINAPI audio_sink_EnumMediaTypes ( IPin *  iface, IEnumMediaTypes **  enum_media_types  )

static

Definition at line 1114 of file audiostream.c.

{
    struct enum_media_types *object;
 
    TRACE("iface %p, enum_media_types %p.\n", iface, enum_media_types);
 
    if (!enum_media_types)
        return E_POINTER;
 
    if (!(object = calloc(1, sizeof(*object))))
        return E_OUTOFMEMORY;
 
    object->IEnumMediaTypes_iface.lpVtbl = &enum_media_types_vtbl;
    object->refcount = 1;
    object->index = 0;
 
    *enum_media_types = &object->IEnumMediaTypes_iface;
    return S_OK;
}

audio_sink_NewSegment()

static HRESULT WINAPI audio_sink_NewSegment ( IPin *  iface, REFERENCE_TIME  start, REFERENCE_TIME  stop, double  rate  )

static

Definition at line 1208 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
 
    TRACE("stream %p, start %s, stop %s, rate %0.16e\n",
            stream, wine_dbgstr_longlong(start), wine_dbgstr_longlong(stop), rate);
 
    EnterCriticalSection(&stream->cs);
 
    stream->segment_start = start;
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_sink_QueryAccept()

static HRESULT WINAPI audio_sink_QueryAccept ( IPin *  iface, const AM_MEDIA_TYPE *  mt  )

static

Definition at line 1108 of file audiostream.c.

{
    TRACE("iface %p, mt %p.\n", iface, mt);
    return E_NOTIMPL;
}

audio_sink_QueryDirection()

static HRESULT WINAPI audio_sink_QueryDirection ( IPin *  iface, PIN_DIRECTION *  dir  )

static

Definition at line 1089 of file audiostream.c.

{
    TRACE("iface %p, dir %p.\n", iface, dir);
    *dir = PINDIR_INPUT;
    return S_OK;
}

audio_sink_QueryId()

static HRESULT WINAPI audio_sink_QueryId ( IPin *  iface, WCHAR **  id  )

static

Definition at line 1096 of file audiostream.c.

{
    TRACE("iface %p, id %p.\n", iface, id);
 
    if (!(*id = CoTaskMemAlloc(sizeof(sink_id))))
        return E_OUTOFMEMORY;
 
    wcscpy(*id, sink_id);
 
    return S_OK;
}

audio_sink_QueryInterface()

static HRESULT WINAPI audio_sink_QueryInterface ( IPin *  iface, REFIID  iid, void **  out  )

static

Definition at line 933 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    return IAMMediaStream_QueryInterface(&stream->IAMMediaStream_iface, iid, out);
}

audio_sink_QueryInternalConnections()

static HRESULT WINAPI audio_sink_QueryInternalConnections ( IPin *  iface, IPin **  pins, ULONG *  count  )

static

Definition at line 1134 of file audiostream.c.

{
    TRACE("iface %p, pins %p, count %p.\n", iface, pins, count);
    return E_NOTIMPL;
}

audio_sink_QueryPinInfo()

static HRESULT WINAPI audio_sink_QueryPinInfo ( IPin *  iface, PIN_INFO *  info  )

static

Definition at line 1076 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
 
    TRACE("stream %p, info %p.\n", stream, info);
 
    IBaseFilter_AddRef(info->pFilter = (IBaseFilter *)stream->filter);
    info->dir = PINDIR_INPUT;
    wcscpy(info->achName, sink_id);
 
    return S_OK;
}

audio_sink_ReceiveConnection()

static HRESULT WINAPI audio_sink_ReceiveConnection ( IPin *  iface, IPin *  peer, const AM_MEDIA_TYPE *  mt  )

static

Definition at line 957 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    PIN_DIRECTION dir;
 
    TRACE("stream %p, peer %p, mt %p.\n", stream, peer, mt);
 
    if (!IsEqualGUID(&mt->majortype, &MEDIATYPE_Audio)
            || !IsEqualGUID(&mt->formattype, &FORMAT_WaveFormatEx)
            || mt->cbFormat < sizeof(WAVEFORMATEX))
        return VFW_E_TYPE_NOT_ACCEPTED;
 
    if (((const WAVEFORMATEX *)mt->pbFormat)->wFormatTag != WAVE_FORMAT_PCM)
        return E_INVALIDARG;
 
    EnterCriticalSection(&stream->cs);
 
    if (stream->peer)
    {
        LeaveCriticalSection(&stream->cs);
        return VFW_E_ALREADY_CONNECTED;
    }
 
    IPin_QueryDirection(peer, &dir);
    if (dir != PINDIR_OUTPUT)
    {
        WARN("Rejecting connection from input pin.\n");
        LeaveCriticalSection(&stream->cs);
        return VFW_E_INVALID_DIRECTION;
    }
 
    if (stream->format.wFormatTag && memcmp(mt->pbFormat, &stream->format, sizeof(WAVEFORMATEX)))
    {
        LeaveCriticalSection(&stream->cs);
        return E_INVALIDARG;
    }
 
    CopyMediaType(&stream->mt, mt);
    IPin_AddRef(stream->peer = peer);
 
    LeaveCriticalSection(&stream->cs);
 
    return S_OK;
}

audio_sink_Release()

static ULONG WINAPI audio_sink_Release ( IPin *  iface )

static

Definition at line 945 of file audiostream.c.

{
    struct audio_stream *stream = impl_from_IPin(iface);
    return IAMMediaStream_Release(&stream->IAMMediaStream_iface);
}

audio_stream_create()

HRESULT audio_stream_create	(	IUnknown *	outer,
		void **	out
	)

Definition at line 1389 of file audiostream.c.

{
    struct audio_stream *object;
 
    if (outer)
        return CLASS_E_NOAGGREGATION;
 
    if (!(object = calloc(1, sizeof(*object))))
        return E_OUTOFMEMORY;
 
    object->IAMMediaStream_iface.lpVtbl = &audio_IAMMediaStream_vtbl;
    object->IAudioMediaStream_iface.lpVtbl = &audio_IAudioMediaStream_vtbl;
    object->IMemInputPin_iface.lpVtbl = &audio_meminput_vtbl;
    object->IPin_iface.lpVtbl = &audio_sink_vtbl;
    object->ref = 1;
 
    InitializeCriticalSection(&object->cs);
    list_init(&object->receive_queue);
    list_init(&object->update_queue);
 
    TRACE("Created audio stream %p.\n", object);
 
    *out = &object->IAMMediaStream_iface;
 
    return S_OK;
}

Referenced by multimedia_stream_AddMediaStream().

audiostreamsample_create()

static HRESULT audiostreamsample_create ( struct audio_stream *  parent, IAudioData *  audio_data, IAudioStreamSample **  audio_stream_sample  )

static

Definition at line 380 of file audiostream.c.

{
    struct audio_sample *object;
 
    TRACE("(%p)\n", audio_stream_sample);
 
    if (!(object = calloc(1, sizeof(*object))))
        return E_OUTOFMEMORY;
 
    object->IAudioStreamSample_iface.lpVtbl = &AudioStreamSample_Vtbl;
    object->ref = 1;
    object->parent = parent;
    IAMMediaStream_AddRef(&parent->IAMMediaStream_iface);
    object->audio_data = audio_data;
    IAudioData_AddRef(audio_data);
    object->update_event = CreateEventW(NULL, FALSE, FALSE, NULL);
 
    *audio_stream_sample = &object->IAudioStreamSample_iface;
 
    return S_OK;
}

Referenced by audio_IAudioMediaStream_CreateSample().

enum_media_types_AddRef()

static ULONG WINAPI enum_media_types_AddRef ( IEnumMediaTypes *  iface )

static

Definition at line 818 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
    ULONG refcount = InterlockedIncrement(&enum_media_types->refcount);
    TRACE("%p increasing refcount to %lu.\n", enum_media_types, refcount);
    return refcount;
}

enum_media_types_Clone()

static HRESULT WINAPI enum_media_types_Clone ( IEnumMediaTypes *  iface, IEnumMediaTypes **  out  )

static

Definition at line 899 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
    struct enum_media_types *object;
 
    TRACE("iface %p, out %p.\n", iface, out);
 
    if (!(object = calloc(1, sizeof(*object))))
        return E_OUTOFMEMORY;
 
    object->IEnumMediaTypes_iface.lpVtbl = &enum_media_types_vtbl;
    object->refcount = 1;
    object->index = enum_media_types->index;
 
    *out = &object->IEnumMediaTypes_iface;
    return S_OK;
}

enum_media_types_Next()

static HRESULT WINAPI enum_media_types_Next ( IEnumMediaTypes *  iface, ULONG  count, AM_MEDIA_TYPE **  mts, ULONG *  ret_count  )

static

Definition at line 836 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
 
    static const WAVEFORMATEX wfx =
    {
        .wFormatTag = WAVE_FORMAT_PCM,
        .nChannels = 1,
        .nSamplesPerSec = 11025,
        .nAvgBytesPerSec = 11025 * 2,
        .nBlockAlign = 2,
        .wBitsPerSample = 16,
        .cbSize = 0,
    };
 
    TRACE("iface %p, count %lu, mts %p, ret_count %p.\n", iface, count, mts, ret_count);
 
    if (!ret_count)
        return E_POINTER;
 
    if (count && !enum_media_types->index)
    {
        mts[0] = CoTaskMemAlloc(sizeof(AM_MEDIA_TYPE));
        memset(mts[0], 0, sizeof(AM_MEDIA_TYPE));
        mts[0]->majortype = MEDIATYPE_Audio;
        mts[0]->subtype = GUID_NULL;
        mts[0]->bFixedSizeSamples = TRUE;
        mts[0]->bTemporalCompression = FALSE;
        mts[0]->lSampleSize = 2;
        mts[0]->formattype = FORMAT_WaveFormatEx;
        mts[0]->cbFormat = sizeof(WAVEFORMATEX);
        mts[0]->pbFormat = CoTaskMemAlloc(sizeof(WAVEFORMATEX));
        memcpy(mts[0]->pbFormat, &wfx, sizeof(WAVEFORMATEX));
 
        ++enum_media_types->index;
        *ret_count = 1;
        return count == 1 ? S_OK : S_FALSE;
    }
 
    *ret_count = 0;
    return count ? S_FALSE : S_OK;
}

enum_media_types_QueryInterface()

static HRESULT WINAPI enum_media_types_QueryInterface ( IEnumMediaTypes *  iface, REFIID  iid, void **  out  )

static

Definition at line 802 of file audiostream.c.

{
    TRACE("iface %p, iid %s, out %p.\n", iface, debugstr_guid(iid), out);
 
    if (IsEqualGUID(iid, &IID_IUnknown) || IsEqualGUID(iid, &IID_IEnumMediaTypes))
    {
        IEnumMediaTypes_AddRef(iface);
        *out = iface;
        return S_OK;
    }
 
    WARN("%s not implemented, returning E_NOINTERFACE.\n", debugstr_guid(iid));
    *out = NULL;
    return E_NOINTERFACE;
}

enum_media_types_Release()

static ULONG WINAPI enum_media_types_Release ( IEnumMediaTypes *  iface )

static

Definition at line 826 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
    ULONG refcount = InterlockedDecrement(&enum_media_types->refcount);
    TRACE("%p decreasing refcount to %lu.\n", enum_media_types, refcount);
    if (!refcount)
        free(enum_media_types);
    return refcount;
}

enum_media_types_Reset()

static HRESULT WINAPI enum_media_types_Reset ( IEnumMediaTypes *  iface )

static

Definition at line 889 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
 
    TRACE("iface %p.\n", iface);
 
    enum_media_types->index = 0;
    return S_OK;
}

enum_media_types_Skip()

static HRESULT WINAPI enum_media_types_Skip ( IEnumMediaTypes *  iface, ULONG  count  )

static

Definition at line 879 of file audiostream.c.

{
    struct enum_media_types *enum_media_types = impl_from_IEnumMediaTypes(iface);
 
    TRACE("iface %p, count %lu.\n", iface, count);
 
    enum_media_types->index += count;
    return S_OK;
}

flush_receive_queue()

static void flush_receive_queue ( struct audio_stream *  stream )

static

Definition at line 103 of file audiostream.c.

{
    struct list *entry;
 
    while ((entry = list_head(&stream->receive_queue)))
        remove_queued_receive(LIST_ENTRY(entry, struct queued_receive, entry));
}

Referenced by audio_IAMMediaStream_SetState(), and audio_sink_BeginFlush().

impl_from_IAMMediaStream()

static struct audio_stream * impl_from_IAMMediaStream ( IAMMediaStream *  iface )

inlinestatic

Definition at line 402 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct audio_stream, IAMMediaStream_iface);
}

Referenced by audio_IAMMediaStream_AddRef(), audio_IAMMediaStream_AllocateSample(), audio_IAMMediaStream_CreateSharedSample(), audio_IAMMediaStream_GetInformation(), audio_IAMMediaStream_GetMultiMediaStream(), audio_IAMMediaStream_Initialize(), audio_IAMMediaStream_JoinAMMultiMediaStream(), audio_IAMMediaStream_JoinFilter(), audio_IAMMediaStream_JoinFilterGraph(), audio_IAMMediaStream_QueryInterface(), audio_IAMMediaStream_Release(), audio_IAMMediaStream_SendEndOfStream(), audio_IAMMediaStream_SetSameFormat(), and audio_IAMMediaStream_SetState().

impl_from_IAudioMediaStream()

static struct audio_stream * impl_from_IAudioMediaStream ( IAudioMediaStream *  iface )

inlinestatic

Definition at line 637 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct audio_stream, IAudioMediaStream_iface);
}

Referenced by audio_IAudioMediaStream_AddRef(), audio_IAudioMediaStream_AllocateSample(), audio_IAudioMediaStream_CreateSample(), audio_IAudioMediaStream_CreateSharedSample(), audio_IAudioMediaStream_GetFormat(), audio_IAudioMediaStream_GetInformation(), audio_IAudioMediaStream_GetMultiMediaStream(), audio_IAudioMediaStream_QueryInterface(), audio_IAudioMediaStream_Release(), audio_IAudioMediaStream_SendEndOfStream(), audio_IAudioMediaStream_SetFormat(), and audio_IAudioMediaStream_SetSameFormat().

impl_from_IAudioStreamSample()

static struct audio_sample * impl_from_IAudioStreamSample ( IAudioStreamSample *  iface )

inlinestatic

Definition at line 161 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct audio_sample, IAudioStreamSample_iface);
}

Referenced by audio_sample_AddRef(), audio_sample_CompletionStatus(), audio_sample_GetAudioData(), audio_sample_GetMediaStream(), audio_sample_GetSampleTimes(), audio_sample_Release(), and audio_sample_Update().

impl_from_IEnumMediaTypes()

static struct enum_media_types * impl_from_IEnumMediaTypes ( IEnumMediaTypes *  iface )

static

Definition at line 797 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct enum_media_types, IEnumMediaTypes_iface);
}

Referenced by enum_media_types_AddRef(), enum_media_types_Clone(), enum_media_types_Next(), enum_media_types_Release(), enum_media_types_Reset(), and enum_media_types_Skip().

impl_from_IMemInputPin()

static struct audio_stream * impl_from_IMemInputPin ( IMemInputPin *  iface )

inlinestatic

Definition at line 1246 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct audio_stream, IMemInputPin_iface);
}

Referenced by audio_meminput_AddRef(), audio_meminput_GetAllocator(), audio_meminput_NotifyAllocator(), audio_meminput_QueryInterface(), audio_meminput_Receive(), and audio_meminput_Release().

impl_from_IPin()

static struct audio_stream * impl_from_IPin ( IPin *  iface )

inlinestatic

Definition at line 928 of file audiostream.c.

{
    return CONTAINING_RECORD(iface, struct audio_stream, IPin_iface);
}

Referenced by audio_sink_AddRef(), audio_sink_BeginFlush(), audio_sink_ConnectedTo(), audio_sink_ConnectionMediaType(), audio_sink_Disconnect(), audio_sink_EndFlush(), audio_sink_EndOfStream(), audio_sink_NewSegment(), audio_sink_QueryInterface(), audio_sink_QueryPinInfo(), audio_sink_ReceiveConnection(), and audio_sink_Release().

process_update()

static void process_update ( struct audio_sample *  sample, struct queued_receive *  receive  )

static

Definition at line 117 of file audiostream.c.

{
    DWORD advance;
 
    advance = min(receive->length - receive->position, sample->length - sample->position);
    memcpy(&sample->pointer[sample->position], &receive->pointer[receive->position], advance);
 
    if (!sample->position)
        sample->start_time = stream_time_from_position(sample->parent, receive);
 
    receive->position += advance;
    sample->position += advance;
 
    sample->end_time = stream_time_from_position(sample->parent, receive);
 
    sample->update_hr = (sample->position == sample->length) ? S_OK : MS_S_PENDING;
}

Referenced by process_updates().

process_updates()

static void process_updates ( struct audio_stream *  stream )

static

Definition at line 135 of file audiostream.c.

{
    while (!list_empty(&stream->update_queue) && !list_empty(&stream->receive_queue))
    {
        struct audio_sample *sample = LIST_ENTRY(list_head(&stream->update_queue), struct audio_sample, entry);
        struct queued_receive *receive = LIST_ENTRY(list_head(&stream->receive_queue), struct queued_receive, entry);
 
        process_update(sample, receive);
 
        if (sample->update_hr != MS_S_PENDING)
            remove_queued_update(sample);
        if (receive->position == receive->length)
            remove_queued_receive(receive);
    }
    if (stream->eos)
    {
        while (!list_empty(&stream->update_queue))
        {
            struct audio_sample *sample = LIST_ENTRY(list_head(&stream->update_queue), struct audio_sample, entry);
 
            sample->update_hr = sample->position ? S_OK : MS_S_ENDOFSTREAM;
            remove_queued_update(sample);
        }
    }
}

Referenced by audio_meminput_Receive(), audio_sample_Update(), and audio_sink_EndOfStream().

remove_queued_receive()

static void remove_queued_receive ( struct queued_receive *  receive )

static

Definition at line 84 of file audiostream.c.

{
    list_remove(&receive->entry);
    IMediaSample_Release(receive->sample);
    free(receive);
}

Referenced by flush_receive_queue(), and process_updates().

remove_queued_update()

static void remove_queued_update ( struct audio_sample *  sample )

static

Definition at line 91 of file audiostream.c.

{
    HRESULT hr;
 
    hr = IAudioData_SetActual(sample->audio_data, sample->position);
    if (FAILED(hr))
        sample->update_hr = hr;
 
    list_remove(&sample->entry);
    SetEvent(sample->update_event);
}

Referenced by process_updates().

stream_time_from_position()

static STREAM_TIME stream_time_from_position ( struct audio_stream *  stream, struct queued_receive *  receive  )

static

Definition at line 111 of file audiostream.c.

{
    const WAVEFORMATEX *format = (WAVEFORMATEX *)stream->mt.pbFormat;
    return receive->start_time + (receive->position * 10000000 + format->nAvgBytesPerSec / 2) / format->nAvgBytesPerSec;
}

Referenced by process_update().

WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL

(

quartz

)

Variable Documentation

audio_IAMMediaStream_vtbl

const struct IAMMediaStreamVtbl audio_IAMMediaStream_vtbl

static

Initial value:

=
{
    audio_IAMMediaStream_QueryInterface,
    audio_IAMMediaStream_AddRef,
    audio_IAMMediaStream_Release,
    audio_IAMMediaStream_GetMultiMediaStream,
    audio_IAMMediaStream_GetInformation,
    audio_IAMMediaStream_SetSameFormat,
    audio_IAMMediaStream_AllocateSample,
    audio_IAMMediaStream_CreateSharedSample,
    audio_IAMMediaStream_SendEndOfStream,
    audio_IAMMediaStream_Initialize,
    audio_IAMMediaStream_SetState,
    audio_IAMMediaStream_JoinAMMultiMediaStream,
    audio_IAMMediaStream_JoinFilter,
    audio_IAMMediaStream_JoinFilterGraph,
}

Definition at line 619 of file audiostream.c.

Referenced by audio_stream_create().

audio_IAudioMediaStream_vtbl

const struct IAudioMediaStreamVtbl audio_IAudioMediaStream_vtbl

static

Initial value:

=
{
    audio_IAudioMediaStream_QueryInterface,
    audio_IAudioMediaStream_AddRef,
    audio_IAudioMediaStream_Release,
    audio_IAudioMediaStream_GetMultiMediaStream,
    audio_IAudioMediaStream_GetInformation,
    audio_IAudioMediaStream_SetSameFormat,
    audio_IAudioMediaStream_AllocateSample,
    audio_IAudioMediaStream_CreateSharedSample,
    audio_IAudioMediaStream_SendEndOfStream,
    audio_IAudioMediaStream_GetFormat,
    audio_IAudioMediaStream_SetFormat,
    audio_IAudioMediaStream_CreateSample,
}

Definition at line 772 of file audiostream.c.

Referenced by audio_stream_create().

audio_meminput_vtbl

const IMemInputPinVtbl audio_meminput_vtbl

static

Initial value:

=
{
    audio_meminput_QueryInterface,
    audio_meminput_AddRef,
    audio_meminput_Release,
    audio_meminput_GetAllocator,
    audio_meminput_NotifyAllocator,
    audio_meminput_GetAllocatorRequirements,
    audio_meminput_Receive,
    audio_meminput_ReceiveMultiple,
    audio_meminput_ReceiveCanBlock,
}

Definition at line 1376 of file audiostream.c.

Referenced by audio_stream_create().

audio_sink_vtbl

const IPinVtbl audio_sink_vtbl

static

Initial value:

=
{
    audio_sink_QueryInterface,
    audio_sink_AddRef,
    audio_sink_Release,
    audio_sink_Connect,
    audio_sink_ReceiveConnection,
    audio_sink_Disconnect,
    audio_sink_ConnectedTo,
    audio_sink_ConnectionMediaType,
    audio_sink_QueryPinInfo,
    audio_sink_QueryDirection,
    audio_sink_QueryId,
    audio_sink_QueryAccept,
    audio_sink_EnumMediaTypes,
    audio_sink_QueryInternalConnections,
    audio_sink_EndOfStream,
    audio_sink_BeginFlush,
    audio_sink_EndFlush,
    audio_sink_NewSegment,
}

Definition at line 1224 of file audiostream.c.

Referenced by audio_stream_create().

AudioStreamSample_Vtbl

const struct IAudioStreamSampleVtbl AudioStreamSample_Vtbl

static

Initial value:

=
{
    
    audio_sample_QueryInterface,
    audio_sample_AddRef,
    audio_sample_Release,
    
    audio_sample_GetMediaStream,
    audio_sample_GetSampleTimes,
    audio_sample_SetSampleTimes,
    audio_sample_Update,
    audio_sample_CompletionStatus,
    
    audio_sample_GetAudioData
}

Definition at line 364 of file audiostream.c.

Referenced by audiostreamsample_create().

enum_media_types_vtbl

static const IEnumMediaTypesVtbl enum_media_types_vtbl

static

Initial value:

=
{
    enum_media_types_QueryInterface,
    enum_media_types_AddRef,
    enum_media_types_Release,
    enum_media_types_Next,
    enum_media_types_Skip,
    enum_media_types_Reset,
    enum_media_types_Clone,
}

Definition at line 795 of file audiostream.c.

Referenced by audio_sink_EnumMediaTypes(), and enum_media_types_Clone().

sink_id

const WCHAR sink_id[] = L"I{A35FF56B-9FDA-11D0-8FDF-00C04FD9189D}"

static

Definition at line 29 of file audiostream.c.

Referenced by audio_sink_QueryId(), and audio_sink_QueryPinInfo().