ReactOS 0.4.17-dev-1071-gb2116d0
renderer.c File Reference
#include "strmbase_private.h"
Include dependency graph for renderer.c:

Go to the source code of this file.

Macros

#define DO_RUNNING_AVG(avg, val, size)   (((val) + ((size)-1) * (avg)) / (size))
 
#define UPDATE_RUNNING_AVG(avg, val)   DO_RUNNING_AVG(avg,val,8)
 
#define UPDATE_RUNNING_AVG_P(avg, val)   DO_RUNNING_AVG(avg,val,16)
 
#define UPDATE_RUNNING_AVG_N(avg, val)   DO_RUNNING_AVG(avg,val,4)
 

Functions

 WINE_DEFAULT_DEBUG_CHANNEL (quartz)
 
static void reset_qos (struct strmbase_renderer *filter)
 
static void perform_qos (struct strmbase_renderer *filter, const REFERENCE_TIME start, const REFERENCE_TIME stop, REFERENCE_TIME jitter)
 
static struct strmbase_renderer * impl_from_strmbase_filter (struct strmbase_filter *iface)
 
static struct strmbase_renderer * impl_from_IPin (IPin *iface)
 
static struct strmbase_pin * renderer_get_pin (struct strmbase_filter *iface, unsigned int index)
 
static void renderer_destroy (struct strmbase_filter *iface)
 
static HRESULT renderer_query_interface (struct strmbase_filter *iface, REFIID iid, void **out)
 
static HRESULT renderer_init_stream (struct strmbase_filter *iface)
 
static HRESULT renderer_start_stream (struct strmbase_filter *iface, REFERENCE_TIME start)
 
static HRESULT renderer_stop_stream (struct strmbase_filter *iface)
 
static HRESULT renderer_cleanup_stream (struct strmbase_filter *iface)
 
static HRESULT renderer_wait_state (struct strmbase_filter *iface, DWORD timeout)
 
static HRESULT sink_query_accept (struct strmbase_pin *pin, const AM_MEDIA_TYPE *mt)
 
static HRESULT sink_query_interface (struct strmbase_pin *iface, REFIID iid, void **out)
 
static HRESULT WINAPI BaseRenderer_Receive (struct strmbase_sink *pin, IMediaSample *sample)
 
static HRESULT sink_connect (struct strmbase_sink *iface, IPin *peer, const AM_MEDIA_TYPE *mt)
 
static void sink_disconnect (struct strmbase_sink *iface)
 
static HRESULT sink_eos (struct strmbase_sink *iface)
 
static HRESULT sink_begin_flush (struct strmbase_sink *iface)
 
static HRESULT sink_end_flush (struct strmbase_sink *iface)
 
static struct strmbase_renderer * impl_from_IQualityControl (IQualityControl *iface)
 
static HRESULT WINAPI quality_control_QueryInterface (IQualityControl *iface, REFIID iid, void **out)
 
static ULONG WINAPI quality_control_AddRef (IQualityControl *iface)
 
static ULONG WINAPI quality_control_Release (IQualityControl *iface)
 
static HRESULT WINAPI quality_control_Notify (IQualityControl *iface, IBaseFilter *sender, Quality q)
 
static HRESULT WINAPI quality_control_SetSink (IQualityControl *iface, IQualityControl *sink)
 
void strmbase_renderer_cleanup (struct strmbase_renderer *filter)
 
void strmbase_renderer_init (struct strmbase_renderer *filter, IUnknown *outer, const CLSID *clsid, const WCHAR *sink_name, const struct strmbase_renderer_ops *ops)
 

Variables

static const struct strmbase_filter_ops filter_ops
 
static const struct strmbase_sink_ops sink_ops
 
static const IQualityControlVtbl quality_control_vtbl
 

Macro Definition Documentation

◆ DO_RUNNING_AVG

#define DO_RUNNING_AVG (   avg,
  val,
  size 
)    (((val) + ((size)-1) * (avg)) / (size))

Definition at line 49 of file renderer.c.

◆ UPDATE_RUNNING_AVG

#define UPDATE_RUNNING_AVG (   avg,
  val 
)    DO_RUNNING_AVG(avg,val,8)

Definition at line 52 of file renderer.c.

◆ UPDATE_RUNNING_AVG_N

#define UPDATE_RUNNING_AVG_N (   avg,
  val 
)    DO_RUNNING_AVG(avg,val,4)

