#ifndef UNDER_CE
# define VLC_CANCEL_INIT { NULL, true, false }
#else
-# define VLC_CANCEL_INIT { NULL, NULL; true, false }
+# define VLC_CANCEL_INIT { NULL, NULL, true, false }
#endif
#ifdef UNDER_CE
* no defined behavior in case of recursive locking. */
InitializeCriticalSection (&p_mutex->mutex);
p_mutex->initialized = 1;
- return 0;
}
void vlc_mutex_init_recursive( vlc_mutex_t *p_mutex )
{
InitializeCriticalSection( &p_mutex->mutex );
p_mutex->initialized = 1;
- return 0;
}
}
va_end (ap);
}
+
+
+/*** Timers ***/
+static void CALLBACK vlc_timer_do (void *val, BOOLEAN timeout)
+{
+ vlc_timer_t *id = val;
+
+ assert (timeout);
+ if (TryEnterCriticalSection (&id->serializer))
+ {
+ id->overrun = InterlockedExchange (&id->counter, 0);
+ id->func (id->data);
+ LeaveCriticalSection (&id->serializer);
+ }
+ else /* Overrun */
+ InterlockedIncrement (&id->counter);
+}
+
+int vlc_timer_create (vlc_timer_t *id, void (*func) (void *), void *data)
+{
+ id->func = func;
+ id->data = data;
+ id->overrun = 0;
+ id->handle = INVALID_HANDLE_VALUE;
+ InitializeCriticalSection (&id->serializer);
+ return 0;
+}
+
+void vlc_timer_destroy (vlc_timer_t *id)
+{
+ if (id->handle != INVALID_HANDLE_VALUE)
+ DeleteTimerQueueTimer (NULL, id->handle, NULL);
+ DeleteCriticalSection (&id->serializer);
+}
+
+void vlc_timer_schedule (vlc_timer_t *id, bool absolute,
+ mtime_t value, mtime_t interval)
+{
+ if (id->handle != INVALID_HANDLE_VALUE)
+ {
+ DeleteTimerQueueTimer (NULL, id->handle, NULL);
+ id->handle = INVALID_HANDLE_VALUE;
+ }
+ if (value == 0)
+ return; /* Disarm */
+
+ if (absolute)
+ value -= mdate ();
+ value = (value + 999) / 1000;
+ interval = (interval + 999) / 1000;
+ if (!CreateTimerQueueTimer (&id->handle, NULL, vlc_timer_do, id, value,
+ interval, WT_EXECUTEDEFAULT))
+ abort ();
+}
+
+unsigned vlc_timer_getoverrun (const vlc_timer_t *id)
+{
+ return id->overrun;
+}