summaryrefslogtreecommitdiff
path: root/protocols/Telegram/src/t_timers.cpp
blob: 296242856da8c69d91908606736204569f6117fc (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56

#include "stdafx.h"

extern HANDLE hQueue;

struct tgl_timer
{
	tgl_state *TLS;
	void(*cb)(struct tgl_state *TLS, void *arg);
	void *arg;
	HANDLE hTimer;
};

VOID CALLBACK WaitOrTimerCallback(_In_ PVOID lpParameter, _In_ BOOLEAN TimerOrWaitFired)
{
	tgl_timer *p = (tgl_timer*)lpParameter;
	p->cb(p->TLS, p->arg);
	p->hTimer = 0;
}


struct tgl_timer *mtgl_timer_alloc (struct tgl_state *TLS, void (*cb)(struct tgl_state *TLS, void *arg), void *arg) 
{
    tgl_timer *p = (tgl_timer *)mir_calloc(sizeof (tgl_timer));
    p->TLS = TLS;
    p->cb = cb;
    p->arg = arg;
    return p;
}

void mtgl_timer_insert (struct tgl_timer *t, double p) 
{
	HANDLE hNewTimer = 0;
	CreateTimerQueueTimer(&hNewTimer, hQueue, WaitOrTimerCallback, t, (DWORD)(p * 1000), 0, 0);
	t->hTimer = hNewTimer;
}

void mtgl_timer_delete (struct tgl_timer *t)
{
	DeleteTimerQueueTimer(hQueue, t->hTimer, 0);
	t->hTimer = 0;
}

void mtgl_timer_free (struct tgl_timer *t)
{
	if (t->hTimer) mtgl_timer_delete(t);
    mir_free(t);
}


struct tgl_timer_methods mtgl_libevent_timers = {
  mtgl_timer_alloc, 
  mtgl_timer_insert,
  mtgl_timer_delete,
  mtgl_timer_free
};