Definition at line 58 of file renderer.c.

◆ UPDATE_RUNNING_AVG_P

#define UPDATE_RUNNING_AVG_P (   avg,
  val 
)    DO_RUNNING_AVG(avg,val,16)

Definition at line 57 of file renderer.c.

Function Documentation

◆ BaseRenderer_Receive()

static HRESULT WINAPI BaseRenderer_Receive ( struct strmbase_sink *  pin,
IMediaSample *  sample 
)
static

Definition at line 335 of file renderer.c.

336{
337 struct strmbase_renderer *filter = impl_from_IPin(&pin->pin.IPin_iface);
338 REFERENCE_TIME start, stop;
339 BOOL need_wait = FALSE;
340 FILTER_STATE state;
341 HRESULT hr = S_OK;
342 AM_MEDIA_TYPE *mt;
343
344 if (filter->eos || filter->sink.flushing)
345 return S_FALSE;
346
347 state = filter->filter.state;
348 if (state == State_Stopped)
349 return VFW_E_WRONG_STATE;
350
351 if (IMediaSample_GetMediaType(sample, &mt) == S_OK)
352 {
353 TRACE("Format change.\n");
355
356 if (FAILED(filter->ops->renderer_query_accept(filter, mt)))
358 DeleteMediaType(mt);
359 }
360
361 if (filter->filter.clock && SUCCEEDED(IMediaSample_GetTime(sample, &start, &stop)))
362 {
364 need_wait = TRUE;
365 }
366
367 if (state == State_Paused)
368 {
369 HANDLE events[2] = {filter->run_event, filter->flush_event};
370
371 filter->current_sample = sample;
372
373 hr = filter->ops->renderer_render(filter, sample);
374
375 SetEvent(filter->state_event);
379
380 filter->current_sample = NULL;
381 }
382
383 if (need_wait)
384 {
385 REFERENCE_TIME now, jitter;
387
388 IReferenceClock_GetTime(filter->filter.clock, &now);
389
390 /* "jitter" describes how early (negative) or late (positive) this
391 * buffer arrived, relative to its PTS. */
392 jitter = (now - filter->stream_start) - start;
393
394 if (jitter <= -10000) /* if we are early by at least 1 ms */
395 {
396 HANDLE handles[2] = {filter->advise_event, filter->flush_event};
397 DWORD ret;
398
399 IReferenceClock_AdviseTime(filter->filter.clock, filter->stream_start,
400 start, (HEVENT)filter->advise_event, &cookie);
401
403 IReferenceClock_Unadvise(filter->filter.clock, cookie);
404
405 if (ret == 1)
406 {
407 TRACE("Flush signaled; discarding current sample.\n");
408 return S_OK;
409 }
410 }
411
412 if (state == State_Running)
413 hr = filter->ops->renderer_render(filter, sample);
414
415 perform_qos(filter, start, stop, jitter);
416 }
417 else
418 {
419 if (state == State_Running)
420 hr = filter->ops->renderer_render(filter, sample);
421 }
422
423 return hr;
424}
static int state
Definition: maze.c:121
DWORD_PTR HEVENT
Definition: axcore.idl:61
HRESULT hr
Definition: delayimp.cpp:582
#define NULL
Definition: types.h:112
#define TRUE
Definition: types.h:120
#define FALSE
Definition: types.h:117
LONGLONG REFERENCE_TIME
Definition: dmusicks.h:9
return ret
Definition: mutex.c:147
#define INFINITE
Definition: serial.h:102
unsigned int BOOL
Definition: ntddk_ex.h:94
unsigned long DWORD
Definition: ntddk_ex.h:95
time_t now
Definition: finger.c:65
GLuint start
Definition: gl.h:1545
#define S_OK
Definition: intsafe.h:52
#define SUCCEEDED(hr)
Definition: intsafe.h:50
#define FAILED(hr)
Definition: intsafe.h:51
HANDLE events[2]
Definition: event.c:4
static struct strmbase_renderer * impl_from_IPin(IPin *iface)
Definition: renderer.c:184
static void perform_qos(struct strmbase_renderer *filter, const REFERENCE_TIME start, const REFERENCE_TIME stop, REFERENCE_TIME jitter)
Definition: renderer.c:66
#define TRACE(s)
Definition: solgame.cpp:4
void strmbase_passthrough_update_time(struct strmbase_passthrough *passthrough, REFERENCE_TIME time)
Definition: pospass.c:744
void strmbase_dump_media_type(const AM_MEDIA_TYPE *mt)
Definition: mediatype.c:58
void WINAPI DeleteMediaType(AM_MEDIA_TYPE *pMediaType)
Definition: mediatype.c:193
Definition: cookie.c:34
Definition: filter.c:165
IBaseFilter * filter
Definition: filtergraph.c:75
Definition: wave.c:25
struct strmbase_pin pin
Definition: strmbase.h:106
DWORD WINAPI WaitForMultipleObjects(IN DWORD nCount, IN CONST HANDLE *lpHandles, IN BOOL bWaitAll, IN DWORD dwMilliseconds)
Definition: synch.c:151
BOOL WINAPI DECLSPEC_HOTPATCH SetEvent(IN HANDLE hEvent)
Definition: synch.c:669
uint32_t DWORD_PTR
Definition: typedefs.h:65
static EFI_HANDLE * handles
Definition: uefidisk.c:66
#define VFW_E_TYPE_NOT_ACCEPTED
Definition: vfwmsgs.h:81
#define VFW_E_WRONG_STATE
Definition: vfwmsgs.h:78
void WINAPI LeaveCriticalSection(LPCRITICAL_SECTION)
void WINAPI EnterCriticalSection(LPCRITICAL_SECTION)
#define S_FALSE
Definition: winerror.h:3451

