mirror/btstack
1
0
Fork 0
mirror of https://github.com/bluekitchen/btstack.git synced 2025-02-04 06:39:53 +00:00
Code Issues Packages Projects Releases Wiki Activity

att_dispatch: round robin for client & server

Browse Source
This commit is contained in:
Matthias Ringwald 2018-02-01 12:19:12 +01:00
parent 53e41ec1de
commit 7a705a928c
1 changed files with 11 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/ble/att_dispatch.c
View File

@ -49,14 +49,19 @@
#define ATT_SERVER 0 #define ATT_SERVER 0
#define ATT_CLIENT 1 #define ATT_CLIENT 1
#define ATT_MAX 2
struct { struct {
btstack_packet_handler_t packet_handler; btstack_packet_handler_t packet_handler;
uint8_t waiting_for_can_send; uint8_t waiting_for_can_send;
} subscriptions[2]; } subscriptions[ATT_MAX];
// index of subscription that will get can send now first if waiting for it
static uint8_t att_round_robin;
static void att_packet_handler(uint8_t packet_type, uint16_t handle, uint8_t *packet, uint16_t size){ static void att_packet_handler(uint8_t packet_type, uint16_t handle, uint8_t *packet, uint16_t size){
int index; uint8_t index;
uint8_t i;
switch (packet_type){ switch (packet_type){
case ATT_DATA_PACKET: case ATT_DATA_PACKET:
// odd PDUs are sent from server to client - even PDUs are sent from client to server // odd PDUs are sent from server to client - even PDUs are sent from client to server
@ -67,10 +72,13 @@ static void att_packet_handler(uint8_t packet_type, uint16_t handle, uint8_t *pa
break; break;
case HCI_EVENT_PACKET: case HCI_EVENT_PACKET:
if (packet[0] != L2CAP_EVENT_CAN_SEND_NOW) break; if (packet[0] != L2CAP_EVENT_CAN_SEND_NOW) break;
for (index = 0; index < 2 ; index++){ for (i = 0; i < ATT_MAX; i++){
index = (att_round_robin + i) & 1;
if (subscriptions[index].packet_handler && subscriptions[index].waiting_for_can_send){ if (subscriptions[index].packet_handler && subscriptions[index].waiting_for_can_send){
subscriptions[index].waiting_for_can_send = 0; subscriptions[index].waiting_for_can_send = 0;
subscriptions[index].packet_handler(packet_type, handle, packet, size); subscriptions[index].packet_handler(packet_type, handle, packet, size);
// fairness
att_round_robin = 1 - index;
// stop if client cannot send anymore // stop if client cannot send anymore
if (!hci_can_send_acl_le_packet_now()) break; if (!hci_can_send_acl_le_packet_now()) break;
} }