X-Git-Url: https://gerrit.automotivelinux.org/gerrit/gitweb?a=blobdiff_plain;f=service%2Fsystem%2Ftask_manager%2Fserver%2Fsrc%2Ftskm_watch.cpp;fp=service%2Fsystem%2Ftask_manager%2Fserver%2Fsrc%2Ftskm_watch.cpp;h=455de0b3811650119f0e37c3c99b1f9a7a0c69d6;hb=17cf21bcf8a2e29d2cbcf0a313474d2a4ee44f5d;hp=0000000000000000000000000000000000000000;hpb=9e86046cdb356913ae026f616e5bf17f6f238aa5;p=staging%2Fbasesystem.git

diff --git a/service/system/task_manager/server/src/tskm_watch.cpp b/service/system/task_manager/server/src/tskm_watch.cpp
new file mode 100755
index 0000000..455de0b
--- /dev/null
+++ b/service/system/task_manager/server/src/tskm_watch.cpp
@@ -0,0 +1,101 @@
+/*
+ * @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 "tskm_watch.h"
+#include <agl_thread.h>
+
+#include "tskm_debug.h"
+#include "tskm_port_pf.h"
+#include "tskm_comm.h"
+
+
+#define WATCH_CYCLE 5
+
+#define TIMER_THREAD_NAME "SS_TskmTimer"
+
+/*******************************************************************
+ *    Periodic Timer-Thread MAIN Function
+ *******************************************************************/
+void *
+watchMain(void *arg) {
+  int connFd = -1;
+
+  connFd = tskm_cliSockConnect(TSKM_SOCKET_NAME);
+  if (connFd < 0) {  // LCOV_EXCL_BR_LINE 5: system function(uinx) "socket" fail process
+    // LCOV_EXCL_START 5: system function(uinx) "socket" fail process
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+    TSKM_ASSERT(0);
+    goto ERROR;
+    // LCOV_EXCL_STOP 5
+  }
+
+  while (1) {
+    int ret;
+    TSKM_EVENT_INFO_t ev;
+
+    sleep(WATCH_CYCLE);
+
+    ev.event = TSKM_EV_LCL_REP_POLLING;
+    ev.errCode = TSKM_E_OK;
+    ret = tskm_sockSend(connFd, &ev);
+    if (ret <= 0) {  // LCOV_EXCL_BR_LINE 5: system function(uinx) "send" fail process
+    // LCOV_EXCL_START 5: system function(uinx) "send" fail process
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+      TSKM_ASSERT(0);
+      goto ERROR;
+      // LCOV_EXCL_STOP 5
+    }
+  }
+
+  // LCOV_EXCL_START 6: system function(uinx) call fail process
+  ERROR:
+  AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+  if (connFd != -1) {
+    tskm_sockDestory(connFd);
+  }
+
+  return 0;
+  // LCOV_EXCL_STOP
+}
+
+/*******************************************************************
+ *    Periodic Timer thread start
+ *******************************************************************/
+int tskm_watch_startTimer() {
+  int ret;
+  pthread_t thId = { 0 };
+
+  ret = tskm_pf_createThread(watchMain, NULL, PR_SS_TSKMTIMER,
+                             TIMER_THREAD_NAME, &thId);
+  if (ret != 0) {  // LCOV_EXCL_BR_LINE 5: system function(uinx) "pthread_*" fail process
+    // LCOV_EXCL_START 5: system function(uinx) "pthread_*" fail process
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+    TSKM_ASSERT(0);
+    goto ERROR;
+    // LCOV_EXCL_STOP 5
+  } else {
+    TSKM_PRINTF(TSKM_LOG_STATE, "watch thread created.");
+  }
+
+  return 0;
+
+  // LCOV_EXCL_LINE 6: system function(uinx) "pthread_*" fail process
+  ERROR:
+  AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+  return -1;
+  // LCOV_EXCL_STOP
+}
+