1 files changed, 309 insertions, 0 deletions
diff --git a/systemservice/version_library/library/src/ss_ver.cc b/systemservice/version_library/library/src/ss_ver.cc
new file mode 100644
index 00000000..70f120c5
--- /dev/null
+++ b/systemservice/version_library/library/src/ss_ver.cc
@@ -0,0 +1,309 @@
+/*
+ * @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 <sys/stat.h>
+#include <sys/types.h>
+#include <sys/file.h>
+#include <dirent.h>
+#include <unistd.h>
+#include <fcntl.h>
+
+#include <native_service/ns_logger_if.h>
+#include <system_service/ss_templates.h>
+
+#include <system_service/ss_ver.h>
+
+// For DEBUG
+#define ZONE_INIT    ZONEMASK(10)
+#define ZONE_FUNC    ZONEMASK(11)
+#define ZONE_MEM     ZONEMASK(12)
+#define ZONE_INFO    ZONEMASK(29)
+#define ZONE_WARN    ZONEMASK(30)
+#define ZONE_ERR     ZONEMASK(31)
+
+#define ZONE_DEFAULT ZONE_FUNC
+
+#define SSVER_TMPDIR "/tmp/ssver"
+
+// FILE IO
+class CPkgInfoIo {
+ private:
+  int m_fd;
+  std::string m_path;
+  static std::map<std::string, int> m_dbgCnt;  // Debug information for exclusive leakage check
+
+  void openFD(const int32_t mode) {
+    m_fd = open(m_path.c_str(), mode, 0664);  // LCOV_EXCL_BR_LINE 11:except,C++ STL
+    if (m_fd == -1) {
+      SS_ASERT_ERRNO(0);  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+      throw eFrameworkunifiedStatusFail;
+    }
+
+    // File lock to protect file accesses
+    SS_ASERT_ERRNO(0 == flock(m_fd, LOCK_EX));  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+    // LCOV_EXCL_BR_START 11:Unexpected branch
+    m_dbgCnt[m_path]++;
+    SS_ASERT_LOG(m_dbgCnt[m_path] == 1, "%s:%d", m_path.c_str(),  // LCOV_EXCL_BR_LINE 15: marco define @ss_templates.h
+                 m_dbgCnt[m_path]);
+    // LCOV_EXCL_BR_STOP
+  }
+
+public:
+  CPkgInfoIo(const std::string& pkgName)
+    : m_fd(-1),
+      m_path(SSVER_TMPDIR) {  // LCOV_EXCL_BR_LINE 11:Unexpected branch
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT,__FUNCTION__,"+:%s",pkgName.c_str());
+    m_path += "/";
+    m_path += pkgName;
+ 
+     FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT,__FUNCTION__,"-");
+   }
+
+  ~CPkgInfoIo() {
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+
+    // LCOV_EXCL_BR_START 11:Unexpected branch
+    m_dbgCnt[m_path]--;
+    SS_ASERT_LOG(m_dbgCnt[m_path] == 0, "%s:%d", m_path.c_str(),  // LCOV_EXCL_BR_LINE 15: marco define @ss_templates.h
+                 m_dbgCnt[m_path]);
+    SS_ASERT_ERRNO(0 == flock(m_fd, LOCK_UN));  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+
+    if (m_fd != -1) {
+      SS_ASERT_ERRNO(0 == close(m_fd));  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+    }
+    // LCOV_EXCL_BR_STOP
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+  }
+
+  void putData(SSVER_PkgInfo &info) {  //  NOLINT (readability/nolint)
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+    openFD(O_RDWR|O_CREAT|O_CLOEXEC);
+    ssize_t wsz;
+    wsz = write(m_fd, &info, sizeof(info));
+    if (wsz != sizeof(info)) {  // LCOV_EXCL_BR_LINE 5:std c lib error process
+      AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+      FRAMEWORKUNIFIEDLOG(ZONE_ERR, __FUNCTION__, "Failed write(). wsz=%d size=%d errno=%d",  // LCOV_EXCL_LINE 5: glibc fail safe
+             wsz, sizeof(info), errno);  // LCOV_EXCL_LINE 5:std c lib error process
+      throw eFrameworkunifiedStatusFail;  // LCOV_EXCL_LINE 5:std c lib error process
+    }
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+  }
+
+  void getData(SSVER_PkgInfo* p_info) {
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+    openFD(O_RDONLY|O_CLOEXEC);
+
+    ssize_t rsz;
+    rsz = my_read(m_fd, p_info, sizeof(*p_info));
+    if (rsz != sizeof(*p_info)) {  // LCOV_EXCL_BR_LINE 5:std c lib error process
+      AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+      FRAMEWORKUNIFIEDLOG(ZONE_ERR, __FUNCTION__, "Failed read(). rsz=%d size=%d", rsz,  // LCOV_EXCL_LINE 5:std c lib error process
+             sizeof(*p_info));  // LCOV_EXCL_LINE 5:std c lib error process
+      p_info->version[0] = '\0';  // LCOV_EXCL_LINE 5:std c lib error process
+      p_info->date[0] = '\0';  // LCOV_EXCL_LINE 5:std c lib error process
+      throw eFrameworkunifiedStatusFail;  // LCOV_EXCL_LINE 5:std c lib error process
+    }
+    FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+  }
+
+  int my_read(int fd, void* buf, int size) {
+    int done = 0;
+    char *buffer = reinterpret_cast<char*>(buf);
+    int sz = done;
+
+    while (size > 0) {
+      done = read(fd, buffer + done, size);
+      if (done < 0) {  // LCOV_EXCL_BR_LINE 5:std c lib error process
+        AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+        SS_ASERT_ERRNO(0);  // LCOV_EXCL_LINE 5:std c lib error process
+        if (errno == EINTR) {  // LCOV_EXCL_LINE 5:std c lib error process
+          continue;
+        } else {
+          return done;
+        }
+      } else if (done == 0) {  // LCOV_EXCL_BR_LINE 5:std c lib error process
+        return sz;
+      }
+      size -= done;
+      sz += done;
+    }
+    return sz;
+  }
+};
+
+std::map<std::string, int> CPkgInfoIo::m_dbgCnt;  // Actual status
+
+//==================================================================
+//                  private
+//==================================================================
+void CSSVer::dump(void) const {  // LCOV_EXCL_START 7:debugging process
+  AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+  std::string dumpStr;
+  dumpStr = "VERINFO DUMP\n";
+
+  for (SSVerPkgList::const_iterator ite = m_verList.begin();
+      ite != m_verList.end(); ite++) {
+    dumpStr += ite->first;
+    dumpStr += "\n";
+    dumpStr += ite->second.version;
+    dumpStr += "\n";
+    dumpStr += ite->second.date;
+    dumpStr += "\n";
+  }
+
+  FRAMEWORKUNIFIEDLOG(ZONE_ERR, __FUNCTION__, "%s", dumpStr.c_str());
+}
+// LCOV_EXCL_STOP
+
+//==================================================================
+//                  PUBLIC
+//==================================================================
+CSSVer::CSSVer() {
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+  DIR *dir = NULL;
+  struct dirent dent, *next;
+  struct stat statbuf;
+
+  try {
+    if (stat(SSVER_TMPDIR, &statbuf) != 0) {
+      mkdir(SSVER_TMPDIR, 0775);
+      // Because this process is not locked, if multiple processes process at the same time,
+      // although it may have been created and fail, do not ASSERT it because it is harmless.
+    }
+
+    // Linux dependency codes
+    if ((dir = opendir(SSVER_TMPDIR)) == NULL) {  // LCOV_EXCL_BR_LINE 5:std c lib error process
+      AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+      SS_ASERT_ERRNO(0);  // LCOV_EXCL_LINE 5:std c lib error process
+      throw eFrameworkunifiedStatusFail;
+    }
+
+    // LCOV_EXCL_BR_START 11:Unexpected branch
+    while (0 == readdir_r(dir, &dent, &next) && next) {
+      if (DT_REG == dent.d_type) {
+        SSVER_PkgInfo info;
+        std::string name(dent.d_name);
+        std::string verInfo;
+
+        CPkgInfoIo pkgIo(name);
+        pkgIo.getData(&info);
+
+        verInfo += "\nPACKAGE :";
+        verInfo += name;
+        verInfo += "\n";
+        verInfo += "  VERSION:";
+        verInfo += info.version;
+        verInfo += "\n";
+        verInfo += "  DATE   :";
+        verInfo += info.date;
+        verInfo += "\n";
+        FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "%s", verInfo.c_str());
+
+        m_verList.insert(std::make_pair(name, info));
+      }
+    }
+    SS_ASERT_ERRNO(0 == closedir(dir));  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+    // LCOV_EXCL_BR_STOP
+  } catch (...) {  // LCOV_EXCL_START 6:unable to reach
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+    if (dir) {
+      SS_ASERT_ERRNO(0 == closedir(dir));
+    }
+  }  // LCOV_EXCL_STOP
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+}
+
+CSSVer::~CSSVer() {
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+}
+
+EFrameworkunifiedStatus CSSVer::getPkgInfo(const std::string &name, SSVER_PkgInfo* p_info) {
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+  EFrameworkunifiedStatus versionlibraryRet = eFrameworkunifiedStatusOK;
+  try {
+    if (p_info == NULL) {
+      SS_ASERT(0);  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+      throw eFrameworkunifiedStatusFail;
+    }
+
+    SSVerPkgList::iterator ite = m_verList.find(name);
+
+    if (ite != m_verList.end()) {
+      // cache hit
+      *p_info = ite->second;
+    } else {
+      // cache miss
+      std::string path(SSVER_TMPDIR);  // LCOV_EXCL_BR_LINE 11:except,C++ STL
+      path += "/";
+      path += name;
+
+      if (access(path.c_str(), F_OK) == 0) {
+        // cache refresh
+        CPkgInfoIo pkgIo(name);  // LCOV_EXCL_BR_LINE 11:Unexpected branch
+        pkgIo.getData(p_info);  // LCOV_EXCL_BR_LINE 11:except,C++ STL
+        m_verList.insert(std::make_pair(name, *p_info));  // LCOV_EXCL_BR_LINE 11:except,C++ STL
+      } else {
+        throw eFrameworkunifiedStatusFileLoadError;
+      }
+    }
+  } catch (EFrameworkunifiedStatus ee) {
+    versionlibraryRet = ee;
+  } catch (...) {  // LCOV_EXCL_START 6:unable to reach
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+    versionlibraryRet = eFrameworkunifiedStatusFail;
+  }  // LCOV_EXCL_STOP
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+  return versionlibraryRet;
+}
+
+EFrameworkunifiedStatus CSSVer::setPkgInfo(const std::string &name, SSVER_PkgInfo &info) {
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "+");
+  EFrameworkunifiedStatus versionlibraryRet = eFrameworkunifiedStatusOK;
+  try {
+    // LCOV_EXCL_BR_START 11:Unexpected branch
+    SSVerPkgList::iterator ite = m_verList.find(name);
+
+    if (ite == m_verList.end()) {
+      m_verList.insert(std::make_pair(name, info));
+      CPkgInfoIo pkgIo(name);
+      pkgIo.putData(info);
+    } else {
+      ite->second = info;
+      CPkgInfoIo pkgIo(name);
+      pkgIo.putData(info);
+    }
+    // LCOV_EXCL_BR_STOP
+  } catch (EFrameworkunifiedStatus ee) {
+    versionlibraryRet = ee;
+  } catch (...) {  // LCOV_EXCL_START 6:unable to reach
+    AGL_ASSERT_NOT_TESTED();  // LCOV_EXCL_LINE 200: test assert
+
+    SS_ASERT(0);  // LCOV_EXCL_BR_LINE 15: marco defined in ss_templates.h
+    versionlibraryRet = eFrameworkunifiedStatusFail;
+  }   // LCOV_EXCL_STOP
+
+  FRAMEWORKUNIFIEDLOG(ZONE_DEFAULT, __FUNCTION__, "-");
+  return versionlibraryRet;
+}  // LCOV_EXCL_BR_LINE 10:for the last line
+