2 * Copyright (c) 2011 Samsung Electronics Co., Ltd All Rights Reserved
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
22 #include <vconf-internal-bt-keys.h>
24 #include "bluetooth-api.h"
25 #include "bt-internal-types.h"
27 #include "bt-service-common.h"
28 #include "bt-service-event.h"
29 #include "bt-service-main.h"
30 #include "bt-service-core-device.h"
31 #include "bt-service-obex-server.h"
32 #include "bt-service-obex-agent.h"
33 #include "bt-service-pbap.h"
34 #include "bt-service-opp-client.h"
35 #include "bt-service-map-client.h"
36 #include "bt-service-core-adapter.h"
38 #ifdef TIZEN_FEATURE_BT_DPM
39 #include "bt-service-dpm.h"
42 #define DBUS_TIMEOUT 20 * 1000 /* 20 Sec */
43 static GDBusConnection *manager_conn;
44 static GDBusConnection *obexd_conn;
45 static GDBusConnection *opc_obexd_conn;
46 static GDBusConnection *map_obexd_conn;
48 static guint event_id;
50 static guint session_reinit_timer;
53 * obexd connection type
61 OBEX_PCSUITE = (1 << 6),
62 OBEX_SYNCEVOLUTION = (1 << 7),
65 } bluetooth_obex_connection_type_t;
68 void _bt_handle_property_changed_event(GVariant *msg, const char *object_path);
69 void _bt_opc_property_changed_event(GVariant *msg, char *path);
70 void _bt_map_property_changed_event(GVariant *msg, const char *path);
71 int _bt_register_service_event(GDBusConnection *g_conn, int event_type);
72 void _bt_unregister_service_event(GDBusConnection *g_conn, int event_type);
73 void _bt_opp_client_event_deinit(void);
74 void _bt_map_client_event_deinit(void);
75 void _bt_map_on_transfer_finished(const char *transfer_object_path, const int error);
77 /* Temp Adapter changes required to make OBEX work for handling device events here ,
78 This code will be removed and moved to OAL Event Handling part .
82 static void __bt_get_uuids(GVariant *value, bt_remote_dev_info_t *info)
84 ret_if(value == NULL);
89 info->uuids = g_variant_dup_strv(value, &uuid_count);
90 info->uuid_count = (unsigned int)uuid_count;
92 BT_DBG("uuid count : %d", uuid_count);
96 void _bt_convert_addr_string_to_secure_string(char *addr,
101 ret_if(address == NULL);
102 ret_if(addr == NULL);
104 len = strlen(address);
105 ret_if(len != BT_ADDRESS_STRING_SIZE - 1);
107 strncpy(addr, address, len);
122 bt_status_t _bt_adapter_get_status_for_Obex(void)
124 int value = VCONFKEY_BT_STATUS_OFF;
126 /* check VCONFKEY_BT_STATUS */
127 if (vconf_get_int(VCONFKEY_BT_STATUS, &value) != 0) {
128 BT_ERR("fail to get vconf key!");
129 return BLUETOOTH_ADAPTER_DISABLED;
135 static int __bt_get_owner_info(GVariant *msg, char **name,
136 char **previous, char **current)
138 g_variant_get(msg, "(&s&s&s)", name, previous, current);
139 return BLUETOOTH_ERROR_NONE;
142 static int __bt_get_agent_signal_info(GVariant *msg, char **address,
143 char **name, char **uuid)
145 g_variant_get(msg, "(sss)", address, name, uuid);
146 return BLUETOOTH_ERROR_NONE;
149 gboolean __bt_handle_is_flight_mode_enabled(void)
151 if (TIZEN_FEATURE_FLIGHTMODE_ENABLED) {
152 int is_flight_mode = 0;
154 ret = vconf_get_bool(VCONFKEY_TELEPHONY_FLIGHT_MODE, &is_flight_mode);
156 BT_ERR("vconf_get_bool failed");
158 return (is_flight_mode == 0) ? FALSE : TRUE;
164 void _bt_handle_adapter_event(GVariant *msg, const char *member)
167 ret_if(member == NULL);
169 if (strcasecmp(member, "DeviceCreated") == 0) {
170 char *object_path = NULL;
172 ret_if(_bt_is_device_creating() == FALSE);
174 /* Bonding from remote device */
175 address = g_malloc0(BT_ADDRESS_STRING_SIZE);
177 g_variant_get(msg, "(&o)", &object_path);
178 _bt_convert_device_path_to_address((const char*)object_path, address);
181 } else if (strcasecmp(member, BT_HARDWARE_ERROR) == 0) {
182 BT_ERR_C("### Hardware error received from BLUEZ");
183 } else if (strcasecmp(member, BT_TX_TIMEOUT_ERROR) == 0) {
184 BT_ERR_C("### Tx timeout error received from BLUEZ");
189 static void __bt_obex_property_changed_event(GVariant *msg, const char *path)
193 GVariantIter value_iter;
194 GVariant *child = NULL, *val = NULL;
195 char *property = NULL;
196 g_variant_iter_init(&value_iter, msg);
197 while ((child = g_variant_iter_next_value(&value_iter))) {
198 g_variant_get(child, "{sv}", &property, &val);
200 ret_if(property == NULL);
202 BT_DBG("property :%s", property);
204 if (strcasecmp(property, "Status") == 0) {
206 g_variant_get(val, "s", &status);
208 if (strcasecmp(status, "active") == 0) {
209 _bt_obex_transfer_started(path);
210 } else if (strcasecmp(status, "complete") == 0) {
211 _bt_obex_transfer_completed(path, TRUE);
212 _bt_pbap_obex_transfer_completed(path, TRUE);
213 } else if (strcasecmp(status, "error") == 0) {
214 _bt_obex_transfer_completed(path, FALSE);
215 _bt_pbap_obex_transfer_completed(path, FALSE);
218 } else if (strcasecmp(property, "Transferred") == 0) {
219 guint64 transferred = 0;
220 /* As Transferred is expected guint64 so change int to guint64 and
221 * eariler transferred is static because of it can overwrite data
222 * on present on opc_obex_conn or obexd_conn as these are
223 * static memory are in sequential */
224 g_variant_get(val, "t", &transferred);
226 _bt_obex_transfer_progress(path, transferred);
228 /* TODO: MAP, "Complete"? see above */
230 g_variant_unref(val);
231 g_variant_unref(child);
236 void _bt_handle_property_changed_event(GVariant *msg, const char *object_path)
238 char *interface_name = NULL;
239 GVariant *val = NULL;
241 g_variant_get(msg, "(&s@a{sv}@as)", &interface_name, &val, NULL);
242 BT_DBG("_bt_handle_property_changed_event");
244 if (strcasecmp(interface_name, BT_ADAPTER_INTERFACE) == 0) {
245 gboolean ret = FALSE;
246 gboolean powered = FALSE;
248 /* Check if Adapter is disabled, cancle queued transfers if any */
249 ret = g_variant_lookup(msg, "Powered", "b", &powered);
251 _bt_cancel_queued_transfers();
252 } else if (strcasecmp(interface_name, BT_OBEX_TRANSFER_INTERFACE) == 0) {
253 BT_DBG("BT_OBEX_TRANSFER_INTERFACE");
254 __bt_obex_property_changed_event(val,
257 g_variant_unref(val);
260 void __bt_opc_property_changed_event(GVariant *msg,
263 GVariantIter value_iter;
264 char *property = NULL;
265 GVariant *val = NULL;
266 GVariant *child = NULL;
268 g_variant_iter_init(&value_iter, msg);
269 if ((child = g_variant_iter_next_value(&value_iter))) {
270 g_variant_get(child, "{sv}", &property, &val);
271 ret_if(property == NULL);
273 if (strcasecmp(property, "Status") == 0) {
275 g_variant_get(val, "s", &status);
276 BT_DBG("Status is %s", status);
278 if (strcasecmp(status, "active") == 0)
279 _bt_obex_client_started(path);
280 else if (strcasecmp(status, "complete") == 0)
281 _bt_obex_client_completed(path, TRUE);
282 else if (strcasecmp(status, "error") == 0)
283 _bt_obex_client_completed(path, FALSE);
286 } else if (strcasecmp(property, "Transferred") == 0) {
287 guint64 transferred = 0;
288 g_variant_get(val, "t", &transferred);
290 _bt_obex_client_progress(path, transferred);
292 BT_DBG("property : [%s]", property);
295 g_variant_unref(child);
296 g_variant_unref(val);
300 void _bt_opc_property_changed_event(GVariant *msg, char *path)
302 char *interface_name = NULL;
303 GVariant *value = NULL;
304 g_variant_get(msg, "(&s@a{sv}@as)", &interface_name, &value, NULL);
305 BT_INFO("interface_name = %s", interface_name);
306 if (strcasecmp(interface_name, BT_OBEX_TRANSFER_INTERFACE) == 0) {
307 __bt_opc_property_changed_event(value,
310 BT_DBG("interface_name : [%s]", interface_name);
312 g_variant_unref(value);
316 void __bt_map_property_changed_event(GVariant *msg,
320 GVariantIter value_iter;
321 char *property = NULL;
322 GVariant *val = NULL;
323 GVariant *child = NULL;
325 g_variant_iter_init(&value_iter, msg);
326 while ((child = g_variant_iter_next_value(&value_iter))) {
327 g_variant_get(child, "{sv}", &property, &val);
328 ret_if(property == NULL);
330 if (strcasecmp(property, "Status") == 0) {
332 g_variant_get(val, "s", &status);
333 BT_DBG("Status is %s", status);
335 if (strcasecmp(status, "active") == 0) {
336 BT_DBG("EVENT : STARTED");
337 // currently doing nothing
338 } else if (strcasecmp(status, "complete") == 0) {
339 BT_DBG("EVENT : COMPLETED");
340 _bt_map_on_transfer_finished(path, BLUETOOTH_ERROR_NONE);
341 } else if (strcasecmp(status, "error") == 0) {
342 BT_DBG("EVENT : FAILED");
343 _bt_map_on_transfer_finished(path, BLUETOOTH_ERROR_INTERNAL);
346 } else if (strcasecmp(property, "Transferred") == 0) {
347 guint64 transferred = 0;
348 g_variant_get(val, "t", &transferred);
350 BT_DBG("EVENT : PROGRESS CALLBACK");
351 // currently doing nothing - progress callback type is not used
353 BT_DBG("OTHER EVENT : property : [%s]", property);
356 g_variant_unref(child);
357 g_variant_unref(val);
361 void _bt_map_property_changed_event(GVariant *msg, const char *path)
363 BT_DBG("Entered _bt_map_property_changed_event");
364 char *interface_name = NULL;
365 GVariant *value = NULL;
366 g_variant_get(msg, "(&s@a{sv}@as)", &interface_name, &value, NULL);
367 BT_INFO("interface_name = %s", interface_name);
368 if (strcasecmp(interface_name, BT_OBEX_TRANSFER_INTERFACE) == 0) {
369 __bt_map_property_changed_event(value,
372 BT_DBG("interface_name : [%s]", interface_name);
374 g_variant_unref(value);
378 void _bt_handle_agent_event(GVariant *msg, const char *member)
380 int result = BLUETOOTH_ERROR_NONE;
381 char *address = NULL;
384 GVariant *param = NULL;
385 ret_if(member == NULL);
387 if (strcasecmp(member, "ObexAuthorize") == 0) {
388 __bt_get_agent_signal_info(msg, &address, &name, &uuid);
389 param = g_variant_new("(i&s&s)", result, address, name);
390 _bt_send_event(BT_OPP_SERVER_EVENT,
391 BLUETOOTH_EVENT_OBEX_SERVER_CONNECTION_AUTHORIZE,
393 /* TODO: MAP? see above */
397 static int __bt_get_object_path(GVariant *msg, char **path)
399 g_variant_get(msg, "(o*)", path, NULL);
401 return BLUETOOTH_ERROR_INTERNAL;
403 return BLUETOOTH_ERROR_NONE;
406 char *_bt_get_bonded_device_name(char *address)
408 bt_remote_dev_info_t *dev_info;
410 retv_if(address == NULL, strdup(""));
412 dev_info = _bt_service_get_remote_dev_info(address);
413 retv_if(dev_info == NULL, strdup(""));
414 retv_if(dev_info->name == NULL, strdup(""));
416 return g_strdup(dev_info->name);
418 /* Temp Adapter Util changes to make OBEX work.
421 void _bt_handle_device_event(GVariant *msg, const char *member, const char *path)
424 ret_if(path == NULL);
426 if (strcasecmp(member, "Disconnected") == 0) {
427 unsigned char disc_reason = 0;
428 unsigned char addr_type = 0;
429 char *dev_name = NULL;
430 gboolean sending = FALSE;
432 g_variant_get(msg, "(yys)", &addr_type, &disc_reason, &dev_name);
434 address = g_malloc0(BT_ADDRESS_STRING_SIZE);
436 _bt_convert_device_path_to_address(path, address);
439 /*Check for any OPP transfer on the device and cancel
442 _bt_obex_check_pending_transfer(address);
443 _bt_opp_client_is_sending(&sending);
445 _bt_opp_client_check_pending_transfer(address);
446 /* TODO: MAP? see above */
453 static void __bt_manager_event_filter(GDBusConnection *connection,
454 const gchar *sender_name,
455 const gchar *object_path,
456 const gchar *interface_name,
457 const gchar *signal_name,
458 GVariant *parameters,
463 char *obj_path = NULL;
465 if (signal_name == NULL)
468 if (strcasecmp(signal_name, "InterfacesAdded") == 0) {
469 g_variant_get(parameters, "(&o@a{sa{sv}})", &obj_path, &value);
471 if (strcasecmp(obj_path, BT_BLUEZ_HCI_PATH) == 0)
472 if (!TIZEN_FEATURE_BT_USB_DONGLE) {
473 if (_bt_register_obex_server() != BLUETOOTH_ERROR_NONE)
474 BT_ERR("Fail to init obex server");
476 g_variant_unref(value);
477 } else if (strcasecmp(signal_name, "InterfacesRemoved") == 0) {
478 if (TIZEN_FEATURE_BT_USB_DONGLE) {
479 if (_bt_unregister_obex_server() != BLUETOOTH_ERROR_NONE)
480 BT_ERR("Fail to unregister obex server");
482 } else if (strcasecmp(signal_name, "NameOwnerChanged") == 0) {
485 char *previous = NULL;
486 char *current = NULL;
488 if (g_strcmp0(g_variant_get_type_string(parameters), "(sss)") != 0) {
489 BT_ERR("Invalid variant format");
493 if (__bt_get_owner_info(parameters, &name, &previous, ¤t)) {
494 BT_ERR("Fail to get the owner info");
498 if (*current != '\0')
504 if (strcasecmp(name, BT_BLUEZ_NAME) == 0) {
505 BT_INFO_C("### Bluetoothd is terminated");
507 if (_bt_unregister_obex_server() != BLUETOOTH_ERROR_NONE)
508 BT_ERR("Fail to unregister obex server");
512 _bt_obex_server_check_allocation(&value);
515 /* Check if the obex server was terminated abnormally */
516 _bt_obex_server_check_termination(name);
518 } else if (g_strcmp0(interface_name, BT_AGENT_INTERFACE) == 0) {
519 _bt_handle_agent_event(parameters, signal_name);
520 } else if (g_strcmp0(interface_name, BT_DEVICE_INTERFACE) == 0) {
521 _bt_handle_device_event(parameters, signal_name, object_path);
527 static gboolean __bt_is_obexd_event(GVariant *msg, const char *interface)
530 if (g_strcmp0(interface, BT_PROPERTIES_INTERFACE) == 0) {
531 char *interface_name = NULL;
533 g_variant_get(msg, "(&s@a{sv}@as)", &interface_name, NULL, NULL);
534 retv_if(interface_name == NULL, FALSE);
536 if (strcasecmp(interface_name, BT_OBEX_TRANSFER_INTERFACE) == 0) {
537 BT_DBG("BT_OBEX_TRANSFER_INTERFACE");
545 static void __bt_obexd_event_filter(GDBusConnection *connection,
546 const gchar *sender_name,
547 const gchar *object_path,
548 const gchar *interface_name,
549 const gchar *signal_name,
550 GVariant *parameters,
553 const char *member = signal_name;
554 char *obj_path = NULL;
555 ret_if(member == NULL);
557 if (strcasecmp(member, "InterfacesAdded") == 0) {
558 if (__bt_get_object_path(parameters, &obj_path)) {
559 BT_ERR("Fail to get the path");
563 /*Handle OPP_SERVER_CONNECTED_EVENT here */
564 /* TODO: MAP? see above */
565 if (strncmp(obj_path, BT_SESSION_BASEPATH_SERVER,
566 strlen(BT_SESSION_BASEPATH_SERVER)) != 0) {
571 if (g_strrstr(obj_path, "session") && g_strrstr(obj_path, "transfer")) {
572 BT_DBG("Obex_Server_Session_Transfer connected");
573 _bt_obex_transfer_connected(obj_path);
576 } else if (strcasecmp(member, "InterfacesRemoved") == 0) {
577 /*Handle OPP_SERVER_DISCONNECTED_EVENT here */
578 /* TODO: MAP? see above */
579 if (__bt_get_object_path(parameters, &obj_path)) {
580 BT_ERR("Fail to get the path");
584 if (strncmp(obj_path, BT_SESSION_BASEPATH_CLIENT,
585 strlen(BT_SESSION_BASEPATH_CLIENT)) == 0) {
586 BT_DBG("Call PBAP Disconnected");
587 _bt_obex_pbap_client_disconnect(obj_path);
590 if (strncmp(obj_path, BT_SESSION_BASEPATH_SERVER,
591 strlen(BT_SESSION_BASEPATH_SERVER)) != 0) {
596 if (g_strrstr(obj_path, "session") && g_strrstr(obj_path, "transfer")) {
597 BT_DBG("Obex_Server_Session_Transfer disconnected %s",
600 _bt_obex_transfer_disconnected(obj_path);
603 } else if (__bt_is_obexd_event(parameters, interface_name) == TRUE) {
604 const char *path = object_path;
606 if (strncmp(path, BT_SESSION_BASEPATH_SERVER,
607 strlen(BT_SESSION_BASEPATH_SERVER)) != 0 &&
608 strncmp(path, BT_SESSION_BASEPATH_CLIENT,
609 strlen(BT_SESSION_BASEPATH_CLIENT)) != 0) {
610 BT_DBG("DBUS_HANDLER_RESULT_NOT_YET_HANDLED");
614 _bt_handle_property_changed_event(parameters, path);
619 static gboolean __bt_is_obexd_client_event(GVariant *msg, const char *interface)
623 if (g_strcmp0(interface, BT_PROPERTIES_INTERFACE) == 0) {
624 char *interface_name = NULL;
626 g_variant_get(msg, "(&s@a{sv}@as)", &interface_name, NULL, NULL);
628 retv_if(interface_name == NULL, FALSE);
630 if (strcasecmp(interface_name,
631 BT_OBEX_TRANSFER_INTERFACE) == 0) {
642 static void __bt_opc_event_filter(GDBusConnection *connection,
643 const gchar *sender_name,
644 const gchar *object_path,
645 const gchar *interface_name,
646 const gchar *signal_name,
647 GVariant *parameters,
650 const char *member = signal_name;
651 char *obj_path = NULL;
652 if (strcasecmp(member, "InterfacesAdded") == 0) {
653 BT_DBG("InterfacesAdded");
654 } else if (strcasecmp(member, "InterfacesRemoved") == 0) {
656 if (__bt_get_object_path(parameters, &obj_path)) {
657 BT_ERR("Fail to get the path");
661 BT_DBG("object_path = %s", obj_path);
663 if (strncmp(obj_path, BT_SESSION_BASEPATH_CLIENT,
664 strlen(BT_SESSION_BASEPATH_CLIENT)) != 0
665 || strstr(obj_path, "transfer") == NULL) {
668 } else if (strncmp(obj_path, BT_SESSION_BASEPATH_CLIENT,
669 strlen(BT_SESSION_BASEPATH_CLIENT)) == 0) {
670 BT_DBG("Going to call opc disconnected");
671 _bt_opc_disconnected(obj_path);
676 } else if (__bt_is_obexd_client_event(parameters, interface_name) == TRUE) {
677 char *path = (char *)object_path;
678 BT_INFO("object_path %s", path);
679 if (strncmp(path, BT_SESSION_BASEPATH_CLIENT,
680 strlen(BT_SESSION_BASEPATH_CLIENT)) != 0) {
681 BT_DBG("NOT BT_SESSION_BASEPATH_CLIENT");
685 _bt_opc_property_changed_event(parameters, path);
691 int _bt_opp_client_event_init(void)
693 GError *error = NULL;
695 if (opc_obexd_conn == NULL) {
696 opc_obexd_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &error);
698 if (!opc_obexd_conn) {
700 BT_ERR("Unable to connect to dbus: %s", error->message);
701 g_clear_error(&error);
703 return BLUETOOTH_ERROR_INTERNAL;
707 if (_bt_register_service_event(opc_obexd_conn,
708 BT_OPP_CLIENT_EVENT) != BLUETOOTH_ERROR_NONE) {
709 g_object_unref(opc_obexd_conn);
710 opc_obexd_conn = NULL;
711 return BLUETOOTH_ERROR_INTERNAL;
714 return BLUETOOTH_ERROR_NONE;
717 void _bt_opp_client_event_deinit(void)
719 if (opc_obexd_conn) {
720 _bt_unregister_service_event(opc_obexd_conn,
721 BT_OPP_CLIENT_EVENT);
722 g_object_unref(opc_obexd_conn);
723 opc_obexd_conn = NULL;
727 static void __bt_map_event_filter(GDBusConnection *connection,
728 const gchar *sender_name,
729 const gchar *object_path,
730 const gchar *interface_name,
731 const gchar *signal_name,
732 GVariant *parameters,
735 BT_DBG("Entered __bt_map_event_filter");
736 const char *member = signal_name;
738 if (strcasecmp(member, "InterfacesAdded") == 0) {
739 BT_DBG("------------------------------------ADDED------------------------------------");
740 // currently doing nothing
741 } else if (strcasecmp(member, "InterfacesRemoved") == 0) {
742 BT_DBG("------------------------------------REMOVED------------------------------------");
743 // TODO check if something should be called here?
744 //_bt_map_on_transfer_finished(object_path, error);
745 } else if (__bt_is_obexd_client_event(parameters, interface_name) == TRUE) {
746 BT_DBG("------------------------------------CLIENT EVENT------------------------------------");
747 _bt_map_property_changed_event(parameters, object_path);
753 int _bt_map_client_event_init(void)
755 GError *error = NULL;
757 if (map_obexd_conn == NULL) {
758 map_obexd_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &error);
760 if (!map_obexd_conn) {
762 BT_ERR("Unable to connect to dbus: %s", error->message);
763 g_clear_error(&error);
765 return BLUETOOTH_ERROR_INTERNAL;
769 if (_bt_register_service_event(map_obexd_conn,
770 BT_MAP_CLIENT_EVENT) != BLUETOOTH_ERROR_NONE) {
771 g_object_unref(map_obexd_conn);
772 map_obexd_conn = NULL;
773 return BLUETOOTH_ERROR_INTERNAL;
776 return BLUETOOTH_ERROR_NONE;
779 void _bt_map_client_event_deinit(void)
781 if (map_obexd_conn) {
782 _bt_unregister_service_event(map_obexd_conn,
783 BT_MAP_CLIENT_EVENT);
784 g_object_unref(map_obexd_conn);
785 map_obexd_conn = NULL;
789 int _bt_register_manager_subscribe_signal(GDBusConnection *conn,
795 static int subs_interface_added_id = -1;
796 static int subs_interface_removed_id = -1;
797 static int subs_name_owner_changed = -1;
800 if (subs_interface_added_id == -1) {
801 subs_interface_added_id = g_dbus_connection_signal_subscribe(conn,
802 NULL, BT_MANAGER_INTERFACE,
803 BT_INTERFACES_ADDED, NULL, NULL, 0,
804 __bt_manager_event_filter,
807 if (subs_interface_removed_id == -1) {
808 subs_interface_removed_id = g_dbus_connection_signal_subscribe(conn,
809 NULL, BT_MANAGER_INTERFACE,
810 BT_INTERFACES_REMOVED, NULL, NULL, 0,
811 __bt_manager_event_filter,
814 if (subs_name_owner_changed == -1) {
815 subs_name_owner_changed = g_dbus_connection_signal_subscribe(conn,
816 NULL, BT_EVENT_FREEDESKTOP,
817 BT_NAME_OWNER_CHANGED, NULL, NULL, 0,
818 __bt_manager_event_filter, NULL, NULL);
822 if (subs_interface_added_id != -1) {
823 g_dbus_connection_signal_unsubscribe(conn,
824 subs_interface_added_id);
825 subs_interface_added_id = -1;
827 if (subs_interface_removed_id != -1) {
828 g_dbus_connection_signal_unsubscribe(conn,
829 subs_interface_removed_id);
830 subs_interface_removed_id = -1;
832 if (subs_name_owner_changed != -1) {
833 g_dbus_connection_signal_unsubscribe(conn,
834 subs_name_owner_changed);
835 subs_name_owner_changed = -1;
842 int _bt_register_device_subscribe_signal(GDBusConnection *conn,
848 static int subs_device_id = -1;
851 if (subs_device_id == -1) {
852 subs_device_id = g_dbus_connection_signal_subscribe(conn,
853 NULL, BT_DEVICE_INTERFACE,
855 __bt_manager_event_filter,
859 if (subs_device_id != -1) {
860 g_dbus_connection_signal_unsubscribe(conn,
868 int _bt_register_input_subscribe_signal(GDBusConnection *conn,
874 static int subs_input_id = -1;
877 if (subs_input_id == -1) {
878 subs_input_id = g_dbus_connection_signal_subscribe(conn,
879 NULL, BT_INPUT_INTERFACE,
881 __bt_manager_event_filter,
885 if (subs_input_id != -1) {
886 g_dbus_connection_signal_unsubscribe(conn,
896 int _bt_register_opp_server_subscribe_signal(GDBusConnection *conn,
902 static int subs_opp_server_interface_added_id = -1;
903 static int subs_opp_server_interface_removed_id = -1;
904 static int subs_opp_server_property_id = -1;
908 if (subs_opp_server_interface_added_id == -1) {
909 subs_opp_server_interface_added_id = g_dbus_connection_signal_subscribe(conn,
910 NULL, BT_MANAGER_INTERFACE,
911 BT_INTERFACES_ADDED, NULL, NULL, 0,
912 __bt_obexd_event_filter,
915 if (subs_opp_server_interface_removed_id == -1) {
916 subs_opp_server_interface_removed_id = g_dbus_connection_signal_subscribe(conn,
917 NULL, BT_MANAGER_INTERFACE,
918 BT_INTERFACES_REMOVED, NULL, NULL, 0,
919 __bt_obexd_event_filter,
922 if (subs_opp_server_property_id == -1) {
923 subs_opp_server_property_id = g_dbus_connection_signal_subscribe(conn,
924 NULL, BT_PROPERTIES_INTERFACE,
925 BT_PROPERTIES_CHANGED, NULL, NULL, 0,
926 __bt_obexd_event_filter,
930 if (subs_opp_server_interface_added_id != -1) {
931 g_dbus_connection_signal_unsubscribe(conn,
932 subs_opp_server_interface_added_id);
933 subs_opp_server_interface_added_id = -1;
935 if (subs_opp_server_interface_removed_id != -1) {
936 g_dbus_connection_signal_unsubscribe(conn,
937 subs_opp_server_interface_removed_id);
938 subs_opp_server_interface_removed_id = -1;
940 if (subs_opp_server_property_id != -1) {
941 g_dbus_connection_signal_unsubscribe(conn,
942 subs_opp_server_property_id);
943 subs_opp_server_property_id = -1;
949 int _bt_register_opp_client_subscribe_signal(GDBusConnection *conn,
955 static int subs_opp_client_interface_added_id = -1;
956 static int subs_opp_client_interface_removed_id = -1;
957 static int subs_opp_client_property_id = -1;
961 if (subs_opp_client_interface_added_id == -1) {
962 subs_opp_client_interface_added_id = g_dbus_connection_signal_subscribe(conn,
963 NULL, BT_MANAGER_INTERFACE,
964 BT_INTERFACES_ADDED, NULL, NULL, 0,
965 __bt_opc_event_filter,
968 if (subs_opp_client_interface_removed_id == -1) {
969 subs_opp_client_interface_removed_id = g_dbus_connection_signal_subscribe(conn,
970 NULL, BT_MANAGER_INTERFACE,
971 BT_INTERFACES_REMOVED, NULL, NULL, 0,
972 __bt_opc_event_filter,
975 if (subs_opp_client_property_id == -1) {
976 subs_opp_client_property_id = g_dbus_connection_signal_subscribe(conn,
977 NULL, BT_PROPERTIES_INTERFACE,
978 BT_PROPERTIES_CHANGED, NULL, NULL, 0,
979 __bt_opc_event_filter,
983 if (subs_opp_client_interface_added_id != -1) {
984 g_dbus_connection_signal_unsubscribe(conn,
985 subs_opp_client_interface_added_id);
986 subs_opp_client_interface_added_id = -1;
988 if (subs_opp_client_interface_removed_id != -1) {
989 g_dbus_connection_signal_unsubscribe(conn,
990 subs_opp_client_interface_removed_id);
991 subs_opp_client_interface_removed_id = -1;
993 if (subs_opp_client_property_id != -1) {
994 g_dbus_connection_signal_unsubscribe(conn,
995 subs_opp_client_property_id);
996 subs_opp_client_property_id = -1;
1002 int _bt_register_map_client_subscribe_signal(GDBusConnection *conn,
1008 static int subs_map_client_interface_added_id = -1;
1009 static int subs_map_client_interface_removed_id = -1;
1010 static int subs_map_client_property_id = -1;
1014 if (subs_map_client_interface_added_id == -1) {
1015 subs_map_client_interface_added_id = g_dbus_connection_signal_subscribe(conn,
1016 NULL, BT_MANAGER_INTERFACE,
1017 BT_INTERFACES_ADDED, NULL, NULL, 0,
1018 __bt_map_event_filter,
1021 if (subs_map_client_interface_removed_id == -1) {
1022 subs_map_client_interface_removed_id = g_dbus_connection_signal_subscribe(conn,
1023 NULL, BT_MANAGER_INTERFACE,
1024 BT_INTERFACES_REMOVED, NULL, NULL, 0,
1025 __bt_map_event_filter,
1028 if (subs_map_client_property_id == -1) {
1029 subs_map_client_property_id = g_dbus_connection_signal_subscribe(conn,
1030 NULL, BT_PROPERTIES_INTERFACE,
1031 BT_PROPERTIES_CHANGED, NULL, NULL, 0,
1032 __bt_map_event_filter,
1036 if (subs_map_client_interface_added_id != -1) {
1037 g_dbus_connection_signal_unsubscribe(conn,
1038 subs_map_client_interface_added_id);
1039 subs_map_client_interface_added_id = -1;
1041 if (subs_map_client_interface_removed_id != -1) {
1042 g_dbus_connection_signal_unsubscribe(conn,
1043 subs_map_client_interface_removed_id);
1044 subs_map_client_interface_removed_id = -1;
1046 if (subs_map_client_property_id != -1) {
1047 g_dbus_connection_signal_unsubscribe(conn,
1048 subs_map_client_property_id);
1049 subs_map_client_property_id = -1;
1056 int _bt_register_service_event(GDBusConnection *g_conn, int event_type)
1058 retv_if(g_conn == NULL, BLUETOOTH_ERROR_INTERNAL);
1060 switch (event_type) {
1061 case BT_MANAGER_EVENT:
1062 _bt_register_manager_subscribe_signal(g_conn, TRUE);
1064 case BT_DEVICE_EVENT:
1065 _bt_register_device_subscribe_signal(g_conn, TRUE);
1067 case BT_OPP_SERVER_EVENT:
1068 _bt_register_opp_server_subscribe_signal(g_conn, TRUE);
1070 case BT_OPP_CLIENT_EVENT:
1071 _bt_register_opp_client_subscribe_signal(g_conn, TRUE);
1073 case BT_MAP_CLIENT_EVENT:
1074 _bt_register_map_client_subscribe_signal(g_conn, TRUE);
1077 BT_ERR("Unknown event");
1078 return BLUETOOTH_ERROR_INTERNAL;
1081 return BLUETOOTH_ERROR_NONE;
1084 void _bt_unregister_service_event(GDBusConnection *g_conn, int event_type)
1088 ret_if(g_conn == NULL);
1090 switch (event_type) {
1091 case BT_MANAGER_EVENT:
1092 _bt_register_manager_subscribe_signal(g_conn, FALSE);
1093 _bt_register_device_subscribe_signal(g_conn, FALSE);
1094 _bt_register_input_subscribe_signal(g_conn, FALSE);
1096 case BT_OPP_SERVER_EVENT:
1097 _bt_register_opp_server_subscribe_signal(g_conn, FALSE);
1099 case BT_OPP_CLIENT_EVENT:
1100 _bt_register_opp_client_subscribe_signal(g_conn, FALSE);
1102 case BT_MAP_CLIENT_EVENT:
1103 _bt_register_map_client_subscribe_signal(g_conn, FALSE);
1106 BT_ERR("Unknown event");
1113 static int __bt_init_manager_receiver(void)
1117 GError *error = NULL;
1119 if (manager_conn == NULL) {
1120 manager_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &error);
1121 if (error != NULL) {
1122 BT_ERR("ERROR: Can't get on system bus [%s]", error->message);
1123 g_clear_error(&error);
1125 retv_if(manager_conn == NULL, BLUETOOTH_ERROR_INTERNAL);
1128 if (_bt_register_service_event(manager_conn,
1129 BT_MANAGER_EVENT) != BLUETOOTH_ERROR_NONE)
1132 if (_bt_register_service_event(manager_conn,
1133 BT_DEVICE_EVENT) != BLUETOOTH_ERROR_NONE)
1136 return BLUETOOTH_ERROR_NONE;
1139 g_object_unref(manager_conn);
1140 manager_conn = NULL;
1145 return BLUETOOTH_ERROR_INTERNAL;
1148 static int __bt_init_obexd_receiver(void)
1151 if (!TIZEN_PROFILE_TV) { /* TODO: obexd doesn't work in TV profile. It should be resolved later. */
1152 GError *error = NULL;
1154 if (obexd_conn == NULL) {
1155 obexd_conn = g_bus_get_sync(G_BUS_TYPE_SYSTEM, NULL, &error);
1156 if (error != NULL) {
1157 BT_ERR("ERROR: Can't get on session bus [%s]", error->message);
1158 g_clear_error(&error);
1160 retv_if(obexd_conn == NULL, BLUETOOTH_ERROR_INTERNAL);
1163 if (_bt_register_service_event(obexd_conn,
1164 BT_OPP_SERVER_EVENT) != BLUETOOTH_ERROR_NONE) {
1165 BT_ERR("Error while registering service event");
1166 g_object_unref(obexd_conn);
1168 return BLUETOOTH_ERROR_INTERNAL;
1174 return BLUETOOTH_ERROR_NONE;
1177 gboolean __bt_reinit_obexd_receiver(gpointer user_data)
1179 static int retry_cnt = 0;
1180 int result = BLUETOOTH_ERROR_NONE;
1184 result = __bt_init_obexd_receiver();
1185 if (result != BLUETOOTH_ERROR_NONE) {
1186 /* 20 ms * 50 = 10 seconds. During 10 seconds fail to initialize,
1187 then it is not the timing issue. Just can't use the session bus connection */
1188 if (retry_cnt > 100) {
1189 BT_ERR("Fail to init obexd receiver by 50 times.");
1191 session_reinit_timer = 0;
1195 BT_DBG("Retry to initialize the obexd receiver");
1200 session_reinit_timer = 0;
1207 /* To receive the event from bluez */
1208 int _bt_init_obex_event_receiver(void)
1214 result = __bt_init_manager_receiver();
1215 retv_if(result != BLUETOOTH_ERROR_NONE, result);
1217 result = __bt_init_obexd_receiver();
1218 if (result != BLUETOOTH_ERROR_NONE) {
1219 BT_ERR("Fail to init obexd receiver");
1221 /* Try to re-initialize obexd receiver in the timer */
1222 if (session_reinit_timer > 0)
1223 g_source_remove(session_reinit_timer);
1225 session_reinit_timer = g_timeout_add(200,
1226 (GSourceFunc)__bt_reinit_obexd_receiver, NULL);
1231 return BLUETOOTH_ERROR_NONE;
1234 void _bt_deinit_obex_event_receiver(void)
1238 _bt_unregister_service_event(manager_conn, BT_MANAGER_EVENT);
1240 _bt_unregister_service_event(obexd_conn, BT_OPP_SERVER_EVENT);
1243 g_object_unref(manager_conn);
1244 manager_conn = NULL;
1248 g_object_unref(obexd_conn);
1253 g_source_remove(event_id);