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

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

#1 separate example code and doxygen comment and fix logging push logic by vfire
File size: 7.7 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_Debug_Ctx gDebugCtx;
25CF_Debug_CallStack gDebugCallstack;
26
27CF_Log_Ctx gLogCtx;
28
29const char * file = "./log.txt";
30
31void test_log (const char * message)
32{
33 int i, j;
34 char idname[16] = {0x00,};
35
36 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
37
38 /* initialize */
39 CF_Log_Initialize (10);
40
41 /* context {{{ */
42 gLogCtx = CF_Log_CreateCtx (file, CF_LOG_BUFFER_DEFAULT);
43 if (gLogCtx == NULL)
44 CF_DEBUG_PRINT (stderr, "create log ctx error\n");
45
46 for (i = 0 ; i < 10000 ; i++)
47 CF_Log_Write (gLogCtx, "LOG_TEST", "turn %d\n", i);
48
49 CF_DEBUG_CALLSTACK_POP (gDebugCtx, &gDebugCallstack);
50
51 CF_Log_Write (gLogCtx, message,
52 "here is the end of function [file:%s line:%d func:%s]\n",
53 gDebugCallstack.file,
54 gDebugCallstack.line,
55 gDebugCallstack.function);
56
57 CF_Log_DestroyCtx (gLogCtx);
58 /* }}} context */
59
60 /* id {{{ */
61 for (i = 0 ; i < 10 ; i++)
62 {
63 sprintf (idname, "logid%d.txt", i);
64 CF_LOG_OPEN (i, idname, CF_LOG_BUFFER_NO);
65 }
66
67 for (i = 0 ; i < 10 ; i++)
68 {
69 for (j = 0 ; j < 10000 ; j++)
70 CF_LOG_WRITE (i, "LOG_ID_TEST", "turn %d\n", j);
71
72 CF_LOG_CLOSE (i);
73 }
74 /* }}} id */
75
76 /* finalize */
77 CF_Log_Finalize ();
78}
79
80void test_file (const char * message)
81{
82 int fd = 0;
83 char buffer[128] = {0x00,};
84
85 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
86
87 fd = CF_File_Open (file, CF_FILE_RO);
88 if (fd < 0)
89 CF_DEBUG_TRACE (gDebugCtx, "what the ... file open ?\n");
90
91 if (CF_File_Read (fd, buffer, sizeof (buffer) - 1) < 0)
92 CF_DEBUG_TRACE (gDebugCtx, "what the ... file read ?\n");
93 else
94 CF_DEBUG_TRACE_BIN (gDebugCtx, (unsigned char *)buffer,
95 sizeof (buffer) - 1,
96 "-- %d bytes of %d bytes\n",
97 sizeof (buffer) - 1,
98 CF_File_GetSize (fd));
99
100 CF_File_Close (fd);
101
102 CF_DEBUG_CALLSTACK_POP (gDebugCtx, NULL);
103}
104
105void test_callstack3 (void)
106{
107 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
108 while (CF_DEBUG_CALLSTACK_POP (gDebugCtx, &gDebugCallstack) == CF_OK)
109 {
110 CF_DEBUG_TRACE (gDebugCtx, "print callstack [file:%s line:%d func:%s]\n",
111 gDebugCallstack.file,
112 gDebugCallstack.line,
113 gDebugCallstack.function);
114 }
115 CF_DEBUG_CALLSTACK_POP (gDebugCtx, NULL);
116}
117void test_callstack2 (void)
118{
119 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
120 test_callstack3 ();
121 CF_DEBUG_CALLSTACK_POP (gDebugCtx, NULL);
122}
123void test_callstack1 (void)
124{
125 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
126 test_callstack2 ();
127 CF_DEBUG_CALLSTACK_POP (gDebugCtx, NULL);
128}
129
130CF_THREAD_RETURN CF_THREAD_CALL socket_echo_server (void * arg)
131{
132 int srvsock = *((int *)arg);
133 int clntsock = 0;
134 int recvd = 0;
135 char buf[1024] = {0x00,};
136
137 /*------------------------------------------------------------*/
138 clntsock = CF_Socket_Accept (srvsock, NULL);
139 if (clntsock < 0)
140 {
141 CF_DEBUG_PRINT (stderr, "failed to accept on server\n");
142 return (CF_THREAD_RETURN)-1;
143 }
144 CF_DEBUG_PRINT (stderr, "SERVER : accepted\n");
145 CF_Log_Write (gLogCtx, "SERVER", "accepted\n");
146
147 if ((recvd = CF_Socket_Recv (clntsock, buf, sizeof (buf))) < 0)
148 {
149 CF_DEBUG_PRINT (stderr, "failed to recv on server\n");
150 return (CF_THREAD_RETURN)-2;
151 }
152 CF_DEBUG_PRINT (stderr, "SERVER : recv {%s}\n", buf);
153 CF_Log_Write (gLogCtx, "SERVER", "recv {%s}\n", buf);
154
155 if (CF_Socket_Send (clntsock, buf, recvd) < 0)
156 {
157 CF_DEBUG_PRINT (stderr, "failed to send on server\n");
158 return (CF_THREAD_RETURN)-3;
159 }
160 CF_DEBUG_PRINT (stderr, "SERVER : resp {%s}\n", buf);
161 CF_Log_Write (gLogCtx, "SERVER", "resp {%s}\n", buf);
162
163 return (CF_THREAD_RETURN)0;
164 /*------------------------------------------------------------*/
165}
166
167CF_THREAD_RETURN CF_THREAD_CALL socket_echo_client (void * arg)
168{
169 int sock = 0;
170 int recvd = 0;
171 char buf[1024] = {0x00,};
172
173 sprintf (buf, "...wow ? is it succeed ?");
174
175 /*------------------------------------------------------------*/
176 sock = CF_Socket_Connect ("localhost", PORT);
177 if (sock < 0)
178 {
179 CF_DEBUG_PRINT (stderr, "failed to connect on client\n");
180 return (CF_THREAD_RETURN)-1;
181 }
182 CF_DEBUG_PRINT (stderr, "CLIENT : connected\n");
183 CF_Log_Write (gLogCtx, "CLIENT", "connected\n");
184
185 if (CF_Socket_Send (sock, buf, sizeof (buf)) < 0)
186 {
187 CF_DEBUG_PRINT (stderr, "failed to send on client %d\n", errno);
188 return (CF_THREAD_RETURN)-2;
189 }
190 CF_DEBUG_PRINT (stderr, "CLIENT : sent {%s}\n", buf);
191 CF_Log_Write (gLogCtx, "CLIENT", "sent {%s}\n", buf);
192
193 memset (buf, 0x00, sizeof (buf));
194
195 if ((recvd = CF_Socket_Recv (sock, buf, sizeof (buf))) < 0)
196 {
197 CF_DEBUG_PRINT (stderr, "failed to recv on client\n");
198 return (CF_THREAD_RETURN)-3;
199 }
200 CF_DEBUG_PRINT (stderr, "CLIENT : recv {%s}\n", buf);
201 CF_Log_Write (gLogCtx, "CLIENT", "recv {%s}\n", buf);
202
203 CF_Socket_Close (sock);
204
205 return (CF_THREAD_RETURN)0;
206 /*------------------------------------------------------------*/
207}
208
209void test_socket (void)
210{
211 CF_Thread tid[THREAD_POOL];
212
213 int sock = 0;
214 int iter = 0;
215 int reuse = 1;
216
217 /*------------------------------------------------------------*/
218 gLogCtx = CF_Log_CreateCtx ("socket.txt", CF_LOG_BUFFER_DEFAULT);
219 if (gLogCtx == NULL)
220 CF_DEBUG_PRINT (stderr, "failed to open log\n");
221
222 CF_Log_Write (gLogCtx, "LOG_MULTITHREAD", "multi-threaded logging test with socket\n");
223
224 if (CF_Socket_Initialize () < 0)
225 {
226 CF_DEBUG_PRINT (stderr, "failed to initialize socket\n");
227 return ;
228 }
229 CF_Log_Write (gLogCtx, "SOCKET", "socket initialized\n");
230
231 sock = CF_Socket_Server (PORT, 5);
232 if (sock < 0)
233 {
234 CF_DEBUG_PRINT (stderr, "failed to ready server %d\n", sock);
235 return ;
236 }
237 CF_Log_Write (gLogCtx, "SOCKET", "socket ready\n");
238
239 if (CF_Socket_SetOption (sock, SO_REUSEADDR, &reuse, sizeof (reuse)) < 0)
240 {
241 CF_DEBUG_PRINT (stderr, "failed to set option\n");
242 return ;
243 }
244 CF_Log_Write (gLogCtx, "SOCKET", "set socket option\n");
245
246 for (iter = 0 ; iter < THREAD_POOL ; iter++)
247 {
248 if (CF_Thread_Create (&tid[iter], socket_echo_server, &sock) < 0)
249 {
250 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
251 return ;
252 }
253 CF_Log_Write (gLogCtx, "SOCKET", "create server thread-%d\n", iter);
254 }
255
256 for (iter = 0 ; iter < THREAD_POOL ; iter++)
257 {
258 CF_Thread dummy;
259 if (CF_Thread_Create (&dummy, socket_echo_client, &sock) < 0)
260 {
261 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
262 return ;
263 }
264 CF_Log_Write (gLogCtx, "SOCKET", "create client thread-%d\n", iter);
265 }
266
267 for (iter = 0 ; iter < THREAD_POOL ; iter++)
268 {
269 CF_DEBUG_PRINT (stderr, "tid[%d] 0x%08x\n", iter, tid[iter]);
270 CF_Thread_Join (&tid[iter]);
271 CF_Thread_Release (&tid[iter]);
272 CF_Log_Write (gLogCtx, "SOCKET", "join server thread-%d\n", iter);
273 }
274
275 CF_Socket_Close (sock);
276
277 CF_Socket_Finalize ();
278
279 CF_Log_DestroyCtx (gLogCtx);
280 /*------------------------------------------------------------*/
281}
282
283int main (int argc, char ** argv)
284{
285 gDebugCtx = CF_Debug_CreateCtx ();
286
287 CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
288
289 // 1
290 CF_DEBUG_PRINT (stderr, " == LOG TEST ==\n");
291 test_log ("LOG_TEST");
292
293 // 2
294 CF_DEBUG_PRINT (stderr, " == FILE READ TEST ==\n");
295 test_file ("FILE_READ_TEST");
296
297 // 3
298 CF_DEBUG_PRINT (stderr, " == CALLSTACK TEST ==\n");
299 test_callstack1 ();
300
301 // 4
302 CF_DEBUG_PRINT (stderr, " == MULTI-THREADED SOCKET TEST with MULTI-THREADED LOGGING ==\n");
303 test_socket ();
304
305 CF_DEBUG_CALLSTACK_POP (gDebugCtx, &gDebugCallstack);
306
307 CF_DEBUG_PRINT (stderr, " == END OF TEST ==\n");
308 CF_DEBUG_TRACE (gDebugCtx, "here is the end of function [file:%s line:%d func:%s]\n",
309 gDebugCallstack.file,
310 gDebugCallstack.line,
311 gDebugCallstack.function);
312
313 CF_Debug_DestroyCtx (gDebugCtx);
314
315 return 0;
316}
317
Note: See TracBrowser for help on using the repository browser.