Ram Gandikota / Mbed OS IOTMetronome

FRDM K64F Metronome

mbed-client/source/m2mnsdlinterface.cpp@0:dbad57390bd1, 2017-05-14 (annotated)

Committer:
ram54288
Date:
Sun May 14 18:37:05 2017 +0000
Revision:
0:dbad57390bd1
Initial commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ram54288 0:dbad57390bd1 1 /*
ram54288 0:dbad57390bd1 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
ram54288 0:dbad57390bd1 3 * SPDX-License-Identifier: Apache-2.0
ram54288 0:dbad57390bd1 4 * Licensed under the Apache License, Version 2.0 (the License); you may
ram54288 0:dbad57390bd1 5 * not use this file except in compliance with the License.
ram54288 0:dbad57390bd1 6 * You may obtain a copy of the License at
ram54288 0:dbad57390bd1 7 *
ram54288 0:dbad57390bd1 8 * http://www.apache.org/licenses/LICENSE-2.0
ram54288 0:dbad57390bd1 9 *
ram54288 0:dbad57390bd1 10 * Unless required by applicable law or agreed to in writing, software
ram54288 0:dbad57390bd1 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
ram54288 0:dbad57390bd1 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
ram54288 0:dbad57390bd1 13 * See the License for the specific language governing permissions and
ram54288 0:dbad57390bd1 14 * limitations under the License.
ram54288 0:dbad57390bd1 15 */
ram54288 0:dbad57390bd1 16
ram54288 0:dbad57390bd1 17 // Note: this macro is needed on armcc to get the the PRI*32 macros
ram54288 0:dbad57390bd1 18 // from inttypes.h in a C++ code.
ram54288 0:dbad57390bd1 19 #ifndef __STDC_FORMAT_MACROS
ram54288 0:dbad57390bd1 20 #define __STDC_FORMAT_MACROS
ram54288 0:dbad57390bd1 21 #endif
ram54288 0:dbad57390bd1 22
ram54288 0:dbad57390bd1 23 // Note: this macro is needed on armcc to get the the limit macros like UINT16_MAX
ram54288 0:dbad57390bd1 24 #ifndef __STDC_LIMIT_MACROS
ram54288 0:dbad57390bd1 25 #define __STDC_LIMIT_MACROS
ram54288 0:dbad57390bd1 26 #endif
ram54288 0:dbad57390bd1 27
ram54288 0:dbad57390bd1 28
ram54288 0:dbad57390bd1 29 #include "include/nsdlaccesshelper.h"
ram54288 0:dbad57390bd1 30 #include "include/m2mnsdlobserver.h"
ram54288 0:dbad57390bd1 31 #include "include/m2mtlvdeserializer.h"
ram54288 0:dbad57390bd1 32 #include "include/m2mtlvserializer.h"
ram54288 0:dbad57390bd1 33 #include "include/m2mnsdlinterface.h"
ram54288 0:dbad57390bd1 34 #include "mbed-client/m2mstring.h"
ram54288 0:dbad57390bd1 35 #include "mbed-client/m2msecurity.h"
ram54288 0:dbad57390bd1 36 #include "mbed-client/m2mserver.h"
ram54288 0:dbad57390bd1 37 #include "mbed-client/m2mobject.h"
ram54288 0:dbad57390bd1 38 #include "mbed-client/m2mobjectinstance.h"
ram54288 0:dbad57390bd1 39 #include "mbed-client/m2mresource.h"
ram54288 0:dbad57390bd1 40 #include "mbed-client/m2mconstants.h"
ram54288 0:dbad57390bd1 41 #include "mbed-trace/mbed_trace.h"
ram54288 0:dbad57390bd1 42 #include "mbed-client/m2mtimer.h"
ram54288 0:dbad57390bd1 43 #include "source/libNsdl/src/include/sn_grs.h"
ram54288 0:dbad57390bd1 44
ram54288 0:dbad57390bd1 45 #include <assert.h>
ram54288 0:dbad57390bd1 46 #include <inttypes.h>
ram54288 0:dbad57390bd1 47 #include <stdlib.h>
ram54288 0:dbad57390bd1 48
ram54288 0:dbad57390bd1 49 #define BUFFER_SIZE 21
ram54288 0:dbad57390bd1 50 #define TRACE_GROUP "mClt"
ram54288 0:dbad57390bd1 51
ram54288 0:dbad57390bd1 52 M2MNsdlInterface::M2MNsdlInterface(M2MNsdlObserver &observer)
ram54288 0:dbad57390bd1 53 : _observer(observer),
ram54288 0:dbad57390bd1 54 _endpoint(NULL),
ram54288 0:dbad57390bd1 55 _nsdl_handle(NULL),
ram54288 0:dbad57390bd1 56 _security(NULL),
ram54288 0:dbad57390bd1 57 _server(),
ram54288 0:dbad57390bd1 58 _nsdl_exceution_timer(new M2MTimer(*this)),
ram54288 0:dbad57390bd1 59 _registration_timer(new M2MTimer(*this)),
ram54288 0:dbad57390bd1 60 _counter_for_nsdl(0),
ram54288 0:dbad57390bd1 61 _bootstrap_id(0),
ram54288 0:dbad57390bd1 62 _unregister_ongoing(false),
ram54288 0:dbad57390bd1 63 _identity_accepted(false)
ram54288 0:dbad57390bd1 64 {
ram54288 0:dbad57390bd1 65 tr_debug("M2MNsdlInterface::M2MNsdlInterface()");
ram54288 0:dbad57390bd1 66 __nsdl_interface_list.push_back(this);
ram54288 0:dbad57390bd1 67 _sn_nsdl_address.addr_len = 0;
ram54288 0:dbad57390bd1 68 _sn_nsdl_address.addr_ptr = NULL;
ram54288 0:dbad57390bd1 69 _sn_nsdl_address.port = 0;
ram54288 0:dbad57390bd1 70 _sn_nsdl_address.type = SN_NSDL_ADDRESS_TYPE_NONE;
ram54288 0:dbad57390bd1 71
ram54288 0:dbad57390bd1 72 // This initializes libCoap and libNsdl
ram54288 0:dbad57390bd1 73 // Parameters are function pointers to used memory allocation
ram54288 0:dbad57390bd1 74 // and free functions in structure and used functions for sending
ram54288 0:dbad57390bd1 75 // and receiving purposes.
ram54288 0:dbad57390bd1 76 _nsdl_handle = sn_nsdl_init(&(__nsdl_c_send_to_server), &(__nsdl_c_received_from_server),
ram54288 0:dbad57390bd1 77 &(__nsdl_c_memory_alloc), &(__nsdl_c_memory_free));
ram54288 0:dbad57390bd1 78
ram54288 0:dbad57390bd1 79 initialize();
ram54288 0:dbad57390bd1 80 }
ram54288 0:dbad57390bd1 81
ram54288 0:dbad57390bd1 82 M2MNsdlInterface::~M2MNsdlInterface()
ram54288 0:dbad57390bd1 83 {
ram54288 0:dbad57390bd1 84 tr_debug("M2MNsdlInterface::~M2MNsdlInterface() - IN");
ram54288 0:dbad57390bd1 85 if(_endpoint) {
ram54288 0:dbad57390bd1 86 memory_free(_endpoint->endpoint_name_ptr);
ram54288 0:dbad57390bd1 87 memory_free(_endpoint->lifetime_ptr);
ram54288 0:dbad57390bd1 88 memory_free(_endpoint->location_ptr);
ram54288 0:dbad57390bd1 89 memory_free(_endpoint);
ram54288 0:dbad57390bd1 90 }
ram54288 0:dbad57390bd1 91 delete _nsdl_exceution_timer;
ram54288 0:dbad57390bd1 92 delete _registration_timer;
ram54288 0:dbad57390bd1 93 _object_list.clear();
ram54288 0:dbad57390bd1 94 _security = NULL;
ram54288 0:dbad57390bd1 95
ram54288 0:dbad57390bd1 96 sn_nsdl_destroy(_nsdl_handle);
ram54288 0:dbad57390bd1 97 _nsdl_handle = NULL;
ram54288 0:dbad57390bd1 98
ram54288 0:dbad57390bd1 99 M2MNsdlInterfaceList::const_iterator it;
ram54288 0:dbad57390bd1 100 it = __nsdl_interface_list.begin();
ram54288 0:dbad57390bd1 101 int index = 0;
ram54288 0:dbad57390bd1 102 for (; it!=__nsdl_interface_list.end(); it++) {
ram54288 0:dbad57390bd1 103 if ((*it) == this) {
ram54288 0:dbad57390bd1 104 __nsdl_interface_list.erase(index);
ram54288 0:dbad57390bd1 105 break;
ram54288 0:dbad57390bd1 106 }
ram54288 0:dbad57390bd1 107 index++;
ram54288 0:dbad57390bd1 108 }
ram54288 0:dbad57390bd1 109 tr_debug("M2MNsdlInterface::~M2MNsdlInterface() - OUT");
ram54288 0:dbad57390bd1 110 }
ram54288 0:dbad57390bd1 111
ram54288 0:dbad57390bd1 112 bool M2MNsdlInterface::initialize()
ram54288 0:dbad57390bd1 113 {
ram54288 0:dbad57390bd1 114 tr_debug("M2MNsdlInterface::initialize()");
ram54288 0:dbad57390bd1 115 bool success = false;
ram54288 0:dbad57390bd1 116
ram54288 0:dbad57390bd1 117 //Sets the packet retransmission attempts and time interval
ram54288 0:dbad57390bd1 118 sn_nsdl_set_retransmission_parameters(_nsdl_handle,
ram54288 0:dbad57390bd1 119 MBED_CLIENT_RECONNECTION_COUNT,
ram54288 0:dbad57390bd1 120 MBED_CLIENT_RECONNECTION_INTERVAL);
ram54288 0:dbad57390bd1 121
ram54288 0:dbad57390bd1 122 //Allocate the memory for endpoint
ram54288 0:dbad57390bd1 123 _endpoint = (sn_nsdl_ep_parameters_s*)memory_alloc(sizeof(sn_nsdl_ep_parameters_s));
ram54288 0:dbad57390bd1 124 if(_endpoint) {
ram54288 0:dbad57390bd1 125 memset(_endpoint, 0, sizeof(sn_nsdl_ep_parameters_s));
ram54288 0:dbad57390bd1 126 success = true;
ram54288 0:dbad57390bd1 127 }
ram54288 0:dbad57390bd1 128 return success;
ram54288 0:dbad57390bd1 129 }
ram54288 0:dbad57390bd1 130
ram54288 0:dbad57390bd1 131 void M2MNsdlInterface::create_endpoint(const String &name,
ram54288 0:dbad57390bd1 132 const String &type,
ram54288 0:dbad57390bd1 133 const int32_t life_time,
ram54288 0:dbad57390bd1 134 const String &domain,
ram54288 0:dbad57390bd1 135 const uint8_t mode,
ram54288 0:dbad57390bd1 136 const String &/*context_address*/)
ram54288 0:dbad57390bd1 137 {
ram54288 0:dbad57390bd1 138 tr_debug("M2MNsdlInterface::create_endpoint( name %s type %s lifetime %" PRId32 ", domain %s, mode %d)",
ram54288 0:dbad57390bd1 139 name.c_str(), type.c_str(), life_time, domain.c_str(), mode);
ram54288 0:dbad57390bd1 140 _endpoint_name = name;
ram54288 0:dbad57390bd1 141 if(_endpoint){
ram54288 0:dbad57390bd1 142 memset(_endpoint, 0, sizeof(sn_nsdl_ep_parameters_s));
ram54288 0:dbad57390bd1 143 if(!_endpoint_name.empty()) {
ram54288 0:dbad57390bd1 144 memory_free(_endpoint->endpoint_name_ptr);
ram54288 0:dbad57390bd1 145 _endpoint->endpoint_name_ptr = alloc_string_copy((uint8_t*)_endpoint_name.c_str(), _endpoint_name.length());
ram54288 0:dbad57390bd1 146 _endpoint->endpoint_name_len = _endpoint_name.length();
ram54288 0:dbad57390bd1 147 }
ram54288 0:dbad57390bd1 148 if(!type.empty()) {
ram54288 0:dbad57390bd1 149 _endpoint->type_ptr = (uint8_t*)type.c_str();
ram54288 0:dbad57390bd1 150 _endpoint->type_len = type.length();
ram54288 0:dbad57390bd1 151 }
ram54288 0:dbad57390bd1 152 if(!domain.empty()) {
ram54288 0:dbad57390bd1 153 _endpoint->domain_name_ptr = (uint8_t*)domain.c_str();
ram54288 0:dbad57390bd1 154 _endpoint->domain_name_len = domain.length();
ram54288 0:dbad57390bd1 155 }
ram54288 0:dbad57390bd1 156 _endpoint->binding_and_mode = (sn_nsdl_oma_binding_and_mode_t)mode;
ram54288 0:dbad57390bd1 157
ram54288 0:dbad57390bd1 158 // If lifetime is less than zero then leave the field empty
ram54288 0:dbad57390bd1 159 if( life_time > 0) {
ram54288 0:dbad57390bd1 160 set_endpoint_lifetime_buffer(life_time);
ram54288 0:dbad57390bd1 161 }
ram54288 0:dbad57390bd1 162 }
ram54288 0:dbad57390bd1 163 }
ram54288 0:dbad57390bd1 164
ram54288 0:dbad57390bd1 165 void M2MNsdlInterface::set_endpoint_lifetime_buffer(int lifetime)
ram54288 0:dbad57390bd1 166 {
ram54288 0:dbad57390bd1 167 // max len of "-9223372036854775808" plus zero termination
ram54288 0:dbad57390bd1 168 char buffer[20+1];
ram54288 0:dbad57390bd1 169
ram54288 0:dbad57390bd1 170 uint32_t size = m2m::itoa_c(lifetime, buffer);
ram54288 0:dbad57390bd1 171
ram54288 0:dbad57390bd1 172 if (_endpoint && size <= sizeof(buffer)) {
ram54288 0:dbad57390bd1 173 _endpoint->lifetime_ptr = alloc_string_copy((uint8_t*)buffer, size);
ram54288 0:dbad57390bd1 174 if(_endpoint->lifetime_ptr) {
ram54288 0:dbad57390bd1 175 _endpoint->lifetime_len = size;
ram54288 0:dbad57390bd1 176 } else {
ram54288 0:dbad57390bd1 177 _endpoint->lifetime_len = 0;
ram54288 0:dbad57390bd1 178 }
ram54288 0:dbad57390bd1 179 }
ram54288 0:dbad57390bd1 180 }
ram54288 0:dbad57390bd1 181
ram54288 0:dbad57390bd1 182
ram54288 0:dbad57390bd1 183 void M2MNsdlInterface::delete_endpoint()
ram54288 0:dbad57390bd1 184 {
ram54288 0:dbad57390bd1 185 tr_debug("M2MNsdlInterface::delete_endpoint()");
ram54288 0:dbad57390bd1 186 if(_endpoint) {
ram54288 0:dbad57390bd1 187 free(_endpoint->lifetime_ptr);
ram54288 0:dbad57390bd1 188
ram54288 0:dbad57390bd1 189 memory_free(_endpoint);
ram54288 0:dbad57390bd1 190 _endpoint = NULL;
ram54288 0:dbad57390bd1 191 }
ram54288 0:dbad57390bd1 192 }
ram54288 0:dbad57390bd1 193
ram54288 0:dbad57390bd1 194 bool M2MNsdlInterface::create_nsdl_list_structure(const M2MObjectList &object_list)
ram54288 0:dbad57390bd1 195 {
ram54288 0:dbad57390bd1 196 tr_debug("M2MNsdlInterface::create_nsdl_list_structure()");
ram54288 0:dbad57390bd1 197 bool success = false;
ram54288 0:dbad57390bd1 198 if(!object_list.empty()) {
ram54288 0:dbad57390bd1 199 tr_debug("M2MNsdlInterface::create_nsdl_list_structure - Object count is %d", object_list.size());
ram54288 0:dbad57390bd1 200 M2MObjectList::const_iterator it;
ram54288 0:dbad57390bd1 201 it = object_list.begin();
ram54288 0:dbad57390bd1 202 for ( ; it != object_list.end(); it++ ) {
ram54288 0:dbad57390bd1 203 // Create NSDL structure for all Objects inside
ram54288 0:dbad57390bd1 204 success = create_nsdl_object_structure(*it);
ram54288 0:dbad57390bd1 205 add_object_to_list(*it);
ram54288 0:dbad57390bd1 206 }
ram54288 0:dbad57390bd1 207 }
ram54288 0:dbad57390bd1 208 return success;
ram54288 0:dbad57390bd1 209 }
ram54288 0:dbad57390bd1 210
ram54288 0:dbad57390bd1 211 bool M2MNsdlInterface::remove_nsdl_resource(M2MBase *base)
ram54288 0:dbad57390bd1 212 {
ram54288 0:dbad57390bd1 213 sn_nsdl_dynamic_resource_parameters_s* resource = base->get_nsdl_resource();
ram54288 0:dbad57390bd1 214 return sn_nsdl_pop_resource(_nsdl_handle, resource);
ram54288 0:dbad57390bd1 215 }
ram54288 0:dbad57390bd1 216
ram54288 0:dbad57390bd1 217 bool M2MNsdlInterface::create_bootstrap_resource(sn_nsdl_addr_s *address, const String &bootstrap_endpoint_name)
ram54288 0:dbad57390bd1 218 {
ram54288 0:dbad57390bd1 219 #ifndef MBED_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 220 tr_debug("M2MNsdlInterface::create_bootstrap_resource()");
ram54288 0:dbad57390bd1 221 _identity_accepted = false;
ram54288 0:dbad57390bd1 222 bool success = false;
ram54288 0:dbad57390bd1 223 sn_nsdl_bs_ep_info_t bootstrap_endpoint;
ram54288 0:dbad57390bd1 224 tr_debug("M2MNsdlInterface::create_bootstrap_resource() - endpoint name: %s", bootstrap_endpoint_name.c_str());
ram54288 0:dbad57390bd1 225 if (_endpoint->endpoint_name_ptr) {
ram54288 0:dbad57390bd1 226 memory_free(_endpoint->endpoint_name_ptr);
ram54288 0:dbad57390bd1 227 }
ram54288 0:dbad57390bd1 228
ram54288 0:dbad57390bd1 229 _endpoint->endpoint_name_ptr = alloc_string_copy((uint8_t*)bootstrap_endpoint_name.c_str(), bootstrap_endpoint_name.length());
ram54288 0:dbad57390bd1 230 _endpoint->endpoint_name_len = bootstrap_endpoint_name.length();
ram54288 0:dbad57390bd1 231 if(_bootstrap_id == 0) {
ram54288 0:dbad57390bd1 232 _bootstrap_id = sn_nsdl_oma_bootstrap(_nsdl_handle,
ram54288 0:dbad57390bd1 233 address,
ram54288 0:dbad57390bd1 234 _endpoint,
ram54288 0:dbad57390bd1 235 &bootstrap_endpoint);
ram54288 0:dbad57390bd1 236 tr_debug("M2MNsdlInterface::create_bootstrap_resource - _bootstrap_id %d", _bootstrap_id);
ram54288 0:dbad57390bd1 237 success = _bootstrap_id != 0;
ram54288 0:dbad57390bd1 238 }
ram54288 0:dbad57390bd1 239 return success;
ram54288 0:dbad57390bd1 240 #else
ram54288 0:dbad57390bd1 241 (void)address;
ram54288 0:dbad57390bd1 242 (void)bootstrap_endpoint_name;
ram54288 0:dbad57390bd1 243 return false;
ram54288 0:dbad57390bd1 244 #endif //MBED_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 245 }
ram54288 0:dbad57390bd1 246
ram54288 0:dbad57390bd1 247 bool M2MNsdlInterface::send_register_message(uint8_t* address,
ram54288 0:dbad57390bd1 248 uint8_t address_length,
ram54288 0:dbad57390bd1 249 const uint16_t port,
ram54288 0:dbad57390bd1 250 sn_nsdl_addr_type_e address_type)
ram54288 0:dbad57390bd1 251 {
ram54288 0:dbad57390bd1 252 tr_debug("M2MNsdlInterface::send_register_message()");
ram54288 0:dbad57390bd1 253 _nsdl_exceution_timer->stop_timer();
ram54288 0:dbad57390bd1 254 _nsdl_exceution_timer->start_timer(ONE_SECOND_TIMER * 1000,
ram54288 0:dbad57390bd1 255 M2MTimerObserver::NsdlExecution,
ram54288 0:dbad57390bd1 256 false);
ram54288 0:dbad57390bd1 257 bool success = false;
ram54288 0:dbad57390bd1 258 if(set_NSP_address(_nsdl_handle, address, address_length, port, address_type) == 0) {
ram54288 0:dbad57390bd1 259 success = sn_nsdl_register_endpoint(_nsdl_handle,_endpoint) != 0;
ram54288 0:dbad57390bd1 260 }
ram54288 0:dbad57390bd1 261 return success;
ram54288 0:dbad57390bd1 262 }
ram54288 0:dbad57390bd1 263
ram54288 0:dbad57390bd1 264 bool M2MNsdlInterface::send_update_registration(const uint32_t lifetime)
ram54288 0:dbad57390bd1 265 {
ram54288 0:dbad57390bd1 266 tr_debug("M2MNsdlInterface::send_update_registration( lifetime %" PRIu32 ")", lifetime);
ram54288 0:dbad57390bd1 267 bool success = false;
ram54288 0:dbad57390bd1 268 create_nsdl_list_structure(_object_list);
ram54288 0:dbad57390bd1 269
ram54288 0:dbad57390bd1 270 //If Lifetime value is 0, then don't change the existing lifetime value
ram54288 0:dbad57390bd1 271 if(lifetime != 0) {
ram54288 0:dbad57390bd1 272 if(_endpoint && _endpoint->lifetime_ptr) {
ram54288 0:dbad57390bd1 273 memory_free(_endpoint->lifetime_ptr);
ram54288 0:dbad57390bd1 274 _endpoint->lifetime_ptr = NULL;
ram54288 0:dbad57390bd1 275 _endpoint->lifetime_len = 0;
ram54288 0:dbad57390bd1 276 }
ram54288 0:dbad57390bd1 277 set_endpoint_lifetime_buffer(lifetime);
ram54288 0:dbad57390bd1 278
ram54288 0:dbad57390bd1 279 _registration_timer->stop_timer();
ram54288 0:dbad57390bd1 280 _registration_timer->start_timer(registration_time() * 1000,
ram54288 0:dbad57390bd1 281 M2MTimerObserver::Registration,
ram54288 0:dbad57390bd1 282 false);
ram54288 0:dbad57390bd1 283 if(_nsdl_handle &&
ram54288 0:dbad57390bd1 284 _endpoint && _endpoint->lifetime_ptr) {
ram54288 0:dbad57390bd1 285 tr_debug("M2MNsdlInterface::send_update_registration - new lifetime value");
ram54288 0:dbad57390bd1 286 success = sn_nsdl_update_registration(_nsdl_handle,
ram54288 0:dbad57390bd1 287 _endpoint->lifetime_ptr,
ram54288 0:dbad57390bd1 288 _endpoint->lifetime_len) != 0;
ram54288 0:dbad57390bd1 289 }
ram54288 0:dbad57390bd1 290 } else {
ram54288 0:dbad57390bd1 291 if(_nsdl_handle) {
ram54288 0:dbad57390bd1 292 tr_debug("M2MNsdlInterface::send_update_registration - regular update");
ram54288 0:dbad57390bd1 293 success = sn_nsdl_update_registration(_nsdl_handle, NULL, 0) != 0;
ram54288 0:dbad57390bd1 294 }
ram54288 0:dbad57390bd1 295 }
ram54288 0:dbad57390bd1 296 return success;
ram54288 0:dbad57390bd1 297 }
ram54288 0:dbad57390bd1 298
ram54288 0:dbad57390bd1 299 bool M2MNsdlInterface::send_unregister_message()
ram54288 0:dbad57390bd1 300 {
ram54288 0:dbad57390bd1 301 tr_debug("M2MNsdlInterface::send_unregister_message");
ram54288 0:dbad57390bd1 302 if (_unregister_ongoing) {
ram54288 0:dbad57390bd1 303 tr_debug("M2MNsdlInterface::send_unregister_message - unregistration already in progress");
ram54288 0:dbad57390bd1 304 return true;
ram54288 0:dbad57390bd1 305 }
ram54288 0:dbad57390bd1 306
ram54288 0:dbad57390bd1 307 bool success = false;
ram54288 0:dbad57390bd1 308 _unregister_ongoing = true;
ram54288 0:dbad57390bd1 309 success = sn_nsdl_unregister_endpoint(_nsdl_handle) != 0;
ram54288 0:dbad57390bd1 310 return success;
ram54288 0:dbad57390bd1 311 }
ram54288 0:dbad57390bd1 312
ram54288 0:dbad57390bd1 313 // XXX: move these to common place, no need to copy these wrappers to multiple places:
ram54288 0:dbad57390bd1 314 void *M2MNsdlInterface::memory_alloc(uint16_t size)
ram54288 0:dbad57390bd1 315 {
ram54288 0:dbad57390bd1 316 if(size)
ram54288 0:dbad57390bd1 317 return malloc(size);
ram54288 0:dbad57390bd1 318 else
ram54288 0:dbad57390bd1 319 return 0;
ram54288 0:dbad57390bd1 320 }
ram54288 0:dbad57390bd1 321
ram54288 0:dbad57390bd1 322 void M2MNsdlInterface::memory_free(void *ptr)
ram54288 0:dbad57390bd1 323 {
ram54288 0:dbad57390bd1 324 if(ptr)
ram54288 0:dbad57390bd1 325 free(ptr);
ram54288 0:dbad57390bd1 326 }
ram54288 0:dbad57390bd1 327
ram54288 0:dbad57390bd1 328 uint8_t* M2MNsdlInterface::alloc_string_copy(const uint8_t* source, uint16_t size)
ram54288 0:dbad57390bd1 329 {
ram54288 0:dbad57390bd1 330 assert(source != NULL);
ram54288 0:dbad57390bd1 331
ram54288 0:dbad57390bd1 332 uint8_t* result = (uint8_t*)memory_alloc(size + 1);
ram54288 0:dbad57390bd1 333 if (result) {
ram54288 0:dbad57390bd1 334 memcpy(result, source, size);
ram54288 0:dbad57390bd1 335 result[size] = '\0';
ram54288 0:dbad57390bd1 336 }
ram54288 0:dbad57390bd1 337 return result;
ram54288 0:dbad57390bd1 338 }
ram54288 0:dbad57390bd1 339
ram54288 0:dbad57390bd1 340 uint8_t M2MNsdlInterface::send_to_server_callback(struct nsdl_s * /*nsdl_handle*/,
ram54288 0:dbad57390bd1 341 sn_nsdl_capab_e /*protocol*/,
ram54288 0:dbad57390bd1 342 uint8_t *data_ptr,
ram54288 0:dbad57390bd1 343 uint16_t data_len,
ram54288 0:dbad57390bd1 344 sn_nsdl_addr_s *address)
ram54288 0:dbad57390bd1 345 {
ram54288 0:dbad57390bd1 346 tr_debug("M2MNsdlInterface::send_to_server_callback()");
ram54288 0:dbad57390bd1 347 _observer.coap_message_ready(data_ptr,data_len,address);
ram54288 0:dbad57390bd1 348 return 1;
ram54288 0:dbad57390bd1 349 }
ram54288 0:dbad57390bd1 350
ram54288 0:dbad57390bd1 351 uint8_t M2MNsdlInterface::received_from_server_callback(struct nsdl_s *nsdl_handle,
ram54288 0:dbad57390bd1 352 sn_coap_hdr_s *coap_header,
ram54288 0:dbad57390bd1 353 sn_nsdl_addr_s *address)
ram54288 0:dbad57390bd1 354 {
ram54288 0:dbad57390bd1 355 _observer.coap_data_processed();
ram54288 0:dbad57390bd1 356 uint8_t value = 0;
ram54288 0:dbad57390bd1 357 if(nsdl_handle && coap_header) {
ram54288 0:dbad57390bd1 358 tr_debug("M2MNsdlInterface::received_from_server_callback - incoming msg id:%" PRIu16, coap_header->msg_id);
ram54288 0:dbad57390bd1 359 tr_debug("M2MNsdlInterface::received_from_server_callback - registration id:%" PRIu16, nsdl_handle->register_msg_id);
ram54288 0:dbad57390bd1 360 tr_debug("M2MNsdlInterface::received_from_server_callback - unregistration id:%" PRIu16, nsdl_handle->unregister_msg_id);
ram54288 0:dbad57390bd1 361 tr_debug("M2MNsdlInterface::received_from_server_callback - update registration id:%" PRIu16, nsdl_handle->update_register_msg_id);
ram54288 0:dbad57390bd1 362 bool is_bootstrap_msg = address && (nsdl_handle->oma_bs_address_len == address->addr_len) &&
ram54288 0:dbad57390bd1 363 (nsdl_handle->oma_bs_port == address->port) &&
ram54288 0:dbad57390bd1 364 !memcmp(nsdl_handle->oma_bs_address_ptr, address->addr_ptr, nsdl_handle->oma_bs_address_len);
ram54288 0:dbad57390bd1 365 if(coap_header->msg_id == nsdl_handle->register_msg_id) {
ram54288 0:dbad57390bd1 366 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_CREATED) {
ram54288 0:dbad57390bd1 367 tr_debug("M2MNsdlInterface::received_from_server_callback - registration callback");
ram54288 0:dbad57390bd1 368 _observer.client_registered(&_server);
ram54288 0:dbad57390bd1 369 // If lifetime is less than zero then leave the field empty
ram54288 0:dbad57390bd1 370 if(coap_header->options_list_ptr) {
ram54288 0:dbad57390bd1 371 memory_free(_endpoint->lifetime_ptr);
ram54288 0:dbad57390bd1 372 _endpoint->lifetime_ptr = NULL;
ram54288 0:dbad57390bd1 373 _endpoint->lifetime_len = 0;
ram54288 0:dbad57390bd1 374
ram54288 0:dbad57390bd1 375 uint32_t max_time = coap_header->options_list_ptr->max_age;
ram54288 0:dbad57390bd1 376 // If lifetime is less than zero then leave the field empty
ram54288 0:dbad57390bd1 377 if( max_time > 0) {
ram54288 0:dbad57390bd1 378 set_endpoint_lifetime_buffer(max_time);
ram54288 0:dbad57390bd1 379 }
ram54288 0:dbad57390bd1 380 if(coap_header->options_list_ptr->location_path_ptr) {
ram54288 0:dbad57390bd1 381
ram54288 0:dbad57390bd1 382 memory_free(_endpoint->location_ptr);
ram54288 0:dbad57390bd1 383
ram54288 0:dbad57390bd1 384 _endpoint->location_ptr = alloc_string_copy(coap_header->options_list_ptr->location_path_ptr, coap_header->options_list_ptr->location_path_len);
ram54288 0:dbad57390bd1 385 if (_endpoint->location_ptr != NULL) {
ram54288 0:dbad57390bd1 386 _endpoint->location_len = coap_header->options_list_ptr->location_path_len;
ram54288 0:dbad57390bd1 387 }
ram54288 0:dbad57390bd1 388 sn_nsdl_set_endpoint_location(_nsdl_handle,_endpoint->location_ptr,_endpoint->location_len);
ram54288 0:dbad57390bd1 389 }
ram54288 0:dbad57390bd1 390 }
ram54288 0:dbad57390bd1 391 if(_endpoint->lifetime_ptr) {
ram54288 0:dbad57390bd1 392 _registration_timer->stop_timer();
ram54288 0:dbad57390bd1 393 _registration_timer->start_timer(registration_time() * 1000,
ram54288 0:dbad57390bd1 394 M2MTimerObserver::Registration,
ram54288 0:dbad57390bd1 395 false);
ram54288 0:dbad57390bd1 396 }
ram54288 0:dbad57390bd1 397 } else {
ram54288 0:dbad57390bd1 398 tr_error("M2MNsdlInterface::received_from_server_callback - registration error %d", coap_header->msg_code);
ram54288 0:dbad57390bd1 399 // Try to do clean register again
ram54288 0:dbad57390bd1 400 if(COAP_MSG_CODE_RESPONSE_BAD_REQUEST == coap_header->msg_code ||
ram54288 0:dbad57390bd1 401 COAP_MSG_CODE_RESPONSE_FORBIDDEN == coap_header->msg_code) {
ram54288 0:dbad57390bd1 402 _observer.registration_error(M2MInterface::InvalidParameters, false);
ram54288 0:dbad57390bd1 403 } else {
ram54288 0:dbad57390bd1 404 _observer.registration_error(M2MInterface::NetworkError, true);
ram54288 0:dbad57390bd1 405 }
ram54288 0:dbad57390bd1 406
ram54288 0:dbad57390bd1 407 }
ram54288 0:dbad57390bd1 408 } else if(coap_header->msg_id == nsdl_handle->unregister_msg_id) {
ram54288 0:dbad57390bd1 409 _unregister_ongoing = false;
ram54288 0:dbad57390bd1 410 tr_debug("M2MNsdlInterface::received_from_server_callback - unregistration callback");
ram54288 0:dbad57390bd1 411 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_DELETED) {
ram54288 0:dbad57390bd1 412 _registration_timer->stop_timer();
ram54288 0:dbad57390bd1 413 _observer.client_unregistered();
ram54288 0:dbad57390bd1 414 } else {
ram54288 0:dbad57390bd1 415 tr_error("M2MNsdlInterface::received_from_server_callback - unregistration error %d", coap_header->msg_code);
ram54288 0:dbad57390bd1 416 M2MInterface::Error error = interface_error(coap_header);
ram54288 0:dbad57390bd1 417 _observer.registration_error(error);
ram54288 0:dbad57390bd1 418 }
ram54288 0:dbad57390bd1 419 } else if(coap_header->msg_id == nsdl_handle->update_register_msg_id) {
ram54288 0:dbad57390bd1 420 if(coap_header->msg_code == COAP_MSG_CODE_RESPONSE_CHANGED) {
ram54288 0:dbad57390bd1 421 tr_debug("M2MNsdlInterface::received_from_server_callback - registration_updated successfully");
ram54288 0:dbad57390bd1 422 _observer.registration_updated(_server);
ram54288 0:dbad57390bd1 423 } else {
ram54288 0:dbad57390bd1 424 tr_error("M2MNsdlInterface::received_from_server_callback - registration_updated failed %d", coap_header->msg_code);
ram54288 0:dbad57390bd1 425 _registration_timer->stop_timer();
ram54288 0:dbad57390bd1 426 sn_nsdl_register_endpoint(_nsdl_handle,_endpoint);
ram54288 0:dbad57390bd1 427 }
ram54288 0:dbad57390bd1 428 }
ram54288 0:dbad57390bd1 429 #ifndef MBED_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 430 else if(coap_header->msg_id == nsdl_handle->bootstrap_msg_id) {
ram54288 0:dbad57390bd1 431 tr_debug("M2MNsdlInterface::received_from_server_callback - bootstrap");
ram54288 0:dbad57390bd1 432 _bootstrap_id = 0;
ram54288 0:dbad57390bd1 433 M2MInterface::Error error = interface_error(coap_header);
ram54288 0:dbad57390bd1 434 if(error != M2MInterface::ErrorNone) {
ram54288 0:dbad57390bd1 435 handle_bootstrap_error();
ram54288 0:dbad57390bd1 436 } else {
ram54288 0:dbad57390bd1 437 _identity_accepted = true;
ram54288 0:dbad57390bd1 438 }
ram54288 0:dbad57390bd1 439 }
ram54288 0:dbad57390bd1 440 #endif //MBED_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 441 else {
ram54288 0:dbad57390bd1 442
ram54288 0:dbad57390bd1 443 sn_coap_hdr_s *coap_response = NULL;
ram54288 0:dbad57390bd1 444 bool execute_value_updated = false;
ram54288 0:dbad57390bd1 445 M2MObjectInstance *obj_instance = NULL;
ram54288 0:dbad57390bd1 446 String resource_name;
ram54288 0:dbad57390bd1 447
ram54288 0:dbad57390bd1 448 if(COAP_MSG_CODE_REQUEST_PUT == coap_header->msg_code) {
ram54288 0:dbad57390bd1 449 if (is_bootstrap_msg) {
ram54288 0:dbad57390bd1 450 handle_bootstrap_put_message(coap_header, address);
ram54288 0:dbad57390bd1 451 }
ram54288 0:dbad57390bd1 452 else{
ram54288 0:dbad57390bd1 453 tr_debug("M2MNsdlInterface::received_from_server_callback - Method not allowed (PUT).");
ram54288 0:dbad57390bd1 454 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 455 coap_header,
ram54288 0:dbad57390bd1 456 COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED);
ram54288 0:dbad57390bd1 457 }
ram54288 0:dbad57390bd1 458 }
ram54288 0:dbad57390bd1 459 else if(COAP_MSG_CODE_REQUEST_DELETE == coap_header->msg_code) {
ram54288 0:dbad57390bd1 460 if (is_bootstrap_msg) {
ram54288 0:dbad57390bd1 461 handle_bootstrap_delete(coap_header, address);
ram54288 0:dbad57390bd1 462 }
ram54288 0:dbad57390bd1 463 else{
ram54288 0:dbad57390bd1 464 tr_debug("M2MNsdlInterface::received_from_server_callback - Method not allowed (DELETE).");
ram54288 0:dbad57390bd1 465 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 466 coap_header,
ram54288 0:dbad57390bd1 467 COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED);
ram54288 0:dbad57390bd1 468 }
ram54288 0:dbad57390bd1 469 }
ram54288 0:dbad57390bd1 470 else if(COAP_MSG_CODE_REQUEST_POST == coap_header->msg_code) {
ram54288 0:dbad57390bd1 471 if(is_bootstrap_msg) {
ram54288 0:dbad57390bd1 472 handle_bootstrap_finished(coap_header, address);
ram54288 0:dbad57390bd1 473 }
ram54288 0:dbad57390bd1 474 else if(coap_header->uri_path_ptr) {
ram54288 0:dbad57390bd1 475
ram54288 0:dbad57390bd1 476 resource_name = coap_to_string(coap_header->uri_path_ptr,
ram54288 0:dbad57390bd1 477 coap_header->uri_path_len);
ram54288 0:dbad57390bd1 478
ram54288 0:dbad57390bd1 479 String object_name;
ram54288 0:dbad57390bd1 480 int slash_found = resource_name.find_last_of('/');
ram54288 0:dbad57390bd1 481 //The POST operation here is only allowed for non-existing object instances
ram54288 0:dbad57390bd1 482 if(slash_found != -1) {
ram54288 0:dbad57390bd1 483 object_name = resource_name.substr(0,slash_found);
ram54288 0:dbad57390bd1 484 if( object_name.find_last_of('/') != -1){
ram54288 0:dbad57390bd1 485 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 486 coap_header,
ram54288 0:dbad57390bd1 487 COAP_MSG_CODE_RESPONSE_NOT_FOUND);
ram54288 0:dbad57390bd1 488 } else {
ram54288 0:dbad57390bd1 489 int32_t instance_id = atoi(resource_name.substr(slash_found+1,
ram54288 0:dbad57390bd1 490 resource_name.size()-object_name.size()).c_str());
ram54288 0:dbad57390bd1 491 M2MBase* base = find_resource(object_name);
ram54288 0:dbad57390bd1 492 if(base && (instance_id >= 0) && (instance_id < UINT16_MAX)) {
ram54288 0:dbad57390bd1 493 if(coap_header->payload_ptr) {
ram54288 0:dbad57390bd1 494 M2MObject* object = static_cast<M2MObject*> (base);
ram54288 0:dbad57390bd1 495 obj_instance = object->create_object_instance(instance_id);
ram54288 0:dbad57390bd1 496 if(obj_instance) {
ram54288 0:dbad57390bd1 497 obj_instance->set_operation(M2MBase::GET_PUT_POST_ALLOWED);
ram54288 0:dbad57390bd1 498 coap_response = obj_instance->handle_post_request(_nsdl_handle,
ram54288 0:dbad57390bd1 499 coap_header,
ram54288 0:dbad57390bd1 500 this,
ram54288 0:dbad57390bd1 501 execute_value_updated);
ram54288 0:dbad57390bd1 502 }
ram54288 0:dbad57390bd1 503 if(coap_response && coap_response->msg_code != COAP_MSG_CODE_RESPONSE_CREATED) {
ram54288 0:dbad57390bd1 504 //Invalid request so remove created ObjectInstance
ram54288 0:dbad57390bd1 505 object->remove_object_instance(instance_id);
ram54288 0:dbad57390bd1 506 } else {
ram54288 0:dbad57390bd1 507 tr_debug("M2MNsdlInterface::received_from_server_callback - Send Update registration for Create");
ram54288 0:dbad57390bd1 508 send_update_registration();
ram54288 0:dbad57390bd1 509 }
ram54288 0:dbad57390bd1 510 } else {
ram54288 0:dbad57390bd1 511 tr_debug("M2MNsdlInterface::received_from_server_callback - Missing Payload - Cannot create");
ram54288 0:dbad57390bd1 512 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 513 coap_header,
ram54288 0:dbad57390bd1 514 COAP_MSG_CODE_RESPONSE_BAD_REQUEST);
ram54288 0:dbad57390bd1 515 }
ram54288 0:dbad57390bd1 516 } else { //if(base)
ram54288 0:dbad57390bd1 517 tr_debug("M2MNsdlInterface::received_from_server_callback - Missing BASE - Cannot create");
ram54288 0:dbad57390bd1 518 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 519 coap_header,
ram54288 0:dbad57390bd1 520 COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED);
ram54288 0:dbad57390bd1 521 }
ram54288 0:dbad57390bd1 522 }
ram54288 0:dbad57390bd1 523 } else{ // if(slash_found != -1)
ram54288 0:dbad57390bd1 524 tr_debug("M2MNsdlInterface::received_from_server_callback - slash_found - Cannot create");
ram54288 0:dbad57390bd1 525 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 526 coap_header,
ram54288 0:dbad57390bd1 527 COAP_MSG_CODE_RESPONSE_NOT_FOUND);
ram54288 0:dbad57390bd1 528 }
ram54288 0:dbad57390bd1 529
ram54288 0:dbad57390bd1 530 }
ram54288 0:dbad57390bd1 531 }
ram54288 0:dbad57390bd1 532 else if(COAP_MSG_CODE_EMPTY == coap_header->msg_code) {
ram54288 0:dbad57390bd1 533 if (COAP_MSG_TYPE_RESET == coap_header->msg_type) {
ram54288 0:dbad57390bd1 534 // Cancel ongoing observation
ram54288 0:dbad57390bd1 535 tr_error("M2MNsdlInterface::received_from_server_callback() - RESET message");
ram54288 0:dbad57390bd1 536 M2MBase *base = find_resource("", coap_header->token_ptr, coap_header->token_len);
ram54288 0:dbad57390bd1 537 if (base) {
ram54288 0:dbad57390bd1 538 M2MBase::BaseType type = base->base_type();
ram54288 0:dbad57390bd1 539 switch (type) {
ram54288 0:dbad57390bd1 540 case M2MBase::Object:
ram54288 0:dbad57390bd1 541 base->remove_observation_level(M2MBase::O_Attribute);
ram54288 0:dbad57390bd1 542 break;
ram54288 0:dbad57390bd1 543 case M2MBase::Resource:
ram54288 0:dbad57390bd1 544 base->remove_observation_level(M2MBase::R_Attribute);
ram54288 0:dbad57390bd1 545 break;
ram54288 0:dbad57390bd1 546 case M2MBase::ObjectInstance:
ram54288 0:dbad57390bd1 547 base->remove_observation_level(M2MBase::OI_Attribute);
ram54288 0:dbad57390bd1 548 break;
ram54288 0:dbad57390bd1 549 default:
ram54288 0:dbad57390bd1 550 break;
ram54288 0:dbad57390bd1 551 }
ram54288 0:dbad57390bd1 552 base->set_under_observation(false, this);
ram54288 0:dbad57390bd1 553 }
ram54288 0:dbad57390bd1 554 } else {
ram54288 0:dbad57390bd1 555 tr_debug("M2MNsdlInterface::received_from_server_callback - Empty ACK, msg id: %d", coap_header->msg_id);
ram54288 0:dbad57390bd1 556 M2MBase *base = find_resource("", coap_header->token_ptr, coap_header->token_len);
ram54288 0:dbad57390bd1 557 if (base) {
ram54288 0:dbad57390bd1 558 // Supported only in Resource level
ram54288 0:dbad57390bd1 559 if (M2MBase::Resource == base->base_type()) {
ram54288 0:dbad57390bd1 560 M2MResource *resource = static_cast<M2MResource *> (base);
ram54288 0:dbad57390bd1 561 resource->notification_sent();
ram54288 0:dbad57390bd1 562 }
ram54288 0:dbad57390bd1 563 }
ram54288 0:dbad57390bd1 564 }
ram54288 0:dbad57390bd1 565 }
ram54288 0:dbad57390bd1 566
ram54288 0:dbad57390bd1 567 if(coap_response) {
ram54288 0:dbad57390bd1 568 tr_debug("M2MNsdlInterface::received_from_server_callback - send CoAP response");
ram54288 0:dbad57390bd1 569 (sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response) == 0) ? value = 0 : value = 1;
ram54288 0:dbad57390bd1 570 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 571 }
ram54288 0:dbad57390bd1 572
ram54288 0:dbad57390bd1 573 if (execute_value_updated) {
ram54288 0:dbad57390bd1 574 value_updated(obj_instance, resource_name);
ram54288 0:dbad57390bd1 575 }
ram54288 0:dbad57390bd1 576
ram54288 0:dbad57390bd1 577 }
ram54288 0:dbad57390bd1 578 }
ram54288 0:dbad57390bd1 579 return value;
ram54288 0:dbad57390bd1 580 }
ram54288 0:dbad57390bd1 581
ram54288 0:dbad57390bd1 582 uint8_t M2MNsdlInterface::resource_callback(struct nsdl_s */*nsdl_handle*/,
ram54288 0:dbad57390bd1 583 sn_coap_hdr_s *received_coap_header,
ram54288 0:dbad57390bd1 584 sn_nsdl_addr_s *address,
ram54288 0:dbad57390bd1 585 sn_nsdl_capab_e /*nsdl_capab*/)
ram54288 0:dbad57390bd1 586 {
ram54288 0:dbad57390bd1 587 tr_debug("M2MNsdlInterface::resource_callback()");
ram54288 0:dbad57390bd1 588 _observer.coap_data_processed();
ram54288 0:dbad57390bd1 589 uint8_t result = 1;
ram54288 0:dbad57390bd1 590 sn_coap_hdr_s *coap_response = NULL;
ram54288 0:dbad57390bd1 591 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 4.00
ram54288 0:dbad57390bd1 592 String resource_name = coap_to_string(received_coap_header->uri_path_ptr,
ram54288 0:dbad57390bd1 593 received_coap_header->uri_path_len);
ram54288 0:dbad57390bd1 594 tr_debug("M2MNsdlInterface::resource_callback() - resource_name %s", resource_name.c_str());
ram54288 0:dbad57390bd1 595 bool execute_value_updated = false;
ram54288 0:dbad57390bd1 596 M2MBase* base = find_resource(resource_name);
ram54288 0:dbad57390bd1 597 if(base) {
ram54288 0:dbad57390bd1 598 if(COAP_MSG_CODE_REQUEST_GET == received_coap_header->msg_code) {
ram54288 0:dbad57390bd1 599 coap_response = base->handle_get_request(_nsdl_handle, received_coap_header,this);
ram54288 0:dbad57390bd1 600 } else if(COAP_MSG_CODE_REQUEST_PUT == received_coap_header->msg_code) {
ram54288 0:dbad57390bd1 601 coap_response = base->handle_put_request(_nsdl_handle, received_coap_header, this, execute_value_updated);
ram54288 0:dbad57390bd1 602 } else if(COAP_MSG_CODE_REQUEST_POST == received_coap_header->msg_code) {
ram54288 0:dbad57390bd1 603 if(base->base_type() == M2MBase::ResourceInstance) {
ram54288 0:dbad57390bd1 604 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 605 } else {
ram54288 0:dbad57390bd1 606 coap_response = base->handle_post_request(_nsdl_handle,
ram54288 0:dbad57390bd1 607 received_coap_header,
ram54288 0:dbad57390bd1 608 this,
ram54288 0:dbad57390bd1 609 execute_value_updated,
ram54288 0:dbad57390bd1 610 address);
ram54288 0:dbad57390bd1 611 }
ram54288 0:dbad57390bd1 612 } else if(COAP_MSG_CODE_REQUEST_DELETE == received_coap_header->msg_code) {
ram54288 0:dbad57390bd1 613 // Delete the object instance
ram54288 0:dbad57390bd1 614 tr_debug("M2MNsdlInterface::resource_callback() - DELETE the object instance");
ram54288 0:dbad57390bd1 615 M2MBase::BaseType type = base->base_type();
ram54288 0:dbad57390bd1 616 if(M2MBase::ObjectInstance == type) {
ram54288 0:dbad57390bd1 617 M2MBase* base_object = find_resource(base->name());
ram54288 0:dbad57390bd1 618 if(base_object) {
ram54288 0:dbad57390bd1 619 M2MObject *object = static_cast<M2MObject*> (base_object);
ram54288 0:dbad57390bd1 620 int slash_found = resource_name.find_last_of('/');
ram54288 0:dbad57390bd1 621 // Object instance validty checks done in upper level, no need for error handling
ram54288 0:dbad57390bd1 622 if(slash_found != -1) {
ram54288 0:dbad57390bd1 623 String object_name;
ram54288 0:dbad57390bd1 624 object_name = resource_name.substr(slash_found + 1, resource_name.length());
ram54288 0:dbad57390bd1 625 if (object->remove_object_instance(strtoul(
ram54288 0:dbad57390bd1 626 object_name.c_str(),
ram54288 0:dbad57390bd1 627 NULL,
ram54288 0:dbad57390bd1 628 10))) {
ram54288 0:dbad57390bd1 629 msg_code = COAP_MSG_CODE_RESPONSE_DELETED;
ram54288 0:dbad57390bd1 630 }
ram54288 0:dbad57390bd1 631 }
ram54288 0:dbad57390bd1 632 }
ram54288 0:dbad57390bd1 633 } else {
ram54288 0:dbad57390bd1 634 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
ram54288 0:dbad57390bd1 635 }
ram54288 0:dbad57390bd1 636 }
ram54288 0:dbad57390bd1 637 } else {
ram54288 0:dbad57390bd1 638 tr_debug("M2MNsdlInterface::resource_callback() - Resource NOT FOUND");
ram54288 0:dbad57390bd1 639 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
ram54288 0:dbad57390bd1 640 }
ram54288 0:dbad57390bd1 641 if(!coap_response) {
ram54288 0:dbad57390bd1 642 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 643 received_coap_header,
ram54288 0:dbad57390bd1 644 msg_code);
ram54288 0:dbad57390bd1 645 }
ram54288 0:dbad57390bd1 646 if(coap_response &&
ram54288 0:dbad57390bd1 647 coap_response->coap_status != COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVING &&
ram54288 0:dbad57390bd1 648 coap_response->msg_code != COAP_MSG_CODE_EMPTY) {
ram54288 0:dbad57390bd1 649
ram54288 0:dbad57390bd1 650 tr_debug("M2MNsdlInterface::resource_callback() - send CoAP response");
ram54288 0:dbad57390bd1 651 (sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response) == 0) ? result = 0 : result = 1;
ram54288 0:dbad57390bd1 652 if(coap_response->payload_ptr) {
ram54288 0:dbad57390bd1 653 free(coap_response->payload_ptr);
ram54288 0:dbad57390bd1 654 coap_response->payload_ptr = NULL;
ram54288 0:dbad57390bd1 655 }
ram54288 0:dbad57390bd1 656 }
ram54288 0:dbad57390bd1 657 // If the external blockwise storing is enabled call value updated once all the blocks have been received
ram54288 0:dbad57390bd1 658 if (execute_value_updated &&
ram54288 0:dbad57390bd1 659 coap_response &&
ram54288 0:dbad57390bd1 660 coap_response->coap_status != COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVING) {
ram54288 0:dbad57390bd1 661 value_updated(base,resource_name);
ram54288 0:dbad57390bd1 662 }
ram54288 0:dbad57390bd1 663
ram54288 0:dbad57390bd1 664 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 665 return result;
ram54288 0:dbad57390bd1 666 }
ram54288 0:dbad57390bd1 667
ram54288 0:dbad57390bd1 668 bool M2MNsdlInterface::process_received_data(uint8_t *data,
ram54288 0:dbad57390bd1 669 uint16_t data_size,
ram54288 0:dbad57390bd1 670 sn_nsdl_addr_s *address)
ram54288 0:dbad57390bd1 671 {
ram54288 0:dbad57390bd1 672 tr_debug("M2MNsdlInterface::process_received_data( data size %d)", data_size);
ram54288 0:dbad57390bd1 673 return (0 == sn_nsdl_process_coap(_nsdl_handle,
ram54288 0:dbad57390bd1 674 data,
ram54288 0:dbad57390bd1 675 data_size,
ram54288 0:dbad57390bd1 676 address)) ? true : false;
ram54288 0:dbad57390bd1 677 }
ram54288 0:dbad57390bd1 678
ram54288 0:dbad57390bd1 679 void M2MNsdlInterface::stop_timers()
ram54288 0:dbad57390bd1 680 {
ram54288 0:dbad57390bd1 681 tr_debug("M2MNsdlInterface::stop_timers()");
ram54288 0:dbad57390bd1 682 if(_registration_timer) {
ram54288 0:dbad57390bd1 683 _registration_timer->stop_timer();
ram54288 0:dbad57390bd1 684 }
ram54288 0:dbad57390bd1 685 if (_nsdl_exceution_timer) {
ram54288 0:dbad57390bd1 686 _nsdl_exceution_timer->stop_timer();
ram54288 0:dbad57390bd1 687 }
ram54288 0:dbad57390bd1 688 _bootstrap_id = 0;
ram54288 0:dbad57390bd1 689 _unregister_ongoing = false;
ram54288 0:dbad57390bd1 690 }
ram54288 0:dbad57390bd1 691
ram54288 0:dbad57390bd1 692 void M2MNsdlInterface::timer_expired(M2MTimerObserver::Type type)
ram54288 0:dbad57390bd1 693 {
ram54288 0:dbad57390bd1 694 if(M2MTimerObserver::NsdlExecution == type) {
ram54288 0:dbad57390bd1 695 sn_nsdl_exec(_nsdl_handle, _counter_for_nsdl);
ram54288 0:dbad57390bd1 696 _counter_for_nsdl++;
ram54288 0:dbad57390bd1 697 } else if(M2MTimerObserver::Registration == type) {
ram54288 0:dbad57390bd1 698 tr_debug("M2MNsdlInterface::timer_expired - M2MTimerObserver::Registration - Send update registration");
ram54288 0:dbad57390bd1 699 send_update_registration();
ram54288 0:dbad57390bd1 700 }
ram54288 0:dbad57390bd1 701 }
ram54288 0:dbad57390bd1 702
ram54288 0:dbad57390bd1 703 void M2MNsdlInterface::observation_to_be_sent(M2MBase *object,
ram54288 0:dbad57390bd1 704 uint16_t obs_number,
ram54288 0:dbad57390bd1 705 m2m::Vector<uint16_t> changed_instance_ids,
ram54288 0:dbad57390bd1 706 bool send_object)
ram54288 0:dbad57390bd1 707 {
ram54288 0:dbad57390bd1 708 __mutex_claim();
ram54288 0:dbad57390bd1 709 if(object) {
ram54288 0:dbad57390bd1 710 tr_debug("M2MNsdlInterface::observation_to_be_sent()");
ram54288 0:dbad57390bd1 711 M2MBase::BaseType type = object->base_type();
ram54288 0:dbad57390bd1 712 if(type == M2MBase::Object) {
ram54288 0:dbad57390bd1 713 send_object_observation(static_cast<M2MObject*> (object),
ram54288 0:dbad57390bd1 714 obs_number,
ram54288 0:dbad57390bd1 715 changed_instance_ids,
ram54288 0:dbad57390bd1 716 send_object);
ram54288 0:dbad57390bd1 717 } else if(type == M2MBase::ObjectInstance) {
ram54288 0:dbad57390bd1 718 send_object_instance_observation(static_cast<M2MObjectInstance*> (object), obs_number);
ram54288 0:dbad57390bd1 719 } else if(type == M2MBase::Resource) {
ram54288 0:dbad57390bd1 720 send_resource_observation(static_cast<M2MResource*> (object), obs_number);
ram54288 0:dbad57390bd1 721 }
ram54288 0:dbad57390bd1 722 }
ram54288 0:dbad57390bd1 723 __mutex_release();
ram54288 0:dbad57390bd1 724 }
ram54288 0:dbad57390bd1 725
ram54288 0:dbad57390bd1 726 void M2MNsdlInterface::send_delayed_response(M2MBase *base)
ram54288 0:dbad57390bd1 727 {
ram54288 0:dbad57390bd1 728 __mutex_claim();
ram54288 0:dbad57390bd1 729 tr_debug("M2MNsdlInterface::send_delayed_response()");
ram54288 0:dbad57390bd1 730 M2MResource *resource = NULL;
ram54288 0:dbad57390bd1 731 if(base) {
ram54288 0:dbad57390bd1 732 if(M2MBase::Resource == base->base_type()) {
ram54288 0:dbad57390bd1 733 resource = static_cast<M2MResource *> (base);
ram54288 0:dbad57390bd1 734 }
ram54288 0:dbad57390bd1 735 if(resource) {
ram54288 0:dbad57390bd1 736 sn_coap_hdr_s * coap_response = static_cast<sn_coap_hdr_s *>(malloc(sizeof(sn_coap_hdr_s)));
ram54288 0:dbad57390bd1 737 if(coap_response) {
ram54288 0:dbad57390bd1 738 memset(coap_response,0,sizeof(sn_coap_hdr_s));
ram54288 0:dbad57390bd1 739
ram54288 0:dbad57390bd1 740 coap_response->msg_type = COAP_MSG_TYPE_CONFIRMABLE;
ram54288 0:dbad57390bd1 741 coap_response->msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
ram54288 0:dbad57390bd1 742 resource->get_delayed_token(coap_response->token_ptr,coap_response->token_len);
ram54288 0:dbad57390bd1 743
ram54288 0:dbad57390bd1 744 uint32_t length = 0;
ram54288 0:dbad57390bd1 745 resource->get_value(coap_response->payload_ptr, length);
ram54288 0:dbad57390bd1 746 coap_response->payload_len = length;
ram54288 0:dbad57390bd1 747
ram54288 0:dbad57390bd1 748 sn_nsdl_send_coap_message(_nsdl_handle, _nsdl_handle->nsp_address_ptr->omalw_address_ptr, coap_response);
ram54288 0:dbad57390bd1 749
ram54288 0:dbad57390bd1 750 if(coap_response->payload_ptr) {
ram54288 0:dbad57390bd1 751 free(coap_response->payload_ptr);
ram54288 0:dbad57390bd1 752 coap_response->payload_ptr = NULL;
ram54288 0:dbad57390bd1 753 }
ram54288 0:dbad57390bd1 754 if(coap_response->token_ptr) {
ram54288 0:dbad57390bd1 755 free(coap_response->token_ptr);
ram54288 0:dbad57390bd1 756 coap_response->token_ptr = NULL;
ram54288 0:dbad57390bd1 757 }
ram54288 0:dbad57390bd1 758 free(coap_response);
ram54288 0:dbad57390bd1 759 }
ram54288 0:dbad57390bd1 760 }
ram54288 0:dbad57390bd1 761 }
ram54288 0:dbad57390bd1 762 __mutex_release();
ram54288 0:dbad57390bd1 763 }
ram54288 0:dbad57390bd1 764
ram54288 0:dbad57390bd1 765 void M2MNsdlInterface::resource_to_be_deleted(M2MBase *base)
ram54288 0:dbad57390bd1 766 {
ram54288 0:dbad57390bd1 767 __mutex_claim();
ram54288 0:dbad57390bd1 768 remove_nsdl_resource(base);
ram54288 0:dbad57390bd1 769 __mutex_release();
ram54288 0:dbad57390bd1 770 }
ram54288 0:dbad57390bd1 771
ram54288 0:dbad57390bd1 772 void M2MNsdlInterface::value_updated(M2MBase *base,
ram54288 0:dbad57390bd1 773 const String &object_name)
ram54288 0:dbad57390bd1 774 {
ram54288 0:dbad57390bd1 775 tr_debug("M2MNsdlInterface::value_updated()");
ram54288 0:dbad57390bd1 776 if(base) {
ram54288 0:dbad57390bd1 777 switch(base->base_type()) {
ram54288 0:dbad57390bd1 778 case M2MBase::Object:
ram54288 0:dbad57390bd1 779 create_nsdl_object_structure(static_cast<M2MObject*> (base));
ram54288 0:dbad57390bd1 780 break;
ram54288 0:dbad57390bd1 781 case M2MBase::ObjectInstance:
ram54288 0:dbad57390bd1 782 create_nsdl_object_instance_structure(static_cast<M2MObjectInstance*> (base));
ram54288 0:dbad57390bd1 783 break;
ram54288 0:dbad57390bd1 784 case M2MBase::Resource: {
ram54288 0:dbad57390bd1 785 M2MResource* resource = static_cast<M2MResource*> (base);
ram54288 0:dbad57390bd1 786 create_nsdl_resource_structure(resource,
ram54288 0:dbad57390bd1 787 resource->supports_multiple_instances());
ram54288 0:dbad57390bd1 788 }
ram54288 0:dbad57390bd1 789 break;
ram54288 0:dbad57390bd1 790 case M2MBase::ResourceInstance: {
ram54288 0:dbad57390bd1 791 M2MResourceInstance* instance = static_cast<M2MResourceInstance*> (base);
ram54288 0:dbad57390bd1 792 create_nsdl_resource(instance);
ram54288 0:dbad57390bd1 793 }
ram54288 0:dbad57390bd1 794 break;
ram54288 0:dbad57390bd1 795 }
ram54288 0:dbad57390bd1 796 }
ram54288 0:dbad57390bd1 797
ram54288 0:dbad57390bd1 798 if (base && base->is_value_updated_function_set()) {
ram54288 0:dbad57390bd1 799 base->execute_value_updated(base->name());
ram54288 0:dbad57390bd1 800 }
ram54288 0:dbad57390bd1 801 else {
ram54288 0:dbad57390bd1 802 _observer.value_updated(base);
ram54288 0:dbad57390bd1 803 }
ram54288 0:dbad57390bd1 804 }
ram54288 0:dbad57390bd1 805
ram54288 0:dbad57390bd1 806 void M2MNsdlInterface::remove_object(M2MBase *object)
ram54288 0:dbad57390bd1 807 {
ram54288 0:dbad57390bd1 808 __mutex_claim();
ram54288 0:dbad57390bd1 809 tr_debug("M2MNsdlInterface::remove_object()");
ram54288 0:dbad57390bd1 810 M2MObject* rem_object = static_cast<M2MObject*> (object);
ram54288 0:dbad57390bd1 811 if(rem_object && !_object_list.empty()) {
ram54288 0:dbad57390bd1 812 M2MObjectList::const_iterator it;
ram54288 0:dbad57390bd1 813 it = _object_list.begin();
ram54288 0:dbad57390bd1 814 int index = 0;
ram54288 0:dbad57390bd1 815 for ( ; it != _object_list.end(); it++, index++ ) {
ram54288 0:dbad57390bd1 816 if((*it) == rem_object) {
ram54288 0:dbad57390bd1 817 _object_list.erase(index);
ram54288 0:dbad57390bd1 818 break;
ram54288 0:dbad57390bd1 819 }
ram54288 0:dbad57390bd1 820 }
ram54288 0:dbad57390bd1 821 }
ram54288 0:dbad57390bd1 822 if(_object_list.empty()) {
ram54288 0:dbad57390bd1 823 _object_list.clear();
ram54288 0:dbad57390bd1 824 }
ram54288 0:dbad57390bd1 825 __mutex_release();
ram54288 0:dbad57390bd1 826 }
ram54288 0:dbad57390bd1 827
ram54288 0:dbad57390bd1 828 bool M2MNsdlInterface::create_nsdl_object_structure(M2MObject *object)
ram54288 0:dbad57390bd1 829 {
ram54288 0:dbad57390bd1 830 tr_debug("M2MNsdlInterface::create_nsdl_object_structure()");
ram54288 0:dbad57390bd1 831 bool success = false;
ram54288 0:dbad57390bd1 832 if(object) {
ram54288 0:dbad57390bd1 833 M2MObjectInstanceList instance_list = object->instances();
ram54288 0:dbad57390bd1 834 tr_debug("M2MNsdlInterface::create_nsdl_object_structure - Object Instance count %d", instance_list.size());
ram54288 0:dbad57390bd1 835 if(!instance_list.empty()) {
ram54288 0:dbad57390bd1 836 M2MObjectInstanceList::const_iterator it;
ram54288 0:dbad57390bd1 837 it = instance_list.begin();
ram54288 0:dbad57390bd1 838 for ( ; it != instance_list.end(); it++ ) {
ram54288 0:dbad57390bd1 839 // Create NSDL structure for all object instances inside
ram54288 0:dbad57390bd1 840 success = create_nsdl_object_instance_structure(*it);
ram54288 0:dbad57390bd1 841 }
ram54288 0:dbad57390bd1 842 }
ram54288 0:dbad57390bd1 843 }
ram54288 0:dbad57390bd1 844 if(object && object->operation() != M2MBase::NOT_ALLOWED) {
ram54288 0:dbad57390bd1 845 success = create_nsdl_resource(object);
ram54288 0:dbad57390bd1 846 }
ram54288 0:dbad57390bd1 847 return success;
ram54288 0:dbad57390bd1 848 }
ram54288 0:dbad57390bd1 849
ram54288 0:dbad57390bd1 850 bool M2MNsdlInterface::create_nsdl_object_instance_structure(M2MObjectInstance *object_instance)
ram54288 0:dbad57390bd1 851 {
ram54288 0:dbad57390bd1 852 tr_debug("M2MNsdlInterface::create_nsdl_object_instance_structure()");
ram54288 0:dbad57390bd1 853 bool success = false;
ram54288 0:dbad57390bd1 854 if( object_instance) {
ram54288 0:dbad57390bd1 855 M2MResourceList res_list = object_instance->resources();
ram54288 0:dbad57390bd1 856 tr_debug("M2MNsdlInterface::create_nsdl_object_instance_structure - ResourceBase count %d", res_list.size());
ram54288 0:dbad57390bd1 857 if(!res_list.empty()) {
ram54288 0:dbad57390bd1 858 M2MResourceList::const_iterator it;
ram54288 0:dbad57390bd1 859 it = res_list.begin();
ram54288 0:dbad57390bd1 860 for ( ; it != res_list.end(); it++ ) {
ram54288 0:dbad57390bd1 861 // Create NSDL structure for all resources inside
ram54288 0:dbad57390bd1 862 success = create_nsdl_resource_structure(*it,
ram54288 0:dbad57390bd1 863 (*it)->supports_multiple_instances());
ram54288 0:dbad57390bd1 864 }
ram54288 0:dbad57390bd1 865 }
ram54288 0:dbad57390bd1 866 if(object_instance->operation() != M2MBase::NOT_ALLOWED) {
ram54288 0:dbad57390bd1 867 success = create_nsdl_resource(object_instance);
ram54288 0:dbad57390bd1 868 }
ram54288 0:dbad57390bd1 869 }
ram54288 0:dbad57390bd1 870 return success;
ram54288 0:dbad57390bd1 871 }
ram54288 0:dbad57390bd1 872
ram54288 0:dbad57390bd1 873 bool M2MNsdlInterface::create_nsdl_resource_structure(M2MResource *res,
ram54288 0:dbad57390bd1 874 bool multiple_instances)
ram54288 0:dbad57390bd1 875 {
ram54288 0:dbad57390bd1 876 tr_debug("M2MNsdlInterface::create_nsdl_resource_structure()");
ram54288 0:dbad57390bd1 877 bool success = false;
ram54288 0:dbad57390bd1 878 if(res) {
ram54288 0:dbad57390bd1 879 // if there are multiple instances supported
ram54288 0:dbad57390bd1 880 if(multiple_instances) {
ram54288 0:dbad57390bd1 881 M2MResourceInstanceList res_list = res->resource_instances();
ram54288 0:dbad57390bd1 882 tr_debug("M2MNsdlInterface::create_nsdl_resource_structure - ResourceInstance count %d", res_list.size());
ram54288 0:dbad57390bd1 883 if(!res_list.empty()) {
ram54288 0:dbad57390bd1 884 M2MResourceInstanceList::const_iterator it;
ram54288 0:dbad57390bd1 885 it = res_list.begin();
ram54288 0:dbad57390bd1 886 for ( ; it != res_list.end(); it++ ) {
ram54288 0:dbad57390bd1 887 success = create_nsdl_resource((*it));
ram54288 0:dbad57390bd1 888 if(!success) {
ram54288 0:dbad57390bd1 889 tr_error("M2MNsdlInterface::create_nsdl_resource_structure - instance creation failed");
ram54288 0:dbad57390bd1 890 return false;
ram54288 0:dbad57390bd1 891 }
ram54288 0:dbad57390bd1 892 }
ram54288 0:dbad57390bd1 893 // Register the main Resource as well along with ResourceInstances
ram54288 0:dbad57390bd1 894 success = create_nsdl_resource(res);
ram54288 0:dbad57390bd1 895 }
ram54288 0:dbad57390bd1 896 } else {
ram54288 0:dbad57390bd1 897 success = create_nsdl_resource(res);
ram54288 0:dbad57390bd1 898 }
ram54288 0:dbad57390bd1 899 }
ram54288 0:dbad57390bd1 900 return success;
ram54288 0:dbad57390bd1 901 }
ram54288 0:dbad57390bd1 902
ram54288 0:dbad57390bd1 903 bool M2MNsdlInterface::create_nsdl_resource(M2MBase *base)
ram54288 0:dbad57390bd1 904 {
ram54288 0:dbad57390bd1 905 __mutex_claim();
ram54288 0:dbad57390bd1 906 tr_debug("M2MNsdlInterface::create_nsdl_resource");
ram54288 0:dbad57390bd1 907 bool success = false;
ram54288 0:dbad57390bd1 908 if(base) {
ram54288 0:dbad57390bd1 909 int8_t result = 0;
ram54288 0:dbad57390bd1 910 sn_nsdl_dynamic_resource_parameters_s* orig_resource = base->get_nsdl_resource();
ram54288 0:dbad57390bd1 911 tr_debug("M2MNsdlInterface::create_nsdl_resource - path (%.*s)", orig_resource->static_resource_parameters->pathlen,
ram54288 0:dbad57390bd1 912 orig_resource->static_resource_parameters->path);
ram54288 0:dbad57390bd1 913
ram54288 0:dbad57390bd1 914 // needed on deletion
ram54288 0:dbad57390bd1 915 if (base->observation_handler() == NULL) {
ram54288 0:dbad57390bd1 916 base->set_observation_handler(this);
ram54288 0:dbad57390bd1 917 }
ram54288 0:dbad57390bd1 918
ram54288 0:dbad57390bd1 919 result = sn_nsdl_put_resource(_nsdl_handle, orig_resource);
ram54288 0:dbad57390bd1 920 tr_debug("M2MNsdlInterface::create_nsdl_resource - Creating in NSDL-C result %d", result);
ram54288 0:dbad57390bd1 921
ram54288 0:dbad57390bd1 922 // Either the resource is created or it already
ram54288 0:dbad57390bd1 923 // exists , then result is success.
ram54288 0:dbad57390bd1 924 if (result == 0 ||
ram54288 0:dbad57390bd1 925 result == -2){
ram54288 0:dbad57390bd1 926 success = true;
ram54288 0:dbad57390bd1 927 }
ram54288 0:dbad57390bd1 928 }
ram54288 0:dbad57390bd1 929 __mutex_release();
ram54288 0:dbad57390bd1 930 return success;
ram54288 0:dbad57390bd1 931 }
ram54288 0:dbad57390bd1 932
ram54288 0:dbad57390bd1 933 // convenience method to get the URI from its buffer field...
ram54288 0:dbad57390bd1 934 String M2MNsdlInterface::coap_to_string(uint8_t *coap_data,int coap_data_length)
ram54288 0:dbad57390bd1 935 {
ram54288 0:dbad57390bd1 936 String value = "";
ram54288 0:dbad57390bd1 937 if (coap_data != NULL && coap_data_length > 0) {
ram54288 0:dbad57390bd1 938 value.append_raw((char *)coap_data,coap_data_length);
ram54288 0:dbad57390bd1 939 }
ram54288 0:dbad57390bd1 940 return value;
ram54288 0:dbad57390bd1 941 }
ram54288 0:dbad57390bd1 942
ram54288 0:dbad57390bd1 943 uint64_t M2MNsdlInterface::registration_time()
ram54288 0:dbad57390bd1 944 {
ram54288 0:dbad57390bd1 945 uint64_t value = 0;
ram54288 0:dbad57390bd1 946 if(_endpoint && _endpoint->lifetime_ptr) {
ram54288 0:dbad57390bd1 947 value = atol((const char*)_endpoint->lifetime_ptr);
ram54288 0:dbad57390bd1 948 }
ram54288 0:dbad57390bd1 949
ram54288 0:dbad57390bd1 950 if(value >= OPTIMUM_LIFETIME) {
ram54288 0:dbad57390bd1 951 value = value - REDUCE_LIFETIME;
ram54288 0:dbad57390bd1 952 } else {
ram54288 0:dbad57390bd1 953 value = REDUCTION_FACTOR * value;
ram54288 0:dbad57390bd1 954 }
ram54288 0:dbad57390bd1 955 tr_debug("M2MNsdlInterface::registration_time - value (in seconds) %ld", value);
ram54288 0:dbad57390bd1 956 return value;
ram54288 0:dbad57390bd1 957 }
ram54288 0:dbad57390bd1 958
ram54288 0:dbad57390bd1 959 M2MBase* M2MNsdlInterface::find_resource(const String &object_name,
ram54288 0:dbad57390bd1 960 uint8_t *token,
ram54288 0:dbad57390bd1 961 uint8_t token_len)
ram54288 0:dbad57390bd1 962 {
ram54288 0:dbad57390bd1 963 tr_debug("M2MNsdlInterface::find_resource(object level) - name (%s)", object_name.c_str());
ram54288 0:dbad57390bd1 964 tr_debug("M2MNsdlInterface::find_resource - token (%.*s)", token_len, token);
ram54288 0:dbad57390bd1 965 M2MBase *object = NULL;
ram54288 0:dbad57390bd1 966 if(!_object_list.empty()) {
ram54288 0:dbad57390bd1 967 M2MObjectList::const_iterator it;
ram54288 0:dbad57390bd1 968 it = _object_list.begin();
ram54288 0:dbad57390bd1 969 for ( ; it != _object_list.end(); it++ ) {
ram54288 0:dbad57390bd1 970 if (token_len == 0) {
ram54288 0:dbad57390bd1 971 tr_debug("M2MNsdlInterface::find_resource(object level) - path (%s)",
ram54288 0:dbad57390bd1 972 (char*)(*it)->uri_path());
ram54288 0:dbad57390bd1 973 if (strcmp((char*)(*it)->uri_path(), object_name.c_str()) == 0) {
ram54288 0:dbad57390bd1 974 object = (*it);
ram54288 0:dbad57390bd1 975 tr_debug("M2MNsdlInterface::find_resource(%s) found", object_name.c_str());
ram54288 0:dbad57390bd1 976 break;
ram54288 0:dbad57390bd1 977 }
ram54288 0:dbad57390bd1 978 } else {
ram54288 0:dbad57390bd1 979 uint8_t *stored_token = 0;
ram54288 0:dbad57390bd1 980 uint32_t stored_token_length = 0;
ram54288 0:dbad57390bd1 981 (*it)->get_observation_token(stored_token, stored_token_length);
ram54288 0:dbad57390bd1 982 tr_debug("M2MNsdlInterface::find_resource(object level) - stored token (%.*s)", stored_token_length, stored_token);
ram54288 0:dbad57390bd1 983 if (stored_token) {
ram54288 0:dbad57390bd1 984 if (stored_token_length == token_len &&
ram54288 0:dbad57390bd1 985 memcmp(token, stored_token, token_len) == 0) {
ram54288 0:dbad57390bd1 986 object = (*it);
ram54288 0:dbad57390bd1 987 tr_debug("M2MNsdlInterface::find_resource - token found");
ram54288 0:dbad57390bd1 988 free(stored_token);
ram54288 0:dbad57390bd1 989 break;
ram54288 0:dbad57390bd1 990 } else {
ram54288 0:dbad57390bd1 991 free(stored_token);
ram54288 0:dbad57390bd1 992 }
ram54288 0:dbad57390bd1 993 }
ram54288 0:dbad57390bd1 994 }
ram54288 0:dbad57390bd1 995 object = find_resource((*it), object_name, token, token_len);
ram54288 0:dbad57390bd1 996 if(object != NULL) {
ram54288 0:dbad57390bd1 997 break;
ram54288 0:dbad57390bd1 998 }
ram54288 0:dbad57390bd1 999 }
ram54288 0:dbad57390bd1 1000 }
ram54288 0:dbad57390bd1 1001 return object;
ram54288 0:dbad57390bd1 1002 }
ram54288 0:dbad57390bd1 1003
ram54288 0:dbad57390bd1 1004 M2MBase* M2MNsdlInterface::find_resource(const M2MObject *object,
ram54288 0:dbad57390bd1 1005 const String &object_instance,
ram54288 0:dbad57390bd1 1006 uint8_t *token,
ram54288 0:dbad57390bd1 1007 uint8_t token_len)
ram54288 0:dbad57390bd1 1008 {
ram54288 0:dbad57390bd1 1009 tr_debug("M2MNsdlInterface::find_resource(object instance level) - name (%s)", object_instance.c_str());
ram54288 0:dbad57390bd1 1010 M2MBase *instance = NULL;
ram54288 0:dbad57390bd1 1011 if(object) {
ram54288 0:dbad57390bd1 1012 M2MObjectInstanceList list = object->instances();
ram54288 0:dbad57390bd1 1013 if(!list.empty()) {
ram54288 0:dbad57390bd1 1014 M2MObjectInstanceList::const_iterator it;
ram54288 0:dbad57390bd1 1015 it = list.begin();
ram54288 0:dbad57390bd1 1016 for ( ; it != list.end(); it++ ) {
ram54288 0:dbad57390bd1 1017 if (!token) {
ram54288 0:dbad57390bd1 1018 tr_debug("M2MNsdlInterface::find_resource(object instance level) - path (%s)",
ram54288 0:dbad57390bd1 1019 (char*)(*it)->uri_path());
ram54288 0:dbad57390bd1 1020 if(!strcmp((char*)(*it)->uri_path(), object_instance.c_str())){
ram54288 0:dbad57390bd1 1021 instance = (*it);
ram54288 0:dbad57390bd1 1022 break;
ram54288 0:dbad57390bd1 1023 }
ram54288 0:dbad57390bd1 1024 } else {
ram54288 0:dbad57390bd1 1025 uint8_t *stored_token = 0;
ram54288 0:dbad57390bd1 1026 uint32_t stored_token_length = 0;
ram54288 0:dbad57390bd1 1027 tr_debug("M2MNsdlInterface::find_resource(object instance level) - in token (%.*s)", token_len, token);
ram54288 0:dbad57390bd1 1028 (*it)->get_observation_token(stored_token, stored_token_length);
ram54288 0:dbad57390bd1 1029 tr_debug("M2MNsdlInterface::find_resource(object instance level) - stored token (%.*s)", stored_token_length, stored_token);
ram54288 0:dbad57390bd1 1030 if (stored_token) {
ram54288 0:dbad57390bd1 1031 if (stored_token_length == token_len &&
ram54288 0:dbad57390bd1 1032 memcmp(token, stored_token, token_len) == 0) {
ram54288 0:dbad57390bd1 1033 instance = (*it);
ram54288 0:dbad57390bd1 1034 free(stored_token);
ram54288 0:dbad57390bd1 1035 break;
ram54288 0:dbad57390bd1 1036 } else {
ram54288 0:dbad57390bd1 1037 free(stored_token);
ram54288 0:dbad57390bd1 1038 }
ram54288 0:dbad57390bd1 1039 }
ram54288 0:dbad57390bd1 1040 }
ram54288 0:dbad57390bd1 1041 instance = find_resource((*it),object_instance, token, token_len);
ram54288 0:dbad57390bd1 1042 if(instance != NULL){
ram54288 0:dbad57390bd1 1043 break;
ram54288 0:dbad57390bd1 1044 }
ram54288 0:dbad57390bd1 1045 }
ram54288 0:dbad57390bd1 1046 }
ram54288 0:dbad57390bd1 1047 }
ram54288 0:dbad57390bd1 1048 return instance;
ram54288 0:dbad57390bd1 1049 }
ram54288 0:dbad57390bd1 1050
ram54288 0:dbad57390bd1 1051 M2MBase* M2MNsdlInterface::find_resource(const M2MObjectInstance *object_instance,
ram54288 0:dbad57390bd1 1052 const String &resource_instance,
ram54288 0:dbad57390bd1 1053 uint8_t *token,
ram54288 0:dbad57390bd1 1054 uint8_t token_len)
ram54288 0:dbad57390bd1 1055 {
ram54288 0:dbad57390bd1 1056 tr_debug("M2MNsdlInterface::find_resource(resource level) - name (%s)", resource_instance.c_str());
ram54288 0:dbad57390bd1 1057 M2MBase *instance = NULL;
ram54288 0:dbad57390bd1 1058 if(object_instance) {
ram54288 0:dbad57390bd1 1059 M2MResourceList list = object_instance->resources();
ram54288 0:dbad57390bd1 1060 if(!list.empty()) {
ram54288 0:dbad57390bd1 1061 M2MResourceList::const_iterator it;
ram54288 0:dbad57390bd1 1062 it = list.begin();
ram54288 0:dbad57390bd1 1063 for ( ; it != list.end(); it++ ) {
ram54288 0:dbad57390bd1 1064 if (!token) {
ram54288 0:dbad57390bd1 1065 if(!strcmp((char*)(*it)->uri_path(), resource_instance.c_str())) {
ram54288 0:dbad57390bd1 1066 instance = *it;
ram54288 0:dbad57390bd1 1067 break;
ram54288 0:dbad57390bd1 1068 }
ram54288 0:dbad57390bd1 1069 else if((*it)->supports_multiple_instances()) {
ram54288 0:dbad57390bd1 1070 instance = find_resource((*it), (*it)->uri_path(),
ram54288 0:dbad57390bd1 1071 resource_instance, token, token_len);
ram54288 0:dbad57390bd1 1072 if(instance != NULL){
ram54288 0:dbad57390bd1 1073 break;
ram54288 0:dbad57390bd1 1074 }
ram54288 0:dbad57390bd1 1075 }
ram54288 0:dbad57390bd1 1076 } else {
ram54288 0:dbad57390bd1 1077 uint8_t *stored_token = 0;
ram54288 0:dbad57390bd1 1078 uint32_t stored_token_length = 0;
ram54288 0:dbad57390bd1 1079 tr_debug("M2MNsdlInterface::find_resource(resource level) - in token (%.*s)", token_len, token);
ram54288 0:dbad57390bd1 1080 (*it)->get_observation_token(stored_token, stored_token_length);
ram54288 0:dbad57390bd1 1081 tr_debug("M2MNsdlInterface::find_resource(resource level) - stored token (%.*s)", stored_token_length, stored_token);
ram54288 0:dbad57390bd1 1082 if (stored_token) {
ram54288 0:dbad57390bd1 1083 if (stored_token_length == token_len &&
ram54288 0:dbad57390bd1 1084 memcmp(token, stored_token, token_len) == 0) {
ram54288 0:dbad57390bd1 1085 instance = *it;
ram54288 0:dbad57390bd1 1086 free(stored_token);
ram54288 0:dbad57390bd1 1087 break;
ram54288 0:dbad57390bd1 1088 } else {
ram54288 0:dbad57390bd1 1089 free(stored_token);
ram54288 0:dbad57390bd1 1090 }
ram54288 0:dbad57390bd1 1091 }
ram54288 0:dbad57390bd1 1092 }
ram54288 0:dbad57390bd1 1093 }
ram54288 0:dbad57390bd1 1094 }
ram54288 0:dbad57390bd1 1095 }
ram54288 0:dbad57390bd1 1096 return instance;
ram54288 0:dbad57390bd1 1097 }
ram54288 0:dbad57390bd1 1098
ram54288 0:dbad57390bd1 1099 M2MBase* M2MNsdlInterface::find_resource(const M2MResource *resource,
ram54288 0:dbad57390bd1 1100 const String &object_name,
ram54288 0:dbad57390bd1 1101 const String &resource_instance,
ram54288 0:dbad57390bd1 1102 uint8_t */*token*/,
ram54288 0:dbad57390bd1 1103 uint8_t /*token_len*/)
ram54288 0:dbad57390bd1 1104 {
ram54288 0:dbad57390bd1 1105 tr_debug("M2MNsdlInterface::find_resource(resource instance level)");
ram54288 0:dbad57390bd1 1106 M2MBase *res = NULL;
ram54288 0:dbad57390bd1 1107 if(resource) {
ram54288 0:dbad57390bd1 1108 if(resource->supports_multiple_instances()) {
ram54288 0:dbad57390bd1 1109 M2MResourceInstanceList list = resource->resource_instances();
ram54288 0:dbad57390bd1 1110 if(!list.empty()) {
ram54288 0:dbad57390bd1 1111 M2MResourceInstanceList::const_iterator it;
ram54288 0:dbad57390bd1 1112 it = list.begin();
ram54288 0:dbad57390bd1 1113 for ( ; it != list.end(); it++ ) {
ram54288 0:dbad57390bd1 1114 if(!strcmp((char*)(*it)->uri_path(), resource_instance.c_str())){
ram54288 0:dbad57390bd1 1115 res = (*it);
ram54288 0:dbad57390bd1 1116 break;
ram54288 0:dbad57390bd1 1117 }
ram54288 0:dbad57390bd1 1118 }
ram54288 0:dbad57390bd1 1119 }
ram54288 0:dbad57390bd1 1120 }
ram54288 0:dbad57390bd1 1121 }
ram54288 0:dbad57390bd1 1122 return res;
ram54288 0:dbad57390bd1 1123 }
ram54288 0:dbad57390bd1 1124
ram54288 0:dbad57390bd1 1125 bool M2MNsdlInterface::object_present(M2MObject* object) const
ram54288 0:dbad57390bd1 1126 {
ram54288 0:dbad57390bd1 1127 bool success = false;
ram54288 0:dbad57390bd1 1128 if(object && !_object_list.empty()) {
ram54288 0:dbad57390bd1 1129 M2MObjectList::const_iterator it;
ram54288 0:dbad57390bd1 1130 it = _object_list.begin();
ram54288 0:dbad57390bd1 1131 for ( ; it != _object_list.end(); it++ ) {
ram54288 0:dbad57390bd1 1132 if((*it) == object) {
ram54288 0:dbad57390bd1 1133 success = true;
ram54288 0:dbad57390bd1 1134 break;
ram54288 0:dbad57390bd1 1135 }
ram54288 0:dbad57390bd1 1136 }
ram54288 0:dbad57390bd1 1137 }
ram54288 0:dbad57390bd1 1138 return success;
ram54288 0:dbad57390bd1 1139 }
ram54288 0:dbad57390bd1 1140
ram54288 0:dbad57390bd1 1141 bool M2MNsdlInterface::add_object_to_list(M2MObject* object)
ram54288 0:dbad57390bd1 1142 {
ram54288 0:dbad57390bd1 1143 bool success = false;
ram54288 0:dbad57390bd1 1144 if(object && !object_present(object)) {
ram54288 0:dbad57390bd1 1145 _object_list.push_back(object);
ram54288 0:dbad57390bd1 1146 success = true;
ram54288 0:dbad57390bd1 1147 }
ram54288 0:dbad57390bd1 1148 return success;
ram54288 0:dbad57390bd1 1149 }
ram54288 0:dbad57390bd1 1150
ram54288 0:dbad57390bd1 1151 M2MInterface::Error M2MNsdlInterface::interface_error(sn_coap_hdr_s *coap_header)
ram54288 0:dbad57390bd1 1152 {
ram54288 0:dbad57390bd1 1153 M2MInterface::Error error = M2MInterface::ErrorNone;
ram54288 0:dbad57390bd1 1154 if(coap_header) {
ram54288 0:dbad57390bd1 1155 switch(coap_header->msg_code) {
ram54288 0:dbad57390bd1 1156 case COAP_MSG_CODE_RESPONSE_BAD_REQUEST:
ram54288 0:dbad57390bd1 1157 case COAP_MSG_CODE_RESPONSE_BAD_OPTION:
ram54288 0:dbad57390bd1 1158 case COAP_MSG_CODE_RESPONSE_REQUEST_ENTITY_INCOMPLETE:
ram54288 0:dbad57390bd1 1159 case COAP_MSG_CODE_RESPONSE_PRECONDITION_FAILED:
ram54288 0:dbad57390bd1 1160 case COAP_MSG_CODE_RESPONSE_REQUEST_ENTITY_TOO_LARGE:
ram54288 0:dbad57390bd1 1161 case COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT:
ram54288 0:dbad57390bd1 1162 error = M2MInterface::InvalidParameters;
ram54288 0:dbad57390bd1 1163 break;
ram54288 0:dbad57390bd1 1164 case COAP_MSG_CODE_RESPONSE_UNAUTHORIZED:
ram54288 0:dbad57390bd1 1165 case COAP_MSG_CODE_RESPONSE_FORBIDDEN:
ram54288 0:dbad57390bd1 1166 case COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE:
ram54288 0:dbad57390bd1 1167 case COAP_MSG_CODE_RESPONSE_NOT_FOUND:
ram54288 0:dbad57390bd1 1168 case COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED:
ram54288 0:dbad57390bd1 1169 error = M2MInterface::NotAllowed;
ram54288 0:dbad57390bd1 1170 break;
ram54288 0:dbad57390bd1 1171 case COAP_MSG_CODE_RESPONSE_CREATED:
ram54288 0:dbad57390bd1 1172 case COAP_MSG_CODE_RESPONSE_DELETED:
ram54288 0:dbad57390bd1 1173 case COAP_MSG_CODE_RESPONSE_VALID:
ram54288 0:dbad57390bd1 1174 case COAP_MSG_CODE_RESPONSE_CHANGED:
ram54288 0:dbad57390bd1 1175 case COAP_MSG_CODE_RESPONSE_CONTENT:
ram54288 0:dbad57390bd1 1176 error = M2MInterface::ErrorNone;
ram54288 0:dbad57390bd1 1177 break;
ram54288 0:dbad57390bd1 1178 default:
ram54288 0:dbad57390bd1 1179 error = M2MInterface::UnknownError;
ram54288 0:dbad57390bd1 1180 break;
ram54288 0:dbad57390bd1 1181 }
ram54288 0:dbad57390bd1 1182 if(coap_header->coap_status == COAP_STATUS_BUILDER_MESSAGE_SENDING_FAILED) {
ram54288 0:dbad57390bd1 1183 error = M2MInterface::NetworkError;
ram54288 0:dbad57390bd1 1184 }
ram54288 0:dbad57390bd1 1185 }
ram54288 0:dbad57390bd1 1186 return error;
ram54288 0:dbad57390bd1 1187 }
ram54288 0:dbad57390bd1 1188
ram54288 0:dbad57390bd1 1189 void M2MNsdlInterface::send_object_observation(M2MObject *object,
ram54288 0:dbad57390bd1 1190 uint16_t obs_number,
ram54288 0:dbad57390bd1 1191 m2m::Vector<uint16_t> changed_instance_ids,
ram54288 0:dbad57390bd1 1192 bool send_object)
ram54288 0:dbad57390bd1 1193 {
ram54288 0:dbad57390bd1 1194 tr_debug("M2MNsdlInterface::send_object_observation");
ram54288 0:dbad57390bd1 1195 if(object) {
ram54288 0:dbad57390bd1 1196 uint8_t *value = 0;
ram54288 0:dbad57390bd1 1197 uint32_t length = 0;
ram54288 0:dbad57390bd1 1198 uint8_t *token = 0;
ram54288 0:dbad57390bd1 1199 uint32_t token_length = 0;
ram54288 0:dbad57390bd1 1200
ram54288 0:dbad57390bd1 1201 M2MTLVSerializer serializer;
ram54288 0:dbad57390bd1 1202 // Send whole object structure
ram54288 0:dbad57390bd1 1203 if (send_object) {
ram54288 0:dbad57390bd1 1204 value = serializer.serialize(object->instances(), length);
ram54288 0:dbad57390bd1 1205 }
ram54288 0:dbad57390bd1 1206 // Send only changed object instances
ram54288 0:dbad57390bd1 1207 else {
ram54288 0:dbad57390bd1 1208 M2MObjectInstanceList list;
ram54288 0:dbad57390bd1 1209 Vector<uint16_t>::const_iterator it;
ram54288 0:dbad57390bd1 1210 it = changed_instance_ids.begin();
ram54288 0:dbad57390bd1 1211 for (; it != changed_instance_ids.end(); it++){
ram54288 0:dbad57390bd1 1212 M2MObjectInstance* obj_instance = object->object_instance(*it);
ram54288 0:dbad57390bd1 1213 if (obj_instance){
ram54288 0:dbad57390bd1 1214 list.push_back(obj_instance);
ram54288 0:dbad57390bd1 1215 }
ram54288 0:dbad57390bd1 1216 }
ram54288 0:dbad57390bd1 1217 if (!list.empty()) {
ram54288 0:dbad57390bd1 1218 value = serializer.serialize(list, length);
ram54288 0:dbad57390bd1 1219 list.clear();
ram54288 0:dbad57390bd1 1220 }
ram54288 0:dbad57390bd1 1221 }
ram54288 0:dbad57390bd1 1222
ram54288 0:dbad57390bd1 1223 object->get_observation_token(token,token_length);
ram54288 0:dbad57390bd1 1224
ram54288 0:dbad57390bd1 1225 send_notification(token,
ram54288 0:dbad57390bd1 1226 token_length,
ram54288 0:dbad57390bd1 1227 value,
ram54288 0:dbad57390bd1 1228 length,
ram54288 0:dbad57390bd1 1229 obs_number,
ram54288 0:dbad57390bd1 1230 object->max_age(),
ram54288 0:dbad57390bd1 1231 object->coap_content_type());
ram54288 0:dbad57390bd1 1232 memory_free(value);
ram54288 0:dbad57390bd1 1233 memory_free(token);
ram54288 0:dbad57390bd1 1234 }
ram54288 0:dbad57390bd1 1235 }
ram54288 0:dbad57390bd1 1236
ram54288 0:dbad57390bd1 1237 void M2MNsdlInterface::send_object_instance_observation(M2MObjectInstance *object_instance,
ram54288 0:dbad57390bd1 1238 uint16_t obs_number)
ram54288 0:dbad57390bd1 1239 {
ram54288 0:dbad57390bd1 1240 tr_debug("M2MNsdlInterface::send_object_instance_observation");
ram54288 0:dbad57390bd1 1241 if(object_instance) {
ram54288 0:dbad57390bd1 1242 uint8_t *value = 0;
ram54288 0:dbad57390bd1 1243 uint32_t length = 0;
ram54288 0:dbad57390bd1 1244 uint8_t *token = 0;
ram54288 0:dbad57390bd1 1245 uint32_t token_length = 0;
ram54288 0:dbad57390bd1 1246
ram54288 0:dbad57390bd1 1247 M2MTLVSerializer serializer;
ram54288 0:dbad57390bd1 1248 value = serializer.serialize(object_instance->resources(), length);
ram54288 0:dbad57390bd1 1249
ram54288 0:dbad57390bd1 1250 object_instance->get_observation_token(token,token_length);
ram54288 0:dbad57390bd1 1251
ram54288 0:dbad57390bd1 1252 send_notification(token,
ram54288 0:dbad57390bd1 1253 token_length,
ram54288 0:dbad57390bd1 1254 value,
ram54288 0:dbad57390bd1 1255 length,
ram54288 0:dbad57390bd1 1256 obs_number,
ram54288 0:dbad57390bd1 1257 object_instance->max_age(),
ram54288 0:dbad57390bd1 1258 object_instance->coap_content_type());
ram54288 0:dbad57390bd1 1259 memory_free(value);
ram54288 0:dbad57390bd1 1260 memory_free(token);
ram54288 0:dbad57390bd1 1261 }
ram54288 0:dbad57390bd1 1262 }
ram54288 0:dbad57390bd1 1263
ram54288 0:dbad57390bd1 1264 void M2MNsdlInterface::send_resource_observation(M2MResource *resource,
ram54288 0:dbad57390bd1 1265 uint16_t obs_number)
ram54288 0:dbad57390bd1 1266 {
ram54288 0:dbad57390bd1 1267 tr_debug("M2MNsdlInterface::send_resource_observation");
ram54288 0:dbad57390bd1 1268 if(resource) {
ram54288 0:dbad57390bd1 1269 uint8_t *value = 0;
ram54288 0:dbad57390bd1 1270 uint32_t length = 0;
ram54288 0:dbad57390bd1 1271 uint8_t *token = 0;
ram54288 0:dbad57390bd1 1272 uint32_t token_length = 0;
ram54288 0:dbad57390bd1 1273
ram54288 0:dbad57390bd1 1274 resource->get_observation_token(token,token_length);
ram54288 0:dbad57390bd1 1275 uint8_t content_type = 0;
ram54288 0:dbad57390bd1 1276 if(M2MResourceInstance::OPAQUE == resource->resource_instance_type()) {
ram54288 0:dbad57390bd1 1277 content_type = COAP_CONTENT_OMA_OPAQUE_TYPE;
ram54288 0:dbad57390bd1 1278 }
ram54288 0:dbad57390bd1 1279 if (resource->resource_instance_count() > 0) {
ram54288 0:dbad57390bd1 1280 content_type = COAP_CONTENT_OMA_TLV_TYPE;
ram54288 0:dbad57390bd1 1281 M2MTLVSerializer serializer;
ram54288 0:dbad57390bd1 1282 value = serializer.serialize(resource, length);
ram54288 0:dbad57390bd1 1283 } else {
ram54288 0:dbad57390bd1 1284 resource->get_value(value,length);
ram54288 0:dbad57390bd1 1285 }
ram54288 0:dbad57390bd1 1286 send_notification(token,
ram54288 0:dbad57390bd1 1287 token_length,
ram54288 0:dbad57390bd1 1288 value,
ram54288 0:dbad57390bd1 1289 length,
ram54288 0:dbad57390bd1 1290 obs_number,
ram54288 0:dbad57390bd1 1291 resource->max_age(),
ram54288 0:dbad57390bd1 1292 content_type);
ram54288 0:dbad57390bd1 1293
ram54288 0:dbad57390bd1 1294 memory_free(value);
ram54288 0:dbad57390bd1 1295 memory_free(token);
ram54288 0:dbad57390bd1 1296 }
ram54288 0:dbad57390bd1 1297 }
ram54288 0:dbad57390bd1 1298
ram54288 0:dbad57390bd1 1299 void M2MNsdlInterface::send_notification(uint8_t *token,
ram54288 0:dbad57390bd1 1300 uint8_t token_length,
ram54288 0:dbad57390bd1 1301 uint8_t *value,
ram54288 0:dbad57390bd1 1302 uint32_t value_length,
ram54288 0:dbad57390bd1 1303 uint16_t observation,
ram54288 0:dbad57390bd1 1304 uint32_t max_age,
ram54288 0:dbad57390bd1 1305 uint8_t coap_content_type)
ram54288 0:dbad57390bd1 1306
ram54288 0:dbad57390bd1 1307 {
ram54288 0:dbad57390bd1 1308 tr_debug("M2MNsdlInterface::send_notification");
ram54288 0:dbad57390bd1 1309 sn_coap_hdr_s *notification_message_ptr;
ram54288 0:dbad57390bd1 1310
ram54288 0:dbad57390bd1 1311 /* Allocate and initialize memory for header struct */
ram54288 0:dbad57390bd1 1312 notification_message_ptr = static_cast<sn_coap_hdr_s *>(memory_alloc(sizeof(sn_coap_hdr_s)));
ram54288 0:dbad57390bd1 1313 if (notification_message_ptr) {
ram54288 0:dbad57390bd1 1314 memset(notification_message_ptr, 0, sizeof(sn_coap_hdr_s));
ram54288 0:dbad57390bd1 1315
ram54288 0:dbad57390bd1 1316 notification_message_ptr->options_list_ptr = sn_nsdl_alloc_options_list(_nsdl_handle, notification_message_ptr);
ram54288 0:dbad57390bd1 1317 if (notification_message_ptr->options_list_ptr) {
ram54288 0:dbad57390bd1 1318 /* Fill header */
ram54288 0:dbad57390bd1 1319 notification_message_ptr->msg_type = COAP_MSG_TYPE_CONFIRMABLE;
ram54288 0:dbad57390bd1 1320 notification_message_ptr->msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
ram54288 0:dbad57390bd1 1321
ram54288 0:dbad57390bd1 1322 /* Fill token */
ram54288 0:dbad57390bd1 1323 notification_message_ptr->token_len = token_length;
ram54288 0:dbad57390bd1 1324 notification_message_ptr->token_ptr = token;
ram54288 0:dbad57390bd1 1325
ram54288 0:dbad57390bd1 1326 /* Fill payload */
ram54288 0:dbad57390bd1 1327 notification_message_ptr->payload_len = value_length;
ram54288 0:dbad57390bd1 1328 notification_message_ptr->payload_ptr = value;
ram54288 0:dbad57390bd1 1329
ram54288 0:dbad57390bd1 1330 /* Fill observe */
ram54288 0:dbad57390bd1 1331 notification_message_ptr->options_list_ptr->observe = observation;
ram54288 0:dbad57390bd1 1332
ram54288 0:dbad57390bd1 1333 notification_message_ptr->options_list_ptr->max_age = max_age;
ram54288 0:dbad57390bd1 1334
ram54288 0:dbad57390bd1 1335 notification_message_ptr->content_format = sn_coap_content_format_e(coap_content_type);
ram54288 0:dbad57390bd1 1336
ram54288 0:dbad57390bd1 1337 /* Send message */
ram54288 0:dbad57390bd1 1338 sn_nsdl_send_coap_message(_nsdl_handle,
ram54288 0:dbad57390bd1 1339 _nsdl_handle->nsp_address_ptr->omalw_address_ptr,
ram54288 0:dbad57390bd1 1340 notification_message_ptr);
ram54288 0:dbad57390bd1 1341
ram54288 0:dbad57390bd1 1342 /* Free memory */
ram54288 0:dbad57390bd1 1343 notification_message_ptr->payload_ptr = NULL;
ram54288 0:dbad57390bd1 1344 notification_message_ptr->options_list_ptr->observe = -1;
ram54288 0:dbad57390bd1 1345 notification_message_ptr->token_ptr = NULL;
ram54288 0:dbad57390bd1 1346 }
ram54288 0:dbad57390bd1 1347 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, notification_message_ptr);
ram54288 0:dbad57390bd1 1348 }
ram54288 0:dbad57390bd1 1349 }
ram54288 0:dbad57390bd1 1350
ram54288 0:dbad57390bd1 1351 nsdl_s * M2MNsdlInterface::get_nsdl_handle()
ram54288 0:dbad57390bd1 1352 {
ram54288 0:dbad57390bd1 1353 return _nsdl_handle;
ram54288 0:dbad57390bd1 1354 }
ram54288 0:dbad57390bd1 1355
ram54288 0:dbad57390bd1 1356 void M2MNsdlInterface::handle_bootstrap_put_message(sn_coap_hdr_s *coap_header,
ram54288 0:dbad57390bd1 1357 sn_nsdl_addr_s *address) {
ram54288 0:dbad57390bd1 1358 #ifndef M2M_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 1359 tr_debug("M2MNsdlInterface::handle_bootstrap_message");
ram54288 0:dbad57390bd1 1360 uint8_t response_code = COAP_MSG_CODE_RESPONSE_CHANGED;
ram54288 0:dbad57390bd1 1361 sn_coap_hdr_s *coap_response = NULL;
ram54288 0:dbad57390bd1 1362 bool success = false;
ram54288 0:dbad57390bd1 1363 bool security_object = false;
ram54288 0:dbad57390bd1 1364 uint16_t content_type = 0;
ram54288 0:dbad57390bd1 1365
ram54288 0:dbad57390bd1 1366 if (!_security) {
ram54288 0:dbad57390bd1 1367 _security = new M2MSecurity(M2MSecurity::M2MServer);
ram54288 0:dbad57390bd1 1368 }
ram54288 0:dbad57390bd1 1369
ram54288 0:dbad57390bd1 1370 String resource_name = coap_to_string(coap_header->uri_path_ptr,
ram54288 0:dbad57390bd1 1371 coap_header->uri_path_len);
ram54288 0:dbad57390bd1 1372 tr_debug("M2MNsdlInterface::handle_bootstrap_message - uri %s", resource_name.c_str());
ram54288 0:dbad57390bd1 1373
ram54288 0:dbad57390bd1 1374 // Check incoming object
ram54288 0:dbad57390bd1 1375 if (resource_name.compare(0,1,"0") == 0) {
ram54288 0:dbad57390bd1 1376 security_object = true;
ram54288 0:dbad57390bd1 1377 if(_security) {
ram54288 0:dbad57390bd1 1378 success = true;
ram54288 0:dbad57390bd1 1379 // Not mandatory resource that's why it must be created first
ram54288 0:dbad57390bd1 1380 _security->create_resource(M2MSecurity::ShortServerID, 1);
ram54288 0:dbad57390bd1 1381 // Change operation mode
ram54288 0:dbad57390bd1 1382 M2MResourceList list = _security->object_instance()->resources();
ram54288 0:dbad57390bd1 1383 if(!list.empty()) {
ram54288 0:dbad57390bd1 1384 M2MResourceList::const_iterator it;
ram54288 0:dbad57390bd1 1385 it = list.begin();
ram54288 0:dbad57390bd1 1386 for ( ; it != list.end(); it++ ) {
ram54288 0:dbad57390bd1 1387 (*it)->set_operation(M2MBase::PUT_ALLOWED);
ram54288 0:dbad57390bd1 1388 }
ram54288 0:dbad57390bd1 1389 }
ram54288 0:dbad57390bd1 1390 }
ram54288 0:dbad57390bd1 1391 }
ram54288 0:dbad57390bd1 1392 else if (resource_name.compare(0,1,"1") == 0) {
ram54288 0:dbad57390bd1 1393 success = true;
ram54288 0:dbad57390bd1 1394 }
ram54288 0:dbad57390bd1 1395
ram54288 0:dbad57390bd1 1396 if (success) {
ram54288 0:dbad57390bd1 1397 // Send delayed response if token is part of the message
ram54288 0:dbad57390bd1 1398 if (coap_header->token_ptr) {
ram54288 0:dbad57390bd1 1399 tr_debug("M2MNsdlInterface::handle_bootstrap_message - send delayed response");
ram54288 0:dbad57390bd1 1400 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 1401 coap_header,
ram54288 0:dbad57390bd1 1402 COAP_MSG_CODE_EMPTY);
ram54288 0:dbad57390bd1 1403 if (coap_response) {
ram54288 0:dbad57390bd1 1404 coap_response->msg_type = COAP_MSG_TYPE_ACKNOWLEDGEMENT;
ram54288 0:dbad57390bd1 1405 sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response);
ram54288 0:dbad57390bd1 1406 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 1407 }
ram54288 0:dbad57390bd1 1408 }
ram54288 0:dbad57390bd1 1409
ram54288 0:dbad57390bd1 1410 if(coap_header->content_format != COAP_CT_NONE) {
ram54288 0:dbad57390bd1 1411 content_type = coap_header->content_format;
ram54288 0:dbad57390bd1 1412 }
ram54288 0:dbad57390bd1 1413
ram54288 0:dbad57390bd1 1414 tr_debug("M2MNsdlInterface::handle_bootstrap_message - content_type %d", content_type);
ram54288 0:dbad57390bd1 1415 if (content_type != COAP_CONTENT_OMA_TLV_TYPE) {
ram54288 0:dbad57390bd1 1416 success = false;
ram54288 0:dbad57390bd1 1417 }
ram54288 0:dbad57390bd1 1418 if (success) {
ram54288 0:dbad57390bd1 1419 success = parse_bootstrap_message(coap_header, security_object);
ram54288 0:dbad57390bd1 1420 // Set operation back to default ones
ram54288 0:dbad57390bd1 1421 if (_security) {
ram54288 0:dbad57390bd1 1422 M2MResourceList list = _security->object_instance()->resources();
ram54288 0:dbad57390bd1 1423 if(!list.empty()) {
ram54288 0:dbad57390bd1 1424 M2MResourceList::const_iterator it;
ram54288 0:dbad57390bd1 1425 it = list.begin();
ram54288 0:dbad57390bd1 1426 for ( ; it != list.end(); it++ ) {
ram54288 0:dbad57390bd1 1427 (*it)->set_operation(M2MBase::NOT_ALLOWED);
ram54288 0:dbad57390bd1 1428 }
ram54288 0:dbad57390bd1 1429 }
ram54288 0:dbad57390bd1 1430 }
ram54288 0:dbad57390bd1 1431 }
ram54288 0:dbad57390bd1 1432 }
ram54288 0:dbad57390bd1 1433
ram54288 0:dbad57390bd1 1434 if (!success) {
ram54288 0:dbad57390bd1 1435 response_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 1436 handle_bootstrap_error();
ram54288 0:dbad57390bd1 1437 }
ram54288 0:dbad57390bd1 1438 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 1439 coap_header,
ram54288 0:dbad57390bd1 1440 response_code);
ram54288 0:dbad57390bd1 1441 if (coap_response) {
ram54288 0:dbad57390bd1 1442 sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response);
ram54288 0:dbad57390bd1 1443 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 1444 }
ram54288 0:dbad57390bd1 1445 #else
ram54288 0:dbad57390bd1 1446 (void) coap_header;
ram54288 0:dbad57390bd1 1447 (void) address;
ram54288 0:dbad57390bd1 1448 #endif
ram54288 0:dbad57390bd1 1449 }
ram54288 0:dbad57390bd1 1450
ram54288 0:dbad57390bd1 1451 bool M2MNsdlInterface::parse_bootstrap_message(sn_coap_hdr_s *coap_header, bool is_security_object)
ram54288 0:dbad57390bd1 1452 {
ram54288 0:dbad57390bd1 1453 #ifndef M2M_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 1454 tr_debug("M2MNsdlInterface::parse_bootstrap_put_message");
ram54288 0:dbad57390bd1 1455 bool ret = false;
ram54288 0:dbad57390bd1 1456 bool is_obj_instance = false;
ram54288 0:dbad57390bd1 1457 uint16_t instance_id = 0;
ram54288 0:dbad57390bd1 1458 if (_security) {
ram54288 0:dbad57390bd1 1459 // Actually there are no member variables on the M2MTLVDeserializer so all the methods
ram54288 0:dbad57390bd1 1460 // could be converted to static ones.
ram54288 0:dbad57390bd1 1461 M2MTLVDeserializer deserializer;
ram54288 0:dbad57390bd1 1462
ram54288 0:dbad57390bd1 1463 ret = is_obj_instance = deserializer.is_object_instance(coap_header->payload_ptr);
ram54288 0:dbad57390bd1 1464 if (!is_obj_instance) {
ram54288 0:dbad57390bd1 1465 ret = deserializer.is_resource(coap_header->payload_ptr);
ram54288 0:dbad57390bd1 1466 }
ram54288 0:dbad57390bd1 1467
ram54288 0:dbad57390bd1 1468 if (ret) {
ram54288 0:dbad57390bd1 1469 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
ram54288 0:dbad57390bd1 1470 if (is_obj_instance) {
ram54288 0:dbad57390bd1 1471 if (is_security_object) {
ram54288 0:dbad57390bd1 1472 error = deserializer.deserialise_object_instances(coap_header->payload_ptr,
ram54288 0:dbad57390bd1 1473 coap_header->payload_len,
ram54288 0:dbad57390bd1 1474 *_security,
ram54288 0:dbad57390bd1 1475 M2MTLVDeserializer::Put);
ram54288 0:dbad57390bd1 1476 }
ram54288 0:dbad57390bd1 1477 else {
ram54288 0:dbad57390bd1 1478 error = deserializer.deserialise_object_instances(coap_header->payload_ptr,
ram54288 0:dbad57390bd1 1479 coap_header->payload_len,
ram54288 0:dbad57390bd1 1480 _server,
ram54288 0:dbad57390bd1 1481 M2MTLVDeserializer::Put);
ram54288 0:dbad57390bd1 1482 }
ram54288 0:dbad57390bd1 1483 }
ram54288 0:dbad57390bd1 1484 else {
ram54288 0:dbad57390bd1 1485 if (is_security_object) {
ram54288 0:dbad57390bd1 1486 instance_id = deserializer.instance_id(coap_header->payload_ptr);
ram54288 0:dbad57390bd1 1487 error = deserializer.deserialize_resources(coap_header->payload_ptr,
ram54288 0:dbad57390bd1 1488 coap_header->payload_len,
ram54288 0:dbad57390bd1 1489 *_security->object_instance(instance_id),
ram54288 0:dbad57390bd1 1490 M2MTLVDeserializer::Put);
ram54288 0:dbad57390bd1 1491 }
ram54288 0:dbad57390bd1 1492 else {
ram54288 0:dbad57390bd1 1493 instance_id = deserializer.instance_id(coap_header->payload_ptr);
ram54288 0:dbad57390bd1 1494 error = deserializer.deserialize_resources(coap_header->payload_ptr,
ram54288 0:dbad57390bd1 1495 coap_header->payload_len,
ram54288 0:dbad57390bd1 1496 *(_server.object_instance(instance_id)),
ram54288 0:dbad57390bd1 1497 M2MTLVDeserializer::Post);
ram54288 0:dbad57390bd1 1498 }
ram54288 0:dbad57390bd1 1499 }
ram54288 0:dbad57390bd1 1500
ram54288 0:dbad57390bd1 1501 if (error != M2MTLVDeserializer::None) {
ram54288 0:dbad57390bd1 1502 tr_error("M2MNsdlInterface::parse_bootstrap_put_message - error %d", error);
ram54288 0:dbad57390bd1 1503 ret = false;
ram54288 0:dbad57390bd1 1504 }
ram54288 0:dbad57390bd1 1505 }
ram54288 0:dbad57390bd1 1506 }
ram54288 0:dbad57390bd1 1507 return ret;
ram54288 0:dbad57390bd1 1508 #else
ram54288 0:dbad57390bd1 1509 (void) coap_header;
ram54288 0:dbad57390bd1 1510 (void) is_security_object;
ram54288 0:dbad57390bd1 1511 return false;
ram54288 0:dbad57390bd1 1512 #endif
ram54288 0:dbad57390bd1 1513 }
ram54288 0:dbad57390bd1 1514
ram54288 0:dbad57390bd1 1515 void M2MNsdlInterface::handle_bootstrap_finished(sn_coap_hdr_s *coap_header,sn_nsdl_addr_s *address)
ram54288 0:dbad57390bd1 1516 {
ram54288 0:dbad57390bd1 1517 #ifndef M2M_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 1518 String object_name = coap_to_string(coap_header->uri_path_ptr,
ram54288 0:dbad57390bd1 1519 coap_header->uri_path_len);
ram54288 0:dbad57390bd1 1520 tr_debug("M2MNsdlInterface::handle_bootstrap_finished - path: %s", object_name.c_str());
ram54288 0:dbad57390bd1 1521 sn_coap_hdr_s *coap_response = NULL;
ram54288 0:dbad57390bd1 1522 uint8_t msg_code = COAP_MSG_CODE_RESPONSE_CHANGED;
ram54288 0:dbad57390bd1 1523
ram54288 0:dbad57390bd1 1524 // Accept only '/bs' path and check that needed data is in security object
ram54288 0:dbad57390bd1 1525 if (object_name.size() != 2 ||
ram54288 0:dbad57390bd1 1526 object_name.compare(0,2,BOOTSTRAP_URI) != 0 ||
ram54288 0:dbad57390bd1 1527 !validate_security_object()) {
ram54288 0:dbad57390bd1 1528 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 1529 } else {
ram54288 0:dbad57390bd1 1530 // Add short server id to server object
ram54288 0:dbad57390bd1 1531 _server.set_resource_value(M2MServer::ShortServerID,
ram54288 0:dbad57390bd1 1532 _security->resource_value_int(M2MSecurity::ShortServerID));
ram54288 0:dbad57390bd1 1533 }
ram54288 0:dbad57390bd1 1534
ram54288 0:dbad57390bd1 1535 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 1536 coap_header,
ram54288 0:dbad57390bd1 1537 msg_code);
ram54288 0:dbad57390bd1 1538 if(coap_response) {
ram54288 0:dbad57390bd1 1539 sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response);
ram54288 0:dbad57390bd1 1540 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 1541 }
ram54288 0:dbad57390bd1 1542 if (COAP_MSG_CODE_RESPONSE_CHANGED == msg_code) {
ram54288 0:dbad57390bd1 1543 // Switch back to original ep name
ram54288 0:dbad57390bd1 1544 if (_endpoint->endpoint_name_ptr) {
ram54288 0:dbad57390bd1 1545 memory_free(_endpoint->endpoint_name_ptr);
ram54288 0:dbad57390bd1 1546 }
ram54288 0:dbad57390bd1 1547 _endpoint->endpoint_name_ptr = alloc_string_copy((uint8_t*)_endpoint_name.c_str(), _endpoint_name.length());
ram54288 0:dbad57390bd1 1548 _endpoint->endpoint_name_len = _endpoint_name.length();
ram54288 0:dbad57390bd1 1549 // Inform observer that bootstrap is finished but it should wait until nsdl has sent data.
ram54288 0:dbad57390bd1 1550 // The final bootstrap_done callback is called in the observers data_sent callback.
ram54288 0:dbad57390bd1 1551 _observer.bootstrap_wait(_security);
ram54288 0:dbad57390bd1 1552 } else {
ram54288 0:dbad57390bd1 1553 handle_bootstrap_error();
ram54288 0:dbad57390bd1 1554 }
ram54288 0:dbad57390bd1 1555 #else
ram54288 0:dbad57390bd1 1556 (void) coap_header;
ram54288 0:dbad57390bd1 1557 (void) address;
ram54288 0:dbad57390bd1 1558 #endif
ram54288 0:dbad57390bd1 1559 }
ram54288 0:dbad57390bd1 1560
ram54288 0:dbad57390bd1 1561 void M2MNsdlInterface::handle_bootstrap_delete(sn_coap_hdr_s *coap_header,sn_nsdl_addr_s *address)
ram54288 0:dbad57390bd1 1562 {
ram54288 0:dbad57390bd1 1563 #ifndef M2M_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 1564 sn_coap_hdr_s *coap_response = NULL;
ram54288 0:dbad57390bd1 1565 uint8_t msg_code = COAP_MSG_CODE_RESPONSE_DELETED;
ram54288 0:dbad57390bd1 1566 String object_name = coap_to_string(coap_header->uri_path_ptr,
ram54288 0:dbad57390bd1 1567 coap_header->uri_path_len);
ram54288 0:dbad57390bd1 1568 tr_debug("M2MNsdlInterface::handle_bootstrap_delete - obj %s", object_name.c_str());
ram54288 0:dbad57390bd1 1569 if(!_identity_accepted) {
ram54288 0:dbad57390bd1 1570 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 1571 }
ram54288 0:dbad57390bd1 1572 // Only following paths are accepted, 0, 0/0
ram54288 0:dbad57390bd1 1573 else if (object_name.size() == 2 || object_name.size() > 3) {
ram54288 0:dbad57390bd1 1574 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 1575 }
ram54288 0:dbad57390bd1 1576 else if ((object_name.size() == 1 && object_name.compare(0,1,"0") != 0) ||
ram54288 0:dbad57390bd1 1577 (object_name.size() == 3 && object_name.compare(0,3,"0/0") != 0)) {
ram54288 0:dbad57390bd1 1578 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:dbad57390bd1 1579 }
ram54288 0:dbad57390bd1 1580
ram54288 0:dbad57390bd1 1581 coap_response = sn_nsdl_build_response(_nsdl_handle,
ram54288 0:dbad57390bd1 1582 coap_header,
ram54288 0:dbad57390bd1 1583 msg_code);
ram54288 0:dbad57390bd1 1584
ram54288 0:dbad57390bd1 1585 if(coap_response) {
ram54288 0:dbad57390bd1 1586 sn_nsdl_send_coap_message(_nsdl_handle, address, coap_response);
ram54288 0:dbad57390bd1 1587 sn_nsdl_release_allocated_coap_msg_mem(_nsdl_handle, coap_response);
ram54288 0:dbad57390bd1 1588 if(_security) {
ram54288 0:dbad57390bd1 1589 _security->clear_resources();
ram54288 0:dbad57390bd1 1590 }
ram54288 0:dbad57390bd1 1591 }
ram54288 0:dbad57390bd1 1592 if (!coap_response || COAP_MSG_CODE_RESPONSE_DELETED != msg_code) {
ram54288 0:dbad57390bd1 1593 handle_bootstrap_error();
ram54288 0:dbad57390bd1 1594 }
ram54288 0:dbad57390bd1 1595 #else
ram54288 0:dbad57390bd1 1596 (void) coap_header;
ram54288 0:dbad57390bd1 1597 (void) address;
ram54288 0:dbad57390bd1 1598 #endif
ram54288 0:dbad57390bd1 1599 }
ram54288 0:dbad57390bd1 1600
ram54288 0:dbad57390bd1 1601 bool M2MNsdlInterface::validate_security_object()
ram54288 0:dbad57390bd1 1602 {
ram54288 0:dbad57390bd1 1603 #ifndef M2M_CLIENT_DISABLE_BOOTSTRAP_FEATURE
ram54288 0:dbad57390bd1 1604 tr_debug("M2MNsdlInterface::validate_security_object");
ram54288 0:dbad57390bd1 1605 if (_security) {
ram54288 0:dbad57390bd1 1606 String address = _security->resource_value_string(M2MSecurity::M2MServerUri);
ram54288 0:dbad57390bd1 1607 uint32_t sec_mode = _security->resource_value_int(M2MSecurity::SecurityMode);
ram54288 0:dbad57390bd1 1608 bool is_bs_server = _security->resource_value_int(M2MSecurity::BootstrapServer);
ram54288 0:dbad57390bd1 1609 uint32_t public_key_size = _security->get_resource(M2MSecurity::PublicKey)->value_length();
ram54288 0:dbad57390bd1 1610 uint32_t server_key_size = _security->get_resource(M2MSecurity::ServerPublicKey)->value_length();
ram54288 0:dbad57390bd1 1611 uint32_t pkey_size = _security->get_resource(M2MSecurity::Secretkey)->value_length();
ram54288 0:dbad57390bd1 1612 tr_debug("M2MNsdlInterface::validate_security_object - Server URI /0/0: %s", address.c_str());
ram54288 0:dbad57390bd1 1613 tr_debug("M2MNsdlInterface::validate_security_object - is bs server /0/1: %d", is_bs_server);
ram54288 0:dbad57390bd1 1614 tr_debug("M2MNsdlInterface::validate_security_object - Security Mode /0/2: %" PRIu32, sec_mode);
ram54288 0:dbad57390bd1 1615 tr_debug("M2MNsdlInterface::validate_security_object - Public key size /0/3: %" PRIu32, public_key_size);
ram54288 0:dbad57390bd1 1616 tr_debug("M2MNsdlInterface::validate_security_object - Server Public key size /0/4: %" PRIu32, server_key_size);
ram54288 0:dbad57390bd1 1617 tr_debug("M2MNsdlInterface::validate_security_object - Secret key size /0/5: %" PRIu32, pkey_size);
ram54288 0:dbad57390bd1 1618 // Only NoSec and Certificate modes are supported
ram54288 0:dbad57390bd1 1619 if (!address.empty() && !is_bs_server) {
ram54288 0:dbad57390bd1 1620 if (M2MSecurity::Certificate == sec_mode) {
ram54288 0:dbad57390bd1 1621 if (!public_key_size || !server_key_size || !pkey_size) {
ram54288 0:dbad57390bd1 1622 return false;
ram54288 0:dbad57390bd1 1623 } else {
ram54288 0:dbad57390bd1 1624 return true;
ram54288 0:dbad57390bd1 1625 }
ram54288 0:dbad57390bd1 1626 } else if (M2MSecurity::NoSecurity == sec_mode){
ram54288 0:dbad57390bd1 1627 return true;
ram54288 0:dbad57390bd1 1628 } else {
ram54288 0:dbad57390bd1 1629 return false;
ram54288 0:dbad57390bd1 1630 }
ram54288 0:dbad57390bd1 1631 } else {
ram54288 0:dbad57390bd1 1632 return false;
ram54288 0:dbad57390bd1 1633 }
ram54288 0:dbad57390bd1 1634 }
ram54288 0:dbad57390bd1 1635 return false;
ram54288 0:dbad57390bd1 1636 #else
ram54288 0:dbad57390bd1 1637 return false;
ram54288 0:dbad57390bd1 1638 #endif
ram54288 0:dbad57390bd1 1639 }
ram54288 0:dbad57390bd1 1640
ram54288 0:dbad57390bd1 1641 void M2MNsdlInterface::handle_bootstrap_error()
ram54288 0:dbad57390bd1 1642 {
ram54288 0:dbad57390bd1 1643 tr_debug("M2MNsdlInterface::handle_bootstrap_error()");
ram54288 0:dbad57390bd1 1644 _identity_accepted = false;
ram54288 0:dbad57390bd1 1645 if (_security) {
ram54288 0:dbad57390bd1 1646 delete _security;
ram54288 0:dbad57390bd1 1647 _security = NULL;
ram54288 0:dbad57390bd1 1648 }
ram54288 0:dbad57390bd1 1649 _observer.bootstrap_error();
ram54288 0:dbad57390bd1 1650 }
ram54288 0:dbad57390bd1 1651
ram54288 0:dbad57390bd1 1652 const String& M2MNsdlInterface::endpoint_name() const
ram54288 0:dbad57390bd1 1653 {
ram54288 0:dbad57390bd1 1654 return _endpoint_name;
ram54288 0:dbad57390bd1 1655 }