Ram Gandikota / Mbed OS metronome

FRDM K64F Metronome

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

Committer:
ram54288
Date:
Sun May 14 18:35:07 2017 +0000
Revision:
0:a2cb7295a1f7
Initial commit

Who changed what in which revision?

UserRevisionLine numberNew contents of line
ram54288 0:a2cb7295a1f7 1 /*
ram54288 0:a2cb7295a1f7 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
ram54288 0:a2cb7295a1f7 3 * SPDX-License-Identifier: Apache-2.0
ram54288 0:a2cb7295a1f7 4 * Licensed under the Apache License, Version 2.0 (the License); you may
ram54288 0:a2cb7295a1f7 5 * not use this file except in compliance with the License.
ram54288 0:a2cb7295a1f7 6 * You may obtain a copy of the License at
ram54288 0:a2cb7295a1f7 7 *
ram54288 0:a2cb7295a1f7 8 * http://www.apache.org/licenses/LICENSE-2.0
ram54288 0:a2cb7295a1f7 9 *
ram54288 0:a2cb7295a1f7 10 * Unless required by applicable law or agreed to in writing, software
ram54288 0:a2cb7295a1f7 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
ram54288 0:a2cb7295a1f7 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
ram54288 0:a2cb7295a1f7 13 * See the License for the specific language governing permissions and
ram54288 0:a2cb7295a1f7 14 * limitations under the License.
ram54288 0:a2cb7295a1f7 15 */
ram54288 0:a2cb7295a1f7 16 #include "mbed-client/m2mobjectinstance.h"
ram54288 0:a2cb7295a1f7 17 #include "mbed-client/m2mobject.h"
ram54288 0:a2cb7295a1f7 18 #include "mbed-client/m2mconstants.h"
ram54288 0:a2cb7295a1f7 19 #include "mbed-client/m2mresource.h"
ram54288 0:a2cb7295a1f7 20 #include "mbed-client/m2mresource.h"
ram54288 0:a2cb7295a1f7 21 #include "mbed-client/m2mobservationhandler.h"
ram54288 0:a2cb7295a1f7 22 #include "mbed-client/m2mstring.h"
ram54288 0:a2cb7295a1f7 23 #include "mbed-client/m2mstringbuffer.h"
ram54288 0:a2cb7295a1f7 24 #include "include/m2mtlvserializer.h"
ram54288 0:a2cb7295a1f7 25 #include "include/m2mtlvdeserializer.h"
ram54288 0:a2cb7295a1f7 26 #include "include/nsdllinker.h"
ram54288 0:a2cb7295a1f7 27 #include "include/m2mreporthandler.h"
ram54288 0:a2cb7295a1f7 28 #include "mbed-trace/mbed_trace.h"
ram54288 0:a2cb7295a1f7 29
ram54288 0:a2cb7295a1f7 30 #include <stdlib.h>
ram54288 0:a2cb7295a1f7 31
ram54288 0:a2cb7295a1f7 32 #define BUFFER_SIZE 10
ram54288 0:a2cb7295a1f7 33 #define TRACE_GROUP "mClt"
ram54288 0:a2cb7295a1f7 34
ram54288 0:a2cb7295a1f7 35 M2MObjectInstance::M2MObjectInstance(M2MObject& parent, const String &object_name,
ram54288 0:a2cb7295a1f7 36 const String &resource_type,
ram54288 0:a2cb7295a1f7 37 char *path,
ram54288 0:a2cb7295a1f7 38 bool external_blockwise_store)
ram54288 0:a2cb7295a1f7 39 : M2MBase(object_name,
ram54288 0:a2cb7295a1f7 40 M2MBase::Dynamic,
ram54288 0:a2cb7295a1f7 41 resource_type,
ram54288 0:a2cb7295a1f7 42 path,
ram54288 0:a2cb7295a1f7 43 external_blockwise_store),
ram54288 0:a2cb7295a1f7 44 _parent(parent)
ram54288 0:a2cb7295a1f7 45 {
ram54288 0:a2cb7295a1f7 46 M2MBase::set_base_type(M2MBase::ObjectInstance);
ram54288 0:a2cb7295a1f7 47 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 48 }
ram54288 0:a2cb7295a1f7 49
ram54288 0:a2cb7295a1f7 50 M2MObjectInstance::M2MObjectInstance(M2MObject& parent, const lwm2m_parameters_s* static_res)
ram54288 0:a2cb7295a1f7 51 : M2MBase(static_res), _parent(parent)
ram54288 0:a2cb7295a1f7 52 {
ram54288 0:a2cb7295a1f7 53 M2MBase::set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 54 }
ram54288 0:a2cb7295a1f7 55
ram54288 0:a2cb7295a1f7 56 M2MObjectInstance::~M2MObjectInstance()
ram54288 0:a2cb7295a1f7 57 {
ram54288 0:a2cb7295a1f7 58 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 59 M2MResource* res = NULL;
ram54288 0:a2cb7295a1f7 60 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 61 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 62 for (; it!=_resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 63 //Free allocated memory for resources.
ram54288 0:a2cb7295a1f7 64 res = *it;
ram54288 0:a2cb7295a1f7 65 delete res;
ram54288 0:a2cb7295a1f7 66 }
ram54288 0:a2cb7295a1f7 67 _resource_list.clear();
ram54288 0:a2cb7295a1f7 68 }
ram54288 0:a2cb7295a1f7 69 }
ram54288 0:a2cb7295a1f7 70
ram54288 0:a2cb7295a1f7 71 // TBD, ResourceType to the base class struct?? TODO!
ram54288 0:a2cb7295a1f7 72 M2MResource* M2MObjectInstance::create_static_resource(const lwm2m_parameters_s* static_res,
ram54288 0:a2cb7295a1f7 73 M2MResourceInstance::ResourceType type)
ram54288 0:a2cb7295a1f7 74 {
ram54288 0:a2cb7295a1f7 75 tr_debug("M2MObjectInstance::create_static_resource(lwm2m_parameters_s resource_name %s)", static_res->name);
ram54288 0:a2cb7295a1f7 76 M2MResource *res = NULL;
ram54288 0:a2cb7295a1f7 77 if (validate_string_length(static_res->name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 78 return res;
ram54288 0:a2cb7295a1f7 79 }
ram54288 0:a2cb7295a1f7 80 if(!resource(static_res->name)) {
ram54288 0:a2cb7295a1f7 81 res = new M2MResource(*this, static_res, type, (const uint16_t) M2MBase::instance_id());
ram54288 0:a2cb7295a1f7 82 if(res) {
ram54288 0:a2cb7295a1f7 83 res->add_observation_level(observation_level());
ram54288 0:a2cb7295a1f7 84 //if (multiple_instance) {
ram54288 0:a2cb7295a1f7 85 //res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 86 //}
ram54288 0:a2cb7295a1f7 87 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 88 }
ram54288 0:a2cb7295a1f7 89 }
ram54288 0:a2cb7295a1f7 90 return res;
ram54288 0:a2cb7295a1f7 91 }
ram54288 0:a2cb7295a1f7 92
ram54288 0:a2cb7295a1f7 93 M2MResource* M2MObjectInstance::create_static_resource(const String &resource_name,
ram54288 0:a2cb7295a1f7 94 const String &resource_type,
ram54288 0:a2cb7295a1f7 95 M2MResourceInstance::ResourceType type,
ram54288 0:a2cb7295a1f7 96 const uint8_t *value,
ram54288 0:a2cb7295a1f7 97 const uint8_t value_length,
ram54288 0:a2cb7295a1f7 98 bool multiple_instance,
ram54288 0:a2cb7295a1f7 99 bool external_blockwise_store)
ram54288 0:a2cb7295a1f7 100 {
ram54288 0:a2cb7295a1f7 101 tr_debug("M2MObjectInstance::create_static_resource(resource_name %s)",resource_name.c_str());
ram54288 0:a2cb7295a1f7 102 M2MResource *res = NULL;
ram54288 0:a2cb7295a1f7 103 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 104 return res;
ram54288 0:a2cb7295a1f7 105 }
ram54288 0:a2cb7295a1f7 106 if(!resource(resource_name)) {
ram54288 0:a2cb7295a1f7 107 char *path = create_path(*this, resource_name.c_str());
ram54288 0:a2cb7295a1f7 108
ram54288 0:a2cb7295a1f7 109 if (path) {
ram54288 0:a2cb7295a1f7 110 res = new M2MResource(*this, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 111 value, value_length, path, M2MBase::instance_id(),
ram54288 0:a2cb7295a1f7 112 multiple_instance, external_blockwise_store);
ram54288 0:a2cb7295a1f7 113 if(res) {
ram54288 0:a2cb7295a1f7 114 res->add_observation_level(observation_level());
ram54288 0:a2cb7295a1f7 115 if (multiple_instance) {
ram54288 0:a2cb7295a1f7 116 res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 117 }
ram54288 0:a2cb7295a1f7 118 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 119 }
ram54288 0:a2cb7295a1f7 120 }
ram54288 0:a2cb7295a1f7 121 }
ram54288 0:a2cb7295a1f7 122 return res;
ram54288 0:a2cb7295a1f7 123 }
ram54288 0:a2cb7295a1f7 124
ram54288 0:a2cb7295a1f7 125 M2MResource* M2MObjectInstance::create_dynamic_resource(const lwm2m_parameters_s* static_res,
ram54288 0:a2cb7295a1f7 126 M2MResourceInstance::ResourceType type,
ram54288 0:a2cb7295a1f7 127 bool observable)
ram54288 0:a2cb7295a1f7 128 {
ram54288 0:a2cb7295a1f7 129 tr_debug("M2MObjectInstance::create_dynamic_resource(resource_name %s)", static_res->name);
ram54288 0:a2cb7295a1f7 130 M2MResource *res = NULL;
ram54288 0:a2cb7295a1f7 131
ram54288 0:a2cb7295a1f7 132 if (validate_string_length(static_res->name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 133 return res;
ram54288 0:a2cb7295a1f7 134 }
ram54288 0:a2cb7295a1f7 135 if(!resource(static_res->name)) {
ram54288 0:a2cb7295a1f7 136 res = new M2MResource(*this, static_res, type, M2MBase::instance_id());
ram54288 0:a2cb7295a1f7 137 if(res) {
ram54288 0:a2cb7295a1f7 138 //if (multiple_instance) { // TODO!
ram54288 0:a2cb7295a1f7 139 // res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 140 //}
ram54288 0:a2cb7295a1f7 141 res->add_observation_level(observation_level());
ram54288 0:a2cb7295a1f7 142 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 143 }
ram54288 0:a2cb7295a1f7 144 }
ram54288 0:a2cb7295a1f7 145 return res;
ram54288 0:a2cb7295a1f7 146 }
ram54288 0:a2cb7295a1f7 147
ram54288 0:a2cb7295a1f7 148 M2MResource* M2MObjectInstance::create_dynamic_resource(const String &resource_name,
ram54288 0:a2cb7295a1f7 149 const String &resource_type,
ram54288 0:a2cb7295a1f7 150 M2MResourceInstance::ResourceType type,
ram54288 0:a2cb7295a1f7 151 bool observable,
ram54288 0:a2cb7295a1f7 152 bool multiple_instance,
ram54288 0:a2cb7295a1f7 153 bool external_blockwise_store)
ram54288 0:a2cb7295a1f7 154 {
ram54288 0:a2cb7295a1f7 155 tr_debug("M2MObjectInstance::create_dynamic_resource(resource_name %s)",resource_name.c_str());
ram54288 0:a2cb7295a1f7 156 M2MResource *res = NULL;
ram54288 0:a2cb7295a1f7 157 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 158 return res;
ram54288 0:a2cb7295a1f7 159 }
ram54288 0:a2cb7295a1f7 160 if(!resource(resource_name)) {
ram54288 0:a2cb7295a1f7 161 char *path = create_path(*this, resource_name.c_str());
ram54288 0:a2cb7295a1f7 162 if (path) {
ram54288 0:a2cb7295a1f7 163 res = new M2MResource(*this, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 164 observable, path, M2MBase::instance_id(),
ram54288 0:a2cb7295a1f7 165 multiple_instance, external_blockwise_store);
ram54288 0:a2cb7295a1f7 166 if(res) {
ram54288 0:a2cb7295a1f7 167 if (multiple_instance) {
ram54288 0:a2cb7295a1f7 168 res->set_coap_content_type(COAP_CONTENT_OMA_TLV_TYPE);
ram54288 0:a2cb7295a1f7 169 }
ram54288 0:a2cb7295a1f7 170 res->add_observation_level(observation_level());
ram54288 0:a2cb7295a1f7 171 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 172 }
ram54288 0:a2cb7295a1f7 173 }
ram54288 0:a2cb7295a1f7 174 }
ram54288 0:a2cb7295a1f7 175 return res;
ram54288 0:a2cb7295a1f7 176 }
ram54288 0:a2cb7295a1f7 177
ram54288 0:a2cb7295a1f7 178 M2MResourceInstance* M2MObjectInstance::create_static_resource_instance(const String &resource_name,
ram54288 0:a2cb7295a1f7 179 const String &resource_type,
ram54288 0:a2cb7295a1f7 180 M2MResourceInstance::ResourceType type,
ram54288 0:a2cb7295a1f7 181 const uint8_t *value,
ram54288 0:a2cb7295a1f7 182 const uint8_t value_length,
ram54288 0:a2cb7295a1f7 183 uint16_t instance_id,
ram54288 0:a2cb7295a1f7 184 bool external_blockwise_store)
ram54288 0:a2cb7295a1f7 185 {
ram54288 0:a2cb7295a1f7 186 tr_debug("M2MObjectInstance::create_static_resource_instance(resource_name %s)",resource_name.c_str());
ram54288 0:a2cb7295a1f7 187 M2MResourceInstance *instance = NULL;
ram54288 0:a2cb7295a1f7 188 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 189
ram54288 0:a2cb7295a1f7 190 return instance;
ram54288 0:a2cb7295a1f7 191 }
ram54288 0:a2cb7295a1f7 192 M2MResource *res = resource(resource_name);
ram54288 0:a2cb7295a1f7 193 if(!res) {
ram54288 0:a2cb7295a1f7 194 char *path = create_path(*this, resource_name.c_str());
ram54288 0:a2cb7295a1f7 195 if (path) {
ram54288 0:a2cb7295a1f7 196 res = new M2MResource(*this, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 197 value, value_length, path, M2MBase::instance_id(),
ram54288 0:a2cb7295a1f7 198 true, external_blockwise_store);
ram54288 0:a2cb7295a1f7 199 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 200 res->set_operation(M2MBase::GET_ALLOWED);
ram54288 0:a2cb7295a1f7 201 res->set_observable(false);
ram54288 0:a2cb7295a1f7 202 res->set_register_uri(false);
ram54288 0:a2cb7295a1f7 203 }
ram54288 0:a2cb7295a1f7 204 }
ram54288 0:a2cb7295a1f7 205 if(res && res->supports_multiple_instances()&& (res->resource_instance(instance_id) == NULL)) {
ram54288 0:a2cb7295a1f7 206 char *path = M2MBase::create_path(*res, instance_id);
ram54288 0:a2cb7295a1f7 207 if (path) {
ram54288 0:a2cb7295a1f7 208 instance = new M2MResourceInstance(*res, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 209 value, value_length,
ram54288 0:a2cb7295a1f7 210 M2MBase::instance_id(),
ram54288 0:a2cb7295a1f7 211 path, external_blockwise_store);
ram54288 0:a2cb7295a1f7 212 if(instance) {
ram54288 0:a2cb7295a1f7 213 instance->set_operation(M2MBase::GET_ALLOWED);
ram54288 0:a2cb7295a1f7 214 instance->set_instance_id(instance_id);
ram54288 0:a2cb7295a1f7 215 res->add_resource_instance(instance);
ram54288 0:a2cb7295a1f7 216 }
ram54288 0:a2cb7295a1f7 217 }
ram54288 0:a2cb7295a1f7 218 }
ram54288 0:a2cb7295a1f7 219 return instance;
ram54288 0:a2cb7295a1f7 220 }
ram54288 0:a2cb7295a1f7 221
ram54288 0:a2cb7295a1f7 222 M2MResourceInstance* M2MObjectInstance::create_dynamic_resource_instance(const String &resource_name,
ram54288 0:a2cb7295a1f7 223 const String &resource_type,
ram54288 0:a2cb7295a1f7 224 M2MResourceInstance::ResourceType type,
ram54288 0:a2cb7295a1f7 225 bool observable,
ram54288 0:a2cb7295a1f7 226 uint16_t instance_id,
ram54288 0:a2cb7295a1f7 227 bool external_blockwise_store)
ram54288 0:a2cb7295a1f7 228 {
ram54288 0:a2cb7295a1f7 229 tr_debug("M2MObjectInstance::create_dynamic_resource_instance(resource_name %s)",resource_name.c_str());
ram54288 0:a2cb7295a1f7 230 M2MResourceInstance *instance = NULL;
ram54288 0:a2cb7295a1f7 231 if (validate_string_length(resource_name, 1, MAX_ALLOWED_STRING_LENGTH) == false) {
ram54288 0:a2cb7295a1f7 232 return instance;
ram54288 0:a2cb7295a1f7 233 }
ram54288 0:a2cb7295a1f7 234 M2MResource *res = resource(resource_name);
ram54288 0:a2cb7295a1f7 235 if(!res) {
ram54288 0:a2cb7295a1f7 236 char *path = create_path(*this, resource_name.c_str());
ram54288 0:a2cb7295a1f7 237 if (path) {
ram54288 0:a2cb7295a1f7 238 res = new M2MResource(*this, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 239 false, path, M2MBase::instance_id(), true);
ram54288 0:a2cb7295a1f7 240 _resource_list.push_back(res);
ram54288 0:a2cb7295a1f7 241 res->set_register_uri(false);
ram54288 0:a2cb7295a1f7 242 res->set_operation(M2MBase::GET_ALLOWED);
ram54288 0:a2cb7295a1f7 243 }
ram54288 0:a2cb7295a1f7 244 }
ram54288 0:a2cb7295a1f7 245 if (res && res->supports_multiple_instances() && (res->resource_instance(instance_id) == NULL)) {
ram54288 0:a2cb7295a1f7 246 char *path = create_path(*res, instance_id);
ram54288 0:a2cb7295a1f7 247 if (path) {
ram54288 0:a2cb7295a1f7 248 instance = new M2MResourceInstance(*res, resource_name, resource_type, type,
ram54288 0:a2cb7295a1f7 249 M2MBase::instance_id(),
ram54288 0:a2cb7295a1f7 250 path, external_blockwise_store);
ram54288 0:a2cb7295a1f7 251 if(instance) {
ram54288 0:a2cb7295a1f7 252 instance->set_operation(M2MBase::GET_ALLOWED);
ram54288 0:a2cb7295a1f7 253 instance->set_observable(observable);
ram54288 0:a2cb7295a1f7 254 instance->set_instance_id(instance_id);
ram54288 0:a2cb7295a1f7 255 res->add_resource_instance(instance);
ram54288 0:a2cb7295a1f7 256 }
ram54288 0:a2cb7295a1f7 257 }
ram54288 0:a2cb7295a1f7 258 }
ram54288 0:a2cb7295a1f7 259 return instance;
ram54288 0:a2cb7295a1f7 260 }
ram54288 0:a2cb7295a1f7 261
ram54288 0:a2cb7295a1f7 262 bool M2MObjectInstance::remove_resource(const String &resource_name)
ram54288 0:a2cb7295a1f7 263 {
ram54288 0:a2cb7295a1f7 264 return remove_resource(resource_name.c_str());
ram54288 0:a2cb7295a1f7 265 }
ram54288 0:a2cb7295a1f7 266
ram54288 0:a2cb7295a1f7 267 bool M2MObjectInstance::remove_resource(const char *resource_name)
ram54288 0:a2cb7295a1f7 268 {
ram54288 0:a2cb7295a1f7 269 tr_debug("M2MObjectInstance::remove_resource(resource_name %s)", resource_name);
ram54288 0:a2cb7295a1f7 270
ram54288 0:a2cb7295a1f7 271 bool success = false;
ram54288 0:a2cb7295a1f7 272 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 273 M2MResource* res = NULL;
ram54288 0:a2cb7295a1f7 274 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 275 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 276 int pos = 0;
ram54288 0:a2cb7295a1f7 277 for ( ; it != _resource_list.end(); it++, pos++ ) {
ram54288 0:a2cb7295a1f7 278 if(strcmp((*it)->name(), resource_name) == 0) {
ram54288 0:a2cb7295a1f7 279 // Resource found and deleted.
ram54288 0:a2cb7295a1f7 280 res = *it;
ram54288 0:a2cb7295a1f7 281 delete res;
ram54288 0:a2cb7295a1f7 282 res = NULL;
ram54288 0:a2cb7295a1f7 283 _resource_list.erase(pos);
ram54288 0:a2cb7295a1f7 284 success = true;
ram54288 0:a2cb7295a1f7 285 break;
ram54288 0:a2cb7295a1f7 286 }
ram54288 0:a2cb7295a1f7 287 }
ram54288 0:a2cb7295a1f7 288 }
ram54288 0:a2cb7295a1f7 289 return success;
ram54288 0:a2cb7295a1f7 290 }
ram54288 0:a2cb7295a1f7 291
ram54288 0:a2cb7295a1f7 292 bool M2MObjectInstance::remove_resource_instance(const String &resource_name,
ram54288 0:a2cb7295a1f7 293 uint16_t inst_id)
ram54288 0:a2cb7295a1f7 294 {
ram54288 0:a2cb7295a1f7 295 tr_debug("M2MObjectInstance::remove_resource_instance(resource_name %s inst_id %d)",
ram54288 0:a2cb7295a1f7 296 resource_name.c_str(), inst_id);
ram54288 0:a2cb7295a1f7 297 bool success = false;
ram54288 0:a2cb7295a1f7 298 M2MResource *res = resource(resource_name);
ram54288 0:a2cb7295a1f7 299 if(res) {
ram54288 0:a2cb7295a1f7 300 M2MResourceInstanceList list = res->resource_instances();
ram54288 0:a2cb7295a1f7 301 M2MResourceInstanceList::const_iterator it;
ram54288 0:a2cb7295a1f7 302 it = list.begin();
ram54288 0:a2cb7295a1f7 303 for ( ; it != list.end(); it++) {
ram54288 0:a2cb7295a1f7 304 if((*it)->instance_id() == inst_id) {
ram54288 0:a2cb7295a1f7 305 success = res->remove_resource_instance(inst_id);
ram54288 0:a2cb7295a1f7 306 if(res->resource_instance_count() == 0) {
ram54288 0:a2cb7295a1f7 307 M2MResourceList::const_iterator itr;
ram54288 0:a2cb7295a1f7 308 itr = _resource_list.begin();
ram54288 0:a2cb7295a1f7 309 int pos = 0;
ram54288 0:a2cb7295a1f7 310 for ( ; itr != _resource_list.end(); itr++, pos++ ) {
ram54288 0:a2cb7295a1f7 311 if(strcmp((*itr)->name(),resource_name.c_str()) == 0) {
ram54288 0:a2cb7295a1f7 312 delete res;
ram54288 0:a2cb7295a1f7 313 res = NULL;
ram54288 0:a2cb7295a1f7 314 _resource_list.erase(pos);
ram54288 0:a2cb7295a1f7 315 break;
ram54288 0:a2cb7295a1f7 316 }
ram54288 0:a2cb7295a1f7 317 }
ram54288 0:a2cb7295a1f7 318 }
ram54288 0:a2cb7295a1f7 319 break;
ram54288 0:a2cb7295a1f7 320 }
ram54288 0:a2cb7295a1f7 321 }
ram54288 0:a2cb7295a1f7 322 }
ram54288 0:a2cb7295a1f7 323 return success;
ram54288 0:a2cb7295a1f7 324 }
ram54288 0:a2cb7295a1f7 325
ram54288 0:a2cb7295a1f7 326 M2MResource* M2MObjectInstance::resource(const String &resource_name) const
ram54288 0:a2cb7295a1f7 327 {
ram54288 0:a2cb7295a1f7 328 return resource(resource_name.c_str());
ram54288 0:a2cb7295a1f7 329 }
ram54288 0:a2cb7295a1f7 330
ram54288 0:a2cb7295a1f7 331 M2MResource* M2MObjectInstance::resource(const char *resource_name) const
ram54288 0:a2cb7295a1f7 332 {
ram54288 0:a2cb7295a1f7 333 M2MResource *res = NULL;
ram54288 0:a2cb7295a1f7 334 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 335 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 336 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 337 for (; it!=_resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 338 if(strcmp((*it)->name(), resource_name) == 0) {
ram54288 0:a2cb7295a1f7 339 res = *it;
ram54288 0:a2cb7295a1f7 340 break;
ram54288 0:a2cb7295a1f7 341 }
ram54288 0:a2cb7295a1f7 342 }
ram54288 0:a2cb7295a1f7 343 }
ram54288 0:a2cb7295a1f7 344 return res;
ram54288 0:a2cb7295a1f7 345 }
ram54288 0:a2cb7295a1f7 346
ram54288 0:a2cb7295a1f7 347 const M2MResourceList& M2MObjectInstance::resources() const
ram54288 0:a2cb7295a1f7 348 {
ram54288 0:a2cb7295a1f7 349 return _resource_list;
ram54288 0:a2cb7295a1f7 350 }
ram54288 0:a2cb7295a1f7 351
ram54288 0:a2cb7295a1f7 352 uint16_t M2MObjectInstance::resource_count() const
ram54288 0:a2cb7295a1f7 353 {
ram54288 0:a2cb7295a1f7 354 uint16_t count = 0;
ram54288 0:a2cb7295a1f7 355 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 356 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 357 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 358 for ( ; it != _resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 359 if((*it)->supports_multiple_instances()) {
ram54288 0:a2cb7295a1f7 360 count += (*it)->resource_instance_count();
ram54288 0:a2cb7295a1f7 361 } else {
ram54288 0:a2cb7295a1f7 362 count++;
ram54288 0:a2cb7295a1f7 363 }
ram54288 0:a2cb7295a1f7 364 }
ram54288 0:a2cb7295a1f7 365 }
ram54288 0:a2cb7295a1f7 366 return count;
ram54288 0:a2cb7295a1f7 367 }
ram54288 0:a2cb7295a1f7 368
ram54288 0:a2cb7295a1f7 369 uint16_t M2MObjectInstance::resource_count(const String& resource) const
ram54288 0:a2cb7295a1f7 370 {
ram54288 0:a2cb7295a1f7 371
ram54288 0:a2cb7295a1f7 372 return resource_count(resource.c_str());
ram54288 0:a2cb7295a1f7 373 }
ram54288 0:a2cb7295a1f7 374
ram54288 0:a2cb7295a1f7 375 uint16_t M2MObjectInstance::resource_count(const char *resource) const
ram54288 0:a2cb7295a1f7 376 {
ram54288 0:a2cb7295a1f7 377 uint16_t count = 0;
ram54288 0:a2cb7295a1f7 378 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 379 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 380 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 381 for ( ; it != _resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 382 if(strcmp((*it)->name(), resource) == 0) {
ram54288 0:a2cb7295a1f7 383 if((*it)->supports_multiple_instances()) {
ram54288 0:a2cb7295a1f7 384 count += (*it)->resource_instance_count();
ram54288 0:a2cb7295a1f7 385 } else {
ram54288 0:a2cb7295a1f7 386 count++;
ram54288 0:a2cb7295a1f7 387 }
ram54288 0:a2cb7295a1f7 388 }
ram54288 0:a2cb7295a1f7 389 }
ram54288 0:a2cb7295a1f7 390 }
ram54288 0:a2cb7295a1f7 391 return count;
ram54288 0:a2cb7295a1f7 392 }
ram54288 0:a2cb7295a1f7 393
ram54288 0:a2cb7295a1f7 394 M2MBase::BaseType M2MObjectInstance::base_type() const
ram54288 0:a2cb7295a1f7 395 {
ram54288 0:a2cb7295a1f7 396 return M2MBase::base_type();
ram54288 0:a2cb7295a1f7 397 }
ram54288 0:a2cb7295a1f7 398
ram54288 0:a2cb7295a1f7 399 void M2MObjectInstance::add_observation_level(M2MBase::Observation observation_level)
ram54288 0:a2cb7295a1f7 400 {
ram54288 0:a2cb7295a1f7 401 M2MBase::add_observation_level(observation_level);
ram54288 0:a2cb7295a1f7 402 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 403 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 404 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 405 for ( ; it != _resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 406 (*it)->add_observation_level(observation_level);
ram54288 0:a2cb7295a1f7 407 }
ram54288 0:a2cb7295a1f7 408 }
ram54288 0:a2cb7295a1f7 409 }
ram54288 0:a2cb7295a1f7 410
ram54288 0:a2cb7295a1f7 411 void M2MObjectInstance::remove_observation_level(M2MBase::Observation observation_level)
ram54288 0:a2cb7295a1f7 412 {
ram54288 0:a2cb7295a1f7 413 M2MBase::remove_observation_level(observation_level);
ram54288 0:a2cb7295a1f7 414 if(!_resource_list.empty()) {
ram54288 0:a2cb7295a1f7 415 M2MResourceList::const_iterator it;
ram54288 0:a2cb7295a1f7 416 it = _resource_list.begin();
ram54288 0:a2cb7295a1f7 417 for ( ; it != _resource_list.end(); it++ ) {
ram54288 0:a2cb7295a1f7 418 (*it)->remove_observation_level(observation_level);
ram54288 0:a2cb7295a1f7 419 }
ram54288 0:a2cb7295a1f7 420 }
ram54288 0:a2cb7295a1f7 421 }
ram54288 0:a2cb7295a1f7 422
ram54288 0:a2cb7295a1f7 423 sn_coap_hdr_s* M2MObjectInstance::handle_get_request(nsdl_s *nsdl,
ram54288 0:a2cb7295a1f7 424 sn_coap_hdr_s *received_coap_header,
ram54288 0:a2cb7295a1f7 425 M2MObservationHandler *observation_handler)
ram54288 0:a2cb7295a1f7 426 {
ram54288 0:a2cb7295a1f7 427 tr_debug("M2MObjectInstance::handle_get_request()");
ram54288 0:a2cb7295a1f7 428 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
ram54288 0:a2cb7295a1f7 429 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
ram54288 0:a2cb7295a1f7 430 received_coap_header,
ram54288 0:a2cb7295a1f7 431 msg_code);
ram54288 0:a2cb7295a1f7 432 uint8_t * data = NULL;
ram54288 0:a2cb7295a1f7 433 uint32_t data_length = 0;
ram54288 0:a2cb7295a1f7 434 if(received_coap_header) {
ram54288 0:a2cb7295a1f7 435 // process the GET if we have registered a callback for it
ram54288 0:a2cb7295a1f7 436 if ((operation() & SN_GRS_GET_ALLOWED) != 0) {
ram54288 0:a2cb7295a1f7 437 if(coap_response) {
ram54288 0:a2cb7295a1f7 438 uint16_t coap_content_type = 0;
ram54288 0:a2cb7295a1f7 439 bool content_type_present = false;
ram54288 0:a2cb7295a1f7 440
ram54288 0:a2cb7295a1f7 441 if(received_coap_header->content_format != COAP_CT_NONE) {
ram54288 0:a2cb7295a1f7 442 content_type_present = true;
ram54288 0:a2cb7295a1f7 443 coap_content_type = received_coap_header->content_format;
ram54288 0:a2cb7295a1f7 444 }
ram54288 0:a2cb7295a1f7 445 if(!content_type_present &&
ram54288 0:a2cb7295a1f7 446 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
ram54288 0:a2cb7295a1f7 447 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
ram54288 0:a2cb7295a1f7 448 }
ram54288 0:a2cb7295a1f7 449
ram54288 0:a2cb7295a1f7 450 tr_debug("M2MObjectInstance::handle_get_request() - Request Content-Type %d", coap_content_type);
ram54288 0:a2cb7295a1f7 451 if (coap_response->content_format == COAP_CT_NONE) {
ram54288 0:a2cb7295a1f7 452 coap_response->content_format = sn_coap_content_format_e(coap_content_type);
ram54288 0:a2cb7295a1f7 453
ram54288 0:a2cb7295a1f7 454 if (coap_response->content_format != COAP_CT_NONE) {
ram54288 0:a2cb7295a1f7 455 set_coap_content_type(coap_content_type);
ram54288 0:a2cb7295a1f7 456 }
ram54288 0:a2cb7295a1f7 457 }
ram54288 0:a2cb7295a1f7 458 // fill in the CoAP response payload
ram54288 0:a2cb7295a1f7 459 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
ram54288 0:a2cb7295a1f7 460 M2MTLVSerializer serializer;
ram54288 0:a2cb7295a1f7 461 data = serializer.serialize(_resource_list, data_length);
ram54288 0:a2cb7295a1f7 462 } else {
ram54288 0:a2cb7295a1f7 463 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
ram54288 0:a2cb7295a1f7 464 }
ram54288 0:a2cb7295a1f7 465
ram54288 0:a2cb7295a1f7 466 coap_response->payload_len = data_length;
ram54288 0:a2cb7295a1f7 467 coap_response->payload_ptr = data;
ram54288 0:a2cb7295a1f7 468
ram54288 0:a2cb7295a1f7 469 if(data) {
ram54288 0:a2cb7295a1f7 470 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
ram54288 0:a2cb7295a1f7 471
ram54288 0:a2cb7295a1f7 472 coap_response->options_list_ptr->max_age = max_age();
ram54288 0:a2cb7295a1f7 473
ram54288 0:a2cb7295a1f7 474 if(received_coap_header->options_list_ptr) {
ram54288 0:a2cb7295a1f7 475 if(received_coap_header->options_list_ptr->observe != -1) {
ram54288 0:a2cb7295a1f7 476 if (is_observable()) {
ram54288 0:a2cb7295a1f7 477 uint32_t number = 0;
ram54288 0:a2cb7295a1f7 478 uint8_t observe_option = 0;
ram54288 0:a2cb7295a1f7 479 observe_option = received_coap_header->options_list_ptr->observe;
ram54288 0:a2cb7295a1f7 480 if(START_OBSERVATION == observe_option) {
ram54288 0:a2cb7295a1f7 481 tr_debug("M2MObjectInstance::handle_get_request - Starts Observation");
ram54288 0:a2cb7295a1f7 482 // If the observe length is 0 means register for observation.
ram54288 0:a2cb7295a1f7 483 if(received_coap_header->options_list_ptr->observe != -1) {
ram54288 0:a2cb7295a1f7 484 number = received_coap_header->options_list_ptr->observe;
ram54288 0:a2cb7295a1f7 485 }
ram54288 0:a2cb7295a1f7 486 if(received_coap_header->token_ptr) {
ram54288 0:a2cb7295a1f7 487 tr_debug("M2MObjectInstance::handle_get_request - Sets Observation Token to resource");
ram54288 0:a2cb7295a1f7 488 set_observation_token(received_coap_header->token_ptr,
ram54288 0:a2cb7295a1f7 489 received_coap_header->token_len);
ram54288 0:a2cb7295a1f7 490 }
ram54288 0:a2cb7295a1f7 491
ram54288 0:a2cb7295a1f7 492 // If the observe value is 0 means register for observation.
ram54288 0:a2cb7295a1f7 493 if(number == 0) {
ram54288 0:a2cb7295a1f7 494 tr_debug("M2MObjectInstance::handle_get_request - Put Resource under Observation");
ram54288 0:a2cb7295a1f7 495 set_under_observation(true,observation_handler);
ram54288 0:a2cb7295a1f7 496 add_observation_level(M2MBase::OI_Attribute);
ram54288 0:a2cb7295a1f7 497 coap_response->options_list_ptr->observe = observation_number();
ram54288 0:a2cb7295a1f7 498 }
ram54288 0:a2cb7295a1f7 499 } else if (STOP_OBSERVATION == observe_option) {
ram54288 0:a2cb7295a1f7 500 tr_debug("M2MObjectInstance::handle_get_request - Stops Observation");
ram54288 0:a2cb7295a1f7 501 set_under_observation(false,NULL);
ram54288 0:a2cb7295a1f7 502 remove_observation_level(M2MBase::OI_Attribute);
ram54288 0:a2cb7295a1f7 503
ram54288 0:a2cb7295a1f7 504 }
ram54288 0:a2cb7295a1f7 505 msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
ram54288 0:a2cb7295a1f7 506 }
ram54288 0:a2cb7295a1f7 507 else {
ram54288 0:a2cb7295a1f7 508 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 509 }
ram54288 0:a2cb7295a1f7 510 }
ram54288 0:a2cb7295a1f7 511 }
ram54288 0:a2cb7295a1f7 512 } else {
ram54288 0:a2cb7295a1f7 513 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT; // Content format not supported
ram54288 0:a2cb7295a1f7 514 }
ram54288 0:a2cb7295a1f7 515 }
ram54288 0:a2cb7295a1f7 516 }else {
ram54288 0:a2cb7295a1f7 517 tr_error("M2MObjectInstance::handle_get_request - Return COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
ram54288 0:a2cb7295a1f7 518 // Operation is not allowed.
ram54288 0:a2cb7295a1f7 519 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 520 }
ram54288 0:a2cb7295a1f7 521 } else {
ram54288 0:a2cb7295a1f7 522 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 523 }
ram54288 0:a2cb7295a1f7 524 if(coap_response) {
ram54288 0:a2cb7295a1f7 525 coap_response->msg_code = msg_code;
ram54288 0:a2cb7295a1f7 526 }
ram54288 0:a2cb7295a1f7 527 return coap_response;
ram54288 0:a2cb7295a1f7 528 }
ram54288 0:a2cb7295a1f7 529
ram54288 0:a2cb7295a1f7 530 sn_coap_hdr_s* M2MObjectInstance::handle_put_request(nsdl_s *nsdl,
ram54288 0:a2cb7295a1f7 531 sn_coap_hdr_s *received_coap_header,
ram54288 0:a2cb7295a1f7 532 M2MObservationHandler *observation_handler,
ram54288 0:a2cb7295a1f7 533 bool &/*execute_value_updated*/)
ram54288 0:a2cb7295a1f7 534 {
ram54288 0:a2cb7295a1f7 535 tr_debug("M2MObjectInstance::handle_put_request()");
ram54288 0:a2cb7295a1f7 536 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
ram54288 0:a2cb7295a1f7 537 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
ram54288 0:a2cb7295a1f7 538 received_coap_header,
ram54288 0:a2cb7295a1f7 539 msg_code);;
ram54288 0:a2cb7295a1f7 540 if(received_coap_header) {
ram54288 0:a2cb7295a1f7 541 uint16_t coap_content_type = 0;
ram54288 0:a2cb7295a1f7 542 bool content_type_present = false;
ram54288 0:a2cb7295a1f7 543 if(received_coap_header->content_format != COAP_CT_NONE) {
ram54288 0:a2cb7295a1f7 544 content_type_present = true;
ram54288 0:a2cb7295a1f7 545 if(coap_response) {
ram54288 0:a2cb7295a1f7 546 coap_content_type = received_coap_header->content_format;
ram54288 0:a2cb7295a1f7 547 }
ram54288 0:a2cb7295a1f7 548 }
ram54288 0:a2cb7295a1f7 549 if(received_coap_header->options_list_ptr &&
ram54288 0:a2cb7295a1f7 550 received_coap_header->options_list_ptr->uri_query_ptr) {
ram54288 0:a2cb7295a1f7 551 char *query = (char*)alloc_string_copy(received_coap_header->options_list_ptr->uri_query_ptr,
ram54288 0:a2cb7295a1f7 552 received_coap_header->options_list_ptr->uri_query_len);
ram54288 0:a2cb7295a1f7 553 if (query){
ram54288 0:a2cb7295a1f7 554 tr_debug("M2MObjectInstance::handle_put_request() - Query %s", query);
ram54288 0:a2cb7295a1f7 555 // if anything was updated, re-initialize the stored notification attributes
ram54288 0:a2cb7295a1f7 556 if (!handle_observation_attribute(query)){
ram54288 0:a2cb7295a1f7 557 tr_debug("M2MObjectInstance::handle_put_request() - Invalid query");
ram54288 0:a2cb7295a1f7 558 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST; // 4.00
ram54288 0:a2cb7295a1f7 559 } else {
ram54288 0:a2cb7295a1f7 560 msg_code =COAP_MSG_CODE_RESPONSE_CHANGED;
ram54288 0:a2cb7295a1f7 561 }
ram54288 0:a2cb7295a1f7 562 free(query);
ram54288 0:a2cb7295a1f7 563 }
ram54288 0:a2cb7295a1f7 564 } else if ((operation() & SN_GRS_PUT_ALLOWED) != 0) {
ram54288 0:a2cb7295a1f7 565 if(!content_type_present &&
ram54288 0:a2cb7295a1f7 566 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
ram54288 0:a2cb7295a1f7 567 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
ram54288 0:a2cb7295a1f7 568 }
ram54288 0:a2cb7295a1f7 569
ram54288 0:a2cb7295a1f7 570 tr_debug("M2MObjectInstance::handle_put_request() - Request Content-Type %d", coap_content_type);
ram54288 0:a2cb7295a1f7 571
ram54288 0:a2cb7295a1f7 572 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
ram54288 0:a2cb7295a1f7 573 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
ram54288 0:a2cb7295a1f7 574 M2MTLVDeserializer deserializer;
ram54288 0:a2cb7295a1f7 575 if(received_coap_header->payload_ptr) {
ram54288 0:a2cb7295a1f7 576 error = deserializer.deserialize_resources(received_coap_header->payload_ptr,
ram54288 0:a2cb7295a1f7 577 received_coap_header->payload_len,
ram54288 0:a2cb7295a1f7 578 *this,
ram54288 0:a2cb7295a1f7 579 M2MTLVDeserializer::Put);
ram54288 0:a2cb7295a1f7 580 switch(error) {
ram54288 0:a2cb7295a1f7 581 case M2MTLVDeserializer::None:
ram54288 0:a2cb7295a1f7 582 if(observation_handler) {
ram54288 0:a2cb7295a1f7 583 observation_handler->value_updated(this);
ram54288 0:a2cb7295a1f7 584 }
ram54288 0:a2cb7295a1f7 585 msg_code = COAP_MSG_CODE_RESPONSE_CHANGED;
ram54288 0:a2cb7295a1f7 586 break;
ram54288 0:a2cb7295a1f7 587 case M2MTLVDeserializer::NotFound:
ram54288 0:a2cb7295a1f7 588 msg_code = COAP_MSG_CODE_RESPONSE_NOT_FOUND;
ram54288 0:a2cb7295a1f7 589 break;
ram54288 0:a2cb7295a1f7 590 case M2MTLVDeserializer::NotAllowed:
ram54288 0:a2cb7295a1f7 591 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 592 break;
ram54288 0:a2cb7295a1f7 593 case M2MTLVDeserializer::NotValid:
ram54288 0:a2cb7295a1f7 594 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:a2cb7295a1f7 595 break;
ram54288 0:a2cb7295a1f7 596 }
ram54288 0:a2cb7295a1f7 597 }
ram54288 0:a2cb7295a1f7 598 } else {
ram54288 0:a2cb7295a1f7 599 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
ram54288 0:a2cb7295a1f7 600 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
ram54288 0:a2cb7295a1f7 601 } else {
ram54288 0:a2cb7295a1f7 602 // Operation is not allowed.
ram54288 0:a2cb7295a1f7 603 tr_error("M2MObjectInstance::handle_put_request() - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
ram54288 0:a2cb7295a1f7 604 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 605 }
ram54288 0:a2cb7295a1f7 606 } else {
ram54288 0:a2cb7295a1f7 607 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 608 }
ram54288 0:a2cb7295a1f7 609 if(coap_response) {
ram54288 0:a2cb7295a1f7 610 coap_response->msg_code = msg_code;
ram54288 0:a2cb7295a1f7 611 }
ram54288 0:a2cb7295a1f7 612 return coap_response;
ram54288 0:a2cb7295a1f7 613 }
ram54288 0:a2cb7295a1f7 614
ram54288 0:a2cb7295a1f7 615
ram54288 0:a2cb7295a1f7 616
ram54288 0:a2cb7295a1f7 617
ram54288 0:a2cb7295a1f7 618 sn_coap_hdr_s* M2MObjectInstance::handle_post_request(nsdl_s *nsdl,
ram54288 0:a2cb7295a1f7 619 sn_coap_hdr_s *received_coap_header,
ram54288 0:a2cb7295a1f7 620 M2MObservationHandler *observation_handler,
ram54288 0:a2cb7295a1f7 621 bool &execute_value_updated,
ram54288 0:a2cb7295a1f7 622 sn_nsdl_addr_s *)
ram54288 0:a2cb7295a1f7 623 {
ram54288 0:a2cb7295a1f7 624 tr_debug("M2MObjectInstance::handle_post_request()");
ram54288 0:a2cb7295a1f7 625 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
ram54288 0:a2cb7295a1f7 626 sn_coap_hdr_s * coap_response = sn_nsdl_build_response(nsdl,
ram54288 0:a2cb7295a1f7 627 received_coap_header,
ram54288 0:a2cb7295a1f7 628 msg_code);
ram54288 0:a2cb7295a1f7 629 if(received_coap_header) {
ram54288 0:a2cb7295a1f7 630 if ((operation() & SN_GRS_POST_ALLOWED) != 0) {
ram54288 0:a2cb7295a1f7 631 uint16_t coap_content_type = 0;
ram54288 0:a2cb7295a1f7 632 bool content_type_present = false;
ram54288 0:a2cb7295a1f7 633 if(received_coap_header->content_format != COAP_CT_NONE) {
ram54288 0:a2cb7295a1f7 634 content_type_present = true;
ram54288 0:a2cb7295a1f7 635 if(coap_response) {
ram54288 0:a2cb7295a1f7 636 coap_content_type = received_coap_header->content_format;
ram54288 0:a2cb7295a1f7 637 }
ram54288 0:a2cb7295a1f7 638 }
ram54288 0:a2cb7295a1f7 639 if(!content_type_present &&
ram54288 0:a2cb7295a1f7 640 M2MBase::coap_content_type() == COAP_CONTENT_OMA_TLV_TYPE) {
ram54288 0:a2cb7295a1f7 641 coap_content_type = COAP_CONTENT_OMA_TLV_TYPE;
ram54288 0:a2cb7295a1f7 642 }
ram54288 0:a2cb7295a1f7 643
ram54288 0:a2cb7295a1f7 644 tr_debug("M2MObjectInstance::handle_post_request() - Request Content-Type %d", coap_content_type);
ram54288 0:a2cb7295a1f7 645
ram54288 0:a2cb7295a1f7 646 if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type) {
ram54288 0:a2cb7295a1f7 647 M2MTLVDeserializer deserializer;
ram54288 0:a2cb7295a1f7 648 M2MTLVDeserializer::Error error = M2MTLVDeserializer::None;
ram54288 0:a2cb7295a1f7 649 error = deserializer.deserialize_resources(received_coap_header->payload_ptr,
ram54288 0:a2cb7295a1f7 650 received_coap_header->payload_len,
ram54288 0:a2cb7295a1f7 651 *this,
ram54288 0:a2cb7295a1f7 652 M2MTLVDeserializer::Post);
ram54288 0:a2cb7295a1f7 653
ram54288 0:a2cb7295a1f7 654 uint16_t instance_id = deserializer.instance_id(received_coap_header->payload_ptr);
ram54288 0:a2cb7295a1f7 655 switch(error) {
ram54288 0:a2cb7295a1f7 656 case M2MTLVDeserializer::None:
ram54288 0:a2cb7295a1f7 657 if(observation_handler) {
ram54288 0:a2cb7295a1f7 658 execute_value_updated = true;
ram54288 0:a2cb7295a1f7 659 }
ram54288 0:a2cb7295a1f7 660 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
ram54288 0:a2cb7295a1f7 661
ram54288 0:a2cb7295a1f7 662 if (coap_response->options_list_ptr) {
ram54288 0:a2cb7295a1f7 663
ram54288 0:a2cb7295a1f7 664 StringBuffer<MAX_PATH_SIZE_3> obj_name;
ram54288 0:a2cb7295a1f7 665 if(!build_path(obj_name, M2MBase::name(), M2MBase::instance_id(), instance_id))
ram54288 0:a2cb7295a1f7 666 {
ram54288 0:a2cb7295a1f7 667 msg_code = COAP_MSG_CODE_RESPONSE_INTERNAL_SERVER_ERROR;
ram54288 0:a2cb7295a1f7 668 break;
ram54288 0:a2cb7295a1f7 669 }
ram54288 0:a2cb7295a1f7 670
ram54288 0:a2cb7295a1f7 671 coap_response->options_list_ptr->location_path_len = obj_name.get_size();
ram54288 0:a2cb7295a1f7 672 coap_response->options_list_ptr->location_path_ptr =
ram54288 0:a2cb7295a1f7 673 alloc_string_copy((uint8_t*)obj_name.c_str(),
ram54288 0:a2cb7295a1f7 674 coap_response->options_list_ptr->location_path_len);
ram54288 0:a2cb7295a1f7 675 // todo: handle allocation error
ram54288 0:a2cb7295a1f7 676 }
ram54288 0:a2cb7295a1f7 677 msg_code = COAP_MSG_CODE_RESPONSE_CREATED;
ram54288 0:a2cb7295a1f7 678 break;
ram54288 0:a2cb7295a1f7 679 case M2MTLVDeserializer::NotAllowed:
ram54288 0:a2cb7295a1f7 680 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 681 break;
ram54288 0:a2cb7295a1f7 682 case M2MTLVDeserializer::NotValid:
ram54288 0:a2cb7295a1f7 683 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
ram54288 0:a2cb7295a1f7 684 break;
ram54288 0:a2cb7295a1f7 685 default:
ram54288 0:a2cb7295a1f7 686 break;
ram54288 0:a2cb7295a1f7 687 }
ram54288 0:a2cb7295a1f7 688 } else {
ram54288 0:a2cb7295a1f7 689 msg_code =COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
ram54288 0:a2cb7295a1f7 690 } // if(COAP_CONTENT_OMA_TLV_TYPE == coap_content_type)
ram54288 0:a2cb7295a1f7 691 } else {
ram54288 0:a2cb7295a1f7 692 // Operation is not allowed.
ram54288 0:a2cb7295a1f7 693 tr_error("M2MObjectInstance::handle_post_request() - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
ram54288 0:a2cb7295a1f7 694 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 695 }
ram54288 0:a2cb7295a1f7 696 } else {
ram54288 0:a2cb7295a1f7 697 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
ram54288 0:a2cb7295a1f7 698 }
ram54288 0:a2cb7295a1f7 699 if(coap_response) {
ram54288 0:a2cb7295a1f7 700 coap_response->msg_code = msg_code;
ram54288 0:a2cb7295a1f7 701 }
ram54288 0:a2cb7295a1f7 702 return coap_response;
ram54288 0:a2cb7295a1f7 703 }
ram54288 0:a2cb7295a1f7 704
ram54288 0:a2cb7295a1f7 705 void M2MObjectInstance::notification_update(M2MBase::Observation observation_level)
ram54288 0:a2cb7295a1f7 706 {
ram54288 0:a2cb7295a1f7 707 tr_debug("M2MObjectInstance::notification_update() - level(%d)", observation_level);
ram54288 0:a2cb7295a1f7 708 if((M2MBase::O_Attribute & observation_level) == M2MBase::O_Attribute) {
ram54288 0:a2cb7295a1f7 709 tr_debug("M2MObjectInstance::notification_update() - object callback");
ram54288 0:a2cb7295a1f7 710 _parent.notification_update(instance_id());
ram54288 0:a2cb7295a1f7 711 }
ram54288 0:a2cb7295a1f7 712 if((M2MBase::OI_Attribute & observation_level) == M2MBase::OI_Attribute) {
ram54288 0:a2cb7295a1f7 713 tr_debug("M2MObjectInstance::notification_update() - object instance callback");
ram54288 0:a2cb7295a1f7 714 M2MReportHandler *report_handler = M2MBase::report_handler();
ram54288 0:a2cb7295a1f7 715 if(report_handler && is_under_observation()) {
ram54288 0:a2cb7295a1f7 716 report_handler->set_notification_trigger();
ram54288 0:a2cb7295a1f7 717 }
ram54288 0:a2cb7295a1f7 718
ram54288 0:a2cb7295a1f7 719 }
ram54288 0:a2cb7295a1f7 720 }