mirror/btstack
1
0
Fork 0
mirror of https://github.com/bluekitchen/btstack.git synced 2025-04-16 08:42:28 +00:00
Code Issues Packages Projects Releases Wiki Activity

example/le_streamer_client: don't print test data but measure throughput instead

Browse Source
This commit is contained in:
Matthias Ringwald 2017-07-19 17:06:32 +02:00
parent 319b19cc14
commit 15304b2d11
1 changed files with 55 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
example/le_streamer_client.c
View File

@ -79,6 +79,53 @@ static int listener_registered;
static gc_state_t state = TC_IDLE; static gc_state_t state = TC_IDLE;
static btstack_packet_callback_registration_t hci_event_callback_registration; static btstack_packet_callback_registration_t hci_event_callback_registration;
/*
* @section Track throughput
* @text We calculate the throughput by setting a start time and measuring the amount of
* data sent. After a configurable REPORT_INTERVAL_MS, we print the throughput in kB/s
* and reset the counter and start time.
*/
/* LISTING_START(tracking): Tracking throughput */
#define REPORT_INTERVAL_MS 3000
// support for multiple clients
typedef struct {
char name;
int le_notification_enabled;
hci_con_handle_t connection_handle;
int counter;
char test_data[200];
int test_data_len;
uint32_t test_data_sent;
uint32_t test_data_start;
} le_streamer_connection_t;
static le_streamer_connection_t le_streamer_connection;
static void test_reset(le_streamer_connection_t * context){
context->test_data_start = btstack_run_loop_get_time_ms();
context->test_data_sent = 0;
}
static void test_track_data(le_streamer_connection_t * context, int bytes_sent){
context->test_data_sent += bytes_sent;
// evaluate
uint32_t now = btstack_run_loop_get_time_ms();
uint32_t time_passed = now - context->test_data_start;
if (time_passed < REPORT_INTERVAL_MS) return;
// print speed
int bytes_per_second = context->test_data_sent * 1000 / time_passed;
printf("%c: %u bytes -> %u.%03u kB/s\n", context->name, context->test_data_sent, bytes_per_second / 1000, bytes_per_second % 1000);
// restart
context->test_data_start = now;
context->test_data_sent = 0;
}
/* LISTING_END(tracking): Tracking throughput */
// returns 1 if name is found in advertisement // returns 1 if name is found in advertisement
static int advertisement_report_contains_name(const char * name, uint8_t * advertisement_report){ static int advertisement_report_contains_name(const char * name, uint8_t * advertisement_report){
// get advertisement from report event // get advertisement from report event
@ -155,6 +202,9 @@ static void handle_gatt_client_event(uint8_t packet_type, uint16_t channel, uint
state = TC_W4_TEST_DATA; state = TC_W4_TEST_DATA;
printf("Start streaming - enable notify on test characteristic.\n"); printf("Start streaming - enable notify on test characteristic.\n");
gatt_client_write_client_characteristic_configuration(handle_gatt_client_event, connection_handle, &le_streamer_characteristic, GATT_CLIENT_CHARACTERISTICS_CONFIGURATION_NOTIFICATION); gatt_client_write_client_characteristic_configuration(handle_gatt_client_event, connection_handle, &le_streamer_characteristic, GATT_CLIENT_CHARACTERISTICS_CONFIGURATION_NOTIFICATION);
// setup tracking
le_streamer_connection.name = 'A';
test_reset(&le_streamer_connection);
break; break;
default: default:
break; break;
@ -164,8 +214,13 @@ static void handle_gatt_client_event(uint8_t packet_type, uint16_t channel, uint
case TC_W4_TEST_DATA: case TC_W4_TEST_DATA:
switch(hci_event_packet_get_type(packet)){ switch(hci_event_packet_get_type(packet)){
case GATT_EVENT_NOTIFICATION: case GATT_EVENT_NOTIFICATION:
#if 0
printf("Data: "); printf("Data: ");
printf_hexdump( gatt_event_notification_get_value(packet), gatt_event_notification_get_value_length(packet)); printf_hexdump( gatt_event_notification_get_value(packet), gatt_event_notification_get_value_length(packet));
#else
test_track_data(&le_streamer_connection, gatt_event_notification_get_value_length(packet));
#endif
break;
case GATT_EVENT_QUERY_COMPLETE: case GATT_EVENT_QUERY_COMPLETE:
break; break;
default: default: