1 /* 2 * Copyright (C) 2016 BlueKitchen GmbH 3 * 4 * Redistribution and use in source and binary forms, with or without 5 * modification, are permitted provided that the following conditions 6 * are met: 7 * 8 * 1. Redistributions of source code must retain the above copyright 9 * notice, this list of conditions and the following disclaimer. 10 * 2. Redistributions in binary form must reproduce the above copyright 11 * notice, this list of conditions and the following disclaimer in the 12 * documentation and/or other materials provided with the distribution. 13 * 3. Neither the name of the copyright holders nor the names of 14 * contributors may be used to endorse or promote products derived 15 * from this software without specific prior written permission. 16 * 4. Any redistribution, use, or modification is done solely for 17 * personal benefit and not for any commercial purpose or for 18 * monetary gain. 19 * 20 * THIS SOFTWARE IS PROVIDED BY BLUEKITCHEN GMBH AND CONTRIBUTORS 21 * ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 22 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS 23 * FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL MATTHIAS 24 * RINGWALD OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, 25 * INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, 26 * BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS 27 * OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED 28 * AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 29 * OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF 30 * THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF 31 * SUCH DAMAGE. 32 * 33 * Please inquire about commercial licensing options at 34 * [email protected] 35 * 36 */ 37 38 #define __BTSTACK_FILE__ "avdtp_initiator.c" 39 40 41 #include <stdint.h> 42 #include <stdio.h> 43 #include <stdlib.h> 44 #include <string.h> 45 46 #include "btstack.h" 47 #include "avdtp.h" 48 #include "avdtp_util.h" 49 #include "avdtp_initiator.h" 50 51 52 static int avdtp_initiator_send_signaling_cmd(uint16_t cid, avdtp_signal_identifier_t identifier, uint8_t transaction_label){ 53 uint8_t command[2]; 54 command[0] = avdtp_header(transaction_label, AVDTP_SINGLE_PACKET, AVDTP_CMD_MSG); 55 command[1] = (uint8_t)identifier; 56 return l2cap_send(cid, command, sizeof(command)); 57 } 58 59 static int avdtp_initiator_send_signaling_cmd_with_seid(uint16_t cid, avdtp_signal_identifier_t identifier, uint8_t transaction_label, uint8_t sep_id){ 60 uint8_t command[3]; 61 command[0] = avdtp_header(transaction_label, AVDTP_SINGLE_PACKET, AVDTP_CMD_MSG); 62 command[1] = (uint8_t)identifier; 63 command[2] = sep_id << 2; 64 return l2cap_send(cid, command, sizeof(command)); 65 } 66 67 void avdtp_initiator_stream_config_subsm(avdtp_connection_t * connection, uint8_t *packet, uint16_t size, int offset, avdtp_context_t * context){ 68 // int status = 0; 69 avdtp_stream_endpoint_t * stream_endpoint = NULL; 70 71 uint8_t remote_sep_index; 72 avdtp_sep_t sep; 73 if (connection->initiator_connection_state == AVDTP_SIGNALING_CONNECTION_INITIATOR_W4_ANSWER) { 74 connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_IDLE; 75 } else { 76 stream_endpoint = avdtp_stream_endpoint_associated_with_acp_seid(connection->remote_seid, context); 77 if (!stream_endpoint){ 78 stream_endpoint = avdtp_stream_endpoint_with_seid(connection->local_seid, context); 79 } 80 if (!stream_endpoint) return; 81 sep.seid = connection->remote_seid; 82 83 if (stream_endpoint->initiator_config_state != AVDTP_INITIATOR_W4_ANSWER) return; 84 stream_endpoint->initiator_config_state = AVDTP_INITIATOR_STREAM_CONFIG_IDLE; 85 } 86 87 switch (connection->signaling_packet.message_type){ 88 case AVDTP_RESPONSE_ACCEPT_MSG: 89 switch (connection->signaling_packet.signal_identifier){ 90 case AVDTP_SI_DISCOVER:{ 91 if (connection->signaling_packet.transaction_label != connection->initiator_transaction_label){ 92 log_info(" unexpected transaction label, got %d, expected %d", connection->signaling_packet.transaction_label, connection->initiator_transaction_label); 93 // status = BAD_HEADER_FORMAT; 94 break; 95 } 96 97 if (size == 3){ 98 log_info(" ERROR code %02x", packet[offset]); 99 break; 100 } 101 102 int i; 103 for (i = offset; i < size; i += 2){ 104 sep.seid = packet[i] >> 2; 105 offset++; 106 if (sep.seid < 0x01 || sep.seid > 0x3E){ 107 log_info(" invalid sep id"); 108 // status = BAD_ACP_SEID; 109 break; 110 } 111 sep.in_use = (packet[i] >> 1) & 0x01; 112 sep.media_type = (avdtp_media_type_t)(packet[i+1] >> 4); 113 sep.type = (avdtp_sep_type_t)((packet[i+1] >> 3) & 0x01); 114 115 if (avdtp_find_remote_sep(connection, sep.seid) == 0xFF){ 116 connection->remote_seps[connection->remote_seps_num++] = sep; 117 } 118 avdtp_signaling_emit_sep(context->avdtp_callback, connection->avdtp_cid, sep); 119 } 120 break; 121 } 122 123 case AVDTP_SI_GET_CAPABILITIES: 124 case AVDTP_SI_GET_ALL_CAPABILITIES: 125 sep.registered_service_categories = avdtp_unpack_service_capabilities(connection, &sep.capabilities, packet+offset, size-offset); 126 if (get_bit16(sep.registered_service_categories, AVDTP_MEDIA_CODEC)){ 127 switch (sep.capabilities.media_codec.media_codec_type){ 128 case AVDTP_CODEC_SBC: 129 avdtp_signaling_emit_media_codec_sbc_capability(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->remote_seid, sep.capabilities.media_codec); 130 break; 131 default: 132 avdtp_signaling_emit_media_codec_other_capability(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->remote_seid, sep.capabilities.media_codec); 133 break; 134 } 135 } 136 break; 137 138 case AVDTP_SI_GET_CONFIGURATION: 139 sep.configured_service_categories = avdtp_unpack_service_capabilities(connection, &sep.configuration, packet+offset, size-offset); 140 if (get_bit16(sep.configured_service_categories, AVDTP_MEDIA_CODEC)){ 141 switch (sep.configuration.media_codec.media_codec_type){ 142 case AVDTP_CODEC_SBC: 143 avdtp_signaling_emit_media_codec_sbc_configuration(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->remote_seid, sep.configuration.media_codec); 144 break; 145 default: 146 avdtp_signaling_emit_media_codec_other_configuration(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->remote_seid, sep.configuration.media_codec); 147 break; 148 } 149 } 150 break; 151 152 case AVDTP_SI_RECONFIGURE: 153 sep.configured_service_categories = avdtp_unpack_service_capabilities(connection, &sep.configuration, connection->signaling_packet.command+4, connection->signaling_packet.size-4); 154 // TODO check if configuration is supported 155 156 remote_sep_index = avdtp_find_remote_sep(connection, sep.seid); 157 if (remote_sep_index != 0xFF){ 158 stream_endpoint->remote_sep_index = remote_sep_index; 159 connection->remote_seps[stream_endpoint->remote_sep_index] = sep; 160 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_CONFIGURED; 161 log_info("INT: update seid %d, to %p", connection->remote_seps[stream_endpoint->remote_sep_index].seid, stream_endpoint); 162 } 163 break; 164 165 case AVDTP_SI_SET_CONFIGURATION:{ 166 sep.configured_service_categories = stream_endpoint->remote_capabilities_bitmap; 167 sep.configuration = stream_endpoint->remote_capabilities; 168 sep.in_use = 1; 169 // TODO check if configuration is supported 170 171 // find or add sep 172 remote_sep_index = avdtp_find_remote_sep(connection, sep.seid); 173 if (remote_sep_index != 0xFF){ 174 stream_endpoint->remote_sep_index = remote_sep_index; 175 } else { 176 stream_endpoint->remote_sep_index = connection->remote_seps_num; 177 connection->remote_seps_num++; 178 } 179 connection->remote_seps[stream_endpoint->remote_sep_index] = sep; 180 log_info("INT: configured remote seid %d, to %p", connection->remote_seps[stream_endpoint->remote_sep_index].seid, stream_endpoint); 181 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_CONFIGURED; 182 break; 183 } 184 185 case AVDTP_SI_OPEN: 186 if (stream_endpoint->state != AVDTP_STREAM_ENDPOINT_W2_REQUEST_OPEN_STREAM) { 187 log_error("AVDTP_SI_OPEN in wrong stream endpoint state"); 188 return; 189 } 190 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_W4_L2CAP_FOR_MEDIA_CONNECTED; 191 connection->local_seid = stream_endpoint->sep.seid; 192 l2cap_create_channel(context->packet_handler, connection->remote_addr, BLUETOOTH_PROTOCOL_AVDTP, 0xffff, NULL); 193 return; 194 case AVDTP_SI_START: 195 if (stream_endpoint->state != AVDTP_STREAM_ENDPOINT_OPENED) { 196 log_error("AVDTP_SI_START in wrong stream endpoint state"); 197 return; 198 } 199 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_STREAMING; 200 break; 201 case AVDTP_SI_SUSPEND: 202 if (stream_endpoint->state != AVDTP_STREAM_ENDPOINT_STREAMING) { 203 log_error("AVDTP_SI_SUSPEND in wrong stream endpoint state"); 204 return; 205 } 206 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_OPENED; 207 break; 208 case AVDTP_SI_CLOSE: 209 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_CLOSING; 210 break; 211 case AVDTP_SI_ABORT: 212 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_ABORTING; 213 break; 214 default: 215 log_info(" AVDTP_RESPONSE_ACCEPT_MSG, signal %d not implemented", connection->signaling_packet.signal_identifier); 216 break; 217 } 218 avdtp_signaling_emit_accept(context->avdtp_callback, connection->avdtp_cid, 0, connection->signaling_packet.signal_identifier); 219 connection->initiator_transaction_label++; 220 break; 221 case AVDTP_RESPONSE_REJECT_MSG: 222 log_info(" AVDTP_RESPONSE_REJECT_MSG signal %d", connection->signaling_packet.signal_identifier); 223 avdtp_signaling_emit_reject(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->signaling_packet.signal_identifier); 224 return; 225 case AVDTP_GENERAL_REJECT_MSG: 226 log_info(" AVDTP_GENERAL_REJECT_MSG signal %d", connection->signaling_packet.signal_identifier); 227 avdtp_signaling_emit_general_reject(context->avdtp_callback, connection->avdtp_cid, connection->local_seid, connection->signaling_packet.signal_identifier); 228 return; 229 default: 230 break; 231 } 232 } 233 234 void avdtp_initiator_stream_config_subsm_run(avdtp_connection_t * connection, avdtp_context_t * context){ 235 int sent = 1; 236 switch (connection->initiator_connection_state){ 237 case AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_DISCOVER_SEPS: 238 log_info("INT: AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_DISCOVER_SEPS"); 239 connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W4_ANSWER; 240 avdtp_initiator_send_signaling_cmd(connection->l2cap_signaling_cid, AVDTP_SI_DISCOVER, connection->initiator_transaction_label); 241 break; 242 case AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_GET_CAPABILITIES: 243 log_info("INT: AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_GET_CAPABILITIES"); 244 connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W4_ANSWER; 245 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_GET_CAPABILITIES, connection->initiator_transaction_label, connection->remote_seid); 246 break; 247 case AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_GET_ALL_CAPABILITIES: 248 log_info("INT: AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_GET_ALL_CAPABILITIES"); 249 connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W4_ANSWER; 250 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_GET_ALL_CAPABILITIES, connection->initiator_transaction_label, connection->remote_seid); 251 break; 252 case AVDTP_SIGNALING_CONNECTION_INITIATOR_W2_GET_CONFIGURATION: 253 log_info("INT: AVDTP_INITIATOR_W4_GET_CONFIGURATION"); 254 connection->initiator_connection_state = AVDTP_SIGNALING_CONNECTION_INITIATOR_W4_ANSWER; 255 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_GET_CONFIGURATION, connection->initiator_transaction_label, connection->remote_seid); 256 break; 257 default: 258 sent = 0; 259 break; 260 } 261 262 if (sent) return; 263 sent = 1; 264 265 avdtp_stream_endpoint_t * stream_endpoint = NULL; 266 267 stream_endpoint = avdtp_stream_endpoint_associated_with_acp_seid(connection->remote_seid, context); 268 if (!stream_endpoint){ 269 stream_endpoint = avdtp_stream_endpoint_with_seid(connection->local_seid, context); 270 } 271 if (!stream_endpoint) return; 272 273 avdtp_initiator_stream_endpoint_state_t stream_endpoint_state = stream_endpoint->initiator_config_state; 274 stream_endpoint->initiator_config_state = AVDTP_INITIATOR_W4_ANSWER; 275 276 if (stream_endpoint->start_stream){ 277 stream_endpoint->start_stream = 0; 278 if (stream_endpoint->state == AVDTP_STREAM_ENDPOINT_OPENED){ 279 connection->local_seid = stream_endpoint->sep.seid; 280 connection->remote_seid = connection->remote_seps[stream_endpoint->remote_sep_index].seid; 281 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_START, connection->initiator_transaction_label++, connection->remote_seid); 282 return; 283 } 284 return; 285 } 286 287 if (stream_endpoint->stop_stream){ 288 stream_endpoint->stop_stream = 0; 289 if (stream_endpoint->state >= AVDTP_STREAM_ENDPOINT_OPENED){ 290 connection->local_seid = stream_endpoint->sep.seid; 291 connection->remote_seid = connection->remote_seps[stream_endpoint->remote_sep_index].seid; 292 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_CLOSE, connection->initiator_transaction_label++, connection->remote_seid); 293 return; 294 } 295 } 296 297 if (stream_endpoint->abort_stream){ 298 stream_endpoint->abort_stream = 0; 299 switch (stream_endpoint->state){ 300 case AVDTP_STREAM_ENDPOINT_CONFIGURED: 301 case AVDTP_STREAM_ENDPOINT_CLOSING: 302 case AVDTP_STREAM_ENDPOINT_OPENED: 303 case AVDTP_STREAM_ENDPOINT_STREAMING: 304 connection->local_seid = stream_endpoint->sep.seid; 305 connection->remote_seid = connection->remote_seps[stream_endpoint->remote_sep_index].seid; 306 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_ABORTING; 307 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_ABORT, connection->initiator_transaction_label++, connection->remote_seid); 308 return; 309 default: 310 break; 311 } 312 } 313 314 if (stream_endpoint->suspend_stream){ 315 stream_endpoint->suspend_stream = 0; 316 if (stream_endpoint->state == AVDTP_STREAM_ENDPOINT_STREAMING){ 317 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_STREAMING; 318 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_SUSPEND, connection->initiator_transaction_label, connection->remote_seid); 319 return; 320 } 321 } 322 323 if (stream_endpoint->send_stream){ 324 stream_endpoint->send_stream = 0; 325 if (stream_endpoint->state == AVDTP_STREAM_ENDPOINT_STREAMING){ 326 stream_endpoint->state = AVDTP_STREAM_ENDPOINT_STREAMING; 327 avdtp_streaming_emit_can_send_media_packet_now(context->avdtp_callback, stream_endpoint->l2cap_media_cid, stream_endpoint->sep.seid, stream_endpoint->sequence_number); 328 return; 329 } 330 } 331 332 333 switch (stream_endpoint_state){ 334 case AVDTP_INITIATOR_W2_SET_CONFIGURATION: 335 case AVDTP_INITIATOR_W2_RECONFIGURE_STREAM_WITH_SEID:{ 336 log_info("INT: AVDTP_INITIATOR_W2_(RE)CONFIGURATION bitmap, int seid %d, acp seid %d", connection->local_seid, connection->remote_seid); 337 // log_info_hexdump( connection->remote_capabilities.media_codec.media_codec_information, connection->remote_capabilities.media_codec.media_codec_information_len); 338 connection->signaling_packet.acp_seid = connection->remote_seid; 339 connection->signaling_packet.int_seid = connection->local_seid; 340 341 connection->signaling_packet.signal_identifier = AVDTP_SI_SET_CONFIGURATION; 342 343 if (stream_endpoint_state == AVDTP_INITIATOR_W2_RECONFIGURE_STREAM_WITH_SEID){ 344 connection->signaling_packet.signal_identifier = AVDTP_SI_RECONFIGURE; 345 } 346 347 avdtp_prepare_capabilities(&connection->signaling_packet, connection->initiator_transaction_label, stream_endpoint->remote_configuration_bitmap, stream_endpoint->remote_configuration, connection->signaling_packet.signal_identifier); 348 l2cap_reserve_packet_buffer(); 349 uint8_t * out_buffer = l2cap_get_outgoing_buffer(); 350 uint16_t pos = avdtp_signaling_create_fragment(connection->l2cap_signaling_cid, &connection->signaling_packet, out_buffer); 351 if (connection->signaling_packet.packet_type != AVDTP_SINGLE_PACKET && connection->signaling_packet.packet_type != AVDTP_END_PACKET){ 352 stream_endpoint->initiator_config_state = AVDTP_INITIATOR_FRAGMENTATED_COMMAND; 353 log_info("INT: fragmented"); 354 } 355 l2cap_send_prepared(connection->l2cap_signaling_cid, pos); 356 break; 357 } 358 case AVDTP_INITIATOR_FRAGMENTATED_COMMAND:{ 359 l2cap_reserve_packet_buffer(); 360 uint8_t * out_buffer = l2cap_get_outgoing_buffer(); 361 uint16_t pos = avdtp_signaling_create_fragment(connection->l2cap_signaling_cid, &connection->signaling_packet, out_buffer); 362 if (connection->signaling_packet.packet_type != AVDTP_SINGLE_PACKET && connection->signaling_packet.packet_type != AVDTP_END_PACKET){ 363 stream_endpoint->initiator_config_state = AVDTP_INITIATOR_FRAGMENTATED_COMMAND; 364 log_info("INT: fragmented"); 365 } 366 l2cap_send_prepared(connection->l2cap_signaling_cid, pos); 367 break; 368 } 369 case AVDTP_INITIATOR_W2_OPEN_STREAM: 370 switch (stream_endpoint->state){ 371 case AVDTP_STREAM_ENDPOINT_W2_REQUEST_OPEN_STREAM: 372 log_info("INT: AVDTP_STREAM_ENDPOINT_W2_REQUEST_OPEN_STREAM"); 373 avdtp_initiator_send_signaling_cmd_with_seid(connection->l2cap_signaling_cid, AVDTP_SI_OPEN, connection->initiator_transaction_label, connection->remote_seid); 374 break; 375 default: 376 sent = 0; 377 break; 378 } 379 break; 380 default: 381 sent = 0; 382 break; 383 } 384 385 // check fragmentation 386 if (connection->signaling_packet.packet_type != AVDTP_SINGLE_PACKET && connection->signaling_packet.packet_type != AVDTP_END_PACKET){ 387 avdtp_request_can_send_now_initiator(connection, connection->l2cap_signaling_cid); 388 } 389 } 390