log information
@@ -0,0 +1,349 @@ | ||
1 | + | |
2 | + | |
3 | +#include "_ts/c++/stdLog_.h" | |
4 | +#include <fcntl.h> | |
5 | +#include <time.h> | |
6 | + | |
7 | + | |
8 | +#define BUFFER_LEN 1024 | |
9 | + | |
10 | +CLASS_TINYSTATE(ts/c++/stdLog,ts/c++/tinyState) | |
11 | + | |
12 | + | |
13 | +#if 0 | |
14 | + | |
15 | +TS_BEGIN_IMPLEMENT | |
16 | + | |
17 | + | |
18 | +#include "ts/c++/tsIOstring.h" | |
19 | + | |
20 | +class TS_THISCLASS : public TS_BASECLASS { | |
21 | +public: | |
22 | + stdLog_( | |
23 | + tinyState * parent); | |
24 | + void inherit( | |
25 | + tinyState * parent); | |
26 | + int printf(tinyState * caller,int level,const char * fmt,...); | |
27 | + int v_printf( | |
28 | + tinyState * caller, | |
29 | + int level, | |
30 | + const char * fmt, | |
31 | + va_list arg); | |
32 | + int printf(tinyState * caller,const char * fmt,...); | |
33 | + int v_printf( | |
34 | + tinyState * caller, | |
35 | + const char * fmt, | |
36 | + va_list arg); | |
37 | +private: | |
38 | +protected: | |
39 | + int write_str(tinyState * caller, | |
40 | + int lev, | |
41 | + stdArray<char,false> * buffer); | |
42 | + stdQueue<stdString> * que; | |
43 | + stdString * log_message; | |
44 | + stdString * log_level; | |
45 | + stdString * log_line; | |
46 | + tsIOstring * out; | |
47 | + struct tm * pnow; | |
48 | + | |
49 | + static const char * message[LOG_MAX]; | |
50 | +}; | |
51 | + | |
52 | +TS_END_IMPLEMENT | |
53 | + | |
54 | +TS_BEGIN_INTERFACE | |
55 | + | |
56 | +class TS_INTERFACE : public TS_BASEINTERFACE { | |
57 | +public: | |
58 | + static int log_printf( | |
59 | + tinyState * caller, | |
60 | + int level, | |
61 | + const char * fmt,...); | |
62 | + static int log_printf( | |
63 | + tinyState * caller, | |
64 | + const char * fmt,...); | |
65 | + static const char * file; | |
66 | + static uint8_t stdout_flag; | |
67 | + static int level; | |
68 | +}; | |
69 | + | |
70 | +TS_END_INTERFACE | |
71 | + | |
72 | +#endif | |
73 | + | |
74 | + | |
75 | +stdLog_::stdLog_( | |
76 | + tinyState * _parent) | |
77 | + : tinyState_(_parent) | |
78 | +{ | |
79 | +} | |
80 | + | |
81 | +void | |
82 | +stdLog_::inherit( | |
83 | + tinyState * _parent) | |
84 | +{ | |
85 | + this->TS_BASECLASS::inherit(_parent); | |
86 | +} | |
87 | + | |
88 | + | |
89 | + | |
90 | +/******************************************* | |
91 | + INSTANCE FUNCTIONS | |
92 | +********************************************/ | |
93 | + | |
94 | +const char * | |
95 | +stdLog::file = VAR_LOG; | |
96 | +uint8_t | |
97 | +stdLog::stdout_flag = 1; | |
98 | +int | |
99 | +stdLog::level = LOG_DEFAULT; | |
100 | + | |
101 | +const char * | |
102 | +stdLog_::message[LOG_MAX] = { | |
103 | + "OFF", | |
104 | + "ERR", | |
105 | + "WAR", | |
106 | + "ACS", | |
107 | + "MSG", | |
108 | + "DEB" | |
109 | +}; | |
110 | + | |
111 | +int | |
112 | +stdLog::log_printf(tinyState * caller,int lev,const char * fmt,...) | |
113 | +{ | |
114 | +stdLog * log; | |
115 | +int ret; | |
116 | +va_list arg; | |
117 | + log = dynamic_cast<stdLog*>(caller->application->get_global("stdLog")); | |
118 | + if ( log == 0 ) { | |
119 | + log = NEW stdLog(caller->application); | |
120 | + caller->application->set_global("stdLog",log); | |
121 | + } | |
122 | + va_start(arg,fmt); | |
123 | + ret = log->v_printf(caller,lev,fmt,arg); | |
124 | + va_end(arg); | |
125 | + return ret; | |
126 | +} | |
127 | + | |
128 | +int | |
129 | +stdLog::log_printf(tinyState * caller,const char * fmt,...) | |
130 | +{ | |
131 | +stdLog * log; | |
132 | +int ret; | |
133 | +va_list arg; | |
134 | + log = dynamic_cast<stdLog*>(caller->application->get_global("stdLog")); | |
135 | + if ( log == 0 ) { | |
136 | + log = NEW stdLog(caller->application); | |
137 | + caller->application->set_global("stdLog",log); | |
138 | + } | |
139 | + va_start(arg,fmt); | |
140 | + ret = log->v_printf(caller,LOG_DEFAULT,fmt,arg); | |
141 | + va_end(arg); | |
142 | + return ret; | |
143 | +} | |
144 | + | |
145 | + | |
146 | +int | |
147 | +stdLog_::printf(tinyState * caller,int lev,const char * fmt,...) | |
148 | +{ | |
149 | +stdArray<char,false> * buffer = NEW stdArray<char,false>(BUFFER_LEN*2); | |
150 | +va_list arg; | |
151 | +int ret; | |
152 | +int bufsize; | |
153 | + if ( stdLog::level < lev ) | |
154 | + return 0; | |
155 | + if ( C_TEST(this->state,C_ZOM|C_FIN) ) | |
156 | + return -1; | |
157 | + bufsize = BUFFER_LEN*2; | |
158 | + for ( ; ; ) { | |
159 | + va_start(arg,fmt); | |
160 | + ret = vsnprintf(&buffer->ary[0],bufsize,fmt,arg); | |
161 | + va_end(arg); | |
162 | + if ( ret <= bufsize-1 ) | |
163 | + break; | |
164 | + bufsize *= 2; | |
165 | + buffer->length(bufsize); | |
166 | + } | |
167 | + return this->write_str(caller,lev,buffer); | |
168 | +} | |
169 | + | |
170 | +int | |
171 | +stdLog_::printf(tinyState * caller,const char * fmt,...) | |
172 | +{ | |
173 | +stdArray<char,false> * buffer = NEW stdArray<char,false>(BUFFER_LEN*2); | |
174 | +va_list arg; | |
175 | +int ret; | |
176 | +int bufsize; | |
177 | + if ( stdLog::level < LOG_DEFAULT ) | |
178 | + return 0; | |
179 | + if ( C_TEST(this->state,C_ZOM|C_FIN) ) | |
180 | + return -1; | |
181 | + bufsize = BUFFER_LEN*2; | |
182 | + for ( ; ; ) { | |
183 | + va_start(arg,fmt); | |
184 | + ret = vsnprintf(&buffer->ary[0],bufsize,fmt,arg); | |
185 | + va_end(arg); | |
186 | + if ( ret <= bufsize-1 ) | |
187 | + break; | |
188 | + bufsize *= 2; | |
189 | + buffer->length(bufsize); | |
190 | + } | |
191 | + return this->write_str(caller,LOG_DEFAULT,buffer); | |
192 | +} | |
193 | + | |
194 | +int | |
195 | +stdLog_::v_printf( | |
196 | + tinyState * caller, | |
197 | + int lev, | |
198 | + const char * fmt, | |
199 | + va_list start_ptr) | |
200 | +{ | |
201 | +stdArray<char,false> * buffer = NEW stdArray<char,false>(BUFFER_LEN*2); | |
202 | +int ret; | |
203 | +int bufsize; | |
204 | +va_list arg; | |
205 | + if ( stdLog::level < lev ) | |
206 | + return 0; | |
207 | + if ( C_TEST(this->state,C_ZOM|C_FIN) ) | |
208 | + return -1; | |
209 | + bufsize = BUFFER_LEN*2; | |
210 | + for ( ; ; ) { | |
211 | + va_copy(arg,start_ptr); | |
212 | + ret = vsnprintf(&buffer->ary[0],bufsize,fmt,arg); | |
213 | + va_end(arg); | |
214 | + if ( ret <= bufsize-1 ) | |
215 | + break; | |
216 | + bufsize *= 2; | |
217 | + buffer->length(bufsize); | |
218 | + } | |
219 | + return this->write_str(caller,lev,buffer); | |
220 | +} | |
221 | + | |
222 | +int | |
223 | +stdLog_::v_printf( | |
224 | + tinyState * caller, | |
225 | + const char * fmt, | |
226 | + va_list start_ptr) | |
227 | +{ | |
228 | + return v_printf(caller,LOG_DEFAULT,fmt,start_ptr); | |
229 | +} | |
230 | + | |
231 | +int | |
232 | +stdLog_::write_str(tinyState * caller, | |
233 | + int lev, | |
234 | + stdArray<char,false> * buffer) | |
235 | +{ | |
236 | + que->ins(MAX_INTEGER64,(NEW stdString(message[lev])) | |
237 | + ->add(":")->add(&buffer->ary[0])); | |
238 | + wakeup(); | |
239 | + return 0; | |
240 | +} | |
241 | + | |
242 | + | |
243 | +/******************************************* | |
244 | + STATE MACHINE | |
245 | +********************************************/ | |
246 | + | |
247 | + | |
248 | +TS_STATE(INI_TINYSTATE_FINISH) | |
249 | +{ | |
250 | + trace("LOG"); | |
251 | + REF_SET(que,(NEW stdQueue<stdString>())); | |
252 | + return ACT_START; | |
253 | +} | |
254 | +TS_STATE(ACT_START) | |
255 | +{ | |
256 | + if ( que->count ) | |
257 | + return rDO|ACT_LOGOUT; | |
258 | + return rDO|FIN_START; | |
259 | +} | |
260 | +TS_STATE(ACT_LOGOUT) | |
261 | +{ | |
262 | + if ( stdLog::file ) | |
263 | + REF_SET(out,NEW tsIOstring( | |
264 | + ifThis, | |
265 | + NEW tsIOraw( | |
266 | + ifThis, | |
267 | + stdLog::file, | |
268 | + O_RDWR|O_CREAT|O_APPEND, | |
269 | + 0644))); | |
270 | + return rDO|ACT_LOGOUT_MESSAGE; | |
271 | +} | |
272 | +TS_STATE(ACT_LOGOUT_MESSAGE) | |
273 | +{ | |
274 | + REF_SET(log_message, que->del()); | |
275 | + if ( log_message == 0 ) | |
276 | + return rDO|ACT_LOGOUT_FINISH; | |
277 | + log_message->rx("s",NEW stdRx("^([^:]+):"),""); | |
278 | + REF_SET(log_level,log_message->rxVar(1)); | |
279 | + return rDO|ACT_LOGOUT_LINE; | |
280 | +} | |
281 | +TS_STATE(ACT_LOGOUT_LINE) | |
282 | +{ | |
283 | +time_t n; | |
284 | + if ( STR_NULL(log_message)->cmp("") == 0 ) | |
285 | + return rDO|ACT_LOGOUT; | |
286 | + else if ( log_message->rx("s",NEW stdRx("^([^\n\r]*)(\n|\r|\r\n)"),"") ) { | |
287 | + REF_SET(log_line,log_message->rxVar(1)->add("\n")); | |
288 | + } | |
289 | + else { | |
290 | + REF_SET(log_line,log_message->add("\n")); | |
291 | + REF_SET(log_message,0); | |
292 | + } | |
293 | + n = time(0); | |
294 | + pnow = localtime(&n); | |
295 | + if ( stdLog::stdout_flag ) { | |
296 | + ::printf("[%04d.%02d.%02d %d:%02d:%02d %s] %s", | |
297 | + pnow->tm_year+1900, | |
298 | + pnow->tm_mon + 1, | |
299 | + pnow->tm_mday, | |
300 | + pnow->tm_hour, | |
301 | + pnow->tm_min, | |
302 | + pnow->tm_sec, | |
303 | + log_level->get_str(), | |
304 | + log_line->get_str()); | |
305 | + ::fflush(stdout); | |
306 | + } | |
307 | + if ( out == 0 ) | |
308 | + return rDO|ACT_LOGOUT_MESSAGE; | |
309 | + out->printf(ifThis,"[%04d.%02d.%02d %d:%02d:%02d %s] %s", | |
310 | + pnow->tm_year+1900, | |
311 | + pnow->tm_mon + 1, | |
312 | + pnow->tm_mday, | |
313 | + pnow->tm_hour, | |
314 | + pnow->tm_min, | |
315 | + pnow->tm_sec, | |
316 | + log_level->get_str(), | |
317 | + log_line->get_str()); | |
318 | + return ACT_LOGOUT_LINE_RET; | |
319 | +} | |
320 | +TS_STATE(ACT_LOGOUT_LINE_RET) | |
321 | +{ | |
322 | + if ( ev->type != TSE_RETURN ) | |
323 | + return 0; | |
324 | + return rDO|ACT_LOGOUT_LINE; | |
325 | +} | |
326 | +TS_STATE(ACT_LOGOUT_FINISH) | |
327 | +{ | |
328 | + out->listen(ifThis,TSE_DESTROY); | |
329 | + out->destroy(); | |
330 | + return rDO|ACT_LOGOUT_FINISH_RET; | |
331 | +} | |
332 | +TS_STATE(ACT_LOGOUT_FINISH_RET) | |
333 | +{ | |
334 | + if ( C_TEST(out->state,C_ZOM) == 0 ) | |
335 | + return 0; | |
336 | + REF_SET(out,0); | |
337 | + return rDO|ACT_START; | |
338 | +} | |
339 | + | |
340 | +TS_STATE(FIN_START) | |
341 | +{ | |
342 | + REF_SET(out,0); | |
343 | + REF_SET(log_line,0); | |
344 | + REF_SET(log_message,0); | |
345 | + REF_SET(log_level,0); | |
346 | + REF_SET(que,0); | |
347 | + application->del_global("stdLog"); | |
348 | + return rDO|FIN_TINYSTATE_START; | |
349 | +} |
@@ -0,0 +1,20 @@ | ||
1 | + | |
2 | +#ifndef ___stdLog_cpp_H___ | |
3 | +#define ___stdLog_cpp_H___ | |
4 | + | |
5 | +#define VAR_LOG "/var/log/tinyState.log"; | |
6 | + | |
7 | +#define LOG_OFF 0 | |
8 | +#define LOG_ERROR 1 | |
9 | +#define LOG_WARNING 2 | |
10 | +#define LOG_ACCESS 3 | |
11 | +#define LOG_MESSAGE 4 | |
12 | +#define LOG_DEBUG 5 | |
13 | +#define LOG_MAX 6 | |
14 | + | |
15 | +#define LOG_DEFAULT LOG_OFF | |
16 | + | |
17 | +#include "_ts/c++/stdLog_pb.h" | |
18 | + | |
19 | +#endif | |
20 | + |