1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
|
/*
* @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_NS_LogTraceSender
/// \brief frameworkunifieddebug writer thread class, handles writing a log file
/// all really done by my_writer class.
///
///////////////////////////////////////////////////////////////////////////////
#ifndef LOGGER_SERVICE_SERVER_INCLUDE_LOGGERSERVICEDEBUG_WRITER_EVNTWORKER_H_
#define LOGGER_SERVICE_SERVER_INCLUDE_LOGGERSERVICEDEBUG_WRITER_EVNTWORKER_H_
#include <stdlib.h>
#include <native_service/frameworkunified_types.h>
#include <native_service/frameworkunified_framework_if.h>
#include <native_service/frameworkunified_multithreading.h>
#include <system_service/ss_devicedetection_service_ifc.h>
#include <native_service/ns_logger_if.h>
#include <native_service/ns_eventlogger.h>
#include <map>
#include <iostream>
#include <deque>
#include "loggerservicedebug_thread_if.h"
// File path names for Evnet and counter logs
extern const CHAR DEBUG_EVNTLOG_PATH_FN[];
extern const CHAR g_strEvntLogQueWorkerName[];
extern const CHAR DEBUG_LOG_PATH_FN[];
extern const CHAR Counter_LOG_PATH_FN[];
extern const CHAR Counter_LOG_PATH_STARTFN[];
extern const CHAR Counter_LOG_PATH_SHUTFN[];
extern const CHAR Mileage_LOG_PATH_FN[];
typedef struct _TevntWriterInfo {
static const UI_32 FN_LEN = 256;
UI_32 max_filelen;
CHAR base_cnt_filename[FN_LEN];
CHAR mileage_filename[FN_LEN];
} TEvntWriterInfo;
typedef enum _eDatatype_ {
COMMON_DATA,
EVENT_SPECIFIC_DATA
} EDatatype_SS;
typedef enum _eSystemPhase_ {
STARTUP_SS = 0x21,
NORMAL_SS = 0x22,
SHUTDOWN_SS = 0x23
} ESystemPhase_SS;
#pragma pack(1)
typedef struct _stLogEventFull_ {
UI_32 ts;
UI_8 grp_ID;
UI_8 event_id;
UI_8 data[4];
ESystemPhase_SS phase;
UI_16 cnt_ID;
EDatatype_SS typeofdata;
} st_LogEvent_full;
#pragma pack(0)
// Deque to hold the Event information
typedef std::deque<st_LogEvent_ss> DEQUE_Event_Type;
// Map to hold the Counter information on phase
typedef std::map<UI_16, UI_32> Counter;
/*Map to hold the all the counter information */
typedef std::map<EStatCounterGroupID, Counter> CounterInformation;
class CEvntWriterWorker {
public:
CEvntWriterWorker();
CEvntWriterWorker(TEvntWriterInfo & wi); // NOLINT (runtime/references)
virtual ~CEvntWriterWorker();
// initialize the object
EFrameworkunifiedStatus Initialize(HANDLE hThread);
/// Copy event logs to USB request from parent thread
EFrameworkunifiedStatus OnCmdWriteEventFilesToUsb(HANDLE hThread);
/// Event logging request from NS logger
EFrameworkunifiedStatus OnCmdEventLog(UI_8* pbuf);
/// Clear event logs request from parent thread
EFrameworkunifiedStatus OnCmdClearEventLogs(HANDLE hThread);
/// Read statistical counter request from parent thread
EFrameworkunifiedStatus OnCmdReadStatisticalCounter(HANDLE hThread);
/// Read statistical counter based on counter group ID
EFrameworkunifiedStatus ReadStatisticalCounter(EStatCounterGroupID eStatCounterGroupID,
SStatisticalCounter& buffer); // NOLINT (runtime/references)
/// Reset statistical counter request from parent thread
EFrameworkunifiedStatus OnCmdResetStatisticalCounter(HANDLE hThread);
/// Reset statistical counter based on counter group ID
EFrameworkunifiedStatus ResetStatisticalCounter(EStatCounterGroupID eStatCounterGroupID);
EFrameworkunifiedStatus OnCmdStop(HANDLE hThread);
EFrameworkunifiedStatus OnCmdStart(HANDLE hThread);
/// Counter logging request from NS logger
EFrameworkunifiedStatus OnCmdIncrcount(UI_8* pbuf);
/// Event and Counter logging request from NS logger
EFrameworkunifiedStatus OnCmdIncrwriteevent(UI_8* pbuf);
/// Reading counter value from file based on phase
EFrameworkunifiedStatus readCountFromFile(PCSTR filename);
/// Writing counter value from file based on phase
EFrameworkunifiedStatus writeCountToFile(PCSTR filename);
/// Writing event value from file based on phase
EFrameworkunifiedStatus write_event_to_file(const CHAR* filename);
/// Copy event files to USB based onUSB device number
UI_8 copy_event_files_to_usb(TThrdEvtLogStore *pStUSBIndo);
/// Functioncall to populate the counter value to map
VOID OnCmdIncrcount_phase(st_LogCount *cnt);
/// Function call to populate the event value to deque
VOID OnCmdWriteEventLogs(st_LogEvent_ss *ev);
/// Set the VIN number
EFrameworkunifiedStatus OnCmdSetVIN(HANDLE hThread);
/// Get the VIN number
VOID OnCmdGetVIN(STVIN_NUMBER& f_stVIN_Number); // NOLINT (runtime/references)
/// Functional call to write events from deque to local buffer
VOID write_events_to_buffer(STEventLogPersistBuffer* f_stEvtLogBuf);
/// Functional call to read events from buffer to deque
VOID read_events_from_buffer(STEventLogPersistBuffer* f_stEvtLogBuf);
/// Functional call to immediate persist event log
EFrameworkunifiedStatus immediate_persist_event_log(HANDLE hThread);
/// Functional call to set mileage information in Evt thread space
EFrameworkunifiedStatus EvtThd_SetMileage(HANDLE hThread);
/// Functional call to write mileage data to file for persisting
EFrameworkunifiedStatus write_mileage_to_file(const CHAR* filename);
/// Functional call to read mileage data from persistent file during startup
EFrameworkunifiedStatus read_mileage_from_file(const CHAR* filename);
EFrameworkunifiedStatus OnCmdReadNumberOfEventsLogged(HANDLE hThread);
EFrameworkunifiedStatus EventLogRegisterCbHandlers(HANDLE hThread);
EFrameworkunifiedStatus OnCmdUploadEventLog(HANDLE hThread);
EFrameworkunifiedStatus OnCmdCopyEvntLogToTmp(HANDLE hThread);
/// Static Members for Event and counter logging
static CounterInformation counter;
static DEQUE_Event_Type deque_event_info;
private:
STVIN_NUMBER m_stVINnumber;
UI_32 m_u32MileageData;
UI_32 m_u32NumberEventsLogged;
TUploadEventLogResp m_stUploadEventLogResp;
EFrameworkunifiedStatus counterIncrementByValue(EStatCounterGroupID group, UI_16 id,
UI_32 value);
EFrameworkunifiedStatus writeGroupToFile(FILE *fp, EStatCounterGroupID group);
};
/// Event logging Child thread start and shut down functions
EFrameworkunifiedStatus EvntWriterWorkerOnStart(HANDLE hThread);
EFrameworkunifiedStatus EvntWriterWorkerOnStop(HANDLE hThread);
/// USBdevice detectioncall backs
EFrameworkunifiedStatus DD_USBSrvDetectionCallBack(HANDLE hApp);
EFrameworkunifiedStatus DD_USBServiceAvailabilityCallBack(HANDLE hThread);
EFrameworkunifiedStatus DD_USBOpenSessionAckCallBack(HANDLE hThread);
EFrameworkunifiedStatus DD_USBCloseSessionAckCallBack(HANDLE hApp);
inline void u16copy(PUI_8 pDest, UI_16 Source) {
*(pDest++) = (UI_8) (Source & 0x00FF);
*(pDest++) = (UI_8) ((Source & 0xFF00) >> 8);
}
inline void u32copy(PUI_8 pDest, UI_32 Source) {
*(pDest++) = (UI_8) (Source & 0x000000FF);
*(pDest++) = (UI_8) ((Source & 0x0000FF00) >> 8);
*(pDest++) = (UI_8) ((Source & 0x00FF0000) >> 16);
*(pDest++) = (UI_8) ((Source & 0xFF000000) >> 24);
}
#endif // LOGGER_SERVICE_SERVER_INCLUDE_LOGGERSERVICEDEBUG_WRITER_EVNTWORKER_H_
|
