150 lines
2.8 KiB
C
150 lines
2.8 KiB
C
/* Bluetooth Mesh */
|
|
|
|
/*
|
|
* Copyright (c) 2017 Intel Corporation
|
|
* Copyright (c) 2020 Nordic Semiconductor ASA
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
#include <bluetooth/mesh.h>
|
|
#include <bluetooth/conn.h>
|
|
#include "prov.h"
|
|
#include "net.h"
|
|
#include "proxy.h"
|
|
#include "adv.h"
|
|
#include "prov_bearer.h"
|
|
|
|
#define BT_DBG_ENABLED IS_ENABLED(CONFIG_BT_MESH_DEBUG_PROV)
|
|
#define LOG_MODULE_NAME bt_mesh_pb_gatt
|
|
#include "common/log.h"
|
|
|
|
struct prov_link {
|
|
struct bt_conn *conn;
|
|
const struct prov_bearer_cb *cb;
|
|
void *cb_data;
|
|
struct net_buf_simple *rx_buf;
|
|
struct k_delayed_work prot_timer;
|
|
};
|
|
|
|
static struct prov_link link;
|
|
|
|
static void reset_state(void)
|
|
{
|
|
if (link.conn) {
|
|
bt_conn_unref(link.conn);
|
|
}
|
|
|
|
k_delayed_work_cancel(&link.prot_timer);
|
|
memset(&link, 0, offsetof(struct prov_link, prot_timer));
|
|
|
|
link.rx_buf = bt_mesh_proxy_get_buf();
|
|
}
|
|
|
|
static void link_closed(enum prov_bearer_link_status status)
|
|
{
|
|
const struct prov_bearer_cb *cb = link.cb;
|
|
void *cb_data = link.cb_data;
|
|
|
|
reset_state();
|
|
|
|
cb->link_closed(&pb_gatt, cb_data, status);
|
|
}
|
|
|
|
static void protocol_timeout(struct k_work *work)
|
|
{
|
|
BT_DBG("Protocol timeout");
|
|
|
|
link_closed(PROV_BEARER_LINK_STATUS_TIMEOUT);
|
|
}
|
|
|
|
int bt_mesh_pb_gatt_recv(struct bt_conn *conn, struct net_buf_simple *buf)
|
|
{
|
|
BT_DBG("%u bytes: %s", buf->len, bt_hex(buf->data, buf->len));
|
|
|
|
if (link.conn != conn || !link.cb) {
|
|
BT_WARN("Data for unexpected connection");
|
|
return -ENOTCONN;
|
|
}
|
|
|
|
if (buf->len < 1) {
|
|
BT_WARN("Too short provisioning packet (len %u)", buf->len);
|
|
return -EINVAL;
|
|
}
|
|
|
|
k_delayed_work_submit(&link.prot_timer, PROTOCOL_TIMEOUT);
|
|
|
|
link.cb->recv(&pb_gatt, link.cb_data, buf);
|
|
|
|
return 0;
|
|
}
|
|
|
|
int bt_mesh_pb_gatt_open(struct bt_conn *conn)
|
|
{
|
|
BT_DBG("conn %p", conn);
|
|
|
|
if (link.conn) {
|
|
return -EBUSY;
|
|
}
|
|
|
|
link.conn = bt_conn_ref(conn);
|
|
k_delayed_work_submit(&link.prot_timer, PROTOCOL_TIMEOUT);
|
|
|
|
link.cb->link_opened(&pb_gatt, link.cb_data);
|
|
|
|
return 0;
|
|
}
|
|
|
|
int bt_mesh_pb_gatt_close(struct bt_conn *conn)
|
|
{
|
|
BT_DBG("conn %p", conn);
|
|
|
|
if (link.conn != conn) {
|
|
BT_ERR("Not connected");
|
|
return -ENOTCONN;
|
|
}
|
|
|
|
link_closed(PROV_BEARER_LINK_STATUS_SUCCESS);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int link_accept(const struct prov_bearer_cb *cb, void *cb_data)
|
|
{
|
|
bt_mesh_proxy_prov_enable();
|
|
bt_mesh_adv_update();
|
|
|
|
link.cb = cb;
|
|
link.cb_data = cb_data;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int buf_send(struct net_buf_simple *buf, prov_bearer_send_complete_t cb,
|
|
void *cb_data)
|
|
{
|
|
if (!link.conn) {
|
|
return -ENOTCONN;
|
|
}
|
|
|
|
k_delayed_work_submit(&link.prot_timer, PROTOCOL_TIMEOUT);
|
|
|
|
return bt_mesh_proxy_send(link.conn, BT_MESH_PROXY_PROV, buf);
|
|
}
|
|
|
|
static void clear_tx(void)
|
|
{
|
|
/* No action */
|
|
}
|
|
|
|
void pb_gatt_init(void)
|
|
{
|
|
k_delayed_work_init(&link.prot_timer, protocol_timeout);
|
|
}
|
|
|
|
const struct prov_bearer pb_gatt = {
|
|
.type = BT_MESH_PROV_GATT,
|
|
.link_accept = link_accept,
|
|
.send = buf_send,
|
|
.clear_tx = clear_tx,
|
|
};
|