1 files changed, 325 insertions, 0 deletions
diff --git a/nsframework/framework_unified/client/NS__CWORD77__ServiceIf/src/frameworkunified__CWORD77__session_if.cpp b/nsframework/framework_unified/client/NS__CWORD77__ServiceIf/src/frameworkunified__CWORD77__session_if.cpp
new file mode 100644
index 00000000..1211f915
--- /dev/null
+++ b/nsframework/framework_unified/client/NS__CWORD77__ServiceIf/src/frameworkunified__CWORD77__session_if.cpp
@@ -0,0 +1,325 @@
+/*
+ * @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.
+ */
+
+////////////////////////////////////////////////////////////////////////////////
+/// \ingroup  tag_HMI_CWORD77_Controller
+/// \brief
+///
+////////////////////////////////////////////////////////////////////////////////
+
+#include <native_service/frameworkunified__CWORD77__session_if.h>
+#include <native_service/ns__CWORD77__data_pool_if.h>
+#include <boost/bind.hpp>
+#include <utility>
+#include <vector>
+#include "ns__CWORD77__data_pool_internal.h"
+#include "ns__CWORD77__common_internal.h"
+
+//////////////////////////////////////////
+/// Function : CFrameworkunified_CWORD77_Session
+//////////////////////////////////////////
+CFrameworkunified_CWORD77_Session::CFrameworkunified_CWORD77_Session() {
+  m_hSession = NULL;
+  m_hApp = NULL;
+  m_hService = NULL;
+  m_uiSessionType = 0;
+}
+//////////////////////////////////////////
+/// Function : ~CFrameworkunified_CWORD77_Session
+//////////////////////////////////////////
+CFrameworkunified_CWORD77_Session::~CFrameworkunified_CWORD77_Session() {  // LCOV_EXCL_BR_LINE 11:except branch
+}
+
+void CFrameworkunified_CWORD77_Session::SetSessionType(const UI_32 &sessioType) {
+  m_uiSessionType = sessioType;
+}
+
+//////////////////////////////////////////
+/// Function : GetSessionType
+//////////////////////////////////////////
+UI_32 CFrameworkunified_CWORD77_Session::GetSessionType() {
+  return m_uiSessionType;
+}
+//////////////////////////////////////////
+/// Function : SetResponseCallback
+//////////////////////////////////////////
+void CFrameworkunified_CWORD77_Session::SetResponseCallback(ResponseServiceTo_CWORD77_ f_cbResponse) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");   // LCOV_EXCL_BR_LINE 15:marco defined in "native_service/ns_logger_if.h"
+  m_ResponseTo_CWORD77_ = f_cbResponse;
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");   // LCOV_EXCL_BR_LINE 15:marco defined in "native_service/ns_logger_if.h"
+}
+//////////////////////////////////////////
+/// Function : AddProtocolHandler
+//////////////////////////////////////////
+void CFrameworkunified_CWORD77_Session::AddProtocolHandler(UI_32 f_uiCmdId, CbFuncPtr f_cbFuncPtr) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  FrameworkunifiedProtocolCallbackHandler l_tProtocolCallback;
+  l_tProtocolCallback.iCmd = f_uiCmdId;
+  l_tProtocolCallback.callBack = f_cbFuncPtr;
+  m_vSessionProtocolHanlder.push_back(l_tProtocolCallback);
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+}
+//////////////////////////////////////////
+/// Function : AddEventHandler
+//////////////////////////////////////////
+void CFrameworkunified_CWORD77_Session::AddEventHandler(UI_32 f_uiCmdId, CbFuncPtr f_cbFuncPtr) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  FrameworkunifiedProtocolCallbackHandler l_tProtocolCallback;
+  l_tProtocolCallback.iCmd = f_uiCmdId;
+  l_tProtocolCallback.callBack = f_cbFuncPtr;
+  m_vSessionEventHandler.push_back(l_tProtocolCallback);
+  m_vEventVector.push_back(f_uiCmdId);  // Code added by Shyam
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+}
+//////////////////////////////////////////
+/// Function : AttachProtocolwithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::AttachProtocolwithDispatcher(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
+  size_t l_uiSize = m_vSessionProtocolHanlder.size();
+  PCSTR l_pRequester   = FrameworkunifiedGetMsgSrc(f_hApp);
+  for (size_t i = 0; i < l_uiSize; i++) {
+    FrameworkunifiedAttachCallbackToDispatcher(f_hApp, l_pRequester, m_vSessionProtocolHanlder[i].iCmd,
+                                  m_vSessionProtocolHanlder[i].callBack, m_hSession);
+  }
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+  return l_eStatus;
+}
+//////////////////////////////////////////
+/// Function : DetachProtocolwithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::DetachProtocolwithDispatcher(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
+  size_t l_uiSize = m_vSessionProtocolHanlder.size();
+  PCSTR l_pRequester   = FrameworkunifiedGetMsgSrc(f_hApp);
+  for (size_t i = 0; i < l_uiSize; i++) {
+    FrameworkunifiedDetachCallbackFromDispatcher(f_hApp, l_pRequester, m_vSessionProtocolHanlder[i].iCmd,
+                                    m_hSession);
+  }
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+  return l_eStatus;
+}
+//////////////////////////////////////////
+/// Function : AttachEventswithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::AttachEventswithDispatcher(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
+  size_t l_uiSize = m_vEventVector.size();
+
+  for (size_t i = 0; i < l_uiSize; i++) {
+    l_eStatus = FrameworkunifiedRegisterEvent(m_hSession, m_vEventVector[i]);
+  }
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+  return l_eStatus;
+}
+//////////////////////////////////////////
+/// Function : AttachEventswithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::RegisterEvents(HANDLE f_hApp) {
+  // Function: added by Shyam to overcome the naming conflict in registering the event
+  return AttachEventswithDispatcher(f_hApp);
+}
+
+//////////////////////////////////////////
+/// Function : AttachEventHandlerswithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::AttachEventHandlerswithDispatcher(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
+  size_t l_uiSize = m_vSessionEventHandler.size();
+  PCSTR l_pRequester   = FrameworkunifiedGetMsgSrc(f_hApp);
+  for (size_t i = 0; i < l_uiSize; i++) {
+    FrameworkunifiedAttachCallbackToDispatcher(f_hApp, l_pRequester, m_vSessionEventHandler[i].iCmd,
+                                  m_vSessionEventHandler[i].callBack, m_hSession);
+  }
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+  return l_eStatus;
+}
+//////////////////////////////////////////
+/// Function : DetachEventHandlerswithDispatcher
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::DetachEventHandlerswithDispatcher(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
+  size_t l_uiSize = m_vSessionEventHandler.size();
+  PCSTR l_pRequester   = FrameworkunifiedGetMsgSrc(f_hApp);
+  for (size_t i = 0; i < l_uiSize; i++) {
+    FrameworkunifiedDetachCallbackFromDispatcher(f_hApp, l_pRequester, m_vSessionEventHandler[i].iCmd,
+                                    m_hSession);
+  }
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");
+  return l_eStatus;
+}
+
+//////////////////////////////////////////
+/// Function : HandleSessionMessage
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::HandleSessionMessage(UI_32 cmdID) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK;
+
+  UI_32 size = 0;
+  PVOID data = NULL;
+
+  if (NULL != m_hSession && NULL != m_hService) {
+    eStatus = GetReqDataFrom_CWORD77_DataPool(std::make_pair(cmdID, FrameworkunifiedGetSessionName(m_hService)), size, data);
+
+    if (eFrameworkunifiedStatusOK == eStatus) {
+      eStatus = FrameworkunifiedSendMsg(m_hSession, cmdID, size, data);
+      if (eFrameworkunifiedStatusOK != eStatus) {
+        FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: FrameworkunifiedSendMsg() returned %d", eStatus);
+      }
+    } else if (eFrameworkunifiedStatusDbRecNotFound == eStatus) {
+      // FIXME: This is added to help, if there is any command with no data. So, that services
+      //      don't need to provide _CWORD77_ interfaces for such command.
+      //       Correct way to solve the problem is, let services provide one _CWORD77_ interface
+      //     which will write 0 length in data pool.
+      // Impact: This may have one impact that, service is expecting some data, but
+      //      _CWORD77_ sends data with 0 length because it didn't find anything in the data pool.
+      FRAMEWORKUNIFIEDLOG(ZONE_NS_WAR, __FUNCTION__,
+             "GetReqDataFrom_CWORD77_DataPool() returned %d. But, still sending cmd 0x%X to service %s with length 0.",
+             eStatus, cmdID, FrameworkunifiedGetSessionName(m_hService));
+      eStatus = FrameworkunifiedSendMsg(m_hSession, cmdID, 0, NULL);
+      if (eFrameworkunifiedStatusOK != eStatus) {
+        FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: FrameworkunifiedSendMsg() returned %d", eStatus);
+      }
+      // end fixme
+    } else {
+      FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__,
+             "GetReqDataFrom_CWORD77_DataPool() returned %d. Can't send cmd 0x%X to service %s.",
+             eStatus, cmdID, FrameworkunifiedGetSessionName(m_hService));
+    }
+  } else {
+    FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__,
+           "Error: HandleSessionMessage: Error sending cmd 0x%X request to service."
+           " Session handle %p Service Handle %p", cmdID, m_hSession, m_hService);
+    if (NULL == m_hSession) {
+      eStatus = eFrameworkunifiedStatusSessionErr;
+    }
+  }
+
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "- %d", eStatus);
+  return eStatus;
+}
+
+//////////////////////////////////////////
+/// Function : AttachResponseCallbacks
+//////////////////////////////////////////
+void CFrameworkunified_CWORD77_Session::AttachResponseCallbacks(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");   // LCOV_EXCL_BR_LINE 15:marco defined in "native_service/ns_logger_if.h"
+  UI_32 l_uiCount = 0;
+  PCSTR l_pRequester   = FrameworkunifiedGetMsgSrc(f_hApp);
+
+  // attach response protocols
+  UI_32 const *l_uiResponseProtocol = GetResponseProtocolArray();
+  if (NULL != l_uiResponseProtocol) {
+    for (; l_uiCount < GetResponseProtocolArrayLength(); l_uiResponseProtocol++, l_uiCount++) {
+      FrameworkunifiedAttachCallbackToDispatcher(f_hApp, l_pRequester, *l_uiResponseProtocol,
+                                    boost::bind(&CFrameworkunified_CWORD77_Session::OnResponse, this, f_hApp), m_hSession);
+    }
+  } else {
+    FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "No Response protocols available for session with %s",
+           FrameworkunifiedGetSessionName(m_hService));
+  }
+
+  // attach events
+  l_uiCount = 0;
+  UI_32 const *l_uiEvents = GetEventArray();
+  if (NULL != l_uiEvents) {
+    for (; l_uiCount < GetEventArrayLength(); l_uiEvents++, l_uiCount++) {
+      // attach callback
+      FrameworkunifiedAttachCallbackToDispatcher(f_hApp, l_pRequester, *l_uiEvents,
+                                    boost::bind(&CFrameworkunified_CWORD77_Session::OnResponse, this, f_hApp), m_hSession);  // LCOV_EXCL_BR_LINE 11:except branch
+      // register event
+      FrameworkunifiedRegisterEvent(m_hSession, *l_uiEvents);
+    }
+  } else {
+    FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "No event protocols available for session with %s",
+      FrameworkunifiedGetSessionName(m_hService));
+  }
+
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "-");   // LCOV_EXCL_BR_LINE 15:marco defined in "native_service/ns_logger_if.h"
+}
+
+//////////////////////////////////////////
+/// Function : DetachResponseCallbacks
+//////////////////////////////////////////
+void CFrameworkunified_CWORD77_Session::DetachResponseCallbacks(HANDLE f_hApp) {
+  if (NULL != m_hSession) {
+    UI_32 l_uiCount = 0;
+    PCSTR l_cSessionName   = FrameworkunifiedGetSessionName(m_hSession);
+    // detach response protocols
+    UI_32 const *l_uiResponseProtocol = GetResponseProtocolArray();
+    if (NULL != l_uiResponseProtocol) {
+      for (; l_uiCount < GetResponseProtocolArrayLength(); l_uiResponseProtocol++, l_uiCount++) {
+        FrameworkunifiedDetachCallbackFromDispatcher(f_hApp, l_cSessionName, *l_uiResponseProtocol, m_hSession);
+      }
+    } else {
+      FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "No Response protocols available for session with %s",
+             FrameworkunifiedGetSessionName(m_hService));
+    }
+
+    // detach and unregister events
+    l_uiCount = 0;
+    UI_32 const *l_uiEvents = GetEventArray();
+    if (NULL != l_uiEvents) {
+      for (; l_uiCount < GetEventArrayLength(); l_uiEvents++, l_uiCount++) {
+        FrameworkunifiedDetachCallbackFromDispatcher(f_hApp, l_cSessionName, *l_uiEvents, m_hSession);
+        FrameworkunifiedUnRegisterEvent(m_hSession, *l_uiEvents);
+      }
+    } else {
+      FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "No event protocols available for session with %s",
+        FrameworkunifiedGetSessionName(m_hService));
+    }
+  } else {
+    FRAMEWORKUNIFIEDLOG(ZONE_NS_INFO, __FUNCTION__, "Detach not required. Session not yet available");
+  }
+}
+
+//////////////////////////////////////////
+/// Function : OnResponse
+//////////////////////////////////////////
+EFrameworkunifiedStatus CFrameworkunified_CWORD77_Session::OnResponse(HANDLE f_hApp) {
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "+");
+  EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK;
+
+  UI_32 length = FrameworkunifiedGetMsgLength(f_hApp);
+  UI_32 cmdId = FrameworkunifiedGetMsgProtocol(f_hApp);
+  PCSTR l_cMsgSourceName = FrameworkunifiedGetMsgSrc(f_hApp);
+  if (NULL != l_cMsgSourceName) {
+    if (length != 0) {
+      std::vector<char> data;
+      data.resize(length);
+      eStatus = FrameworkunifiedGetMsgDataOfSize(f_hApp, &data[0], length);
+      FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "OnResponse from %s cmdId:%d", l_cMsgSourceName, cmdId);
+      SetRespDataIn_CWORD77_DataPool(std::make_pair(cmdId, l_cMsgSourceName), static_cast<UI_32>(data.size()), &data[0]);
+    } else {
+      FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "OnResponse from %s cmdId:[%d], Value: [NULL]", l_cMsgSourceName, cmdId);
+      SetRespDataIn_CWORD77_DataPool(std::make_pair(cmdId, l_cMsgSourceName), 0, NULL);
+    }
+
+    m_ResponseTo_CWORD77_(f_hApp, RESPONSE, l_cMsgSourceName);
+  } else {
+    FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: Setting response value of cmd 0x%X in data pool.", cmdId);
+  }
+
+  FRAMEWORKUNIFIEDLOG(ZONE_NS__CWORD77_, __FUNCTION__, "- %d", eStatus);
+  return eStatus;
+}
+