blob: e1657aeb439ed144f513c7d14988d306f31b8ef1 (
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
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
|
/**
* @file lv_async.c
*
*/
/*********************
* INCLUDES
*********************/
#include "lv_async.h"
#include "lv_timer_private.h"
#include "../stdlib/lv_mem.h"
/*********************
* DEFINES
*********************/
/**********************
* TYPEDEFS
**********************/
typedef struct lv_async_info_t {
lv_async_cb_t cb;
void * user_data;
} lv_async_info_t;
/**********************
* STATIC PROTOTYPES
**********************/
static void lv_async_timer_cb(lv_timer_t * timer);
/**********************
* STATIC VARIABLES
**********************/
/**********************
* MACROS
**********************/
/**********************
* GLOBAL FUNCTIONS
**********************/
lv_result_t lv_async_call(lv_async_cb_t async_xcb, void * user_data)
{
/*Allocate an info structure*/
lv_async_info_t * info = lv_malloc(sizeof(lv_async_info_t));
if(info == NULL)
return LV_RESULT_INVALID;
/*Create a new timer*/
lv_timer_t * timer = lv_timer_create(lv_async_timer_cb, 0, info);
if(timer == NULL) {
lv_free(info);
return LV_RESULT_INVALID;
}
info->cb = async_xcb;
info->user_data = user_data;
lv_timer_set_repeat_count(timer, 1);
return LV_RESULT_OK;
}
lv_result_t lv_async_call_cancel(lv_async_cb_t async_xcb, void * user_data)
{
lv_timer_t * timer = lv_timer_get_next(NULL);
lv_result_t res = LV_RESULT_INVALID;
while(timer != NULL) {
/*Find the next timer node*/
lv_timer_t * timer_next = lv_timer_get_next(timer);
/*Find async timer callback*/
if(timer->timer_cb == lv_async_timer_cb) {
lv_async_info_t * info = (lv_async_info_t *)timer->user_data;
/*Match user function callback and user data*/
if(info->cb == async_xcb && info->user_data == user_data) {
lv_timer_delete(timer);
lv_free(info);
res = LV_RESULT_OK;
}
}
timer = timer_next;
}
return res;
}
/**********************
* STATIC FUNCTIONS
**********************/
static void lv_async_timer_cb(lv_timer_t * timer)
{
/*Save the info because an lv_async_call_cancel might delete it in the callback*/
lv_async_info_t * info = (lv_async_info_t *)timer->user_data;
lv_async_info_t info_save = *info;
lv_timer_delete(timer);
lv_free(info);
info_save.cb(info_save.user_data);
}
|