◆ impl_from_IPin()

static struct strmbase_renderer * impl_from_IPin ( IPin *  iface)
inlinestatic

Definition at line 184 of file renderer.c.

185{
186 return CONTAINING_RECORD(iface, struct strmbase_renderer, sink.pin.IPin_iface);
187}
GLsizei GLenum GLboolean sink
Definition: glext.h:5672
#define CONTAINING_RECORD(address, type, field)
Definition: typedefs.h:260

Referenced by BaseRenderer_Receive(), sink_begin_flush(), sink_connect(), sink_disconnect(), sink_end_flush(), sink_eos(), sink_query_accept(), and sink_query_interface().

◆ impl_from_IQualityControl()

static struct strmbase_renderer * impl_from_IQualityControl ( IQualityControl *  iface)
static

Definition at line 501 of file renderer.c.

502{
503 return CONTAINING_RECORD(iface, struct strmbase_renderer, IQualityControl_iface);
504}

Referenced by quality_control_AddRef(), quality_control_Notify(), quality_control_QueryInterface(), quality_control_Release(), and quality_control_SetSink().

◆ impl_from_strmbase_filter()

◆ perform_qos()

static void perform_qos ( struct strmbase_renderer *  filter,
const REFERENCE_TIME  start,
const REFERENCE_TIME  stop,
REFERENCE_TIME  jitter 
)
static

Definition at line 66 of file renderer.c.

