mirror/btstack
1
0
Fork 0
mirror of https://github.com/bluekitchen/btstack.git synced 2025-03-14 01:27:41 +00:00
Code Issues Packages Projects Releases Wiki Activity

example/spp_streamer_client: add option to stream as fast as possible

Browse Source
This commit is contained in:
Matthias Ringwald 2019-02-07 13:45:49 +01:00
parent 1fb071232a
commit 83c123990b
1 changed files with 98 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

145
example/spp_streamer_client.c
View File

@ -59,8 +59,18 @@
#define RFCOMM_SERVER_CHANNEL 1
#define NUM_ROWS 25
#define NUM_COLS 40
#define TEST_COD 0x1234
#define TEST_MODE_SEND 1
#define TEST_MODE_RECEIVE 2
#define TEST_MODE_DUPLEX 3
// configure test mode: send only, receive only, full duplex
#define TEST_MODE TEST_MODE_SEND
typedef enum {
// SPP
W4_PEER_COD,
@ -72,6 +82,9 @@ typedef enum {
DONE
} state_t;
static uint8_t test_data[NUM_ROWS * NUM_COLS];
static uint16_t spp_test_data_len;
static btstack_packet_callback_registration_t hci_event_callback_registration;
static bd_addr_t peer_addr;
@ -160,6 +173,24 @@ static void test_track_transferred(int bytes_sent){
}
/* LISTING_END(tracking): Tracking throughput */
#if (TEST_MODE & TEST_MODE_SEND)
static void spp_create_test_data(void){
int x,y;
for (y=0;y<NUM_ROWS;y++){
for (x=0;x<NUM_COLS-2;x++){
test_data[y*NUM_COLS+x] = '0' + (x % 10);
}
test_data[y*NUM_COLS+NUM_COLS-2] = '\n';
test_data[y*NUM_COLS+NUM_COLS-1] = '\r';
}
}
static void spp_send_packet(void){
rfcomm_send(rfcomm_cid, (uint8_t*) test_data, spp_test_data_len);
test_track_transferred(spp_test_data_len);
rfcomm_request_can_send_now_event(rfcomm_cid);
}
#endif
/*
* @section Packet Handler
*
@ -177,53 +208,6 @@ static void packet_handler (uint8_t packet_type, uint16_t channel, uint8_t *pack
case HCI_EVENT_PACKET:
switch (hci_event_packet_get_type(packet)) {
case HCI_EVENT_PIN_CODE_REQUEST:
// inform about pin code request
printf("Pin code request - using '0000'\n");
hci_event_pin_code_request_get_bd_addr(packet, event_addr);
gap_pin_code_response(event_addr, "0000");
break;
case HCI_EVENT_USER_CONFIRMATION_REQUEST:
// inform about user confirmation request
printf("SSP User Confirmation Request with numeric value '%06"PRIu32"'\n", little_endian_read_32(packet, 8));
printf("SSP User Confirmation Auto accept\n");
break;
case RFCOMM_EVENT_INCOMING_CONNECTION:
// data: event (8), len(8), address(48), channel (8), rfcomm_cid (16)
rfcomm_event_incoming_connection_get_bd_addr(packet, event_addr);
rfcomm_channel_nr = rfcomm_event_incoming_connection_get_server_channel(packet);
rfcomm_cid = rfcomm_event_incoming_connection_get_rfcomm_cid(packet);
printf("RFCOMM channel %u requested for %s\n", rfcomm_channel_nr, bd_addr_to_str(event_addr));
rfcomm_accept_connection(rfcomm_cid);
break;
case RFCOMM_EVENT_CHANNEL_OPENED:
// data: event(8), len(8), status (8), address (48), server channel(8), rfcomm_cid(16), max frame size(16)
if (rfcomm_event_channel_opened_get_status(packet)) {
printf("RFCOMM channel open failed, status %u\n", rfcomm_event_channel_opened_get_status(packet));
} else {
rfcomm_cid = rfcomm_event_channel_opened_get_rfcomm_cid(packet);
rfcomm_mtu = rfcomm_event_channel_opened_get_max_frame_size(packet);
printf("RFCOMM channel open succeeded. New RFCOMM Channel ID %u, max frame size %u\n", rfcomm_cid, rfcomm_mtu);
test_reset();
// disable page/inquiry scan to get max performance
gap_discoverable_control(0);
gap_connectable_control(0);
}
break;
case RFCOMM_EVENT_CHANNEL_CLOSED:
printf("RFCOMM channel closed\n");
rfcomm_cid = 0;
// re-enable page/inquiry scan again
gap_discoverable_control(1);
gap_connectable_control(1);
break;
case BTSTACK_EVENT_STATE:
if (btstack_event_state_get_state(packet) != HCI_STATE_WORKING) return;
start_scan();
@ -261,6 +245,73 @@ static void packet_handler (uint8_t packet_type, uint16_t channel, uint8_t *pack
}
break;
case HCI_EVENT_PIN_CODE_REQUEST:
// inform about pin code request
printf("Pin code request - using '0000'\n");
hci_event_pin_code_request_get_bd_addr(packet, event_addr);
gap_pin_code_response(event_addr, "0000");
break;
case HCI_EVENT_USER_CONFIRMATION_REQUEST:
// inform about user confirmation request
printf("SSP User Confirmation Request with numeric value '%06"PRIu32"'\n", little_endian_read_32(packet, 8));
printf("SSP User Confirmation Auto accept\n");
break;
case RFCOMM_EVENT_INCOMING_CONNECTION:
// data: event (8), len(8), address(48), channel (8), rfcomm_cid (16)
rfcomm_event_incoming_connection_get_bd_addr(packet, event_addr);
rfcomm_channel_nr = rfcomm_event_incoming_connection_get_server_channel(packet);
rfcomm_cid = rfcomm_event_incoming_connection_get_rfcomm_cid(packet);
printf("RFCOMM channel %u requested for %s\n", rfcomm_channel_nr, bd_addr_to_str(event_addr));
rfcomm_accept_connection(rfcomm_cid);
break;
case RFCOMM_EVENT_CHANNEL_OPENED:
// data: event(8), len(8), status (8), address (48), server channel(8), rfcomm_cid(16), max frame size(16)
if (rfcomm_event_channel_opened_get_status(packet)) {
printf("RFCOMM channel open failed, status %u\n", rfcomm_event_channel_opened_get_status(packet));
} else {
rfcomm_cid = rfcomm_event_channel_opened_get_rfcomm_cid(packet);
rfcomm_mtu = rfcomm_event_channel_opened_get_max_frame_size(packet);
printf("RFCOMM channel open succeeded. New RFCOMM Channel ID %u, max frame size %u\n", rfcomm_cid, rfcomm_mtu);
test_reset();
// disable page/inquiry scan to get max performance
gap_discoverable_control(0);
gap_connectable_control(0);
#if (TEST_MODE & TEST_MODE_SEND)
// configure test data
spp_test_data_len = rfcomm_mtu;
if (spp_test_data_len > sizeof(test_data)){
spp_test_data_len = sizeof(test_data);
}
spp_create_test_data();
// start sending
rfcomm_request_can_send_now_event(rfcomm_cid);
#endif
}
break;
#if (TEST_MODE & TEST_MODE_SEND)
case RFCOMM_EVENT_CAN_SEND_NOW:
spp_send_packet();
break;
#endif
case RFCOMM_EVENT_CHANNEL_CLOSED:
printf("RFCOMM channel closed\n");
rfcomm_cid = 0;
// re-enable page/inquiry scan again
gap_discoverable_control(1);
gap_connectable_control(1);
break;
default:
break;
}