pendingInfoRequestsStart;
- @Getter
- @Setter
- private volatile LwM2mClientRpcRequest rpcRequest;
- @Getter
- @Setter
- private volatile int updateStrategy;
-
- public LwM2mFwSwUpdate(LwM2mClient lwM2MClient, OtaPackageType type, int updateStrategy) {
- this.lwM2MClient = lwM2MClient;
- this.pendingInfoRequestsStart = new CopyOnWriteArrayList<>();
- this.type = type;
- this.stateUpdate = null;
- this.updateStrategy = updateStrategy;
- this.initPathId();
- }
-
- private void initPathId() {
- if (FIRMWARE.equals(this.type)) {
- this.pathPackageId = LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_5_BINARY.code == this.updateStrategy ?
- FW_PACKAGE_5_ID : LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_5_TEMP_URL.code == this.updateStrategy ?
- FW_PACKAGE_URI_ID : FW_PACKAGE_19_ID;
- this.pathStateId = FW_STATE_ID;
- this.pathResultId = FW_RESULT_ID;
- this.pathNameId = FW_NAME_ID;
- this.pathVerId = FW_5_VER_ID;
- this.pathInstallId = FW_UPDATE_ID;
- this.wUpdate = FW_UPDATE;
- } else if (SOFTWARE.equals(this.type)) {
- this.pathPackageId = SW_PACKAGE_ID;
- this.pathStateId = SW_UPDATE_STATE_ID;
- this.pathResultId = SW_RESULT_ID;
- this.pathNameId = SW_NAME_ID;
- this.pathVerId = SW_VER_ID;
- this.pathInstallId = SW_INSTALL_ID;
- this.pathUnInstallId = SW_UN_INSTALL_ID;
- this.wUpdate = SW_UPDATE;
- }
- }
-
- public void initReadValue(DefaultLwM2MTransportMsgHandler handler, LwM2mTransportRequest request, String pathIdVer) {
- if (pathIdVer != null) {
- this.pendingInfoRequestsStart.remove(pathIdVer);
- }
- if (this.pendingInfoRequestsStart.size() == 0) {
- this.infoFwSwUpdate = false;
-// if (!FAILED.name().equals(this.stateUpdate)) {
- boolean conditionalStart = this.type.equals(FIRMWARE) ? this.conditionalFwUpdateStart(handler) :
- this.conditionalSwUpdateStart(handler);
- if (conditionalStart) {
- this.writeFwSwWare(handler, request);
- }
-// }
- }
- }
-
- /**
- * Send FsSw to Lwm2mClient:
- * before operation Write: fw_state = DOWNLOADING
- */
- public void writeFwSwWare(DefaultLwM2MTransportMsgHandler handler, LwM2mTransportRequest request) {
- if (this.currentId != null) {
- this.stateUpdate = OtaPackageUpdateStatus.INITIATED.name();
- this.sendLogs(handler, WRITE_REPLACE.name(), LOG_LW2M_INFO, null);
- String targetIdVer = convertPathFromObjectIdToIdVer(this.pathPackageId, this.lwM2MClient.getRegistration());
- String fwMsg = String.format("%s: Start type operation %s paths: %s", LOG_LW2M_INFO,
- LwM2mTransportUtil.LwM2mTypeOper.FW_UPDATE.name(), this.pathPackageId);
- handler.sendLogsToThingsboard(fwMsg, lwM2MClient.getRegistration().getId());
- log.warn("8) Start firmware Update. Send save to: [{}] ver: [{}] path: [{}]", this.lwM2MClient.getDeviceName(), this.currentVersion, targetIdVer);
- if (LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_5_BINARY.code == this.updateStrategy) {
- int chunkSize = 0;
- int chunk = 0;
- byte[] firmwareChunk = handler.otaPackageDataCache.get(this.currentId.toString(), chunkSize, chunk);
- request.sendAllRequest(this.lwM2MClient, targetIdVer, WRITE_REPLACE, ContentFormat.OPAQUE,
- firmwareChunk, handler.config.getTimeout(), this.rpcRequest);
- } else if (LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_5_TEMP_URL.code == this.updateStrategy) {
- String apiFont = "coap://176.36.143.9:5685";
- String uri = apiFont + "/" + FIRMWARE_UPDATE_COAP_RECOURSE + "/" + this.currentId.toString();
- log.warn("89) coapUri: [{}]", uri);
- request.sendAllRequest(this.lwM2MClient, targetIdVer, WRITE_REPLACE, null,
- uri, handler.config.getTimeout(), this.rpcRequest);
- } else if (LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_19_BINARY.code == this.updateStrategy) {
-
- }
- } else {
- String msgError = "FirmWareId is null.";
- log.warn("6) [{}]", msgError);
- if (this.rpcRequest != null) {
- handler.sentRpcResponse(this.rpcRequest, CONTENT.name(), msgError, LOG_LW2M_ERROR);
- }
- log.error(msgError);
- this.sendLogs(handler, WRITE_REPLACE.name(), LOG_LW2M_ERROR, msgError);
- }
- }
-
- public void sendLogs(DefaultLwM2MTransportMsgHandler handler, String typeOper, String typeInfo, String msgError) {
-// this.sendSateOnThingsBoard(handler);
- String msg = String.format("%s: %s, %s, pkgVer: %s: pkgName - %s state - %s.",
- typeInfo, this.wUpdate, typeOper, this.currentVersion, this.currentTitle, this.stateUpdate);
- if (LOG_LW2M_ERROR.equals(typeInfo)) {
- msg = String.format("%s Error: %s", msg, msgError);
- }
- handler.sendLogsToThingsboard(lwM2MClient, msg);
- }
-
-
- /**
- * After inspection Update Result
- * fw_state/sw_state = UPDATING
- * send execute
- */
- public void executeFwSwWare(DefaultLwM2MTransportMsgHandler handler, LwM2mTransportRequest request) {
- this.sendLogs(handler, EXECUTE.name(), LOG_LW2M_INFO, null);
- request.sendAllRequest(this.lwM2MClient, this.pathInstallId, EXECUTE, null, 0, this.rpcRequest);
- }
-
- /**
- * Firmware start: Check if the version has changed and launch a new update.
- * -ObjectId 5, Binary or ObjectId 5, URI
- * -- If the result of the update - errors (more than 1) - This means that the previous. the update failed.
- * - We launch the update regardless of the state of the firmware and its version.
- * -- If the result of the update - errors (more than 1) - This means that the previous. the update failed.
- * * ObjectId 5, Binary
- * -- If the result of the update is not errors (equal to 1 or 0) and ver in Object 5 is not empty - it means that the previous update has passed.
- * Compare current versions by equals.
- * * ObjectId 5, URI
- * -- If the result of the update is not errors (equal to 1 or 0) and ver in Object 5 is not empty - it means that the previous update has passed.
- * Compare current versions by contains.
- */
- private boolean conditionalFwUpdateStart(DefaultLwM2MTransportMsgHandler handler) {
- Long updateResultFw = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- String ver5 = (String) this.lwM2MClient.getResourceValue(null, this.pathVerId);
- String pathName = (String) this.lwM2MClient.getResourceValue(null, this.pathNameId);
- String ver3 = (String) this.lwM2MClient.getResourceValue(null, FW_3_VER_ID);
- // #1/#2
- String fwMsg = null;
- if ((this.currentVersion != null && (
- ver5 != null && ver5.equals(this.currentVersion) ||
- ver3 != null && ver3.contains(this.currentVersion)
- )) ||
- (this.currentTitle != null && pathName != null && this.currentTitle.equals(pathName))) {
- fwMsg = String.format("%s: The update was interrupted. The device has the same version: %s.", LOG_LW2M_ERROR,
- this.currentVersion);
- }
- else if (updateResultFw != null && updateResultFw > LwM2mTransportUtil.UpdateResultFw.UPDATE_SUCCESSFULLY.code) {
- fwMsg = String.format("%s: The update was interrupted. The device has the status UpdateResult: error (%d).", LOG_LW2M_ERROR,
- updateResultFw);
- }
- if (fwMsg != null) {
- handler.sendLogsToThingsboard(fwMsg, lwM2MClient.getRegistration().getId());
- return false;
- }
- else {
- return true;
- }
- }
-
-
- /**
- * Before operation Execute inspection Update Result :
- * 0 - Initial value
- */
- public boolean conditionalFwExecuteStart() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultFw.INITIAL.code == updateResult;
- }
-
- /**
- * After operation Execute success inspection Update Result :
- * 1 - "Firmware updated successfully"
- */
- public boolean conditionalFwExecuteAfterSuccess() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultFw.UPDATE_SUCCESSFULLY.code == updateResult;
- }
-
- /**
- * After operation Execute success inspection Update Result :
- * > 1 error: "Firmware updated successfully"
- */
- public boolean conditionalFwExecuteAfterError() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultFw.UPDATE_SUCCESSFULLY.code < updateResult;
- }
-
- /**
- * Software start
- * - If Update Result -errors (equal or more than 50) - This means that the previous. the update failed.
- * * - We launch the update regardless of the state of the firmware and its version.
- * - If Update Result is not errors (less than 50) and ver is not empty - This means that before. the update has passed.
- * - If Update Result is not errors and ver is empty - This means that there was no update yet or before. UnInstall update
- * - If Update Result is not errors and ver is not empty - This means that before unInstall update
- * * - Check if the version has changed and launch a new update.
- */
- private boolean conditionalSwUpdateStart(DefaultLwM2MTransportMsgHandler handler) {
- Long updateResultSw = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- // #1/#2
- return updateResultSw >= LwM2mTransportUtil.UpdateResultSw.NOT_ENOUGH_STORAGE.code ||
- (
- (updateResultSw <= LwM2mTransportUtil.UpdateResultSw.NOT_ENOUGH_STORAGE.code
- ) &&
- (
- (this.currentVersion != null && !this.currentVersion.equals(this.lwM2MClient.getResourceValue(null, this.pathVerId))) ||
- (this.currentTitle != null && !this.currentTitle.equals(this.lwM2MClient.getResourceValue(null, this.pathNameId)))
- )
- );
- }
-
- /**
- * Before operation Execute inspection Update Result :
- * 3 - Successfully Downloaded and package integrity verified
- */
- public boolean conditionalSwUpdateExecute() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultSw.SUCCESSFULLY_DOWNLOADED_VERIFIED.code == updateResult;
- }
-
- /**
- * After finish operation Execute (success):
- * -- inspection Update Result:
- * ---- FW если Update Result == 1 ("Firmware updated successfully") или SW если Update Result == 2 ("Software successfully installed.")
- * -- fw_state/sw_state = UPDATED
- *
- * After finish operation Execute (error):
- * -- inspection updateResult and send to thingsboard info about error
- * --- send to telemetry ( key - this is name Update Result in model) (
- * -- fw_state/sw_state = FAILED
- */
- public void finishFwSwUpdate(DefaultLwM2MTransportMsgHandler handler, boolean success) {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- String value = FIRMWARE.equals(this.type) ? LwM2mTransportUtil.UpdateResultFw.fromUpdateResultFwByCode(updateResult.intValue()).type :
- LwM2mTransportUtil.UpdateResultSw.fromUpdateResultSwByCode(updateResult.intValue()).type;
- String key = splitCamelCaseString((String) this.lwM2MClient.getResourceNameByRezId(null, this.pathResultId));
- if (success) {
- this.stateUpdate = OtaPackageUpdateStatus.UPDATED.name();
- this.sendLogs(handler, EXECUTE.name(), LOG_LW2M_INFO, null);
- } else {
- this.stateUpdate = OtaPackageUpdateStatus.FAILED.name();
- this.sendLogs(handler, EXECUTE.name(), LOG_LW2M_ERROR, value);
- }
- handler.helper.sendParametersOnThingsboardTelemetry(
- handler.helper.getKvStringtoThingsboard(key, value), this.lwM2MClient.getSession());
- }
-
- /**
- * After operation Execute success inspection Update Result :
- * 2 - "Software successfully installed."
- */
- public boolean conditionalSwExecuteAfterSuccess() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultSw.SUCCESSFULLY_INSTALLED.code == updateResult;
- }
-
- /**
- * After operation Execute success inspection Update Result :
- * >= 50 - error "NOT_ENOUGH_STORAGE"
- */
- public boolean conditionalSwExecuteAfterError() {
- Long updateResult = (Long) this.lwM2MClient.getResourceValue(null, this.pathResultId);
- return LwM2mTransportUtil.UpdateResultSw.NOT_ENOUGH_STORAGE.code <= updateResult;
- }
-
- private void observeStateUpdate(DefaultLwM2MTransportMsgHandler handler, LwM2mTransportRequest request) {
- request.sendAllRequest(lwM2MClient,
- convertPathFromObjectIdToIdVer(this.pathStateId, this.lwM2MClient.getRegistration()), OBSERVE,
- null, null, 0, null);
- request.sendAllRequest(lwM2MClient,
- convertPathFromObjectIdToIdVer(this.pathResultId, this.lwM2MClient.getRegistration()), OBSERVE,
- null, null, 0, null);
- }
-
- public void sendSateOnThingsBoard(DefaultLwM2MTransportMsgHandler handler) {
- if (StringUtils.trimToNull(this.stateUpdate) != null) {
- List result = new ArrayList<>();
- TransportProtos.KeyValueProto.Builder kvProto = TransportProtos.KeyValueProto.newBuilder().setKey(getAttributeKey(this.type, STATE));
- kvProto.setType(TransportProtos.KeyValueType.STRING_V).setStringV(stateUpdate);
- result.add(kvProto.build());
- handler.helper.sendParametersOnThingsboardTelemetry(result,
- handler.getSessionInfoOrCloseSession(this.lwM2MClient.getRegistration()));
- }
- }
-
- public void sendReadObserveInfo(LwM2mTransportRequest request) {
- this.infoFwSwUpdate = true;
- this.pendingInfoRequestsStart.add(convertPathFromObjectIdToIdVer(
- this.pathStateId, this.lwM2MClient.getRegistration()));
- this.pendingInfoRequestsStart.add(convertPathFromObjectIdToIdVer(
- this.pathResultId, this.lwM2MClient.getRegistration()));
- this.pendingInfoRequestsStart.add(convertPathFromObjectIdToIdVer(
- FW_3_VER_ID, this.lwM2MClient.getRegistration()));
- if (LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_5_BINARY.code == this.updateStrategy ||
- LwM2mTransportUtil.LwM2MFirmwareUpdateStrategy.OBJ_19_BINARY.code == this.updateStrategy ||
- SOFTWARE.equals(this.type)) {
- this.pendingInfoRequestsStart.add(convertPathFromObjectIdToIdVer(
- this.pathVerId, this.lwM2MClient.getRegistration()));
- this.pendingInfoRequestsStart.add(convertPathFromObjectIdToIdVer(
- this.pathNameId, this.lwM2MClient.getRegistration()));
- }
- this.pendingInfoRequestsStart.forEach(pathIdVer -> {
- request.sendAllRequest(this.lwM2MClient, pathIdVer, OBSERVE, null, 0, this.rpcRequest);
- });
-
- }
-
- /**
- * Before operation Execute (FwUpdate) inspection Update Result :
- * - after finished operation Write result: success (FwUpdate): fw_state = DOWNLOADED
- * - before start operation Execute (FwUpdate) Update Result = 0 - Initial value
- * - start Execute (FwUpdate)
- * After finished operation Execute (FwUpdate) inspection Update Result :
- * - after start operation Execute (FwUpdate): fw_state = UPDATING
- * - after success finished operation Execute (FwUpdate) Update Result == 1 ("Firmware updated successfully")
- * - finished operation Execute (FwUpdate)
- */
- public void updateStateOta(DefaultLwM2MTransportMsgHandler handler, LwM2mTransportRequest request,
- Registration registration, String path, int value) {
- if (OBJ_5_BINARY.code == this.getUpdateStrategy()) {
- if ((convertPathFromObjectIdToIdVer(FW_RESULT_ID, registration).equals(path))) {
- if (DOWNLOADED.name().equals(this.getStateUpdate())
- && this.conditionalFwExecuteStart()) {
- this.executeFwSwWare(handler, request);
- } else if (UPDATING.name().equals(this.getStateUpdate())
- && this.conditionalFwExecuteAfterSuccess()) {
- this.finishFwSwUpdate(handler, true);
- } else if (UPDATING.name().equals(this.getStateUpdate())
- && this.conditionalFwExecuteAfterError()) {
- this.finishFwSwUpdate(handler, false);
- }
- }
- } else if (OBJ_5_TEMP_URL.code == this.getUpdateStrategy()) {
- if (this.currentId != null && (convertPathFromObjectIdToIdVer(FW_STATE_ID, registration).equals(path))) {
- String state = equalsFwSateToFirmwareUpdateStatus(LwM2mTransportUtil.StateFw.fromStateFwByCode(value)).name();
- if (StringUtils.isNotEmpty(state) && !FAILED.name().equals(this.stateUpdate) && !state.equals(this.stateUpdate)) {
- this.stateUpdate = state;
- this.sendSateOnThingsBoard(handler);
- }
- if (value == LwM2mTransportUtil.StateFw.DOWNLOADED.code) {
- this.executeFwSwWare(handler, request);
- }
- handler.firmwareUpdateState.put(lwM2MClient.getEndpoint(), value);
- }
- if ((convertPathFromObjectIdToIdVer(FW_RESULT_ID, registration).equals(path))) {
- if (this.currentId != null && value == LwM2mTransportUtil.UpdateResultFw.INITIAL.code) {
- this.setStateUpdate(INITIATED.name());
- } else if (this.currentId != null && value == LwM2mTransportUtil.UpdateResultFw.UPDATE_SUCCESSFULLY.code) {
- this.setStateUpdate(UPDATED.name());
- } else if (value > LwM2mTransportUtil.UpdateResultFw.UPDATE_SUCCESSFULLY.code) {
- this.setStateUpdate(FAILED.name());
- }
- this.sendSateOnThingsBoard(handler);
- }
- } else if (OBJ_19_BINARY.code == this.getUpdateStrategy()) {
-
- }
- }
-}
diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ResultsAnalyzerParameters.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ParametersAnalyzeResult.java
similarity index 92%
rename from common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ResultsAnalyzerParameters.java
rename to common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ParametersAnalyzeResult.java
index 45b52811d8..9cf304ab97 100644
--- a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ResultsAnalyzerParameters.java
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/client/ParametersAnalyzeResult.java
@@ -21,11 +21,11 @@ import java.util.Set;
import java.util.concurrent.ConcurrentHashMap;
@Data
-public class ResultsAnalyzerParameters {
+public class ParametersAnalyzeResult {
Set pathPostParametersAdd;
Set pathPostParametersDel;
- public ResultsAnalyzerParameters() {
+ public ParametersAnalyzeResult() {
this.pathPostParametersAdd = ConcurrentHashMap.newKeySet();
this.pathPostParametersDel = ConcurrentHashMap.newKeySet();
}
diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/common/LwM2MExecutorAwareService.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/common/LwM2MExecutorAwareService.java
new file mode 100644
index 0000000000..1f1dff784f
--- /dev/null
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/common/LwM2MExecutorAwareService.java
@@ -0,0 +1,41 @@
+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.transport.lwm2m.server.common;
+
+import org.thingsboard.common.util.ThingsBoardExecutors;
+
+import javax.annotation.PreDestroy;
+import java.util.concurrent.ExecutorService;
+
+public abstract class LwM2MExecutorAwareService {
+
+ protected ExecutorService executor;
+
+ protected abstract int getExecutorSize();
+
+ protected abstract String getExecutorName();
+
+ protected void init() {
+ this.executor = ThingsBoardExecutors.newWorkStealingPool(getExecutorSize(), getExecutorName());
+ }
+
+ public void destroy() {
+ if (executor != null) {
+ executor.shutdownNow();
+ }
+ }
+
+}
diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MRequestCallback.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MRequestCallback.java
new file mode 100644
index 0000000000..561b103277
--- /dev/null
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MRequestCallback.java
@@ -0,0 +1,46 @@
+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.transport.lwm2m.server.downlink;
+
+import lombok.extern.slf4j.Slf4j;
+import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClient;
+import org.thingsboard.server.transport.lwm2m.server.log.LwM2MTelemetryLogService;
+
+import static org.thingsboard.server.transport.lwm2m.server.LwM2mTransportUtil.LOG_LWM2M_WARN;
+
+@Slf4j
+public abstract class AbstractTbLwM2MRequestCallback implements DownlinkRequestCallback {
+
+ protected final LwM2MTelemetryLogService logService;
+ protected final LwM2mClient client;
+
+ protected AbstractTbLwM2MRequestCallback(LwM2MTelemetryLogService logService, LwM2mClient client) {
+ this.logService = logService;
+ this.client = client;
+ }
+
+ @Override
+ public void onValidationError(String params, String msg) {
+ log.trace("[{}] Request [{}] validation failed. Reason: {}", client.getEndpoint(), params, msg);
+ logService.log(client, String.format("[%s]: Request [%s] validation failed. Reason: %s", LOG_LWM2M_WARN, params, msg));
+ }
+
+ @Override
+ public void onError(String params, Exception e) {
+ log.trace("[{}] Request [{}] processing failed", client.getEndpoint(), params, e);
+ logService.log(client, String.format("[%s]: Request [%s] processing failed. Reason: %s", LOG_LWM2M_WARN, params, e));
+ }
+}
diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MTargetedDownlinkRequest.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MTargetedDownlinkRequest.java
new file mode 100644
index 0000000000..7d81308df1
--- /dev/null
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/AbstractTbLwM2MTargetedDownlinkRequest.java
@@ -0,0 +1,32 @@
+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.transport.lwm2m.server.downlink;
+
+import lombok.Getter;
+
+public abstract class AbstractTbLwM2MTargetedDownlinkRequest implements TbLwM2MDownlinkRequest, HasVersionedId {
+
+ @Getter
+ private final String versionedId;
+ @Getter
+ private final long timeout;
+
+ public AbstractTbLwM2MTargetedDownlinkRequest(String versionedId, long timeout) {
+ this.versionedId = versionedId;
+ this.timeout = timeout;
+ }
+
+}
diff --git a/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/DefaultLwM2mDownlinkMsgHandler.java b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/DefaultLwM2mDownlinkMsgHandler.java
new file mode 100644
index 0000000000..52ef83bf8e
--- /dev/null
+++ b/common/transport/lwm2m/src/main/java/org/thingsboard/server/transport/lwm2m/server/downlink/DefaultLwM2mDownlinkMsgHandler.java
@@ -0,0 +1,353 @@
+/**
+ * Copyright © 2016-2021 The Thingsboard Authors
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.thingsboard.server.transport.lwm2m.server.downlink;
+
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.eclipse.leshan.core.Link;
+import org.eclipse.leshan.core.attributes.Attribute;
+import org.eclipse.leshan.core.attributes.AttributeSet;
+import org.eclipse.leshan.core.model.ResourceModel;
+import org.eclipse.leshan.core.node.LwM2mPath;
+import org.eclipse.leshan.core.node.LwM2mResource;
+import org.eclipse.leshan.core.node.ObjectLink;
+import org.eclipse.leshan.core.node.codec.CodecException;
+import org.eclipse.leshan.core.observation.Observation;
+import org.eclipse.leshan.core.request.ContentFormat;
+import org.eclipse.leshan.core.request.DeleteRequest;
+import org.eclipse.leshan.core.request.DiscoverRequest;
+import org.eclipse.leshan.core.request.ExecuteRequest;
+import org.eclipse.leshan.core.request.ObserveRequest;
+import org.eclipse.leshan.core.request.ReadRequest;
+import org.eclipse.leshan.core.request.SimpleDownlinkRequest;
+import org.eclipse.leshan.core.request.WriteAttributesRequest;
+import org.eclipse.leshan.core.request.WriteRequest;
+import org.eclipse.leshan.core.response.DeleteResponse;
+import org.eclipse.leshan.core.response.DiscoverResponse;
+import org.eclipse.leshan.core.response.ExecuteResponse;
+import org.eclipse.leshan.core.response.LwM2mResponse;
+import org.eclipse.leshan.core.response.ObserveResponse;
+import org.eclipse.leshan.core.response.ReadResponse;
+import org.eclipse.leshan.core.response.WriteAttributesResponse;
+import org.eclipse.leshan.core.response.WriteResponse;
+import org.eclipse.leshan.core.util.Hex;
+import org.eclipse.leshan.server.registration.Registration;
+import org.springframework.stereotype.Service;
+import org.thingsboard.common.util.JacksonUtil;
+import org.thingsboard.server.common.data.device.data.lwm2m.ObjectAttributes;
+import org.thingsboard.server.queue.util.TbLwM2mTransportComponent;
+import org.thingsboard.server.transport.lwm2m.config.LwM2MTransportServerConfig;
+import org.thingsboard.server.transport.lwm2m.server.LwM2mTransportContext;
+import org.thingsboard.server.transport.lwm2m.server.client.LwM2mClient;
+import org.thingsboard.server.transport.lwm2m.server.common.LwM2MExecutorAwareService;
+import org.thingsboard.server.transport.lwm2m.server.log.LwM2MTelemetryLogService;
+import org.thingsboard.server.transport.lwm2m.utils.LwM2mValueConverterImpl;
+
+import javax.annotation.PostConstruct;
+import javax.annotation.PreDestroy;
+import java.util.Arrays;
+import java.util.Collection;
+import java.util.Date;
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Set;
+import java.util.function.Function;
+import java.util.function.Predicate;
+import java.util.stream.Collectors;
+
+import static org.eclipse.leshan.core.attributes.Attribute.GREATER_THAN;
+import static org.eclipse.leshan.core.attributes.Attribute.LESSER_THAN;
+import static org.eclipse.leshan.core.attributes.Attribute.MAXIMUM_PERIOD;
+import static org.eclipse.leshan.core.attributes.Attribute.MINIMUM_PERIOD;
+import static org.eclipse.leshan.core.attributes.Attribute.STEP;
+
+@Slf4j
+@Service
+@TbLwM2mTransportComponent
+@RequiredArgsConstructor
+public class DefaultLwM2mDownlinkMsgHandler extends LwM2MExecutorAwareService implements LwM2mDownlinkMsgHandler {
+
+ public LwM2mValueConverterImpl converter;
+
+ private final LwM2mTransportContext context;
+ private final LwM2MTransportServerConfig config;
+ private final LwM2MTelemetryLogService logService;
+
+ @PostConstruct
+ public void init() {
+ super.init();
+ this.converter = LwM2mValueConverterImpl.getInstance();
+ }
+
+ @PreDestroy
+ public void destroy() {
+ super.destroy();
+ }
+
+ @Override
+ protected int getExecutorSize() {
+ return config.getDownlinkPoolSize();
+ }
+
+ @Override
+ protected String getExecutorName() {
+ return "LwM2M Downlink";
+ }
+
+ @Override
+ public void sendReadRequest(LwM2mClient client, TbLwM2MReadRequest request, DownlinkRequestCallback