68{
69 REFERENCE_TIME pt, entered, left, duration;
70 double rate;
71
72 if (jitter < 0)
73 {
74 /* This is the time the buffer entered the sink. */
75 if (start < -jitter)
76 entered = 0;
77 else
78 entered = start + jitter;
79 left = start;
80 }
81 else
82 {
83 /* This is the time the buffer entered the sink. */
84 entered = start + jitter;
85 /* This is the time the buffer left the sink. */
86 left = start + jitter;
87 }
88
89 /* Calculate the duration of the buffer. */
90 if (stop >= start)
91 duration = stop - start;
92 else
93 duration = 0;
94
95 /* If we have the time when the last buffer left us, calculate processing
96 * time. */
97 if (filter->last_left >= 0)
98 {
99 if (entered > filter->last_left)
100 pt = entered - filter->last_left;
101 else
102 pt = 0;
103 }
104 else
105 {
106 pt = filter->avg_pt;
107 }
108
109 TRACE("start %s, entered %s, left %s, pt %s, duration %s, jitter %s.\n",
111 debugstr_time(pt), debugstr_time(duration), debugstr_time(jitter));
112
113 TRACE("average duration %s, average pt %s, average rate %.16e.\n",
114 debugstr_time(filter->avg_duration), debugstr_time(filter->avg_pt), filter->avg_rate);
115
116 /* Collect running averages. For first observations, we copy the values. */
117 if (filter->avg_duration < 0)
118 filter->avg_duration = duration;
119 else
120 filter->avg_duration = UPDATE_RUNNING_AVG(filter->avg_duration, duration);
121
122 if (filter->avg_pt < 0)
123 filter->avg_pt = pt;
124 else
125 filter->avg_pt = UPDATE_RUNNING_AVG(filter->avg_pt, pt);
126
127 if (filter->avg_duration != 0)
128 rate = (double)filter->avg_pt / (double)filter->avg_duration;
129 else
130 rate = 0.0;
131
132 if (filter->last_left >= 0)
133 {
134 if (filter->avg_rate < 0.0)
135 {
136 filter->avg_rate = rate;
137 }
138 else
139 {
140 if (rate > 1.0)
141 filter->avg_rate = UPDATE_RUNNING_AVG_N(filter->avg_rate, rate);
142 else
143 filter->avg_rate = UPDATE_RUNNING_AVG_P(filter->avg_rate, rate);
144 }
145 }
146
147 if (filter->avg_rate >= 0.0)
148 {
149 Quality q;
150
151 /* If we have a valid rate, start sending QoS messages. */
152 if (jitter < 0)
153 {
154 /* Make sure we never go below 0 when adding the jitter to the
155 * timestamp. */
156 if (start < -jitter)
157 jitter = -start;
158 }
159 else
160 {
161 jitter += stop - start;
162 }
163
164 q.Type = (jitter > 0 ? Famine : Flood);
165 q.Proportion = 1000.0 / filter->avg_rate;
166 if (q.Proportion < 200)
167 q.Proportion = 200;
168 else if (q.Proportion > 5000)
169 q.Proportion = 5000;
170 q.Late = jitter;
171 q.TimeStamp = start;
172 IQualityControl_Notify(&filter->IQualityControl_iface, &filter->filter.IBaseFilter_iface, q);
173 }
174
175 /* Record when this buffer will leave us. */
176 filter->last_left = left;
177}
unsigned int rate
Definition: audiorecord.c:87
#define pt(x, y)
Definition: drawing.c:79
GLdouble GLdouble GLdouble GLdouble q
Definition: gl.h:2063
GLint left
Definition: glext.h:7726
static const char mbstate_t *static wchar_t const char mbstate_t *static const wchar_t int *static double
Definition: string.c:91
#define UPDATE_RUNNING_AVG_N(avg, val)
Definition: renderer.c:58
#define UPDATE_RUNNING_AVG(avg, val)
Definition: renderer.c:52
#define UPDATE_RUNNING_AVG_P(avg, val)
Definition: renderer.c:57
static const char * debugstr_time(REFERENCE_TIME time)
Definition: strmbase.h:32

Referenced by BaseRenderer_Receive().

◆ quality_control_AddRef()

static ULONG WINAPI quality_control_AddRef ( IQualityControl *  iface)
static

Definition at line 512 of file renderer.c.

513{
515 return IUnknown_AddRef(filter->filter.outer_unk);
516}
static struct strmbase_renderer * impl_from_IQualityControl(IQualityControl *iface)
Definition: renderer.c:501

◆ quality_control_Notify()

static HRESULT WINAPI quality_control_Notify ( IQualityControl *  iface,
IBaseFilter *  sender,
Quality  q 
)
static

Definition at line 524 of file renderer.c.

525{
528
529 TRACE("filter %p, sender %p, type %#x, proportion %ld, late %s, timestamp %s.\n",
530 filter, sender, q.Type, q.Proportion, debugstr_time(q.Late), debugstr_time(q.TimeStamp));
531
532 if (filter->qc_sink)
533 return IQualityControl_Notify(filter->qc_sink, &filter->filter.IBaseFilter_iface, q);
534
535 if (filter->sink.pin.peer)
536 {
537 IQualityControl *peer_qc = NULL;
538 IPin_QueryInterface(filter->sink.pin.peer, &IID_IQualityControl, (void **)&peer_qc);
539 if (peer_qc)
540 {
541 hr = IQualityControl_Notify(peer_qc, &filter->filter.IBaseFilter_iface, q);
542 IQualityControl_Release(peer_qc);
543 }
544 }
545
546 return hr;
547}

◆ quality_control_QueryInterface()

static HRESULT WINAPI quality_control_QueryInterface ( IQualityControl *  iface,
REFIID  iid,
void **  out 
)
static

Definition at line 506 of file renderer.c.

507{
509 return IUnknown_QueryInterface(filter->filter.outer_unk, iid, out);
510}
wchar_t tm const _CrtWcstime_Writes_and_advances_ptr_ count wchar_t ** out
Definition: wcsftime.cpp:383

