Example
Dependencies: FXAS21002 FXOS8700Q
simple-mbed-cloud-client/mbed-cloud-client/mbed-client/mbed-client-c/source/sn_grs.c
- Committer:
- maygup01
- Date:
- 2019-11-19
- Revision:
- 0:11cc2b7889af
File content as of revision 0:11cc2b7889af:
/* * Copyright (c) 2011-2015 ARM Limited. All rights reserved. * SPDX-License-Identifier: Apache-2.0 * Licensed under the Apache License, Version 2.0 (the License); you may * not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an AS IS BASIS, WITHOUT * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ /** * * \file sn_grs.c * * \brief General resource server. * */ #include <string.h> #include <stdlib.h> #include "ns_list.h" #include "ns_types.h" #include "sn_nsdl.h" #include "sn_coap_header.h" #include "sn_coap_protocol.h" #include "source/include/sn_coap_protocol_internal.h" #include "sn_nsdl_lib.h" #include "sn_grs.h" /* Defines */ #define WELLKNOWN_PATH_LEN 16 #define WELLKNOWN_PATH (".well-known/core") /* Local static function prototypes */ static int8_t sn_grs_resource_info_free(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *resource_ptr); static char *sn_grs_convert_uri(uint16_t *uri_len, const char *uri_ptr); 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); static uint8_t coap_tx_callback(uint8_t *, uint16_t, sn_nsdl_addr_s *, void *); static int8_t coap_rx_callback(sn_coap_hdr_s *coap_ptr, sn_nsdl_addr_s *address_ptr, void *param); /* Extern function prototypes */ extern int8_t sn_nsdl_build_registration_body(struct nsdl_s *handle, sn_coap_hdr_s *message_ptr, uint8_t updating_registeration); /** * \fn int8_t sn_grs_destroy(void) * \brief This function may be used to flush GRS related stuff when a program exits. * @return always 0. */ extern int8_t sn_grs_destroy(struct grs_s *handle) { if( handle == NULL ){ return 0; } ns_list_foreach_safe(sn_nsdl_dynamic_resource_parameters_s, tmp, &handle->resource_root_list) { ns_list_remove(&handle->resource_root_list, tmp); --handle->resource_root_count; sn_grs_resource_info_free(handle, tmp); } handle->sn_grs_free(handle); return 0; } static uint8_t coap_tx_callback(uint8_t *data_ptr, uint16_t data_len, sn_nsdl_addr_s *address_ptr, void *param) { struct nsdl_s *handle = (struct nsdl_s *)param; if (handle == NULL) { return 0; } return handle->grs->sn_grs_tx_callback(handle, SN_NSDL_PROTOCOL_COAP, data_ptr, data_len, address_ptr); } static int8_t coap_rx_callback(sn_coap_hdr_s *coap_ptr, sn_nsdl_addr_s *address_ptr, void *param) { struct nsdl_s *handle = (struct nsdl_s *)param; if (handle == NULL) { return 0; } return handle->sn_nsdl_rx_callback(handle, coap_ptr, address_ptr); } /** * \fn int8_t sn_grs_init (uint8_t (*sn_grs_tx_callback_ptr)(sn_nsdl_capab_e , uint8_t *, uint16_t, * 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) * * \brief GRS library initialize function. * * This function initializes GRS and CoAP libraries. * * \param sn_grs_tx_callback A function pointer to a transmit callback function. * \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 * upper level (NSDL) to be proceed. * \param sn_memory A pointer to a structure containing the platform specific functions for memory allocation and free. * * \return success = 0, failure = -1 * */ 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, sn_nsdl_addr_s *), int8_t (*sn_grs_rx_callback_ptr)(struct nsdl_s *, sn_coap_hdr_s *, sn_nsdl_addr_s *), void *(*sn_grs_alloc)(uint16_t), void (*sn_grs_free)(void *)) { struct grs_s *handle_ptr = NULL; /* Check parameters */ if (sn_grs_alloc == NULL || sn_grs_free == NULL || sn_grs_tx_callback_ptr == NULL || sn_grs_rx_callback_ptr == NULL) { return NULL; } handle_ptr = sn_grs_alloc(sizeof(struct grs_s)); if (handle_ptr == NULL) { return NULL; } memset(handle_ptr, 0, sizeof(struct grs_s)); /* Allocation and free - function pointers */ handle_ptr->sn_grs_alloc = sn_grs_alloc; handle_ptr->sn_grs_free = sn_grs_free; /* TX callback function pointer */ handle_ptr->sn_grs_tx_callback = sn_grs_tx_callback_ptr; handle_ptr->sn_grs_rx_callback = sn_grs_rx_callback_ptr; /* Initialize CoAP protocol library */ handle_ptr->coap = sn_coap_protocol_init(sn_grs_alloc, sn_grs_free, coap_tx_callback, coap_rx_callback); return handle_ptr; } extern sn_nsdl_dynamic_resource_parameters_s *sn_grs_get_first_resource(struct grs_s *handle) { if( !handle ){ return NULL; } return ns_list_get_first(&handle->resource_root_list); } extern sn_nsdl_dynamic_resource_parameters_s *sn_grs_get_next_resource(struct grs_s *handle, const sn_nsdl_dynamic_resource_parameters_s *sn_grs_current_resource) { if( !handle || !sn_grs_current_resource ){ return NULL; } return ns_list_get_next(&handle->resource_root_list, sn_grs_current_resource); } extern int8_t sn_grs_delete_resource(struct grs_s *handle, const char *path) { /* Local variables */ sn_nsdl_dynamic_resource_parameters_s *resource_temp = NULL; /* Search if resource found */ resource_temp = sn_grs_search_resource(handle, path, SN_GRS_SEARCH_METHOD); /* If not found */ if (resource_temp == NULL) { return SN_NSDL_FAILURE; } /* If found, delete it and delete also subresources, if there is any */ do { /* Remove from list */ ns_list_remove(&handle->resource_root_list, resource_temp); --handle->resource_root_count; /* Free */ sn_grs_resource_info_free(handle, resource_temp); /* Search for subresources */ resource_temp = sn_grs_search_resource(handle, path, SN_GRS_DELETE_METHOD); } while (resource_temp != NULL); return SN_NSDL_SUCCESS; } int8_t sn_grs_put_resource(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *res) { if (!res || !handle) { return SN_NSDL_FAILURE; } /* Check path validity */ if (!res->static_resource_parameters->path || res->static_resource_parameters->path[0] == '\0') { return SN_GRS_INVALID_PATH; } /* Check if resource already exists */ if (sn_grs_search_resource(handle, res->static_resource_parameters->path, SN_GRS_SEARCH_METHOD) != (sn_nsdl_dynamic_resource_parameters_s *)NULL) { return SN_GRS_RESOURCE_ALREADY_EXISTS; } res->registered = SN_NDSL_RESOURCE_NOT_REGISTERED; ns_list_add_to_start(&handle->resource_root_list, res); ++handle->resource_root_count; return SN_NSDL_SUCCESS; } int8_t sn_grs_pop_resource(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *res) { if (!res || !handle) { return SN_NSDL_FAILURE; } /* Check path validity */ if (!res->static_resource_parameters->path || res->static_resource_parameters->path[0] == '\0') { return SN_GRS_INVALID_PATH; } /* Check if resource exists on list. */ if (sn_grs_search_resource(handle, res->static_resource_parameters->path, SN_GRS_SEARCH_METHOD) == (sn_nsdl_dynamic_resource_parameters_s *)NULL) { return SN_NSDL_FAILURE; } ns_list_remove(&handle->resource_root_list, res); --handle->resource_root_count; return SN_NSDL_SUCCESS; } /** * \fn extern int8_t sn_grs_process_coap(uint8_t *packet, uint16_t *packet_len, sn_nsdl_addr_s *src) * * \brief To push CoAP packet to GRS library * * Used to push an CoAP packet to GRS library for processing. * * \param *packet Pointer to a uint8_t array containing the packet (including the CoAP headers). * After successful execution this array may contain the response packet. * * \param *packet_len Pointer to length of the packet. After successful execution this array may contain the length * of the response packet. * * \param *src Pointer to packet source address information. After successful execution this array may contain * the destination address of the response packet. * * \return 0 = success, -1 = failure */ 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) { if( !coap_packet_ptr || !nsdl_handle){ return SN_NSDL_FAILURE; } sn_nsdl_dynamic_resource_parameters_s *resource_temp_ptr = NULL; sn_coap_msg_code_e status = COAP_MSG_CODE_EMPTY; sn_coap_hdr_s *response_message_hdr_ptr = NULL; struct grs_s *handle = nsdl_handle->grs; bool static_get_request = false; if (coap_packet_ptr->msg_code <= COAP_MSG_CODE_REQUEST_DELETE) { /* Check if .well-known/core */ if (coap_packet_ptr->uri_path_len == WELLKNOWN_PATH_LEN && memcmp(coap_packet_ptr->uri_path_ptr, WELLKNOWN_PATH, WELLKNOWN_PATH_LEN) == 0) { return sn_grs_core_request(nsdl_handle, src_addr_ptr, coap_packet_ptr); } /* Get resource */ char* path = nsdl_handle->grs->sn_grs_alloc(coap_packet_ptr->uri_path_len + 1); if (!path) { return SN_NSDL_FAILURE; } memcpy(path, coap_packet_ptr->uri_path_ptr, coap_packet_ptr->uri_path_len); path[coap_packet_ptr->uri_path_len] = '\0'; resource_temp_ptr = sn_grs_search_resource(handle, path, SN_GRS_SEARCH_METHOD); nsdl_handle->grs->sn_grs_free(path); /* * * * * * * * * * * */ /* If resource exists */ /* * * * * * * * * * * */ if (resource_temp_ptr) { /* If dynamic resource, go to callback */ if (resource_temp_ptr->static_resource_parameters->mode == SN_GRS_DYNAMIC) { /* Check accesses */ if (((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_GET) && !(resource_temp_ptr->access & SN_GRS_GET_ALLOWED)) || ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) && !(resource_temp_ptr->access & SN_GRS_POST_ALLOWED)) || ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_PUT) && !(resource_temp_ptr->access & SN_GRS_PUT_ALLOWED)) || ((coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_DELETE) && !(resource_temp_ptr->access & SN_GRS_DELETE_ALLOWED))) { status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; } else { /* Do not call null pointer.. */ if (resource_temp_ptr->sn_grs_dyn_res_callback != NULL) { resource_temp_ptr->sn_grs_dyn_res_callback(nsdl_handle, coap_packet_ptr, src_addr_ptr, SN_NSDL_PROTOCOL_COAP); } else { if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); } return SN_NSDL_SUCCESS; } } else { /* Static resource handling */ switch (coap_packet_ptr->msg_code) { case COAP_MSG_CODE_REQUEST_GET: if (resource_temp_ptr->access & SN_GRS_GET_ALLOWED) { status = COAP_MSG_CODE_RESPONSE_CONTENT; static_get_request = true; } else { status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; } break; case COAP_MSG_CODE_REQUEST_POST: case COAP_MSG_CODE_REQUEST_PUT: case COAP_MSG_CODE_REQUEST_DELETE: status = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED; break; default: status = COAP_MSG_CODE_RESPONSE_FORBIDDEN; break; } } } /* * * * * * * * * * * * * * */ /* If resource was not found */ /* * * * * * * * * * * * * * */ else { if (coap_packet_ptr->msg_code == COAP_MSG_CODE_REQUEST_POST) { handle->sn_grs_rx_callback(nsdl_handle, coap_packet_ptr, src_addr_ptr); if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); return SN_NSDL_SUCCESS; } else { status = COAP_MSG_CODE_RESPONSE_NOT_FOUND; } } } /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */ /* If received packed was other than reset, create response */ /* * * * * * * * * * * * * * * * * * * * * * * * * * * * * * */ if (coap_packet_ptr->msg_type != COAP_MSG_TYPE_RESET && coap_packet_ptr->msg_type != COAP_MSG_TYPE_ACKNOWLEDGEMENT) { /* Allocate resopnse message */ response_message_hdr_ptr = sn_coap_parser_alloc_message(handle->coap); if (!response_message_hdr_ptr) { if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); return SN_NSDL_FAILURE; } /* If status has not been defined, response internal server error */ if (status == COAP_MSG_CODE_EMPTY) { status = COAP_MSG_CODE_RESPONSE_INTERNAL_SERVER_ERROR; } /* Fill header */ response_message_hdr_ptr->msg_code = status; if (coap_packet_ptr->msg_type == COAP_MSG_TYPE_CONFIRMABLE) { response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_ACKNOWLEDGEMENT; } else { response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_NON_CONFIRMABLE; } response_message_hdr_ptr->msg_id = coap_packet_ptr->msg_id; if (coap_packet_ptr->token_ptr) { response_message_hdr_ptr->token_len = coap_packet_ptr->token_len; response_message_hdr_ptr->token_ptr = handle->sn_grs_alloc(response_message_hdr_ptr->token_len); if (!response_message_hdr_ptr->token_ptr) { sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr); if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); return SN_NSDL_FAILURE; } memcpy(response_message_hdr_ptr->token_ptr, coap_packet_ptr->token_ptr, response_message_hdr_ptr->token_len); } if (status == COAP_MSG_CODE_RESPONSE_CONTENT) { /* Add content type if other than default */ if (resource_temp_ptr->static_resource_parameters) { response_message_hdr_ptr->content_format = (sn_coap_content_format_e) resource_temp_ptr->coap_content_type; } /* Add payload */ if (resource_temp_ptr->resource_len != 0) { response_message_hdr_ptr->payload_len = resource_temp_ptr->resource_len; response_message_hdr_ptr->payload_ptr = handle->sn_grs_alloc(response_message_hdr_ptr->payload_len); if (!response_message_hdr_ptr->payload_ptr) { sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr); if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); return SN_NSDL_FAILURE; } memcpy(response_message_hdr_ptr->payload_ptr, resource_temp_ptr->resource, response_message_hdr_ptr->payload_len); } // Add max-age attribute for static resources. // Not a mandatory parameter, no need to return in case of memory allocation fails. if (static_get_request) { if (sn_coap_parser_alloc_options(handle->coap, response_message_hdr_ptr)) { response_message_hdr_ptr->options_list_ptr->max_age = 0; } } } sn_grs_send_coap_message(nsdl_handle, src_addr_ptr, response_message_hdr_ptr); if (response_message_hdr_ptr->payload_ptr) { handle->sn_grs_free(response_message_hdr_ptr->payload_ptr); response_message_hdr_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, response_message_hdr_ptr); } /* Free parsed CoAP message */ if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->coap, coap_packet_ptr); return SN_NSDL_SUCCESS; } 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) { uint8_t *message_ptr = NULL; uint16_t message_len = 0; int16_t ret_val = 0; if( !handle ){ return SN_NSDL_FAILURE; } #if SN_COAP_MAX_BLOCKWISE_PAYLOAD_SIZE /* If Message blockwising is not used at all, this part of code will not be compiled */ ret_val = prepare_blockwise_message(handle->grs->coap, coap_hdr_ptr); if( 0 != ret_val ) { return SN_NSDL_FAILURE; } #endif /* Calculate message length */ message_len = sn_coap_builder_calc_needed_packet_data_size_2(coap_hdr_ptr, handle->grs->coap->sn_coap_block_data_size); /* Allocate memory for message and check was allocating successfully */ message_ptr = handle->grs->sn_grs_alloc(message_len); if (message_ptr == NULL) { return SN_NSDL_FAILURE; } /* Build CoAP message */ ret_val = sn_coap_protocol_build(handle->grs->coap, address_ptr, message_ptr, coap_hdr_ptr, (void *)handle); if (ret_val < 0) { handle->grs->sn_grs_free(message_ptr); message_ptr = 0; if (ret_val == -4) { return SN_NSDL_RESEND_QUEUE_FULL; } else { return SN_NSDL_FAILURE; } } /* Call tx callback function to send message */ ret_val = handle->grs->sn_grs_tx_callback(handle, SN_NSDL_PROTOCOL_COAP, message_ptr, message_len, address_ptr); /* Free allocated memory */ handle->grs->sn_grs_free(message_ptr); message_ptr = 0; if (ret_val == 0) { return SN_NSDL_FAILURE; } else { return SN_NSDL_SUCCESS; } } 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) { sn_coap_hdr_s *response_message_hdr_ptr = NULL; sn_coap_content_format_e wellknown_content_format = COAP_CT_LINK_FORMAT; /* Allocate response message */ response_message_hdr_ptr = sn_coap_parser_alloc_message(handle->grs->coap); if (response_message_hdr_ptr == NULL) { if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->grs->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, coap_packet_ptr); return SN_NSDL_FAILURE; } /* Build response */ response_message_hdr_ptr->msg_code = COAP_MSG_CODE_RESPONSE_CONTENT; response_message_hdr_ptr->msg_type = COAP_MSG_TYPE_ACKNOWLEDGEMENT; response_message_hdr_ptr->msg_id = coap_packet_ptr->msg_id; response_message_hdr_ptr->content_format = wellknown_content_format; sn_nsdl_build_registration_body(handle, response_message_hdr_ptr, 0); /* Send and free */ sn_grs_send_coap_message(handle, src_addr_ptr, response_message_hdr_ptr); if (response_message_hdr_ptr->payload_ptr) { handle->grs->sn_grs_free(response_message_hdr_ptr->payload_ptr); response_message_hdr_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, response_message_hdr_ptr); /* Free parsed CoAP message */ if (coap_packet_ptr->coap_status == COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED && coap_packet_ptr->payload_ptr) { handle->grs->sn_grs_free(coap_packet_ptr->payload_ptr); coap_packet_ptr->payload_ptr = 0; } sn_coap_parser_release_allocated_coap_msg_mem(handle->grs->coap, coap_packet_ptr); return SN_NSDL_SUCCESS; } /** * \fn static sn_grs_resource_info_s *sn_grs_search_resource(struct grs_s *handle, const char *path, uint8_t search_method) * * \brief Searches given resource from linked list * * Search either precise path, or subresources, eg. dr/x -> returns dr/x/1, dr/x/2 etc... * * \param pathlen Length of the path to be search * * \param *path Pointer to the path string to be search * * \param search_method Search method, SEARCH or DELETE * * \return Pointer to the resource. If resource not found, return value is NULL * */ sn_nsdl_dynamic_resource_parameters_s *sn_grs_search_resource(struct grs_s *handle, const char *path, uint8_t search_method) { /* Local variables */ char *path_temp_ptr = NULL; /* Check parameters */ if (!handle || !path) { return NULL; } uint16_t pathlen = strlen(path); /* Remove '/' - marks from the end and beginning */ path_temp_ptr = sn_grs_convert_uri(&pathlen, path); /* Searchs exact path */ if (search_method == SN_GRS_SEARCH_METHOD) { /* Scan all nodes on list */ ns_list_foreach(sn_nsdl_dynamic_resource_parameters_s, resource_search_temp, &handle->resource_root_list) { /* If length equals.. */ size_t len = 0; if(resource_search_temp && resource_search_temp->static_resource_parameters && resource_search_temp->static_resource_parameters->path) { len = strlen(resource_search_temp->static_resource_parameters->path); } if (len == pathlen) { /* Compare paths, If same return node pointer*/ if (0 == memcmp(resource_search_temp->static_resource_parameters->path, path_temp_ptr, pathlen)) { return resource_search_temp; } } } } /* Search also subresources, eg. dr/x -> returns dr/x/1, dr/x/2 etc... */ else if (search_method == SN_GRS_DELETE_METHOD) { /* Scan all nodes on list */ ns_list_foreach(sn_nsdl_dynamic_resource_parameters_s, resource_search_temp, &handle->resource_root_list) { char *temp_path = resource_search_temp->static_resource_parameters->path; if (strlen(resource_search_temp->static_resource_parameters->path) > pathlen && (*(temp_path + (uint8_t)pathlen) == '/') && 0 == memcmp(resource_search_temp->static_resource_parameters->path, path_temp_ptr, pathlen)) { return resource_search_temp; } } } /* If there was not nodes we wanted, return NULL */ return NULL; } /** * \fn static uint8_t *sn_grs_convert_uri(uint16_t *uri_len, uint8_t *uri_ptr) * * \brief Removes '/' from the beginning and from the end of uri string * * \param *uri_len Pointer to the length of the path string * * \param *uri_ptr Pointer to the path string * * \return start pointer of the uri * */ static char *sn_grs_convert_uri(uint16_t *uri_len, const char *uri_ptr) { /* Local variables */ char *uri_start_ptr = (char *) uri_ptr; /* If '/' in the beginning, update uri start pointer and uri len */ if (*uri_ptr == '/') { uri_start_ptr = (char *) uri_ptr + 1; *uri_len = *uri_len - 1; } /* If '/' at the end, update uri len */ if (*(uri_start_ptr + *uri_len - 1) == '/') { *uri_len = *uri_len - 1; } /* Return start pointer */ return uri_start_ptr; } /** * \fn static int8_t sn_grs_resource_info_free(sn_grs_resource_info_s *resource_ptr) * * \brief Frees resource info structure * * \param *resource_ptr Pointer to the resource * * \return 0 if success, -1 if failed * */ static int8_t sn_grs_resource_info_free(struct grs_s *handle, sn_nsdl_dynamic_resource_parameters_s *resource_ptr) { if (resource_ptr) { #ifdef MEMORY_OPTIMIZED_API if (resource_ptr->free_on_delete) { handle->sn_grs_free(resource_ptr); } return SN_NSDL_FAILURE; #else if (resource_ptr->static_resource_parameters && resource_ptr->static_resource_parameters->free_on_delete) { #ifndef RESOURCE_ATTRIBUTES_LIST #ifndef DISABLE_INTERFACE_DESCRIPTION if (resource_ptr->static_resource_parameters->interface_description_ptr) { handle->sn_grs_free(resource_ptr->static_resource_parameters->interface_description_ptr); resource_ptr->static_resource_parameters->interface_description_ptr = 0; } #endif #ifndef DISABLE_RESOURCE_TYPE if (resource_ptr->static_resource_parameters->resource_type_ptr) { handle->sn_grs_free(resource_ptr->static_resource_parameters->resource_type_ptr); resource_ptr->static_resource_parameters->resource_type_ptr = 0; } #endif #else sn_nsdl_free_resource_attributes_list(resource_ptr->static_resource_parameters); #endif if (resource_ptr->static_resource_parameters->path) { handle->sn_grs_free(resource_ptr->static_resource_parameters->path); resource_ptr->static_resource_parameters->path = 0; } if (resource_ptr->resource) { handle->sn_grs_free(resource_ptr->resource); resource_ptr->resource = 0; } handle->sn_grs_free(resource_ptr->static_resource_parameters); resource_ptr->static_resource_parameters = 0; } if (resource_ptr->free_on_delete) { handle->sn_grs_free(resource_ptr); } return SN_NSDL_SUCCESS; #endif } return SN_NSDL_FAILURE; //Dead code? } void sn_grs_mark_resources_as_registered(struct nsdl_s *handle) { if( !handle ){ return; } sn_nsdl_dynamic_resource_parameters_s *temp_resource; temp_resource = sn_grs_get_first_resource(handle->grs); while (temp_resource) { if (temp_resource->registered == SN_NDSL_RESOURCE_REGISTERING) { temp_resource->registered = SN_NDSL_RESOURCE_REGISTERED; } temp_resource = sn_grs_get_next_resource(handle->grs, temp_resource); } }