Austin Blackstone / Mbed 2 deprecated mbed-client-classic-example-lwip

mbed client on ethernet with LWIP

Dependencies:   mbed Socket lwip-eth lwip-sys lwip

Fork of mbed-client-classic-example-lwip by sandbox

mbed-client/source/m2mnsdlinterface.cpp@11:cada08fc8a70, 2016-06-09 (annotated)

Committer:
mbedAustin
Date:
Thu Jun 09 17:08:36 2016 +0000
Revision:
11:cada08fc8a70
Commit for public Consumption

Who changed what in which revision?

UserRevisionLine numberNew contents of line
mbedAustin 11:cada08fc8a70 1 /*
mbedAustin 11:cada08fc8a70 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
mbedAustin 11:cada08fc8a70 3 * SPDX-License-Identifier: Apache-2.0
mbedAustin 11:cada08fc8a70 4 * Licensed under the Apache License, Version 2.0 (the License); you may
mbedAustin 11:cada08fc8a70 5 * not use this file except in compliance with the License.
mbedAustin 11:cada08fc8a70 6 * You may obtain a copy of the License at
mbedAustin 11:cada08fc8a70 7 *
mbedAustin 11:cada08fc8a70 8 * http://www.apache.org/licenses/LICENSE-2.0
mbedAustin 11:cada08fc8a70 9 *
mbedAustin 11:cada08fc8a70 10 * Unless required by applicable law or agreed to in writing, software
mbedAustin 11:cada08fc8a70 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
mbedAustin 11:cada08fc8a70 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
mbedAustin 11:cada08fc8a70 13 * See the License for the specific language governing permissions and
mbedAustin 11:cada08fc8a70 14 * limitations under the License.
mbedAustin 11:cada08fc8a70 15 */
mbedAustin 11:cada08fc8a70 16 #include "include/nsdlaccesshelper.h"
mbedAustin 11:cada08fc8a70 17 #include "include/m2mnsdlobserver.h"
mbedAustin 11:cada08fc8a70 18 #include "mbed-client/m2msecurity.h"
mbedAustin 11:cada08fc8a70 19 #include "mbed-client/m2mserver.h"
mbedAustin 11:cada08fc8a70 20 #include "mbed-client/m2mobject.h"
mbedAustin 11:cada08fc8a70 21 #include "mbed-client/m2mobjectinstance.h"
mbedAustin 11:cada08fc8a70 22 #include "mbed-client/m2mresource.h"
mbedAustin 11:cada08fc8a70 23 #include "mbed-client/m2mconstants.h"
mbedAustin 11:cada08fc8a70 24 #include "include/m2mtlvserializer.h"
mbedAustin 11:cada08fc8a70 25 #include "ip6string.h"
mbedAustin 11:cada08fc8a70 26 #include "ns_trace.h"
mbedAustin 11:cada08fc8a70 27 #include "mbed-client/m2mtimer.h"
mbedAustin 11:cada08fc8a70 28
mbedAustin 11:cada08fc8a70 29 M2MNsdlInterface::M2MNsdlInterface(M2MNsdlObserver &observer)
mbedAustin 11:cada08fc8a70 30 : _observer(observer),
mbedAustin 11:cada08fc8a70 31 _server(NULL),
mbedAustin 11:cada08fc8a70 32 _nsdl_exceution_timer(new M2MTimer(*this)),
mbedAustin 11:cada08fc8a70 33 _registration_timer(new M2MTimer(*this)),
mbedAustin 11:cada08fc8a70 34 _nsdl_handle(NULL),
mbedAustin 11:cada08fc8a70 35 _counter_for_nsdl(0),
mbedAustin 11:cada08fc8a70 36 _register_id(0),
mbedAustin 11:cada08fc8a70 37 _unregister_id(0),
mbedAustin 11:cada08fc8a70 38 _update_id(0),
mbedAustin 11:cada08fc8a70 39 _bootstrap_id(0)
mbedAustin 11:cada08fc8a70 40 {
mbedAustin 11:cada08fc8a70 41 tr_debug("M2MNsdlInterface::M2MNsdlInterface()");
mbedAustin 11:cada08fc8a70 42 _endpoint = NULL;
mbedAustin 11:cada08fc8a70 43 _resource = NULL;
mbedAustin 11:cada08fc8a70 44 __nsdl_interface = this;
mbedAustin 11:cada08fc8a70 45
mbedAustin 11:cada08fc8a70 46 _bootstrap_endpoint.device_object = NULL;
mbedAustin 11:cada08fc8a70 47 _bootstrap_endpoint.oma_bs_status_cb = NULL;
mbedAustin 11:cada08fc8a70 48
mbedAustin 11:cada08fc8a70 49 _bootstrap_device_setup.sn_oma_device_boot_callback = NULL;
mbedAustin 11:cada08fc8a70 50 _bootstrap_device_setup.error_code = NO_ERROR;
mbedAustin 11:cada08fc8a70 51
mbedAustin 11:cada08fc8a70 52 _sn_nsdl_address.addr_len = 0;
mbedAustin 11:cada08fc8a70 53 _sn_nsdl_address.addr_ptr = NULL;
mbedAustin 11:cada08fc8a70 54 _sn_nsdl_address.port = 0;
mbedAustin 11:cada08fc8a70 55
mbedAustin 11:cada08fc8a70 56 // This initializes libCoap and libNsdl
mbedAustin 11:cada08fc8a70 57 // Parameters are function pointers to used memory allocation
mbedAustin 11:cada08fc8a70 58 // and free functions in structure and used functions for sending
mbedAustin 11:cada08fc8a70 59 // and receiving purposes.
mbedAustin 11:cada08fc8a70 60 _nsdl_handle = sn_nsdl_init(&(__nsdl_c_send_to_server), &(__nsdl_c_received_from_server),
mbedAustin 11:cada08fc8a70 61 &(__nsdl_c_memory_alloc), &(__nsdl_c_memory_free));
mbedAustin 11:cada08fc8a70 62
mbedAustin 11:cada08fc8a70 63 initialize();
mbedAustin 11:cada08fc8a70 64 }
mbedAustin 11:cada08fc8a70 65
mbedAustin 11:cada08fc8a70 66 M2MNsdlInterface::~M2MNsdlInterface()
mbedAustin 11:cada08fc8a70 67 {
mbedAustin 11:cada08fc8a70 68 tr_debug("M2MNsdlInterface::~M2MNsdlInterface() - IN");
mbedAustin 11:cada08fc8a70 69 if(_resource) {
mbedAustin 11:cada08fc8a70 70 if(_resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 71 memory_free(_resource->resource_parameters_ptr);
mbedAustin 11:cada08fc8a70 72 _resource->resource_parameters_ptr = NULL;
mbedAustin 11:cada08fc8a70 73 }
mbedAustin 11:cada08fc8a70 74 memory_free(_resource);
mbedAustin 11:cada08fc8a70 75 _resource = NULL;
mbedAustin 11:cada08fc8a70 76 }
mbedAustin 11:cada08fc8a70 77 if(_endpoint) {
mbedAustin 11:cada08fc8a70 78 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 79 memory_free(_endpoint->lifetime_ptr);
mbedAustin 11:cada08fc8a70 80 _endpoint->lifetime_ptr = NULL;
mbedAustin 11:cada08fc8a70 81 }
mbedAustin 11:cada08fc8a70 82 if(_endpoint->location_ptr) {
mbedAustin 11:cada08fc8a70 83 memory_free(_endpoint->location_ptr);
mbedAustin 11:cada08fc8a70 84 _endpoint->location_ptr = NULL;
mbedAustin 11:cada08fc8a70 85 }
mbedAustin 11:cada08fc8a70 86 memory_free(_endpoint);
mbedAustin 11:cada08fc8a70 87 _endpoint = NULL;
mbedAustin 11:cada08fc8a70 88
mbedAustin 11:cada08fc8a70 89 }
mbedAustin 11:cada08fc8a70 90 delete _nsdl_exceution_timer;
mbedAustin 11:cada08fc8a70 91 delete _registration_timer;
mbedAustin 11:cada08fc8a70 92 _object_list.clear();
mbedAustin 11:cada08fc8a70 93
mbedAustin 11:cada08fc8a70 94 if(_server){
mbedAustin 11:cada08fc8a70 95 delete _server;
mbedAustin 11:cada08fc8a70 96 _server = NULL;
mbedAustin 11:cada08fc8a70 97 }
mbedAustin 11:cada08fc8a70 98 sn_nsdl_destroy(_nsdl_handle);
mbedAustin 11:cada08fc8a70 99 _nsdl_handle = NULL;
mbedAustin 11:cada08fc8a70 100 __nsdl_interface = NULL;
mbedAustin 11:cada08fc8a70 101 tr_debug("M2MNsdlInterface::~M2MNsdlInterface() - OUT");
mbedAustin 11:cada08fc8a70 102 }
mbedAustin 11:cada08fc8a70 103
mbedAustin 11:cada08fc8a70 104 bool M2MNsdlInterface::initialize()
mbedAustin 11:cada08fc8a70 105 {
mbedAustin 11:cada08fc8a70 106 tr_debug("M2MNsdlInterface::initialize()");
mbedAustin 11:cada08fc8a70 107 bool success = false;
mbedAustin 11:cada08fc8a70 108
mbedAustin 11:cada08fc8a70 109 //Sets the packet retransmission attempts and time interval
mbedAustin 11:cada08fc8a70 110 sn_coap_protocol_set_retransmission_parameters(RETRY_COUNT,RETRY_INTERVAL);
mbedAustin 11:cada08fc8a70 111
mbedAustin 11:cada08fc8a70 112 _nsdl_exceution_timer->start_timer(ONE_SECOND_TIMER * 1000,
mbedAustin 11:cada08fc8a70 113 M2MTimerObserver::NsdlExecution,
mbedAustin 11:cada08fc8a70 114 false);
mbedAustin 11:cada08fc8a70 115
mbedAustin 11:cada08fc8a70 116 // Allocate the memory for resources
mbedAustin 11:cada08fc8a70 117 _resource = (sn_nsdl_resource_info_s*)memory_alloc(sizeof(sn_nsdl_resource_info_s));
mbedAustin 11:cada08fc8a70 118 if(_resource) {
mbedAustin 11:cada08fc8a70 119 memset(_resource, 0, sizeof(sn_nsdl_resource_info_s));
mbedAustin 11:cada08fc8a70 120 _resource->resource_parameters_ptr = (sn_nsdl_resource_parameters_s*)memory_alloc(sizeof(sn_nsdl_resource_parameters_s)+1);
mbedAustin 11:cada08fc8a70 121 if(_resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 122 memset(_resource->resource_parameters_ptr, 0, sizeof(sn_nsdl_resource_parameters_s)+1);
mbedAustin 11:cada08fc8a70 123 }
mbedAustin 11:cada08fc8a70 124 }
mbedAustin 11:cada08fc8a70 125
mbedAustin 11:cada08fc8a70 126 //Allocate the memory for endpoint
mbedAustin 11:cada08fc8a70 127 _endpoint = (sn_nsdl_ep_parameters_s*)memory_alloc(sizeof(sn_nsdl_ep_parameters_s)+1);
mbedAustin 11:cada08fc8a70 128 if(_endpoint) {
mbedAustin 11:cada08fc8a70 129 memset(_endpoint, 0, sizeof(sn_nsdl_ep_parameters_s)+1);
mbedAustin 11:cada08fc8a70 130 success = true;
mbedAustin 11:cada08fc8a70 131 }
mbedAustin 11:cada08fc8a70 132 return success;
mbedAustin 11:cada08fc8a70 133 }
mbedAustin 11:cada08fc8a70 134
mbedAustin 11:cada08fc8a70 135 void M2MNsdlInterface::create_endpoint(const String &name,
mbedAustin 11:cada08fc8a70 136 const String &type,
mbedAustin 11:cada08fc8a70 137 const int32_t life_time,
mbedAustin 11:cada08fc8a70 138 const String &domain,
mbedAustin 11:cada08fc8a70 139 const uint8_t mode,
mbedAustin 11:cada08fc8a70 140 const String &/*context_address*/)
mbedAustin 11:cada08fc8a70 141 {
mbedAustin 11:cada08fc8a70 142 tr_debug("M2MNsdlInterface::create_endpoint( name %s type %s lifetime %d, domain %s, mode %d)",
mbedAustin 11:cada08fc8a70 143 name.c_str(), type.c_str(), life_time, domain.c_str(), mode);
mbedAustin 11:cada08fc8a70 144 if(_endpoint){
mbedAustin 11:cada08fc8a70 145 memset(_endpoint, 0, sizeof(sn_nsdl_ep_parameters_s)+1);
mbedAustin 11:cada08fc8a70 146 if(!name.empty()) {
mbedAustin 11:cada08fc8a70 147 _endpoint->endpoint_name_ptr = (uint8_t*)name.c_str();
mbedAustin 11:cada08fc8a70 148 _endpoint->endpoint_name_len = name.length();
mbedAustin 11:cada08fc8a70 149 }
mbedAustin 11:cada08fc8a70 150 if(!type.empty()) {
mbedAustin 11:cada08fc8a70 151 _endpoint->type_ptr = (uint8_t*)type.c_str();
mbedAustin 11:cada08fc8a70 152 _endpoint->type_len = type.length();
mbedAustin 11:cada08fc8a70 153 }
mbedAustin 11:cada08fc8a70 154 if(!domain.empty()) {
mbedAustin 11:cada08fc8a70 155 _endpoint->domain_name_ptr = (uint8_t*)domain.c_str();
mbedAustin 11:cada08fc8a70 156 _endpoint->domain_name_len = domain.length();
mbedAustin 11:cada08fc8a70 157 }
mbedAustin 11:cada08fc8a70 158 _endpoint->binding_and_mode = (sn_nsdl_oma_binding_and_mode_t)mode;
mbedAustin 11:cada08fc8a70 159
mbedAustin 11:cada08fc8a70 160 // If lifetime is less than zero then leave the field empty
mbedAustin 11:cada08fc8a70 161 if( life_time > 0) {
mbedAustin 11:cada08fc8a70 162 char *buffer = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 163 int size = snprintf(buffer, 20,"%ld",(long int)life_time);
mbedAustin 11:cada08fc8a70 164 if( _endpoint->lifetime_ptr == NULL ){
mbedAustin 11:cada08fc8a70 165 _endpoint->lifetime_ptr = (uint8_t*)memory_alloc(size+1);
mbedAustin 11:cada08fc8a70 166 }
mbedAustin 11:cada08fc8a70 167 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 168 memset(_endpoint->lifetime_ptr, 0, size+1);
mbedAustin 11:cada08fc8a70 169 memcpy(_endpoint->lifetime_ptr,buffer,size);
mbedAustin 11:cada08fc8a70 170 _endpoint->lifetime_len = size;
mbedAustin 11:cada08fc8a70 171 }
mbedAustin 11:cada08fc8a70 172 memory_free(buffer);
mbedAustin 11:cada08fc8a70 173 }
mbedAustin 11:cada08fc8a70 174 }
mbedAustin 11:cada08fc8a70 175 }
mbedAustin 11:cada08fc8a70 176
mbedAustin 11:cada08fc8a70 177 void M2MNsdlInterface::delete_endpoint()
mbedAustin 11:cada08fc8a70 178 {
mbedAustin 11:cada08fc8a70 179 tr_debug("M2MNsdlInterface::delete_endpoint()");
mbedAustin 11:cada08fc8a70 180 if(_endpoint) {
mbedAustin 11:cada08fc8a70 181 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 182 free(_endpoint->lifetime_ptr);
mbedAustin 11:cada08fc8a70 183 _endpoint->lifetime_ptr = NULL;
mbedAustin 11:cada08fc8a70 184 }
mbedAustin 11:cada08fc8a70 185 memory_free(_endpoint);
mbedAustin 11:cada08fc8a70 186 _endpoint = NULL;
mbedAustin 11:cada08fc8a70 187 }
mbedAustin 11:cada08fc8a70 188 }
mbedAustin 11:cada08fc8a70 189
mbedAustin 11:cada08fc8a70 190 bool M2MNsdlInterface::create_nsdl_list_structure(const M2MObjectList &object_list)
mbedAustin 11:cada08fc8a70 191 {
mbedAustin 11:cada08fc8a70 192 tr_debug("M2MNsdlInterface::create_nsdl_list_structure()");
mbedAustin 11:cada08fc8a70 193 bool success = false;
mbedAustin 11:cada08fc8a70 194 if(!object_list.empty()) {
mbedAustin 11:cada08fc8a70 195 tr_debug("M2MNsdlInterface::create_nsdl_list_structure - Object count is %d", object_list.size());
mbedAustin 11:cada08fc8a70 196 M2MObjectList::const_iterator it;
mbedAustin 11:cada08fc8a70 197 it = object_list.begin();
mbedAustin 11:cada08fc8a70 198 for ( ; it != object_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 199 // Create NSDL structure for all Objects inside
mbedAustin 11:cada08fc8a70 200 success = create_nsdl_object_structure(*it);
mbedAustin 11:cada08fc8a70 201 add_object_to_list(*it);
mbedAustin 11:cada08fc8a70 202 }
mbedAustin 11:cada08fc8a70 203 }
mbedAustin 11:cada08fc8a70 204 return success;
mbedAustin 11:cada08fc8a70 205 }
mbedAustin 11:cada08fc8a70 206
mbedAustin 11:cada08fc8a70 207 bool M2MNsdlInterface::delete_nsdl_resource(const String &resource_name)
mbedAustin 11:cada08fc8a70 208 {
mbedAustin 11:cada08fc8a70 209 tr_debug("M2MNsdlInterface::delete_nsdl_resource( %s)", resource_name.c_str());
mbedAustin 11:cada08fc8a70 210 return (sn_nsdl_delete_resource(_nsdl_handle,
mbedAustin 11:cada08fc8a70 211 resource_name.length(),
mbedAustin 11:cada08fc8a70 212 (uint8_t *)resource_name.c_str()) == 0) ? true : false;
mbedAustin 11:cada08fc8a70 213 }
mbedAustin 11:cada08fc8a70 214
mbedAustin 11:cada08fc8a70 215 bool M2MNsdlInterface::create_bootstrap_resource(sn_nsdl_addr_s *address)
mbedAustin 11:cada08fc8a70 216 {
mbedAustin 11:cada08fc8a70 217 tr_debug("M2MNsdlInterface::create_bootstrap_resource()");
mbedAustin 11:cada08fc8a70 218 bool success = false;
mbedAustin 11:cada08fc8a70 219 _bootstrap_device_setup.error_code = NO_ERROR;
mbedAustin 11:cada08fc8a70 220 _bootstrap_device_setup.sn_oma_device_boot_callback = 0;
mbedAustin 11:cada08fc8a70 221
mbedAustin 11:cada08fc8a70 222 _bootstrap_endpoint.device_object = &_bootstrap_device_setup;
mbedAustin 11:cada08fc8a70 223 _bootstrap_endpoint.oma_bs_status_cb = &__nsdl_c_bootstrap_done;
mbedAustin 11:cada08fc8a70 224
mbedAustin 11:cada08fc8a70 225 if(_bootstrap_id == 0) {
mbedAustin 11:cada08fc8a70 226 _bootstrap_id = sn_nsdl_oma_bootstrap(_nsdl_handle,
mbedAustin 11:cada08fc8a70 227 address,
mbedAustin 11:cada08fc8a70 228 _endpoint,
mbedAustin 11:cada08fc8a70 229 &_bootstrap_endpoint);
mbedAustin 11:cada08fc8a70 230 tr_debug("M2MNsdlInterface::create_bootstrap_resource - _bootstrap_id %d", _bootstrap_id);
mbedAustin 11:cada08fc8a70 231 success = _bootstrap_id != 0;
mbedAustin 11:cada08fc8a70 232
mbedAustin 11:cada08fc8a70 233 }
mbedAustin 11:cada08fc8a70 234 return success;
mbedAustin 11:cada08fc8a70 235 }
mbedAustin 11:cada08fc8a70 236
mbedAustin 11:cada08fc8a70 237 bool M2MNsdlInterface::send_register_message(uint8_t* address,
mbedAustin 11:cada08fc8a70 238 const uint16_t port,
mbedAustin 11:cada08fc8a70 239 sn_nsdl_addr_type_e address_type)
mbedAustin 11:cada08fc8a70 240 {
mbedAustin 11:cada08fc8a70 241 tr_debug("M2MNsdlInterface::send_register_message()");
mbedAustin 11:cada08fc8a70 242 bool success = false;
mbedAustin 11:cada08fc8a70 243 if(set_NSP_address(_nsdl_handle,address, port, address_type) == 0) {
mbedAustin 11:cada08fc8a70 244 if(_register_id == 0) {
mbedAustin 11:cada08fc8a70 245 _register_id = sn_nsdl_register_endpoint(_nsdl_handle,_endpoint);
mbedAustin 11:cada08fc8a70 246 tr_debug("M2MNsdlInterface::send_register_message - _register_id %d", _register_id);
mbedAustin 11:cada08fc8a70 247 success = _register_id != 0;
mbedAustin 11:cada08fc8a70 248 }
mbedAustin 11:cada08fc8a70 249 }
mbedAustin 11:cada08fc8a70 250 return success;
mbedAustin 11:cada08fc8a70 251 }
mbedAustin 11:cada08fc8a70 252
mbedAustin 11:cada08fc8a70 253 bool M2MNsdlInterface::send_update_registration(const uint32_t lifetime)
mbedAustin 11:cada08fc8a70 254 {
mbedAustin 11:cada08fc8a70 255 tr_debug("M2MNsdlInterface::send_update_registration( lifetime %d)", lifetime);
mbedAustin 11:cada08fc8a70 256 bool success = false;
mbedAustin 11:cada08fc8a70 257
mbedAustin 11:cada08fc8a70 258 create_nsdl_list_structure(_object_list);
mbedAustin 11:cada08fc8a70 259 //If Lifetime value is 0, then don't change the existing lifetime value
mbedAustin 11:cada08fc8a70 260 if(lifetime != 0) {
mbedAustin 11:cada08fc8a70 261 char *buffer = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 262 int size = snprintf(buffer, 20,"%ld",(long int)lifetime);
mbedAustin 11:cada08fc8a70 263 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 264 memory_free(_endpoint->lifetime_ptr);
mbedAustin 11:cada08fc8a70 265 _endpoint->lifetime_ptr = NULL;
mbedAustin 11:cada08fc8a70 266 _endpoint->lifetime_len = 0;
mbedAustin 11:cada08fc8a70 267 }
mbedAustin 11:cada08fc8a70 268
mbedAustin 11:cada08fc8a70 269 if(_endpoint->lifetime_ptr == NULL){
mbedAustin 11:cada08fc8a70 270 _endpoint->lifetime_ptr = (uint8_t*)memory_alloc(size+1);
mbedAustin 11:cada08fc8a70 271 }
mbedAustin 11:cada08fc8a70 272 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 273 memset(_endpoint->lifetime_ptr, 0, size+1);
mbedAustin 11:cada08fc8a70 274 memcpy(_endpoint->lifetime_ptr,buffer,size);
mbedAustin 11:cada08fc8a70 275 _endpoint->lifetime_len = size;
mbedAustin 11:cada08fc8a70 276 }
mbedAustin 11:cada08fc8a70 277 memory_free(buffer);
mbedAustin 11:cada08fc8a70 278
mbedAustin 11:cada08fc8a70 279 _registration_timer->stop_timer();
mbedAustin 11:cada08fc8a70 280 _registration_timer->start_timer(registration_time() * 1000,
mbedAustin 11:cada08fc8a70 281 M2MTimerObserver::Registration,
mbedAustin 11:cada08fc8a70 282 false);
mbedAustin 11:cada08fc8a70 283 if(_nsdl_handle &&
mbedAustin 11:cada08fc8a70 284 _endpoint && _endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 285 _update_id = sn_nsdl_update_registration(_nsdl_handle,
mbedAustin 11:cada08fc8a70 286 _endpoint->lifetime_ptr,
mbedAustin 11:cada08fc8a70 287 _endpoint->lifetime_len);
mbedAustin 11:cada08fc8a70 288 tr_debug("M2MNsdlInterface::send_update_registration - New lifetime value _update_id %d", _update_id);
mbedAustin 11:cada08fc8a70 289 success = _update_id != 0;
mbedAustin 11:cada08fc8a70 290 }
mbedAustin 11:cada08fc8a70 291 } else {
mbedAustin 11:cada08fc8a70 292 if(_nsdl_handle) {
mbedAustin 11:cada08fc8a70 293 _update_id = sn_nsdl_update_registration(_nsdl_handle, NULL, 0);
mbedAustin 11:cada08fc8a70 294 tr_debug("M2MNsdlInterface::send_update_registration - regular update- _update_id %d", _update_id);
mbedAustin 11:cada08fc8a70 295 success = _update_id != 0;
mbedAustin 11:cada08fc8a70 296 }
mbedAustin 11:cada08fc8a70 297 }
mbedAustin 11:cada08fc8a70 298 return success;
mbedAustin 11:cada08fc8a70 299 }
mbedAustin 11:cada08fc8a70 300
mbedAustin 11:cada08fc8a70 301 bool M2MNsdlInterface::send_unregister_message()
mbedAustin 11:cada08fc8a70 302 {
mbedAustin 11:cada08fc8a70 303 tr_debug("M2MNsdlInterface::send_unregister_message");
mbedAustin 11:cada08fc8a70 304 bool success = false;
mbedAustin 11:cada08fc8a70 305 //Does not clean resources automatically
mbedAustin 11:cada08fc8a70 306 if(_unregister_id == 0) {
mbedAustin 11:cada08fc8a70 307 _unregister_id = sn_nsdl_unregister_endpoint(_nsdl_handle);
mbedAustin 11:cada08fc8a70 308 tr_debug("M2MNsdlInterface::send_unregister_message - _unregister_id %d", _unregister_id);
mbedAustin 11:cada08fc8a70 309 success = _unregister_id != 0;
mbedAustin 11:cada08fc8a70 310 }
mbedAustin 11:cada08fc8a70 311 return success;
mbedAustin 11:cada08fc8a70 312 }
mbedAustin 11:cada08fc8a70 313
mbedAustin 11:cada08fc8a70 314 void *M2MNsdlInterface::memory_alloc(uint16_t size)
mbedAustin 11:cada08fc8a70 315 {
mbedAustin 11:cada08fc8a70 316 if(size)
mbedAustin 11:cada08fc8a70 317 return malloc(size);
mbedAustin 11:cada08fc8a70 318 else
mbedAustin 11:cada08fc8a70 319 return 0;
mbedAustin 11:cada08fc8a70 320 }
mbedAustin 11:cada08fc8a70 321
mbedAustin 11:cada08fc8a70 322 void M2MNsdlInterface::memory_free(void *ptr)
mbedAustin 11:cada08fc8a70 323 {
mbedAustin 11:cada08fc8a70 324 if(ptr)
mbedAustin 11:cada08fc8a70 325 free(ptr);
mbedAustin 11:cada08fc8a70 326 }
mbedAustin 11:cada08fc8a70 327
mbedAustin 11:cada08fc8a70 328 uint8_t M2MNsdlInterface::send_to_server_callback(struct nsdl_s * /*nsdl_handle*/,
mbedAustin 11:cada08fc8a70 329 sn_nsdl_capab_e /*protocol*/,
mbedAustin 11:cada08fc8a70 330 uint8_t *data_ptr,
mbedAustin 11:cada08fc8a70 331 uint16_t data_len,
mbedAustin 11:cada08fc8a70 332 sn_nsdl_addr_s *address)
mbedAustin 11:cada08fc8a70 333 {
mbedAustin 11:cada08fc8a70 334 tr_debug("M2MNsdlInterface::send_to_server_callback()");
mbedAustin 11:cada08fc8a70 335 _observer.coap_message_ready(data_ptr,data_len,address);
mbedAustin 11:cada08fc8a70 336 return 1;
mbedAustin 11:cada08fc8a70 337 }
mbedAustin 11:cada08fc8a70 338
mbedAustin 11:cada08fc8a70 339 uint8_t M2MNsdlInterface::received_from_server_callback(struct nsdl_s * /*nsdl_handle*/,
mbedAustin 11:cada08fc8a70 340 sn_coap_hdr_s *coap_header,
mbedAustin 11:cada08fc8a70 341 sn_nsdl_addr_s *address)
mbedAustin 11:cada08fc8a70 342 {
mbedAustin 11:cada08fc8a70 343 tr_debug("M2MNsdlInterface::received_from_server_callback()");
mbedAustin 11:cada08fc8a70 344 _observer.coap_data_processed();
mbedAustin 11:cada08fc8a70 345 uint8_t value = 0;
mbedAustin 11:cada08fc8a70 346 if(coap_header) {
mbedAustin 11:cada08fc8a70 347 if(coap_header->msg_id == _register_id) {
mbedAustin 11:cada08fc8a70 348 _register_id = 0;
mbedAustin 11:cada08fc8a70 349 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_CREATED) {
mbedAustin 11:cada08fc8a70 350 if(_server) {
mbedAustin 11:cada08fc8a70 351 delete _server;
mbedAustin 11:cada08fc8a70 352 _server = NULL;
mbedAustin 11:cada08fc8a70 353 }
mbedAustin 11:cada08fc8a70 354 tr_debug("M2MNsdlInterface::received_from_server_callback - registration callback");
mbedAustin 11:cada08fc8a70 355 _server = new M2MServer();
mbedAustin 11:cada08fc8a70 356 _server->set_resource_value(M2MServer::ShortServerID,1);
mbedAustin 11:cada08fc8a70 357
mbedAustin 11:cada08fc8a70 358 _observer.client_registered(_server);
mbedAustin 11:cada08fc8a70 359 // If lifetime is less than zero then leave the field empty
mbedAustin 11:cada08fc8a70 360 if(coap_header->options_list_ptr) {
mbedAustin 11:cada08fc8a70 361 if(coap_header->options_list_ptr->max_age_ptr) {
mbedAustin 11:cada08fc8a70 362 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 363 memory_free(_endpoint->lifetime_ptr);
mbedAustin 11:cada08fc8a70 364 _endpoint->lifetime_ptr = NULL;
mbedAustin 11:cada08fc8a70 365 _endpoint->lifetime_len = 0;
mbedAustin 11:cada08fc8a70 366 }
mbedAustin 11:cada08fc8a70 367 uint32_t max_time = 0;
mbedAustin 11:cada08fc8a70 368 for(int i=0;i < coap_header->options_list_ptr->max_age_len; i++) {
mbedAustin 11:cada08fc8a70 369 max_time += (*(coap_header->options_list_ptr->max_age_ptr + i) & 0xff) <<
mbedAustin 11:cada08fc8a70 370 8*(coap_header->options_list_ptr->max_age_len- 1 - i);
mbedAustin 11:cada08fc8a70 371 }
mbedAustin 11:cada08fc8a70 372 // If lifetime is less than zero then leave the field empty
mbedAustin 11:cada08fc8a70 373 if( max_time > 0) {
mbedAustin 11:cada08fc8a70 374 char *buffer = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 375 if(buffer) {
mbedAustin 11:cada08fc8a70 376 int size = snprintf(buffer, 20,"%ld",(long int)max_time);
mbedAustin 11:cada08fc8a70 377 _endpoint->lifetime_ptr = (uint8_t*)memory_alloc(size+1);
mbedAustin 11:cada08fc8a70 378
mbedAustin 11:cada08fc8a70 379 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 380 memset(_endpoint->lifetime_ptr, 0, size+1);
mbedAustin 11:cada08fc8a70 381 memcpy(_endpoint->lifetime_ptr,buffer,size);
mbedAustin 11:cada08fc8a70 382 _endpoint->lifetime_len = size;
mbedAustin 11:cada08fc8a70 383 }
mbedAustin 11:cada08fc8a70 384 memory_free(buffer);
mbedAustin 11:cada08fc8a70 385 }
mbedAustin 11:cada08fc8a70 386 }
mbedAustin 11:cada08fc8a70 387 }
mbedAustin 11:cada08fc8a70 388 if(coap_header->options_list_ptr->location_path_ptr) {
mbedAustin 11:cada08fc8a70 389 _endpoint->location_ptr = (uint8_t*)memory_alloc(coap_header->options_list_ptr->location_path_len+1);
mbedAustin 11:cada08fc8a70 390 memset(_endpoint->location_ptr,0,coap_header->options_list_ptr->location_path_len+1);
mbedAustin 11:cada08fc8a70 391 memcpy(_endpoint->location_ptr,
mbedAustin 11:cada08fc8a70 392 coap_header->options_list_ptr->location_path_ptr,
mbedAustin 11:cada08fc8a70 393 coap_header->options_list_ptr->location_path_len);
mbedAustin 11:cada08fc8a70 394 _endpoint->location_len = coap_header->options_list_ptr->location_path_len ;
mbedAustin 11:cada08fc8a70 395 sn_nsdl_set_endpoint_location(_nsdl_handle,_endpoint->location_ptr,_endpoint->location_len);
mbedAustin 11:cada08fc8a70 396 }
mbedAustin 11:cada08fc8a70 397 }
mbedAustin 11:cada08fc8a70 398 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 399 _registration_timer->stop_timer();
mbedAustin 11:cada08fc8a70 400 _registration_timer->start_timer(registration_time() * 1000,
mbedAustin 11:cada08fc8a70 401 M2MTimerObserver::Registration,
mbedAustin 11:cada08fc8a70 402 false);
mbedAustin 11:cada08fc8a70 403 }
mbedAustin 11:cada08fc8a70 404 } else {
mbedAustin 11:cada08fc8a70 405 if(_server) {
mbedAustin 11:cada08fc8a70 406 delete _server;
mbedAustin 11:cada08fc8a70 407 _server = NULL;
mbedAustin 11:cada08fc8a70 408 }
mbedAustin 11:cada08fc8a70 409 tr_error("M2MNsdlInterface::received_from_server_callback - registration error %d", coap_header->msg_code);
mbedAustin 11:cada08fc8a70 410 M2MInterface::Error error = interface_error(coap_header);
mbedAustin 11:cada08fc8a70 411 _observer.registration_error(error);
mbedAustin 11:cada08fc8a70 412 }
mbedAustin 11:cada08fc8a70 413 } else if(coap_header->msg_id == _unregister_id) {
mbedAustin 11:cada08fc8a70 414 _unregister_id = 0;
mbedAustin 11:cada08fc8a70 415 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_DELETED) {
mbedAustin 11:cada08fc8a70 416 _registration_timer->stop_timer();
mbedAustin 11:cada08fc8a70 417 if(_server) {
mbedAustin 11:cada08fc8a70 418 delete _server;
mbedAustin 11:cada08fc8a70 419 _server = NULL;
mbedAustin 11:cada08fc8a70 420 }
mbedAustin 11:cada08fc8a70 421 tr_debug("M2MNsdlInterface::received_from_server_callback - unregistration callback");
mbedAustin 11:cada08fc8a70 422 _observer.client_unregistered();
mbedAustin 11:cada08fc8a70 423 } else {
mbedAustin 11:cada08fc8a70 424 tr_error("M2MNsdlInterface::received_from_server_callback - unregistration error %d", coap_header->msg_code);
mbedAustin 11:cada08fc8a70 425 M2MInterface::Error error = interface_error(coap_header);
mbedAustin 11:cada08fc8a70 426 _observer.registration_error(error);
mbedAustin 11:cada08fc8a70 427 }
mbedAustin 11:cada08fc8a70 428 } else if(coap_header->msg_id == _update_id) {
mbedAustin 11:cada08fc8a70 429 _update_id = 0;
mbedAustin 11:cada08fc8a70 430
mbedAustin 11:cada08fc8a70 431 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_CHANGED) {
mbedAustin 11:cada08fc8a70 432 tr_debug("M2MNsdlInterface::received_from_server_callback - registration_updated successfully");
mbedAustin 11:cada08fc8a70 433 _observer.registration_updated(*_server);
mbedAustin 11:cada08fc8a70 434 } else {
mbedAustin 11:cada08fc8a70 435 tr_error("M2MNsdlInterface::received_from_server_callback - registration_updated failed %d", coap_header->msg_code);
mbedAustin 11:cada08fc8a70 436 M2MInterface::Error error = interface_error(coap_header);
mbedAustin 11:cada08fc8a70 437 // In case, the error for update registration is not allowed implies the client is no longer registered in
mbedAustin 11:cada08fc8a70 438 // server hence the error returns should be NotRegistered.
mbedAustin 11:cada08fc8a70 439 if(M2MInterface::NotAllowed == error) {
mbedAustin 11:cada08fc8a70 440 error = M2MInterface::NotRegistered;
mbedAustin 11:cada08fc8a70 441 }
mbedAustin 11:cada08fc8a70 442 _observer.registration_error(error);
mbedAustin 11:cada08fc8a70 443 }
mbedAustin 11:cada08fc8a70 444 }else if(coap_header->msg_id == _bootstrap_id) {
mbedAustin 11:cada08fc8a70 445 _bootstrap_id = 0;
mbedAustin 11:cada08fc8a70 446 M2MInterface::Error error = interface_error(coap_header);
mbedAustin 11:cada08fc8a70 447 if(error != M2MInterface::ErrorNone) {
mbedAustin 11:cada08fc8a70 448 _observer.bootstrap_error();
mbedAustin 11:cada08fc8a70 449 }
mbedAustin 11:cada08fc8a70 450 } else {
mbedAustin 11:cada08fc8a70 451 if(COAP_MSG_CODE_REQUEST_POST == coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 452 if(coap_header->uri_path_ptr) {
mbedAustin 11:cada08fc8a70 453 String resource_name = coap_to_string(coap_header->uri_path_ptr,
mbedAustin 11:cada08fc8a70 454 coap_header->uri_path_len);
mbedAustin 11:cada08fc8a70 455
mbedAustin 11:cada08fc8a70 456 sn_coap_hdr_s *coap_response = NULL;
mbedAustin 11:cada08fc8a70 457 String object_name;
mbedAustin 11:cada08fc8a70 458 int slash_found = resource_name.find_last_of('/');
mbedAustin 11:cada08fc8a70 459 //The POST operation here is only allowed for non-existing object instances
mbedAustin 11:cada08fc8a70 460 if(slash_found != -1) {
mbedAustin 11:cada08fc8a70 461 object_name = resource_name.substr(0,slash_found);
mbedAustin 11:cada08fc8a70 462 if( object_name.find_last_of('/') != -1){
mbedAustin 11:cada08fc8a70 463 coap_response = sn_nsdl_build_response(_nsdl_handle,
mbedAustin 11:cada08fc8a70 464 coap_header,
mbedAustin 11:cada08fc8a70 465 COAP_MSG_CODE_RESPONSE_NOT_FOUND);
mbedAustin 11:cada08fc8a70 466 } else {
mbedAustin 11:cada08fc8a70 467 int32_t instance_id = atoi(resource_name.substr(slash_found+1,
mbedAustin 11:cada08fc8a70 468 resource_name.size()-object_name.size()).c_str());
mbedAustin 11:cada08fc8a70 469 M2MBase* base = find_resource(object_name);
mbedAustin 11:cada08fc8a70 470 if(base && (instance_id >= 0) && (instance_id < 65535)) {
mbedAustin 11:cada08fc8a70 471 if(coap_header->payload_ptr) {
mbedAustin 11:cada08fc8a70 472 M2MObject* object = (M2MObject*)base;
mbedAustin 11:cada08fc8a70 473 M2MObjectInstance *obj_instance = object->create_object_instance(instance_id);
mbedAustin 11:cada08fc8a70 474 if(obj_instance) {
mbedAustin 11:cada08fc8a70 475 obj_instance->set_operation(M2MBase::GET_PUT_POST_ALLOWED);
mbedAustin 11:cada08fc8a70 476 coap_response = obj_instance->handle_post_request(_nsdl_handle,coap_header,this);
mbedAustin 11:cada08fc8a70 477 }
mbedAustin 11:cada08fc8a70 478 if(coap_response && coap_response->msg_code != COAP_MSG_CODE_RESPONSE_CREATED) {
mbedAustin 11:cada08fc8a70 479 //Invalid request so remove created ObjectInstance
mbedAustin 11:cada08fc8a70 480 object->remove_object_instance(instance_id);
mbedAustin 11:cada08fc8a70 481 }
mbedAustin 11:cada08fc8a70 482 } else {
mbedAustin 11:cada08fc8a70 483 tr_debug("M2MNsdlInterface::received_from_server_callback - Missing Payload - Cannot create");
mbedAustin 11:cada08fc8a70 484 coap_response = sn_nsdl_build_response(_nsdl_handle,
mbedAustin 11:cada08fc8a70 485 coap_header,
mbedAustin 11:cada08fc8a70 486 COAP_MSG_CODE_RESPONSE_BAD_REQUEST);
mbedAustin 11:cada08fc8a70 487 }
mbedAustin 11:cada08fc8a70 488 } else { //if(base)
mbedAustin 11:cada08fc8a70 489 tr_debug("M2MNsdlInterface::received_from_server_callback - Missing BASE - Cannot create");
mbedAustin 11:cada08fc8a70 490 coap_response = sn_nsdl_build_response(_nsdl_handle,
mbedAustin 11:cada08fc8a70 491 coap_header,
mbedAustin 11:cada08fc8a70 492 COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED);
mbedAustin 11:cada08fc8a70 493 }
mbedAustin 11:cada08fc8a70 494 }
mbedAustin 11:cada08fc8a70 495 } else{ // if(slash_found != -1)
mbedAustin 11:cada08fc8a70 496 tr_debug("M2MNsdlInterface::received_from_server_callback - slash_found - Cannot create");
mbedAustin 11:cada08fc8a70 497 coap_response = sn_nsdl_build_response(_nsdl_handle,
mbedAustin 11:cada08fc8a70 498 coap_header,
mbedAustin 11:cada08fc8a70 499 COAP_MSG_CODE_RESPONSE_NOT_FOUND);
mbedAustin 11:cada08fc8a70 500 }
mbedAustin 11:cada08fc8a70 501 if(coap_response) {
mbedAustin 11:cada08fc8a70 502 tr_debug("M2MNsdlInterface::received_from_server_callback - send CoAP response");
mbedAustin 11:cada08fc8a70 503 (sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response) == 0) ? value = 0 : value = 1;
mbedAustin 11:cada08fc8a70 504 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
mbedAustin 11:cada08fc8a70 505 }
mbedAustin 11:cada08fc8a70 506 }
mbedAustin 11:cada08fc8a70 507 }
mbedAustin 11:cada08fc8a70 508 }
mbedAustin 11:cada08fc8a70 509 }
mbedAustin 11:cada08fc8a70 510 return value;
mbedAustin 11:cada08fc8a70 511 }
mbedAustin 11:cada08fc8a70 512
mbedAustin 11:cada08fc8a70 513 uint8_t M2MNsdlInterface::resource_callback(struct nsdl_s */*nsdl_handle*/,
mbedAustin 11:cada08fc8a70 514 sn_coap_hdr_s *received_coap_header,
mbedAustin 11:cada08fc8a70 515 sn_nsdl_addr_s *address,
mbedAustin 11:cada08fc8a70 516 sn_nsdl_capab_e /*nsdl_capab*/)
mbedAustin 11:cada08fc8a70 517 {
mbedAustin 11:cada08fc8a70 518 tr_debug("M2MNsdlInterface::resource_callback()");
mbedAustin 11:cada08fc8a70 519 _observer.coap_data_processed();
mbedAustin 11:cada08fc8a70 520 uint8_t result = 1;
mbedAustin 11:cada08fc8a70 521 sn_coap_hdr_s *coap_response = NULL;
mbedAustin 11:cada08fc8a70 522 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 4.00
mbedAustin 11:cada08fc8a70 523 String resource_name = coap_to_string(received_coap_header->uri_path_ptr,
mbedAustin 11:cada08fc8a70 524 received_coap_header->uri_path_len);
mbedAustin 11:cada08fc8a70 525 tr_debug("M2MNsdlInterface::resource_callback() - resource_name %s", resource_name.c_str());
mbedAustin 11:cada08fc8a70 526 M2MBase* base = find_resource(resource_name);
mbedAustin 11:cada08fc8a70 527
mbedAustin 11:cada08fc8a70 528 if(base) {
mbedAustin 11:cada08fc8a70 529 if(COAP_MSG_CODE_REQUEST_GET == received_coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 530 coap_response = base->handle_get_request(_nsdl_handle, received_coap_header,this);
mbedAustin 11:cada08fc8a70 531 } else if(COAP_MSG_CODE_REQUEST_PUT == received_coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 532 coap_response = base->handle_put_request(_nsdl_handle, received_coap_header,this);
mbedAustin 11:cada08fc8a70 533 } else if(COAP_MSG_CODE_REQUEST_POST == received_coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 534 if(base->base_type() == M2MBase::ResourceInstance) {
mbedAustin 11:cada08fc8a70 535 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
mbedAustin 11:cada08fc8a70 536 } else {
mbedAustin 11:cada08fc8a70 537 coap_response = base->handle_post_request(_nsdl_handle, received_coap_header,this);
mbedAustin 11:cada08fc8a70 538 }
mbedAustin 11:cada08fc8a70 539 } else if(COAP_MSG_CODE_REQUEST_DELETE == received_coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 540 // Delete the object instance
mbedAustin 11:cada08fc8a70 541 tr_debug("M2MNsdlInterface::resource_callback() - DELETE the object instance");
mbedAustin 11:cada08fc8a70 542 M2MBase::BaseType type = base->base_type();
mbedAustin 11:cada08fc8a70 543 if(M2MBase::ObjectInstance == type) {
mbedAustin 11:cada08fc8a70 544 M2MBase* base_object = find_resource(base->name());
mbedAustin 11:cada08fc8a70 545 if(base_object) {
mbedAustin 11:cada08fc8a70 546 M2MObject *object = (M2MObject*)base_object;
mbedAustin 11:cada08fc8a70 547 int slash_found = resource_name.find_last_of('/');
mbedAustin 11:cada08fc8a70 548 // Object instance validty checks done in upper level, no need for error handling
mbedAustin 11:cada08fc8a70 549 if(slash_found != -1) {
mbedAustin 11:cada08fc8a70 550 String object_name;
mbedAustin 11:cada08fc8a70 551 object_name = resource_name.substr(slash_found + 1, resource_name.length());
mbedAustin 11:cada08fc8a70 552 if (object->remove_object_instance(strtoul(
mbedAustin 11:cada08fc8a70 553 object_name.c_str(), NULL, 10))) {
mbedAustin 11:cada08fc8a70 554 msg_code = COAP_MSG_CODE_RESPONSE_DELETED;
mbedAustin 11:cada08fc8a70 555 }
mbedAustin 11:cada08fc8a70 556 }
mbedAustin 11:cada08fc8a70 557 }
mbedAustin 11:cada08fc8a70 558 } else {
mbedAustin 11:cada08fc8a70 559 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
mbedAustin 11:cada08fc8a70 560 }
mbedAustin 11:cada08fc8a70 561 }
mbedAustin 11:cada08fc8a70 562 } else {
mbedAustin 11:cada08fc8a70 563 tr_debug("M2MNsdlInterface::resource_callback() - Resource NOT FOUND");
mbedAustin 11:cada08fc8a70 564 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
mbedAustin 11:cada08fc8a70 565 }
mbedAustin 11:cada08fc8a70 566 if(!coap_response) {
mbedAustin 11:cada08fc8a70 567 coap_response = sn_nsdl_build_response(_nsdl_handle,
mbedAustin 11:cada08fc8a70 568 received_coap_header,
mbedAustin 11:cada08fc8a70 569 msg_code);
mbedAustin 11:cada08fc8a70 570 }
mbedAustin 11:cada08fc8a70 571 if(coap_response) {
mbedAustin 11:cada08fc8a70 572 tr_debug("M2MNsdlInterface::resource_callback() - send CoAP response");
mbedAustin 11:cada08fc8a70 573 (sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response) == 0) ? result = 0 : result = 1;
mbedAustin 11:cada08fc8a70 574 if(coap_response->payload_ptr) {
mbedAustin 11:cada08fc8a70 575 free(coap_response->payload_ptr);
mbedAustin 11:cada08fc8a70 576 coap_response->payload_ptr = NULL;
mbedAustin 11:cada08fc8a70 577 }
mbedAustin 11:cada08fc8a70 578 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
mbedAustin 11:cada08fc8a70 579 }
mbedAustin 11:cada08fc8a70 580 return result;
mbedAustin 11:cada08fc8a70 581 }
mbedAustin 11:cada08fc8a70 582
mbedAustin 11:cada08fc8a70 583 void M2MNsdlInterface::bootstrap_done_callback(sn_nsdl_oma_server_info_t *server_info)
mbedAustin 11:cada08fc8a70 584 {
mbedAustin 11:cada08fc8a70 585 tr_debug("M2MNsdlInterface::bootstrap_done_callback()");
mbedAustin 11:cada08fc8a70 586 _bootstrap_id = 0;
mbedAustin 11:cada08fc8a70 587 M2MSecurity* security = NULL;
mbedAustin 11:cada08fc8a70 588 if(server_info && server_info->omalw_address_ptr->addr_ptr) {
mbedAustin 11:cada08fc8a70 589 security = new M2MSecurity(M2MSecurity::M2MServer);
mbedAustin 11:cada08fc8a70 590 uint16_t port = server_info->omalw_address_ptr->port;
mbedAustin 11:cada08fc8a70 591 char *buffer = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 592 snprintf(buffer, 20,"%d",port);
mbedAustin 11:cada08fc8a70 593 String server_uri(COAP);
mbedAustin 11:cada08fc8a70 594 String server_address;
mbedAustin 11:cada08fc8a70 595 //TODO: currently only supports IPV4 Mapping, fix to support IPV6 as well
mbedAustin 11:cada08fc8a70 596 if(SN_NSDL_ADDRESS_TYPE_IPV4 == server_info->omalw_address_ptr->type) {
mbedAustin 11:cada08fc8a70 597 int val = 0;
mbedAustin 11:cada08fc8a70 598 for(int index = 0; index < server_info->omalw_address_ptr->addr_len; index++) {
mbedAustin 11:cada08fc8a70 599 char *server_buffer = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 600 val = (int)server_info->omalw_address_ptr->addr_ptr[index];
mbedAustin 11:cada08fc8a70 601 snprintf(server_buffer, 20,"%d",val);
mbedAustin 11:cada08fc8a70 602 server_address +=String(server_buffer);
mbedAustin 11:cada08fc8a70 603
mbedAustin 11:cada08fc8a70 604 memory_free(server_buffer);
mbedAustin 11:cada08fc8a70 605
mbedAustin 11:cada08fc8a70 606 if(index < server_info->omalw_address_ptr->addr_len-1) {
mbedAustin 11:cada08fc8a70 607 server_address += String(".");
mbedAustin 11:cada08fc8a70 608 }
mbedAustin 11:cada08fc8a70 609 }
mbedAustin 11:cada08fc8a70 610
mbedAustin 11:cada08fc8a70 611 tr_debug("M2MNsdlInterface::bootstrap_done_callback - IPv4 Server address received %s", server_address.c_str());
mbedAustin 11:cada08fc8a70 612 } else if(SN_NSDL_ADDRESS_TYPE_HOSTNAME == server_info->omalw_address_ptr->type) {
mbedAustin 11:cada08fc8a70 613 char *hostname = (char*)memory_alloc(server_info->omalw_address_ptr->addr_len);
mbedAustin 11:cada08fc8a70 614 if(hostname) {
mbedAustin 11:cada08fc8a70 615 memset(hostname, 0, server_info->omalw_address_ptr->addr_len);
mbedAustin 11:cada08fc8a70 616 memcpy(hostname,
mbedAustin 11:cada08fc8a70 617 server_info->omalw_address_ptr->addr_ptr,
mbedAustin 11:cada08fc8a70 618 server_info->omalw_address_ptr->addr_len);
mbedAustin 11:cada08fc8a70 619 server_address += String(hostname);
mbedAustin 11:cada08fc8a70 620 memory_free(hostname);
mbedAustin 11:cada08fc8a70 621 hostname = NULL;
mbedAustin 11:cada08fc8a70 622 tr_debug("M2MNsdlInterface::bootstrap_done_callback - Hostname Server address received %s", server_address.c_str());
mbedAustin 11:cada08fc8a70 623 }
mbedAustin 11:cada08fc8a70 624 } else if(SN_NSDL_ADDRESS_TYPE_IPV6 == server_info->omalw_address_ptr->type) {
mbedAustin 11:cada08fc8a70 625 char ipv6_address[40];
mbedAustin 11:cada08fc8a70 626 ip6tos(server_info->omalw_address_ptr->addr_ptr, ipv6_address);
mbedAustin 11:cada08fc8a70 627 server_address += String(ipv6_address);
mbedAustin 11:cada08fc8a70 628 tr_debug("M2MNsdlInterface::bootstrap_done_callback - IPv6 Server address received %s", server_address.c_str());
mbedAustin 11:cada08fc8a70 629 }
mbedAustin 11:cada08fc8a70 630
mbedAustin 11:cada08fc8a70 631 server_uri += server_address;
mbedAustin 11:cada08fc8a70 632 server_uri +=String(":");
mbedAustin 11:cada08fc8a70 633 server_uri += String(buffer);
mbedAustin 11:cada08fc8a70 634
mbedAustin 11:cada08fc8a70 635 memory_free(buffer);
mbedAustin 11:cada08fc8a70 636 security->set_resource_value(M2MSecurity::M2MServerUri, server_uri);
mbedAustin 11:cada08fc8a70 637 security->set_resource_value(M2MSecurity::BootstrapServer, 0);
mbedAustin 11:cada08fc8a70 638
mbedAustin 11:cada08fc8a70 639 M2MSecurity::SecurityModeType security_mode = M2MSecurity::SecurityNotSet;
mbedAustin 11:cada08fc8a70 640
mbedAustin 11:cada08fc8a70 641 switch(server_info->omalw_server_security) {
mbedAustin 11:cada08fc8a70 642 case SEC_NOT_SET:
mbedAustin 11:cada08fc8a70 643 security_mode = M2MSecurity::SecurityNotSet;
mbedAustin 11:cada08fc8a70 644 break;
mbedAustin 11:cada08fc8a70 645 case PSK:
mbedAustin 11:cada08fc8a70 646 //Not supported at the moment
mbedAustin 11:cada08fc8a70 647 break;
mbedAustin 11:cada08fc8a70 648 case RPK:
mbedAustin 11:cada08fc8a70 649 //Not supported at the moment
mbedAustin 11:cada08fc8a70 650 break;
mbedAustin 11:cada08fc8a70 651 case CERTIFICATE:
mbedAustin 11:cada08fc8a70 652 security_mode = M2MSecurity::Certificate;
mbedAustin 11:cada08fc8a70 653 break;
mbedAustin 11:cada08fc8a70 654 case NO_SEC:
mbedAustin 11:cada08fc8a70 655 security_mode = M2MSecurity::NoSecurity;
mbedAustin 11:cada08fc8a70 656 break;
mbedAustin 11:cada08fc8a70 657 }
mbedAustin 11:cada08fc8a70 658 security->set_resource_value(M2MSecurity::SecurityMode,security_mode);
mbedAustin 11:cada08fc8a70 659
mbedAustin 11:cada08fc8a70 660 //TODO: This is mandatory parameter for LWM2M server,
mbedAustin 11:cada08fc8a70 661 // why is it missing from nsdl-c API ?
mbedAustin 11:cada08fc8a70 662 security->set_resource_value(M2MSecurity::ShortServerID,1);
mbedAustin 11:cada08fc8a70 663
mbedAustin 11:cada08fc8a70 664 // Check certiticates only if the mode is Certificate
mbedAustin 11:cada08fc8a70 665 // else it is in NoSecurity Mode, Psk and Rsk are not supported.
mbedAustin 11:cada08fc8a70 666 if(M2MSecurity::Certificate == security_mode) {
mbedAustin 11:cada08fc8a70 667 omalw_certificate_list_t *certificates = sn_nsdl_get_certificates(_nsdl_handle);
mbedAustin 11:cada08fc8a70 668 if(certificates) {
mbedAustin 11:cada08fc8a70 669 security->set_resource_value(M2MSecurity::ServerPublicKey,certificates->certificate_ptr[0],certificates->certificate_len[0]);
mbedAustin 11:cada08fc8a70 670 security->set_resource_value(M2MSecurity::PublicKey,certificates->certificate_ptr[1],certificates->certificate_len[1]);
mbedAustin 11:cada08fc8a70 671 security->set_resource_value(M2MSecurity::Secretkey,certificates->own_private_key_ptr,certificates->own_private_key_len);
mbedAustin 11:cada08fc8a70 672 } else {
mbedAustin 11:cada08fc8a70 673 // Mode is certificate but certificates are missing so its bootstrap error.
mbedAustin 11:cada08fc8a70 674 delete security;
mbedAustin 11:cada08fc8a70 675 security = NULL;
mbedAustin 11:cada08fc8a70 676 }
mbedAustin 11:cada08fc8a70 677 }
mbedAustin 11:cada08fc8a70 678 }
mbedAustin 11:cada08fc8a70 679 if(security) {
mbedAustin 11:cada08fc8a70 680 tr_debug("M2MNsdlInterface::bootstrap_done_callback - bootstrap_done");
mbedAustin 11:cada08fc8a70 681 // Inform that bootstrap is done and LWM2M server object is available.
mbedAustin 11:cada08fc8a70 682 _observer.bootstrap_done(security);
mbedAustin 11:cada08fc8a70 683 } else {
mbedAustin 11:cada08fc8a70 684 tr_error("M2MNsdlInterface::bootstrap_done_callback - bootstrap_error");
mbedAustin 11:cada08fc8a70 685 // Bootstrap error inform to the application.
mbedAustin 11:cada08fc8a70 686 _observer.bootstrap_error();
mbedAustin 11:cada08fc8a70 687 }
mbedAustin 11:cada08fc8a70 688 }
mbedAustin 11:cada08fc8a70 689
mbedAustin 11:cada08fc8a70 690 bool M2MNsdlInterface::process_received_data(uint8_t *data,
mbedAustin 11:cada08fc8a70 691 uint16_t data_size,
mbedAustin 11:cada08fc8a70 692 sn_nsdl_addr_s *address)
mbedAustin 11:cada08fc8a70 693 {
mbedAustin 11:cada08fc8a70 694 tr_debug("M2MNsdlInterface::process_received_data( data size %d)", data_size);
mbedAustin 11:cada08fc8a70 695 return (0 == sn_nsdl_process_coap(_nsdl_handle,
mbedAustin 11:cada08fc8a70 696 data,
mbedAustin 11:cada08fc8a70 697 data_size,
mbedAustin 11:cada08fc8a70 698 address)) ? true : false;
mbedAustin 11:cada08fc8a70 699 }
mbedAustin 11:cada08fc8a70 700
mbedAustin 11:cada08fc8a70 701 void M2MNsdlInterface::stop_timers()
mbedAustin 11:cada08fc8a70 702 {
mbedAustin 11:cada08fc8a70 703 tr_debug("M2MNsdlInterface::stop_timers()");
mbedAustin 11:cada08fc8a70 704 if(_registration_timer) {
mbedAustin 11:cada08fc8a70 705 _registration_timer->stop_timer();
mbedAustin 11:cada08fc8a70 706 }
mbedAustin 11:cada08fc8a70 707 }
mbedAustin 11:cada08fc8a70 708
mbedAustin 11:cada08fc8a70 709 void M2MNsdlInterface::timer_expired(M2MTimerObserver::Type type)
mbedAustin 11:cada08fc8a70 710 {
mbedAustin 11:cada08fc8a70 711 if(M2MTimerObserver::NsdlExecution == type) {
mbedAustin 11:cada08fc8a70 712 sn_nsdl_exec(_nsdl_handle, _counter_for_nsdl);
mbedAustin 11:cada08fc8a70 713 _counter_for_nsdl++;
mbedAustin 11:cada08fc8a70 714 } else if(M2MTimerObserver::Registration == type) {
mbedAustin 11:cada08fc8a70 715 tr_debug("M2MNsdlInterface::timer_expired - M2MTimerObserver::Registration - Send update registration");
mbedAustin 11:cada08fc8a70 716 send_update_registration();
mbedAustin 11:cada08fc8a70 717 }
mbedAustin 11:cada08fc8a70 718 }
mbedAustin 11:cada08fc8a70 719
mbedAustin 11:cada08fc8a70 720 void M2MNsdlInterface::observation_to_be_sent(M2MBase *object)
mbedAustin 11:cada08fc8a70 721 {
mbedAustin 11:cada08fc8a70 722 tr_debug("M2MNsdlInterface::observation_to_be_sent()");
mbedAustin 11:cada08fc8a70 723 if(object) {
mbedAustin 11:cada08fc8a70 724 M2MBase::BaseType type = object->base_type();
mbedAustin 11:cada08fc8a70 725 if(type == M2MBase::Object) {
mbedAustin 11:cada08fc8a70 726 send_object_observation((M2MObject*)object);
mbedAustin 11:cada08fc8a70 727 } else if(type == M2MBase::ObjectInstance) {
mbedAustin 11:cada08fc8a70 728 send_object_instance_observation((M2MObjectInstance*)object);
mbedAustin 11:cada08fc8a70 729 } else if(type == M2MBase::Resource) {
mbedAustin 11:cada08fc8a70 730 send_resource_observation((M2MResource*)object);
mbedAustin 11:cada08fc8a70 731 }
mbedAustin 11:cada08fc8a70 732 }
mbedAustin 11:cada08fc8a70 733 }
mbedAustin 11:cada08fc8a70 734
mbedAustin 11:cada08fc8a70 735 void M2MNsdlInterface::resource_to_be_deleted(const String &resource_name)
mbedAustin 11:cada08fc8a70 736 {
mbedAustin 11:cada08fc8a70 737 tr_debug("M2MNsdlInterface::resource_to_be_deleted(resource_name %s)", resource_name.c_str());
mbedAustin 11:cada08fc8a70 738 delete_nsdl_resource(resource_name);
mbedAustin 11:cada08fc8a70 739 }
mbedAustin 11:cada08fc8a70 740
mbedAustin 11:cada08fc8a70 741 void M2MNsdlInterface::value_updated(M2MBase *base,
mbedAustin 11:cada08fc8a70 742 const String &object_name)
mbedAustin 11:cada08fc8a70 743 {
mbedAustin 11:cada08fc8a70 744 tr_debug("M2MNsdlInterface::value_updated()");
mbedAustin 11:cada08fc8a70 745 if(base) {
mbedAustin 11:cada08fc8a70 746 switch(base->base_type()) {
mbedAustin 11:cada08fc8a70 747 case M2MBase::Object:
mbedAustin 11:cada08fc8a70 748 create_nsdl_object_structure((M2MObject*)base);
mbedAustin 11:cada08fc8a70 749 break;
mbedAustin 11:cada08fc8a70 750 case M2MBase::ObjectInstance:
mbedAustin 11:cada08fc8a70 751 create_nsdl_object_instance_structure((M2MObjectInstance*)base);
mbedAustin 11:cada08fc8a70 752 break;
mbedAustin 11:cada08fc8a70 753 case M2MBase::Resource: {
mbedAustin 11:cada08fc8a70 754 M2MResource* resource = (M2MResource*)base;
mbedAustin 11:cada08fc8a70 755 create_nsdl_resource_structure(resource,object_name,
mbedAustin 11:cada08fc8a70 756 resource->supports_multiple_instances());
mbedAustin 11:cada08fc8a70 757 }
mbedAustin 11:cada08fc8a70 758 break;
mbedAustin 11:cada08fc8a70 759 case M2MBase::ResourceInstance: {
mbedAustin 11:cada08fc8a70 760 M2MResourceInstance* instance = (M2MResourceInstance*)base;
mbedAustin 11:cada08fc8a70 761 create_nsdl_resource(instance,object_name);
mbedAustin 11:cada08fc8a70 762 }
mbedAustin 11:cada08fc8a70 763 break;
mbedAustin 11:cada08fc8a70 764 }
mbedAustin 11:cada08fc8a70 765 }
mbedAustin 11:cada08fc8a70 766 _observer.value_updated(base);
mbedAustin 11:cada08fc8a70 767 }
mbedAustin 11:cada08fc8a70 768
mbedAustin 11:cada08fc8a70 769 void M2MNsdlInterface::remove_object(M2MBase *object)
mbedAustin 11:cada08fc8a70 770 {
mbedAustin 11:cada08fc8a70 771 tr_debug("M2MNsdlInterface::remove_object()");
mbedAustin 11:cada08fc8a70 772 M2MObject* rem_object = (M2MObject*)object;
mbedAustin 11:cada08fc8a70 773 if(rem_object && !_object_list.empty()) {
mbedAustin 11:cada08fc8a70 774 M2MObjectList::const_iterator it;
mbedAustin 11:cada08fc8a70 775 it = _object_list.begin();
mbedAustin 11:cada08fc8a70 776 int index = 0;
mbedAustin 11:cada08fc8a70 777 for ( ; it != _object_list.end(); it++, index++ ) {
mbedAustin 11:cada08fc8a70 778 if((*it) == rem_object) {
mbedAustin 11:cada08fc8a70 779 _object_list.erase(index);
mbedAustin 11:cada08fc8a70 780 break;
mbedAustin 11:cada08fc8a70 781 }
mbedAustin 11:cada08fc8a70 782 }
mbedAustin 11:cada08fc8a70 783 }
mbedAustin 11:cada08fc8a70 784 if(_object_list.empty()) {
mbedAustin 11:cada08fc8a70 785 _object_list.clear();
mbedAustin 11:cada08fc8a70 786 }
mbedAustin 11:cada08fc8a70 787 }
mbedAustin 11:cada08fc8a70 788
mbedAustin 11:cada08fc8a70 789 bool M2MNsdlInterface::create_nsdl_object_structure(M2MObject *object)
mbedAustin 11:cada08fc8a70 790 {
mbedAustin 11:cada08fc8a70 791 tr_debug("M2MNsdlInterface::create_nsdl_object_structure()");
mbedAustin 11:cada08fc8a70 792 bool success = false;
mbedAustin 11:cada08fc8a70 793 if(object) {
mbedAustin 11:cada08fc8a70 794 //object->set_under_observation(false,this);
mbedAustin 11:cada08fc8a70 795 M2MObjectInstanceList instance_list = object->instances();
mbedAustin 11:cada08fc8a70 796 tr_debug("M2MNsdlInterface::create_nsdl_object_structure - Object Instance count %d", instance_list.size());
mbedAustin 11:cada08fc8a70 797 if(!instance_list.empty()) {
mbedAustin 11:cada08fc8a70 798 M2MObjectInstanceList::const_iterator it;
mbedAustin 11:cada08fc8a70 799 it = instance_list.begin();
mbedAustin 11:cada08fc8a70 800 for ( ; it != instance_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 801 // Create NSDL structure for all object instances inside
mbedAustin 11:cada08fc8a70 802 success = create_nsdl_object_instance_structure(*it);
mbedAustin 11:cada08fc8a70 803 }
mbedAustin 11:cada08fc8a70 804 }
mbedAustin 11:cada08fc8a70 805 }
mbedAustin 11:cada08fc8a70 806 if((object->operation() != M2MBase::NOT_ALLOWED)) {
mbedAustin 11:cada08fc8a70 807 success = create_nsdl_resource(object,object->name());
mbedAustin 11:cada08fc8a70 808 }
mbedAustin 11:cada08fc8a70 809 return success;
mbedAustin 11:cada08fc8a70 810 }
mbedAustin 11:cada08fc8a70 811
mbedAustin 11:cada08fc8a70 812 bool M2MNsdlInterface::create_nsdl_object_instance_structure(M2MObjectInstance *object_instance)
mbedAustin 11:cada08fc8a70 813 {
mbedAustin 11:cada08fc8a70 814 tr_debug("M2MNsdlInterface::create_nsdl_object_instance_structure()");
mbedAustin 11:cada08fc8a70 815 bool success = false;
mbedAustin 11:cada08fc8a70 816 if( object_instance) {
mbedAustin 11:cada08fc8a70 817
mbedAustin 11:cada08fc8a70 818 char *inst_id = (char*)malloc(20);
mbedAustin 11:cada08fc8a70 819 snprintf(inst_id, 20,"%d",object_instance->instance_id());
mbedAustin 11:cada08fc8a70 820
mbedAustin 11:cada08fc8a70 821 // Append object instance id to the object name.
mbedAustin 11:cada08fc8a70 822 String object_name = object_instance->name();
mbedAustin 11:cada08fc8a70 823 object_name += String("/");
mbedAustin 11:cada08fc8a70 824 object_name += String(inst_id);
mbedAustin 11:cada08fc8a70 825 free(inst_id);
mbedAustin 11:cada08fc8a70 826
mbedAustin 11:cada08fc8a70 827
mbedAustin 11:cada08fc8a70 828 //object_instance->set_under_observation(false,this);
mbedAustin 11:cada08fc8a70 829
mbedAustin 11:cada08fc8a70 830 M2MResourceList res_list = object_instance->resources();
mbedAustin 11:cada08fc8a70 831 tr_debug("M2MNsdlInterface::create_nsdl_object_instance_structure - ResourceBase count %d", res_list.size());
mbedAustin 11:cada08fc8a70 832 if(!res_list.empty()) {
mbedAustin 11:cada08fc8a70 833 M2MResourceList::const_iterator it;
mbedAustin 11:cada08fc8a70 834 it = res_list.begin();
mbedAustin 11:cada08fc8a70 835 for ( ; it != res_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 836 // Create NSDL structure for all resources inside
mbedAustin 11:cada08fc8a70 837 success = create_nsdl_resource_structure(*it,object_name,
mbedAustin 11:cada08fc8a70 838 (*it)->supports_multiple_instances());
mbedAustin 11:cada08fc8a70 839 }
mbedAustin 11:cada08fc8a70 840 }
mbedAustin 11:cada08fc8a70 841 if(object_instance->operation() != M2MBase::NOT_ALLOWED) {
mbedAustin 11:cada08fc8a70 842 success = create_nsdl_resource(object_instance,object_name);
mbedAustin 11:cada08fc8a70 843 }
mbedAustin 11:cada08fc8a70 844 }
mbedAustin 11:cada08fc8a70 845 return success;
mbedAustin 11:cada08fc8a70 846 }
mbedAustin 11:cada08fc8a70 847
mbedAustin 11:cada08fc8a70 848 bool M2MNsdlInterface::create_nsdl_resource_structure(M2MResource *res,
mbedAustin 11:cada08fc8a70 849 const String &object_name,
mbedAustin 11:cada08fc8a70 850 bool multiple_instances)
mbedAustin 11:cada08fc8a70 851 {
mbedAustin 11:cada08fc8a70 852 tr_debug("M2MNsdlInterface::create_nsdl_resource_structure(object_name %s)", object_name.c_str());
mbedAustin 11:cada08fc8a70 853 bool success = false;
mbedAustin 11:cada08fc8a70 854 if(res) {
mbedAustin 11:cada08fc8a70 855 // Append object name to the resource.
mbedAustin 11:cada08fc8a70 856 // Take out the instance Id and append to the
mbedAustin 11:cada08fc8a70 857 // resource name like "object/0/+ resource + / + 0"
mbedAustin 11:cada08fc8a70 858 String res_name = object_name;
mbedAustin 11:cada08fc8a70 859 res_name+= String("/");
mbedAustin 11:cada08fc8a70 860 res_name.append(res->name().c_str(),res->name().length());
mbedAustin 11:cada08fc8a70 861
mbedAustin 11:cada08fc8a70 862 // if there are multiple instances supported
mbedAustin 11:cada08fc8a70 863 // then add instance Id into creating resource path
mbedAustin 11:cada08fc8a70 864 // else normal /object_id/object_instance/resource_id format.
mbedAustin 11:cada08fc8a70 865 if(multiple_instances) {
mbedAustin 11:cada08fc8a70 866 M2MResourceInstanceList res_list = res->resource_instances();
mbedAustin 11:cada08fc8a70 867 tr_debug("M2MNsdlInterface::create_nsdl_resource_structure - ResourceInstance count %d", res_list.size());
mbedAustin 11:cada08fc8a70 868 if(!res_list.empty()) {
mbedAustin 11:cada08fc8a70 869 M2MResourceInstanceList::const_iterator it;
mbedAustin 11:cada08fc8a70 870 it = res_list.begin();
mbedAustin 11:cada08fc8a70 871 for ( ; it != res_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 872 String inst_name = res_name;
mbedAustin 11:cada08fc8a70 873 // Create NSDL structure for all resources inside
mbedAustin 11:cada08fc8a70 874 char *inst_id = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 875 snprintf(inst_id, 20,"%d",(*it)->instance_id());
mbedAustin 11:cada08fc8a70 876 inst_name+= String("/") ;
mbedAustin 11:cada08fc8a70 877 inst_name+= String(inst_id);
mbedAustin 11:cada08fc8a70 878
mbedAustin 11:cada08fc8a70 879 memory_free(inst_id);
mbedAustin 11:cada08fc8a70 880
mbedAustin 11:cada08fc8a70 881 success = create_nsdl_resource((*it),inst_name);
mbedAustin 11:cada08fc8a70 882 }
mbedAustin 11:cada08fc8a70 883 // Register the main Resource as well along with ResourceInstances
mbedAustin 11:cada08fc8a70 884 success = create_nsdl_resource(res,res_name);
mbedAustin 11:cada08fc8a70 885 }
mbedAustin 11:cada08fc8a70 886 } else {
mbedAustin 11:cada08fc8a70 887 tr_debug("M2MNsdlInterface::create_nsdl_resource_structure - res_name %s", res_name.c_str());
mbedAustin 11:cada08fc8a70 888 success = create_nsdl_resource(res,res_name);
mbedAustin 11:cada08fc8a70 889 }
mbedAustin 11:cada08fc8a70 890 }
mbedAustin 11:cada08fc8a70 891 return success;
mbedAustin 11:cada08fc8a70 892 }
mbedAustin 11:cada08fc8a70 893
mbedAustin 11:cada08fc8a70 894 bool M2MNsdlInterface::create_nsdl_resource(M2MBase *base, const String &name)
mbedAustin 11:cada08fc8a70 895 {
mbedAustin 11:cada08fc8a70 896 tr_debug("M2MNsdlInterface::create_nsdl_resource(name %s)", name.c_str());
mbedAustin 11:cada08fc8a70 897 bool success = false;
mbedAustin 11:cada08fc8a70 898 uint8_t* buffer = 0;
mbedAustin 11:cada08fc8a70 899 uint32_t length = 0;
mbedAustin 11:cada08fc8a70 900
mbedAustin 11:cada08fc8a70 901 // Create the NSDL Resource Pointer...
mbedAustin 11:cada08fc8a70 902 if(base) {
mbedAustin 11:cada08fc8a70 903 sn_nsdl_resource_info_s* resource = sn_nsdl_get_resource(_nsdl_handle,
mbedAustin 11:cada08fc8a70 904 name.length(),
mbedAustin 11:cada08fc8a70 905 (uint8_t*)name.c_str());
mbedAustin 11:cada08fc8a70 906 if(resource) {
mbedAustin 11:cada08fc8a70 907 success = true;
mbedAustin 11:cada08fc8a70 908 if(resource->mode == SN_GRS_STATIC) {
mbedAustin 11:cada08fc8a70 909 if((M2MBase::Resource == base->base_type() ||
mbedAustin 11:cada08fc8a70 910 M2MBase::ResourceInstance == base->base_type()) &&
mbedAustin 11:cada08fc8a70 911 M2MBase::Static == base->mode()) {
mbedAustin 11:cada08fc8a70 912 M2MResourceInstance *res = (M2MResourceInstance*)base;
mbedAustin 11:cada08fc8a70 913 res->get_value(buffer,length);
mbedAustin 11:cada08fc8a70 914 if(resource->resource) {
mbedAustin 11:cada08fc8a70 915 memory_free(resource->resource);
mbedAustin 11:cada08fc8a70 916 }
mbedAustin 11:cada08fc8a70 917 resource->resource = buffer;
mbedAustin 11:cada08fc8a70 918 resource->resourcelen = length;
mbedAustin 11:cada08fc8a70 919 sn_nsdl_update_resource(_nsdl_handle,resource);
mbedAustin 11:cada08fc8a70 920 }
mbedAustin 11:cada08fc8a70 921 }
mbedAustin 11:cada08fc8a70 922 // Update Resource access everytime for existing resource.
mbedAustin 11:cada08fc8a70 923 resource->access = (sn_grs_resource_acl_e)base->operation();
mbedAustin 11:cada08fc8a70 924 } else if(_resource) {
mbedAustin 11:cada08fc8a70 925 base->set_under_observation(false,this);
mbedAustin 11:cada08fc8a70 926 //TODO: implement access control
mbedAustin 11:cada08fc8a70 927 // Currently complete access is given
mbedAustin 11:cada08fc8a70 928 _resource->access = (sn_grs_resource_acl_e)base->operation();
mbedAustin 11:cada08fc8a70 929
mbedAustin 11:cada08fc8a70 930 if((M2MBase::Resource == base->base_type() ||
mbedAustin 11:cada08fc8a70 931 M2MBase::ResourceInstance == base->base_type()) &&
mbedAustin 11:cada08fc8a70 932 M2MBase::Static == base->mode()) {
mbedAustin 11:cada08fc8a70 933 M2MResourceInstance *res = (M2MResourceInstance*)base;
mbedAustin 11:cada08fc8a70 934 // Static resource is updated
mbedAustin 11:cada08fc8a70 935 _resource->mode = SN_GRS_STATIC;
mbedAustin 11:cada08fc8a70 936
mbedAustin 11:cada08fc8a70 937 res->get_value(buffer,length);
mbedAustin 11:cada08fc8a70 938 _resource->resource = buffer;
mbedAustin 11:cada08fc8a70 939 _resource->resourcelen = length;
mbedAustin 11:cada08fc8a70 940 }
mbedAustin 11:cada08fc8a70 941
mbedAustin 11:cada08fc8a70 942 if(M2MBase::Dynamic == base->mode()){
mbedAustin 11:cada08fc8a70 943 // Dynamic resource is updated
mbedAustin 11:cada08fc8a70 944 _resource->mode = SN_GRS_DYNAMIC;
mbedAustin 11:cada08fc8a70 945 _resource->sn_grs_dyn_res_callback = __nsdl_c_callback;
mbedAustin 11:cada08fc8a70 946 } else {
mbedAustin 11:cada08fc8a70 947 _resource->mode = SN_GRS_DIRECTORY;
mbedAustin 11:cada08fc8a70 948 }
mbedAustin 11:cada08fc8a70 949
mbedAustin 11:cada08fc8a70 950 if( _resource->path != NULL ){
mbedAustin 11:cada08fc8a70 951 memory_free(_resource->path);
mbedAustin 11:cada08fc8a70 952 _resource->path = NULL;
mbedAustin 11:cada08fc8a70 953 }
mbedAustin 11:cada08fc8a70 954 if(name.length() > 0 ){
mbedAustin 11:cada08fc8a70 955 _resource->path = ((uint8_t*)memory_alloc(name.length()+1));
mbedAustin 11:cada08fc8a70 956 if(_resource->path) {
mbedAustin 11:cada08fc8a70 957 memset(_resource->path, 0, name.length()+1);
mbedAustin 11:cada08fc8a70 958 memcpy(_resource->path, (uint8_t*)name.c_str(), name.length());
mbedAustin 11:cada08fc8a70 959 _resource->pathlen = name.length();
mbedAustin 11:cada08fc8a70 960 }
mbedAustin 11:cada08fc8a70 961 }
mbedAustin 11:cada08fc8a70 962
mbedAustin 11:cada08fc8a70 963 if(!base->resource_type().empty() && _resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 964 _resource->resource_parameters_ptr->resource_type_ptr =
mbedAustin 11:cada08fc8a70 965 ((uint8_t*)memory_alloc(base->resource_type().length()+1));
mbedAustin 11:cada08fc8a70 966 if(_resource->resource_parameters_ptr->resource_type_ptr) {
mbedAustin 11:cada08fc8a70 967 memset(_resource->resource_parameters_ptr->resource_type_ptr,
mbedAustin 11:cada08fc8a70 968 0, base->resource_type().length()+1);
mbedAustin 11:cada08fc8a70 969 memcpy(_resource->resource_parameters_ptr->resource_type_ptr,
mbedAustin 11:cada08fc8a70 970 (uint8_t*)base->resource_type().c_str(),
mbedAustin 11:cada08fc8a70 971 base->resource_type().length());
mbedAustin 11:cada08fc8a70 972 _resource->resource_parameters_ptr->resource_type_len =
mbedAustin 11:cada08fc8a70 973 base->resource_type().length();
mbedAustin 11:cada08fc8a70 974 }
mbedAustin 11:cada08fc8a70 975 }
mbedAustin 11:cada08fc8a70 976 if(!base->interface_description().empty() && _resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 977 _resource->resource_parameters_ptr->interface_description_ptr =
mbedAustin 11:cada08fc8a70 978 ((uint8_t*)memory_alloc(base->interface_description().length()+1));
mbedAustin 11:cada08fc8a70 979 if(_resource->resource_parameters_ptr->interface_description_ptr) {
mbedAustin 11:cada08fc8a70 980 memset(_resource->resource_parameters_ptr->interface_description_ptr,
mbedAustin 11:cada08fc8a70 981 0, base->interface_description().length()+1);
mbedAustin 11:cada08fc8a70 982 memcpy(_resource->resource_parameters_ptr->interface_description_ptr,
mbedAustin 11:cada08fc8a70 983 (uint8_t*)base->interface_description().c_str(),
mbedAustin 11:cada08fc8a70 984 base->interface_description().length());
mbedAustin 11:cada08fc8a70 985 _resource->resource_parameters_ptr->interface_description_len =
mbedAustin 11:cada08fc8a70 986 base->interface_description().length();
mbedAustin 11:cada08fc8a70 987 }
mbedAustin 11:cada08fc8a70 988 }
mbedAustin 11:cada08fc8a70 989 if(_resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 990 _resource->resource_parameters_ptr->coap_content_type = base->coap_content_type();
mbedAustin 11:cada08fc8a70 991 _resource->resource_parameters_ptr->observable = (uint8_t)base->is_observable();
mbedAustin 11:cada08fc8a70 992 }
mbedAustin 11:cada08fc8a70 993
mbedAustin 11:cada08fc8a70 994 int8_t result = sn_nsdl_create_resource(_nsdl_handle,_resource);
mbedAustin 11:cada08fc8a70 995 tr_debug("M2MNsdlInterface::create_nsdl_resource - Creating in NSDL-C result %d", result);
mbedAustin 11:cada08fc8a70 996
mbedAustin 11:cada08fc8a70 997 // Either the resource is created or it already
mbedAustin 11:cada08fc8a70 998 // exists , then result is success.
mbedAustin 11:cada08fc8a70 999 if (result == 0 ||
mbedAustin 11:cada08fc8a70 1000 result == -2){
mbedAustin 11:cada08fc8a70 1001 success = true;
mbedAustin 11:cada08fc8a70 1002 }
mbedAustin 11:cada08fc8a70 1003
mbedAustin 11:cada08fc8a70 1004 if(_resource->path) {
mbedAustin 11:cada08fc8a70 1005 memory_free(_resource->path);
mbedAustin 11:cada08fc8a70 1006 }
mbedAustin 11:cada08fc8a70 1007 if(_resource->resource_parameters_ptr->resource_type_ptr){
mbedAustin 11:cada08fc8a70 1008 memory_free(_resource->resource_parameters_ptr->resource_type_ptr);
mbedAustin 11:cada08fc8a70 1009 }
mbedAustin 11:cada08fc8a70 1010 if(_resource->resource_parameters_ptr->interface_description_ptr){
mbedAustin 11:cada08fc8a70 1011 memory_free(_resource->resource_parameters_ptr->interface_description_ptr);
mbedAustin 11:cada08fc8a70 1012 }
mbedAustin 11:cada08fc8a70 1013
mbedAustin 11:cada08fc8a70 1014 //Clear up the filled resource to fill up new resource.
mbedAustin 11:cada08fc8a70 1015 clear_resource(_resource);
mbedAustin 11:cada08fc8a70 1016
mbedAustin 11:cada08fc8a70 1017 if(success) {
mbedAustin 11:cada08fc8a70 1018 base->set_under_observation(false,this);
mbedAustin 11:cada08fc8a70 1019 }
mbedAustin 11:cada08fc8a70 1020 }
mbedAustin 11:cada08fc8a70 1021 }
mbedAustin 11:cada08fc8a70 1022 if(buffer) {
mbedAustin 11:cada08fc8a70 1023 free(buffer);
mbedAustin 11:cada08fc8a70 1024 }
mbedAustin 11:cada08fc8a70 1025 return success;
mbedAustin 11:cada08fc8a70 1026 }
mbedAustin 11:cada08fc8a70 1027
mbedAustin 11:cada08fc8a70 1028 // convenience method to get the URI from its buffer field...
mbedAustin 11:cada08fc8a70 1029 String M2MNsdlInterface::coap_to_string(uint8_t *coap_data,int coap_data_length)
mbedAustin 11:cada08fc8a70 1030 {
mbedAustin 11:cada08fc8a70 1031 String value = "";
mbedAustin 11:cada08fc8a70 1032 if (coap_data != NULL && coap_data_length > 0) {
mbedAustin 11:cada08fc8a70 1033 char buf[256+1];
mbedAustin 11:cada08fc8a70 1034 memset(buf,0,256+1);
mbedAustin 11:cada08fc8a70 1035 memcpy(buf,(char *)coap_data,coap_data_length);
mbedAustin 11:cada08fc8a70 1036 value = String(buf);
mbedAustin 11:cada08fc8a70 1037 }
mbedAustin 11:cada08fc8a70 1038 return value;
mbedAustin 11:cada08fc8a70 1039 }
mbedAustin 11:cada08fc8a70 1040
mbedAustin 11:cada08fc8a70 1041 uint64_t M2MNsdlInterface::registration_time()
mbedAustin 11:cada08fc8a70 1042 {
mbedAustin 11:cada08fc8a70 1043 uint64_t value = 0;
mbedAustin 11:cada08fc8a70 1044 if(_endpoint->lifetime_ptr) {
mbedAustin 11:cada08fc8a70 1045 value = atol((const char*)_endpoint->lifetime_ptr);
mbedAustin 11:cada08fc8a70 1046 }
mbedAustin 11:cada08fc8a70 1047
mbedAustin 11:cada08fc8a70 1048 if(value >= OPTIMUM_LIFETIME) {
mbedAustin 11:cada08fc8a70 1049 value = value - REDUCE_LIFETIME;
mbedAustin 11:cada08fc8a70 1050 } else {
mbedAustin 11:cada08fc8a70 1051 value = REDUCTION_FACTOR * value;
mbedAustin 11:cada08fc8a70 1052 }
mbedAustin 11:cada08fc8a70 1053 tr_debug("M2MNsdlInterface::registration_time - value (in seconds) %ld", value);
mbedAustin 11:cada08fc8a70 1054 return value;
mbedAustin 11:cada08fc8a70 1055 }
mbedAustin 11:cada08fc8a70 1056
mbedAustin 11:cada08fc8a70 1057 M2MBase* M2MNsdlInterface::find_resource(const String &object_name)
mbedAustin 11:cada08fc8a70 1058 {
mbedAustin 11:cada08fc8a70 1059 M2MBase *object = NULL;
mbedAustin 11:cada08fc8a70 1060 if(!_object_list.empty()) {
mbedAustin 11:cada08fc8a70 1061 M2MObjectList::const_iterator it;
mbedAustin 11:cada08fc8a70 1062 it = _object_list.begin();
mbedAustin 11:cada08fc8a70 1063 for ( ; it != _object_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 1064 if((*it)->name() == object_name) {
mbedAustin 11:cada08fc8a70 1065 object = (*it);
mbedAustin 11:cada08fc8a70 1066 tr_debug("M2MNsdlInterface::find_resource(%s) found", object_name.c_str());
mbedAustin 11:cada08fc8a70 1067 break;
mbedAustin 11:cada08fc8a70 1068 }
mbedAustin 11:cada08fc8a70 1069 object = find_resource((*it),object_name);
mbedAustin 11:cada08fc8a70 1070 if(object != NULL) {
mbedAustin 11:cada08fc8a70 1071 tr_debug("M2MNsdlInterface::find_resource(%s) found", object_name.c_str());
mbedAustin 11:cada08fc8a70 1072 break;
mbedAustin 11:cada08fc8a70 1073 }
mbedAustin 11:cada08fc8a70 1074 }
mbedAustin 11:cada08fc8a70 1075 }
mbedAustin 11:cada08fc8a70 1076 return object;
mbedAustin 11:cada08fc8a70 1077 }
mbedAustin 11:cada08fc8a70 1078
mbedAustin 11:cada08fc8a70 1079 M2MBase* M2MNsdlInterface::find_resource(const M2MObject *object,
mbedAustin 11:cada08fc8a70 1080 const String &object_instance)
mbedAustin 11:cada08fc8a70 1081 {
mbedAustin 11:cada08fc8a70 1082 M2MBase *instance = NULL;
mbedAustin 11:cada08fc8a70 1083 if(object) {
mbedAustin 11:cada08fc8a70 1084 M2MObjectInstanceList list = object->instances();
mbedAustin 11:cada08fc8a70 1085 if(!list.empty()) {
mbedAustin 11:cada08fc8a70 1086 M2MObjectInstanceList::const_iterator it;
mbedAustin 11:cada08fc8a70 1087 it = list.begin();
mbedAustin 11:cada08fc8a70 1088 for ( ; it != list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 1089 char *inst_id = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 1090 snprintf(inst_id, 20,"%d",(*it)->instance_id());
mbedAustin 11:cada08fc8a70 1091
mbedAustin 11:cada08fc8a70 1092 // Append object instance id to the object name.
mbedAustin 11:cada08fc8a70 1093 String name = (*it)->name();
mbedAustin 11:cada08fc8a70 1094 name+= String("/");
mbedAustin 11:cada08fc8a70 1095 name+= String(inst_id);
mbedAustin 11:cada08fc8a70 1096
mbedAustin 11:cada08fc8a70 1097 memory_free(inst_id);
mbedAustin 11:cada08fc8a70 1098
mbedAustin 11:cada08fc8a70 1099 if(name == object_instance){
mbedAustin 11:cada08fc8a70 1100 instance = (*it);
mbedAustin 11:cada08fc8a70 1101 break;
mbedAustin 11:cada08fc8a70 1102 }
mbedAustin 11:cada08fc8a70 1103 instance = find_resource((*it),object_instance);
mbedAustin 11:cada08fc8a70 1104 if(instance != NULL){
mbedAustin 11:cada08fc8a70 1105 break;
mbedAustin 11:cada08fc8a70 1106 }
mbedAustin 11:cada08fc8a70 1107 }
mbedAustin 11:cada08fc8a70 1108 }
mbedAustin 11:cada08fc8a70 1109 }
mbedAustin 11:cada08fc8a70 1110 return instance;
mbedAustin 11:cada08fc8a70 1111 }
mbedAustin 11:cada08fc8a70 1112
mbedAustin 11:cada08fc8a70 1113 M2MBase* M2MNsdlInterface::find_resource(const M2MObjectInstance *object_instance,
mbedAustin 11:cada08fc8a70 1114 const String &resource_instance)
mbedAustin 11:cada08fc8a70 1115 {
mbedAustin 11:cada08fc8a70 1116 M2MBase *instance = NULL;
mbedAustin 11:cada08fc8a70 1117 if(object_instance) {
mbedAustin 11:cada08fc8a70 1118 M2MResourceList list = object_instance->resources();
mbedAustin 11:cada08fc8a70 1119 if(!list.empty()) {
mbedAustin 11:cada08fc8a70 1120 M2MResourceList::const_iterator it;
mbedAustin 11:cada08fc8a70 1121 it = list.begin();
mbedAustin 11:cada08fc8a70 1122 for ( ; it != list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 1123 String name = object_instance->name();
mbedAustin 11:cada08fc8a70 1124 char *obj_inst_id = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 1125 snprintf(obj_inst_id, 20,"%d",object_instance->instance_id());
mbedAustin 11:cada08fc8a70 1126
mbedAustin 11:cada08fc8a70 1127 // Append object instance id to the object name.
mbedAustin 11:cada08fc8a70 1128 name+= String("/");
mbedAustin 11:cada08fc8a70 1129 name+= String(obj_inst_id);
mbedAustin 11:cada08fc8a70 1130
mbedAustin 11:cada08fc8a70 1131 memory_free(obj_inst_id);
mbedAustin 11:cada08fc8a70 1132
mbedAustin 11:cada08fc8a70 1133 name+= String("/");
mbedAustin 11:cada08fc8a70 1134 name+= (*it)->name();
mbedAustin 11:cada08fc8a70 1135
mbedAustin 11:cada08fc8a70 1136 if(name == resource_instance) {
mbedAustin 11:cada08fc8a70 1137 instance = *it;
mbedAustin 11:cada08fc8a70 1138 break;
mbedAustin 11:cada08fc8a70 1139 } else if((*it)->supports_multiple_instances()) {
mbedAustin 11:cada08fc8a70 1140 instance = find_resource((*it),name, resource_instance);
mbedAustin 11:cada08fc8a70 1141 if(instance != NULL){
mbedAustin 11:cada08fc8a70 1142 break;
mbedAustin 11:cada08fc8a70 1143 }
mbedAustin 11:cada08fc8a70 1144 }
mbedAustin 11:cada08fc8a70 1145 }
mbedAustin 11:cada08fc8a70 1146 }
mbedAustin 11:cada08fc8a70 1147 }
mbedAustin 11:cada08fc8a70 1148 return instance;
mbedAustin 11:cada08fc8a70 1149 }
mbedAustin 11:cada08fc8a70 1150
mbedAustin 11:cada08fc8a70 1151 M2MBase* M2MNsdlInterface::find_resource(const M2MResource *resource,
mbedAustin 11:cada08fc8a70 1152 const String &object_name,
mbedAustin 11:cada08fc8a70 1153 const String &resource_instance)
mbedAustin 11:cada08fc8a70 1154 {
mbedAustin 11:cada08fc8a70 1155 M2MBase *res = NULL;
mbedAustin 11:cada08fc8a70 1156 if(resource) {
mbedAustin 11:cada08fc8a70 1157 if(resource->supports_multiple_instances()) {
mbedAustin 11:cada08fc8a70 1158 M2MResourceInstanceList list = resource->resource_instances();
mbedAustin 11:cada08fc8a70 1159 if(!list.empty()) {
mbedAustin 11:cada08fc8a70 1160 M2MResourceInstanceList::const_iterator it;
mbedAustin 11:cada08fc8a70 1161 it = list.begin();
mbedAustin 11:cada08fc8a70 1162 for ( ; it != list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 1163 String name = object_name;
mbedAustin 11:cada08fc8a70 1164 // if there are multiple instances supported
mbedAustin 11:cada08fc8a70 1165 // then add instance Id into creating resource path
mbedAustin 11:cada08fc8a70 1166 // else normal /object_id/object_instance/resource_id format.
mbedAustin 11:cada08fc8a70 1167
mbedAustin 11:cada08fc8a70 1168 char *inst_id = (char*)memory_alloc(20);
mbedAustin 11:cada08fc8a70 1169 snprintf(inst_id, 20,"%d",(*it)->instance_id());
mbedAustin 11:cada08fc8a70 1170
mbedAustin 11:cada08fc8a70 1171 name+= String("/") ;
mbedAustin 11:cada08fc8a70 1172 name+= String(inst_id);
mbedAustin 11:cada08fc8a70 1173
mbedAustin 11:cada08fc8a70 1174 memory_free(inst_id);
mbedAustin 11:cada08fc8a70 1175
mbedAustin 11:cada08fc8a70 1176 if(name == resource_instance){
mbedAustin 11:cada08fc8a70 1177 res = (*it);
mbedAustin 11:cada08fc8a70 1178 break;
mbedAustin 11:cada08fc8a70 1179 }
mbedAustin 11:cada08fc8a70 1180 }
mbedAustin 11:cada08fc8a70 1181 }
mbedAustin 11:cada08fc8a70 1182 }
mbedAustin 11:cada08fc8a70 1183 }
mbedAustin 11:cada08fc8a70 1184 return res;
mbedAustin 11:cada08fc8a70 1185 }
mbedAustin 11:cada08fc8a70 1186
mbedAustin 11:cada08fc8a70 1187 bool M2MNsdlInterface::object_present(M2MObject* object) const
mbedAustin 11:cada08fc8a70 1188 {
mbedAustin 11:cada08fc8a70 1189 bool success = false;
mbedAustin 11:cada08fc8a70 1190 if(object && !_object_list.empty()) {
mbedAustin 11:cada08fc8a70 1191 M2MObjectList::const_iterator it;
mbedAustin 11:cada08fc8a70 1192 it = _object_list.begin();
mbedAustin 11:cada08fc8a70 1193 for ( ; it != _object_list.end(); it++ ) {
mbedAustin 11:cada08fc8a70 1194 if((*it) == object) {
mbedAustin 11:cada08fc8a70 1195 success = true;
mbedAustin 11:cada08fc8a70 1196 break;
mbedAustin 11:cada08fc8a70 1197 }
mbedAustin 11:cada08fc8a70 1198 }
mbedAustin 11:cada08fc8a70 1199 }
mbedAustin 11:cada08fc8a70 1200 return success;
mbedAustin 11:cada08fc8a70 1201 }
mbedAustin 11:cada08fc8a70 1202
mbedAustin 11:cada08fc8a70 1203 bool M2MNsdlInterface::add_object_to_list(M2MObject* object)
mbedAustin 11:cada08fc8a70 1204 {
mbedAustin 11:cada08fc8a70 1205 bool success = false;
mbedAustin 11:cada08fc8a70 1206 if(object && !object_present(object)) {
mbedAustin 11:cada08fc8a70 1207 _object_list.push_back(object);
mbedAustin 11:cada08fc8a70 1208 success = true;
mbedAustin 11:cada08fc8a70 1209 }
mbedAustin 11:cada08fc8a70 1210 return success;
mbedAustin 11:cada08fc8a70 1211 }
mbedAustin 11:cada08fc8a70 1212
mbedAustin 11:cada08fc8a70 1213 void M2MNsdlInterface::clear_resource(sn_nsdl_resource_info_s *&resource)
mbedAustin 11:cada08fc8a70 1214 {
mbedAustin 11:cada08fc8a70 1215 //Clear up the filled resource to fill up new resource.
mbedAustin 11:cada08fc8a70 1216 if(resource && resource->resource_parameters_ptr) {
mbedAustin 11:cada08fc8a70 1217 sn_nsdl_resource_parameters_s *temp_resource_parameter = resource->resource_parameters_ptr;
mbedAustin 11:cada08fc8a70 1218 memset(resource->resource_parameters_ptr, 0, sizeof(sn_nsdl_resource_parameters_s));
mbedAustin 11:cada08fc8a70 1219 memset(resource,0, sizeof(sn_nsdl_resource_info_s));
mbedAustin 11:cada08fc8a70 1220 resource->resource_parameters_ptr = temp_resource_parameter;
mbedAustin 11:cada08fc8a70 1221 }
mbedAustin 11:cada08fc8a70 1222 }
mbedAustin 11:cada08fc8a70 1223
mbedAustin 11:cada08fc8a70 1224 M2MInterface::Error M2MNsdlInterface::interface_error(sn_coap_hdr_s *coap_header)
mbedAustin 11:cada08fc8a70 1225 {
mbedAustin 11:cada08fc8a70 1226 M2MInterface::Error error = M2MInterface::ErrorNone;
mbedAustin 11:cada08fc8a70 1227 if(coap_header) {
mbedAustin 11:cada08fc8a70 1228 switch(coap_header->msg_code) {
mbedAustin 11:cada08fc8a70 1229 case COAP_MSG_CODE_RESPONSE_BAD_REQUEST:
mbedAustin 11:cada08fc8a70 1230 case COAP_MSG_CODE_RESPONSE_BAD_OPTION:
mbedAustin 11:cada08fc8a70 1231 case COAP_MSG_CODE_RESPONSE_REQUEST_ENTITY_INCOMPLETE:
mbedAustin 11:cada08fc8a70 1232 case COAP_MSG_CODE_RESPONSE_PRECONDITION_FAILED:
mbedAustin 11:cada08fc8a70 1233 case COAP_MSG_CODE_RESPONSE_REQUEST_ENTITY_TOO_LARGE:
mbedAustin 11:cada08fc8a70 1234 case COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT:
mbedAustin 11:cada08fc8a70 1235 error = M2MInterface::InvalidParameters;
mbedAustin 11:cada08fc8a70 1236 break;
mbedAustin 11:cada08fc8a70 1237 case COAP_MSG_CODE_RESPONSE_UNAUTHORIZED:
mbedAustin 11:cada08fc8a70 1238 case COAP_MSG_CODE_RESPONSE_FORBIDDEN:
mbedAustin 11:cada08fc8a70 1239 case COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE:
mbedAustin 11:cada08fc8a70 1240 case COAP_MSG_CODE_RESPONSE_NOT_FOUND:
mbedAustin 11:cada08fc8a70 1241 case COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED:
mbedAustin 11:cada08fc8a70 1242 error = M2MInterface::NotAllowed;
mbedAustin 11:cada08fc8a70 1243 break;
mbedAustin 11:cada08fc8a70 1244 case COAP_MSG_CODE_RESPONSE_CREATED:
mbedAustin 11:cada08fc8a70 1245 case COAP_MSG_CODE_RESPONSE_DELETED:
mbedAustin 11:cada08fc8a70 1246 case COAP_MSG_CODE_RESPONSE_VALID:
mbedAustin 11:cada08fc8a70 1247 case COAP_MSG_CODE_RESPONSE_CHANGED:
mbedAustin 11:cada08fc8a70 1248 case COAP_MSG_CODE_RESPONSE_CONTENT:
mbedAustin 11:cada08fc8a70 1249 error = M2MInterface::ErrorNone;
mbedAustin 11:cada08fc8a70 1250 break;
mbedAustin 11:cada08fc8a70 1251 default:
mbedAustin 11:cada08fc8a70 1252 error = M2MInterface::UnknownError;
mbedAustin 11:cada08fc8a70 1253 break;
mbedAustin 11:cada08fc8a70 1254 }
mbedAustin 11:cada08fc8a70 1255 if(coap_header->coap_status == COAP_STATUS_BUILDER_MESSAGE_SENDING_FAILED) {
mbedAustin 11:cada08fc8a70 1256 error = M2MInterface::NetworkError;
mbedAustin 11:cada08fc8a70 1257 }
mbedAustin 11:cada08fc8a70 1258 }
mbedAustin 11:cada08fc8a70 1259 return error;
mbedAustin 11:cada08fc8a70 1260 }
mbedAustin 11:cada08fc8a70 1261
mbedAustin 11:cada08fc8a70 1262 void M2MNsdlInterface::send_object_observation(M2MObject *object)
mbedAustin 11:cada08fc8a70 1263 {
mbedAustin 11:cada08fc8a70 1264 tr_debug("M2MNsdlInterface::send_object_observation");
mbedAustin 11:cada08fc8a70 1265 if(object) {
mbedAustin 11:cada08fc8a70 1266 uint8_t *value = 0;
mbedAustin 11:cada08fc8a70 1267 uint32_t length = 0;
mbedAustin 11:cada08fc8a70 1268 uint8_t *token = 0;
mbedAustin 11:cada08fc8a70 1269 uint32_t token_length = 0;
mbedAustin 11:cada08fc8a70 1270 uint8_t observation_number[2];
mbedAustin 11:cada08fc8a70 1271 uint8_t observation_number_length = 1;
mbedAustin 11:cada08fc8a70 1272
mbedAustin 11:cada08fc8a70 1273 uint16_t number = object->observation_number();
mbedAustin 11:cada08fc8a70 1274
mbedAustin 11:cada08fc8a70 1275 observation_number[0] = ((number>>8) & 0xFF);
mbedAustin 11:cada08fc8a70 1276 observation_number[1] = (number & 0xFF);
mbedAustin 11:cada08fc8a70 1277
mbedAustin 11:cada08fc8a70 1278 if(number > 0xFF) {
mbedAustin 11:cada08fc8a70 1279 observation_number_length = 2;
mbedAustin 11:cada08fc8a70 1280 }
mbedAustin 11:cada08fc8a70 1281
mbedAustin 11:cada08fc8a70 1282 M2MTLVSerializer *serializer = new M2MTLVSerializer();
mbedAustin 11:cada08fc8a70 1283 if(serializer) {
mbedAustin 11:cada08fc8a70 1284 value = serializer->serialize(object->instances(), length);
mbedAustin 11:cada08fc8a70 1285 delete serializer;
mbedAustin 11:cada08fc8a70 1286 }
mbedAustin 11:cada08fc8a70 1287
mbedAustin 11:cada08fc8a70 1288 object->get_observation_token(token,token_length);
mbedAustin 11:cada08fc8a70 1289
mbedAustin 11:cada08fc8a70 1290 sn_nsdl_send_observation_notification(_nsdl_handle,
mbedAustin 11:cada08fc8a70 1291 token,
mbedAustin 11:cada08fc8a70 1292 token_length,
mbedAustin 11:cada08fc8a70 1293 value,length,
mbedAustin 11:cada08fc8a70 1294 observation_number,
mbedAustin 11:cada08fc8a70 1295 observation_number_length,
mbedAustin 11:cada08fc8a70 1296 COAP_MSG_TYPE_CONFIRMABLE,
mbedAustin 11:cada08fc8a70 1297 object->coap_content_type());
mbedAustin 11:cada08fc8a70 1298 memory_free(value);
mbedAustin 11:cada08fc8a70 1299 memory_free(token);
mbedAustin 11:cada08fc8a70 1300 }
mbedAustin 11:cada08fc8a70 1301 }
mbedAustin 11:cada08fc8a70 1302
mbedAustin 11:cada08fc8a70 1303 void M2MNsdlInterface::send_object_instance_observation(M2MObjectInstance *object_instance)
mbedAustin 11:cada08fc8a70 1304 {
mbedAustin 11:cada08fc8a70 1305 tr_debug("M2MNsdlInterface::send_object_instance_observation");
mbedAustin 11:cada08fc8a70 1306 if(object_instance) {
mbedAustin 11:cada08fc8a70 1307 uint8_t *value = 0;
mbedAustin 11:cada08fc8a70 1308 uint32_t length = 0;
mbedAustin 11:cada08fc8a70 1309 uint8_t *token = 0;
mbedAustin 11:cada08fc8a70 1310 uint32_t token_length = 0;
mbedAustin 11:cada08fc8a70 1311 uint8_t observation_number[2];
mbedAustin 11:cada08fc8a70 1312 uint8_t observation_number_length = 1;
mbedAustin 11:cada08fc8a70 1313
mbedAustin 11:cada08fc8a70 1314 uint16_t number = object_instance->observation_number();
mbedAustin 11:cada08fc8a70 1315
mbedAustin 11:cada08fc8a70 1316 observation_number[0] = ((number>>8) & 0xFF);
mbedAustin 11:cada08fc8a70 1317 observation_number[1] = (number & 0xFF);
mbedAustin 11:cada08fc8a70 1318
mbedAustin 11:cada08fc8a70 1319 if(number > 0xFF) {
mbedAustin 11:cada08fc8a70 1320 observation_number_length = 2;
mbedAustin 11:cada08fc8a70 1321 }
mbedAustin 11:cada08fc8a70 1322
mbedAustin 11:cada08fc8a70 1323 M2MTLVSerializer *serializer = new M2MTLVSerializer();
mbedAustin 11:cada08fc8a70 1324 if(serializer) {
mbedAustin 11:cada08fc8a70 1325 value = serializer->serialize(object_instance->resources(), length);
mbedAustin 11:cada08fc8a70 1326 delete serializer;
mbedAustin 11:cada08fc8a70 1327 }
mbedAustin 11:cada08fc8a70 1328
mbedAustin 11:cada08fc8a70 1329 object_instance->get_observation_token(token,token_length);
mbedAustin 11:cada08fc8a70 1330
mbedAustin 11:cada08fc8a70 1331 sn_nsdl_send_observation_notification(_nsdl_handle,
mbedAustin 11:cada08fc8a70 1332 token,
mbedAustin 11:cada08fc8a70 1333 token_length,
mbedAustin 11:cada08fc8a70 1334 value,length,
mbedAustin 11:cada08fc8a70 1335 observation_number,
mbedAustin 11:cada08fc8a70 1336 observation_number_length,
mbedAustin 11:cada08fc8a70 1337 COAP_MSG_TYPE_CONFIRMABLE,
mbedAustin 11:cada08fc8a70 1338 object_instance->coap_content_type());
mbedAustin 11:cada08fc8a70 1339 memory_free(value);
mbedAustin 11:cada08fc8a70 1340 memory_free(token);
mbedAustin 11:cada08fc8a70 1341 }
mbedAustin 11:cada08fc8a70 1342 }
mbedAustin 11:cada08fc8a70 1343
mbedAustin 11:cada08fc8a70 1344 void M2MNsdlInterface::send_resource_observation(M2MResource *resource)
mbedAustin 11:cada08fc8a70 1345 {
mbedAustin 11:cada08fc8a70 1346 tr_debug("M2MNsdlInterface::send_resource_observation");
mbedAustin 11:cada08fc8a70 1347 if(resource) {
mbedAustin 11:cada08fc8a70 1348 uint8_t *value = 0;
mbedAustin 11:cada08fc8a70 1349 uint32_t length = 0;
mbedAustin 11:cada08fc8a70 1350 uint8_t *token = 0;
mbedAustin 11:cada08fc8a70 1351 uint32_t token_length = 0;
mbedAustin 11:cada08fc8a70 1352 uint8_t observation_number[2];
mbedAustin 11:cada08fc8a70 1353 uint8_t observation_number_length = 1;
mbedAustin 11:cada08fc8a70 1354
mbedAustin 11:cada08fc8a70 1355 uint16_t number = resource->observation_number();
mbedAustin 11:cada08fc8a70 1356
mbedAustin 11:cada08fc8a70 1357 observation_number[0] = ((number>>8) & 0xFF);
mbedAustin 11:cada08fc8a70 1358 observation_number[1] = (number & 0xFF);
mbedAustin 11:cada08fc8a70 1359
mbedAustin 11:cada08fc8a70 1360 if(number > 0xFF) {
mbedAustin 11:cada08fc8a70 1361 observation_number_length = 2;
mbedAustin 11:cada08fc8a70 1362 }
mbedAustin 11:cada08fc8a70 1363
mbedAustin 11:cada08fc8a70 1364 resource->get_observation_token(token,token_length);
mbedAustin 11:cada08fc8a70 1365 uint8_t content_type = 0;
mbedAustin 11:cada08fc8a70 1366 if (resource->resource_instance_count() > 0) {
mbedAustin 11:cada08fc8a70 1367 M2MTLVSerializer *serializer = new M2MTLVSerializer();
mbedAustin 11:cada08fc8a70 1368 content_type = COAP_CONTENT_OMA_TLV_TYPE;
mbedAustin 11:cada08fc8a70 1369 if(serializer) {
mbedAustin 11:cada08fc8a70 1370 value = serializer->serialize(resource, length);
mbedAustin 11:cada08fc8a70 1371 delete serializer;
mbedAustin 11:cada08fc8a70 1372 }
mbedAustin 11:cada08fc8a70 1373 } else {
mbedAustin 11:cada08fc8a70 1374 resource->get_value(value,length);
mbedAustin 11:cada08fc8a70 1375 }
mbedAustin 11:cada08fc8a70 1376
mbedAustin 11:cada08fc8a70 1377 sn_nsdl_send_observation_notification(_nsdl_handle,
mbedAustin 11:cada08fc8a70 1378 token,
mbedAustin 11:cada08fc8a70 1379 token_length,
mbedAustin 11:cada08fc8a70 1380 value,length,
mbedAustin 11:cada08fc8a70 1381 observation_number,
mbedAustin 11:cada08fc8a70 1382 observation_number_length,
mbedAustin 11:cada08fc8a70 1383 COAP_MSG_TYPE_CONFIRMABLE,
mbedAustin 11:cada08fc8a70 1384 content_type);
mbedAustin 11:cada08fc8a70 1385 memory_free(value);
mbedAustin 11:cada08fc8a70 1386 memory_free(token);
mbedAustin 11:cada08fc8a70 1387 }
mbedAustin 11:cada08fc8a70 1388 }