| /****************************************************************************** |
| * |
| * Copyright (C) 2014 Google, Inc. |
| * |
| * Licensed under the Apache License, Version 2.0 (the "License"); |
| * you may not use this file except in compliance with the License. |
| * You may obtain a copy of the License at: |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| * |
| ******************************************************************************/ |
| |
| #define LOG_TAG "bt_btif_sock" |
| |
| #include <assert.h> |
| |
| #include <hardware/bluetooth.h> |
| #include <hardware/bt_sock.h> |
| |
| #include "bta_api.h" |
| #include "btif_common.h" |
| #include "btif_sock_l2cap.h" |
| #include "btif_sock_rfc.h" |
| #include "btif_sock_sco.h" |
| #include "btif_sock_sdp.h" |
| #include "btif_sock_thread.h" |
| #include "btif_util.h" |
| #include "osi/include/thread.h" |
| |
| static bt_status_t btsock_listen(btsock_type_t type, const char *service_name, const uint8_t *uuid, int channel, int *sock_fd, int flags); |
| static bt_status_t btsock_connect(const bt_bdaddr_t *bd_addr, btsock_type_t type, const uint8_t *uuid, int channel, int *sock_fd, int flags); |
| |
| static void btsock_signaled(int fd, int type, int flags, uint32_t user_id); |
| |
| static int thread_handle = -1; |
| static thread_t *thread; |
| |
| btsock_interface_t *btif_sock_get_interface(void) { |
| static btsock_interface_t interface = { |
| sizeof(interface), |
| btsock_listen, |
| btsock_connect |
| }; |
| |
| |
| return &interface; |
| } |
| |
| bt_status_t btif_sock_init(void) { |
| assert(thread_handle == -1); |
| assert(thread == NULL); |
| |
| btsock_thread_init(); |
| thread_handle = btsock_thread_create(btsock_signaled, NULL); |
| if (thread_handle == -1) { |
| LOG_ERROR(LOG_TAG, "%s unable to create btsock_thread.", __func__); |
| goto error; |
| } |
| |
| bt_status_t status = btsock_rfc_init(thread_handle); |
| if (status != BT_STATUS_SUCCESS) { |
| LOG_ERROR(LOG_TAG, "%s error initializing RFCOMM sockets: %d", __func__, status); |
| goto error; |
| } |
| |
| status = btsock_l2cap_init(thread_handle); |
| if (status != BT_STATUS_SUCCESS) { |
| LOG_ERROR(LOG_TAG, "%s error initializing L2CAP sockets: %d", __func__, status); |
| goto error; |
| } |
| |
| thread = thread_new("btif_sock"); |
| if (!thread) { |
| LOG_ERROR(LOG_TAG, "%s error creating new thread.", __func__); |
| btsock_rfc_cleanup(); |
| goto error; |
| } |
| |
| status = btsock_sco_init(thread); |
| if (status != BT_STATUS_SUCCESS) { |
| LOG_ERROR(LOG_TAG, "%s error initializing SCO sockets: %d", __func__, status); |
| btsock_rfc_cleanup(); |
| goto error; |
| } |
| |
| return BT_STATUS_SUCCESS; |
| |
| error:; |
| thread_free(thread); |
| thread = NULL; |
| if (thread_handle != -1) |
| btsock_thread_exit(thread_handle); |
| thread_handle = -1; |
| return BT_STATUS_FAIL; |
| } |
| |
| void btif_sock_cleanup(void) { |
| if (thread_handle == -1) |
| return; |
| |
| thread_stop(thread); |
| thread_join(thread); |
| btsock_thread_exit(thread_handle); |
| btsock_rfc_cleanup(); |
| btsock_sco_cleanup(); |
| btsock_l2cap_cleanup(); |
| thread_free(thread); |
| thread_handle = -1; |
| thread = NULL; |
| } |
| |
| static bt_status_t btsock_listen(btsock_type_t type, const char *service_name, const uint8_t *service_uuid, int channel, int *sock_fd, int flags) { |
| if((flags & BTSOCK_FLAG_NO_SDP) == 0) { |
| assert(service_uuid != NULL || channel > 0); |
| assert(sock_fd != NULL); |
| } |
| |
| *sock_fd = INVALID_FD; |
| bt_status_t status = BT_STATUS_FAIL; |
| |
| switch (type) { |
| case BTSOCK_RFCOMM: |
| status = btsock_rfc_listen(service_name, service_uuid, channel, sock_fd, flags); |
| break; |
| case BTSOCK_L2CAP: |
| status = btsock_l2cap_listen(service_name, channel, sock_fd, flags); |
| break; |
| |
| case BTSOCK_SCO: |
| status = btsock_sco_listen(sock_fd, flags); |
| break; |
| |
| default: |
| LOG_ERROR(LOG_TAG, "%s unknown/unsupported socket type: %d", __func__, type); |
| status = BT_STATUS_UNSUPPORTED; |
| break; |
| } |
| return status; |
| } |
| |
| static bt_status_t btsock_connect(const bt_bdaddr_t *bd_addr, btsock_type_t type, const uint8_t *uuid, int channel, int *sock_fd, int flags) { |
| assert(uuid != NULL || channel > 0); |
| assert(bd_addr != NULL); |
| assert(sock_fd != NULL); |
| |
| *sock_fd = INVALID_FD; |
| bt_status_t status = BT_STATUS_FAIL; |
| |
| switch (type) { |
| case BTSOCK_RFCOMM: |
| status = btsock_rfc_connect(bd_addr, uuid, channel, sock_fd, flags); |
| break; |
| |
| case BTSOCK_L2CAP: |
| status = btsock_l2cap_connect(bd_addr, channel, sock_fd, flags); |
| break; |
| |
| case BTSOCK_SCO: |
| status = btsock_sco_connect(bd_addr, sock_fd, flags); |
| break; |
| |
| default: |
| LOG_ERROR(LOG_TAG, "%s unknown/unsupported socket type: %d", __func__, type); |
| status = BT_STATUS_UNSUPPORTED; |
| break; |
| } |
| return status; |
| } |
| |
| static void btsock_signaled(int fd, int type, int flags, uint32_t user_id) { |
| switch (type) { |
| case BTSOCK_RFCOMM: |
| btsock_rfc_signaled(fd, flags, user_id); |
| break; |
| case BTSOCK_L2CAP: |
| btsock_l2cap_signaled(fd, flags, user_id); |
| break; |
| default: |
| assert(false && "Invalid socket type"); |
| break; |
| } |
| } |