mirror of
https://github.com/zephyrproject-rtos/zephyr
synced 2025-08-06 11:37:32 +00:00
431dd9f25b
Refactor out implementation of functions defined in buf.h to its own source file buf.c Signed-off-by: Joakim Andersson <joakim.andersson@nordicsemi.no>
138 lines
3.5 KiB
C
138 lines
3.5 KiB
C
/*
|
|
* Copyright (c) 2017 Nordic Semiconductor ASA
|
|
* Copyright (c) 2015 Intel Corporation
|
|
*
|
|
* SPDX-License-Identifier: Apache-2.0
|
|
*/
|
|
|
|
#include <bluetooth/buf.h>
|
|
#include <bluetooth/l2cap.h>
|
|
|
|
#include "hci_core.h"
|
|
#include "conn_internal.h"
|
|
#include "audio/iso_internal.h"
|
|
|
|
#define BT_DBG_ENABLED IS_ENABLED(CONFIG_BT_DEBUG_HCI_CORE)
|
|
#define LOG_MODULE_NAME bt_buf
|
|
#include "common/log.h"
|
|
|
|
NET_BUF_POOL_FIXED_DEFINE(hci_rx_pool, CONFIG_BT_RX_BUF_COUNT,
|
|
BT_BUF_RX_SIZE, NULL);
|
|
|
|
#if defined(CONFIG_BT_CONN)
|
|
#define NUM_COMLETE_EVENT_SIZE BT_BUF_SIZE(\
|
|
sizeof(struct bt_hci_evt_hdr) + \
|
|
sizeof(struct bt_hci_cp_host_num_completed_packets) + \
|
|
CONFIG_BT_MAX_CONN * sizeof(struct bt_hci_handle_count))
|
|
/* Dedicated pool for HCI_Number_of_Completed_Packets. This event is always
|
|
* consumed synchronously by bt_recv_prio() so a single buffer is enough.
|
|
* Having a dedicated pool for it ensures that exhaustion of the RX pool
|
|
* cannot block the delivery of this priority event.
|
|
*/
|
|
NET_BUF_POOL_FIXED_DEFINE(num_complete_pool, 1, NUM_COMLETE_EVENT_SIZE, NULL);
|
|
#endif /* CONFIG_BT_CONN */
|
|
|
|
#if defined(CONFIG_BT_DISCARDABLE_BUF_COUNT)
|
|
#define DISCARDABLE_EVENT_SIZE BT_BUF_SIZE(CONFIG_BT_DISCARDABLE_BUF_SIZE)
|
|
NET_BUF_POOL_FIXED_DEFINE(discardable_pool, CONFIG_BT_DISCARDABLE_BUF_COUNT,
|
|
DISCARDABLE_EVENT_SIZE, NULL);
|
|
#endif /* CONFIG_BT_DISCARDABLE_BUF_COUNT */
|
|
|
|
#if defined(CONFIG_BT_HCI_ACL_FLOW_CONTROL)
|
|
#define ACL_IN_SIZE BT_L2CAP_BUF_SIZE(CONFIG_BT_L2CAP_RX_MTU)
|
|
NET_BUF_POOL_DEFINE(acl_in_pool, CONFIG_BT_ACL_RX_COUNT, ACL_IN_SIZE,
|
|
sizeof(struct acl_data), bt_hci_host_num_completed_packets);
|
|
#endif /* CONFIG_BT_HCI_ACL_FLOW_CONTROL */
|
|
|
|
struct net_buf *bt_buf_get_rx(enum bt_buf_type type, k_timeout_t timeout)
|
|
{
|
|
struct net_buf *buf;
|
|
|
|
__ASSERT(type == BT_BUF_EVT || type == BT_BUF_ACL_IN ||
|
|
type == BT_BUF_ISO_IN, "Invalid buffer type requested");
|
|
|
|
if (IS_ENABLED(CONFIG_BT_ISO) && type == BT_BUF_ISO_IN) {
|
|
return bt_iso_get_rx(timeout);
|
|
}
|
|
|
|
#if defined(CONFIG_BT_HCI_ACL_FLOW_CONTROL)
|
|
if (type == BT_BUF_EVT) {
|
|
buf = net_buf_alloc(&hci_rx_pool, timeout);
|
|
} else {
|
|
buf = net_buf_alloc(&acl_in_pool, timeout);
|
|
}
|
|
#else
|
|
buf = net_buf_alloc(&hci_rx_pool, timeout);
|
|
#endif
|
|
|
|
if (buf) {
|
|
net_buf_reserve(buf, BT_BUF_RESERVE);
|
|
bt_buf_set_type(buf, type);
|
|
}
|
|
|
|
return buf;
|
|
}
|
|
|
|
struct net_buf *bt_buf_get_cmd_complete(k_timeout_t timeout)
|
|
{
|
|
struct net_buf *buf;
|
|
unsigned int key;
|
|
|
|
key = irq_lock();
|
|
buf = bt_dev.sent_cmd;
|
|
bt_dev.sent_cmd = NULL;
|
|
irq_unlock(key);
|
|
|
|
BT_DBG("sent_cmd %p", buf);
|
|
|
|
if (buf) {
|
|
bt_buf_set_type(buf, BT_BUF_EVT);
|
|
buf->len = 0U;
|
|
net_buf_reserve(buf, BT_BUF_RESERVE);
|
|
|
|
return buf;
|
|
}
|
|
|
|
return bt_buf_get_rx(BT_BUF_EVT, timeout);
|
|
}
|
|
|
|
struct net_buf *bt_buf_get_evt(uint8_t evt, bool discardable,
|
|
k_timeout_t timeout)
|
|
{
|
|
switch (evt) {
|
|
#if defined(CONFIG_BT_CONN)
|
|
case BT_HCI_EVT_NUM_COMPLETED_PACKETS:
|
|
{
|
|
struct net_buf *buf;
|
|
|
|
buf = net_buf_alloc(&num_complete_pool, timeout);
|
|
if (buf) {
|
|
net_buf_reserve(buf, BT_BUF_RESERVE);
|
|
bt_buf_set_type(buf, BT_BUF_EVT);
|
|
}
|
|
|
|
return buf;
|
|
}
|
|
#endif /* CONFIG_BT_CONN */
|
|
case BT_HCI_EVT_CMD_COMPLETE:
|
|
case BT_HCI_EVT_CMD_STATUS:
|
|
return bt_buf_get_cmd_complete(timeout);
|
|
default:
|
|
#if defined(CONFIG_BT_DISCARDABLE_BUF_COUNT)
|
|
if (discardable) {
|
|
struct net_buf *buf;
|
|
|
|
buf = net_buf_alloc(&discardable_pool, timeout);
|
|
if (buf) {
|
|
net_buf_reserve(buf, BT_BUF_RESERVE);
|
|
bt_buf_set_type(buf, BT_BUF_EVT);
|
|
}
|
|
|
|
return buf;
|
|
}
|
|
#endif /* CONFIG_BT_DISCARDABLE_BUF_COUNT */
|
|
|
|
return bt_buf_get_rx(BT_BUF_EVT, timeout);
|
|
}
|
|
}
|