source: libcf/trunk/test/test.c@ 51

Last change on this file since 51 was 51, checked in by cheese, 11 years ago

#1 change the debugging utiltity to support single context with mutex
File size: 7.5 KB
Line 
1/**
2 * @file test.c
3 * @author myusgun <myusgun@gmail.com>
4 * @version 0.1
5 */
6#include "cf_file.h"
7#include "cf_log.h"
8#include "cf_socket.h"
9#include "cf_thread.h"
10
11/*
12 * before including "cf_debug.h",
13 * if _DEBUG is defined, the debugging code will be act.
14 */
15#include "cf_debug.h"
16
17#include <stdlib.h>
18#include <string.h>
19#include <errno.h>
20
21#define THREAD_POOL 5
22#define PORT 1234
23
24CF_Mutex globalMutex;
25
26#define LOG_SOCKET 0
27#define LOG_MT 1
28
29const char * file = "./log.txt";
30
31CF_THREAD_RETURN CF_THREAD_CALL test_log_mt (void * arg)
32{
33 static int cnt = 0;
34 int i = 0;
35 int th = 0;
36
37 if (CF_Mutex_Lock (&globalMutex) < 0) { // for critical section
38 // error
39 }
40 th = cnt++;
41 if (CF_Mutex_Unlock (&globalMutex) < 0) { // for critical section
42 // error
43 }
44
45 CF_DEBUG_PRINT (stderr, "created %dth thread\n", th);
46
47 for (i = 0 ; i < 100000 ; i++)
48 {
49 CF_Log_Write (LOG_MT, "LOG_MT", "[%d] multi-threadedlogging test %d\n", th, i);
50 }
51
52 CF_DEBUG_PRINT (stderr, "end %dth thread\n", th);
53
54 return (CF_THREAD_RETURN)0;
55}
56
57void test_log (const char * message)
58{
59 int i, j;
60 char idname[16] = {0x00,};
61 CF_Thread tid[10];
62
63 CF_DEBUG_BEGIN_FUNCTION;
64
65 /* initialize */
66 if (CF_Log_Initialize (10) < 0)
67 {
68 fprintf (stderr, "failed to init. log\n");
69 return ;
70 }
71
72 for (i = 0 ; i < 10 ; i++)
73 {
74 sprintf (idname, "logid%d.txt", i);
75 if (CF_Log_Open (i, idname, CF_LOG_BUFFER_NO) < 0)
76 fprintf (stderr, "failed to open log\n");
77 }
78
79 for (i = 0 ; i < 10 ; i++)
80 {
81 for (j = 0 ; j < 10000 ; j++)
82 {
83 int result = CF_Log_Write (i, "LOG_ID_TEST", "turn %d\n", j);
84 if (result < 0)
85 fprintf (stderr, "failed to write log %d\n", result);
86 }
87
88 if (CF_Log_Close (i) < 0)
89 fprintf (stderr, "failed to close log\n");
90 }
91
92 /* mt {{{ */
93 if (CF_Log_Open (LOG_MT, "log_mt.txt", CF_LOG_BUFFER_DEFAULT) < 0)
94 CF_DEBUG_PRINT (stderr, "create log ctx error\n");
95
96 if (CF_Log_SetMT (LOG_MT, CF_TRUE) < 0)
97 CF_DEBUG_PRINT (stderr, "set multi-threading mode error\n");
98
99 if (CF_Mutex_Create (&globalMutex) < 0) {
100 // error
101 }
102
103 for (i = 0 ; i < 10 ; i++)
104 {
105 if (CF_Thread_Create (&tid[i], test_log_mt, &i) < 0)
106 {
107 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", i);
108 return ;
109 }
110 }
111
112 if (CF_Mutex_Destory (&globalMutex) < 0) {
113 // error
114 }
115
116 for (i = 0 ; i < 10 ; i++)
117 {
118 if (CF_Thread_Join (&tid[i]) < 0)
119 CF_DEBUG_PRINT (stderr, "failed to join %dth thread\n", i);
120 }
121 /* }}} mt */
122
123 /* finalize */
124 CF_Log_Finalize ();
125
126 CF_DEBUG_END_FUNCTION;
127}
128
129void test_file (const char * message)
130{
131 int fd = 0;
132 char buffer[128] = {0x00,};
133
134 CF_DEBUG_BEGIN_FUNCTION;
135
136 fd = CF_File_Open (file, CF_FILE_RO);
137 if (fd < 0)
138 CF_DEBUG_PRINT (stderr, "what the ... file open ?\n");
139
140 if (CF_File_Read (fd, buffer, sizeof (buffer)) < 0)
141 CF_DEBUG_PRINT (stderr, "what the ... file read ?\n");
142 else
143 CF_DEBUG_PRINT_BIN (stdout, (unsigned char *)buffer,
144 sizeof (buffer),
145 "-- %d bytes of %d bytes\n",
146 sizeof (buffer),
147 CF_File_GetSize (fd));
148
149 CF_File_Close (fd);
150
151 CF_DEBUG_END_FUNCTION;
152}
153
154void test_callstack3 (void)
155{
156 CF_DEBUG_BEGIN_FUNCTION;
157 CF_Debug_PrintCallStack (stdout);
158 CF_DEBUG_END_FUNCTION;
159}
160void test_callstack2 (void)
161{
162 CF_DEBUG_BEGIN_FUNCTION;
163 test_callstack3 ();
164 CF_DEBUG_END_FUNCTION;
165}
166void test_callstack1 (void)
167{
168 CF_DEBUG_BEGIN_FUNCTION;
169 test_callstack2 ();
170 CF_DEBUG_END_FUNCTION;
171}
172
173CF_THREAD_RETURN CF_THREAD_CALL socket_echo_server (void * arg)
174{
175 int srvsock = *((int *)arg);
176 int clntsock = 0;
177 int recvd = 0;
178 char buf[1024] = {0x00,};
179 int i = 0;
180
181 /*------------------------------------------------------------*/
182 clntsock = CF_Socket_Accept (srvsock, NULL);
183 if (clntsock < 0)
184 {
185 CF_DEBUG_PRINT (stderr, "failed to accept on server\n");
186 return (CF_THREAD_RETURN)-1;
187 }
188 CF_Log_Write (LOG_SOCKET, "SERVER", "accepted\n");
189
190 for (i = 0 ; i < 100 ; i++)
191 {
192 if ((recvd = CF_Socket_Recv (clntsock, buf, sizeof (buf))) < 0)
193 {
194 CF_DEBUG_PRINT (stderr, "failed to recv on server\n");
195 return (CF_THREAD_RETURN)-2;
196 }
197 CF_Log_Write (LOG_SOCKET, "SERVER", "recv {%s}\n", buf);
198
199 if (CF_Socket_Send (clntsock, buf, recvd) < 0)
200 {
201 return (CF_THREAD_RETURN)-3;
202 }
203 CF_Log_Write (LOG_SOCKET, "SERVER", "resp {%s}\n", buf);
204 }
205
206 CF_Socket_Close (clntsock);
207
208 return (CF_THREAD_RETURN)0;
209 /*------------------------------------------------------------*/
210}
211
212CF_THREAD_RETURN CF_THREAD_CALL socket_echo_client (void * arg)
213{
214 int sock = 0;
215 int recvd = 0;
216 char buf[1024] = {0x00,};
217 int i = 0;
218
219 sprintf (buf, "...wow ? is it succeed ?");
220
221 /*------------------------------------------------------------*/
222 sock = CF_Socket_Connect ("localhost", PORT);
223 if (sock < 0)
224 {
225 CF_DEBUG_PRINT (stderr, "failed to connect on client\n");
226 return (CF_THREAD_RETURN)-1;
227 }
228 CF_Log_Write (LOG_SOCKET, "CLIENT", "connected\n");
229
230 for (i = 0 ; i < 100 ; i++)
231 {
232 if (CF_Socket_Send (sock, buf, sizeof (buf)) < 0)
233 {
234 CF_DEBUG_PRINT (stderr, "failed to send on client %d\n", errno);
235 return (CF_THREAD_RETURN)-2;
236 }
237 CF_Log_Write (LOG_SOCKET, "CLIENT", "sent {%s}\n", buf);
238
239 memset (buf, 0x00, sizeof (buf));
240
241 if ((recvd = CF_Socket_Recv (sock, buf, sizeof (buf))) < 0)
242 {
243 CF_DEBUG_PRINT (stderr, "failed to recv on client\n");
244 return (CF_THREAD_RETURN)-3;
245 }
246 CF_Log_Write (LOG_SOCKET, "CLIENT", "recv {%s}\n", buf);
247 }
248
249 CF_Socket_Close (sock);
250
251 return (CF_THREAD_RETURN)0;
252 /*------------------------------------------------------------*/
253}
254
255void test_socket (void)
256{
257 CF_Thread tid[THREAD_POOL];
258
259 int sock = 0;
260 int iter = 0;
261
262 /*------------------------------------------------------------*/
263 if (CF_Log_Initialize (1) < 0)
264 {
265 fprintf (stderr, "failed to init. log\n");
266 return ;
267 }
268
269 if (CF_Log_Open (LOG_SOCKET, "socket.txt", CF_LOG_BUFFER_DEFAULT) < 0)
270 CF_DEBUG_PRINT (stderr, "failed to open log\n");
271
272 CF_Log_Write (LOG_SOCKET, "LOG_MULTITHREAD", "multi-threaded logging test with socket\n");
273
274 if (CF_Socket_Initialize () < 0)
275 {
276 CF_DEBUG_PRINT (stderr, "failed to initialize socket\n");
277 return ;
278 }
279 CF_Log_Write (LOG_SOCKET, "SOCKET", "socket initialized\n");
280
281 sock = CF_Socket_Server (PORT, 5);
282 if (sock < 0)
283 {
284 CF_DEBUG_PRINT (stderr, "failed to ready server %d\n", sock);
285 return ;
286 }
287 CF_Log_Write (LOG_SOCKET, "SOCKET", "socket ready\n");
288
289 for (iter = 0 ; iter < THREAD_POOL ; iter++)
290 {
291 if (CF_Thread_Create (&tid[iter], socket_echo_server, &sock) < 0)
292 {
293 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
294 return ;
295 }
296 CF_Log_Write (LOG_SOCKET, "SOCKET", "create server thread-%d\n", iter);
297 }
298
299 for (iter = 0 ; iter < THREAD_POOL ; iter++)
300 {
301 CF_Thread dummy;
302 if (CF_Thread_Create (&dummy, socket_echo_client, &sock) < 0)
303 {
304 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
305 return ;
306 }
307 CF_Log_Write (LOG_SOCKET, "SOCKET", "create client thread-%d\n", iter);
308 }
309
310 for (iter = 0 ; iter < THREAD_POOL ; iter++)
311 {
312 CF_Thread_Join (&tid[iter]);
313 CF_Thread_Release (&tid[iter]);
314 CF_Log_Write (LOG_SOCKET, "SOCKET", "join server thread-%d\n", iter);
315 }
316
317 CF_Socket_Close (sock);
318
319 CF_Socket_Finalize ();
320
321 CF_Log_Close (LOG_SOCKET);
322
323 CF_Log_Finalize ();
324 /*------------------------------------------------------------*/
325}
326
327int main (int argc, char ** argv)
328{
329 CF_DEBUG_BEGIN_FUNCTION;
330
331 // 1
332 CF_DEBUG_PRINT (stderr, " == LOG TEST ==\n");
333 test_log ("LOG_TEST");
334
335 // 2
336 CF_DEBUG_PRINT (stderr, " == FILE READ TEST ==\n");
337 test_file ("FILE_READ_TEST");
338
339 // 3
340 CF_DEBUG_PRINT (stderr, " == CALLSTACK TEST ==\n");
341 test_callstack1 ();
342
343 // 4
344 CF_DEBUG_PRINT (stderr, " == MULTI-THREADED SOCKET TEST ==\n");
345 test_socket ();
346
347 CF_DEBUG_PRINT (stderr, " == END OF TEST ==\n");
348
349 CF_DEBUG_END_FUNCTION;
350
351 return 0;
352}
353
Note: See TracBrowser for help on using the repository browser.