5 * Copyright (C) 2007-2010 Intel Corporation. All rights reserved.
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU General Public License version 2 as
9 * published by the Free Software Foundation.
11 * This program is distributed in the hope that it will be useful,
12 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
14 * GNU General Public License for more details.
16 * You should have received a copy of the GNU General Public License
17 * along with this program; if not, write to the Free Software
18 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
30 static DBusConnection *connection = NULL;
32 static GSList *notifier_list = NULL;
33 static GHashTable *service_hash = NULL;
35 static const char *notifier_state;
37 static gint compare_priority(gconstpointer a, gconstpointer b)
39 const struct connman_notifier *notifier1 = a;
40 const struct connman_notifier *notifier2 = b;
42 return notifier2->priority - notifier1->priority;
46 * connman_notifier_register:
47 * @notifier: notifier module
49 * Register a new notifier module
51 * Returns: %0 on success
53 int connman_notifier_register(struct connman_notifier *notifier)
55 DBG("notifier %p name %s", notifier, notifier->name);
57 notifier_list = g_slist_insert_sorted(notifier_list, notifier,
64 * connman_notifier_unregister:
65 * @notifier: notifier module
67 * Remove a previously registered notifier module
69 void connman_notifier_unregister(struct connman_notifier *notifier)
71 DBG("notifier %p name %s", notifier, notifier->name);
73 notifier_list = g_slist_remove(notifier_list, notifier);
76 #define MAX_TECHNOLOGIES 10
78 static int connected[MAX_TECHNOLOGIES];
79 static int online[MAX_TECHNOLOGIES];
81 static connman_bool_t notifier_is_online(void)
86 for (i = 0; i < MAX_TECHNOLOGIES; i++) {
94 connman_bool_t __connman_notifier_is_connected(void)
99 for (i = 0; i < MAX_TECHNOLOGIES; i++) {
100 if (connected[i] > 0)
107 static const char *evaluate_notifier_state(void)
109 if (notifier_is_online() == TRUE)
112 if (__connman_notifier_is_connected() == TRUE)
115 if ( __connman_technology_get_offlinemode() == TRUE)
121 const char *__connman_notifier_get_state(void)
123 return notifier_state;
126 static void state_changed(void)
130 state = evaluate_notifier_state();
132 if (g_strcmp0(state, notifier_state) == 0)
135 notifier_state = state;
137 connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH,
138 CONNMAN_MANAGER_INTERFACE, "State",
139 DBUS_TYPE_STRING, ¬ifier_state);
142 static void technology_connected(enum connman_service_type type,
143 connman_bool_t connected)
145 DBG("type %d connected %d", type, connected);
147 __connman_technology_set_connected(type, connected);
151 void __connman_notifier_connect(enum connman_service_type type)
153 DBG("type %d", type);
156 case CONNMAN_SERVICE_TYPE_UNKNOWN:
157 case CONNMAN_SERVICE_TYPE_SYSTEM:
158 case CONNMAN_SERVICE_TYPE_GPS:
159 case CONNMAN_SERVICE_TYPE_VPN:
160 case CONNMAN_SERVICE_TYPE_GADGET:
162 case CONNMAN_SERVICE_TYPE_ETHERNET:
163 case CONNMAN_SERVICE_TYPE_WIFI:
164 case CONNMAN_SERVICE_TYPE_WIMAX:
165 case CONNMAN_SERVICE_TYPE_BLUETOOTH:
166 case CONNMAN_SERVICE_TYPE_CELLULAR:
170 if (__sync_fetch_and_add(&connected[type], 1) == 0)
171 technology_connected(type, TRUE);
174 void __connman_notifier_online(enum connman_service_type type)
176 DBG("type %d", type);
178 if (__sync_fetch_and_add(&online[type], 1) == 0)
182 void __connman_notifier_disconnect(enum connman_service_type type,
183 enum connman_service_state old_state)
185 DBG("type %d", type);
187 __sync_synchronize();
188 if (connected[type] == 0) {
189 connman_error("notifier disconnect underflow");
194 case CONNMAN_SERVICE_TYPE_UNKNOWN:
195 case CONNMAN_SERVICE_TYPE_SYSTEM:
196 case CONNMAN_SERVICE_TYPE_GPS:
197 case CONNMAN_SERVICE_TYPE_VPN:
198 case CONNMAN_SERVICE_TYPE_GADGET:
200 case CONNMAN_SERVICE_TYPE_ETHERNET:
201 case CONNMAN_SERVICE_TYPE_WIFI:
202 case CONNMAN_SERVICE_TYPE_WIMAX:
203 case CONNMAN_SERVICE_TYPE_BLUETOOTH:
204 case CONNMAN_SERVICE_TYPE_CELLULAR:
208 if (old_state == CONNMAN_SERVICE_STATE_ONLINE)
209 __sync_fetch_and_sub(&online[type], 1);
211 if (__sync_fetch_and_sub(&connected[type], 1) != 1)
214 technology_connected(type, FALSE);
217 static void technology_default(enum connman_service_type type)
221 str = __connman_service_type2string(type);
225 connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH,
226 CONNMAN_MANAGER_INTERFACE, "DefaultTechnology",
227 DBUS_TYPE_STRING, &str);
230 void __connman_notifier_default_changed(struct connman_service *service)
232 enum connman_service_type type = connman_service_get_type(service);
235 technology_default(type);
237 for (list = notifier_list; list; list = list->next) {
238 struct connman_notifier *notifier = list->data;
240 if (notifier->default_changed)
241 notifier->default_changed(service);
245 void __connman_notifier_service_add(struct connman_service *service,
250 for (list = notifier_list; list; list = list->next) {
251 struct connman_notifier *notifier = list->data;
253 if (notifier->service_add)
254 notifier->service_add(service, name);
258 void __connman_notifier_service_remove(struct connman_service *service)
262 if (g_hash_table_lookup(service_hash, service) != NULL) {
264 * This is a tempory check for consistency. It can be
265 * removed when there are no reports for the following
268 connman_error("Service state machine inconsistency detected.");
270 g_hash_table_remove(service_hash, service);
273 for (list = notifier_list; list; list = list->next) {
274 struct connman_notifier *notifier = list->data;
276 if (notifier->service_remove)
277 notifier->service_remove(service);
281 void __connman_notifier_proxy_changed(struct connman_service *service)
285 for (list = notifier_list; list; list = list->next) {
286 struct connman_notifier *notifier = list->data;
288 if (notifier->proxy_changed)
289 notifier->proxy_changed(service);
293 static void offlinemode_changed(dbus_bool_t enabled)
295 DBG("enabled %d", enabled);
297 connman_dbus_property_changed_basic(CONNMAN_MANAGER_PATH,
298 CONNMAN_MANAGER_INTERFACE, "OfflineMode",
299 DBUS_TYPE_BOOLEAN, &enabled);
302 void __connman_notifier_offlinemode(connman_bool_t enabled)
306 DBG("enabled %d", enabled);
308 offlinemode_changed(enabled);
311 for (list = notifier_list; list; list = list->next) {
312 struct connman_notifier *notifier = list->data;
314 if (notifier->offline_mode)
315 notifier->offline_mode(enabled);
319 static void notify_idle_state(connman_bool_t idle)
323 DBG("idle %d", idle);
325 for (list = notifier_list; list; list = list->next) {
326 struct connman_notifier *notifier = list->data;
328 if (notifier->idle_state)
329 notifier->idle_state(idle);
333 void __connman_notifier_service_state_changed(struct connman_service *service,
334 enum connman_service_state state)
337 unsigned int old_size;
338 connman_bool_t found;
340 for (list = notifier_list; list; list = list->next) {
341 struct connman_notifier *notifier = list->data;
343 if (notifier->service_state_changed)
344 notifier->service_state_changed(service, state);
347 old_size = g_hash_table_size(service_hash);
348 found = g_hash_table_lookup(service_hash, service) != NULL;
351 case CONNMAN_SERVICE_STATE_UNKNOWN:
352 case CONNMAN_SERVICE_STATE_FAILURE:
353 case CONNMAN_SERVICE_STATE_DISCONNECT:
354 case CONNMAN_SERVICE_STATE_IDLE:
358 g_hash_table_remove(service_hash, service);
360 notify_idle_state(TRUE);
363 case CONNMAN_SERVICE_STATE_ASSOCIATION:
364 case CONNMAN_SERVICE_STATE_CONFIGURATION:
365 case CONNMAN_SERVICE_STATE_READY:
366 case CONNMAN_SERVICE_STATE_ONLINE:
370 g_hash_table_insert(service_hash, service, service);
372 notify_idle_state(FALSE);
378 void __connman_notifier_ipconfig_changed(struct connman_service *service,
379 struct connman_ipconfig *ipconfig)
383 for (list = notifier_list; list; list = list->next) {
384 struct connman_notifier *notifier = list->data;
386 if (notifier->ipconfig_changed)
387 notifier->ipconfig_changed(service, ipconfig);
391 int __connman_notifier_init(void)
395 connection = connman_dbus_get_connection();
397 service_hash = g_hash_table_new_full(g_direct_hash, g_direct_equal,
400 notifier_state = evaluate_notifier_state();
405 void __connman_notifier_cleanup(void)
409 g_hash_table_destroy(service_hash);
412 dbus_connection_unref(connection);