summaryrefslogtreecommitdiffstats
path: root/video_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'video_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp')
-rwxr-xr-xvideo_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp151
1 files changed, 0 insertions, 151 deletions
diff --git a/video_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp b/video_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp
deleted file mode 100755
index 692cab8..0000000
--- a/video_in_hal/systemservice/logger_service/server/src/ss_logger_reader_writer_control.cpp
+++ /dev/null
@@ -1,151 +0,0 @@
-/*
- * @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.
- */
-
-/*
- * ss_logger_reader_writer_control.cpp
- */
-#include "ss_logger_reader_writer_control.h"
-#include <boost/bind.hpp>
-#include <native_service/ns_sharedmem.h>
-#include <native_service/ns_transmit_log.h>
-#include <native_service/ns_logger_if.h>
-#include <string>
-#include "ss_logger_common.h"
-
-#define LOGGERSERVICELOG_REMOTE_IP_PORT 3500
-#define TRANSMIT_REMOTE_IP_PORT 3500
-
-CReaderWriterControl::CReaderWriterControl()
- : m_pLoggerCfg(NULL) { // LCOV_EXCL_BR_LINE 11:Unexpected branch
-}
-
-CReaderWriterControl::~CReaderWriterControl() { // LCOV_EXCL_START 14:globle instance
- AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert
-}
-// LCOV_EXCL_STOP
-
-EFrameworkunifiedStatus CReaderWriterControl::Initialize(CLoggerCfg * f_pLoggerCfg) {
- EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
- if (NULL != f_pLoggerCfg) { // LCOV_EXCL_BR_LINE 200:As it is not always NULL
- this->m_pLoggerCfg = f_pLoggerCfg;
-
- l_eStatus = m_debugReaderWriter.Initialize( // LCOV_EXCL_BR_LINE 11:Unexpected branch
- f_pLoggerCfg, ReaderWriter::eReaderWriterTypeMem, std::string(FRAMEWORKUNIFIEDLOG_SHAREDMEM_NAME),
- FRAMEWORKUNIFIEDLOG_SHAREDMEM_SIZE, ReaderWriter::eReaderWriterTypeUdp,
- std::string("169.254.80.9"), LOGGERSERVICELOG_REMOTE_IP_PORT, "", 0); // LCOV_EXCL_BR_LINE 11:except,C++ STL
- if (eFrameworkunifiedStatusOK == l_eStatus) { // LCOV_EXCL_BR_LINE 200:To ensure success
- l_eStatus = m_debugReaderWriter.Start(std::string("pdg.LogQueR"));
- }
-
- LOG_STATUS_IF_ERRORED( // LCOV_EXCL_BR_LINE 15:macro
- l_eStatus, "m_debugReaderWriter.Start(std::string(pdg.TransQueR)");
-
-
- l_eStatus = m_transmitReaderWriter.Initialize( // LCOV_EXCL_BR_LINE 11:Unexpected branch
- f_pLoggerCfg, ReaderWriter::eReaderWriterTypeMem,
- std::string(TRANSMIT_LOG_SHAREDMEM_NAME), TRANSMIT_LOG_SHAREDMEM_SIZE,
- ReaderWriter::eReaderWriterTypeUdp, std::string("169.254.80.9"),
- TRANSMIT_REMOTE_IP_PORT, "", 0); // LCOV_EXCL_BR_LINE 11:except,C++ STL
- if (eFrameworkunifiedStatusOK == l_eStatus) { // LCOV_EXCL_BR_LINE 6:it can not be fail
- l_eStatus = m_transmitReaderWriter.Start(std::string("pdg.TransQueR")); // LCOV_EXCL_BR_LINE 11:except,C++ STL
- }
-
- LOG_STATUS_IF_ERRORED( // LCOV_EXCL_BR_LINE 15:macro
- l_eStatus, "m_transmitReaderWriter.Start(std::string(pdg.TransQueR)");
-
-
- l_eStatus = m_performanceReaderWriter.Initialize( // LCOV_EXCL_BR_LINE 11:Unexpected branch
- f_pLoggerCfg, ReaderWriter::eReaderWriterTypeQueue, std::string("/NSplog"), 0,
- ReaderWriter::eReaderWriterTypeFile, std::string(PERFORMANCE_LOG_PATH_FN),
- f_pLoggerCfg->m_performanceLogMaxFileSize, std::string("169.254.80.9"),
- 0); // LCOV_EXCL_BR_LINE 11:except,C++ STL
-
- if (eFrameworkunifiedStatusOK == l_eStatus) { // LCOV_EXCL_BR_LINE 6:it can not be fail
- l_eStatus = m_performanceReaderWriter.Start(
- std::string("pdg.PerformQueR")); // LCOV_EXCL_BR_LINE 11:except,C++ STL
- }
-
- LOG_STATUS_IF_ERRORED( // LCOV_EXCL_BR_LINE 15:macro
- l_eStatus,
- "m_performanceReaderWriter.Start(std::string(pdg.PerformQueR)");
-
-
- this->m_pLoggerCfg->AddLoggingParamCB(
- boost::bind(&CReaderWriterControl::UpdateLoggingParams, this, _1));
- }
- return (l_eStatus);
-}
-
-EFrameworkunifiedStatus CReaderWriterControl::UpdateLoggingParams(void* param) {
- FRAMEWORKUNIFIEDLOG(ZONE_FUNC, __FUNCTION__, "+");
- EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusOK;
- l_eStatus = this->m_debugReaderWriter.UpdateLoggingParameters();
- LOG_STATUS_IF_ERRORED(l_eStatus, // LCOV_EXCL_BR_LINE 15:macro
- "this->m_debugReaderWriter.UpdateLoggingParameters()");
-
- l_eStatus = this->m_transmitReaderWriter.UpdateLoggingParameters();
- LOG_STATUS_IF_ERRORED( // LCOV_EXCL_BR_LINE 15:macro
- l_eStatus, "this->m_transmitReaderWriter.UpdateLoggingParameters()");
-
- l_eStatus = this->m_performanceReaderWriter.UpdateLoggingParameters();
- LOG_STATUS_IF_ERRORED( // LCOV_EXCL_BR_LINE 15:macro
- l_eStatus,
- "this->m_performanceReaderWriter."
- "UpdateLoggingParameters()");
-
- FRAMEWORKUNIFIEDLOG(ZONE_FUNC, __FUNCTION__, "- : %d", l_eStatus);
- return (l_eStatus);
-}
-
-EFrameworkunifiedStatus CReaderWriterControl::FlushCache(EReaderWriterType f_type) {
- FRAMEWORKUNIFIEDLOG(ZONE_FUNC, __FUNCTION__, "+");
- EFrameworkunifiedStatus l_eStatus = eFrameworkunifiedStatusInvldParam;
- switch (f_type) { // LCOV_EXCL_BR_LINE 8: eReaderWriterLogDebug and eReaderWriterLogInvalid can not be called
- // LCOV_EXCL_START 8: dead code
- case eReaderWriterLogDebug:
- AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert
- l_eStatus = this->m_debugReaderWriter.FlushCache(
- std::string(DEBUG_LOG_PATH_FN));
- LOG_STATUS_IF_ERRORED(
- l_eStatus, "this->m_debugReaderWriter.FlushCache(DEBUG_LOG_PATH_FN)");
- break;
- // LCOV_EXCL_STOP
- case eReaderWriterLogTransmit:
- l_eStatus = this->m_transmitReaderWriter.FlushCache(
- std::string(TRANSMIT_LOG_PATH_FN));
- LOG_STATUS_IF_ERRORED(
- l_eStatus,
- "this->m_debugReaderWriter.FlushCache(TRANSMIT_LOG_PATH_FN)");
- break;
-
- case eReaderWriterLogPerformance:
- l_eStatus = this->m_performanceReaderWriter.FlushCache(
- std::string(PERFORMANCE_LOG_PATH_FN));
- LOG_STATUS_IF_ERRORED(
- l_eStatus,
- "this->m_debugReaderWriter.FlushCache(PERFORMANCE_LOG_PATH_FN)");
- break;
- // LCOV_EXCL_START 8: dead code
- case eReaderWriterLogInvalid:
- default:
- AGL_ASSERT_NOT_TESTED(); // LCOV_EXCL_LINE 200: test assert
- break;
- // LCOV_EXCL_STOP
- }
- FRAMEWORKUNIFIEDLOG(ZONE_FUNC, __FUNCTION__, "- : %d", l_eStatus);
- return (l_eStatus);
-}
-