A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
saslclientio.c@5:ae49385aff34, 2016-07-01 (annotated)
- Committer:
- Azure.IoT Build
- Date:
- Fri Jul 01 10:42:48 2016 -0700
- Revision:
- 5:ae49385aff34
- Parent:
- 1:eab586236bfe
- Child:
- 6:641a9672db08
1.0.10
Who changed what in which revision?
User | Revision | Line number | New contents of line |
---|---|---|---|
Azure.IoT Build | 0:6ae2f7bca550 | 1 | // Copyright (c) Microsoft. All rights reserved. |
Azure.IoT Build | 0:6ae2f7bca550 | 2 | // Licensed under the MIT license. See LICENSE file in the project root for full license information. |
Azure.IoT Build | 0:6ae2f7bca550 | 3 | |
Azure.IoT Build | 0:6ae2f7bca550 | 4 | #include <stdlib.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 5 | #ifdef _CRTDBG_MAP_ALLOC |
Azure.IoT Build | 0:6ae2f7bca550 | 6 | #include <crtdbg.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 7 | #endif |
Azure.IoT Build | 0:6ae2f7bca550 | 8 | #include <stddef.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 9 | #include <stdio.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 10 | #include <string.h> |
Azure.IoT Build | 0:6ae2f7bca550 | 11 | #include "azure_uamqp_c/saslclientio.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 12 | #include "azure_c_shared_utility/xio.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 13 | #include "azure_c_shared_utility/xlogging.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 14 | #include "azure_uamqp_c/amqpalloc.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 15 | #include "azure_uamqp_c/frame_codec.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 16 | #include "azure_uamqp_c/sasl_frame_codec.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 17 | #include "azure_uamqp_c/amqp_definitions.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 18 | #include "azure_uamqp_c/amqpvalue_to_string.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 19 | |
Azure.IoT Build | 0:6ae2f7bca550 | 20 | typedef enum IO_STATE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 21 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 22 | IO_STATE_NOT_OPEN, |
Azure.IoT Build | 0:6ae2f7bca550 | 23 | IO_STATE_OPENING_UNDERLYING_IO, |
Azure.IoT Build | 0:6ae2f7bca550 | 24 | IO_STATE_SASL_HANDSHAKE, |
Azure.IoT Build | 0:6ae2f7bca550 | 25 | IO_STATE_OPEN, |
Azure.IoT Build | 0:6ae2f7bca550 | 26 | IO_STATE_CLOSING, |
Azure.IoT Build | 0:6ae2f7bca550 | 27 | IO_STATE_ERROR |
Azure.IoT Build | 0:6ae2f7bca550 | 28 | } IO_STATE; |
Azure.IoT Build | 0:6ae2f7bca550 | 29 | |
Azure.IoT Build | 0:6ae2f7bca550 | 30 | typedef enum SASL_HEADER_EXCHANGE_STATE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 31 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 32 | SASL_HEADER_EXCHANGE_IDLE, |
Azure.IoT Build | 0:6ae2f7bca550 | 33 | SASL_HEADER_EXCHANGE_HEADER_SENT, |
Azure.IoT Build | 0:6ae2f7bca550 | 34 | SASL_HEADER_EXCHANGE_HEADER_RCVD, |
Azure.IoT Build | 0:6ae2f7bca550 | 35 | SASL_HEADER_EXCHANGE_HEADER_EXCH |
Azure.IoT Build | 0:6ae2f7bca550 | 36 | } SASL_HEADER_EXCHANGE_STATE; |
Azure.IoT Build | 0:6ae2f7bca550 | 37 | |
Azure.IoT Build | 0:6ae2f7bca550 | 38 | typedef enum SASL_CLIENT_NEGOTIATION_STATE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 39 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 40 | SASL_CLIENT_NEGOTIATION_NOT_STARTED, |
Azure.IoT Build | 0:6ae2f7bca550 | 41 | SASL_CLIENT_NEGOTIATION_MECH_RCVD, |
Azure.IoT Build | 0:6ae2f7bca550 | 42 | SASL_CLIENT_NEGOTIATION_INIT_SENT, |
Azure.IoT Build | 0:6ae2f7bca550 | 43 | SASL_CLIENT_NEGOTIATION_CHALLENGE_RCVD, |
Azure.IoT Build | 0:6ae2f7bca550 | 44 | SASL_CLIENT_NEGOTIATION_RESPONSE_SENT, |
Azure.IoT Build | 0:6ae2f7bca550 | 45 | SASL_CLIENT_NEGOTIATION_OUTCOME_RCVD, |
Azure.IoT Build | 0:6ae2f7bca550 | 46 | SASL_CLIENT_NEGOTIATION_ERROR |
Azure.IoT Build | 0:6ae2f7bca550 | 47 | } SASL_CLIENT_NEGOTIATION_STATE; |
Azure.IoT Build | 0:6ae2f7bca550 | 48 | |
Azure.IoT Build | 0:6ae2f7bca550 | 49 | typedef struct SASL_CLIENT_IO_INSTANCE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 50 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 51 | XIO_HANDLE underlying_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 52 | ON_BYTES_RECEIVED on_bytes_received; |
Azure.IoT Build | 0:6ae2f7bca550 | 53 | ON_IO_OPEN_COMPLETE on_io_open_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 54 | ON_IO_CLOSE_COMPLETE on_io_close_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 55 | ON_IO_ERROR on_io_error; |
Azure.IoT Build | 0:6ae2f7bca550 | 56 | void* on_bytes_received_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 57 | void* on_io_open_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 58 | void* on_io_close_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 59 | void* on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 60 | SASL_HEADER_EXCHANGE_STATE sasl_header_exchange_state; |
Azure.IoT Build | 0:6ae2f7bca550 | 61 | SASL_CLIENT_NEGOTIATION_STATE sasl_client_negotiation_state; |
Azure.IoT Build | 0:6ae2f7bca550 | 62 | size_t header_bytes_received; |
Azure.IoT Build | 0:6ae2f7bca550 | 63 | SASL_FRAME_CODEC_HANDLE sasl_frame_codec; |
Azure.IoT Build | 0:6ae2f7bca550 | 64 | FRAME_CODEC_HANDLE frame_codec; |
Azure.IoT Build | 0:6ae2f7bca550 | 65 | IO_STATE io_state; |
Azure.IoT Build | 0:6ae2f7bca550 | 66 | SASL_MECHANISM_HANDLE sasl_mechanism; |
Azure.IoT Build | 0:6ae2f7bca550 | 67 | } SASL_CLIENT_IO_INSTANCE; |
Azure.IoT Build | 0:6ae2f7bca550 | 68 | |
Azure.IoT Build | 0:6ae2f7bca550 | 69 | /* Codes_SRS_SASLCLIENTIO_01_002: [The protocol header consists of the upper case ASCII letters AMQP followed by a protocol id of three, followed by three unsigned bytes representing the major, minor, and revision of the specification version (currently 1 (SASL-MAJOR), 0 (SASLMINOR), 0 (SASL-REVISION)).] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 70 | /* Codes_SRS_SASLCLIENTIO_01_124: [SASL-MAJOR 1 major protocol version.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 71 | /* Codes_SRS_SASLCLIENTIO_01_125: [SASL-MINOR 0 minor protocol version.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 72 | /* Codes_SRS_SASLCLIENTIO_01_126: [SASL-REVISION 0 protocol revision.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 73 | const unsigned char sasl_header[] = { 'A', 'M', 'Q', 'P', 3, 1, 0, 0 }; |
Azure.IoT Build | 0:6ae2f7bca550 | 74 | |
Azure.IoT Build | 0:6ae2f7bca550 | 75 | static void indicate_error(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 76 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 77 | if (sasl_client_io_instance->on_io_error != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 78 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 79 | sasl_client_io_instance->on_io_error(sasl_client_io_instance->on_io_error_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 80 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 81 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 82 | |
Azure.IoT Build | 0:6ae2f7bca550 | 83 | static void indicate_open_complete(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 84 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 85 | if (sasl_client_io_instance->on_io_open_complete != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 86 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 87 | sasl_client_io_instance->on_io_open_complete(sasl_client_io_instance->on_io_open_complete_context, open_result); |
Azure.IoT Build | 0:6ae2f7bca550 | 88 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 89 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 90 | |
Azure.IoT Build | 0:6ae2f7bca550 | 91 | static void indicate_close_complete(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 92 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 93 | if (sasl_client_io_instance->on_io_close_complete != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 94 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 95 | sasl_client_io_instance->on_io_close_complete(sasl_client_io_instance->on_io_close_complete_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 96 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 97 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 98 | |
Azure.IoT Build | 0:6ae2f7bca550 | 99 | static void on_underlying_io_close_complete(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 100 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 101 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 102 | |
Azure.IoT Build | 0:6ae2f7bca550 | 103 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 104 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 105 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 106 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 107 | |
Azure.IoT Build | 0:6ae2f7bca550 | 108 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 109 | case IO_STATE_SASL_HANDSHAKE: |
Azure.IoT Build | 0:6ae2f7bca550 | 110 | sasl_client_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 111 | indicate_open_complete(sasl_client_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 112 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 113 | |
Azure.IoT Build | 0:6ae2f7bca550 | 114 | case IO_STATE_CLOSING: |
Azure.IoT Build | 0:6ae2f7bca550 | 115 | sasl_client_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 116 | indicate_close_complete(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 117 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 118 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 119 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 120 | |
Azure.IoT Build | 0:6ae2f7bca550 | 121 | static void handle_error(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 122 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 123 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 124 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 125 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 126 | case IO_STATE_NOT_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 127 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 128 | |
Azure.IoT Build | 0:6ae2f7bca550 | 129 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 130 | case IO_STATE_SASL_HANDSHAKE: |
Azure.IoT Build | 0:6ae2f7bca550 | 131 | if (xio_close(sasl_client_io_instance->underlying_io, on_underlying_io_close_complete, sasl_client_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 132 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 133 | sasl_client_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 134 | indicate_open_complete(sasl_client_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 135 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 136 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 137 | |
Azure.IoT Build | 0:6ae2f7bca550 | 138 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 139 | sasl_client_io_instance->io_state = IO_STATE_ERROR; |
Azure.IoT Build | 0:6ae2f7bca550 | 140 | indicate_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 141 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 142 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 143 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 144 | |
Azure.IoT Build | 0:6ae2f7bca550 | 145 | static int send_sasl_header(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 146 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 147 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 148 | |
Azure.IoT Build | 0:6ae2f7bca550 | 149 | /* Codes_SRS_SASLCLIENTIO_01_078: [SASL client IO shall start the header exchange by sending the SASL header.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 150 | /* Codes_SRS_SASLCLIENTIO_01_095: [Sending the header shall be done by using xio_send.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 151 | if (xio_send(sasl_client_io_instance->underlying_io, sasl_header, sizeof(sasl_header), NULL, NULL) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 152 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 153 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 154 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 155 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 156 | { |
Azure.IoT Build | 5:ae49385aff34 | 157 | LOG(LOG_TRACE, LOG_LINE, "-> Header (AMQP 3.1.0.0)"); |
Azure.IoT Build | 0:6ae2f7bca550 | 158 | |
Azure.IoT Build | 0:6ae2f7bca550 | 159 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 160 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 161 | |
Azure.IoT Build | 0:6ae2f7bca550 | 162 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 163 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 164 | |
Azure.IoT Build | 0:6ae2f7bca550 | 165 | static void on_underlying_io_open_complete(void* context, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 166 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 167 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 168 | |
Azure.IoT Build | 0:6ae2f7bca550 | 169 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 170 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 171 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 172 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 173 | |
Azure.IoT Build | 0:6ae2f7bca550 | 174 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 175 | if (open_result == IO_OPEN_OK) |
Azure.IoT Build | 0:6ae2f7bca550 | 176 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 177 | sasl_client_io_instance->io_state = IO_STATE_SASL_HANDSHAKE; |
Azure.IoT Build | 0:6ae2f7bca550 | 178 | if (sasl_client_io_instance->sasl_header_exchange_state != SASL_HEADER_EXCHANGE_IDLE) |
Azure.IoT Build | 0:6ae2f7bca550 | 179 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 180 | /* Codes_SRS_SASLCLIENTIO_01_116: [Any underlying IO state changes to state OPEN after the header exchange has been started shall trigger no action.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 181 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 182 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 183 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 184 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 185 | /* Codes_SRS_SASLCLIENTIO_01_105: [start header exchange] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 186 | /* Codes_SRS_SASLCLIENTIO_01_001: [To establish a SASL layer, each peer MUST start by sending a protocol header.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 187 | if (send_sasl_header(sasl_client_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 188 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 189 | /* Codes_SRS_SASLCLIENTIO_01_073: [If the handshake fails (i.e. the outcome is an error) the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 190 | /* Codes_SRS_SASLCLIENTIO_01_077: [If sending the SASL header fails, the SASL client IO state shall be set to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 191 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 192 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 193 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 194 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 195 | sasl_client_io_instance->sasl_header_exchange_state = SASL_HEADER_EXCHANGE_HEADER_SENT; |
Azure.IoT Build | 0:6ae2f7bca550 | 196 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 197 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 198 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 199 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 200 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 201 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 202 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 203 | |
Azure.IoT Build | 0:6ae2f7bca550 | 204 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 205 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 206 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 207 | |
Azure.IoT Build | 0:6ae2f7bca550 | 208 | static void on_underlying_io_error(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 209 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 210 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 211 | |
Azure.IoT Build | 0:6ae2f7bca550 | 212 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 213 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 214 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 215 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 216 | |
Azure.IoT Build | 0:6ae2f7bca550 | 217 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 218 | case IO_STATE_SASL_HANDSHAKE: |
Azure.IoT Build | 0:6ae2f7bca550 | 219 | sasl_client_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 220 | indicate_open_complete(sasl_client_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 221 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 222 | |
Azure.IoT Build | 0:6ae2f7bca550 | 223 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 224 | sasl_client_io_instance->io_state = IO_STATE_ERROR; |
Azure.IoT Build | 0:6ae2f7bca550 | 225 | indicate_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 226 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 227 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 228 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 229 | |
Azure.IoT Build | 0:6ae2f7bca550 | 230 | static const char* get_frame_type_as_string(AMQP_VALUE descriptor) |
Azure.IoT Build | 0:6ae2f7bca550 | 231 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 232 | const char* result; |
Azure.IoT Build | 0:6ae2f7bca550 | 233 | |
Azure.IoT Build | 0:6ae2f7bca550 | 234 | if (is_sasl_mechanisms_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 235 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 236 | result = "[SASL MECHANISMS]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 237 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 238 | else if (is_sasl_init_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 239 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 240 | result = "[SASL INIT]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 241 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 242 | else if (is_sasl_challenge_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 243 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 244 | result = "[SASL CHALLENGE]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 245 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 246 | else if (is_sasl_response_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 247 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 248 | result = "[SASL RESPONSE]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 249 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 250 | else if (is_sasl_outcome_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 251 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 252 | result = "[SASL OUTCOME]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 253 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 254 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 255 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 256 | result = "[Unknown]"; |
Azure.IoT Build | 0:6ae2f7bca550 | 257 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 258 | |
Azure.IoT Build | 0:6ae2f7bca550 | 259 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 260 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 261 | |
Azure.IoT Build | 0:6ae2f7bca550 | 262 | static void log_incoming_frame(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance, AMQP_VALUE performative) |
Azure.IoT Build | 0:6ae2f7bca550 | 263 | { |
Azure.IoT Build | 5:ae49385aff34 | 264 | if (xlogging_get_log_function() != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 265 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 266 | AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(performative); |
Azure.IoT Build | 0:6ae2f7bca550 | 267 | if (descriptor != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 268 | { |
Azure.IoT Build | 5:ae49385aff34 | 269 | LOG(LOG_TRACE, 0, "<- "); |
Azure.IoT Build | 5:ae49385aff34 | 270 | LOG(LOG_TRACE, 0, (char*)get_frame_type_as_string(descriptor)); |
Azure.IoT Build | 0:6ae2f7bca550 | 271 | char* performative_as_string = NULL; |
Azure.IoT Build | 5:ae49385aff34 | 272 | LOG(LOG_TRACE, LOG_LINE, (performative_as_string = amqpvalue_to_string(performative))); |
Azure.IoT Build | 0:6ae2f7bca550 | 273 | if (performative_as_string != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 274 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 275 | amqpalloc_free(performative_as_string); |
Azure.IoT Build | 0:6ae2f7bca550 | 276 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 277 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 278 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 279 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 280 | |
Azure.IoT Build | 0:6ae2f7bca550 | 281 | static void log_outgoing_frame(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance, AMQP_VALUE performative) |
Azure.IoT Build | 0:6ae2f7bca550 | 282 | { |
Azure.IoT Build | 5:ae49385aff34 | 283 | if (xlogging_get_log_function() != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 284 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 285 | AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(performative); |
Azure.IoT Build | 0:6ae2f7bca550 | 286 | if (descriptor != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 287 | { |
Azure.IoT Build | 5:ae49385aff34 | 288 | LOG(LOG_TRACE, 0, "-> "); |
Azure.IoT Build | 5:ae49385aff34 | 289 | LOG(LOG_TRACE, 0, (char*)get_frame_type_as_string(descriptor)); |
Azure.IoT Build | 0:6ae2f7bca550 | 290 | char* performative_as_string = NULL; |
Azure.IoT Build | 5:ae49385aff34 | 291 | LOG(LOG_TRACE, LOG_LINE, (performative_as_string = amqpvalue_to_string(performative))); |
Azure.IoT Build | 0:6ae2f7bca550 | 292 | if (performative_as_string != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 293 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 294 | amqpalloc_free(performative_as_string); |
Azure.IoT Build | 0:6ae2f7bca550 | 295 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 296 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 297 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 298 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 299 | |
Azure.IoT Build | 0:6ae2f7bca550 | 300 | static int saslclientio_receive_byte(SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance, unsigned char b) |
Azure.IoT Build | 0:6ae2f7bca550 | 301 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 302 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 303 | |
Azure.IoT Build | 0:6ae2f7bca550 | 304 | switch (sasl_client_io_instance->sasl_header_exchange_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 305 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 306 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 307 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 308 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 309 | |
Azure.IoT Build | 0:6ae2f7bca550 | 310 | case SASL_HEADER_EXCHANGE_HEADER_EXCH: |
Azure.IoT Build | 0:6ae2f7bca550 | 311 | switch (sasl_client_io_instance->sasl_client_negotiation_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 312 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 313 | case SASL_CLIENT_NEGOTIATION_ERROR: |
Azure.IoT Build | 0:6ae2f7bca550 | 314 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 315 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 316 | |
Azure.IoT Build | 0:6ae2f7bca550 | 317 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 318 | /* Codes_SRS_SASLCLIENTIO_01_068: [During the SASL frame exchange that constitutes the handshake the received bytes from the underlying IO shall be fed to the frame_codec instance created in saslclientio_create by calling frame_codec_receive_bytes.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 319 | if (frame_codec_receive_bytes(sasl_client_io_instance->frame_codec, &b, 1) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 320 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 321 | /* Codes_SRS_SASLCLIENTIO_01_088: [If frame_codec_receive_bytes fails, the state of SASL client IO shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 322 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 323 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 324 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 325 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 326 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 327 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 328 | |
Azure.IoT Build | 0:6ae2f7bca550 | 329 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 330 | |
Azure.IoT Build | 0:6ae2f7bca550 | 331 | case SASL_CLIENT_NEGOTIATION_OUTCOME_RCVD: |
Azure.IoT Build | 0:6ae2f7bca550 | 332 | sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->on_bytes_received_context, &b, 1); |
Azure.IoT Build | 0:6ae2f7bca550 | 333 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 334 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 335 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 336 | |
Azure.IoT Build | 0:6ae2f7bca550 | 337 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 338 | |
Azure.IoT Build | 0:6ae2f7bca550 | 339 | /* Codes_SRS_SASLCLIENTIO_01_003: [Other than using a protocol id of three, the exchange of SASL layer headers follows the same rules specified in the version negotiation section of the transport specification (See Part 2: section 2.2).] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 340 | case SASL_HEADER_EXCHANGE_IDLE: |
Azure.IoT Build | 0:6ae2f7bca550 | 341 | case SASL_HEADER_EXCHANGE_HEADER_SENT: |
Azure.IoT Build | 0:6ae2f7bca550 | 342 | if (b != sasl_header[sasl_client_io_instance->header_bytes_received]) |
Azure.IoT Build | 0:6ae2f7bca550 | 343 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 344 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 345 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 346 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 347 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 348 | sasl_client_io_instance->header_bytes_received++; |
Azure.IoT Build | 0:6ae2f7bca550 | 349 | if (sasl_client_io_instance->header_bytes_received == sizeof(sasl_header)) |
Azure.IoT Build | 0:6ae2f7bca550 | 350 | { |
Azure.IoT Build | 5:ae49385aff34 | 351 | LOG(LOG_TRACE, LOG_LINE, "<- Header (AMQP 3.1.0.0)"); |
Azure.IoT Build | 0:6ae2f7bca550 | 352 | |
Azure.IoT Build | 0:6ae2f7bca550 | 353 | switch (sasl_client_io_instance->sasl_header_exchange_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 354 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 355 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 356 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 357 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 358 | |
Azure.IoT Build | 0:6ae2f7bca550 | 359 | case SASL_HEADER_EXCHANGE_HEADER_SENT: |
Azure.IoT Build | 0:6ae2f7bca550 | 360 | /* from this point on we need to decode SASL frames */ |
Azure.IoT Build | 0:6ae2f7bca550 | 361 | sasl_client_io_instance->sasl_header_exchange_state = SASL_HEADER_EXCHANGE_HEADER_EXCH; |
Azure.IoT Build | 0:6ae2f7bca550 | 362 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 363 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 364 | |
Azure.IoT Build | 0:6ae2f7bca550 | 365 | case SASL_HEADER_EXCHANGE_IDLE: |
Azure.IoT Build | 0:6ae2f7bca550 | 366 | sasl_client_io_instance->sasl_header_exchange_state = SASL_HEADER_EXCHANGE_HEADER_RCVD; |
Azure.IoT Build | 0:6ae2f7bca550 | 367 | if (send_sasl_header(sasl_client_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 368 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 369 | /* Codes_SRS_SASLCLIENTIO_01_077: [If sending the SASL header fails, the SASL client IO state shall be set to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 370 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 371 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 372 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 373 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 374 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 375 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 376 | |
Azure.IoT Build | 0:6ae2f7bca550 | 377 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 378 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 379 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 380 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 381 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 382 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 383 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 384 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 385 | |
Azure.IoT Build | 0:6ae2f7bca550 | 386 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 387 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 388 | |
Azure.IoT Build | 0:6ae2f7bca550 | 389 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 390 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 391 | |
Azure.IoT Build | 0:6ae2f7bca550 | 392 | static void on_underlying_io_bytes_received(void* context, const unsigned char* buffer, size_t size) |
Azure.IoT Build | 0:6ae2f7bca550 | 393 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 394 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 395 | |
Azure.IoT Build | 0:6ae2f7bca550 | 396 | /* Codes_SRS_SASLCLIENTIO_01_028: [If buffer is NULL or size is zero, nothing should be indicated as received and the saslio state shall be switched to ERROR the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 397 | if ((buffer == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 398 | (size == 0)) |
Azure.IoT Build | 0:6ae2f7bca550 | 399 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 400 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 401 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 402 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 403 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 404 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 405 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 406 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 407 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 408 | |
Azure.IoT Build | 0:6ae2f7bca550 | 409 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 410 | /* Codes_SRS_SASLCLIENTIO_01_027: [When the on_bytes_received callback passed to the underlying IO is called and the SASL client IO state is IO_STATE_OPEN, the bytes shall be indicated to the user of SASL client IO by calling the on_bytes_received that was passed in saslclientio_open.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 411 | /* Codes_SRS_SASLCLIENTIO_01_029: [The context argument shall be set to the callback_context passed in saslclientio_open.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 412 | sasl_client_io_instance->on_bytes_received(sasl_client_io_instance->on_bytes_received_context, buffer, size); |
Azure.IoT Build | 0:6ae2f7bca550 | 413 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 414 | |
Azure.IoT Build | 0:6ae2f7bca550 | 415 | case IO_STATE_SASL_HANDSHAKE: |
Azure.IoT Build | 0:6ae2f7bca550 | 416 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 417 | size_t i; |
Azure.IoT Build | 0:6ae2f7bca550 | 418 | |
Azure.IoT Build | 0:6ae2f7bca550 | 419 | for (i = 0; i < size; i++) |
Azure.IoT Build | 0:6ae2f7bca550 | 420 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 421 | if (saslclientio_receive_byte(sasl_client_io_instance, buffer[i]) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 422 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 423 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 424 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 425 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 426 | |
Azure.IoT Build | 0:6ae2f7bca550 | 427 | if (i < size) |
Azure.IoT Build | 0:6ae2f7bca550 | 428 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 429 | /* Codes_SRS_SASLCLIENTIO_01_073: [If the handshake fails (i.e. the outcome is an error) the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 430 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 431 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 432 | |
Azure.IoT Build | 0:6ae2f7bca550 | 433 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 434 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 435 | |
Azure.IoT Build | 0:6ae2f7bca550 | 436 | case IO_STATE_ERROR: |
Azure.IoT Build | 0:6ae2f7bca550 | 437 | /* Codes_SRS_SASLCLIENTIO_01_031: [If bytes are received when the SASL client IO state is IO_STATE_ERROR, SASL client IO shall do nothing.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 438 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 439 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 440 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 441 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 442 | |
Azure.IoT Build | 0:6ae2f7bca550 | 443 | static void on_bytes_encoded(void* context, const unsigned char* bytes, size_t length, bool encode_complete) |
Azure.IoT Build | 0:6ae2f7bca550 | 444 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 445 | (void)encode_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 446 | |
Azure.IoT Build | 0:6ae2f7bca550 | 447 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 448 | |
Azure.IoT Build | 0:6ae2f7bca550 | 449 | /* Codes_SRS_SASLCLIENTIO_01_120: [When SASL client IO is notified by sasl_frame_codec of bytes that have been encoded via the on_bytes_encoded callback and SASL client IO is in the state OPENING, SASL client IO shall send these bytes by using xio_send.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 450 | if (xio_send(sasl_client_io_instance->underlying_io, bytes, length, NULL, NULL) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 451 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 452 | /* Codes_SRS_SASLCLIENTIO_01_121: [If xio_send fails, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 453 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 454 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 455 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 456 | |
Azure.IoT Build | 0:6ae2f7bca550 | 457 | static int send_sasl_init(SASL_CLIENT_IO_INSTANCE* sasl_client_io, const char* sasl_mechanism_name) |
Azure.IoT Build | 0:6ae2f7bca550 | 458 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 459 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 460 | |
Azure.IoT Build | 0:6ae2f7bca550 | 461 | SASL_INIT_HANDLE sasl_init; |
Azure.IoT Build | 0:6ae2f7bca550 | 462 | SASL_MECHANISM_BYTES init_bytes; |
Azure.IoT Build | 0:6ae2f7bca550 | 463 | |
Azure.IoT Build | 0:6ae2f7bca550 | 464 | /* Codes_SRS_SASLCLIENTIO_01_045: [The name of the SASL mechanism used for the SASL exchange.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 465 | sasl_init = sasl_init_create(sasl_mechanism_name); |
Azure.IoT Build | 0:6ae2f7bca550 | 466 | if (sasl_init == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 467 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 468 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 469 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 470 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 471 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 472 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 473 | /* Codes_SRS_SASLCLIENTIO_01_048: [The contents of this data are defined by the SASL security mechanism.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 474 | if (saslmechanism_get_init_bytes(sasl_client_io->sasl_mechanism, &init_bytes) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 475 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 476 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 477 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 478 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 479 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 480 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 481 | amqp_binary creds = { init_bytes.bytes, init_bytes.length }; |
Azure.IoT Build | 0:6ae2f7bca550 | 482 | if ((init_bytes.length > 0) && |
Azure.IoT Build | 0:6ae2f7bca550 | 483 | /* Codes_SRS_SASLCLIENTIO_01_047: [A block of opaque data passed to the security mechanism.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 484 | (sasl_init_set_initial_response(sasl_init, creds) != 0)) |
Azure.IoT Build | 0:6ae2f7bca550 | 485 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 486 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 487 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 488 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 489 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 490 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 491 | AMQP_VALUE sasl_init_value = amqpvalue_create_sasl_init(sasl_init); |
Azure.IoT Build | 0:6ae2f7bca550 | 492 | if (sasl_init_value == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 493 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 494 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 495 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 496 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 497 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 498 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 499 | /* Codes_SRS_SASLCLIENTIO_01_070: [When a frame needs to be sent as part of the SASL handshake frame exchange, the send shall be done by calling sasl_frame_codec_encode_frame.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 500 | if (sasl_frame_codec_encode_frame(sasl_client_io->sasl_frame_codec, sasl_init_value, on_bytes_encoded, sasl_client_io) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 501 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 502 | /* Codes_SRS_SASLCLIENTIO_01_071: [If sasl_frame_codec_encode_frame fails, then the state of SASL client IO shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 503 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 504 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 505 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 506 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 507 | log_outgoing_frame(sasl_client_io, sasl_init_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 508 | |
Azure.IoT Build | 0:6ae2f7bca550 | 509 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 510 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 511 | |
Azure.IoT Build | 0:6ae2f7bca550 | 512 | amqpvalue_destroy(sasl_init_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 513 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 514 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 515 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 516 | |
Azure.IoT Build | 0:6ae2f7bca550 | 517 | sasl_init_destroy(sasl_init); |
Azure.IoT Build | 0:6ae2f7bca550 | 518 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 519 | |
Azure.IoT Build | 0:6ae2f7bca550 | 520 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 521 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 522 | |
Azure.IoT Build | 0:6ae2f7bca550 | 523 | static int send_sasl_response(SASL_CLIENT_IO_INSTANCE* sasl_client_io, SASL_MECHANISM_BYTES sasl_response) |
Azure.IoT Build | 0:6ae2f7bca550 | 524 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 525 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 526 | |
Azure.IoT Build | 0:6ae2f7bca550 | 527 | SASL_RESPONSE_HANDLE sasl_response_handle; |
Azure.IoT Build | 0:6ae2f7bca550 | 528 | amqp_binary response_binary_value = { sasl_response.bytes, sasl_response.length }; |
Azure.IoT Build | 0:6ae2f7bca550 | 529 | |
Azure.IoT Build | 0:6ae2f7bca550 | 530 | /* Codes_SRS_SASLCLIENTIO_01_055: [Send the SASL response data as defined by the SASL specification.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 531 | /* Codes_SRS_SASLCLIENTIO_01_056: [A block of opaque data passed to the security mechanism.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 532 | if ((sasl_response_handle = sasl_response_create(response_binary_value)) == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 533 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 534 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 535 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 536 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 537 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 538 | AMQP_VALUE sasl_response_value = amqpvalue_create_sasl_response(sasl_response_handle); |
Azure.IoT Build | 0:6ae2f7bca550 | 539 | if (sasl_response_value == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 540 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 541 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 542 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 543 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 544 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 545 | /* Codes_SRS_SASLCLIENTIO_01_070: [When a frame needs to be sent as part of the SASL handshake frame exchange, the send shall be done by calling sasl_frame_codec_encode_frame.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 546 | if (sasl_frame_codec_encode_frame(sasl_client_io->sasl_frame_codec, sasl_response_value, on_bytes_encoded, sasl_client_io) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 547 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 548 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 549 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 550 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 551 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 552 | log_outgoing_frame(sasl_client_io, sasl_response_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 553 | |
Azure.IoT Build | 0:6ae2f7bca550 | 554 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 555 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 556 | |
Azure.IoT Build | 0:6ae2f7bca550 | 557 | amqpvalue_destroy(sasl_response_value); |
Azure.IoT Build | 0:6ae2f7bca550 | 558 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 559 | |
Azure.IoT Build | 0:6ae2f7bca550 | 560 | sasl_response_destroy(sasl_response_handle); |
Azure.IoT Build | 0:6ae2f7bca550 | 561 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 562 | |
Azure.IoT Build | 0:6ae2f7bca550 | 563 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 564 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 565 | |
Azure.IoT Build | 0:6ae2f7bca550 | 566 | static void sasl_frame_received_callback(void* context, AMQP_VALUE sasl_frame) |
Azure.IoT Build | 0:6ae2f7bca550 | 567 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 568 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 569 | |
Azure.IoT Build | 0:6ae2f7bca550 | 570 | /* Codes_SRS_SASLCLIENTIO_01_067: [The SASL frame exchange shall be started as soon as the SASL header handshake is done.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 571 | switch (sasl_client_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 572 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 573 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 574 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 575 | |
Azure.IoT Build | 0:6ae2f7bca550 | 576 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 577 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 578 | case IO_STATE_CLOSING: |
Azure.IoT Build | 0:6ae2f7bca550 | 579 | /* Codes_SRS_SASLCLIENTIO_01_117: [If on_sasl_frame_received_callback is called when the state of the IO is OPEN then the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 580 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 581 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 582 | |
Azure.IoT Build | 0:6ae2f7bca550 | 583 | case IO_STATE_SASL_HANDSHAKE: |
Azure.IoT Build | 0:6ae2f7bca550 | 584 | if (sasl_client_io_instance->sasl_header_exchange_state != SASL_HEADER_EXCHANGE_HEADER_EXCH) |
Azure.IoT Build | 0:6ae2f7bca550 | 585 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 586 | /* Codes_SRS_SASLCLIENTIO_01_118: [If on_sasl_frame_received_callback is called in the OPENING state but the header exchange has not yet been completed, then the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 587 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 588 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 589 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 590 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 591 | AMQP_VALUE descriptor = amqpvalue_get_inplace_descriptor(sasl_frame); |
Azure.IoT Build | 0:6ae2f7bca550 | 592 | if (descriptor == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 593 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 594 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 595 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 596 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 597 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 598 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 599 | log_incoming_frame(sasl_client_io_instance, sasl_frame); |
Azure.IoT Build | 0:6ae2f7bca550 | 600 | |
Azure.IoT Build | 0:6ae2f7bca550 | 601 | /* Codes_SRS_SASLCLIENTIO_01_032: [The peer acting as the SASL server MUST announce supported authentication mechanisms using the sasl-mechanisms frame.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 602 | /* Codes_SRS_SASLCLIENTIO_01_040: [The peer playing the role of the SASL client and the peer playing the role of the SASL server MUST correspond to the TCP client and server respectively.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 603 | /* Codes_SRS_SASLCLIENTIO_01_034: [<-- SASL-MECHANISMS] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 604 | if (is_sasl_mechanisms_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 605 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 606 | switch (sasl_client_io_instance->sasl_client_negotiation_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 607 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 608 | case SASL_CLIENT_NEGOTIATION_NOT_STARTED: |
Azure.IoT Build | 0:6ae2f7bca550 | 609 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 610 | SASL_MECHANISMS_HANDLE sasl_mechanisms_handle; |
Azure.IoT Build | 0:6ae2f7bca550 | 611 | |
Azure.IoT Build | 0:6ae2f7bca550 | 612 | if (amqpvalue_get_sasl_mechanisms(sasl_frame, &sasl_mechanisms_handle) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 613 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 614 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 615 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 616 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 617 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 618 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 619 | AMQP_VALUE sasl_server_mechanisms; |
Azure.IoT Build | 0:6ae2f7bca550 | 620 | uint32_t mechanisms_count; |
Azure.IoT Build | 0:6ae2f7bca550 | 621 | |
Azure.IoT Build | 0:6ae2f7bca550 | 622 | if ((sasl_mechanisms_get_sasl_server_mechanisms(sasl_mechanisms_handle, &sasl_server_mechanisms) != 0) || |
Azure.IoT Build | 0:6ae2f7bca550 | 623 | (amqpvalue_get_array_item_count(sasl_server_mechanisms, &mechanisms_count) != 0) || |
Azure.IoT Build | 0:6ae2f7bca550 | 624 | (mechanisms_count == 0)) |
Azure.IoT Build | 0:6ae2f7bca550 | 625 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 626 | /* Codes_SRS_SASLCLIENTIO_01_042: [It is invalid for this list to be null or empty.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 627 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 628 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 629 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 630 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 631 | const char* sasl_mechanism_name = saslmechanism_get_mechanism_name(sasl_client_io_instance->sasl_mechanism); |
Azure.IoT Build | 0:6ae2f7bca550 | 632 | if (sasl_mechanism_name == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 633 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 634 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 635 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 636 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 637 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 638 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 639 | uint32_t i; |
Azure.IoT Build | 0:6ae2f7bca550 | 640 | |
Azure.IoT Build | 0:6ae2f7bca550 | 641 | for (i = 0; i < mechanisms_count; i++) |
Azure.IoT Build | 0:6ae2f7bca550 | 642 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 643 | AMQP_VALUE sasl_server_mechanism; |
Azure.IoT Build | 0:6ae2f7bca550 | 644 | sasl_server_mechanism = amqpvalue_get_array_item(sasl_server_mechanisms, i); |
Azure.IoT Build | 0:6ae2f7bca550 | 645 | if (sasl_server_mechanism == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 646 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 647 | i = mechanisms_count; |
Azure.IoT Build | 0:6ae2f7bca550 | 648 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 649 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 650 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 651 | const char* sasl_server_mechanism_name; |
Azure.IoT Build | 0:6ae2f7bca550 | 652 | if (amqpvalue_get_symbol(sasl_server_mechanism, &sasl_server_mechanism_name) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 653 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 654 | i = mechanisms_count; |
Azure.IoT Build | 0:6ae2f7bca550 | 655 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 656 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 657 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 658 | if (strcmp(sasl_mechanism_name, sasl_server_mechanism_name) == 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 659 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 660 | amqpvalue_destroy(sasl_server_mechanism); |
Azure.IoT Build | 0:6ae2f7bca550 | 661 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 662 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 663 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 664 | |
Azure.IoT Build | 0:6ae2f7bca550 | 665 | amqpvalue_destroy(sasl_server_mechanism); |
Azure.IoT Build | 0:6ae2f7bca550 | 666 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 667 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 668 | |
Azure.IoT Build | 0:6ae2f7bca550 | 669 | if (i == mechanisms_count) |
Azure.IoT Build | 0:6ae2f7bca550 | 670 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 671 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 672 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 673 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 674 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 675 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 676 | sasl_client_io_instance->sasl_client_negotiation_state = SASL_CLIENT_NEGOTIATION_MECH_RCVD; |
Azure.IoT Build | 0:6ae2f7bca550 | 677 | |
Azure.IoT Build | 0:6ae2f7bca550 | 678 | /* Codes_SRS_SASLCLIENTIO_01_035: [SASL-INIT -->] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 679 | /* Codes_SRS_SASLCLIENTIO_01_033: [The partner MUST then choose one of the supported mechanisms and initiate a sasl exchange.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 680 | /* Codes_SRS_SASLCLIENTIO_01_054: [Selects the sasl mechanism and provides the initial response if needed.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 681 | if (send_sasl_init(sasl_client_io_instance, sasl_mechanism_name) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 682 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 683 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 684 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 685 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 686 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 687 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 688 | sasl_client_io_instance->sasl_client_negotiation_state = SASL_CLIENT_NEGOTIATION_INIT_SENT; |
Azure.IoT Build | 0:6ae2f7bca550 | 689 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 690 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 691 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 692 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 693 | |
Azure.IoT Build | 0:6ae2f7bca550 | 694 | sasl_mechanisms_destroy(sasl_mechanisms_handle); |
Azure.IoT Build | 0:6ae2f7bca550 | 695 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 696 | |
Azure.IoT Build | 0:6ae2f7bca550 | 697 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 698 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 699 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 700 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 701 | /* Codes_SRS_SASLCLIENTIO_01_052: [Send the SASL challenge data as defined by the SASL specification.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 702 | /* Codes_SRS_SASLCLIENTIO_01_036: [<-- SASL-CHALLENGE *] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 703 | /* Codes_SRS_SASLCLIENTIO_01_039: [the SASL challenge/response step can occur zero or more times depending on the details of the SASL mechanism chosen.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 704 | else if (is_sasl_challenge_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 705 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 706 | /* Codes_SRS_SASLCLIENTIO_01_032: [The peer acting as the SASL server MUST announce supported authentication mechanisms using the sasl-mechanisms frame.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 707 | if ((sasl_client_io_instance->sasl_client_negotiation_state != SASL_CLIENT_NEGOTIATION_INIT_SENT) && |
Azure.IoT Build | 0:6ae2f7bca550 | 708 | (sasl_client_io_instance->sasl_client_negotiation_state != SASL_CLIENT_NEGOTIATION_RESPONSE_SENT)) |
Azure.IoT Build | 0:6ae2f7bca550 | 709 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 710 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 711 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 712 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 713 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 714 | SASL_CHALLENGE_HANDLE sasl_challenge_handle; |
Azure.IoT Build | 0:6ae2f7bca550 | 715 | |
Azure.IoT Build | 0:6ae2f7bca550 | 716 | if (amqpvalue_get_sasl_challenge(sasl_frame, &sasl_challenge_handle) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 717 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 718 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 719 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 720 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 721 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 722 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 723 | amqp_binary challenge_binary_value; |
Azure.IoT Build | 0:6ae2f7bca550 | 724 | SASL_MECHANISM_BYTES response_bytes; |
Azure.IoT Build | 0:6ae2f7bca550 | 725 | |
Azure.IoT Build | 0:6ae2f7bca550 | 726 | /* Codes_SRS_SASLCLIENTIO_01_053: [Challenge information, a block of opaque binary data passed to the security mechanism.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 727 | if (sasl_challenge_get_challenge(sasl_challenge_handle, &challenge_binary_value) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 728 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 729 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 730 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 731 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 732 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 733 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 734 | SASL_MECHANISM_BYTES challenge = { challenge_binary_value.bytes, challenge_binary_value.length }; |
Azure.IoT Build | 0:6ae2f7bca550 | 735 | |
Azure.IoT Build | 0:6ae2f7bca550 | 736 | /* Codes_SRS_SASLCLIENTIO_01_057: [The contents of this data are defined by the SASL security mechanism.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 737 | /* Codes_SRS_SASLCLIENTIO_01_037: [SASL-RESPONSE -->] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 738 | if ((saslmechanism_challenge(sasl_client_io_instance->sasl_mechanism, &challenge, &response_bytes) != 0) || |
Azure.IoT Build | 0:6ae2f7bca550 | 739 | (send_sasl_response(sasl_client_io_instance, response_bytes) != 0)) |
Azure.IoT Build | 0:6ae2f7bca550 | 740 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 741 | /* Codes_SRS_SASLCLIENTIO_01_119: [If any error is encountered when parsing the received frame, the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 742 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 743 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 744 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 745 | |
Azure.IoT Build | 0:6ae2f7bca550 | 746 | sasl_challenge_destroy(sasl_challenge_handle); |
Azure.IoT Build | 0:6ae2f7bca550 | 747 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 748 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 749 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 750 | /* Codes_SRS_SASLCLIENTIO_01_058: [This frame indicates the outcome of the SASL dialog.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 751 | /* Codes_SRS_SASLCLIENTIO_01_038: [<-- SASL-OUTCOME] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 752 | else if (is_sasl_outcome_type_by_descriptor(descriptor)) |
Azure.IoT Build | 0:6ae2f7bca550 | 753 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 754 | /* Codes_SRS_SASLCLIENTIO_01_032: [The peer acting as the SASL server MUST announce supported authentication mechanisms using the sasl-mechanisms frame.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 755 | if ((sasl_client_io_instance->sasl_client_negotiation_state != SASL_CLIENT_NEGOTIATION_INIT_SENT) && |
Azure.IoT Build | 0:6ae2f7bca550 | 756 | (sasl_client_io_instance->sasl_client_negotiation_state != SASL_CLIENT_NEGOTIATION_RESPONSE_SENT)) |
Azure.IoT Build | 0:6ae2f7bca550 | 757 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 758 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 759 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 760 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 761 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 762 | SASL_OUTCOME_HANDLE sasl_outcome; |
Azure.IoT Build | 0:6ae2f7bca550 | 763 | |
Azure.IoT Build | 0:6ae2f7bca550 | 764 | sasl_client_io_instance->sasl_client_negotiation_state = SASL_CLIENT_NEGOTIATION_OUTCOME_RCVD; |
Azure.IoT Build | 0:6ae2f7bca550 | 765 | |
Azure.IoT Build | 0:6ae2f7bca550 | 766 | if (amqpvalue_get_sasl_outcome(sasl_frame, &sasl_outcome) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 767 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 768 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 769 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 770 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 771 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 772 | sasl_code sasl_code; |
Azure.IoT Build | 0:6ae2f7bca550 | 773 | |
Azure.IoT Build | 0:6ae2f7bca550 | 774 | /* Codes_SRS_SASLCLIENTIO_01_060: [A reply-code indicating the outcome of the SASL dialog.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 775 | if (sasl_outcome_get_code(sasl_outcome, &sasl_code) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 776 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 777 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 778 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 779 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 780 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 781 | switch (sasl_code) |
Azure.IoT Build | 0:6ae2f7bca550 | 782 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 783 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 784 | case sasl_code_auth: |
Azure.IoT Build | 0:6ae2f7bca550 | 785 | /* Codes_SRS_SASLCLIENTIO_01_063: [1 Connection authentication failed due to an unspecified problem with the supplied credentials.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 786 | case sasl_code_sys: |
Azure.IoT Build | 0:6ae2f7bca550 | 787 | /* Codes_SRS_SASLCLIENTIO_01_064: [2 Connection authentication failed due to a system error.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 788 | case sasl_code_sys_perm: |
Azure.IoT Build | 0:6ae2f7bca550 | 789 | /* Codes_SRS_SASLCLIENTIO_01_065: [3 Connection authentication failed due to a system error that is unlikely to be corrected without intervention.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 790 | case sasl_code_sys_temp: |
Azure.IoT Build | 0:6ae2f7bca550 | 791 | /* Codes_SRS_SASLCLIENTIO_01_066: [4 Connection authentication failed due to a transient system error.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 792 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 793 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 794 | |
Azure.IoT Build | 0:6ae2f7bca550 | 795 | case sasl_code_ok: |
Azure.IoT Build | 0:6ae2f7bca550 | 796 | /* Codes_SRS_SASLCLIENTIO_01_059: [Upon successful completion of the SASL dialog the security layer has been established] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 797 | /* Codes_SRS_SASLCLIENTIO_01_062: [0 Connection authentication succeeded.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 798 | sasl_client_io_instance->io_state = IO_STATE_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 799 | indicate_open_complete(sasl_client_io_instance, IO_OPEN_OK); |
Azure.IoT Build | 0:6ae2f7bca550 | 800 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 801 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 802 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 803 | |
Azure.IoT Build | 0:6ae2f7bca550 | 804 | sasl_outcome_destroy(sasl_outcome); |
Azure.IoT Build | 0:6ae2f7bca550 | 805 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 806 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 807 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 808 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 809 | { |
Azure.IoT Build | 5:ae49385aff34 | 810 | LogError("Bad SASL frame"); |
Azure.IoT Build | 0:6ae2f7bca550 | 811 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 812 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 813 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 814 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 815 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 816 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 817 | |
Azure.IoT Build | 0:6ae2f7bca550 | 818 | static void on_frame_codec_error(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 819 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 820 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 821 | |
Azure.IoT Build | 0:6ae2f7bca550 | 822 | /* Codes_SRS_SASLCLIENTIO_01_122: [When on_frame_codec_error is called while in the OPENING or OPEN state the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 823 | /* Codes_SRS_SASLCLIENTIO_01_123: [When on_frame_codec_error is called in the ERROR state nothing shall be done.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 824 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 825 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 826 | |
Azure.IoT Build | 0:6ae2f7bca550 | 827 | static void on_sasl_frame_codec_error(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 828 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 829 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 830 | |
Azure.IoT Build | 0:6ae2f7bca550 | 831 | /* Codes_SRS_SASLCLIENTIO_01_124: [**When on_sasl_frame_codec_error is called while in the OPENING or OPEN state the SASL client IO state shall be switched to IO_STATE_ERROR and the on_state_changed callback shall be triggered.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 832 | /* Codes_SRS_SASLCLIENTIO_01_125: [When on_sasl_frame_codec_error is called in the ERROR state nothing shall be done.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 833 | handle_error(sasl_client_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 834 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 835 | |
Azure.IoT Build | 5:ae49385aff34 | 836 | CONCRETE_IO_HANDLE saslclientio_create(void* io_create_parameters) |
Azure.IoT Build | 0:6ae2f7bca550 | 837 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 838 | SASLCLIENTIO_CONFIG* sasl_client_io_config = io_create_parameters; |
Azure.IoT Build | 0:6ae2f7bca550 | 839 | SASL_CLIENT_IO_INSTANCE* result; |
Azure.IoT Build | 0:6ae2f7bca550 | 840 | |
Azure.IoT Build | 0:6ae2f7bca550 | 841 | /* Codes_SRS_SASLCLIENTIO_01_005: [If xio_create_parameters is NULL, saslclientio_create shall fail and return NULL.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 842 | if ((sasl_client_io_config == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 843 | /* Codes_SRS_SASLCLIENTIO_01_092: [If any of the sasl_mechanism or underlying_io members of the configuration structure are NULL, saslclientio_create shall fail and return NULL.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 844 | (sasl_client_io_config->underlying_io == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 845 | (sasl_client_io_config->sasl_mechanism == NULL)) |
Azure.IoT Build | 0:6ae2f7bca550 | 846 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 847 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 848 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 849 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 850 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 851 | result = amqpalloc_malloc(sizeof(SASL_CLIENT_IO_INSTANCE)); |
Azure.IoT Build | 0:6ae2f7bca550 | 852 | /* Codes_SRS_SASLCLIENTIO_01_006: [If memory cannot be allocated for the new instance, saslclientio_create shall fail and return NULL.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 853 | if (result != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 854 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 855 | result->underlying_io = sasl_client_io_config->underlying_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 856 | if (result->underlying_io == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 857 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 858 | amqpalloc_free(result); |
Azure.IoT Build | 0:6ae2f7bca550 | 859 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 860 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 861 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 862 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 863 | /* Codes_SRS_SASLCLIENTIO_01_089: [saslclientio_create shall create a frame_codec to be used for encoding/decoding frames bycalling frame_codec_create and passing the underlying_io as argument.] */ |
Azure.IoT Build | 5:ae49385aff34 | 864 | result->frame_codec = frame_codec_create(on_frame_codec_error, result); |
Azure.IoT Build | 0:6ae2f7bca550 | 865 | if (result->frame_codec == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 866 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 867 | /* Codes_SRS_SASLCLIENTIO_01_090: [If frame_codec_create fails, then saslclientio_create shall fail and return NULL.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 868 | amqpalloc_free(result); |
Azure.IoT Build | 0:6ae2f7bca550 | 869 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 870 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 871 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 872 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 873 | /* Codes_SRS_SASLCLIENTIO_01_084: [saslclientio_create shall create a sasl_frame_codec to be used for SASL frame encoding/decoding by calling sasl_frame_codec_create and passing the just created frame_codec as argument.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 874 | result->sasl_frame_codec = sasl_frame_codec_create(result->frame_codec, sasl_frame_received_callback, on_sasl_frame_codec_error, result); |
Azure.IoT Build | 0:6ae2f7bca550 | 875 | if (result->sasl_frame_codec == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 876 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 877 | frame_codec_destroy(result->frame_codec); |
Azure.IoT Build | 0:6ae2f7bca550 | 878 | amqpalloc_free(result); |
Azure.IoT Build | 0:6ae2f7bca550 | 879 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 880 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 881 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 882 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 883 | /* Codes_SRS_SASLCLIENTIO_01_004: [saslclientio_create shall return on success a non-NULL handle to a new SASL client IO instance.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 884 | result->on_bytes_received = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 885 | result->on_io_open_complete = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 886 | result->on_io_error = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 887 | result->on_io_close_complete = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 888 | result->on_bytes_received_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 889 | result->on_io_open_complete_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 890 | result->on_io_close_complete_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 891 | result->on_io_error_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 892 | result->sasl_mechanism = sasl_client_io_config->sasl_mechanism; |
Azure.IoT Build | 0:6ae2f7bca550 | 893 | |
Azure.IoT Build | 0:6ae2f7bca550 | 894 | result->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 895 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 896 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 897 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 898 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 899 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 900 | |
Azure.IoT Build | 0:6ae2f7bca550 | 901 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 902 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 903 | |
Azure.IoT Build | 0:6ae2f7bca550 | 904 | void saslclientio_destroy(CONCRETE_IO_HANDLE sasl_client_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 905 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 906 | if (sasl_client_io != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 907 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 908 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 909 | |
Azure.IoT Build | 0:6ae2f7bca550 | 910 | /* Codes_SRS_SASLCLIENTIO_01_007: [saslclientio_destroy shall free all resources associated with the SASL client IO handle.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 911 | /* Codes_SRS_SASLCLIENTIO_01_086: [saslclientio_destroy shall destroy the sasl_frame_codec created in saslclientio_create by calling sasl_frame_codec_destroy.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 912 | sasl_frame_codec_destroy(sasl_client_io_instance->sasl_frame_codec); |
Azure.IoT Build | 0:6ae2f7bca550 | 913 | |
Azure.IoT Build | 0:6ae2f7bca550 | 914 | /* Codes_SRS_SASLCLIENTIO_01_091: [saslclientio_destroy shall destroy the frame_codec created in saslclientio_create by calling frame_codec_destroy.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 915 | frame_codec_destroy(sasl_client_io_instance->frame_codec); |
Azure.IoT Build | 0:6ae2f7bca550 | 916 | amqpalloc_free(sasl_client_io); |
Azure.IoT Build | 0:6ae2f7bca550 | 917 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 918 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 919 | |
Azure.IoT Build | 0:6ae2f7bca550 | 920 | int saslclientio_open(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_OPEN_COMPLETE on_io_open_complete, void* on_io_open_complete_context, ON_BYTES_RECEIVED on_bytes_received, void* on_bytes_received_context, ON_IO_ERROR on_io_error, void* on_io_error_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 921 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 922 | int result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 923 | |
Azure.IoT Build | 0:6ae2f7bca550 | 924 | /* Codes_SRS_SASLCLIENTIO_01_011: [If any of the sasl_client_io or on_bytes_received arguments is NULL, saslclientio_open shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 925 | if ((sasl_client_io == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 926 | (on_bytes_received == NULL)) |
Azure.IoT Build | 0:6ae2f7bca550 | 927 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 928 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 929 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 930 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 931 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 932 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 933 | |
Azure.IoT Build | 0:6ae2f7bca550 | 934 | if (sasl_client_io_instance->io_state != IO_STATE_NOT_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 935 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 936 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 937 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 938 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 939 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 940 | sasl_client_io_instance->on_bytes_received = on_bytes_received; |
Azure.IoT Build | 0:6ae2f7bca550 | 941 | sasl_client_io_instance->on_io_open_complete = on_io_open_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 942 | sasl_client_io_instance->on_io_error = on_io_error; |
Azure.IoT Build | 0:6ae2f7bca550 | 943 | sasl_client_io_instance->on_bytes_received_context = on_bytes_received_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 944 | sasl_client_io_instance->on_io_open_complete_context = on_io_open_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 945 | sasl_client_io_instance->on_io_error_context = on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 946 | sasl_client_io_instance->sasl_header_exchange_state = SASL_HEADER_EXCHANGE_IDLE; |
Azure.IoT Build | 0:6ae2f7bca550 | 947 | sasl_client_io_instance->sasl_client_negotiation_state = SASL_CLIENT_NEGOTIATION_NOT_STARTED; |
Azure.IoT Build | 0:6ae2f7bca550 | 948 | sasl_client_io_instance->header_bytes_received = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 949 | sasl_client_io_instance->io_state = IO_STATE_OPENING_UNDERLYING_IO; |
Azure.IoT Build | 0:6ae2f7bca550 | 950 | |
Azure.IoT Build | 0:6ae2f7bca550 | 951 | /* Codes_SRS_SASLCLIENTIO_01_009: [saslclientio_open shall call xio_open on the underlying_io passed to saslclientio_create.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 952 | /* Codes_SRS_SASLCLIENTIO_01_013: [saslclientio_open shall pass to xio_open a callback for receiving bytes and a state changed callback for the underlying_io state changes.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 953 | if (xio_open(sasl_client_io_instance->underlying_io, on_underlying_io_open_complete, sasl_client_io_instance, on_underlying_io_bytes_received, sasl_client_io_instance, on_underlying_io_error, sasl_client_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 954 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 955 | /* Codes_SRS_SASLCLIENTIO_01_012: [If the open of the underlying_io fails, saslclientio_open shall fail and return non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 956 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 957 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 958 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 959 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 960 | /* Codes_SRS_SASLCLIENTIO_01_010: [On success, saslclientio_open shall return 0.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 961 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 962 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 963 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 964 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 965 | |
Azure.IoT Build | 0:6ae2f7bca550 | 966 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 967 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 968 | |
Azure.IoT Build | 0:6ae2f7bca550 | 969 | int saslclientio_close(CONCRETE_IO_HANDLE sasl_client_io, ON_IO_CLOSE_COMPLETE on_io_close_complete, void* on_io_close_complete_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 970 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 971 | int result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 972 | |
Azure.IoT Build | 0:6ae2f7bca550 | 973 | /* Codes_SRS_SASLCLIENTIO_01_017: [If sasl_client_io is NULL, saslclientio_close shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 974 | if (sasl_client_io == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 975 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 976 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 977 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 978 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 979 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 980 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 981 | |
Azure.IoT Build | 0:6ae2f7bca550 | 982 | /* Codes_SRS_SASLCLIENTIO_01_098: [saslclientio_close shall only perform the close if the state is OPEN, OPENING or ERROR.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 983 | if ((sasl_client_io_instance->io_state == IO_STATE_NOT_OPEN) || |
Azure.IoT Build | 0:6ae2f7bca550 | 984 | (sasl_client_io_instance->io_state == IO_STATE_CLOSING)) |
Azure.IoT Build | 0:6ae2f7bca550 | 985 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 986 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 987 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 988 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 989 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 990 | sasl_client_io_instance->io_state = IO_STATE_CLOSING; |
Azure.IoT Build | 0:6ae2f7bca550 | 991 | |
Azure.IoT Build | 0:6ae2f7bca550 | 992 | sasl_client_io_instance->on_io_close_complete = on_io_close_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 993 | sasl_client_io_instance->on_io_close_complete_context = on_io_close_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 994 | |
Azure.IoT Build | 0:6ae2f7bca550 | 995 | /* Codes_SRS_SASLCLIENTIO_01_015: [saslclientio_close shall close the underlying io handle passed in saslclientio_create by calling xio_close.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 996 | if (xio_close(sasl_client_io_instance->underlying_io, on_underlying_io_close_complete, sasl_client_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 997 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 998 | /* Codes_SRS_SASLCLIENTIO_01_018: [If xio_close fails, then saslclientio_close shall return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 999 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 1000 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1001 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 1002 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1003 | /* Codes_SRS_SASLCLIENTIO_01_016: [On success, saslclientio_close shall return 0.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1004 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 1005 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1006 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1007 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1008 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1009 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 1010 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1011 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1012 | int saslclientio_send(CONCRETE_IO_HANDLE sasl_client_io, const void* buffer, size_t size, ON_SEND_COMPLETE on_send_complete, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 1013 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1014 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 1015 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1016 | /* Codes_SRS_SASLCLIENTIO_01_022: [If the saslio or buffer argument is NULL, saslclientio_send shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1017 | if ((sasl_client_io == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 1018 | (buffer == NULL) || |
Azure.IoT Build | 0:6ae2f7bca550 | 1019 | /* Codes_SRS_SASLCLIENTIO_01_023: [If size is 0, saslclientio_send shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1020 | (size == 0)) |
Azure.IoT Build | 0:6ae2f7bca550 | 1021 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1022 | /* Invalid arguments */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1023 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 1024 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1025 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 1026 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1027 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 1028 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1029 | /* Codes_SRS_SASLCLIENTIO_01_019: [If saslclientio_send is called while the SASL client IO state is not IO_STATE_OPEN, saslclientio_send shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1030 | if (sasl_client_io_instance->io_state != IO_STATE_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 1031 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1032 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 1033 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1034 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 1035 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1036 | /* Codes_SRS_SASLCLIENTIO_01_020: [If the SASL client IO state is IO_STATE_OPEN, saslclientio_send shall call xio_send on the underlying_io passed to saslclientio_create, while passing as arguments the buffer, size, on_send_complete and callback_context.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1037 | if (xio_send(sasl_client_io_instance->underlying_io, buffer, size, on_send_complete, callback_context) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 1038 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1039 | /* Codes_SRS_SASLCLIENTIO_01_024: [If the call to xio_send fails, then saslclientio_send shall fail and return a non-zero value.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1040 | result = __LINE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 1041 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1042 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 1043 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1044 | /* Codes_SRS_SASLCLIENTIO_01_021: [On success, saslclientio_send shall return 0.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1045 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 1046 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1047 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1048 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1049 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1050 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 1051 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1052 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1053 | void saslclientio_dowork(CONCRETE_IO_HANDLE sasl_client_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 1054 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1055 | /* Codes_SRS_SASLCLIENTIO_01_026: [If the sasl_client_io argument is NULL, saslclientio_dowork shall do nothing.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1056 | if (sasl_client_io != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 1057 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1058 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 1059 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1060 | /* Codes_SRS_SASLCLIENTIO_01_025: [saslclientio_dowork shall call the xio_dowork on the underlying_io passed in saslclientio_create.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1061 | if (sasl_client_io_instance->io_state != IO_STATE_NOT_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 1062 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1063 | /* Codes_SRS_SASLCLIENTIO_01_025: [saslclientio_dowork shall call the xio_dowork on the underlying_io passed in saslclientio_create.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1064 | xio_dowork(sasl_client_io_instance->underlying_io); |
Azure.IoT Build | 0:6ae2f7bca550 | 1065 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1066 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1067 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1068 | |
AzureIoTClient | 1:eab586236bfe | 1069 | /* Codes_SRS_SASLCLIENTIO_03_001: [saslclientio_setoption shall forward options to underlying io.]*/ |
AzureIoTClient | 1:eab586236bfe | 1070 | int saslclientio_setoption(CONCRETE_IO_HANDLE sasl_client_io, const char* optionName, const void* value) |
Azure.IoT Build | 0:6ae2f7bca550 | 1071 | { |
AzureIoTClient | 1:eab586236bfe | 1072 | int result; |
AzureIoTClient | 1:eab586236bfe | 1073 | |
AzureIoTClient | 1:eab586236bfe | 1074 | if (sasl_client_io == NULL) |
AzureIoTClient | 1:eab586236bfe | 1075 | { |
AzureIoTClient | 1:eab586236bfe | 1076 | result = __LINE__; |
AzureIoTClient | 1:eab586236bfe | 1077 | } |
AzureIoTClient | 1:eab586236bfe | 1078 | else |
AzureIoTClient | 1:eab586236bfe | 1079 | { |
AzureIoTClient | 1:eab586236bfe | 1080 | SASL_CLIENT_IO_INSTANCE* sasl_client_io_instance = (SASL_CLIENT_IO_INSTANCE*)sasl_client_io; |
AzureIoTClient | 1:eab586236bfe | 1081 | |
AzureIoTClient | 1:eab586236bfe | 1082 | if (sasl_client_io_instance->underlying_io == NULL) |
AzureIoTClient | 1:eab586236bfe | 1083 | { |
AzureIoTClient | 1:eab586236bfe | 1084 | result = __LINE__; |
AzureIoTClient | 1:eab586236bfe | 1085 | } |
AzureIoTClient | 1:eab586236bfe | 1086 | else |
AzureIoTClient | 1:eab586236bfe | 1087 | { |
AzureIoTClient | 1:eab586236bfe | 1088 | result = xio_setoption(sasl_client_io_instance->underlying_io, optionName, value); |
AzureIoTClient | 1:eab586236bfe | 1089 | } |
AzureIoTClient | 1:eab586236bfe | 1090 | } |
AzureIoTClient | 1:eab586236bfe | 1091 | |
AzureIoTClient | 1:eab586236bfe | 1092 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 1093 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 1094 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1095 | static const IO_INTERFACE_DESCRIPTION sasl_client_io_interface_description = |
Azure.IoT Build | 0:6ae2f7bca550 | 1096 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1097 | saslclientio_create, |
Azure.IoT Build | 0:6ae2f7bca550 | 1098 | saslclientio_destroy, |
Azure.IoT Build | 0:6ae2f7bca550 | 1099 | saslclientio_open, |
Azure.IoT Build | 0:6ae2f7bca550 | 1100 | saslclientio_close, |
Azure.IoT Build | 0:6ae2f7bca550 | 1101 | saslclientio_send, |
Azure.IoT Build | 0:6ae2f7bca550 | 1102 | saslclientio_dowork, |
Azure.IoT Build | 0:6ae2f7bca550 | 1103 | saslclientio_setoption |
Azure.IoT Build | 0:6ae2f7bca550 | 1104 | }; |
Azure.IoT Build | 0:6ae2f7bca550 | 1105 | |
Azure.IoT Build | 0:6ae2f7bca550 | 1106 | /* Codes_SRS_SASLCLIENTIO_01_087: [saslclientio_get_interface_description shall return a pointer to an IO_INTERFACE_DESCRIPTION structure that contains pointers to the functions: saslclientio_create, saslclientio_destroy, saslclientio_open, saslclientio_close, saslclientio_send and saslclientio_dowork.] */ |
Azure.IoT Build | 0:6ae2f7bca550 | 1107 | const IO_INTERFACE_DESCRIPTION* saslclientio_get_interface_description(void) |
Azure.IoT Build | 0:6ae2f7bca550 | 1108 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 1109 | return &sasl_client_io_interface_description; |
Azure.IoT Build | 0:6ae2f7bca550 | 1110 | } |