◆ quality_control_Release()

static ULONG WINAPI quality_control_Release ( IQualityControl *  iface)
static

Definition at line 518 of file renderer.c.

519{
521 return IUnknown_Release(filter->filter.outer_unk);
522}

◆ quality_control_SetSink()

static HRESULT WINAPI quality_control_SetSink ( IQualityControl *  iface,
IQualityControl *  sink 
)
static

Definition at line 549 of file renderer.c.

550{
552
553 TRACE("filter %p, sink %p.\n", filter, sink);
554
555 filter->qc_sink = sink;
556 return S_OK;
557}

◆ renderer_cleanup_stream()

static HRESULT renderer_cleanup_stream ( struct strmbase_filter *  iface)
static

Definition at line 279 of file renderer.c.

280{
282
284 SetEvent(filter->state_event);
285 SetEvent(filter->flush_event);
286
287 return S_OK;
288}
static struct strmbase_renderer * impl_from_strmbase_filter(struct strmbase_filter *iface)
Definition: renderer.c:179
void strmbase_passthrough_invalidate_time(struct strmbase_passthrough *passthrough)
Definition: pospass.c:752

◆ renderer_destroy()

static void renderer_destroy ( struct strmbase_filter *  iface)
static

Definition at line 198 of file renderer.c.

199{
201 filter->ops->renderer_destroy(filter);
202}

◆ renderer_get_pin()

static struct strmbase_pin * renderer_get_pin ( struct strmbase_filter *  iface,
unsigned int  index 
)
static

Definition at line 189 of file renderer.c.

190{
192
193 if (index == 0)
194 return &filter->sink.pin;
195 return NULL;
196}
GLuint index
Definition: glext.h:6031

◆ renderer_init_stream()

static HRESULT renderer_init_stream ( struct strmbase_filter *  iface)
static

Definition at line 228 of file renderer.c.

229{
231
232 if (filter->sink.pin.peer)
233 ResetEvent(filter->state_event);
234 filter->eos = FALSE;
235 ResetEvent(filter->flush_event);
236 if (filter->ops->renderer_init_stream)
237 filter->ops->renderer_init_stream(filter);
238
239 return filter->sink.pin.peer ? S_FALSE : S_OK;
240}
BOOL WINAPI DECLSPEC_HOTPATCH ResetEvent(IN HANDLE hEvent)
Definition: synch.c:650

◆ renderer_query_interface()

static HRESULT renderer_query_interface ( struct strmbase_filter *  iface,
REFIID  iid,
void **  out 
)
static

Definition at line 204 of file renderer.c.

205{
207 HRESULT hr;
208
209 if (filter->ops->renderer_query_interface
210 && SUCCEEDED(hr = filter->ops->renderer_query_interface(filter, iid, out)))
211 {
212 return hr;
213 }
214
215 if (IsEqualGUID(iid, &IID_IMediaPosition))
216 *out = &filter->passthrough.IMediaPosition_iface;
217 else if (IsEqualGUID(iid, &IID_IMediaSeeking))
218 *out = &filter->passthrough.IMediaSeeking_iface;
219 else if (IsEqualGUID(iid, &IID_IQualityControl))
220 *out = &filter->IQualityControl_iface;
221 else
222 return E_NOINTERFACE;
223
224 IUnknown_AddRef((IUnknown *)*out);
225 return S_OK;
226}
#define IsEqualGUID(rguid1, rguid2)
Definition: guiddef.h:147
IMediaSeeking IMediaSeeking_iface
Definition: filter.c:167
#define E_NOINTERFACE
Definition: winerror.h:3479

◆ renderer_start_stream()

static HRESULT renderer_start_stream ( struct strmbase_filter *  iface,
REFERENCE_TIME  start 
)
static

Definition at line 242 of file renderer.c.

243{
246 IMediaEventSink *event_sink;
247
248 filter->stream_start = start;
249 SetEvent(filter->state_event);
250 SetEvent(filter->run_event);
252 if (filter->sink.pin.peer && filter->ops->renderer_start_stream)
253 filter->ops->renderer_start_stream(filter);
254
255 if ((filter->eos || !filter->sink.pin.peer) && graph
256 && SUCCEEDED(IFilterGraph_QueryInterface(graph,
257 &IID_IMediaEventSink, (void **)&event_sink)))
258 {
259 IMediaEventSink_Notify(event_sink, EC_COMPLETE, S_OK,
260 (LONG_PTR)&filter->filter.IBaseFilter_iface);
261 IMediaEventSink_Release(event_sink);
262 }
263
264 return S_OK;
265}
#define EC_COMPLETE
Definition: evcode.h:17
__int3264 LONG_PTR
Definition: mstsclib_h.h:276
static void reset_qos(struct strmbase_renderer *filter)
Definition: renderer.c:60
Definition: graph.c:32

◆ renderer_stop_stream()

static HRESULT renderer_stop_stream ( struct strmbase_filter *  iface)
static

Definition at line 267 of file renderer.c.

268{
270
271 ResetEvent(filter->run_event);
272
273 if (filter->sink.pin.peer && filter->ops->renderer_stop_stream)
274 filter->ops->renderer_stop_stream(filter);
275
276 return S_OK;
277}

◆ renderer_wait_state()

static HRESULT renderer_wait_state ( struct strmbase_filter *  iface,
DWORD  timeout 
)
static

Definition at line 290 of file renderer.c.

291{
293
294 if (WaitForSingleObject(filter->state_event, timeout) == WAIT_TIMEOUT)
296 return S_OK;
297}
#define WAIT_TIMEOUT
Definition: dderror.h:14
Definition: dhcpd.h:248
DWORD WINAPI WaitForSingleObject(IN HANDLE hHandle, IN DWORD dwMilliseconds)
Definition: synch.c:82
#define VFW_S_STATE_INTERMEDIATE
Definition: vfwmsgs.h:21

◆ reset_qos()

static void reset_qos ( struct strmbase_renderer *  filter)
static

Definition at line 60 of file renderer.c.

61{
62 filter->last_left = filter->avg_duration = filter->avg_pt = -1;
63 filter->avg_rate = -1.0;
64}

Referenced by renderer_start_stream(), and sink_end_flush().

◆ sink_begin_flush()

static HRESULT sink_begin_flush ( struct strmbase_sink *  iface)
static

Definition at line 465 of file renderer.c.

466{
467 struct strmbase_renderer *filter = impl_from_IPin(&iface->pin.IPin_iface);
468
469 SetEvent(filter->flush_event);
470
471 return S_OK;
472}

◆ sink_connect()

static HRESULT sink_connect ( struct strmbase_sink *  iface,
IPin *  peer,
const AM_MEDIA_TYPE *  mt 
)
static

Definition at line 426 of file renderer.c.

427{
428 struct strmbase_renderer *filter = impl_from_IPin(&iface->pin.IPin_iface);
429
430 if (filter->ops->renderer_connect)
431 return filter->ops->renderer_connect(filter, mt);
432 return S_OK;
433}

◆ sink_disconnect()

static void sink_disconnect ( struct strmbase_sink *  iface)
static

Definition at line 435 of file renderer.c.

436{
437 struct strmbase_renderer *filter = impl_from_IPin(&iface->pin.IPin_iface);
438
439 if (filter->ops->renderer_disconnect)
440 filter->ops->renderer_disconnect(filter);
441}

◆ sink_end_flush()

static HRESULT sink_end_flush ( struct strmbase_sink *  iface)
static

Definition at line 474 of file renderer.c.

475{
476 struct strmbase_renderer *filter = impl_from_IPin(&iface->pin.IPin_iface);
477
479
480 filter->eos = FALSE;
483 ResetEvent(filter->flush_event);
484
486 return S_OK;
487}

◆ sink_eos()

static HRESULT sink_eos ( struct strmbase_sink *  iface)
static

Definition at line 443 of file renderer.c.

444{
445 struct strmbase_renderer *filter = impl_from_IPin(&iface->pin.IPin_iface);
447 IMediaEventSink *event_sink;
448
449 filter->eos = TRUE;
450
451 if (filter->filter.state == State_Running && graph
452 && SUCCEEDED(IFilterGraph_QueryInterface(graph,
453 &IID_IMediaEventSink, (void **)&event_sink)))
454 {
455 IMediaEventSink_Notify(event_sink, EC_COMPLETE, S_OK,
456 (LONG_PTR)&filter->filter.IBaseFilter_iface);
457 IMediaEventSink_Release(event_sink);
458 }
459 strmbase_passthrough_eos(&filter->passthrough);
460 SetEvent(filter->state_event);
461
462 return S_OK;
463}
void strmbase_passthrough_eos(struct strmbase_passthrough *passthrough)
Definition: pospass.c:759

