diff options
Diffstat (limited to 'nsframework/framework_unified/client/NS_FrameworkCore/src/frameworkunified_multithreading.cpp')
| -rw-r--r-- | nsframework/framework_unified/client/NS_FrameworkCore/src/frameworkunified_multithreading.cpp | 531 |
1 files changed, 531 insertions, 0 deletions
diff --git a/nsframework/framework_unified/client/NS_FrameworkCore/src/frameworkunified_multithreading.cpp b/nsframework/framework_unified/client/NS_FrameworkCore/src/frameworkunified_multithreading.cpp new file mode 100644 index 00000000..986f3b34 --- /dev/null +++ b/nsframework/framework_unified/client/NS_FrameworkCore/src/frameworkunified_multithreading.cpp @@ -0,0 +1,531 @@ +/* + * @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_NSFramework +/// \brief Framework wrapper over the service directory interface APIs +/// +/// +/// +/////////////////////////////////////////////////////////////////////////////// + +#include <pthread.h> +#include <errno.h> +#include <string.h> +#include <sys/prctl.h> +#include <sys/resource.h> +#include <sys/syscall.h> + +#include <native_service/frameworkunified_dispatcher.h> +#include <native_service/frameworkunified_multithreading.h> +#include <native_service/ns_utility.hpp> +#include <native_service/ns_message_center_if.h> +#include <native_service/frameworkunified_framework_if.h> +#include <native_service/ns_system_mode.h> +#include <native_service/ns_logger_if.h> +#include <native_service/frameworkunified_sm_hsmframework.h> +#include <native_service/frameworkunified_sm_framework_dispatch.h> + +#include <iostream> + +#ifdef DISPATCHER_PROFILER +#include <boost/bind.hpp> +#include "frameworkunified_msgprofiler.h" +#endif + +#include "frameworkunified_framework_core.h" +#include "frameworkunified_framework_utility.h" +#include "frameworkunified_framework_internal.h" +#include "frameworkunified_sm_multithreading_internal.h" + +__thread HANDLE responseWaitQ = NULL; + +//////////////////////////////////////////////////////////////////////////////////////////// +/// IsValidWaitBarrier +//////////////////////////////////////////////////////////////////////////////////////////// +bool IsValidWaitBarrier(int wbret) { + return (PTHREAD_BARRIER_SERIAL_THREAD == wbret) || + (0 == wbret); +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// DestroyThread +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus DestroyThread(HANDLE hApp) { + // terminates the dispatcher loop to destroy the thread + if (responseWaitQ != NULL) { + /** + * @todo + * The responseWaitQ is set in the FrameworkunifiedInvokeSync and is closed in the callback process (DestroyThread) of the FrameworkunifiedDestroyChildThread. + * Therefore, the responseWaitQ is not closed when FrameworkunifiedInvokeSync is used on the parent. + */ + McClose(responseWaitQ); + responseWaitQ = NULL; + } + return eFrameworkunifiedStatusExit; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// setChildThreadSched +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus setChildThreadSched(EFrameworkunifiedSchedPolicy policy, SI_32 priority) { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + struct sched_param param; + int get_policy, set_policy; + int set_priority; + + if (pthread_getschedparam(pthread_self(), &get_policy, ¶m) != 0) { + // LCOV_EXCL_BR_START 15:marco defined in "native_service/ns_logger_if.h" + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: pthread_getschedparam errno:%d", errno); + // LCOV_EXCL_BR_STOP + return eFrameworkunifiedStatusFail; + } + + if (policy == eFrameworkunifiedSchedPolicyInherit) { + set_policy = get_policy; + } else { + if (policy == eFrameworkunifiedSchedPolicyFIFO) { + set_policy = SCHED_FIFO; + } else if (policy == eFrameworkunifiedSchedPolicyRR) { + set_policy = SCHED_RR; + } else { + set_policy = SCHED_OTHER; + } + } + + if (priority == INHERIT_PARENT_THREAD_PRIO) { + if (get_policy != set_policy) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_WAR, __FUNCTION__, "Warning: Change policy(%d-%d) but inherit priority", get_policy, set_policy); + + if (set_policy == SCHED_OTHER) { + set_priority = 0; + } else { + set_priority = sched_get_priority_min(set_policy); + } + } else { + set_priority = param.sched_priority; + } + } else { + set_priority = priority; + } + + switch (set_policy) { + case SCHED_OTHER: + param.sched_priority = 0; + if (pthread_setschedparam(pthread_self(), SCHED_OTHER, ¶m) != 0) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: pthread_setschedparam errno:%d", errno); + eStatus = eFrameworkunifiedStatusFail; + } else { + if (setpriority(PRIO_PROCESS, static_cast<int>(syscall(__NR_gettid)), set_priority) != 0) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: setpriority errno:%d", errno); + eStatus = eFrameworkunifiedStatusFail; + } + } + break; + + case SCHED_FIFO: + case SCHED_RR: + param.sched_priority = set_priority; + if (pthread_setschedparam(pthread_self(), set_policy, ¶m) != 0) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: pthread_setschedparam errno:%d", errno); + eStatus = eFrameworkunifiedStatusFail; + } + break; + } + + return eStatus; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// child_thread_proc +//////////////////////////////////////////////////////////////////////////////////////////// +void *child_thread_proc(void *args) { + if (args == NULL) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __func__, "args is NULL"); + return NULL; + } + PCData pcdata = *reinterpret_cast< PCData * >(args); // Create a local copy of data + + try { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + HANDLE hApp = NULL; + + if (eFrameworkunifiedStatusOK == (eStatus = FrameworkunifiedCreateDispatcherChild(hApp, + pcdata.childName.c_str(), + pcdata.parentName.c_str()))) { + // LCOV_EXCL_BR_START 200: If FrameworkunifiedCreateDispatcherChild return eFrameworkunifiedStatusOK, hApp would also be valid. + if (frameworkunifiedCheckValidAppHandle(hApp)) { + // LCOV_EXCL_BR_STOP + THApp hChildApp(hApp); + + const FrameworkunifiedProtocolCallbackHandler pcbhs[] = { { SYSTEM_ON_INITIALIZATION, pcdata.initFn }, + { SYSTEM_ON_SHUTDOWN, pcdata.shdnFn }, + { SYSTEM_ON_DESTROY, DestroyThread } + }; // LCOV_EXCL_BR_LINE 11:except branch + + if (eFrameworkunifiedStatusOK != FrameworkunifiedAttachCallbacksToDispatcher(hChildApp, + pcdata.parentName.c_str(), + &pcbhs[ 0 ], + static_cast<UI_32>(_countof(pcbhs)))) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, + "Error: Attaching child callbacks to dispatcher %s", pcdata.childName.c_str()); + } + + char thread_name[16]; + strncpy(thread_name, pcdata.childName.c_str(), sizeof(thread_name)); + prctl(PR_SET_NAME, thread_name); + thread_name[15] = '\0'; + + setChildThreadSched(pcdata.schedPolicy, pcdata.schedPriority); + + *pcdata.childStatus = eFrameworkunifiedStatusOK; + if (IsValidWaitBarrier(pthread_barrier_wait(pcdata.barrier))) { + RunChildDispatcher(hChildApp); + } + } else { + // LCOV_EXCL_START 200: If FrameworkunifiedCreateDispatcherChild return eFrameworkunifiedStatusOK, hApp would also be valid. + AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "hApp is NULL"); + // LCOV_EXCL_STOP + } + } else { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "FrameworkunifiedCreateDispatcherChild error, status=%d", eStatus); + + *pcdata.childStatus = eFrameworkunifiedStatusFail; + pthread_barrier_wait(pcdata.barrier); + } + } catch (const THApp::Exception &) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Error: Failed to create child %s", pcdata.childName.c_str()); + } + + return NULL; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// CreateChildThread +//////////////////////////////////////////////////////////////////////////////////////////// +HANDLE CreateChildThread(HANDLE hApp, PCSTR childName, CbFuncPtr CbInitialize, CbFuncPtr CbShutdown, + const FrameworkunifiedChildThreadAttr *attr, CbFuncPtr CbCreateStateMachine) { + HANDLE hChildQ = NULL; + pthread_attr_t tAttr; + pthread_attr_t *pAttr = NULL; + SI_32 l_iThrCreate = 0; + EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK; + + if (frameworkunifiedCheckValidAppHandle(hApp) && NULL != childName && strlen(childName) < LIMIT_NAME_SIZE_APP && + NULL != CbInitialize && NULL != CbShutdown && NULL != attr) { + if (attr->schedPolicy < eFrameworkunifiedSchedPolicyInherit || attr->schedPolicy >= eFrameworkunifiedSchedPolicyMAX) { + l_eStatus = eFrameworkunifiedStatusInvldParam; + } else { + if (EOK == pthread_attr_init(&tAttr)) { + if (EOK != pthread_attr_setinheritsched(&tAttr, PTHREAD_INHERIT_SCHED)) { + l_eStatus = eFrameworkunifiedStatusFail; + } else { + pAttr = &tAttr; + } + } + } + + if (eFrameworkunifiedStatusOK == l_eStatus) { + pthread_barrier_t barrier; + if (EOK == pthread_barrier_init(&barrier, NULL, 2)) { + PCData pc(&barrier, &l_eStatus, FrameworkunifiedGetAppName(hApp), childName, CbInitialize, CbShutdown, + attr->schedPolicy, attr->schedPriority, CbCreateStateMachine); + pthread_t childThread = 0; + + if (NULL != CbCreateStateMachine) { + l_iThrCreate = pthread_create(&childThread, pAttr, child_hsm_thread_proc, &pc); + } else { + l_iThrCreate = pthread_create(&childThread, pAttr, child_thread_proc, &pc); + } + + if (EOK == l_iThrCreate) { + if (IsValidWaitBarrier(pthread_barrier_wait(&barrier))) { + if (eFrameworkunifiedStatusOK == l_eStatus) { + hChildQ = McOpenSenderChild(childName, childThread); + } + } + } + pthread_barrier_destroy(&barrier); + } + } +#ifdef DISPATCHER_PROFILER + if (TRUE == FrameworkunifiedMsgProfiler::m_bMsgProfilerEnabled) { + CFrameworkunifiedFrameworkApp *pApp = static_cast<CFrameworkunifiedFrameworkApp *>(hApp); + if (NULL != pApp->m_pFrameworkunifiedMsgProfiler) { + pApp->m_pFrameworkunifiedMsgProfiler->AddChildName(childName); + } + } +#endif + } + return hChildQ; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// CreateChildThreadAttrInit +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus CreateChildThreadAttrInit(FrameworkunifiedChildThreadAttr *attr) { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + + if (attr == NULL) { + eStatus = eFrameworkunifiedStatusNullPointer; + } else { + memset(attr, 0, sizeof(FrameworkunifiedChildThreadAttr)); + attr->schedPolicy = eFrameworkunifiedSchedPolicyInherit; + attr->schedPriority = INHERIT_PARENT_THREAD_PRIO; + } + + return eStatus; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// CreateChildThreadAttrSetSched +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus CreateChildThreadAttrSetSched(FrameworkunifiedChildThreadAttr *attr, EFrameworkunifiedSchedPolicy policy, SI_32 priority) { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + + if (attr == NULL) { + eStatus = eFrameworkunifiedStatusNullPointer; + } else { + if (policy < eFrameworkunifiedSchedPolicyInherit || policy >= eFrameworkunifiedSchedPolicyMAX) { + eStatus = eFrameworkunifiedStatusInvldParam; + } else { + attr->schedPolicy = policy; + attr->schedPriority = priority; + } + } + + return eStatus; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateChildThreadAttrInit +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedCreateChildThreadAttrInit(FrameworkunifiedChildThreadAttr *attr) { + return CreateChildThreadAttrInit(attr); +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateChildThreadAttrSetSched +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedCreateChildThreadAttrSetSched(FrameworkunifiedChildThreadAttr *attr, EFrameworkunifiedSchedPolicy policy, SI_32 priority) { + return CreateChildThreadAttrSetSched(attr, policy, priority); +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateChildThread +//////////////////////////////////////////////////////////////////////////////////////////// +HANDLE FrameworkunifiedCreateChildThread(HANDLE hApp, PCSTR childName, CbFuncPtr CbInitialize + , CbFuncPtr CbShutdown) { + HANDLE hChildQ = NULL; + FrameworkunifiedChildThreadAttr attr; + + if (frameworkunifiedCheckValidAppHandle(hApp) && NULL != childName && strlen(childName) < LIMIT_NAME_SIZE_APP && + NULL != CbInitialize && NULL != CbShutdown) { + CreateChildThreadAttrInit(&attr); + hChildQ = CreateChildThread(hApp, childName, CbInitialize, CbShutdown, &attr, NULL); + } + + return hChildQ; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateChildThreadWithPriority +//////////////////////////////////////////////////////////////////////////////////////////// +HANDLE FrameworkunifiedCreateChildThreadWithPriority(HANDLE hApp, PCSTR childName, CbFuncPtr CbInitialize + , CbFuncPtr CbShutdown, SI_32 schedPrio) { + HANDLE hChildQ = NULL; + FrameworkunifiedChildThreadAttr attr; + + if (frameworkunifiedCheckValidAppHandle(hApp) && NULL != childName && strlen(childName) < LIMIT_NAME_SIZE_APP && + NULL != CbInitialize && NULL != CbShutdown) { + CreateChildThreadAttrInit(&attr); + CreateChildThreadAttrSetSched(&attr, eFrameworkunifiedSchedPolicyFIFO, schedPrio); + hChildQ = CreateChildThread(hApp, childName, CbInitialize, CbShutdown, &attr, NULL); + } + + return hChildQ; +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateChildThreadWithAttribute +//////////////////////////////////////////////////////////////////////////////////////////// +HANDLE FrameworkunifiedCreateChildThreadWithAttribute(HANDLE hApp, PCSTR childName, CbFuncPtr CbInitialize + , CbFuncPtr CbShutdown, const FrameworkunifiedChildThreadAttr *attr) { + HANDLE hChildQ = NULL; + + if (frameworkunifiedCheckValidAppHandle(hApp) && NULL != childName && strlen(childName) < LIMIT_NAME_SIZE_APP && + NULL != CbInitialize && NULL != CbShutdown && NULL != attr) { + hChildQ = CreateChildThread(hApp, childName, CbInitialize, CbShutdown, attr, NULL); + } + + return hChildQ; +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedDestroyChildThread +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedDestroyChildThread(HANDLE hApp, HANDLE hChildQ) { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + + if (frameworkunifiedCheckValidAppHandle(hApp) && NULL != hChildQ) { + eStatus = FrameworkunifiedSendChild(hApp, hChildQ, PROTOCOL_THREAD_DESTROY, 0, NULL); + + if (eFrameworkunifiedStatusOK != (eStatus = FrameworkunifiedJoinChild(hChildQ))) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "FrameworkunifiedJoinChild Error. status: %d", eStatus); + } + + // close the child message queue handle + eStatus = McClose(hChildQ); + hChildQ = NULL; + } else { + eStatus = eFrameworkunifiedStatusInvldParam; + } + + return eStatus; +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedStartChildThread +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedStartChildThread(HANDLE hApp, HANDLE hChildQ, UI_32 length, PCVOID data) { + return FrameworkunifiedSendChild(hApp, hChildQ, SYSTEM_ON_INITIALIZATION, length, data); +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedStopChildThread +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedStopChildThread(HANDLE hApp, HANDLE hChildQ, UI_32 length, PCVOID data) { + return FrameworkunifiedSendChild(hApp, hChildQ, SYSTEM_ON_SHUTDOWN, length, data); +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedSendChild +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedSendChild(HANDLE hApp, HANDLE hChildQ, UI_32 iCmd, UI_32 length, PCVOID data) { + if (frameworkunifiedCheckValidAppHandle(hApp)) { + CFrameworkunifiedFrameworkApp *pApp = reinterpret_cast< CFrameworkunifiedFrameworkApp * >(hApp); + return McSend(hChildQ, &pApp->cAppName[ 0 ], iCmd, length, data); + } + return eFrameworkunifiedStatusInvldHandle; +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedSendParent +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedSendParent(HANDLE hChildApp, UI_32 iCmd, UI_32 length, PCVOID data) { + if (frameworkunifiedCheckValidAppHandle(hChildApp)) { + CFrameworkunifiedFrameworkApp *pApp = reinterpret_cast< CFrameworkunifiedFrameworkApp * >(hChildApp); + return McSend(pApp->hParentSndMsgQ, &pApp->cAppName[ 0 ], iCmd, length, data); + } + return eFrameworkunifiedStatusInvldHandle; +} + + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedCreateDispatcherChild +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedCreateDispatcherChild(HANDLE &hChildApp, // NOLINT (readability/nolint) + PCSTR childName, + PCSTR parentName) { + EFrameworkunifiedStatus eStatus = eFrameworkunifiedStatusOK; + + if ((NULL != childName) && (NULL != parentName) && (LIMIT_NAME_SIZE_APP > strlen(parentName)) && + (LIMIT_NAME_SIZE_APP > strlen(parentName))) { + if (eFrameworkunifiedStatusOK == (eStatus = FrameworkunifiedCreateDispatcher(childName, hChildApp, TRUE))) { + // LCOV_EXCL_BR_START 200: If FrameworkunifiedCreateDispatcher return eFrameworkunifiedStatusOK, hChildApp would also be valid. + if (frameworkunifiedCheckValidAppHandle(hChildApp)) { + // LCOV_EXCL_BR_STOP + CFrameworkunifiedFrameworkApp *pApp = reinterpret_cast< CFrameworkunifiedFrameworkApp * >(hChildApp); + + memset(pApp->cParentAppName, 0, sizeof(pApp->cParentAppName)); + memcpy(pApp->cParentAppName, parentName, strlen(parentName)); + + pApp->hParentSndMsgQ = McOpenSender(parentName); + if (NULL == pApp->hParentSndMsgQ) { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "McOpenSender is NULL"); + eStatus = eFrameworkunifiedStatusNullPointer; + return eStatus; + } + pApp->uiSessionId = THREAD_SESSION_ID; + } else { + // LCOV_EXCL_START 200: If FrameworkunifiedCreateDispatcher return eFrameworkunifiedStatusOK, hChildApp would also be valid. + AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "hChildApp is NULL"); + eStatus = eFrameworkunifiedStatusNullPointer; + // LCOV_EXCL_STOP + } + } else { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "FrameworkunifiedCreateDispatcher error, status=%d", eStatus); + } + } else { + FRAMEWORKUNIFIEDLOG(ZONE_NS_ERR, __FUNCTION__, "Invalid parameter received"); + eStatus = eFrameworkunifiedStatusInvldParam; + } + return eStatus; +} + + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedJoinChild +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedJoinChild(HANDLE hChildApp) { + return McJoinChild(hChildApp); +} + +//////////////////////////////////////////////////////////////////////////////////////////// +/// FrameworkunifiedGetChildThreadPriority +//////////////////////////////////////////////////////////////////////////////////////////// +EFrameworkunifiedStatus FrameworkunifiedGetChildThreadPriority(HANDLE hChildApp, PSI_32 threadPrio) { + return McGetChildThreadPriority(hChildApp, threadPrio); +} + +EFrameworkunifiedStatus RunChildDispatcher(HANDLE hChildApp) { + EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK; + int efd; + // LCOV_EXCL_BR_START 6: RunChildDispatcher is a internal function, hChildApp would checked in child_thread_proc. + if (frameworkunifiedCheckValidAppHandle(hChildApp)) { + // LCOV_EXCL_BR_STOP +#ifdef DISPATCHER_PROFILER + // Get the application handle + CFrameworkunifiedFrameworkApp *pApp = reinterpret_cast< CFrameworkunifiedFrameworkApp * >(hChildApp); + if (TRUE == FrameworkunifiedMsgProfiler::m_bMsgProfilerEnabled) { + pApp->m_pFrameworkunifiedMsgProfiler = new(std::nothrow) FrameworkunifiedMsgProfiler(FrameworkunifiedGetAppName(hChildApp)); + if (NULL != pApp->m_pFrameworkunifiedMsgProfiler) { + FrameworkunifiedAttachChildMsgProfilerCallbacksDispatcher(hChildApp); + } + } +#endif + FrameworkunifiedGetDispatcherFD(hChildApp, &efd); + + while (eFrameworkunifiedStatusExit != l_eStatus) { + l_eStatus = frameworkunifiedFdHandler(hChildApp, efd); + } + } else { + // LCOV_EXCL_START 6: RunChildDispatcher is a internal function, hChildApp would checked in child_thread_proc. + AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert + l_eStatus = eFrameworkunifiedStatusInvldHandle; + // LCOV_EXCL_STOP + } + + return l_eStatus; +} |