Important changes to repositories hosted on mbed.com
Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.
To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.
It is also possible to export all your personal repositories from the account settings page.
Diff: mbed-cloud-client/mbed-client/mbed-client-c/source/sn_grs.c
- Revision:
- 0:276e7a263c35
diff -r 000000000000 -r 276e7a263c35 mbed-cloud-client/mbed-client/mbed-client-c/source/sn_grs.c
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/mbed-cloud-client/mbed-client/mbed-client-c/source/sn_grs.c Mon Jul 02 06:30:39 2018 +0000
@@ -0,0 +1,820 @@
+/*
+ * 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_grs_resource_list_s *sn_grs_list_resource(struct grs_s *handle, const char *path)
+{
+ (void) (path);
+ sn_grs_resource_list_s *grs_resource_list_ptr = NULL;
+
+ if(handle == NULL){
+ return NULL;
+ }
+
+ /* Allocate memory for the resource list to be filled */
+ grs_resource_list_ptr = handle->sn_grs_alloc(sizeof(sn_grs_resource_list_s));
+ if (!grs_resource_list_ptr) {
+ goto fail;
+ }
+
+ /* Count resources to the resource list struct */
+ grs_resource_list_ptr->res_count = handle->resource_root_count;
+ grs_resource_list_ptr->res = NULL;
+
+ /**************************************/
+ /* Fill resource structs to the table */
+ /**************************************/
+
+ /* If resources in list */
+ if (grs_resource_list_ptr->res_count) {
+ int i;
+
+ /* Allocate memory for resources */
+ grs_resource_list_ptr->res = handle->sn_grs_alloc(grs_resource_list_ptr->res_count * sizeof(sn_grs_resource_s));
+ if (!grs_resource_list_ptr->res) {
+ goto fail;
+ }
+
+ /* Initialise the pointers to NULL to permit easy cleanup */
+ for (i = 0; i < grs_resource_list_ptr->res_count; i++) {
+ grs_resource_list_ptr->res[i].path = NULL;
+ }
+
+ i = 0;
+ size_t len = 0;
+ ns_list_foreach(sn_nsdl_dynamic_resource_parameters_s, grs_resource_ptr, &handle->resource_root_list) {
+ /* Copy pathlen to resource list */
+ len = strlen(grs_resource_ptr->static_resource_parameters->path);
+
+ /* Allocate memory for path string */
+ grs_resource_list_ptr->res[i].path = handle->sn_grs_alloc(len);
+ if (!grs_resource_list_ptr->res[i].path) {
+ goto fail;
+ }
+
+ /* Copy pathstring to resource list */
+ memcpy(grs_resource_list_ptr->res[i].path,
+ grs_resource_ptr->static_resource_parameters->path,
+ len);
+
+ i++;
+ }
+ }
+ return grs_resource_list_ptr;
+
+fail:
+ sn_grs_free_resource_list(handle, grs_resource_list_ptr);
+ return NULL;
+}
+
+extern void sn_grs_free_resource_list(struct grs_s *handle, sn_grs_resource_list_s *list)
+{
+ if (!list || !handle) {
+ return;
+ }
+
+ if (list->res) {
+ for (int i = 0; i < list->res_count; i++) {
+ if (list->res[i].path) {
+ handle->sn_grs_free(list->res[i].path);
+ list->res[i].path = NULL;
+ }
+ }
+ handle->sn_grs_free(list->res);
+ list->res = NULL;
+ }
+
+ handle->sn_grs_free(list);
+}
+
+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->resourcelen != 0) {
+ response_message_hdr_ptr->payload_len = resource_temp_ptr->resourcelen;
+ 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);
+ }
+}