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