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

sink initiator: discover

Browse Source
This commit is contained in:
Milanka Ringwald 2017-01-03 15:50:35 +01:00
parent aa0799ab6c
commit 82059260d2
4 changed files with 71 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
test/avdtp/avdtp.h
View File

@ -391,7 +391,7 @@ typedef struct {
uint8_t initiator_transaction_label;
uint8_t acceptor_transaction_label;
uint8_t query_seid;
uint8_t wait_to_send_acceptor;
uint8_t wait_to_send_initiator;
uint8_t wait_to_send_self;

52
test/avdtp/avdtp_sink.c
View File

@ -142,6 +142,22 @@ void a2dp_sink_create_sdp_record(uint8_t * service, uint32_t service_record_han
de_add_number(service, DE_UINT, DE_SIZE_16, supported_features);
}
static void avdtp_emit_signaling_connection_established(btstack_packet_handler_t callback, uint8_t status, uint16_t con_handle, bd_addr_t addr){
if (!callback) return;
uint8_t event[12];
int pos = 0;
event[pos++] = HCI_EVENT_AVDTP_META;
event[pos++] = sizeof(event) - 2;
event[pos++] = AVDTP_SUBEVENT_SIGNALING_CONNECTION_ESTABLISHED;
event[pos++] = status;
little_endian_store_16(event, pos, con_handle);
pos += 2;
reverse_bd_addr(addr,&event[pos]);
pos += 6;
(*callback)(HCI_EVENT_PACKET, 0, event, sizeof(event));
}
static avdtp_stream_endpoint_t * get_avdtp_stream_endpoint_for_seid(uint16_t seid){
btstack_linked_list_iterator_t it;
btstack_linked_list_iterator_init(&it, (btstack_linked_list_t *) &stream_endpoints);
@ -417,6 +433,7 @@ static void avdtp_sink_handle_can_send_now(avdtp_connection_t * connection, uint
} else if (connection->wait_to_send_self){
connection->wait_to_send_self = 0;
// if (connection->confirm_suspend){
// printf(" -> STREAMS SUSPENDED\n");
// connection->confirm_suspend = 0;
@ -464,6 +481,8 @@ static void avdtp_sink_handle_can_send_now(avdtp_connection_t * connection, uint
}
}
/* END: tracking can send now requests pro l2cap cid */
static int handle_l2cap_data_packet_for_stream_endpoint(avdtp_connection_t * connection, avdtp_stream_endpoint_t * stream_endpoint, uint8_t *packet, uint16_t size){
avdtp_read_signaling_header(&connection->signaling_packet, packet, size);
@ -615,7 +634,7 @@ static int handle_l2cap_data_packet_for_signaling_connection(avdtp_connection_t
}
break;
case AVDTP_RESPONSE_ACCEPT_MSG:
printf("handle_l2cap_data_packet_for_signaling_connection AVDTP_RESPONSE_ACCEPT_MSG\n");
printf("handle_l2cap_data_packet_for_signaling_connection AVDTP_RESPONSE_ACCEPT_MSG, identifier %d\n", connection->signaling_packet.signal_identifier);
switch (connection->signaling_packet.signal_identifier){
case AVDTP_SI_DISCOVER:
@ -623,12 +642,12 @@ static int handle_l2cap_data_packet_for_signaling_connection(avdtp_connection_t
printf("unexpected transaction label, got %d, expected %d\n", connection->signaling_packet.transaction_label, connection->initiator_transaction_label);
return 0;
}
if (size == 3){
printf("ERROR code %02x\n", packet[2]);
return 0;
}
avdtp_sep_t sep;
int i;
for (i=2; i<size; i+=2){
@ -640,14 +659,11 @@ static int handle_l2cap_data_packet_for_signaling_connection(avdtp_connection_t
sep.in_use = (packet[i] >> 1) & 0x01;
sep.media_type = (avdtp_media_type_t)(packet[i+1] >> 4);
sep.type = (avdtp_sep_type_t)((packet[i+1] >> 3) & 0x01);
stream_endpoint->remote_seps[stream_endpoint->remote_seps_num++] = sep;
// printf("found sep: seid %u, in_use %d, media type %d, sep type %d (1-SNK)\n",
// sep.seid, sep.in_use, sep.media_type, sep.type);
printf("found sep: seid %u, in_use %d, media type %d, sep type %d (1-SNK)\n",
sep.seid, sep.in_use, sep.media_type, sep.type);
}
connection->initiator_transaction_label++;
printf(" -> AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_DISCOVER_SEPS\n");
connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_DISCOVER_SEPS;
avdtp_sink_request_can_send_now_self(connection, connection->l2cap_signaling_cid);
connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_IDLE;
break;
default:
printf("AVDTP_RESPONSE_ACCEPT_MSG signal %d not implemented\n", connection->signaling_packet.signal_identifier);
@ -819,6 +835,7 @@ static void packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packe
connection->query_seid = 0;
connection->state = AVDTP_SIGNALING_CONNECTION_OPENED;
printf(" -> AVDTP_SIGNALING_CONNECTION_OPENED, connection %p\n", connection);
avdtp_emit_signaling_connection_established(avdtp_sink_callback, 0, con_handle, event_addr);
break;
}
@ -932,4 +949,21 @@ void avdtp_sink_disconnect(uint16_t con_handle){
//avdtp_sink_run(connection);
}
void avdtp_sink_stream_endpoint_discovery(uint16_t con_handle){
avdtp_connection_t * connection = get_avdtp_connection_for_con_handle(con_handle);
if (!connection){
printf("avdtp_sink_stream_endpoint_discovery: no connection for handle 0x%02x found\n", con_handle);
return;
}
if (connection->state != AVDTP_SIGNALING_CONNECTION_OPENED) return;
switch (connection->initiator_connection_state){
case AVDTP_SIGNALING_CONNECTION_INITIATOR_IDLE:
connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_DISCOVER_SEPS;
avdtp_sink_request_can_send_now_self(connection, connection->l2cap_signaling_cid);
break;
default:
printf("avdtp_sink_stream_endpoint_discovery: wrong state\n");
break;
}
}

7
test/avdtp/avdtp_sink.h
View File

@ -102,6 +102,13 @@ void avdtp_sink_register_media_handler(void (*callback)(avdtp_stream_endpoint_t
*/
void avdtp_sink_disconnect(uint16_t con_handle);
/**
* @brief Discover stream endpoints
* @param con_handle
*/
void avdtp_sink_stream_endpoint_discovery(uint16_t con_handle);
/* API_END */
#if defined __cplusplus

30
test/avdtp/avdtp_test.c
View File

@ -144,7 +144,7 @@ static char * sbc_filename = "avdtp_sink.sbc";
// mac: static bd_addr_t remote = {0x04, 0x0C, 0xCE, 0xE4, 0x85, 0xD3};
// pts: static bd_addr_t remote = {0x00, 0x1B, 0xDC, 0x08, 0x0A, 0xA5};
static bd_addr_t remote = {0x00, 0x1B, 0xDC, 0x08, 0x0A, 0xA5};
static uint16_t con_handle = 0;
static uint8_t sdp_avdtp_sink_service_buffer[150];
static btstack_packet_callback_registration_t hci_event_callback_registration;
@ -289,7 +289,6 @@ static void handle_l2cap_media_data_packet(avdtp_stream_endpoint_t * stream_endp
static void packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packet, uint16_t size){
bd_addr_t event_addr;
switch (packet_type) {
case L2CAP_DATA_PACKET:
// just dump data for now
@ -299,7 +298,6 @@ static void packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packe
case HCI_EVENT_PACKET:
switch (hci_event_packet_get_type(packet)) {
case BTSTACK_EVENT_STATE:
// bt stack activated, get started
if (btstack_event_state_get_state(packet) == HCI_STATE_WORKING){
@ -312,20 +310,27 @@ static void packet_handler(uint8_t packet_type, uint16_t channel, uint8_t *packe
hci_event_pin_code_request_get_bd_addr(packet, event_addr);
hci_send_cmd(&hci_pin_code_request_reply, &event_addr, 4, "0000");
break;
case HCI_EVENT_DISCONNECTION_COMPLETE:
// connection closed -> quit test app
printf("\n --- avdtp_test: HCI_EVENT_DISCONNECTION_COMPLETE ---\n");
close_media_processing();
// exit(0);
break;
case HCI_EVENT_AVDTP_META:
switch (packet[2]){
case AVDTP_SUBEVENT_SIGNALING_CONNECTION_ESTABLISHED:
con_handle = avdtp_subevent_signaling_connection_established_get_con_handle(packet);
printf("\n --- avdtp_test: AVDTP_SUBEVENT_SIGNALING_CONNECTION_ESTABLISHED, con handle 0x%02x ---\n", con_handle);
break;
default:
printf(" not implemented\n");
break;
}
break;
default:
// other event
break;
}
break;
default:
// other packet type
break;
@ -337,7 +342,9 @@ static void show_usage(void){
gap_local_bd_addr(iut_address);
printf("\n--- Bluetooth AVDTP SINK Test Console %s ---\n", bd_addr_to_str(iut_address));
printf("c - create connection to addr %s\n", bd_addr_to_str(remote));
printf("d - disconnect\n");
printf("C - disconnect\n");
printf("d - discover stream endpoints\n");
printf("Ctrl-c - exit\n");
printf("---\n");
}
@ -350,10 +357,13 @@ static void stdin_process(btstack_data_source_t *ds, btstack_data_source_callbac
printf("Creating L2CAP Connection to %s, PSM_AVDTP\n", bd_addr_to_str(remote));
avdtp_sink_connect(remote);
break;
case 'd':
printf("L2CAP Channel Closed\n");
case 'C':
printf("Disconnect not implemented\n");
// avdtp_sink_disconnect(local_cid);
break;
case 'd':
avdtp_sink_stream_endpoint_discovery(con_handle);
break;
case '\n':
case '\r':
break;