[PATCH v4 1/3] mf: Handle timer time behind clock time in present_clock_schedule_timer().

[Paul Gofman]

From: Paul Gofman

---
 dlls/mf/clock.c    |  5 ++++-
 dlls/mf/tests/mf.c | 42 ++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 46 insertions(+), 1 deletion(-)

diff --git a/dlls/mf/clock.c b/dlls/mf/clock.c
index e9877533a5a..aef4366c6d9 100644
--- a/dlls/mf/clock.c
+++ b/dlls/mf/clock.c
@@ -819,7 +819,10 @@ static HRESULT present_clock_schedule_timer(struct presentation_clock *clock, DW
             WARN("Failed to get clock time, hr %#lx.\n", hr);
             return hr;
         }
-        time -= clocktime;
+        if (time > clocktime)
+            time -= clocktime;
+        else
+            time = 0;
     }

frequency = clock->frequency / 1000;
diff --git a/dlls/mf/tests/mf.c b/dlls/mf/tests/mf.c
index 9dab87b928d..2b116ab0d9e 100644
--- a/dlls/mf/tests/mf.c
+++ b/dlls/mf/tests/mf.c
@@ -1428,8 +1428,14 @@ static const struct test_stream_sink test_stream_sink = {.IMFStreamSink_iface.lp
 struct test_callback
 {
     IMFAsyncCallback IMFAsyncCallback_iface;
+    HANDLE event;
 };

+static struct test_callback *test_callback_from_IMFAsyncCallback(IMFAsyncCallback *iface)
+{
+    return CONTAINING_RECORD(iface, struct test_callback, IMFAsyncCallback_iface);
+}
+
 static HRESULT WINAPI testcallback_QueryInterface(IMFAsyncCallback *iface, REFIID riid, void **obj)
 {
     if (IsEqualIID(riid, &IID_IMFAsyncCallback) ||
@@ -1462,8 +1468,12 @@ static HRESULT WINAPI testcallback_GetParameters(IMFAsyncCallback *iface, DWORD

static HRESULT WINAPI testcallback_Invoke(IMFAsyncCallback *iface, IMFAsyncResult *result)
 {
+    struct test_callback *test = test_callback_from_IMFAsyncCallback(iface);
     ok(result != NULL, "Unexpected result object.\n");

+    if (test->event)
+        SetEvent(test->event);
+
     return E_NOTIMPL;
 }

@@ -1479,6 +1489,7 @@ static const IMFAsyncCallbackVtbl testcallbackvtbl =
 static void init_test_callback(struct test_callback *callback)
 {
     callback->IMFAsyncCallback_iface.lpVtbl = &testcallbackvtbl;
+    callback->event = NULL;
 }

static void test_session_events(IMFMediaSession *session)
@@ -2907,15 +2918,19 @@ static void test_presentation_clock(void)
     };
     IMFClockStateSink test_sink = { &test_clock_sink_vtbl };
     IMFPresentationTimeSource *time_source;
+    struct test_callback timer_callback;
     MFCLOCK_PROPERTIES props, props2;
     IMFRateControl *rate_control;
     IMFPresentationClock *clock;
+    IUnknown *timer_cancel_key;
     MFSHUTDOWN_STATUS status;
     IMFShutdown *shutdown;
     MFTIME systime, time;
     LONGLONG clock_time;
     MFCLOCK_STATE state;
+    IMFTimer *timer;
     unsigned int i;
+    DWORD t1, t2;
     DWORD value;
     float rate;
     HRESULT hr;
@@ -3139,6 +3154,33 @@ static void test_presentation_clock(void)

IMFRateControl_Release(rate_control);

+
+    hr = IMFPresentationClock_QueryInterface(clock, &IID_IMFTimer, (void **)&timer);
+    ok(hr == S_OK, "got hr %#lx.\n", hr);
+
+    hr = IMFPresentationClock_Start(clock, 200000);
+    ok(hr == S_OK, "got hr %#lx.\n", hr);
+
+    hr = IMFPresentationClock_GetCorrelatedTime(clock, 0, &time, &systime);
+    ok(hr == S_OK, "got hr %#lx.\n", hr);
+
+    init_test_callback(&timer_callback);
+    timer_callback.event = CreateEventW(NULL, FALSE, FALSE, NULL);
+    hr = IMFTimer_SetTimer(timer, 0, 100000,
+            &timer_callback.IMFAsyncCallback_iface, NULL, &timer_cancel_key);
+    ok(hr == S_OK, "got hr %#lx.\n", hr);
+
+    t1 = GetTickCount();
+    ok(WaitForSingleObject(timer_callback.event, 4000) == WAIT_OBJECT_0, "WaitForSingleObject failed.\n");
+    t2 = GetTickCount();
+
+    ok(t2 - t1 < 200, "unexpected time difference %lu.\n", t2 - t1);
+
+    CloseHandle(timer_callback.event);
+    IUnknown_Release(timer_cancel_key);
+    IMFTimer_Release(timer);
+
+
     hr = IMFPresentationClock_QueryInterface(clock, &IID_IMFShutdown, (void **)&shutdown);
     ok(hr == S_OK, "Failed to get shutdown interface, hr %#lx.\n", hr);