◆ sink_query_accept()

static HRESULT sink_query_accept ( struct strmbase_pin *  pin,
const AM_MEDIA_TYPE *  mt 
)
static

Definition at line 311 of file renderer.c.

312{
314 return filter->ops->renderer_query_accept(filter, mt);
315}
IPin IPin_iface
Definition: strmbase.h:57

◆ sink_query_interface()

static HRESULT sink_query_interface ( struct strmbase_pin *  iface,
REFIID  iid,
void **  out 
)
static

Definition at line 317 of file renderer.c.

318{
320 HRESULT hr;
321
322 if (filter->ops->renderer_pin_query_interface
323 && SUCCEEDED(hr = filter->ops->renderer_pin_query_interface(filter, iid, out)))
324 return hr;
325
326 if (IsEqualGUID(iid, &IID_IMemInputPin))
327 *out = &filter->sink.IMemInputPin_iface;
328 else
329 return E_NOINTERFACE;
330
331 IUnknown_AddRef((IUnknown *)*out);
332 return S_OK;
333}

◆ strmbase_renderer_cleanup()

void strmbase_renderer_cleanup ( struct strmbase_renderer *  filter)

Definition at line 568 of file renderer.c.

569{
570 if (filter->sink.pin.peer)
571 IPin_Disconnect(filter->sink.pin.peer);
572 IPin_Disconnect(&filter->sink.pin.IPin_iface);
574
576
577 CloseHandle(filter->state_event);
578 CloseHandle(filter->advise_event);
579 CloseHandle(filter->run_event);
580 CloseHandle(filter->flush_event);
582}
#define CloseHandle
Definition: compat.h:739
void strmbase_passthrough_cleanup(struct strmbase_passthrough *passthrough)
Definition: pospass.c:738
void strmbase_sink_cleanup(struct strmbase_sink *pin)
Definition: pin.c:1185
void strmbase_filter_cleanup(struct strmbase_filter *filter)
Definition: filter.c:540

Referenced by null_renderer_destroy(), video_renderer_create(), video_renderer_destroy(), vmr7_create(), vmr9_create(), and vmr_destroy().

◆ strmbase_renderer_init()

void strmbase_renderer_init ( struct strmbase_renderer *  filter,
IUnknown *  outer,
const CLSID *  clsid,
const WCHAR *  sink_name,
const struct strmbase_renderer_ops *  ops 
)

Definition at line 584 of file renderer.c.

586{
587 memset(filter, 0, sizeof(*filter));
589 strmbase_passthrough_init(&filter->passthrough, (IUnknown *)&filter->filter.IBaseFilter_iface);
590 ISeekingPassThru_Init(&filter->passthrough.ISeekingPassThru_iface, TRUE, &filter->sink.pin.IPin_iface);
591 filter->IQualityControl_iface.lpVtbl = &quality_control_vtbl;
592
593 filter->ops = ops;
594
595 strmbase_sink_init(&filter->sink, &filter->filter, sink_name, &sink_ops, NULL);
596
597 filter->state_event = CreateEventW(NULL, TRUE, TRUE, NULL);
598 filter->advise_event = CreateEventW(NULL, FALSE, FALSE, NULL);
599 filter->run_event = CreateEventW(NULL, TRUE, FALSE, NULL);
600 filter->flush_event = CreateEventW(NULL, TRUE, TRUE, NULL);
601}
static IUnknown * outer
Definition: compobj.c:82
const CLSID * clsid
Definition: msctf.cpp:50
static const IQualityControlVtbl quality_control_vtbl
Definition: renderer.c:559
static const struct strmbase_sink_ops sink_ops
Definition: renderer.c:489
static const struct strmbase_filter_ops filter_ops
Definition: renderer.c:299
#define memset(x, y, z)
Definition: compat.h:39
void strmbase_sink_init(struct strmbase_sink *pin, struct strmbase_filter *filter, const WCHAR *name, const struct strmbase_sink_ops *ops, IMemAllocator *allocator)
Definition: pin.c:1168
void strmbase_passthrough_init(struct strmbase_passthrough *passthrough, IUnknown *outer)
Definition: pospass.c:725
void strmbase_filter_init(struct strmbase_filter *filter, IUnknown *outer, const CLSID *clsid, const struct strmbase_filter_ops *func_table)
Definition: filter.c:517
HANDLE WINAPI DECLSPEC_HOTPATCH CreateEventW(IN LPSECURITY_ATTRIBUTES lpEventAttributes OPTIONAL, IN BOOL bManualReset, IN BOOL bInitialState, IN LPCWSTR lpName OPTIONAL)
Definition: synch.c:587

