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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
/* -*- Mode: C; tab-width: 4; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
#include "mm-callback-info.h"
#include "mm-modem-error.h"
static void
callback_info_done (gpointer user_data)
{
MMCallbackInfo *info = (MMCallbackInfo *) user_data;
gpointer result;
info->pending_id = 0;
result = mm_callback_info_get_data (info, "callback-info-result");
if (info->async_callback)
info->async_callback (info->modem, info->error, info->user_data);
else if (info->uint_callback)
info->uint_callback (info->modem, GPOINTER_TO_UINT (result), info->error, info->user_data);
else if (info->str_callback)
info->str_callback (info->modem, (const char *) result, info->error, info->user_data);
if (info->error)
g_error_free (info->error);
g_object_unref (info->modem);
g_datalist_clear (&info->qdata);
g_slice_free (MMCallbackInfo, info);
}
static gboolean
callback_info_do (gpointer user_data)
{
/* Nothing here, everything is done in callback_info_done to make sure the info->callback
always gets called, even if the pending call gets cancelled. */
return FALSE;
}
void
mm_callback_info_schedule (MMCallbackInfo *info)
{
info->pending_id = g_idle_add_full (G_PRIORITY_DEFAULT_IDLE, callback_info_do, info, callback_info_done);
}
void
mm_callback_info_cancel (MMCallbackInfo *info)
{
if (info->pending_id) {
info->error = g_error_new (MM_MODEM_ERROR, MM_MODEM_ERROR_GENERAL, "%s", "Call cancelled");
mm_callback_info_schedule (info);
}
}
MMCallbackInfo *
mm_callback_info_new (MMModem *modem, MMModemFn callback, gpointer user_data)
{
MMCallbackInfo *info;
info = g_slice_new0 (MMCallbackInfo);
g_datalist_init (&info->qdata);
info->modem = g_object_ref (modem);
info->async_callback = callback;
info->user_data = user_data;
return info;
}
MMCallbackInfo *
mm_callback_info_uint_new (MMModem *modem,
MMModemUIntFn callback,
gpointer user_data)
{
MMCallbackInfo *info;
info = g_slice_new0 (MMCallbackInfo);
g_datalist_init (&info->qdata);
info->modem = g_object_ref (modem);
info->uint_callback = callback;
info->user_data = user_data;
return info;
}
MMCallbackInfo *
mm_callback_info_string_new (MMModem *modem,
MMModemStringFn callback,
gpointer user_data)
{
MMCallbackInfo *info;
info = g_slice_new0 (MMCallbackInfo);
g_datalist_init (&info->qdata);
info->modem = g_object_ref (modem);
info->str_callback = callback;
info->user_data = user_data;
return info;
}
void
mm_callback_info_set_result (MMCallbackInfo *info,
gpointer data,
GDestroyNotify destroy)
{
mm_callback_info_set_data (info, "callback-info-result", data, destroy);
}
void
mm_callback_info_set_data (MMCallbackInfo *info,
const char *key,
gpointer data,
GDestroyNotify destroy)
{
g_datalist_id_set_data_full (&info->qdata, g_quark_from_string (key), data,
data ? destroy : (GDestroyNotify) NULL);
}
gpointer
mm_callback_info_get_data (MMCallbackInfo *info, const char *key)
{
GQuark quark;
quark = g_quark_try_string (key);
return quark ? g_datalist_id_get_data (&info->qdata, quark) : NULL;
}
|
