| /* |
| * Licensed to the Apache Software Foundation (ASF) under one |
| * or more contributor license agreements. See the NOTICE file |
| * distributed with this work for additional information |
| * regarding copyright ownership. The ASF licenses this file |
| * to you 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. |
| */ |
| |
| #include <string.h> |
| #include <errno.h> |
| #include "testutil/testutil.h" |
| #include "nimble/ble.h" |
| #include "host/ble_hs_test.h" |
| #include "ble_hs_test_util.h" |
| |
| #define BLE_GATT_BREAK_TEST_READ_ATTR_HANDLE 0x9383 |
| #define BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE 0x1234 |
| |
| static uint8_t ble_gatt_conn_test_write_value[] = { 1, 3, 64, 21, 6 }; |
| |
| struct ble_gatt_conn_test_arg { |
| uint16_t exp_conn_handle; |
| int exp_status; |
| int called; |
| }; |
| |
| static struct ble_gap_event ble_gatt_conn_test_gap_event; |
| |
| static void |
| ble_gatt_conn_test_util_init(void) |
| { |
| ble_hs_test_util_init(); |
| memset(&ble_gatt_conn_test_gap_event, -1, |
| sizeof ble_gatt_conn_test_gap_event); |
| } |
| |
| static int |
| ble_gatt_conn_test_indicate_cb(struct ble_gap_event *event, void *arg) |
| { |
| /* Only record indication failures. */ |
| if (event->type == BLE_GAP_EVENT_NOTIFY_TX && |
| event->notify_tx.status != 0) { |
| |
| ble_gatt_conn_test_gap_event = *event; |
| } |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_attr_cb(uint16_t conn_handle, uint16_t attr_handle, |
| uint8_t op, uint16_t offset, struct os_mbuf **om, |
| void *arg) |
| { |
| uint8_t *buf; |
| |
| switch (op) { |
| case BLE_ATT_ACCESS_OP_READ: |
| buf = os_mbuf_extend(*om, 1); |
| TEST_ASSERT_FATAL(buf != NULL); |
| *buf = 1; |
| return 0; |
| |
| default: |
| return -1; |
| } |
| } |
| |
| static int |
| ble_gatt_conn_test_mtu_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| uint16_t mtu, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(mtu == 0); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_disc_all_svcs_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| const struct ble_gatt_svc *service, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(service == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_disc_svc_uuid_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| const struct ble_gatt_svc *service, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(service == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_find_inc_svcs_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| const struct ble_gatt_svc *service, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(service == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_disc_all_chrs_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| const struct ble_gatt_chr *chr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(chr == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_disc_chr_uuid_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| const struct ble_gatt_chr *chr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(chr == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_disc_all_dscs_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| uint16_t chr_def_handle, |
| const struct ble_gatt_dsc *dsc, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(dsc == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_read_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_read_uuid_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_read_long_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| static int |
| ble_gatt_conn_test_read_mult_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr->om == NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_write_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr != NULL); |
| TEST_ASSERT(attr->handle == BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_write_long_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attr, void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attr != NULL); |
| TEST_ASSERT(attr->handle == BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| static int |
| ble_gatt_conn_test_write_rel_cb(uint16_t conn_handle, |
| const struct ble_gatt_error *error, |
| struct ble_gatt_attr *attrs, |
| uint8_t num_attrs, |
| void *arg) |
| { |
| struct ble_gatt_conn_test_arg *cb_arg; |
| |
| cb_arg = arg; |
| |
| TEST_ASSERT(cb_arg->exp_conn_handle == conn_handle); |
| TEST_ASSERT(!cb_arg->called); |
| TEST_ASSERT_FATAL(error != NULL); |
| TEST_ASSERT(error->status == cb_arg->exp_status); |
| TEST_ASSERT(attrs != NULL); |
| |
| cb_arg->called++; |
| |
| return 0; |
| } |
| |
| TEST_CASE(ble_gatt_conn_test_disconnect) |
| { |
| struct ble_gatt_conn_test_arg mtu_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg disc_all_svcs_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg disc_svc_uuid_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg find_inc_svcs_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg disc_all_chrs_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg disc_chr_uuid_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg disc_all_dscs_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg read_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg read_uuid_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg read_long_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg read_mult_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg write_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg write_long_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_conn_test_arg write_rel_arg = { 0, BLE_HS_ENOTCONN }; |
| struct ble_gatt_attr attr; |
| uint16_t attr_handle; |
| uint16_t offset = 0; |
| int rc; |
| |
| ble_gatt_conn_test_util_init(); |
| |
| /*** Register an attribute to allow indicatations to be sent. */ |
| rc = ble_att_svr_register(BLE_UUID16_DECLARE(0x1212), BLE_ATT_F_READ, 0, |
| &attr_handle, |
| ble_gatt_conn_test_attr_cb, NULL); |
| TEST_ASSERT(rc == 0); |
| |
| /* Create three connections. */ |
| ble_hs_test_util_create_conn(1, ((uint8_t[]){1,2,3,4,5,6,7,8}), |
| ble_gatt_conn_test_indicate_cb, NULL); |
| ble_hs_test_util_create_conn(2, ((uint8_t[]){2,3,4,5,6,7,8,9}), |
| ble_gatt_conn_test_indicate_cb, NULL); |
| ble_hs_test_util_create_conn(3, ((uint8_t[]){3,4,5,6,7,8,9,10}), |
| ble_gatt_conn_test_indicate_cb, NULL); |
| |
| /*** Schedule some GATT procedures. */ |
| /* Connection 1. */ |
| mtu_arg.exp_conn_handle = 1; |
| ble_gattc_exchange_mtu(1, ble_gatt_conn_test_mtu_cb, &mtu_arg); |
| |
| disc_all_svcs_arg.exp_conn_handle = 1; |
| rc = ble_gattc_disc_all_svcs(1, ble_gatt_conn_test_disc_all_svcs_cb, |
| &disc_all_svcs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| disc_svc_uuid_arg.exp_conn_handle = 1; |
| rc = ble_gattc_disc_svc_by_uuid(1, BLE_UUID16_DECLARE(0x1111), |
| ble_gatt_conn_test_disc_svc_uuid_cb, |
| &disc_svc_uuid_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| find_inc_svcs_arg.exp_conn_handle = 1; |
| rc = ble_gattc_find_inc_svcs(1, 1, 0xffff, |
| ble_gatt_conn_test_find_inc_svcs_cb, |
| &find_inc_svcs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| disc_all_chrs_arg.exp_conn_handle = 1; |
| rc = ble_gattc_disc_all_chrs(1, 1, 0xffff, |
| ble_gatt_conn_test_disc_all_chrs_cb, |
| &disc_all_chrs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| /* Connection 2. */ |
| disc_all_dscs_arg.exp_conn_handle = 2; |
| rc = ble_gattc_disc_all_dscs(2, 3, 0xffff, |
| ble_gatt_conn_test_disc_all_dscs_cb, |
| &disc_all_dscs_arg); |
| |
| disc_chr_uuid_arg.exp_conn_handle = 2; |
| rc = ble_gattc_disc_chrs_by_uuid(2, 2, 0xffff, BLE_UUID16_DECLARE(0x2222), |
| ble_gatt_conn_test_disc_chr_uuid_cb, |
| &disc_chr_uuid_arg); |
| |
| read_arg.exp_conn_handle = 2; |
| rc = ble_gattc_read(2, BLE_GATT_BREAK_TEST_READ_ATTR_HANDLE, |
| ble_gatt_conn_test_read_cb, &read_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| read_uuid_arg.exp_conn_handle = 2; |
| rc = ble_gattc_read_by_uuid(2, 1, 0xffff, BLE_UUID16_DECLARE(0x3333), |
| ble_gatt_conn_test_read_uuid_cb, |
| &read_uuid_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| read_long_arg.exp_conn_handle = 2; |
| rc = ble_gattc_read_long(2, BLE_GATT_BREAK_TEST_READ_ATTR_HANDLE, offset, |
| ble_gatt_conn_test_read_long_cb, &read_long_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| /* Connection 3. */ |
| read_mult_arg.exp_conn_handle = 3; |
| rc = ble_gattc_read_mult(3, ((uint16_t[3]){5,6,7}), 3, |
| ble_gatt_conn_test_read_mult_cb, &read_mult_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| write_arg.exp_conn_handle = 3; |
| rc = ble_hs_test_util_gatt_write_flat( |
| 3, BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE, |
| ble_gatt_conn_test_write_value, sizeof ble_gatt_conn_test_write_value, |
| ble_gatt_conn_test_write_cb, &write_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| write_long_arg.exp_conn_handle = 3; |
| rc = ble_hs_test_util_gatt_write_long_flat( |
| 3, BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE, |
| ble_gatt_conn_test_write_value, sizeof ble_gatt_conn_test_write_value, |
| ble_gatt_conn_test_write_long_cb, &write_long_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| attr.handle = 8; |
| attr.offset = 0; |
| attr.om = os_msys_get_pkthdr(0, 0); |
| write_rel_arg.exp_conn_handle = 3; |
| rc = ble_gattc_write_reliable( |
| 3, &attr, 1, ble_gatt_conn_test_write_rel_cb, &write_rel_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| rc = ble_gattc_indicate(3, attr_handle); |
| TEST_ASSERT_FATAL(rc == 0); |
| |
| /*** Start the procedures. */ |
| |
| /*** Break the connections; verify proper callbacks got called. */ |
| /* Connection 1. */ |
| ble_gattc_connection_broken(1); |
| TEST_ASSERT(mtu_arg.called == 1); |
| TEST_ASSERT(disc_all_svcs_arg.called == 1); |
| TEST_ASSERT(disc_svc_uuid_arg.called == 1); |
| TEST_ASSERT(find_inc_svcs_arg.called == 1); |
| TEST_ASSERT(disc_all_chrs_arg.called == 1); |
| TEST_ASSERT(disc_chr_uuid_arg.called == 0); |
| TEST_ASSERT(disc_all_dscs_arg.called == 0); |
| TEST_ASSERT(read_arg.called == 0); |
| TEST_ASSERT(read_uuid_arg.called == 0); |
| TEST_ASSERT(read_long_arg.called == 0); |
| TEST_ASSERT(read_mult_arg.called == 0); |
| TEST_ASSERT(write_arg.called == 0); |
| TEST_ASSERT(write_long_arg.called == 0); |
| TEST_ASSERT(write_rel_arg.called == 0); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.type == 255); |
| |
| /* Connection 2. */ |
| ble_gattc_connection_broken(2); |
| TEST_ASSERT(mtu_arg.called == 1); |
| TEST_ASSERT(disc_all_svcs_arg.called == 1); |
| TEST_ASSERT(disc_svc_uuid_arg.called == 1); |
| TEST_ASSERT(find_inc_svcs_arg.called == 1); |
| TEST_ASSERT(disc_all_chrs_arg.called == 1); |
| TEST_ASSERT(disc_chr_uuid_arg.called == 1); |
| TEST_ASSERT(disc_all_dscs_arg.called == 1); |
| TEST_ASSERT(read_arg.called == 1); |
| TEST_ASSERT(read_uuid_arg.called == 1); |
| TEST_ASSERT(read_long_arg.called == 1); |
| TEST_ASSERT(read_mult_arg.called == 0); |
| TEST_ASSERT(write_arg.called == 0); |
| TEST_ASSERT(write_long_arg.called == 0); |
| TEST_ASSERT(write_rel_arg.called == 0); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.type == 255); |
| |
| /* Connection 3. */ |
| ble_gattc_connection_broken(3); |
| TEST_ASSERT(mtu_arg.called == 1); |
| TEST_ASSERT(disc_all_svcs_arg.called == 1); |
| TEST_ASSERT(disc_svc_uuid_arg.called == 1); |
| TEST_ASSERT(find_inc_svcs_arg.called == 1); |
| TEST_ASSERT(disc_all_chrs_arg.called == 1); |
| TEST_ASSERT(disc_chr_uuid_arg.called == 1); |
| TEST_ASSERT(disc_all_dscs_arg.called == 1); |
| TEST_ASSERT(read_arg.called == 1); |
| TEST_ASSERT(read_uuid_arg.called == 1); |
| TEST_ASSERT(read_long_arg.called == 1); |
| TEST_ASSERT(read_mult_arg.called == 1); |
| TEST_ASSERT(write_arg.called == 1); |
| TEST_ASSERT(write_long_arg.called == 1); |
| TEST_ASSERT(write_rel_arg.called == 1); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.type == BLE_GAP_EVENT_NOTIFY_TX); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.notify_tx.status == |
| BLE_HS_ENOTCONN); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.notify_tx.conn_handle == 3); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.notify_tx.attr_handle == |
| attr_handle); |
| TEST_ASSERT(ble_gatt_conn_test_gap_event.notify_tx.indication); |
| } |
| |
| static void |
| ble_gatt_conn_test_util_timeout(uint16_t conn_handle, |
| struct ble_gatt_conn_test_arg *arg) |
| { |
| struct hci_disconn_complete evt; |
| int32_t ticks_from_now; |
| |
| ticks_from_now = ble_gattc_timer(); |
| TEST_ASSERT(ticks_from_now == 30 * OS_TICKS_PER_SEC); |
| |
| os_time_advance(29 * OS_TICKS_PER_SEC); |
| ticks_from_now = ble_gattc_timer(); |
| TEST_ASSERT(ticks_from_now == 1 * OS_TICKS_PER_SEC); |
| |
| ble_hs_test_util_hci_ack_set_disconnect(0); |
| os_time_advance(1 * OS_TICKS_PER_SEC); |
| ticks_from_now = ble_gattc_timer(); |
| TEST_ASSERT(ticks_from_now == BLE_HS_FOREVER); |
| |
| /* Ensure connection was terminated due to proecedure timeout. */ |
| evt.connection_handle = conn_handle; |
| evt.status = 0; |
| evt.reason = BLE_ERR_REM_USER_CONN_TERM; |
| ble_hs_test_util_hci_rx_disconn_complete_event(&evt); |
| |
| /* Ensure GATT callback was called with timeout status. */ |
| if (arg != NULL) { |
| TEST_ASSERT(arg->called == 1); |
| } |
| } |
| |
| TEST_CASE(ble_gatt_conn_test_timeout) |
| { |
| static const uint8_t peer_addr[6] = { 1, 2, 3, 4, 5, 6 }; |
| |
| struct ble_gatt_conn_test_arg mtu_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg disc_all_svcs_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg disc_svc_uuid_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg find_inc_svcs_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg disc_all_chrs_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg disc_chr_uuid_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg disc_all_dscs_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg read_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg read_uuid_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg read_long_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg read_mult_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg write_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg write_long_arg = { 1, BLE_HS_ETIMEOUT }; |
| struct ble_gatt_conn_test_arg write_rel_arg = { 1, BLE_HS_ETIMEOUT }; |
| |
| struct ble_gatt_attr attr; |
| int32_t ticks_from_now; |
| uint16_t attr_handle; |
| uint16_t offset = 0; |
| int rc; |
| |
| ble_gatt_conn_test_util_init(); |
| |
| ticks_from_now = ble_gattc_timer(); |
| TEST_ASSERT(ticks_from_now == BLE_HS_FOREVER); |
| |
| /*** Register an attribute to allow indicatations to be sent. */ |
| rc = ble_att_svr_register(BLE_UUID16_DECLARE(0x1212), BLE_ATT_F_READ, 0, |
| &attr_handle, |
| ble_gatt_conn_test_attr_cb, NULL); |
| TEST_ASSERT(rc == 0); |
| |
| /*** MTU. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_exchange_mtu(1, ble_gatt_conn_test_mtu_cb, &mtu_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &mtu_arg); |
| |
| /*** Discover all services. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_disc_all_svcs(1, ble_gatt_conn_test_disc_all_svcs_cb, |
| &disc_all_svcs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &disc_all_svcs_arg); |
| |
| /*** Discover services by UUID. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_disc_svc_by_uuid(1, BLE_UUID16_DECLARE(0x1111), |
| ble_gatt_conn_test_disc_svc_uuid_cb, |
| &disc_svc_uuid_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &disc_svc_uuid_arg); |
| |
| /*** Find included services. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_find_inc_svcs(1, 1, 0xffff, |
| ble_gatt_conn_test_find_inc_svcs_cb, |
| &find_inc_svcs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &find_inc_svcs_arg); |
| |
| /*** Discover all characteristics. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_disc_all_chrs(1, 1, 0xffff, |
| ble_gatt_conn_test_disc_all_chrs_cb, |
| &disc_all_chrs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &disc_all_chrs_arg); |
| |
| /*** Discover all descriptors. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_disc_all_dscs(1, 3, 0xffff, |
| ble_gatt_conn_test_disc_all_dscs_cb, |
| &disc_chr_uuid_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &disc_chr_uuid_arg); |
| |
| /*** Discover characteristics by UUID. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_disc_chrs_by_uuid(1, 2, 0xffff, BLE_UUID16_DECLARE(0x2222), |
| ble_gatt_conn_test_disc_chr_uuid_cb, |
| &disc_all_dscs_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &disc_all_dscs_arg); |
| |
| /*** Read. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_read(1, BLE_GATT_BREAK_TEST_READ_ATTR_HANDLE, |
| ble_gatt_conn_test_read_cb, &read_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &read_arg); |
| |
| /*** Read by UUID. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_read_by_uuid(1, 1, 0xffff, BLE_UUID16_DECLARE(0x3333), |
| ble_gatt_conn_test_read_uuid_cb, |
| &read_uuid_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &read_uuid_arg); |
| |
| /*** Read long. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_read_long(1, BLE_GATT_BREAK_TEST_READ_ATTR_HANDLE, offset, |
| ble_gatt_conn_test_read_long_cb, |
| &read_long_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &read_long_arg); |
| |
| /*** Read multiple. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_read_mult(1, ((uint16_t[3]){5,6,7}), 3, |
| ble_gatt_conn_test_read_mult_cb, |
| &read_mult_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &read_mult_arg); |
| |
| /*** Write. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_hs_test_util_gatt_write_flat( |
| 1, BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE, |
| ble_gatt_conn_test_write_value, sizeof ble_gatt_conn_test_write_value, |
| ble_gatt_conn_test_write_cb, &write_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &write_arg); |
| |
| /*** Write long. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_hs_test_util_gatt_write_long_flat( |
| 1, BLE_GATT_BREAK_TEST_WRITE_ATTR_HANDLE, |
| ble_gatt_conn_test_write_value, sizeof ble_gatt_conn_test_write_value, |
| ble_gatt_conn_test_write_long_cb, &write_long_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &write_long_arg); |
| |
| /*** Write reliable. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| attr.handle = 8; |
| attr.offset = 0; |
| attr.om = os_msys_get_pkthdr(0, 0); |
| rc = ble_gattc_write_reliable( |
| 1, &attr, 1, ble_gatt_conn_test_write_rel_cb, &write_rel_arg); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, &write_rel_arg); |
| |
| /*** Indication. */ |
| ble_hs_test_util_create_conn(1, peer_addr, NULL, NULL); |
| rc = ble_gattc_indicate(1, attr_handle); |
| TEST_ASSERT_FATAL(rc == 0); |
| ble_gatt_conn_test_util_timeout(1, NULL); |
| } |
| |
| TEST_SUITE(ble_gatt_conn_suite) |
| { |
| tu_suite_set_post_test_cb(ble_hs_test_util_post_test, NULL); |
| |
| ble_gatt_conn_test_disconnect(); |
| ble_gatt_conn_test_timeout(); |
| } |
| |
| int |
| ble_gatt_conn_test_all(void) |
| { |
| ble_gatt_conn_suite(); |
| |
| return tu_any_failed; |
| } |
