Pfp Cybersecurity (Aka Power Fingerprinting, Inc.) / Mbed OS pfp-emon-nxp

Important changes to repositories hosted on mbed.com

Mbed hosted mercurial repositories are deprecated and are due to be permanently deleted in July 2026.

To keep a copy of this software download the repository Zip archive or clone locally using Mercurial.

It is also possible to export all your personal repositories from the account settings page.

Dependencies:   FXAS21002 FXOS8700Q

simple-mbed-cloud-client/mbed-cloud-client/mbed-client/source/m2mresourcebase.cpp@0:977e87915078, 2019-08-28 (annotated)

Committer:
vithyat
Date:
Wed Aug 28 19:24:56 2019 +0000
Revision:
0:977e87915078
init

Who changed what in which revision?

UserRevisionLine numberNew contents of line
vithyat 0:977e87915078 1 /*
vithyat 0:977e87915078 2 * Copyright (c) 2015 ARM Limited. All rights reserved.
vithyat 0:977e87915078 3 * SPDX-License-Identifier: Apache-2.0
vithyat 0:977e87915078 4 * Licensed under the Apache License, Version 2.0 (the License); you may
vithyat 0:977e87915078 5 * not use this file except in compliance with the License.
vithyat 0:977e87915078 6 * You may obtain a copy of the License at
vithyat 0:977e87915078 7 *
vithyat 0:977e87915078 8 * http://www.apache.org/licenses/LICENSE-2.0
vithyat 0:977e87915078 9 *
vithyat 0:977e87915078 10 * Unless required by applicable law or agreed to in writing, software
vithyat 0:977e87915078 11 * distributed under the License is distributed on an AS IS BASIS, WITHOUT
vithyat 0:977e87915078 12 * WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
vithyat 0:977e87915078 13 * See the License for the specific language governing permissions and
vithyat 0:977e87915078 14 * limitations under the License.
vithyat 0:977e87915078 15 */
vithyat 0:977e87915078 16
vithyat 0:977e87915078 17 // Needed for PRIu64 on FreeRTOS
vithyat 0:977e87915078 18 #include <stdio.h>
vithyat 0:977e87915078 19 // Note: this macro is needed on armcc to get the the limit macros like UINT16_MAX
vithyat 0:977e87915078 20 #ifndef __STDC_LIMIT_MACROS
vithyat 0:977e87915078 21 #define __STDC_LIMIT_MACROS
vithyat 0:977e87915078 22 #endif
vithyat 0:977e87915078 23
vithyat 0:977e87915078 24 // Note: this macro is needed on armcc to get the the PRI*32 macros
vithyat 0:977e87915078 25 // from inttypes.h in a C++ code.
vithyat 0:977e87915078 26 #ifndef __STDC_FORMAT_MACROS
vithyat 0:977e87915078 27 #define __STDC_FORMAT_MACROS
vithyat 0:977e87915078 28 #endif
vithyat 0:977e87915078 29
vithyat 0:977e87915078 30 #include <stdlib.h>
vithyat 0:977e87915078 31 #include "mbed-client/m2mresourcebase.h"
vithyat 0:977e87915078 32 #include "mbed-client/m2mconstants.h"
vithyat 0:977e87915078 33 #include "mbed-client/m2mobservationhandler.h"
vithyat 0:977e87915078 34 #include "mbed-client/m2mobject.h"
vithyat 0:977e87915078 35 #include "mbed-client/m2mobjectinstance.h"
vithyat 0:977e87915078 36 #include "include/m2mcallbackstorage.h"
vithyat 0:977e87915078 37 #include "include/m2mreporthandler.h"
vithyat 0:977e87915078 38 #include "include/nsdllinker.h"
vithyat 0:977e87915078 39 #include "include/m2mtlvserializer.h"
vithyat 0:977e87915078 40 #include "mbed-client/m2mblockmessage.h"
vithyat 0:977e87915078 41 #include "mbed-trace/mbed_trace.h"
vithyat 0:977e87915078 42
vithyat 0:977e87915078 43 #define TRACE_GROUP "mClt"
vithyat 0:977e87915078 44
vithyat 0:977e87915078 45 // -9223372036854775808 - +9223372036854775807
vithyat 0:977e87915078 46 // max length of int64_t string is 20 bytes + nil
vithyat 0:977e87915078 47 #define REGISTRY_INT64_STRING_MAX_LEN 21
vithyat 0:977e87915078 48 // (space needed for -3.402823 × 10^38) + (magic decimal 6 digits added as no precision is added to "%f") + trailing zero
vithyat 0:977e87915078 49 #define REGISTRY_FLOAT_STRING_MAX_LEN 48
vithyat 0:977e87915078 50
vithyat 0:977e87915078 51
vithyat 0:977e87915078 52
vithyat 0:977e87915078 53 M2MResourceBase::M2MResourceBase(
vithyat 0:977e87915078 54 const String &res_name,
vithyat 0:977e87915078 55 M2MBase::Mode resource_mode,
vithyat 0:977e87915078 56 const String &resource_type,
vithyat 0:977e87915078 57 M2MBase::DataType type,
vithyat 0:977e87915078 58 char* path,
vithyat 0:977e87915078 59 bool external_blockwise_store,
vithyat 0:977e87915078 60 bool multiple_instance)
vithyat 0:977e87915078 61 : M2MBase(res_name,
vithyat 0:977e87915078 62 resource_mode,
vithyat 0:977e87915078 63 #ifndef DISABLE_RESOURCE_TYPE
vithyat 0:977e87915078 64 resource_type,
vithyat 0:977e87915078 65 #endif
vithyat 0:977e87915078 66 path,
vithyat 0:977e87915078 67 external_blockwise_store,
vithyat 0:977e87915078 68 multiple_instance,
vithyat 0:977e87915078 69 type)
vithyat 0:977e87915078 70 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 71 ,_block_message_data(NULL),
vithyat 0:977e87915078 72 #endif
vithyat 0:977e87915078 73 _notification_status(M2MResourceBase::INIT)
vithyat 0:977e87915078 74 {
vithyat 0:977e87915078 75 }
vithyat 0:977e87915078 76
vithyat 0:977e87915078 77 M2MResourceBase::M2MResourceBase(
vithyat 0:977e87915078 78 const String &res_name,
vithyat 0:977e87915078 79 M2MBase::Mode resource_mode,
vithyat 0:977e87915078 80 const String &resource_type,
vithyat 0:977e87915078 81 M2MBase::DataType type,
vithyat 0:977e87915078 82 const uint8_t *value,
vithyat 0:977e87915078 83 const uint8_t value_length,
vithyat 0:977e87915078 84 char* path,
vithyat 0:977e87915078 85 bool external_blockwise_store,
vithyat 0:977e87915078 86 bool multiple_instance)
vithyat 0:977e87915078 87 : M2MBase(res_name,
vithyat 0:977e87915078 88 resource_mode,
vithyat 0:977e87915078 89 #ifndef DISABLE_RESOURCE_TYPE
vithyat 0:977e87915078 90 resource_type,
vithyat 0:977e87915078 91 #endif
vithyat 0:977e87915078 92 path,
vithyat 0:977e87915078 93 external_blockwise_store,
vithyat 0:977e87915078 94 multiple_instance,
vithyat 0:977e87915078 95 type)
vithyat 0:977e87915078 96 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 97 ,_block_message_data(NULL),
vithyat 0:977e87915078 98 #endif
vithyat 0:977e87915078 99 _notification_status(M2MResourceBase::INIT)
vithyat 0:977e87915078 100 {
vithyat 0:977e87915078 101 M2MBase::set_base_type(M2MBase::ResourceInstance);
vithyat 0:977e87915078 102 if( value != NULL && value_length > 0 ) {
vithyat 0:977e87915078 103 sn_nsdl_dynamic_resource_parameters_s* res = get_nsdl_resource();
vithyat 0:977e87915078 104 res->resource = alloc_string_copy(value, value_length);
vithyat 0:977e87915078 105 res->resource_len = value_length;
vithyat 0:977e87915078 106 }
vithyat 0:977e87915078 107 }
vithyat 0:977e87915078 108
vithyat 0:977e87915078 109 M2MResourceBase::M2MResourceBase(
vithyat 0:977e87915078 110 const lwm2m_parameters_s* s,
vithyat 0:977e87915078 111 M2MBase::DataType /*type*/)
vithyat 0:977e87915078 112 : M2MBase(s)
vithyat 0:977e87915078 113 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 114 ,_block_message_data(NULL),
vithyat 0:977e87915078 115 #endif
vithyat 0:977e87915078 116 _notification_status(M2MResourceBase::INIT)
vithyat 0:977e87915078 117 {
vithyat 0:977e87915078 118 // we are not there yet for this check as this is called from M2MResource(): assert(base_type() == M2MBase::ResourceInstance);
vithyat 0:977e87915078 119 }
vithyat 0:977e87915078 120
vithyat 0:977e87915078 121 M2MResourceBase::~M2MResourceBase()
vithyat 0:977e87915078 122 {
vithyat 0:977e87915078 123 execute_callback* callback = (execute_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 124 M2MCallbackAssociation::M2MResourceInstanceExecuteCallback);
vithyat 0:977e87915078 125 delete callback;
vithyat 0:977e87915078 126
vithyat 0:977e87915078 127 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback2);
vithyat 0:977e87915078 128 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 129 incoming_block_message_callback *in_callback = (incoming_block_message_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 130 M2MCallbackAssociation::M2MResourceInstanceIncomingBlockMessageCallback);
vithyat 0:977e87915078 131 delete in_callback;
vithyat 0:977e87915078 132
vithyat 0:977e87915078 133 outgoing_block_message_callback *out_callback = (outgoing_block_message_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 134 M2MCallbackAssociation::M2MResourceInstanceOutgoingBlockMessageCallback);
vithyat 0:977e87915078 135 delete out_callback;
vithyat 0:977e87915078 136 #endif
vithyat 0:977e87915078 137
vithyat 0:977e87915078 138 notification_sent_callback *notif_callback = (notification_sent_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 139 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback);
vithyat 0:977e87915078 140 delete notif_callback;
vithyat 0:977e87915078 141
vithyat 0:977e87915078 142 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback2);
vithyat 0:977e87915078 143
vithyat 0:977e87915078 144 notification_status_callback *notif_status_callback = (notification_status_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 145 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback);
vithyat 0:977e87915078 146 delete notif_status_callback;
vithyat 0:977e87915078 147
vithyat 0:977e87915078 148 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback2);
vithyat 0:977e87915078 149
vithyat 0:977e87915078 150 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueReadCallback);
vithyat 0:977e87915078 151
vithyat 0:977e87915078 152 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueWriteCallback);
vithyat 0:977e87915078 153
vithyat 0:977e87915078 154 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 155 delete _block_message_data;
vithyat 0:977e87915078 156 #endif
vithyat 0:977e87915078 157 }
vithyat 0:977e87915078 158
vithyat 0:977e87915078 159 M2MResourceBase::ResourceType M2MResourceBase::resource_instance_type() const
vithyat 0:977e87915078 160 {
vithyat 0:977e87915078 161 M2MBase::lwm2m_parameters_s* param = M2MBase::get_lwm2m_parameters();
vithyat 0:977e87915078 162 M2MBase::DataType type = param->data_type;
vithyat 0:977e87915078 163 return convert_data_type(type);
vithyat 0:977e87915078 164 }
vithyat 0:977e87915078 165
vithyat 0:977e87915078 166
vithyat 0:977e87915078 167 bool M2MResourceBase::set_execute_function(execute_callback callback)
vithyat 0:977e87915078 168 {
vithyat 0:977e87915078 169 execute_callback* old_callback = (execute_callback*)M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback);
vithyat 0:977e87915078 170 delete old_callback;
vithyat 0:977e87915078 171 // XXX: create a copy of the copy of callback object. Perhaps it would better to
vithyat 0:977e87915078 172 // give a reference as parameter and just store that, as it would save some memory.
vithyat 0:977e87915078 173 execute_callback* new_callback = new execute_callback(callback);
vithyat 0:977e87915078 174
vithyat 0:977e87915078 175 return M2MCallbackStorage::add_callback(*this, new_callback, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback);
vithyat 0:977e87915078 176 }
vithyat 0:977e87915078 177
vithyat 0:977e87915078 178 bool M2MResourceBase::set_execute_function(execute_callback_2 callback)
vithyat 0:977e87915078 179 {
vithyat 0:977e87915078 180 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback2);
vithyat 0:977e87915078 181
vithyat 0:977e87915078 182 return M2MCallbackStorage::add_callback(*this, (void*)callback, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback2);
vithyat 0:977e87915078 183 }
vithyat 0:977e87915078 184
vithyat 0:977e87915078 185 bool M2MResourceBase::set_resource_read_callback(read_resource_value_callback callback, void *client_args)
vithyat 0:977e87915078 186 {
vithyat 0:977e87915078 187 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueReadCallback);
vithyat 0:977e87915078 188 M2MBase::lwm2m_parameters_s* param = M2MBase::get_lwm2m_parameters();
vithyat 0:977e87915078 189 param->read_write_callback_set = true;
vithyat 0:977e87915078 190 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 191 (void*)callback,
vithyat 0:977e87915078 192 M2MCallbackAssociation::M2MResourceBaseValueReadCallback,
vithyat 0:977e87915078 193 client_args);
vithyat 0:977e87915078 194
vithyat 0:977e87915078 195 }
vithyat 0:977e87915078 196
vithyat 0:977e87915078 197 bool M2MResourceBase::set_resource_write_callback(write_resource_value_callback callback, void *client_args)
vithyat 0:977e87915078 198 {
vithyat 0:977e87915078 199 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueWriteCallback);
vithyat 0:977e87915078 200 M2MBase::lwm2m_parameters_s* param = M2MBase::get_lwm2m_parameters();
vithyat 0:977e87915078 201 param->read_write_callback_set = true;
vithyat 0:977e87915078 202
vithyat 0:977e87915078 203 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 204 (void*)callback,
vithyat 0:977e87915078 205 M2MCallbackAssociation::M2MResourceBaseValueWriteCallback,
vithyat 0:977e87915078 206 client_args);
vithyat 0:977e87915078 207 }
vithyat 0:977e87915078 208
vithyat 0:977e87915078 209 void M2MResourceBase::clear_value()
vithyat 0:977e87915078 210 {
vithyat 0:977e87915078 211 tr_debug("M2MResourceBase::clear_value");
vithyat 0:977e87915078 212
vithyat 0:977e87915078 213 sn_nsdl_dynamic_resource_parameters_s* res = get_nsdl_resource();
vithyat 0:977e87915078 214 free(res->resource);
vithyat 0:977e87915078 215 res->resource = NULL;
vithyat 0:977e87915078 216 res->resource_len = 0;
vithyat 0:977e87915078 217
vithyat 0:977e87915078 218 report();
vithyat 0:977e87915078 219 }
vithyat 0:977e87915078 220
vithyat 0:977e87915078 221 bool M2MResourceBase::set_value_float(float value)
vithyat 0:977e87915078 222 {
vithyat 0:977e87915078 223 bool success;
vithyat 0:977e87915078 224 char buffer[REGISTRY_FLOAT_STRING_MAX_LEN];
vithyat 0:977e87915078 225
vithyat 0:977e87915078 226 // Convert value to string
vithyat 0:977e87915078 227 /* write the float value to a decimal number string and copy it into a buffer allocated for caller */
vithyat 0:977e87915078 228 uint32_t size = snprintf(buffer, REGISTRY_FLOAT_STRING_MAX_LEN, "%f", value);
vithyat 0:977e87915078 229
vithyat 0:977e87915078 230 success = set_value((const uint8_t*)buffer, size);
vithyat 0:977e87915078 231
vithyat 0:977e87915078 232 return success;
vithyat 0:977e87915078 233 }
vithyat 0:977e87915078 234
vithyat 0:977e87915078 235 bool M2MResourceBase::set_value(int64_t value)
vithyat 0:977e87915078 236 {
vithyat 0:977e87915078 237 bool success;
vithyat 0:977e87915078 238 char buffer[REGISTRY_INT64_STRING_MAX_LEN];
vithyat 0:977e87915078 239 uint32_t size = m2m::itoa_c(value, buffer);
vithyat 0:977e87915078 240
vithyat 0:977e87915078 241 success = set_value((const uint8_t*)buffer, size);
vithyat 0:977e87915078 242
vithyat 0:977e87915078 243 return success;
vithyat 0:977e87915078 244 }
vithyat 0:977e87915078 245
vithyat 0:977e87915078 246 bool M2MResourceBase::set_value(const uint8_t *value,
vithyat 0:977e87915078 247 const uint32_t value_length)
vithyat 0:977e87915078 248 {
vithyat 0:977e87915078 249 tr_debug("M2MResourceBase::set_value()");
vithyat 0:977e87915078 250 bool success = false;
vithyat 0:977e87915078 251 if( value != NULL && value_length > 0 ) {
vithyat 0:977e87915078 252 M2MBase::lwm2m_parameters_s* param = M2MBase::get_lwm2m_parameters();
vithyat 0:977e87915078 253 if (param->read_write_callback_set) {
vithyat 0:977e87915078 254 return write_resource_value(*this, value, value_length);
vithyat 0:977e87915078 255 } else {
vithyat 0:977e87915078 256 uint8_t *value_copy = alloc_string_copy(value, value_length);
vithyat 0:977e87915078 257 if (value_copy) {
vithyat 0:977e87915078 258 value_set_callback callback = (value_set_callback)M2MCallbackStorage::get_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueSetCallback);
vithyat 0:977e87915078 259 if (callback) {
vithyat 0:977e87915078 260 (*callback)((const M2MResourceBase*)this, value_copy, value_length);
vithyat 0:977e87915078 261 }
vithyat 0:977e87915078 262 else {
vithyat 0:977e87915078 263 update_value(value_copy, value_length);
vithyat 0:977e87915078 264 }
vithyat 0:977e87915078 265 success = true;
vithyat 0:977e87915078 266 }
vithyat 0:977e87915078 267 }
vithyat 0:977e87915078 268 }
vithyat 0:977e87915078 269 return success;
vithyat 0:977e87915078 270 }
vithyat 0:977e87915078 271
vithyat 0:977e87915078 272 bool M2MResourceBase::set_value_raw(uint8_t *value,
vithyat 0:977e87915078 273 const uint32_t value_length)
vithyat 0:977e87915078 274
vithyat 0:977e87915078 275 {
vithyat 0:977e87915078 276 tr_debug("M2MResourceBase::set_value_raw()");
vithyat 0:977e87915078 277 bool success = false;
vithyat 0:977e87915078 278 if( value != NULL && value_length > 0 ) {
vithyat 0:977e87915078 279 success = true;
vithyat 0:977e87915078 280 value_set_callback callback = (value_set_callback)M2MCallbackStorage::get_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueSetCallback);
vithyat 0:977e87915078 281 if (callback) {
vithyat 0:977e87915078 282 (*callback)((const M2MResourceBase*)this, value, value_length);
vithyat 0:977e87915078 283 }
vithyat 0:977e87915078 284 else {
vithyat 0:977e87915078 285 update_value(value, value_length);
vithyat 0:977e87915078 286 }
vithyat 0:977e87915078 287 }
vithyat 0:977e87915078 288 return success;
vithyat 0:977e87915078 289 }
vithyat 0:977e87915078 290
vithyat 0:977e87915078 291 void M2MResourceBase::update_value(uint8_t *value, const uint32_t value_length)
vithyat 0:977e87915078 292 {
vithyat 0:977e87915078 293 bool changed = has_value_changed(value,value_length);
vithyat 0:977e87915078 294 sn_nsdl_dynamic_resource_parameters_s* res = get_nsdl_resource();
vithyat 0:977e87915078 295 free(res->resource);
vithyat 0:977e87915078 296 res->resource = value;
vithyat 0:977e87915078 297 res->resource_len = value_length;
vithyat 0:977e87915078 298 if (changed) {
vithyat 0:977e87915078 299 report_value_change();
vithyat 0:977e87915078 300 }
vithyat 0:977e87915078 301 }
vithyat 0:977e87915078 302
vithyat 0:977e87915078 303 void M2MResourceBase::report()
vithyat 0:977e87915078 304 {
vithyat 0:977e87915078 305 M2MBase::Observation observation_level = M2MBase::observation_level();
vithyat 0:977e87915078 306 tr_debug("M2MResourceBase::report() - level %d", observation_level);
vithyat 0:977e87915078 307
vithyat 0:977e87915078 308 // We must combine the parent object/objectinstance/resource observation information
vithyat 0:977e87915078 309 // when determining if there is observation set or not.
vithyat 0:977e87915078 310 M2MObjectInstance& object_instance = get_parent_resource().get_parent_object_instance();
vithyat 0:977e87915078 311 int parent_observation_level = (int)object_instance.observation_level();
vithyat 0:977e87915078 312
vithyat 0:977e87915078 313 parent_observation_level |= (int)object_instance.get_parent_object().observation_level();
vithyat 0:977e87915078 314 parent_observation_level |= (int)get_parent_resource().observation_level();
vithyat 0:977e87915078 315 parent_observation_level |= (int)observation_level;
vithyat 0:977e87915078 316
vithyat 0:977e87915078 317 tr_debug("M2MResourceBase::report() - combined level %d", parent_observation_level);
vithyat 0:977e87915078 318
vithyat 0:977e87915078 319 if((M2MBase::O_Attribute & parent_observation_level) == M2MBase::O_Attribute ||
vithyat 0:977e87915078 320 (M2MBase::OI_Attribute & parent_observation_level) == M2MBase::OI_Attribute) {
vithyat 0:977e87915078 321 tr_debug("M2MResourceBase::report() -- object/instance level");
vithyat 0:977e87915078 322 object_instance.notification_update((M2MBase::Observation)parent_observation_level);
vithyat 0:977e87915078 323 }
vithyat 0:977e87915078 324
vithyat 0:977e87915078 325 if(M2MBase::Dynamic == mode() &&
vithyat 0:977e87915078 326 (M2MBase::R_Attribute & parent_observation_level) == M2MBase::R_Attribute) {
vithyat 0:977e87915078 327 tr_debug("M2MResourceBase::report() - resource level");
vithyat 0:977e87915078 328
vithyat 0:977e87915078 329 if (((resource_instance_type() != M2MResourceBase::STRING) &&
vithyat 0:977e87915078 330 (resource_instance_type() != M2MResourceBase::OPAQUE)) &&
vithyat 0:977e87915078 331 (observation_level != M2MBase::None)) {
vithyat 0:977e87915078 332 M2MReportHandler *report_handler = M2MBase::report_handler();
vithyat 0:977e87915078 333 if (report_handler && (is_observable() || is_auto_observable())) {
vithyat 0:977e87915078 334 if (resource_instance_type() == M2MResourceBase::FLOAT) {
vithyat 0:977e87915078 335 const float float_value = get_value_float();
vithyat 0:977e87915078 336 report_handler->set_value_float(float_value);
vithyat 0:977e87915078 337 } else {
vithyat 0:977e87915078 338 const int64_t int_value = get_value_int();
vithyat 0:977e87915078 339 report_handler->set_value_int(int_value);
vithyat 0:977e87915078 340 }
vithyat 0:977e87915078 341 }
vithyat 0:977e87915078 342 }
vithyat 0:977e87915078 343 else {
vithyat 0:977e87915078 344 if (base_type() == M2MBase::ResourceInstance) {
vithyat 0:977e87915078 345 const M2MResource& parent_resource = get_parent_resource();
vithyat 0:977e87915078 346 M2MReportHandler *report_handler = parent_resource.report_handler();
vithyat 0:977e87915078 347 if(report_handler && (parent_resource.is_observable() || parent_resource.is_auto_observable())) {
vithyat 0:977e87915078 348 report_handler->set_notification_trigger(parent_resource.get_parent_object_instance().instance_id());
vithyat 0:977e87915078 349 }
vithyat 0:977e87915078 350 }
vithyat 0:977e87915078 351 }
vithyat 0:977e87915078 352 } else if(M2MBase::Static == mode()) {
vithyat 0:977e87915078 353 M2MObservationHandler *obs_handler = observation_handler();
vithyat 0:977e87915078 354 if(obs_handler) {
vithyat 0:977e87915078 355 obs_handler->value_updated(this);
vithyat 0:977e87915078 356 }
vithyat 0:977e87915078 357 } else {
vithyat 0:977e87915078 358 if (is_observable() || is_auto_observable()) {
vithyat 0:977e87915078 359 tr_debug("M2MResourceBase::report() - resource %s is observable but not yet subscribed!", uri_path());
vithyat 0:977e87915078 360 }
vithyat 0:977e87915078 361 tr_debug("M2MResourceBase::report() - mode = %d, is_observable = %d", mode(), is_observable());
vithyat 0:977e87915078 362 }
vithyat 0:977e87915078 363 }
vithyat 0:977e87915078 364
vithyat 0:977e87915078 365 bool M2MResourceBase::has_value_changed(const uint8_t* value, const uint32_t value_len)
vithyat 0:977e87915078 366 {
vithyat 0:977e87915078 367 bool changed = false;
vithyat 0:977e87915078 368 sn_nsdl_dynamic_resource_parameters_s* res = get_nsdl_resource();
vithyat 0:977e87915078 369
vithyat 0:977e87915078 370 if(value_len != res->resource_len) {
vithyat 0:977e87915078 371 changed = true;
vithyat 0:977e87915078 372 } else if(value && !res->resource) {
vithyat 0:977e87915078 373 changed = true;
vithyat 0:977e87915078 374 } else if(res->resource && !value) {
vithyat 0:977e87915078 375 changed = true;
vithyat 0:977e87915078 376 } else {
vithyat 0:977e87915078 377 if (res->resource) {
vithyat 0:977e87915078 378 if (memcmp(value, res->resource, res->resource_len) != 0) {
vithyat 0:977e87915078 379 changed = true;
vithyat 0:977e87915078 380 }
vithyat 0:977e87915078 381 }
vithyat 0:977e87915078 382 }
vithyat 0:977e87915078 383 return changed;
vithyat 0:977e87915078 384 }
vithyat 0:977e87915078 385
vithyat 0:977e87915078 386 void M2MResourceBase::report_value_change()
vithyat 0:977e87915078 387 {
vithyat 0:977e87915078 388 if (resource_instance_type() == M2MResourceBase::STRING ||
vithyat 0:977e87915078 389 resource_instance_type() == M2MResourceBase::OPAQUE) {
vithyat 0:977e87915078 390 M2MReportHandler *report_handler = M2MBase::report_handler();
vithyat 0:977e87915078 391 if(report_handler && is_under_observation()) {
vithyat 0:977e87915078 392 report_handler->set_notification_trigger();
vithyat 0:977e87915078 393 }
vithyat 0:977e87915078 394 }
vithyat 0:977e87915078 395 report();
vithyat 0:977e87915078 396 }
vithyat 0:977e87915078 397
vithyat 0:977e87915078 398 void M2MResourceBase::execute(void *arguments)
vithyat 0:977e87915078 399 {
vithyat 0:977e87915078 400 // XXX: this line is expected by seven testcases and until this code hits master branch
vithyat 0:977e87915078 401 // the testcases can not be modified and we need to print the false information too.
vithyat 0:977e87915078 402 tr_debug("M2MResourceBase::execute");
vithyat 0:977e87915078 403
vithyat 0:977e87915078 404 execute_callback* callback = (execute_callback*)M2MCallbackStorage::get_callback(*this, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback);
vithyat 0:977e87915078 405
vithyat 0:977e87915078 406 if (callback) {
vithyat 0:977e87915078 407 (*callback)(arguments);
vithyat 0:977e87915078 408 }
vithyat 0:977e87915078 409
vithyat 0:977e87915078 410 execute_callback_2 callback2 = (execute_callback_2)M2MCallbackStorage::get_callback(*this, M2MCallbackAssociation::M2MResourceInstanceExecuteCallback2);
vithyat 0:977e87915078 411 if (callback2) {
vithyat 0:977e87915078 412 (*callback2)(arguments);
vithyat 0:977e87915078 413 }
vithyat 0:977e87915078 414 }
vithyat 0:977e87915078 415
vithyat 0:977e87915078 416 int M2MResourceBase::read_resource_value(const M2MResourceBase &resource, void *buffer, size_t *buffer_len)
vithyat 0:977e87915078 417 {
vithyat 0:977e87915078 418 tr_debug("M2MResourceBase::read_resource_value");
vithyat 0:977e87915078 419
vithyat 0:977e87915078 420 M2MCallbackAssociation* item = M2MCallbackStorage::get_association_item(resource,
vithyat 0:977e87915078 421 M2MCallbackAssociation::M2MResourceBaseValueReadCallback);
vithyat 0:977e87915078 422
vithyat 0:977e87915078 423 if (item) {
vithyat 0:977e87915078 424 read_resource_value_callback callback = (read_resource_value_callback)item->_callback;
vithyat 0:977e87915078 425 assert(callback);
vithyat 0:977e87915078 426 return (*callback)(resource, buffer, buffer_len, item->_client_args);
vithyat 0:977e87915078 427 } else {
vithyat 0:977e87915078 428 if (value_length() > *buffer_len) {
vithyat 0:977e87915078 429 return -1;
vithyat 0:977e87915078 430 } else {
vithyat 0:977e87915078 431 memcpy(buffer, value(), value_length());
vithyat 0:977e87915078 432 *buffer_len = value_length();
vithyat 0:977e87915078 433 return 0;
vithyat 0:977e87915078 434 }
vithyat 0:977e87915078 435 }
vithyat 0:977e87915078 436 }
vithyat 0:977e87915078 437
vithyat 0:977e87915078 438 bool M2MResourceBase::write_resource_value(const M2MResourceBase &resource, const uint8_t *buffer, const size_t buffer_size)
vithyat 0:977e87915078 439 {
vithyat 0:977e87915078 440 tr_debug("M2MResourceBase::write_resource_value");
vithyat 0:977e87915078 441 M2MCallbackAssociation* item = M2MCallbackStorage::get_association_item(resource,
vithyat 0:977e87915078 442 M2MCallbackAssociation::M2MResourceBaseValueWriteCallback);
vithyat 0:977e87915078 443 if (item) {
vithyat 0:977e87915078 444 write_resource_value_callback callback = (write_resource_value_callback)item->_callback;
vithyat 0:977e87915078 445 if (callback) {
vithyat 0:977e87915078 446 return (*callback)(resource, buffer, buffer_size, item->_client_args);
vithyat 0:977e87915078 447 }
vithyat 0:977e87915078 448 }
vithyat 0:977e87915078 449
vithyat 0:977e87915078 450 return false;
vithyat 0:977e87915078 451 }
vithyat 0:977e87915078 452
vithyat 0:977e87915078 453 void M2MResourceBase::get_value(uint8_t *&value, uint32_t &value_length)
vithyat 0:977e87915078 454 {
vithyat 0:977e87915078 455 value_length = 0;
vithyat 0:977e87915078 456 if(value) {
vithyat 0:977e87915078 457 free(value);
vithyat 0:977e87915078 458 value = NULL;
vithyat 0:977e87915078 459 }
vithyat 0:977e87915078 460
vithyat 0:977e87915078 461 sn_nsdl_dynamic_resource_parameters_s* res = get_nsdl_resource();
vithyat 0:977e87915078 462 if(res->resource && res->resource_len > 0) {
vithyat 0:977e87915078 463 value = alloc_string_copy(res->resource, res->resource_len);
vithyat 0:977e87915078 464 if(value) {
vithyat 0:977e87915078 465 value_length = res->resource_len;
vithyat 0:977e87915078 466 }
vithyat 0:977e87915078 467 }
vithyat 0:977e87915078 468 }
vithyat 0:977e87915078 469
vithyat 0:977e87915078 470 int64_t M2MResourceBase::get_value_int() const
vithyat 0:977e87915078 471 {
vithyat 0:977e87915078 472 int64_t value_int = 0;
vithyat 0:977e87915078 473
vithyat 0:977e87915078 474 const char *value_string = (char *)value();
vithyat 0:977e87915078 475 const uint32_t value_len = value_length();
vithyat 0:977e87915078 476
vithyat 0:977e87915078 477 if ((value_string) && (value_len <= REGISTRY_INT64_STRING_MAX_LEN)) {
vithyat 0:977e87915078 478
vithyat 0:977e87915078 479 // -9223372036854775808 - +9223372036854775807
vithyat 0:977e87915078 480 // max length of int64_t string is 20 bytes + nil
vithyat 0:977e87915078 481 // The +1 here is there in case the string was already zero terminated.
vithyat 0:977e87915078 482
vithyat 0:977e87915078 483
vithyat 0:977e87915078 484 bool success = String::convert_ascii_to_int(value_string, value_len, value_int);
vithyat 0:977e87915078 485 if (!success) {
vithyat 0:977e87915078 486 // note: the convert_ascii_to_int() actually allows one to pass the conversion
vithyat 0:977e87915078 487 // onwards, but this get_value_int() does not. Lets just dump error to log, but
vithyat 0:977e87915078 488 // do not log the value as that might be part of a attack. Same reason (valid or not)
vithyat 0:977e87915078 489 // is behind the selection of log level
vithyat 0:977e87915078 490 tr_warn("M2MResourceBase::get_value_int(): conversion failed");
vithyat 0:977e87915078 491 }
vithyat 0:977e87915078 492 }
vithyat 0:977e87915078 493 return value_int;
vithyat 0:977e87915078 494 }
vithyat 0:977e87915078 495
vithyat 0:977e87915078 496 String M2MResourceBase::get_value_string() const
vithyat 0:977e87915078 497 {
vithyat 0:977e87915078 498 // XXX: do a better constructor to avoid pointless malloc
vithyat 0:977e87915078 499 String value;
vithyat 0:977e87915078 500 if (get_nsdl_resource()->resource) {
vithyat 0:977e87915078 501 value.append_raw((char*)get_nsdl_resource()->resource, get_nsdl_resource()->resource_len);
vithyat 0:977e87915078 502 }
vithyat 0:977e87915078 503 return value;
vithyat 0:977e87915078 504 }
vithyat 0:977e87915078 505
vithyat 0:977e87915078 506 float M2MResourceBase::get_value_float() const
vithyat 0:977e87915078 507 {
vithyat 0:977e87915078 508 float value_float = 0;
vithyat 0:977e87915078 509
vithyat 0:977e87915078 510 const char *value_string = (char *)value();
vithyat 0:977e87915078 511 const uint32_t value_len = value_length();
vithyat 0:977e87915078 512
vithyat 0:977e87915078 513 if ((value_string) && (value_len <= REGISTRY_FLOAT_STRING_MAX_LEN)) {
vithyat 0:977e87915078 514
vithyat 0:977e87915078 515 // (space needed for -3.402823 × 10^38) + (magic decimal 6 digits added as no precision is added to "%f") + trailing zero
vithyat 0:977e87915078 516 // The +1 here is there in case the string was already zero terminated.
vithyat 0:977e87915078 517 char temp[REGISTRY_FLOAT_STRING_MAX_LEN + 1];
vithyat 0:977e87915078 518
vithyat 0:977e87915078 519 memcpy(temp, value_string, value_len);
vithyat 0:977e87915078 520 temp[value_len] = 0;
vithyat 0:977e87915078 521
vithyat 0:977e87915078 522 value_float = atof(temp);
vithyat 0:977e87915078 523 }
vithyat 0:977e87915078 524
vithyat 0:977e87915078 525 return value_float;
vithyat 0:977e87915078 526 }
vithyat 0:977e87915078 527
vithyat 0:977e87915078 528 uint8_t* M2MResourceBase::value() const
vithyat 0:977e87915078 529 {
vithyat 0:977e87915078 530 return get_nsdl_resource()->resource;
vithyat 0:977e87915078 531 }
vithyat 0:977e87915078 532
vithyat 0:977e87915078 533 uint32_t M2MResourceBase::value_length() const
vithyat 0:977e87915078 534 {
vithyat 0:977e87915078 535 return get_nsdl_resource()->resource_len;
vithyat 0:977e87915078 536 }
vithyat 0:977e87915078 537
vithyat 0:977e87915078 538 void M2MResourceBase::set_value_set_callback(value_set_callback callback)
vithyat 0:977e87915078 539 {
vithyat 0:977e87915078 540 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceBaseValueSetCallback);
vithyat 0:977e87915078 541 M2MCallbackStorage::add_callback(*this, (void*)callback, M2MCallbackAssociation::M2MResourceBaseValueSetCallback);
vithyat 0:977e87915078 542 }
vithyat 0:977e87915078 543
vithyat 0:977e87915078 544 sn_coap_hdr_s* M2MResourceBase::handle_get_request(nsdl_s *nsdl,
vithyat 0:977e87915078 545 sn_coap_hdr_s *received_coap_header,
vithyat 0:977e87915078 546 M2MObservationHandler *observation_handler)
vithyat 0:977e87915078 547 {
vithyat 0:977e87915078 548 tr_info("M2MResourceBase::handle_get_request()");
vithyat 0:977e87915078 549 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CONTENT;
vithyat 0:977e87915078 550 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
vithyat 0:977e87915078 551 received_coap_header,
vithyat 0:977e87915078 552 msg_code);
vithyat 0:977e87915078 553 if (received_coap_header) {
vithyat 0:977e87915078 554 // process the GET if we have registered a callback for it
vithyat 0:977e87915078 555 if ((operation() & M2MBase::GET_ALLOWED) != 0) {
vithyat 0:977e87915078 556 if (coap_response) {
vithyat 0:977e87915078 557 bool content_type_present = false;
vithyat 0:977e87915078 558 if (received_coap_header->options_list_ptr &&
vithyat 0:977e87915078 559 received_coap_header->options_list_ptr->accept != COAP_CT_NONE) {
vithyat 0:977e87915078 560 content_type_present = true;
vithyat 0:977e87915078 561 coap_response->content_format = received_coap_header->options_list_ptr->accept;
vithyat 0:977e87915078 562 set_coap_content_type(coap_response->content_format);
vithyat 0:977e87915078 563 }
vithyat 0:977e87915078 564 if (!content_type_present) {
vithyat 0:977e87915078 565 if (resource_instance_type() == M2MResourceInstance::OPAQUE) {
vithyat 0:977e87915078 566 coap_response->content_format = sn_coap_content_format_e(COAP_CONTENT_OMA_OPAQUE_TYPE);
vithyat 0:977e87915078 567 } else {
vithyat 0:977e87915078 568 coap_response->content_format = sn_coap_content_format_e(COAP_CONTENT_OMA_PLAIN_TEXT_TYPE);
vithyat 0:977e87915078 569 }
vithyat 0:977e87915078 570 }
vithyat 0:977e87915078 571 // fill in the CoAP response payload
vithyat 0:977e87915078 572 coap_response->payload_ptr = NULL;
vithyat 0:977e87915078 573 uint32_t payload_len = 0;
vithyat 0:977e87915078 574 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 575 //If handler exists it means that resource value is stored in application side
vithyat 0:977e87915078 576 if (block_message() && block_message()->is_block_message()) {
vithyat 0:977e87915078 577 outgoing_block_message_callback* outgoing_block_message_cb = (outgoing_block_message_callback*)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 578 M2MCallbackAssociation::M2MResourceInstanceOutgoingBlockMessageCallback);
vithyat 0:977e87915078 579 if (outgoing_block_message_cb) {
vithyat 0:977e87915078 580 String name = "";
vithyat 0:977e87915078 581 if (received_coap_header->uri_path_ptr != NULL &&
vithyat 0:977e87915078 582 received_coap_header->uri_path_len > 0) {
vithyat 0:977e87915078 583 name.append_raw((char *)received_coap_header->uri_path_ptr, received_coap_header->uri_path_len);
vithyat 0:977e87915078 584 }
vithyat 0:977e87915078 585 (*outgoing_block_message_cb)(name, coap_response->payload_ptr, payload_len);
vithyat 0:977e87915078 586 }
vithyat 0:977e87915078 587 } else {
vithyat 0:977e87915078 588 #endif
vithyat 0:977e87915078 589 if (coap_response->content_format == COAP_CONTENT_OMA_TLV_TYPE ||
vithyat 0:977e87915078 590 coap_response->content_format == COAP_CONTENT_OMA_TLV_TYPE_OLD) {
vithyat 0:977e87915078 591 coap_response->payload_ptr = M2MTLVSerializer::serialize(&get_parent_resource(), payload_len);
vithyat 0:977e87915078 592 } else {
vithyat 0:977e87915078 593 get_value(coap_response->payload_ptr,payload_len);
vithyat 0:977e87915078 594 }
vithyat 0:977e87915078 595 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 596 }
vithyat 0:977e87915078 597 #endif
vithyat 0:977e87915078 598 tr_debug("M2MResourceBase::handle_get_request() - Request Content-type: %d", coap_response->content_format);
vithyat 0:977e87915078 599 coap_response->payload_len = payload_len;
vithyat 0:977e87915078 600 coap_response->options_list_ptr = sn_nsdl_alloc_options_list(nsdl, coap_response);
vithyat 0:977e87915078 601 if (coap_response->options_list_ptr) {
vithyat 0:977e87915078 602 coap_response->options_list_ptr->max_age = max_age();
vithyat 0:977e87915078 603 }
vithyat 0:977e87915078 604
vithyat 0:977e87915078 605 if (received_coap_header->options_list_ptr) {
vithyat 0:977e87915078 606 if(received_coap_header->options_list_ptr->observe != -1) {
vithyat 0:977e87915078 607 handle_observation(nsdl, *received_coap_header, *coap_response, observation_handler, msg_code);
vithyat 0:977e87915078 608 }
vithyat 0:977e87915078 609 }
vithyat 0:977e87915078 610 }
vithyat 0:977e87915078 611 } else {
vithyat 0:977e87915078 612 tr_error("M2MResourceBase::handle_get_request - Return COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
vithyat 0:977e87915078 613 // Operation is not allowed.
vithyat 0:977e87915078 614 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
vithyat 0:977e87915078 615 }
vithyat 0:977e87915078 616 } else {
vithyat 0:977e87915078 617 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
vithyat 0:977e87915078 618 }
vithyat 0:977e87915078 619
vithyat 0:977e87915078 620 if (coap_response) {
vithyat 0:977e87915078 621 coap_response->msg_code = msg_code;
vithyat 0:977e87915078 622 }
vithyat 0:977e87915078 623
vithyat 0:977e87915078 624 return coap_response;
vithyat 0:977e87915078 625 }
vithyat 0:977e87915078 626
vithyat 0:977e87915078 627 sn_coap_hdr_s* M2MResourceBase::handle_put_request(nsdl_s *nsdl,
vithyat 0:977e87915078 628 sn_coap_hdr_s *received_coap_header,
vithyat 0:977e87915078 629 M2MObservationHandler *observation_handler,
vithyat 0:977e87915078 630 bool &execute_value_updated)
vithyat 0:977e87915078 631 {
vithyat 0:977e87915078 632 tr_info("M2MResourceBase::handle_put_request()");
vithyat 0:977e87915078 633
vithyat 0:977e87915078 634 sn_coap_msg_code_e msg_code = COAP_MSG_CODE_RESPONSE_CHANGED; // 2.04
vithyat 0:977e87915078 635 sn_coap_hdr_s *coap_response = sn_nsdl_build_response(nsdl,
vithyat 0:977e87915078 636 received_coap_header,
vithyat 0:977e87915078 637 msg_code);
vithyat 0:977e87915078 638 // process the PUT if we have registered a callback for it
vithyat 0:977e87915078 639 if(received_coap_header && coap_response) {
vithyat 0:977e87915078 640 uint16_t coap_content_type = 0;
vithyat 0:977e87915078 641 if(received_coap_header->content_format != COAP_CT_NONE) {
vithyat 0:977e87915078 642 coap_content_type = received_coap_header->content_format;
vithyat 0:977e87915078 643 }
vithyat 0:977e87915078 644 if(received_coap_header->options_list_ptr &&
vithyat 0:977e87915078 645 received_coap_header->options_list_ptr->uri_query_ptr) {
vithyat 0:977e87915078 646 char *query = (char*)alloc_string_copy(received_coap_header->options_list_ptr->uri_query_ptr,
vithyat 0:977e87915078 647 received_coap_header->options_list_ptr->uri_query_len);
vithyat 0:977e87915078 648 if (query){
vithyat 0:977e87915078 649 tr_info("M2MResourceBase::handle_put_request() - query %s", query);
vithyat 0:977e87915078 650
vithyat 0:977e87915078 651 // if anything was updated, re-initialize the stored notification attributes
vithyat 0:977e87915078 652 if (!handle_observation_attribute(query)){
vithyat 0:977e87915078 653 tr_error("M2MResourceBase::handle_put_request() - Invalid query");
vithyat 0:977e87915078 654 msg_code = COAP_MSG_CODE_RESPONSE_BAD_REQUEST;
vithyat 0:977e87915078 655 }
vithyat 0:977e87915078 656 free(query);
vithyat 0:977e87915078 657 }
vithyat 0:977e87915078 658 else {
vithyat 0:977e87915078 659 // memory allocation for query fails
vithyat 0:977e87915078 660 tr_error("M2MResourceBase::handle_put_request() - Out of memory !!!");
vithyat 0:977e87915078 661 msg_code = COAP_MSG_CODE_RESPONSE_INTERNAL_SERVER_ERROR; // 4.00
vithyat 0:977e87915078 662 }
vithyat 0:977e87915078 663 } else if ((operation() & M2MBase::PUT_ALLOWED) != 0) {
vithyat 0:977e87915078 664 tr_debug("M2MResourceBase::handle_put_request() - Request Content-type: %d", coap_content_type);
vithyat 0:977e87915078 665
vithyat 0:977e87915078 666 if(COAP_CONTENT_OMA_OPAQUE_TYPE != coap_content_type &&
vithyat 0:977e87915078 667 COAP_CONTENT_OMA_PLAIN_TEXT_TYPE != coap_content_type) {
vithyat 0:977e87915078 668 msg_code = COAP_MSG_CODE_RESPONSE_UNSUPPORTED_CONTENT_FORMAT;
vithyat 0:977e87915078 669 } else {
vithyat 0:977e87915078 670 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 671 if (block_message()) {
vithyat 0:977e87915078 672 block_message()->set_message_info(received_coap_header);
vithyat 0:977e87915078 673 if (block_message()->is_block_message()) {
vithyat 0:977e87915078 674 incoming_block_message_callback* incoming_block_message_cb = (incoming_block_message_callback*)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 675 M2MCallbackAssociation::M2MResourceInstanceIncomingBlockMessageCallback);
vithyat 0:977e87915078 676 if (incoming_block_message_cb) {
vithyat 0:977e87915078 677 (*incoming_block_message_cb)(_block_message_data);
vithyat 0:977e87915078 678 }
vithyat 0:977e87915078 679 if (block_message()->is_last_block()) {
vithyat 0:977e87915078 680 block_message()->clear_values();
vithyat 0:977e87915078 681 coap_response->coap_status = COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVED;
vithyat 0:977e87915078 682 } else {
vithyat 0:977e87915078 683 coap_response->coap_status = COAP_STATUS_PARSER_BLOCKWISE_MSG_RECEIVING;
vithyat 0:977e87915078 684 }
vithyat 0:977e87915078 685 if (block_message()->error_code() != M2MBlockMessage::ErrorNone) {
vithyat 0:977e87915078 686 block_message()->clear_values();
vithyat 0:977e87915078 687 }
vithyat 0:977e87915078 688 }
vithyat 0:977e87915078 689 }
vithyat 0:977e87915078 690 #endif
vithyat 0:977e87915078 691 // Firmware object uri path is limited to be max 255 bytes
vithyat 0:977e87915078 692 if ((strcmp(uri_path(), FIRMAWARE_PACKAGE_URI_PATH) == 0) &&
vithyat 0:977e87915078 693 received_coap_header->payload_len > 255) {
vithyat 0:977e87915078 694 msg_code = COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE;
vithyat 0:977e87915078 695 } else if ((strcmp(uri_path(), SERVER_LIFETIME_PATH) == 0)) {
vithyat 0:977e87915078 696 // Check that lifetime can't go below 60s
vithyat 0:977e87915078 697 if(received_coap_header->payload_ptr) {
vithyat 0:977e87915078 698 int64_t lifetime;
vithyat 0:977e87915078 699 bool success = String::convert_ascii_to_int((char*)received_coap_header->payload_ptr, received_coap_header->payload_len, lifetime);
vithyat 0:977e87915078 700 if ((success == false) || (lifetime < MINIMUM_REGISTRATION_TIME)) {
vithyat 0:977e87915078 701 tr_error("M2MResourceBase::handle_put_request() - lifetime value % " PRId32 " not acceptable", lifetime);
vithyat 0:977e87915078 702 msg_code = COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE;
vithyat 0:977e87915078 703 }
vithyat 0:977e87915078 704 } else {
vithyat 0:977e87915078 705 tr_error("M2MResourceBase::handle_put_request() - empty lifetime payload not acceptable");
vithyat 0:977e87915078 706 msg_code = COAP_MSG_CODE_RESPONSE_NOT_ACCEPTABLE;
vithyat 0:977e87915078 707 }
vithyat 0:977e87915078 708 }
vithyat 0:977e87915078 709
vithyat 0:977e87915078 710 // Do not update resource value in error case.
vithyat 0:977e87915078 711 if ((received_coap_header->payload_ptr) && (msg_code == COAP_MSG_CODE_RESPONSE_CHANGED)) {
vithyat 0:977e87915078 712 execute_value_updated = true;
vithyat 0:977e87915078 713 }
vithyat 0:977e87915078 714 }
vithyat 0:977e87915078 715 } else {
vithyat 0:977e87915078 716 // Operation is not allowed.
vithyat 0:977e87915078 717 tr_error("M2MResourceBase::handle_put_request() - COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED");
vithyat 0:977e87915078 718 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
vithyat 0:977e87915078 719 }
vithyat 0:977e87915078 720 } else {
vithyat 0:977e87915078 721 msg_code = COAP_MSG_CODE_RESPONSE_METHOD_NOT_ALLOWED;
vithyat 0:977e87915078 722 }
vithyat 0:977e87915078 723 if(coap_response) {
vithyat 0:977e87915078 724 coap_response->msg_code = msg_code;
vithyat 0:977e87915078 725 }
vithyat 0:977e87915078 726
vithyat 0:977e87915078 727 return coap_response;
vithyat 0:977e87915078 728 }
vithyat 0:977e87915078 729
vithyat 0:977e87915078 730
vithyat 0:977e87915078 731 #ifndef DISABLE_BLOCK_MESSAGE
vithyat 0:977e87915078 732
vithyat 0:977e87915078 733 M2MBlockMessage* M2MResourceBase::block_message() const
vithyat 0:977e87915078 734 {
vithyat 0:977e87915078 735 return _block_message_data;
vithyat 0:977e87915078 736 }
vithyat 0:977e87915078 737
vithyat 0:977e87915078 738 bool M2MResourceBase::set_incoming_block_message_callback(incoming_block_message_callback callback)
vithyat 0:977e87915078 739 {
vithyat 0:977e87915078 740 incoming_block_message_callback* old_callback = (incoming_block_message_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 741 M2MCallbackAssociation::M2MResourceInstanceIncomingBlockMessageCallback);
vithyat 0:977e87915078 742 delete old_callback;
vithyat 0:977e87915078 743
vithyat 0:977e87915078 744 // copy the callback object. This will change on next version to be a direct pointer to a interface class,
vithyat 0:977e87915078 745 // this FPn<> is just too heavy for this usage.
vithyat 0:977e87915078 746 incoming_block_message_callback* new_callback = new incoming_block_message_callback(callback);
vithyat 0:977e87915078 747
vithyat 0:977e87915078 748 delete _block_message_data;
vithyat 0:977e87915078 749 _block_message_data = NULL;
vithyat 0:977e87915078 750 _block_message_data = new M2MBlockMessage();
vithyat 0:977e87915078 751
vithyat 0:977e87915078 752 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 753 new_callback,
vithyat 0:977e87915078 754 M2MCallbackAssociation::M2MResourceInstanceIncomingBlockMessageCallback);
vithyat 0:977e87915078 755 }
vithyat 0:977e87915078 756
vithyat 0:977e87915078 757 bool M2MResourceBase::set_outgoing_block_message_callback(outgoing_block_message_callback callback)
vithyat 0:977e87915078 758 {
vithyat 0:977e87915078 759 outgoing_block_message_callback *old_callback = (outgoing_block_message_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 760 M2MCallbackAssociation::M2MResourceInstanceOutgoingBlockMessageCallback);
vithyat 0:977e87915078 761 delete old_callback;
vithyat 0:977e87915078 762
vithyat 0:977e87915078 763 outgoing_block_message_callback *new_callback = new outgoing_block_message_callback(callback);
vithyat 0:977e87915078 764 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 765 new_callback,
vithyat 0:977e87915078 766 M2MCallbackAssociation::M2MResourceInstanceOutgoingBlockMessageCallback);
vithyat 0:977e87915078 767 }
vithyat 0:977e87915078 768 #endif
vithyat 0:977e87915078 769
vithyat 0:977e87915078 770 bool M2MResourceBase::set_notification_sent_callback(notification_sent_callback callback)
vithyat 0:977e87915078 771 {
vithyat 0:977e87915078 772 notification_sent_callback *old_callback = (notification_sent_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 773 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback);
vithyat 0:977e87915078 774 delete old_callback;
vithyat 0:977e87915078 775
vithyat 0:977e87915078 776 notification_sent_callback *new_callback = new notification_sent_callback(callback);
vithyat 0:977e87915078 777 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 778 new_callback,
vithyat 0:977e87915078 779 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback);
vithyat 0:977e87915078 780 }
vithyat 0:977e87915078 781
vithyat 0:977e87915078 782 bool M2MResourceBase::set_notification_sent_callback(notification_sent_callback_2 callback)
vithyat 0:977e87915078 783 {
vithyat 0:977e87915078 784 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback2);
vithyat 0:977e87915078 785
vithyat 0:977e87915078 786 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 787 (void*)callback,
vithyat 0:977e87915078 788 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback2);
vithyat 0:977e87915078 789 }
vithyat 0:977e87915078 790
vithyat 0:977e87915078 791 bool M2MResourceBase::set_notification_status_callback(notification_status_callback callback)
vithyat 0:977e87915078 792 {
vithyat 0:977e87915078 793 notification_status_callback *old_callback = (notification_status_callback*)M2MCallbackStorage::remove_callback(*this,
vithyat 0:977e87915078 794 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback);
vithyat 0:977e87915078 795 delete old_callback;
vithyat 0:977e87915078 796
vithyat 0:977e87915078 797 notification_status_callback *new_callback = new notification_status_callback(callback);
vithyat 0:977e87915078 798 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 799 new_callback,
vithyat 0:977e87915078 800 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback);
vithyat 0:977e87915078 801 }
vithyat 0:977e87915078 802
vithyat 0:977e87915078 803 bool M2MResourceBase::set_notification_status_callback(notification_status_callback_2 callback)
vithyat 0:977e87915078 804 {
vithyat 0:977e87915078 805 M2MCallbackStorage::remove_callback(*this, M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback2);
vithyat 0:977e87915078 806
vithyat 0:977e87915078 807 return M2MCallbackStorage::add_callback(*this,
vithyat 0:977e87915078 808 (void*)callback,
vithyat 0:977e87915078 809 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback2);
vithyat 0:977e87915078 810 }
vithyat 0:977e87915078 811
vithyat 0:977e87915078 812 void M2MResourceBase::notification_sent()
vithyat 0:977e87915078 813 {
vithyat 0:977e87915078 814 // Now we will call both callbacks, if they are set. This is different from original behavior.
vithyat 0:977e87915078 815 notification_sent_callback* callback =
vithyat 0:977e87915078 816 (notification_sent_callback*)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 817 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback);
vithyat 0:977e87915078 818 if (callback) {
vithyat 0:977e87915078 819 (*callback)();
vithyat 0:977e87915078 820 }
vithyat 0:977e87915078 821
vithyat 0:977e87915078 822 notification_sent_callback_2 callback2 =
vithyat 0:977e87915078 823 (notification_sent_callback_2)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 824 M2MCallbackAssociation::M2MResourceInstanceNotificationSentCallback2);
vithyat 0:977e87915078 825 if (callback2) {
vithyat 0:977e87915078 826 (*callback2)();
vithyat 0:977e87915078 827 }
vithyat 0:977e87915078 828 }
vithyat 0:977e87915078 829
vithyat 0:977e87915078 830 void M2MResourceBase::notification_status(const uint16_t msg_id, const NotificationStatus status)
vithyat 0:977e87915078 831 {
vithyat 0:977e87915078 832 if (_notification_status != status) {
vithyat 0:977e87915078 833 _notification_status = status;
vithyat 0:977e87915078 834 // Now we will call both callbacks, if they are set. This is different from original behavior.
vithyat 0:977e87915078 835 notification_status_callback* callback =
vithyat 0:977e87915078 836 (notification_status_callback*)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 837 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback);
vithyat 0:977e87915078 838 if (callback) {
vithyat 0:977e87915078 839 (*callback)(msg_id, status);
vithyat 0:977e87915078 840 }
vithyat 0:977e87915078 841
vithyat 0:977e87915078 842 notification_status_callback_2 callback2 =
vithyat 0:977e87915078 843 (notification_status_callback_2)M2MCallbackStorage::get_callback(*this,
vithyat 0:977e87915078 844 M2MCallbackAssociation::M2MResourceInstanceNotificationStatusCallback2);
vithyat 0:977e87915078 845 if (callback2) {
vithyat 0:977e87915078 846 (*callback2)(msg_id, status);
vithyat 0:977e87915078 847 }
vithyat 0:977e87915078 848 }
vithyat 0:977e87915078 849 }
vithyat 0:977e87915078 850
vithyat 0:977e87915078 851 M2MResourceBase::ResourceType M2MResourceBase::convert_data_type(M2MBase::DataType type) const
vithyat 0:977e87915078 852 {
vithyat 0:977e87915078 853 M2MResourceBase::ResourceType res_type = M2MResourceBase::OBJLINK;
vithyat 0:977e87915078 854 switch(type) {
vithyat 0:977e87915078 855 case M2MBase::STRING:
vithyat 0:977e87915078 856 res_type = M2MResourceBase::STRING;
vithyat 0:977e87915078 857 break;
vithyat 0:977e87915078 858 case M2MBase::INTEGER:
vithyat 0:977e87915078 859 res_type = M2MResourceBase::INTEGER;
vithyat 0:977e87915078 860 break;
vithyat 0:977e87915078 861 case M2MBase::FLOAT:
vithyat 0:977e87915078 862 res_type = M2MResourceBase::FLOAT;
vithyat 0:977e87915078 863 break;
vithyat 0:977e87915078 864 case M2MBase::OPAQUE:
vithyat 0:977e87915078 865 res_type = M2MResourceBase::OPAQUE;
vithyat 0:977e87915078 866 break;
vithyat 0:977e87915078 867 case M2MBase::BOOLEAN:
vithyat 0:977e87915078 868 res_type = M2MResourceBase::BOOLEAN;
vithyat 0:977e87915078 869 break;
vithyat 0:977e87915078 870 case M2MBase::TIME:
vithyat 0:977e87915078 871 res_type = M2MResourceBase::TIME;
vithyat 0:977e87915078 872 break;
vithyat 0:977e87915078 873 case M2MBase::OBJLINK:
vithyat 0:977e87915078 874 res_type = M2MResourceBase::OBJLINK;
vithyat 0:977e87915078 875 break;
vithyat 0:977e87915078 876 }
vithyat 0:977e87915078 877 return res_type;
vithyat 0:977e87915078 878 }
vithyat 0:977e87915078 879
vithyat 0:977e87915078 880 M2MResourceBase::NotificationStatus M2MResourceBase::notification_status() const
vithyat 0:977e87915078 881 {
vithyat 0:977e87915078 882 return _notification_status;
vithyat 0:977e87915078 883 }
vithyat 0:977e87915078 884
vithyat 0:977e87915078 885 void M2MResourceBase::clear_notification_status()
vithyat 0:977e87915078 886 {
vithyat 0:977e87915078 887 _notification_status = M2MResourceBase::INIT;
vithyat 0:977e87915078 888 }
vithyat 0:977e87915078 889
vithyat 0:977e87915078 890 void M2MResourceBase::publish_value_in_registration_msg(bool publish_value)
vithyat 0:977e87915078 891 {
vithyat 0:977e87915078 892 M2MBase::lwm2m_parameters_s* param = M2MBase::get_lwm2m_parameters();
vithyat 0:977e87915078 893 assert(param->data_type == M2MBase::INTEGER ||
vithyat 0:977e87915078 894 param->data_type == M2MBase::STRING ||
vithyat 0:977e87915078 895 param->data_type == M2MBase::FLOAT ||
vithyat 0:977e87915078 896 param->data_type == M2MBase::BOOLEAN ||
vithyat 0:977e87915078 897 param->data_type == M2MBase::OPAQUE);
vithyat 0:977e87915078 898
vithyat 0:977e87915078 899 uint8_t pub_value = publish_value;
vithyat 0:977e87915078 900
vithyat 0:977e87915078 901 if (param->data_type == M2MBase::OPAQUE) {
vithyat 0:977e87915078 902 pub_value = 2;
vithyat 0:977e87915078 903 } else {
vithyat 0:977e87915078 904 pub_value = (uint8_t)publish_value;
vithyat 0:977e87915078 905 }
vithyat 0:977e87915078 906 param->dynamic_resource_params->publish_value = pub_value;
vithyat 0:977e87915078 907 }