A small memory footprint AMQP implimentation
Dependents: iothub_client_sample_amqp remote_monitoring simplesample_amqp
header_detect_io.c@21:f9c433d8e6ca, 2017-03-24 (annotated)
- Committer:
- AzureIoTClient
- Date:
- Fri Mar 24 16:35:45 2017 -0700
- Revision:
- 21:f9c433d8e6ca
- Parent:
- 19:000ab4e6a2c1
- Child:
- 27:d74f1cea23e1
1.1.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 | |
AzureIoTClient | 21:f9c433d8e6ca | 4 | #include <stdlib.h> |
AzureIoTClient | 19:000ab4e6a2c1 | 5 | #include "azure_c_shared_utility/optimize_size.h" |
AzureIoTClient | 21:f9c433d8e6ca | 6 | #include "azure_c_shared_utility/gballoc.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 7 | #include "azure_uamqp_c/header_detect_io.h" |
Azure.IoT Build | 0:6ae2f7bca550 | 8 | |
Azure.IoT Build | 0:6ae2f7bca550 | 9 | typedef enum IO_STATE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 10 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 11 | IO_STATE_NOT_OPEN, |
Azure.IoT Build | 0:6ae2f7bca550 | 12 | IO_STATE_OPENING_UNDERLYING_IO, |
Azure.IoT Build | 0:6ae2f7bca550 | 13 | IO_STATE_WAIT_FOR_HEADER, |
Azure.IoT Build | 0:6ae2f7bca550 | 14 | IO_STATE_OPEN, |
Azure.IoT Build | 0:6ae2f7bca550 | 15 | IO_STATE_CLOSING, |
Azure.IoT Build | 0:6ae2f7bca550 | 16 | IO_STATE_ERROR |
Azure.IoT Build | 0:6ae2f7bca550 | 17 | } IO_STATE; |
Azure.IoT Build | 0:6ae2f7bca550 | 18 | |
Azure.IoT Build | 0:6ae2f7bca550 | 19 | typedef struct HEADER_DETECT_IO_INSTANCE_TAG |
Azure.IoT Build | 0:6ae2f7bca550 | 20 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 21 | XIO_HANDLE underlying_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 22 | size_t header_pos; |
Azure.IoT Build | 0:6ae2f7bca550 | 23 | IO_STATE io_state; |
Azure.IoT Build | 0:6ae2f7bca550 | 24 | ON_IO_OPEN_COMPLETE on_io_open_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 25 | ON_IO_CLOSE_COMPLETE on_io_close_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 26 | ON_IO_ERROR on_io_error; |
Azure.IoT Build | 0:6ae2f7bca550 | 27 | ON_BYTES_RECEIVED on_bytes_received; |
Azure.IoT Build | 0:6ae2f7bca550 | 28 | void* on_io_open_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 29 | void* on_io_close_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 30 | void* on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 31 | void* on_bytes_received_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 32 | } HEADER_DETECT_IO_INSTANCE; |
Azure.IoT Build | 0:6ae2f7bca550 | 33 | |
Azure.IoT Build | 0:6ae2f7bca550 | 34 | static const unsigned char amqp_header[] = { 'A', 'M', 'Q', 'P', 0, 1, 0, 0 }; |
Azure.IoT Build | 0:6ae2f7bca550 | 35 | |
Azure.IoT Build | 0:6ae2f7bca550 | 36 | static void indicate_error(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 37 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 38 | if (header_detect_io_instance->on_io_error != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 39 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 40 | header_detect_io_instance->on_io_error(header_detect_io_instance->on_io_error_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 41 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 42 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 43 | |
Azure.IoT Build | 0:6ae2f7bca550 | 44 | static void indicate_open_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 45 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 46 | if (header_detect_io_instance->on_io_open_complete != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 47 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 48 | header_detect_io_instance->on_io_open_complete(header_detect_io_instance->on_io_open_complete_context, open_result); |
Azure.IoT Build | 0:6ae2f7bca550 | 49 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 50 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 51 | |
Azure.IoT Build | 0:6ae2f7bca550 | 52 | static void indicate_close_complete(HEADER_DETECT_IO_INSTANCE* header_detect_io_instance) |
Azure.IoT Build | 0:6ae2f7bca550 | 53 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 54 | if (header_detect_io_instance->on_io_close_complete != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 55 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 56 | header_detect_io_instance->on_io_close_complete(header_detect_io_instance->on_io_close_complete_context); |
Azure.IoT Build | 0:6ae2f7bca550 | 57 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 58 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 59 | |
Azure.IoT Build | 0:6ae2f7bca550 | 60 | static void on_underlying_io_error(void* context); |
Azure.IoT Build | 0:6ae2f7bca550 | 61 | static void on_send_complete_close(void* context, IO_SEND_RESULT send_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 62 | { |
AzureIoTClient | 6:641a9672db08 | 63 | (void)send_result; |
Azure.IoT Build | 0:6ae2f7bca550 | 64 | on_underlying_io_error(context); |
Azure.IoT Build | 0:6ae2f7bca550 | 65 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 66 | |
Azure.IoT Build | 0:6ae2f7bca550 | 67 | static void on_underlying_io_bytes_received(void* context, const unsigned char* buffer, size_t size) |
Azure.IoT Build | 0:6ae2f7bca550 | 68 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 69 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 70 | |
Azure.IoT Build | 0:6ae2f7bca550 | 71 | while (size > 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 72 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 73 | switch (header_detect_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 74 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 75 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 76 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 77 | |
Azure.IoT Build | 0:6ae2f7bca550 | 78 | case IO_STATE_WAIT_FOR_HEADER: |
Azure.IoT Build | 0:6ae2f7bca550 | 79 | if (amqp_header[header_detect_io_instance->header_pos] != buffer[0]) |
Azure.IoT Build | 0:6ae2f7bca550 | 80 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 81 | /* Send expected header, then close as per spec. We do not care if we fail */ |
Azure.IoT Build | 0:6ae2f7bca550 | 82 | (void)xio_send(header_detect_io_instance->underlying_io, amqp_header, sizeof(amqp_header), on_send_complete_close, context); |
Azure.IoT Build | 0:6ae2f7bca550 | 83 | |
Azure.IoT Build | 0:6ae2f7bca550 | 84 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 85 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 86 | size = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 87 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 88 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 89 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 90 | header_detect_io_instance->header_pos++; |
Azure.IoT Build | 0:6ae2f7bca550 | 91 | size--; |
Azure.IoT Build | 0:6ae2f7bca550 | 92 | buffer++; |
Azure.IoT Build | 0:6ae2f7bca550 | 93 | if (header_detect_io_instance->header_pos == sizeof(amqp_header)) |
Azure.IoT Build | 0:6ae2f7bca550 | 94 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 95 | if (xio_send(header_detect_io_instance->underlying_io, amqp_header, sizeof(amqp_header), NULL, NULL) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 96 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 97 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 98 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 99 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 100 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 101 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 102 | header_detect_io_instance->io_state = IO_STATE_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 103 | indicate_open_complete(header_detect_io_instance, IO_OPEN_OK); |
Azure.IoT Build | 0:6ae2f7bca550 | 104 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 105 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 106 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 107 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 108 | |
Azure.IoT Build | 0:6ae2f7bca550 | 109 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 110 | header_detect_io_instance->on_bytes_received(header_detect_io_instance->on_bytes_received_context, buffer, size); |
Azure.IoT Build | 0:6ae2f7bca550 | 111 | size = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 112 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 113 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 114 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 115 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 116 | |
Azure.IoT Build | 0:6ae2f7bca550 | 117 | static void on_underlying_io_close_complete(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 118 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 119 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 120 | |
Azure.IoT Build | 0:6ae2f7bca550 | 121 | switch (header_detect_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 122 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 123 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 124 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 125 | |
Azure.IoT Build | 0:6ae2f7bca550 | 126 | case IO_STATE_CLOSING: |
Azure.IoT Build | 0:6ae2f7bca550 | 127 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 128 | indicate_close_complete(header_detect_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 129 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 130 | |
Azure.IoT Build | 0:6ae2f7bca550 | 131 | case IO_STATE_WAIT_FOR_HEADER: |
Azure.IoT Build | 0:6ae2f7bca550 | 132 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 133 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 134 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 135 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 136 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 137 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 138 | |
Azure.IoT Build | 0:6ae2f7bca550 | 139 | static void on_underlying_io_open_complete(void* context, IO_OPEN_RESULT open_result) |
Azure.IoT Build | 0:6ae2f7bca550 | 140 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 141 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 142 | |
Azure.IoT Build | 0:6ae2f7bca550 | 143 | switch (header_detect_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 144 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 145 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 146 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 147 | |
Azure.IoT Build | 0:6ae2f7bca550 | 148 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 149 | if (open_result == IO_OPEN_OK) |
Azure.IoT Build | 0:6ae2f7bca550 | 150 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 151 | header_detect_io_instance->io_state = IO_STATE_WAIT_FOR_HEADER; |
Azure.IoT Build | 0:6ae2f7bca550 | 152 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 153 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 154 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 155 | if (xio_close(header_detect_io_instance->underlying_io, on_underlying_io_close_complete, header_detect_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 156 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 157 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 158 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 159 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 160 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 161 | |
Azure.IoT Build | 0:6ae2f7bca550 | 162 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 163 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 164 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 165 | |
Azure.IoT Build | 0:6ae2f7bca550 | 166 | static void on_underlying_io_error(void* context) |
Azure.IoT Build | 0:6ae2f7bca550 | 167 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 168 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)context; |
Azure.IoT Build | 0:6ae2f7bca550 | 169 | |
Azure.IoT Build | 0:6ae2f7bca550 | 170 | switch (header_detect_io_instance->io_state) |
Azure.IoT Build | 0:6ae2f7bca550 | 171 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 172 | default: |
Azure.IoT Build | 0:6ae2f7bca550 | 173 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 174 | |
Azure.IoT Build | 0:6ae2f7bca550 | 175 | case IO_STATE_WAIT_FOR_HEADER: |
Azure.IoT Build | 0:6ae2f7bca550 | 176 | case IO_STATE_OPENING_UNDERLYING_IO: |
Azure.IoT Build | 0:6ae2f7bca550 | 177 | header_detect_io_instance->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 178 | indicate_open_complete(header_detect_io_instance, IO_OPEN_ERROR); |
Azure.IoT Build | 0:6ae2f7bca550 | 179 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 180 | |
Azure.IoT Build | 0:6ae2f7bca550 | 181 | case IO_STATE_OPEN: |
Azure.IoT Build | 0:6ae2f7bca550 | 182 | header_detect_io_instance->io_state = IO_STATE_ERROR; |
Azure.IoT Build | 0:6ae2f7bca550 | 183 | indicate_error(header_detect_io_instance); |
Azure.IoT Build | 0:6ae2f7bca550 | 184 | break; |
Azure.IoT Build | 0:6ae2f7bca550 | 185 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 186 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 187 | |
Azure.IoT Build | 5:ae49385aff34 | 188 | CONCRETE_IO_HANDLE headerdetectio_create(void* io_create_parameters) |
Azure.IoT Build | 0:6ae2f7bca550 | 189 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 190 | HEADER_DETECT_IO_INSTANCE* result; |
Azure.IoT Build | 0:6ae2f7bca550 | 191 | |
Azure.IoT Build | 0:6ae2f7bca550 | 192 | if (io_create_parameters == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 193 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 194 | result = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 195 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 196 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 197 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 198 | HEADERDETECTIO_CONFIG* header_detect_io_config = (HEADERDETECTIO_CONFIG*)io_create_parameters; |
AzureIoTClient | 21:f9c433d8e6ca | 199 | result = (HEADER_DETECT_IO_INSTANCE*)malloc(sizeof(HEADER_DETECT_IO_INSTANCE)); |
Azure.IoT Build | 0:6ae2f7bca550 | 200 | if (result != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 201 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 202 | result->underlying_io = header_detect_io_config->underlying_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 203 | result->on_io_open_complete = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 204 | result->on_io_close_complete = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 205 | result->on_io_error = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 206 | result->on_bytes_received = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 207 | result->on_io_open_complete_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 208 | result->on_io_close_complete_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 209 | result->on_io_error_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 210 | result->on_bytes_received_context = NULL; |
Azure.IoT Build | 0:6ae2f7bca550 | 211 | |
Azure.IoT Build | 0:6ae2f7bca550 | 212 | result->io_state = IO_STATE_NOT_OPEN; |
Azure.IoT Build | 0:6ae2f7bca550 | 213 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 214 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 215 | |
Azure.IoT Build | 0:6ae2f7bca550 | 216 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 217 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 218 | |
Azure.IoT Build | 0:6ae2f7bca550 | 219 | void headerdetectio_destroy(CONCRETE_IO_HANDLE header_detect_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 220 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 221 | if (header_detect_io != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 222 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 223 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 224 | (void)headerdetectio_close(header_detect_io, NULL, NULL); |
Azure.IoT Build | 0:6ae2f7bca550 | 225 | xio_destroy(header_detect_io_instance->underlying_io); |
AzureIoTClient | 21:f9c433d8e6ca | 226 | free(header_detect_io); |
Azure.IoT Build | 0:6ae2f7bca550 | 227 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 228 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 229 | |
Azure.IoT Build | 0:6ae2f7bca550 | 230 | int headerdetectio_open(CONCRETE_IO_HANDLE header_detect_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 | 231 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 232 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 233 | |
Azure.IoT Build | 0:6ae2f7bca550 | 234 | if (header_detect_io == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 235 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 236 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 237 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 238 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 239 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 240 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 241 | |
Azure.IoT Build | 0:6ae2f7bca550 | 242 | if (header_detect_io_instance->io_state != IO_STATE_NOT_OPEN && |
Azure.IoT Build | 0:6ae2f7bca550 | 243 | header_detect_io_instance->io_state != IO_STATE_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 244 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 245 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 246 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 247 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 248 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 249 | header_detect_io_instance->on_bytes_received = on_bytes_received; |
Azure.IoT Build | 0:6ae2f7bca550 | 250 | header_detect_io_instance->on_io_open_complete = on_io_open_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 251 | header_detect_io_instance->on_io_error = on_io_error; |
Azure.IoT Build | 0:6ae2f7bca550 | 252 | header_detect_io_instance->on_bytes_received_context = on_bytes_received_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 253 | header_detect_io_instance->on_io_open_complete_context = on_io_open_complete_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 254 | header_detect_io_instance->on_io_error_context = on_io_error_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 255 | |
Azure.IoT Build | 0:6ae2f7bca550 | 256 | if (header_detect_io_instance->io_state == IO_STATE_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 257 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 258 | indicate_open_complete(header_detect_io_instance, IO_OPEN_OK); |
Azure.IoT Build | 0:6ae2f7bca550 | 259 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 260 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 261 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 262 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 263 | header_detect_io_instance->header_pos = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 264 | header_detect_io_instance->io_state = IO_STATE_OPENING_UNDERLYING_IO; |
Azure.IoT Build | 0:6ae2f7bca550 | 265 | |
Azure.IoT Build | 0:6ae2f7bca550 | 266 | if (xio_open(header_detect_io_instance->underlying_io, on_underlying_io_open_complete, header_detect_io_instance, on_underlying_io_bytes_received, header_detect_io_instance, on_underlying_io_error, header_detect_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 267 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 268 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 269 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 270 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 271 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 272 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 273 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 274 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 275 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 276 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 277 | |
Azure.IoT Build | 0:6ae2f7bca550 | 278 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 279 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 280 | |
Azure.IoT Build | 0:6ae2f7bca550 | 281 | int headerdetectio_close(CONCRETE_IO_HANDLE header_detect_io, ON_IO_CLOSE_COMPLETE on_io_close_complete, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 282 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 283 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 284 | |
Azure.IoT Build | 0:6ae2f7bca550 | 285 | if (header_detect_io == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 286 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 287 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 288 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 289 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 290 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 291 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 292 | |
Azure.IoT Build | 0:6ae2f7bca550 | 293 | if ((header_detect_io_instance->io_state == IO_STATE_NOT_OPEN) || |
Azure.IoT Build | 0:6ae2f7bca550 | 294 | (header_detect_io_instance->io_state == IO_STATE_CLOSING)) |
Azure.IoT Build | 0:6ae2f7bca550 | 295 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 296 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 297 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 298 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 299 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 300 | header_detect_io_instance->io_state = IO_STATE_CLOSING; |
Azure.IoT Build | 0:6ae2f7bca550 | 301 | header_detect_io_instance->on_io_close_complete = on_io_close_complete; |
Azure.IoT Build | 0:6ae2f7bca550 | 302 | header_detect_io_instance->on_io_close_complete_context = callback_context; |
Azure.IoT Build | 0:6ae2f7bca550 | 303 | |
Azure.IoT Build | 0:6ae2f7bca550 | 304 | if (xio_close(header_detect_io_instance->underlying_io, on_underlying_io_close_complete, header_detect_io_instance) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 305 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 306 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 307 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 308 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 309 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 310 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 311 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 312 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 313 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 314 | |
Azure.IoT Build | 0:6ae2f7bca550 | 315 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 316 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 317 | |
Azure.IoT Build | 0:6ae2f7bca550 | 318 | int headerdetectio_send(CONCRETE_IO_HANDLE header_detect_io, const void* buffer, size_t size, ON_SEND_COMPLETE on_send_complete, void* callback_context) |
Azure.IoT Build | 0:6ae2f7bca550 | 319 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 320 | int result; |
Azure.IoT Build | 0:6ae2f7bca550 | 321 | |
Azure.IoT Build | 0:6ae2f7bca550 | 322 | if (header_detect_io == NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 323 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 324 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 325 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 326 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 327 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 328 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 329 | |
Azure.IoT Build | 0:6ae2f7bca550 | 330 | if (header_detect_io_instance->io_state != IO_STATE_OPEN) |
Azure.IoT Build | 0:6ae2f7bca550 | 331 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 332 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 333 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 334 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 335 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 336 | if (xio_send(header_detect_io_instance->underlying_io, buffer, size, on_send_complete, callback_context) != 0) |
Azure.IoT Build | 0:6ae2f7bca550 | 337 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 338 | result = __FAILURE__; |
Azure.IoT Build | 0:6ae2f7bca550 | 339 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 340 | else |
Azure.IoT Build | 0:6ae2f7bca550 | 341 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 342 | result = 0; |
Azure.IoT Build | 0:6ae2f7bca550 | 343 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 344 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 345 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 346 | |
Azure.IoT Build | 0:6ae2f7bca550 | 347 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 348 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 349 | |
Azure.IoT Build | 0:6ae2f7bca550 | 350 | void headerdetectio_dowork(CONCRETE_IO_HANDLE header_detect_io) |
Azure.IoT Build | 0:6ae2f7bca550 | 351 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 352 | if (header_detect_io != NULL) |
Azure.IoT Build | 0:6ae2f7bca550 | 353 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 354 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
Azure.IoT Build | 0:6ae2f7bca550 | 355 | |
Azure.IoT Build | 0:6ae2f7bca550 | 356 | if ((header_detect_io_instance->io_state != IO_STATE_NOT_OPEN) && |
Azure.IoT Build | 0:6ae2f7bca550 | 357 | (header_detect_io_instance->io_state != IO_STATE_ERROR)) |
Azure.IoT Build | 0:6ae2f7bca550 | 358 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 359 | xio_dowork(header_detect_io_instance->underlying_io); |
Azure.IoT Build | 0:6ae2f7bca550 | 360 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 361 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 362 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 363 | |
AzureIoTClient | 1:eab586236bfe | 364 | int headerdetectio_setoption(CONCRETE_IO_HANDLE header_detect_io, const char* optionName, const void* value) |
Azure.IoT Build | 0:6ae2f7bca550 | 365 | { |
AzureIoTClient | 1:eab586236bfe | 366 | int result; |
AzureIoTClient | 1:eab586236bfe | 367 | |
AzureIoTClient | 1:eab586236bfe | 368 | if (header_detect_io == NULL) |
AzureIoTClient | 1:eab586236bfe | 369 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 370 | result = __FAILURE__; |
AzureIoTClient | 1:eab586236bfe | 371 | } |
AzureIoTClient | 1:eab586236bfe | 372 | else |
AzureIoTClient | 1:eab586236bfe | 373 | { |
AzureIoTClient | 1:eab586236bfe | 374 | HEADER_DETECT_IO_INSTANCE* header_detect_io_instance = (HEADER_DETECT_IO_INSTANCE*)header_detect_io; |
AzureIoTClient | 1:eab586236bfe | 375 | |
AzureIoTClient | 1:eab586236bfe | 376 | if (header_detect_io_instance->underlying_io == NULL) |
AzureIoTClient | 1:eab586236bfe | 377 | { |
AzureIoTClient | 19:000ab4e6a2c1 | 378 | result = __FAILURE__; |
AzureIoTClient | 1:eab586236bfe | 379 | } |
AzureIoTClient | 1:eab586236bfe | 380 | else |
AzureIoTClient | 1:eab586236bfe | 381 | { |
AzureIoTClient | 1:eab586236bfe | 382 | result = xio_setoption(header_detect_io_instance->underlying_io, optionName, value); |
AzureIoTClient | 1:eab586236bfe | 383 | } |
AzureIoTClient | 1:eab586236bfe | 384 | } |
AzureIoTClient | 1:eab586236bfe | 385 | |
AzureIoTClient | 1:eab586236bfe | 386 | return result; |
Azure.IoT Build | 0:6ae2f7bca550 | 387 | } |
Azure.IoT Build | 0:6ae2f7bca550 | 388 | |
AzureIoTClient | 6:641a9672db08 | 389 | /*this function will clone an option given by name and value*/ |
AzureIoTClient | 6:641a9672db08 | 390 | static void* headerdetectio_CloneOption(const char* name, const void* value) |
AzureIoTClient | 6:641a9672db08 | 391 | { |
AzureIoTClient | 17:923575db8b2d | 392 | (void)name; |
AzureIoTClient | 17:923575db8b2d | 393 | (void)value; |
AzureIoTClient | 6:641a9672db08 | 394 | return NULL; |
AzureIoTClient | 6:641a9672db08 | 395 | } |
AzureIoTClient | 6:641a9672db08 | 396 | |
AzureIoTClient | 6:641a9672db08 | 397 | /*this function destroys an option previously created*/ |
AzureIoTClient | 6:641a9672db08 | 398 | static void headerdetectio_DestroyOption(const char* name, const void* value) |
AzureIoTClient | 6:641a9672db08 | 399 | { |
AzureIoTClient | 17:923575db8b2d | 400 | (void)name; |
AzureIoTClient | 17:923575db8b2d | 401 | (void)value; |
AzureIoTClient | 6:641a9672db08 | 402 | } |
AzureIoTClient | 6:641a9672db08 | 403 | |
AzureIoTClient | 6:641a9672db08 | 404 | static OPTIONHANDLER_HANDLE headerdetectio_retrieveoptions(CONCRETE_IO_HANDLE handle) |
AzureIoTClient | 6:641a9672db08 | 405 | { |
AzureIoTClient | 6:641a9672db08 | 406 | OPTIONHANDLER_HANDLE result; |
AzureIoTClient | 6:641a9672db08 | 407 | (void)handle; |
AzureIoTClient | 6:641a9672db08 | 408 | result = OptionHandler_Create(headerdetectio_CloneOption, headerdetectio_DestroyOption, headerdetectio_setoption); |
AzureIoTClient | 6:641a9672db08 | 409 | if (result == NULL) |
AzureIoTClient | 6:641a9672db08 | 410 | { |
AzureIoTClient | 6:641a9672db08 | 411 | LogError("unable to OptionHandler_Create"); |
AzureIoTClient | 6:641a9672db08 | 412 | /*return as is*/ |
AzureIoTClient | 6:641a9672db08 | 413 | } |
AzureIoTClient | 6:641a9672db08 | 414 | else |
AzureIoTClient | 6:641a9672db08 | 415 | { |
AzureIoTClient | 6:641a9672db08 | 416 | /*insert here work to add the options to "result" handle*/ |
AzureIoTClient | 6:641a9672db08 | 417 | } |
AzureIoTClient | 6:641a9672db08 | 418 | return result; |
AzureIoTClient | 6:641a9672db08 | 419 | } |
AzureIoTClient | 6:641a9672db08 | 420 | |
Azure.IoT Build | 0:6ae2f7bca550 | 421 | static const IO_INTERFACE_DESCRIPTION header_detect_io_interface_description = |
Azure.IoT Build | 0:6ae2f7bca550 | 422 | { |
AzureIoTClient | 6:641a9672db08 | 423 | headerdetectio_retrieveoptions, |
Azure.IoT Build | 0:6ae2f7bca550 | 424 | headerdetectio_create, |
Azure.IoT Build | 0:6ae2f7bca550 | 425 | headerdetectio_destroy, |
Azure.IoT Build | 0:6ae2f7bca550 | 426 | headerdetectio_open, |
Azure.IoT Build | 0:6ae2f7bca550 | 427 | headerdetectio_close, |
Azure.IoT Build | 0:6ae2f7bca550 | 428 | headerdetectio_send, |
Azure.IoT Build | 0:6ae2f7bca550 | 429 | headerdetectio_dowork, |
Azure.IoT Build | 0:6ae2f7bca550 | 430 | headerdetectio_setoption |
Azure.IoT Build | 0:6ae2f7bca550 | 431 | }; |
Azure.IoT Build | 0:6ae2f7bca550 | 432 | |
Azure.IoT Build | 0:6ae2f7bca550 | 433 | const IO_INTERFACE_DESCRIPTION* headerdetectio_get_interface_description(void) |
Azure.IoT Build | 0:6ae2f7bca550 | 434 | { |
Azure.IoT Build | 0:6ae2f7bca550 | 435 | return &header_detect_io_interface_description; |
Azure.IoT Build | 0:6ae2f7bca550 | 436 | } |