Mayank Gupta / Mbed OS pelion-example-frdm

Example

Dependencies:   FXAS21002 FXOS8700Q

simple-mbed-cloud-client/mbed-cloud-client/mbed-client/mbed-client-c/source/sn_grs.c@0:11cc2b7889af, 2019-11-19 (annotated)

Committer:
maygup01
Date:
Tue Nov 19 09:49:38 2019 +0000
Revision:
0:11cc2b7889af
Example

Who changed what in which revision?

UserRevisionLine numberNew contents of line
maygup01 0:11cc2b7889af 1 /*
maygup01 0:11cc2b7889af 2 * Copyright (c) 2011-2015 ARM Limited. All rights reserved.
maygup01 0:11cc2b7889af 3 * SPDX-License-Identifier: Apache-2.0
maygup01 0:11cc2b7889af 4 * Licensed under the Apache License, Version 2.0 (the License); you may
maygup01 0:11cc2b7889af 5 * not use this file except in compliance with the License.
maygup01 0:11cc2b7889af 6 * You may obtain a copy of the License at
maygup01 0:11cc2b7889af 7 *
maygup01 0:11cc2b7889af 8 * http://www.apache.org/licenses/LICENSE-2.0
maygup01 0:11cc2b7889af 9 *
maygup01 0:11cc2b7889af 10 * Unless required by applicable law or agreed to in writing, software
maygup01 0:11cc2b7889af 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
maygup01 0:11cc2b7889af 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
maygup01 0:11cc2b7889af 13 * See the License for the specific language governing permissions and
maygup01 0:11cc2b7889af 14 * limitations under the License.
maygup01 0:11cc2b7889af 15 */
maygup01 0:11cc2b7889af 16
maygup01 0:11cc2b7889af 17 /**
maygup01 0:11cc2b7889af 18 *
maygup01 0:11cc2b7889af 19 * \file sn_grs.c
maygup01 0:11cc2b7889af 20 *
maygup01 0:11cc2b7889af 21 * \brief General resource server.
maygup01 0:11cc2b7889af 22 *
maygup01 0:11cc2b7889af 23 */
maygup01 0:11cc2b7889af 24 #include <string.h>
maygup01 0:11cc2b7889af 25 #include <stdlib.h>
maygup01 0:11cc2b7889af 26 #include "ns_list.h"
maygup01 0:11cc2b7889af 27 #include "ns_types.h"
maygup01 0:11cc2b7889af 28 #include "sn_nsdl.h"
maygup01 0:11cc2b7889af 29 #include "sn_coap_header.h"
maygup01 0:11cc2b7889af 30 #include "sn_coap_protocol.h"
maygup01 0:11cc2b7889af 31 #include "source/include/sn_coap_protocol_internal.h"
maygup01 0:11cc2b7889af 32 #include "sn_nsdl_lib.h"
maygup01 0:11cc2b7889af 33 #include "sn_grs.h"
maygup01 0:11cc2b7889af 34
maygup01 0:11cc2b7889af 35 /* Defines */
maygup01 0:11cc2b7889af 36 #define WELLKNOWN_PATH_LEN 16
maygup01 0:11cc2b7889af 37 #define WELLKNOWN_PATH (".well-known/core")
maygup01 0:11cc2b7889af 38
maygup01 0:11cc2b7889af 39 /* Local static function prototypes */
maygup01 0:11cc2b7889af 40 static int8_t sn_grs_resource_info_free(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *resource_ptr);
maygup01 0:11cc2b7889af 41 static char *sn_grs_convert_uri(uint16_t *uri_len, const char *uri_ptr);
maygup01 0:11cc2b7889af 42 static int8_t sn_grs_core_request(struct nsdl_s *handle, sn_nsdl_addr_s *src_addr_ptr, sn_coap_hdr_s *coap_packet_ptr);
maygup01 0:11cc2b7889af 43 static uint8_t coap_tx_callback(uint8_t *, uint16_t, sn_nsdl_addr_s *, void *);
maygup01 0:11cc2b7889af 44 static int8_t coap_rx_callback(sn_coap_hdr_s *coap_ptr, sn_nsdl_addr_s *address_ptr, void *param);
maygup01 0:11cc2b7889af 45
maygup01 0:11cc2b7889af 46 /* Extern function prototypes */
maygup01 0:11cc2b7889af 47 extern int8_t sn_nsdl_build_registration_body(struct nsdl_s *handle, sn_coap_hdr_s *message_ptr, uint8_t updating_registeration);
maygup01 0:11cc2b7889af 48
maygup01 0:11cc2b7889af 49 /**
maygup01 0:11cc2b7889af 50 * \fn int8_t sn_grs_destroy(void)
maygup01 0:11cc2b7889af 51 * \brief This function may be used to flush GRS related stuff when a program exits.
maygup01 0:11cc2b7889af 52 * @return always 0.
maygup01 0:11cc2b7889af 53 */
maygup01 0:11cc2b7889af 54 extern int8_t sn_grs_destroy(struct grs_s *handle)
maygup01 0:11cc2b7889af 55 {
maygup01 0:11cc2b7889af 56 if( handle == NULL ){
maygup01 0:11cc2b7889af 57 return 0;
maygup01 0:11cc2b7889af 58 }
maygup01 0:11cc2b7889af 59 ns_list_foreach_safe(sn_nsdl_dynamic_resource_parameters_s, tmp, &handle->resource_root_list) {
maygup01 0:11cc2b7889af 60 ns_list_remove(&handle->resource_root_list, tmp);
maygup01 0:11cc2b7889af 61 --handle->resource_root_count;
maygup01 0:11cc2b7889af 62 sn_grs_resource_info_free(handle, tmp);
maygup01 0:11cc2b7889af 63 }
maygup01 0:11cc2b7889af 64 handle->sn_grs_free(handle);
maygup01 0:11cc2b7889af 65
maygup01 0:11cc2b7889af 66 return 0;
maygup01 0:11cc2b7889af 67 }
maygup01 0:11cc2b7889af 68
maygup01 0:11cc2b7889af 69 static uint8_t coap_tx_callback(uint8_t *data_ptr, uint16_t data_len, sn_nsdl_addr_s *address_ptr, void *param)
maygup01 0:11cc2b7889af 70 {
maygup01 0:11cc2b7889af 71 struct nsdl_s *handle = (struct nsdl_s *)param;
maygup01 0:11cc2b7889af 72
maygup01 0:11cc2b7889af 73 if (handle == NULL) {
maygup01 0:11cc2b7889af 74 return 0;
maygup01 0:11cc2b7889af 75 }
maygup01 0:11cc2b7889af 76
maygup01 0:11cc2b7889af 77 return handle->grs->sn_grs_tx_callback(handle, SN_NSDL_PROTOCOL_COAP, data_ptr, data_len, address_ptr);
maygup01 0:11cc2b7889af 78 }
maygup01 0:11cc2b7889af 79
maygup01 0:11cc2b7889af 80 static int8_t coap_rx_callback(sn_coap_hdr_s *coap_ptr, sn_nsdl_addr_s *address_ptr, void *param)
maygup01 0:11cc2b7889af 81 {
maygup01 0:11cc2b7889af 82 struct nsdl_s *handle = (struct nsdl_s *)param;
maygup01 0:11cc2b7889af 83
maygup01 0:11cc2b7889af 84 if (handle == NULL) {
maygup01 0:11cc2b7889af 85 return 0;
maygup01 0:11cc2b7889af 86 }
maygup01 0:11cc2b7889af 87
maygup01 0:11cc2b7889af 88 return handle->sn_nsdl_rx_callback(handle, coap_ptr, address_ptr);
maygup01 0:11cc2b7889af 89 }
maygup01 0:11cc2b7889af 90
maygup01 0:11cc2b7889af 91 /**
maygup01 0:11cc2b7889af 92 * \fn int8_t sn_grs_init (uint8_t (*sn_grs_tx_callback_ptr)(sn_nsdl_capab_e , uint8_t *, uint16_t,
maygup01 0:11cc2b7889af 93 * sn_nsdl_addr_s *), int8_t (*sn_grs_rx_callback_ptr)(sn_coap_hdr_s *, sn_nsdl_addr_s *), sn_nsdl_mem_s *sn_memory)
maygup01 0:11cc2b7889af 94 *
maygup01 0:11cc2b7889af 95 * \brief GRS library initialize function.
maygup01 0:11cc2b7889af 96 *
maygup01 0:11cc2b7889af 97 * This function initializes GRS and CoAP libraries.
maygup01 0:11cc2b7889af 98 *
maygup01 0:11cc2b7889af 99 * \param sn_grs_tx_callback A function pointer to a transmit callback function.
maygup01 0:11cc2b7889af 100 * \param *sn_grs_rx_callback_ptr A function pointer to a receiving callback function. If received packet is not for GRS, it will be passed to
maygup01 0:11cc2b7889af 101 * upper level (NSDL) to be proceed.
maygup01 0:11cc2b7889af 102 * \param sn_memory A pointer to a structure containing the platform specific functions for memory allocation and free.
maygup01 0:11cc2b7889af 103 *
maygup01 0:11cc2b7889af 104 * \return success = 0, failure = -1
maygup01 0:11cc2b7889af 105 *
maygup01 0:11cc2b7889af 106 */
maygup01 0:11cc2b7889af 107 extern struct grs_s *sn_grs_init(uint8_t (*sn_grs_tx_callback_ptr)(struct nsdl_s *, sn_nsdl_capab_e , uint8_t *, uint16_t,
maygup01 0:11cc2b7889af 108 sn_nsdl_addr_s *), int8_t (*sn_grs_rx_callback_ptr)(struct nsdl_s *, sn_coap_hdr_s *, sn_nsdl_addr_s *),
maygup01 0:11cc2b7889af 109 void *(*sn_grs_alloc)(uint16_t), void (*sn_grs_free)(void *))
maygup01 0:11cc2b7889af 110 {
maygup01 0:11cc2b7889af 111
maygup01 0:11cc2b7889af 112 struct grs_s *handle_ptr = NULL;
maygup01 0:11cc2b7889af 113
maygup01 0:11cc2b7889af 114 /* Check parameters */
maygup01 0:11cc2b7889af 115 if (sn_grs_alloc == NULL || sn_grs_free == NULL ||
maygup01 0:11cc2b7889af 116 sn_grs_tx_callback_ptr == NULL || sn_grs_rx_callback_ptr == NULL) {
maygup01 0:11cc2b7889af 117 return NULL;
maygup01 0:11cc2b7889af 118 }
maygup01 0:11cc2b7889af 119
maygup01 0:11cc2b7889af 120 handle_ptr = sn_grs_alloc(sizeof(struct grs_s));
maygup01 0:11cc2b7889af 121
maygup01 0:11cc2b7889af 122 if (handle_ptr == NULL) {
maygup01 0:11cc2b7889af 123 return NULL;
maygup01 0:11cc2b7889af 124 }
maygup01 0:11cc2b7889af 125
maygup01 0:11cc2b7889af 126 memset(handle_ptr, 0, sizeof(struct grs_s));
maygup01 0:11cc2b7889af 127
maygup01 0:11cc2b7889af 128 /* Allocation and free - function pointers */
maygup01 0:11cc2b7889af 129 handle_ptr->sn_grs_alloc = sn_grs_alloc;
maygup01 0:11cc2b7889af 130 handle_ptr->sn_grs_free = sn_grs_free;
maygup01 0:11cc2b7889af 131
maygup01 0:11cc2b7889af 132 /* TX callback function pointer */
maygup01 0:11cc2b7889af 133 handle_ptr->sn_grs_tx_callback = sn_grs_tx_callback_ptr;
maygup01 0:11cc2b7889af 134 handle_ptr->sn_grs_rx_callback = sn_grs_rx_callback_ptr;
maygup01 0:11cc2b7889af 135
maygup01 0:11cc2b7889af 136 /* Initialize CoAP protocol library */
maygup01 0:11cc2b7889af 137 handle_ptr->coap = sn_coap_protocol_init(sn_grs_alloc, sn_grs_free, coap_tx_callback, coap_rx_callback);
maygup01 0:11cc2b7889af 138
maygup01 0:11cc2b7889af 139 return handle_ptr;
maygup01 0:11cc2b7889af 140 }
maygup01 0:11cc2b7889af 141
maygup01 0:11cc2b7889af 142 extern sn_nsdl_dynamic_resource_parameters_s *sn_grs_get_first_resource(struct grs_s *handle)
maygup01 0:11cc2b7889af 143 {
maygup01 0:11cc2b7889af 144 if( !handle ){
maygup01 0:11cc2b7889af 145 return NULL;
maygup01 0:11cc2b7889af 146 }
maygup01 0:11cc2b7889af 147 return ns_list_get_first(&handle->resource_root_list);
maygup01 0:11cc2b7889af 148 }
maygup01 0:11cc2b7889af 149
maygup01 0:11cc2b7889af 150 extern sn_nsdl_dynamic_resource_parameters_s *sn_grs_get_next_resource(struct grs_s *handle,
maygup01 0:11cc2b7889af 151 const sn_nsdl_dynamic_resource_parameters_s *sn_grs_current_resource)
maygup01 0:11cc2b7889af 152 {
maygup01 0:11cc2b7889af 153 if( !handle || !sn_grs_current_resource ){
maygup01 0:11cc2b7889af 154 return NULL;
maygup01 0:11cc2b7889af 155 }
maygup01 0:11cc2b7889af 156 return ns_list_get_next(&handle->resource_root_list, sn_grs_current_resource);
maygup01 0:11cc2b7889af 157 }
maygup01 0:11cc2b7889af 158
maygup01 0:11cc2b7889af 159 extern int8_t sn_grs_delete_resource(struct grs_s *handle, const char *path)
maygup01 0:11cc2b7889af 160 {
maygup01 0:11cc2b7889af 161 /* Local variables */
maygup01 0:11cc2b7889af 162 sn_nsdl_dynamic_resource_parameters_s *resource_temp = NULL;
maygup01 0:11cc2b7889af 163
maygup01 0:11cc2b7889af 164 /* Search if resource found */
maygup01 0:11cc2b7889af 165 resource_temp = sn_grs_search_resource(handle, path, SN_GRS_SEARCH_METHOD);
maygup01 0:11cc2b7889af 166
maygup01 0:11cc2b7889af 167 /* If not found */
maygup01 0:11cc2b7889af 168 if (resource_temp == NULL) {
maygup01 0:11cc2b7889af 169 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 170 }
maygup01 0:11cc2b7889af 171
maygup01 0:11cc2b7889af 172 /* If found, delete it and delete also subresources, if there is any */
maygup01 0:11cc2b7889af 173 do {
maygup01 0:11cc2b7889af 174 /* Remove from list */
maygup01 0:11cc2b7889af 175 ns_list_remove(&handle->resource_root_list, resource_temp);
maygup01 0:11cc2b7889af 176 --handle->resource_root_count;
maygup01 0:11cc2b7889af 177
maygup01 0:11cc2b7889af 178 /* Free */
maygup01 0:11cc2b7889af 179 sn_grs_resource_info_free(handle, resource_temp);
maygup01 0:11cc2b7889af 180
maygup01 0:11cc2b7889af 181 /* Search for subresources */
maygup01 0:11cc2b7889af 182 resource_temp = sn_grs_search_resource(handle, path, SN_GRS_DELETE_METHOD);
maygup01 0:11cc2b7889af 183 } while (resource_temp != NULL);
maygup01 0:11cc2b7889af 184
maygup01 0:11cc2b7889af 185 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 186 }
maygup01 0:11cc2b7889af 187
maygup01 0:11cc2b7889af 188 int8_t sn_grs_put_resource(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *res)
maygup01 0:11cc2b7889af 189 {
maygup01 0:11cc2b7889af 190 if (!res || !handle) {
maygup01 0:11cc2b7889af 191 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 192 }
maygup01 0:11cc2b7889af 193
maygup01 0:11cc2b7889af 194 /* Check path validity */
maygup01 0:11cc2b7889af 195 if (!res->static_resource_parameters->path || res->static_resource_parameters->path[0] == '\0') {
maygup01 0:11cc2b7889af 196 return SN_GRS_INVALID_PATH;
maygup01 0:11cc2b7889af 197 }
maygup01 0:11cc2b7889af 198
maygup01 0:11cc2b7889af 199 /* Check if resource already exists */
maygup01 0:11cc2b7889af 200 if (sn_grs_search_resource(handle,
maygup01 0:11cc2b7889af 201 res->static_resource_parameters->path, SN_GRS_SEARCH_METHOD) != (sn_nsdl_dynamic_resource_parameters_s *)NULL) {
maygup01 0:11cc2b7889af 202 return SN_GRS_RESOURCE_ALREADY_EXISTS;
maygup01 0:11cc2b7889af 203 }
maygup01 0:11cc2b7889af 204
maygup01 0:11cc2b7889af 205 res->registered = SN_NDSL_RESOURCE_NOT_REGISTERED;
maygup01 0:11cc2b7889af 206
maygup01 0:11cc2b7889af 207 ns_list_add_to_start(&handle->resource_root_list, res);
maygup01 0:11cc2b7889af 208 ++handle->resource_root_count;
maygup01 0:11cc2b7889af 209
maygup01 0:11cc2b7889af 210 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 211 }
maygup01 0:11cc2b7889af 212
maygup01 0:11cc2b7889af 213 int8_t sn_grs_pop_resource(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *res)
maygup01 0:11cc2b7889af 214 {
maygup01 0:11cc2b7889af 215 if (!res || !handle) {
maygup01 0:11cc2b7889af 216 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 217 }
maygup01 0:11cc2b7889af 218
maygup01 0:11cc2b7889af 219 /* Check path validity */
maygup01 0:11cc2b7889af 220 if (!res->static_resource_parameters->path || res->static_resource_parameters->path[0] == '\0') {
maygup01 0:11cc2b7889af 221 return SN_GRS_INVALID_PATH;
maygup01 0:11cc2b7889af 222 }
maygup01 0:11cc2b7889af 223
maygup01 0:11cc2b7889af 224 /* Check if resource exists on list. */
maygup01 0:11cc2b7889af 225 if (sn_grs_search_resource(handle,
maygup01 0:11cc2b7889af 226 res->static_resource_parameters->path, SN_GRS_SEARCH_METHOD) == (sn_nsdl_dynamic_resource_parameters_s *)NULL) {
maygup01 0:11cc2b7889af 227 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 228 }
maygup01 0:11cc2b7889af 229
maygup01 0:11cc2b7889af 230 ns_list_remove(&handle->resource_root_list, res);
maygup01 0:11cc2b7889af 231 --handle->resource_root_count;
maygup01 0:11cc2b7889af 232
maygup01 0:11cc2b7889af 233 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 234 }
maygup01 0:11cc2b7889af 235
maygup01 0:11cc2b7889af 236 /**
maygup01 0:11cc2b7889af 237 * \fn extern int8_t sn_grs_process_coap(uint8_t *packet, uint16_t *packet_len, sn_nsdl_addr_s *src)
maygup01 0:11cc2b7889af 238 *
maygup01 0:11cc2b7889af 239 * \brief To push CoAP packet to GRS library
maygup01 0:11cc2b7889af 240 *
maygup01 0:11cc2b7889af 241 * Used to push an CoAP packet to GRS library for processing.
maygup01 0:11cc2b7889af 242 *
maygup01 0:11cc2b7889af 243 * \param *packet Pointer to a uint8_t array containing the packet (including the CoAP headers).
maygup01 0:11cc2b7889af 244 * After successful execution this array may contain the response packet.
maygup01 0:11cc2b7889af 245 *
maygup01 0:11cc2b7889af 246 * \param *packet_len Pointer to length of the packet. After successful execution this array may contain the length
maygup01 0:11cc2b7889af 247 * of the response packet.
maygup01 0:11cc2b7889af 248 *
maygup01 0:11cc2b7889af 249 * \param *src Pointer to packet source address information. After successful execution this array may contain
maygup01 0:11cc2b7889af 250 * the destination address of the response packet.
maygup01 0:11cc2b7889af 251 *
maygup01 0:11cc2b7889af 252 * \return 0 = success, -1 = failure
maygup01 0:11cc2b7889af 253 */
maygup01 0:11cc2b7889af 254 extern int8_t sn_grs_process_coap(struct nsdl_s *nsdl_handle, sn_coap_hdr_s *coap_packet_ptr, sn_nsdl_addr_s *src_addr_ptr)
maygup01 0:11cc2b7889af 255 {
maygup01 0:11cc2b7889af 256 if( !coap_packet_ptr || !nsdl_handle){
maygup01 0:11cc2b7889af 257 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 258 }
maygup01 0:11cc2b7889af 259
maygup01 0:11cc2b7889af 260 sn_nsdl_dynamic_resource_parameters_s *resource_temp_ptr = NULL;
maygup01 0:11cc2b7889af 261 sn_coap_msg_code_e status = COAP_MSG_CODE_EMPTY;
maygup01 0:11cc2b7889af 262 sn_coap_hdr_s *response_message_hdr_ptr = NULL;
maygup01 0:11cc2b7889af 263 struct grs_s *handle = nsdl_handle->grs;
maygup01 0:11cc2b7889af 264 bool static_get_request = false;
maygup01 0:11cc2b7889af 265
maygup01 0:11cc2b7889af 266 if (coap_packet_ptr->msg_code <= COAP_MSG_CODE_REQUEST_DELETE) {
maygup01 0:11cc2b7889af 267 /* Check if .well-known/core */
maygup01 0:11cc2b7889af 268 if (coap_packet_ptr->uri_path_len == WELLKNOWN_PATH_LEN && memcmp(coap_packet_ptr->uri_path_ptr, WELLKNOWN_PATH, WELLKNOWN_PATH_LEN) == 0) {
maygup01 0:11cc2b7889af 269 return sn_grs_core_request(nsdl_handle, src_addr_ptr, coap_packet_ptr);
maygup01 0:11cc2b7889af 270 }
maygup01 0:11cc2b7889af 271
maygup01 0:11cc2b7889af 272 /* Get resource */
maygup01 0:11cc2b7889af 273 char* path = nsdl_handle->grs->sn_grs_alloc(coap_packet_ptr->uri_path_len + 1);
maygup01 0:11cc2b7889af 274 if (!path) {
maygup01 0:11cc2b7889af 275 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 276 }
maygup01 0:11cc2b7889af 277
maygup01 0:11cc2b7889af 278 memcpy(path,
maygup01 0:11cc2b7889af 279 coap_packet_ptr->uri_path_ptr,
maygup01 0:11cc2b7889af 280 coap_packet_ptr->uri_path_len);
maygup01 0:11cc2b7889af 281 path[coap_packet_ptr->uri_path_len] = '\0';
maygup01 0:11cc2b7889af 282
maygup01 0:11cc2b7889af 283 resource_temp_ptr = sn_grs_search_resource(handle, path, SN_GRS_SEARCH_METHOD);
maygup01 0:11cc2b7889af 284 nsdl_handle->grs->sn_grs_free(path);
maygup01 0:11cc2b7889af 285
maygup01 0:11cc2b7889af 286 /* * * * * * * * * * * */
maygup01 0:11cc2b7889af 287 /* If resource exists */
maygup01 0:11cc2b7889af 288 /* * * * * * * * * * * */
maygup01 0:11cc2b7889af 289 if (resource_temp_ptr) {
maygup01 0:11cc2b7889af 290 /* If dynamic resource, go to callback */
maygup01 0:11cc2b7889af 291 if (resource_temp_ptr->static_resource_parameters->mode == SN_GRS_DYNAMIC) {
maygup01 0:11cc2b7889af 292 /* Check accesses */
maygup01 0:11cc2b7889af 293 if (((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_GET) && !(resource_temp_ptr->access & SN_GRS_GET_ALLOWED)) ||
maygup01 0:11cc2b7889af 294 ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) && !(resource_temp_ptr->access & SN_GRS_POST_ALLOWED)) ||
maygup01 0:11cc2b7889af 295 ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_PUT) && !(resource_temp_ptr->access & SN_GRS_PUT_ALLOWED)) ||
maygup01 0:11cc2b7889af 296 ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_DELETE) && !(resource_temp_ptr->access & SN_GRS_DELETE_ALLOWED))) {
maygup01 0:11cc2b7889af 297 status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
maygup01 0:11cc2b7889af 298 } else {
maygup01 0:11cc2b7889af 299 /* Do not call null pointer.. */
maygup01 0:11cc2b7889af 300 if (resource_temp_ptr->sn_grs_dyn_res_callback != NULL) {
maygup01 0:11cc2b7889af 301 resource_temp_ptr->sn_grs_dyn_res_callback(nsdl_handle, coap_packet_ptr, src_addr_ptr, SN_NSDL_PROTOCOL_COAP);
maygup01 0:11cc2b7889af 302 } else {
maygup01 0:11cc2b7889af 303 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 304 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 305 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 306 }
maygup01 0:11cc2b7889af 307 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 308 }
maygup01 0:11cc2b7889af 309
maygup01 0:11cc2b7889af 310 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 311 }
maygup01 0:11cc2b7889af 312 } else {
maygup01 0:11cc2b7889af 313 /* Static resource handling */
maygup01 0:11cc2b7889af 314 switch (coap_packet_ptr->msg_code) {
maygup01 0:11cc2b7889af 315 case COAP_MSG_CODE_REQUEST_GET:
maygup01 0:11cc2b7889af 316 if (resource_temp_ptr->access & SN_GRS_GET_ALLOWED) {
maygup01 0:11cc2b7889af 317 status = COAP_MSG_CODE_RESPONSE_CONTENT;
maygup01 0:11cc2b7889af 318 static_get_request = true;
maygup01 0:11cc2b7889af 319 } else {
maygup01 0:11cc2b7889af 320 status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
maygup01 0:11cc2b7889af 321 }
maygup01 0:11cc2b7889af 322 break;
maygup01 0:11cc2b7889af 323
maygup01 0:11cc2b7889af 324 case COAP_MSG_CODE_REQUEST_POST:
maygup01 0:11cc2b7889af 325 case COAP_MSG_CODE_REQUEST_PUT:
maygup01 0:11cc2b7889af 326 case COAP_MSG_CODE_REQUEST_DELETE:
maygup01 0:11cc2b7889af 327 status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
maygup01 0:11cc2b7889af 328 break;
maygup01 0:11cc2b7889af 329
maygup01 0:11cc2b7889af 330 default:
maygup01 0:11cc2b7889af 331 status = COAP_MSG_CODE_RESPONSE_FORBIDDEN;
maygup01 0:11cc2b7889af 332 break;
maygup01 0:11cc2b7889af 333 }
maygup01 0:11cc2b7889af 334 }
maygup01 0:11cc2b7889af 335 }
maygup01 0:11cc2b7889af 336
maygup01 0:11cc2b7889af 337 /* * * * * * * * * * * * * * */
maygup01 0:11cc2b7889af 338 /* If resource was not found */
maygup01 0:11cc2b7889af 339 /* * * * * * * * * * * * * * */
maygup01 0:11cc2b7889af 340
maygup01 0:11cc2b7889af 341 else {
maygup01 0:11cc2b7889af 342 if (coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) {
maygup01 0:11cc2b7889af 343 handle->sn_grs_rx_callback(nsdl_handle, coap_packet_ptr, src_addr_ptr);
maygup01 0:11cc2b7889af 344
maygup01 0:11cc2b7889af 345 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 346 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 347 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 348 }
maygup01 0:11cc2b7889af 349
maygup01 0:11cc2b7889af 350 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 351 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 352 } else {
maygup01 0:11cc2b7889af 353 status = COAP_MSG_CODE_RESPONSE_NOT_FOUND;
maygup01 0:11cc2b7889af 354 }
maygup01 0:11cc2b7889af 355 }
maygup01 0:11cc2b7889af 356 }
maygup01 0:11cc2b7889af 357
maygup01 0:11cc2b7889af 358 /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
maygup01 0:11cc2b7889af 359 /* If received packed was other than reset, create response */
maygup01 0:11cc2b7889af 360 /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */
maygup01 0:11cc2b7889af 361 if (coap_packet_ptr->msg_type != COAP_MSG_TYPE_RESET && coap_packet_ptr->msg_type != COAP_MSG_TYPE_ACKNOWLEDGEMENT) {
maygup01 0:11cc2b7889af 362
maygup01 0:11cc2b7889af 363 /* Allocate resopnse message */
maygup01 0:11cc2b7889af 364 response_message_hdr_ptr = sn_coap_parser_alloc_message(handle->coap);
maygup01 0:11cc2b7889af 365 if (!response_message_hdr_ptr) {
maygup01 0:11cc2b7889af 366 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 367 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 368 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 369 }
maygup01 0:11cc2b7889af 370 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 371 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 372 }
maygup01 0:11cc2b7889af 373
maygup01 0:11cc2b7889af 374 /* If status has not been defined, response internal server error */
maygup01 0:11cc2b7889af 375 if (status == COAP_MSG_CODE_EMPTY) {
maygup01 0:11cc2b7889af 376 status = COAP_MSG_CODE_RESPONSE_INTERNAL_SERVER_ERROR;
maygup01 0:11cc2b7889af 377 }
maygup01 0:11cc2b7889af 378
maygup01 0:11cc2b7889af 379 /* Fill header */
maygup01 0:11cc2b7889af 380 response_message_hdr_ptr->msg_code = status;
maygup01 0:11cc2b7889af 381
maygup01 0:11cc2b7889af 382 if (coap_packet_ptr->msg_type == COAP_MSG_TYPE_CONFIRMABLE) {
maygup01 0:11cc2b7889af 383 response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_ACKNOWLEDGEMENT;
maygup01 0:11cc2b7889af 384 } else {
maygup01 0:11cc2b7889af 385 response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_NON_CONFIRMABLE;
maygup01 0:11cc2b7889af 386 }
maygup01 0:11cc2b7889af 387
maygup01 0:11cc2b7889af 388 response_message_hdr_ptr->msg_id = coap_packet_ptr->msg_id;
maygup01 0:11cc2b7889af 389
maygup01 0:11cc2b7889af 390 if (coap_packet_ptr->token_ptr) {
maygup01 0:11cc2b7889af 391 response_message_hdr_ptr->token_len = coap_packet_ptr->token_len;
maygup01 0:11cc2b7889af 392 response_message_hdr_ptr->token_ptr = handle->sn_grs_alloc(response_message_hdr_ptr->token_len);
maygup01 0:11cc2b7889af 393 if (!response_message_hdr_ptr->token_ptr) {
maygup01 0:11cc2b7889af 394 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 395
maygup01 0:11cc2b7889af 396 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 397 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 398 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 399 }
maygup01 0:11cc2b7889af 400
maygup01 0:11cc2b7889af 401 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 402 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 403 }
maygup01 0:11cc2b7889af 404 memcpy(response_message_hdr_ptr->token_ptr, coap_packet_ptr->token_ptr, response_message_hdr_ptr->token_len);
maygup01 0:11cc2b7889af 405 }
maygup01 0:11cc2b7889af 406
maygup01 0:11cc2b7889af 407 if (status == COAP_MSG_CODE_RESPONSE_CONTENT) {
maygup01 0:11cc2b7889af 408 /* Add content type if other than default */
maygup01 0:11cc2b7889af 409 if (resource_temp_ptr->static_resource_parameters) {
maygup01 0:11cc2b7889af 410 response_message_hdr_ptr->content_format =
maygup01 0:11cc2b7889af 411 (sn_coap_content_format_e) resource_temp_ptr->coap_content_type;
maygup01 0:11cc2b7889af 412 }
maygup01 0:11cc2b7889af 413
maygup01 0:11cc2b7889af 414 /* Add payload */
maygup01 0:11cc2b7889af 415 if (resource_temp_ptr->resource_len != 0) {
maygup01 0:11cc2b7889af 416 response_message_hdr_ptr->payload_len = resource_temp_ptr->resource_len;
maygup01 0:11cc2b7889af 417 response_message_hdr_ptr->payload_ptr = handle->sn_grs_alloc(response_message_hdr_ptr->payload_len);
maygup01 0:11cc2b7889af 418
maygup01 0:11cc2b7889af 419 if (!response_message_hdr_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 420 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 421
maygup01 0:11cc2b7889af 422 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 423 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 424 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 425 }
maygup01 0:11cc2b7889af 426
maygup01 0:11cc2b7889af 427 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 428 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 429 }
maygup01 0:11cc2b7889af 430
maygup01 0:11cc2b7889af 431 memcpy(response_message_hdr_ptr->payload_ptr,
maygup01 0:11cc2b7889af 432 resource_temp_ptr->resource,
maygup01 0:11cc2b7889af 433 response_message_hdr_ptr->payload_len);
maygup01 0:11cc2b7889af 434 }
maygup01 0:11cc2b7889af 435 // Add max-age attribute for static resources.
maygup01 0:11cc2b7889af 436 // Not a mandatory parameter, no need to return in case of memory allocation fails.
maygup01 0:11cc2b7889af 437 if (static_get_request) {
maygup01 0:11cc2b7889af 438 if (sn_coap_parser_alloc_options(handle->coap, response_message_hdr_ptr)) {
maygup01 0:11cc2b7889af 439 response_message_hdr_ptr->options_list_ptr->max_age = 0;
maygup01 0:11cc2b7889af 440 }
maygup01 0:11cc2b7889af 441 }
maygup01 0:11cc2b7889af 442 }
maygup01 0:11cc2b7889af 443 sn_grs_send_coap_message(nsdl_handle, src_addr_ptr, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 444
maygup01 0:11cc2b7889af 445 if (response_message_hdr_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 446 handle->sn_grs_free(response_message_hdr_ptr->payload_ptr);
maygup01 0:11cc2b7889af 447 response_message_hdr_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 448 }
maygup01 0:11cc2b7889af 449 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 450 }
maygup01 0:11cc2b7889af 451
maygup01 0:11cc2b7889af 452 /* Free parsed CoAP message */
maygup01 0:11cc2b7889af 453 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 454 handle->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 455 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 456 }
maygup01 0:11cc2b7889af 457 sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 458
maygup01 0:11cc2b7889af 459 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 460 }
maygup01 0:11cc2b7889af 461
maygup01 0:11cc2b7889af 462 extern int8_t sn_grs_send_coap_message(struct nsdl_s *handle, sn_nsdl_addr_s *address_ptr, sn_coap_hdr_s *coap_hdr_ptr)
maygup01 0:11cc2b7889af 463 {
maygup01 0:11cc2b7889af 464 uint8_t *message_ptr = NULL;
maygup01 0:11cc2b7889af 465 uint16_t message_len = 0;
maygup01 0:11cc2b7889af 466 int16_t ret_val = 0;
maygup01 0:11cc2b7889af 467
maygup01 0:11cc2b7889af 468 if( !handle ){
maygup01 0:11cc2b7889af 469 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 470 }
maygup01 0:11cc2b7889af 471
maygup01 0:11cc2b7889af 472 #if SN_COAP_MAX_BLOCKWISE_PAYLOAD_SIZE /* If Message blockwising is not used at all, this part of code will not be compiled */
maygup01 0:11cc2b7889af 473 ret_val = prepare_blockwise_message(handle->grs->coap, coap_hdr_ptr);
maygup01 0:11cc2b7889af 474 if( 0 != ret_val ) {
maygup01 0:11cc2b7889af 475 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 476 }
maygup01 0:11cc2b7889af 477 #endif
maygup01 0:11cc2b7889af 478
maygup01 0:11cc2b7889af 479 /* Calculate message length */
maygup01 0:11cc2b7889af 480 message_len = sn_coap_builder_calc_needed_packet_data_size_2(coap_hdr_ptr, handle->grs->coap->sn_coap_block_data_size);
maygup01 0:11cc2b7889af 481
maygup01 0:11cc2b7889af 482 /* Allocate memory for message and check was allocating successfully */
maygup01 0:11cc2b7889af 483 message_ptr = handle->grs->sn_grs_alloc(message_len);
maygup01 0:11cc2b7889af 484 if (message_ptr == NULL) {
maygup01 0:11cc2b7889af 485 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 486 }
maygup01 0:11cc2b7889af 487
maygup01 0:11cc2b7889af 488 /* Build CoAP message */
maygup01 0:11cc2b7889af 489 ret_val = sn_coap_protocol_build(handle->grs->coap, address_ptr, message_ptr, coap_hdr_ptr, (void *)handle);
maygup01 0:11cc2b7889af 490 if (ret_val < 0) {
maygup01 0:11cc2b7889af 491 handle->grs->sn_grs_free(message_ptr);
maygup01 0:11cc2b7889af 492 message_ptr = 0;
maygup01 0:11cc2b7889af 493 if (ret_val == -4) {
maygup01 0:11cc2b7889af 494 return SN_NSDL_RESEND_QUEUE_FULL;
maygup01 0:11cc2b7889af 495 } else {
maygup01 0:11cc2b7889af 496 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 497 }
maygup01 0:11cc2b7889af 498 }
maygup01 0:11cc2b7889af 499
maygup01 0:11cc2b7889af 500 /* Call tx callback function to send message */
maygup01 0:11cc2b7889af 501 ret_val = handle->grs->sn_grs_tx_callback(handle, SN_NSDL_PROTOCOL_COAP, message_ptr, message_len, address_ptr);
maygup01 0:11cc2b7889af 502
maygup01 0:11cc2b7889af 503 /* Free allocated memory */
maygup01 0:11cc2b7889af 504 handle->grs->sn_grs_free(message_ptr);
maygup01 0:11cc2b7889af 505 message_ptr = 0;
maygup01 0:11cc2b7889af 506
maygup01 0:11cc2b7889af 507 if (ret_val == 0) {
maygup01 0:11cc2b7889af 508 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 509 } else {
maygup01 0:11cc2b7889af 510 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 511 }
maygup01 0:11cc2b7889af 512 }
maygup01 0:11cc2b7889af 513
maygup01 0:11cc2b7889af 514 static int8_t sn_grs_core_request(struct nsdl_s *handle, sn_nsdl_addr_s *src_addr_ptr, sn_coap_hdr_s *coap_packet_ptr)
maygup01 0:11cc2b7889af 515 {
maygup01 0:11cc2b7889af 516 sn_coap_hdr_s *response_message_hdr_ptr = NULL;
maygup01 0:11cc2b7889af 517 sn_coap_content_format_e wellknown_content_format = COAP_CT_LINK_FORMAT;
maygup01 0:11cc2b7889af 518
maygup01 0:11cc2b7889af 519 /* Allocate response message */
maygup01 0:11cc2b7889af 520 response_message_hdr_ptr = sn_coap_parser_alloc_message(handle->grs->coap);
maygup01 0:11cc2b7889af 521 if (response_message_hdr_ptr == NULL) {
maygup01 0:11cc2b7889af 522 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 523 handle->grs->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 524 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 525 }
maygup01 0:11cc2b7889af 526 sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 527 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 528 }
maygup01 0:11cc2b7889af 529
maygup01 0:11cc2b7889af 530 /* Build response */
maygup01 0:11cc2b7889af 531 response_message_hdr_ptr->msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
maygup01 0:11cc2b7889af 532 response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_ACKNOWLEDGEMENT;
maygup01 0:11cc2b7889af 533 response_message_hdr_ptr->msg_id = coap_packet_ptr->msg_id;
maygup01 0:11cc2b7889af 534 response_message_hdr_ptr->content_format = wellknown_content_format;
maygup01 0:11cc2b7889af 535
maygup01 0:11cc2b7889af 536 sn_nsdl_build_registration_body(handle, response_message_hdr_ptr, 0);
maygup01 0:11cc2b7889af 537
maygup01 0:11cc2b7889af 538 /* Send and free */
maygup01 0:11cc2b7889af 539 sn_grs_send_coap_message(handle, src_addr_ptr, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 540
maygup01 0:11cc2b7889af 541 if (response_message_hdr_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 542 handle->grs->sn_grs_free(response_message_hdr_ptr->payload_ptr);
maygup01 0:11cc2b7889af 543 response_message_hdr_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 544 }
maygup01 0:11cc2b7889af 545 sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, response_message_hdr_ptr);
maygup01 0:11cc2b7889af 546
maygup01 0:11cc2b7889af 547 /* Free parsed CoAP message */
maygup01 0:11cc2b7889af 548 if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) {
maygup01 0:11cc2b7889af 549 handle->grs->sn_grs_free(coap_packet_ptr->payload_ptr);
maygup01 0:11cc2b7889af 550 coap_packet_ptr->payload_ptr = 0;
maygup01 0:11cc2b7889af 551 }
maygup01 0:11cc2b7889af 552 sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, coap_packet_ptr);
maygup01 0:11cc2b7889af 553
maygup01 0:11cc2b7889af 554 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 555 }
maygup01 0:11cc2b7889af 556
maygup01 0:11cc2b7889af 557 /**
maygup01 0:11cc2b7889af 558 * \fn static sn_grs_resource_info_s *sn_grs_search_resource(struct grs_s *handle, const char *path, uint8_t search_method)
maygup01 0:11cc2b7889af 559 *
maygup01 0:11cc2b7889af 560 * \brief Searches given resource from linked list
maygup01 0:11cc2b7889af 561 *
maygup01 0:11cc2b7889af 562 * Search either precise path, or subresources, eg. dr/x -> returns dr/x/1, dr/x/2 etc...
maygup01 0:11cc2b7889af 563 *
maygup01 0:11cc2b7889af 564 * \param pathlen Length of the path to be search
maygup01 0:11cc2b7889af 565 *
maygup01 0:11cc2b7889af 566 * \param *path Pointer to the path string to be search
maygup01 0:11cc2b7889af 567 *
maygup01 0:11cc2b7889af 568 * \param search_method Search method, SEARCH or DELETE
maygup01 0:11cc2b7889af 569 *
maygup01 0:11cc2b7889af 570 * \return Pointer to the resource. If resource not found, return value is NULL
maygup01 0:11cc2b7889af 571 *
maygup01 0:11cc2b7889af 572 */
maygup01 0:11cc2b7889af 573
maygup01 0:11cc2b7889af 574 sn_nsdl_dynamic_resource_parameters_s *sn_grs_search_resource(struct grs_s *handle, const char *path, uint8_t search_method)
maygup01 0:11cc2b7889af 575 {
maygup01 0:11cc2b7889af 576 /* Local variables */
maygup01 0:11cc2b7889af 577 char *path_temp_ptr = NULL;
maygup01 0:11cc2b7889af 578 /* Check parameters */
maygup01 0:11cc2b7889af 579 if (!handle || !path) {
maygup01 0:11cc2b7889af 580 return NULL;
maygup01 0:11cc2b7889af 581 }
maygup01 0:11cc2b7889af 582 uint16_t pathlen = strlen(path);
maygup01 0:11cc2b7889af 583 /* Remove '/' - marks from the end and beginning */
maygup01 0:11cc2b7889af 584 path_temp_ptr = sn_grs_convert_uri(&pathlen, path);
maygup01 0:11cc2b7889af 585
maygup01 0:11cc2b7889af 586 /* Searchs exact path */
maygup01 0:11cc2b7889af 587 if (search_method == SN_GRS_SEARCH_METHOD) {
maygup01 0:11cc2b7889af 588 /* Scan all nodes on list */
maygup01 0:11cc2b7889af 589 ns_list_foreach(sn_nsdl_dynamic_resource_parameters_s, resource_search_temp, &handle->resource_root_list) {
maygup01 0:11cc2b7889af 590 /* If length equals.. */
maygup01 0:11cc2b7889af 591 size_t len = 0;
maygup01 0:11cc2b7889af 592 if(resource_search_temp &&
maygup01 0:11cc2b7889af 593 resource_search_temp->static_resource_parameters &&
maygup01 0:11cc2b7889af 594 resource_search_temp->static_resource_parameters->path) {
maygup01 0:11cc2b7889af 595 len = strlen(resource_search_temp->static_resource_parameters->path);
maygup01 0:11cc2b7889af 596 }
maygup01 0:11cc2b7889af 597
maygup01 0:11cc2b7889af 598 if (len == pathlen) {
maygup01 0:11cc2b7889af 599 /* Compare paths, If same return node pointer*/
maygup01 0:11cc2b7889af 600 if (0 == memcmp(resource_search_temp->static_resource_parameters->path,
maygup01 0:11cc2b7889af 601 path_temp_ptr,
maygup01 0:11cc2b7889af 602 pathlen)) {
maygup01 0:11cc2b7889af 603 return resource_search_temp;
maygup01 0:11cc2b7889af 604 }
maygup01 0:11cc2b7889af 605 }
maygup01 0:11cc2b7889af 606 }
maygup01 0:11cc2b7889af 607 }
maygup01 0:11cc2b7889af 608 /* Search also subresources, eg. dr/x -> returns dr/x/1, dr/x/2 etc... */
maygup01 0:11cc2b7889af 609 else if (search_method == SN_GRS_DELETE_METHOD) {
maygup01 0:11cc2b7889af 610 /* Scan all nodes on list */
maygup01 0:11cc2b7889af 611 ns_list_foreach(sn_nsdl_dynamic_resource_parameters_s, resource_search_temp, &handle->resource_root_list) {
maygup01 0:11cc2b7889af 612 char *temp_path = resource_search_temp->static_resource_parameters->path;
maygup01 0:11cc2b7889af 613 if (strlen(resource_search_temp->static_resource_parameters->path) > pathlen &&
maygup01 0:11cc2b7889af 614 (*(temp_path + (uint8_t)pathlen) == '/') &&
maygup01 0:11cc2b7889af 615 0 == memcmp(resource_search_temp->static_resource_parameters->path,
maygup01 0:11cc2b7889af 616 path_temp_ptr,
maygup01 0:11cc2b7889af 617 pathlen)) {
maygup01 0:11cc2b7889af 618 return resource_search_temp;
maygup01 0:11cc2b7889af 619 }
maygup01 0:11cc2b7889af 620 }
maygup01 0:11cc2b7889af 621 }
maygup01 0:11cc2b7889af 622
maygup01 0:11cc2b7889af 623 /* If there was not nodes we wanted, return NULL */
maygup01 0:11cc2b7889af 624 return NULL;
maygup01 0:11cc2b7889af 625 }
maygup01 0:11cc2b7889af 626
maygup01 0:11cc2b7889af 627 /**
maygup01 0:11cc2b7889af 628 * \fn static uint8_t *sn_grs_convert_uri(uint16_t *uri_len, uint8_t *uri_ptr)
maygup01 0:11cc2b7889af 629 *
maygup01 0:11cc2b7889af 630 * \brief Removes '/' from the beginning and from the end of uri string
maygup01 0:11cc2b7889af 631 *
maygup01 0:11cc2b7889af 632 * \param *uri_len Pointer to the length of the path string
maygup01 0:11cc2b7889af 633 *
maygup01 0:11cc2b7889af 634 * \param *uri_ptr Pointer to the path string
maygup01 0:11cc2b7889af 635 *
maygup01 0:11cc2b7889af 636 * \return start pointer of the uri
maygup01 0:11cc2b7889af 637 *
maygup01 0:11cc2b7889af 638 */
maygup01 0:11cc2b7889af 639
maygup01 0:11cc2b7889af 640 static char *sn_grs_convert_uri(uint16_t *uri_len, const char *uri_ptr)
maygup01 0:11cc2b7889af 641 {
maygup01 0:11cc2b7889af 642 /* Local variables */
maygup01 0:11cc2b7889af 643 char *uri_start_ptr = (char *) uri_ptr;
maygup01 0:11cc2b7889af 644
maygup01 0:11cc2b7889af 645 /* If '/' in the beginning, update uri start pointer and uri len */
maygup01 0:11cc2b7889af 646 if (*uri_ptr == '/') {
maygup01 0:11cc2b7889af 647 uri_start_ptr = (char *) uri_ptr + 1;
maygup01 0:11cc2b7889af 648 *uri_len = *uri_len - 1;
maygup01 0:11cc2b7889af 649 }
maygup01 0:11cc2b7889af 650
maygup01 0:11cc2b7889af 651 /* If '/' at the end, update uri len */
maygup01 0:11cc2b7889af 652 if (*(uri_start_ptr + *uri_len - 1) == '/') {
maygup01 0:11cc2b7889af 653 *uri_len = *uri_len - 1;
maygup01 0:11cc2b7889af 654 }
maygup01 0:11cc2b7889af 655
maygup01 0:11cc2b7889af 656 /* Return start pointer */
maygup01 0:11cc2b7889af 657 return uri_start_ptr;
maygup01 0:11cc2b7889af 658 }
maygup01 0:11cc2b7889af 659
maygup01 0:11cc2b7889af 660 /**
maygup01 0:11cc2b7889af 661 * \fn static int8_t sn_grs_resource_info_free(sn_grs_resource_info_s *resource_ptr)
maygup01 0:11cc2b7889af 662 *
maygup01 0:11cc2b7889af 663 * \brief Frees resource info structure
maygup01 0:11cc2b7889af 664 *
maygup01 0:11cc2b7889af 665 * \param *resource_ptr Pointer to the resource
maygup01 0:11cc2b7889af 666 *
maygup01 0:11cc2b7889af 667 * \return 0 if success, -1 if failed
maygup01 0:11cc2b7889af 668 *
maygup01 0:11cc2b7889af 669 */
maygup01 0:11cc2b7889af 670 static int8_t sn_grs_resource_info_free(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *resource_ptr)
maygup01 0:11cc2b7889af 671 {
maygup01 0:11cc2b7889af 672 if (resource_ptr) {
maygup01 0:11cc2b7889af 673 #ifdef MEMORY_OPTIMIZED_API
maygup01 0:11cc2b7889af 674 if (resource_ptr->free_on_delete) {
maygup01 0:11cc2b7889af 675 handle->sn_grs_free(resource_ptr);
maygup01 0:11cc2b7889af 676 }
maygup01 0:11cc2b7889af 677 return SN_NSDL_FAILURE;
maygup01 0:11cc2b7889af 678 #else
maygup01 0:11cc2b7889af 679 if (resource_ptr->static_resource_parameters &&
maygup01 0:11cc2b7889af 680 resource_ptr->static_resource_parameters->free_on_delete) {
maygup01 0:11cc2b7889af 681 #ifndef RESOURCE_ATTRIBUTES_LIST
maygup01 0:11cc2b7889af 682 #ifndef DISABLE_INTERFACE_DESCRIPTION
maygup01 0:11cc2b7889af 683 if (resource_ptr->static_resource_parameters->interface_description_ptr) {
maygup01 0:11cc2b7889af 684 handle->sn_grs_free(resource_ptr->static_resource_parameters->interface_description_ptr);
maygup01 0:11cc2b7889af 685 resource_ptr->static_resource_parameters->interface_description_ptr = 0;
maygup01 0:11cc2b7889af 686 }
maygup01 0:11cc2b7889af 687 #endif
maygup01 0:11cc2b7889af 688 #ifndef DISABLE_RESOURCE_TYPE
maygup01 0:11cc2b7889af 689 if (resource_ptr->static_resource_parameters->resource_type_ptr) {
maygup01 0:11cc2b7889af 690 handle->sn_grs_free(resource_ptr->static_resource_parameters->resource_type_ptr);
maygup01 0:11cc2b7889af 691 resource_ptr->static_resource_parameters->resource_type_ptr = 0;
maygup01 0:11cc2b7889af 692 }
maygup01 0:11cc2b7889af 693 #endif
maygup01 0:11cc2b7889af 694 #else
maygup01 0:11cc2b7889af 695 sn_nsdl_free_resource_attributes_list(resource_ptr->static_resource_parameters);
maygup01 0:11cc2b7889af 696 #endif
maygup01 0:11cc2b7889af 697 if (resource_ptr->static_resource_parameters->path) {
maygup01 0:11cc2b7889af 698 handle->sn_grs_free(resource_ptr->static_resource_parameters->path);
maygup01 0:11cc2b7889af 699 resource_ptr->static_resource_parameters->path = 0;
maygup01 0:11cc2b7889af 700 }
maygup01 0:11cc2b7889af 701
maygup01 0:11cc2b7889af 702 if (resource_ptr->resource) {
maygup01 0:11cc2b7889af 703 handle->sn_grs_free(resource_ptr->resource);
maygup01 0:11cc2b7889af 704 resource_ptr->resource = 0;
maygup01 0:11cc2b7889af 705 }
maygup01 0:11cc2b7889af 706
maygup01 0:11cc2b7889af 707 handle->sn_grs_free(resource_ptr->static_resource_parameters);
maygup01 0:11cc2b7889af 708 resource_ptr->static_resource_parameters = 0;
maygup01 0:11cc2b7889af 709 }
maygup01 0:11cc2b7889af 710 if (resource_ptr->free_on_delete) {
maygup01 0:11cc2b7889af 711 handle->sn_grs_free(resource_ptr);
maygup01 0:11cc2b7889af 712 }
maygup01 0:11cc2b7889af 713 return SN_NSDL_SUCCESS;
maygup01 0:11cc2b7889af 714 #endif
maygup01 0:11cc2b7889af 715 }
maygup01 0:11cc2b7889af 716 return SN_NSDL_FAILURE; //Dead code?
maygup01 0:11cc2b7889af 717 }
maygup01 0:11cc2b7889af 718
maygup01 0:11cc2b7889af 719 void sn_grs_mark_resources_as_registered(struct nsdl_s *handle)
maygup01 0:11cc2b7889af 720 {
maygup01 0:11cc2b7889af 721 if( !handle ){
maygup01 0:11cc2b7889af 722 return;
maygup01 0:11cc2b7889af 723 }
maygup01 0:11cc2b7889af 724
maygup01 0:11cc2b7889af 725 sn_nsdl_dynamic_resource_parameters_s *temp_resource;
maygup01 0:11cc2b7889af 726
maygup01 0:11cc2b7889af 727 temp_resource = sn_grs_get_first_resource(handle->grs);
maygup01 0:11cc2b7889af 728
maygup01 0:11cc2b7889af 729 while (temp_resource) {
maygup01 0:11cc2b7889af 730 if (temp_resource->registered == SN_NDSL_RESOURCE_REGISTERING) {
maygup01 0:11cc2b7889af 731 temp_resource->registered = SN_NDSL_RESOURCE_REGISTERED;
maygup01 0:11cc2b7889af 732 }
maygup01 0:11cc2b7889af 733 temp_resource = sn_grs_get_next_resource(handle->grs, temp_resource);
maygup01 0:11cc2b7889af 734 }
maygup01 0:11cc2b7889af 735 }