Referenced by null_renderer_create(), video_renderer_create(), vmr7_create(), and vmr9_create().

◆ WINE_DEFAULT_DEBUG_CHANNEL()

WINE_DEFAULT_DEBUG_CHANNEL ( quartz  )

Variable Documentation

◆ filter_ops

const struct strmbase_filter_ops filter_ops
static
Initial value:
=
{
.filter_get_pin = renderer_get_pin,
.filter_destroy = renderer_destroy,
.filter_query_interface = renderer_query_interface,
.filter_init_stream = renderer_init_stream,
.filter_start_stream = renderer_start_stream,
.filter_stop_stream = renderer_stop_stream,
.filter_cleanup_stream = renderer_cleanup_stream,
.filter_wait_state = renderer_wait_state,
}
static HRESULT renderer_start_stream(struct strmbase_filter *iface, REFERENCE_TIME start)
Definition: renderer.c:242
static HRESULT renderer_wait_state(struct strmbase_filter *iface, DWORD timeout)
Definition: renderer.c:290
static HRESULT renderer_stop_stream(struct strmbase_filter *iface)
Definition: renderer.c:267
static HRESULT renderer_query_interface(struct strmbase_filter *iface, REFIID iid, void **out)
Definition: renderer.c:204
static HRESULT renderer_init_stream(struct strmbase_filter *iface)
Definition: renderer.c:228
static HRESULT renderer_cleanup_stream(struct strmbase_filter *iface)
Definition: renderer.c:279
static struct strmbase_pin * renderer_get_pin(struct strmbase_filter *iface, unsigned int index)
Definition: renderer.c:189
static void renderer_destroy(struct strmbase_filter *iface)
Definition: renderer.c:198

Definition at line 299 of file renderer.c.

Referenced by strmbase_renderer_init().

◆ quality_control_vtbl

const IQualityControlVtbl quality_control_vtbl
static
Initial value:
=
{
}
static HRESULT WINAPI quality_control_QueryInterface(IQualityControl *iface, REFIID iid, void **out)
Definition: renderer.c:506
static HRESULT WINAPI quality_control_Notify(IQualityControl *iface, IBaseFilter *sender, Quality q)
Definition: renderer.c:524
static HRESULT WINAPI quality_control_SetSink(IQualityControl *iface, IQualityControl *sink)
Definition: renderer.c:549
static ULONG WINAPI quality_control_AddRef(IQualityControl *iface)
Definition: renderer.c:512
static ULONG WINAPI quality_control_Release(IQualityControl *iface)
Definition: renderer.c:518

Definition at line 559 of file renderer.c.

Referenced by strmbase_renderer_init().

◆ sink_ops

const struct strmbase_sink_ops sink_ops
static
Initial value:
=
{
.base.pin_query_accept = sink_query_accept,
.base.pin_query_interface = sink_query_interface,
.pfnReceive = BaseRenderer_Receive,
.sink_connect = sink_connect,
.sink_disconnect = sink_disconnect,
.sink_eos = sink_eos,
.sink_begin_flush = sink_begin_flush,
.sink_end_flush = sink_end_flush,
}
static HRESULT sink_end_flush(struct strmbase_sink *iface)
Definition: renderer.c:474
static HRESULT sink_connect(struct strmbase_sink *iface, IPin *peer, const AM_MEDIA_TYPE *mt)
Definition: renderer.c:426
static void sink_disconnect(struct strmbase_sink *iface)
Definition: renderer.c:435
static HRESULT sink_query_accept(struct strmbase_pin *pin, const AM_MEDIA_TYPE *mt)
Definition: renderer.c:311
static HRESULT WINAPI BaseRenderer_Receive(struct strmbase_sink *pin, IMediaSample *sample)
Definition: renderer.c:335
static HRESULT sink_begin_flush(struct strmbase_sink *iface)
Definition: renderer.c:465
static HRESULT sink_eos(struct strmbase_sink *iface)
Definition: renderer.c:443
static HRESULT sink_query_interface(struct strmbase_pin *iface, REFIID iid, void **out)
Definition: renderer.c:317

Definition at line 489 of file renderer.c.

Referenced by strmbase_renderer_init().