1 files changed, 90 insertions, 0 deletions
diff --git a/systemservice/task_manager/client/libtskm/src/tskm_api_lib.cpp b/systemservice/task_manager/client/libtskm/src/tskm_api_lib.cpp
new file mode 100644
index 00000000..625b639d
--- /dev/null
+++ b/systemservice/task_manager/client/libtskm/src/tskm_api_lib.cpp
@@ -0,0 +1,90 @@
+/*
+ * @copyright Copyright (c) 2016-2020 TOYOTA MOTOR CORPORATION.
+ *
+ * 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.
+ */
+
+#include <unistd.h>
+#include <signal.h>
+
+#include <native_service/frameworkunified_framework_if.h>
+
+#include "tskm_debug.h"
+#include "tskm_api.h"
+
+TSKM_ERR_t TSKM_SvcCtl(TSKM_SVCID_t svcId, const TSKM_SVC_CTL_t* ctl) {
+  TSKM_ERR_t tskmRet;
+  int ii;
+
+  for (ii = 0; ii < 3; ii++) {
+    // Retry three times
+    tskmRet = _TSKM_SvcCtl(svcId, ctl);
+    if (tskmRet == TSKM_E_RETRY) {
+      usleep(300 * 1000);  // 300ms wait
+    } else {
+      break;
+    }
+  }
+
+  return tskmRet;
+}
+
+TSKM_ERR_t TSKM_ErrorReboot(const TSKM_ERROR_REBOOT_t* p_info) {
+  TSKM_ERR_t tskmRet = TSKM_E_OK;
+  RPC_Result rpcRet;
+
+  rpcRet = _TSKM_ErrorReboot(p_info);
+  if (RPC_OK != rpcRet) {
+    tskmRet = TSKM_E_PAR;
+  }
+
+  return tskmRet;
+}
+
+TSKM_ERR_t TSKM_DataInit(HANDLE hApp, const TSKM_DATAINIT_t *p_info) {
+  TSKM_ERR_t tskmRet = TSKM_E_NG;
+  TSKM_PRINTF(TSKM_LOG_API, "%s()", __FUNCTION__)
+
+  if (!p_info || !hApp || (p_info->type != TSKM_DATAINIT_TYPE_USER)
+      || !(p_info->onCompInit)) {
+    TSKM_ASSERT(0);
+    return TSKM_E_PAR;
+  }
+
+  // LCOV_EXCL_BR_START 10: Due to compiler dependency
+  EFrameworkunifiedStatus l_eStatus = FrameworkunifiedAttachCallbackToDispatcher(hApp,
+  SS_TASK_MANAGER,
+                                                       TSKM_DATAINIT_RESP,
+                                                       p_info->onCompInit);
+  // LCOV_EXCL_BR_STOP
+  if (eFrameworkunifiedStatusOK != l_eStatus) {
+    TSKM_ASSERT(0);
+  } else {
+    HANDLE hSvc = FrameworkunifiedOpenService(hApp, SS_TASK_MANAGER);
+    if (hSvc == NULL) {
+      TSKM_ASSERT(0);
+      tskmRet = TSKM_E_STATE;
+    } else {
+      if (eFrameworkunifiedStatusOK != FrameworkunifiedSendMsg(hSvc, TSKM_DATAINIT_REQ, 0, NULL)) {
+        TSKM_ASSERT(0);
+      } else {
+        tskmRet = TSKM_E_OK;
+      }
+    }
+
+    TSKM_ASSERT(eFrameworkunifiedStatusOK == FrameworkunifiedCloseService(hApp, hSvc));
+  }
+
+  return tskmRet;
+}  // LCOV_EXCL_BR_LINE 10: Final line
+