Changeset 38 in libcf for trunk/test/test.c

Timestamp:

02/06/13 10:26:54 (11 years ago)

Author:

cheese

Message:

#1 modify test.c for more detail test of multi-threaded logging

File:

• trunk/test/test.c (modified) (10 diffs)

trunk/test/test.c

@@ -29 +29 @@
 const char * file = "./log.txt";
 
+CF_THREAD_RETURN CF_THREAD_CALL test_log_mt (void * arg)
+{
+    int i = 0;
+    int th = *((int *)arg);
+
+    for (i = 0 ; i < 100000 ; i++)
+    {
+        CF_Log_Write (gLogCtx, "LOG_MT", "[%d] multi-threadedlogging test %d\n", th, i);
+    }
+
+    return (CF_THREAD_RETURN)0;
+}
+
 void test_log (const char * message)
 {
     int         i, j;
     char        idname[16] = {0x00,};
+    CF_Thread   tid[10];
 
     CF_DEBUG_CALLSTACK_PUSH (gDebugCtx);
@@ -44 +58 @@
         CF_DEBUG_PRINT (stderr, "create log ctx error\n");
 
-    for (i = 0 ; i < 10000 ; i++)
+    for (i = 0 ; i < 1000 ; i++)
         CF_Log_Write (gLogCtx, "LOG_TEST", "turn %d\n", i);
 
@@ -74 +88 @@
     /* }}} id */
 
+    /* mt {{{ */
+    gLogCtx = CF_Log_CreateCtx ("log_mt.txt", CF_LOG_BUFFER_DEFAULT);
+    if (gLogCtx == NULL)
+        CF_DEBUG_PRINT (stderr, "create log ctx error\n");
+
+    if (CF_Log_SetMultiThread (gLogCtx) < 0)
+        CF_DEBUG_PRINT (stderr, "set multi-threading mode error\n");
+
+    for (i = 0 ; i < 10 ; i++)
+    {
+        if (CF_Thread_Create (&tid[i], test_log_mt, &i) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", i);
+            return ;
+        }
+        CF_DEBUG_PRINT (stderr, "created %dth thread\n", i);
+    }
+
+    for (i = 0 ; i < 10 ; i++)
+    {
+        if (CF_Thread_Join (&tid[i]) < 0)
+            CF_DEBUG_PRINT (stderr, "failed to join %dth thread\n", i);
+    }
+
+    CF_Log_DestroyCtx (gLogCtx);
+    /* }}} mt */
+
     /* finalize */
     CF_Log_Finalize ();
@@ -89 +130 @@
         CF_DEBUG_TRACE (gDebugCtx, "what the ... file open ?\n");
 
-    if (CF_File_Read (fd, buffer, sizeof (buffer) - 1) < 0)
+    if (CF_File_Read (fd, buffer, sizeof (buffer)) < 0)
         CF_DEBUG_TRACE (gDebugCtx, "what the ... file read ?\n");
     else
         CF_DEBUG_TRACE_BIN (gDebugCtx, (unsigned char *)buffer,
-                                        sizeof (buffer) - 1,
+                                        sizeof (buffer),
                                         "-- %d bytes of %d bytes\n",
-                                        sizeof (buffer) - 1,
+                                        sizeof (buffer),
                                         CF_File_GetSize (fd));
 
@@ -134 +175 @@
     int recvd = 0;
     char buf[1024] = {0x00,};
+    int i = 0;
 
     /*------------------------------------------------------------*/
@@ -142 +184 @@
         return (CF_THREAD_RETURN)-1;
     }
-    CF_DEBUG_PRINT (stderr, "SERVER : accepted\n");
     CF_Log_Write (gLogCtx, "SERVER", "accepted\n");
 
-    if ((recvd = CF_Socket_Recv (clntsock, buf, sizeof (buf))) < 0)
-    {
-        CF_DEBUG_PRINT (stderr, "failed to recv on server\n");
-        return (CF_THREAD_RETURN)-2;
-    }
-    CF_DEBUG_PRINT (stderr, "SERVER : recv {%s}\n", buf);
-    CF_Log_Write (gLogCtx, "SERVER", "recv {%s}\n", buf);
-
-    if (CF_Socket_Send (clntsock, buf, recvd) < 0)
-    {
-        CF_DEBUG_PRINT (stderr, "failed to send on server\n");
-        return (CF_THREAD_RETURN)-3;
-    }
-    CF_DEBUG_PRINT (stderr, "SERVER : resp {%s}\n", buf);
-    CF_Log_Write (gLogCtx, "SERVER", "resp {%s}\n", buf);
+    for (i = 0 ; i < 100 ; i++)
+    {
+        if ((recvd = CF_Socket_Recv (clntsock, buf, sizeof (buf))) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to recv on server\n");
+            return (CF_THREAD_RETURN)-2;
+        }
+        CF_Log_Write (gLogCtx, "SERVER", "recv {%s}\n", buf);
+
+        if (CF_Socket_Send (clntsock, buf, recvd) < 0)
+        {
+            return (CF_THREAD_RETURN)-3;
+        }
+        CF_Log_Write (gLogCtx, "SERVER", "resp {%s}\n", buf);
+    }
+
+    CF_Socket_Close (clntsock);
 
     return (CF_THREAD_RETURN)0;
@@ -170 +213 @@
     int recvd = 0;
     char buf[1024] = {0x00,};
+    int i = 0;
 
     sprintf (buf, "...wow ? is it succeed ?");
@@ -180 +224 @@
         return (CF_THREAD_RETURN)-1;
     }
-    CF_DEBUG_PRINT (stderr, "CLIENT : connected\n");
     CF_Log_Write (gLogCtx, "CLIENT", "connected\n");
 
-    if (CF_Socket_Send (sock, buf, sizeof (buf)) < 0)
-    {
-        CF_DEBUG_PRINT (stderr, "failed to send on client %d\n", errno);
-        return (CF_THREAD_RETURN)-2;
-    }
-    CF_DEBUG_PRINT (stderr, "CLIENT : sent {%s}\n", buf);
-    CF_Log_Write (gLogCtx, "CLIENT", "sent {%s}\n", buf);
-
-    memset (buf, 0x00, sizeof (buf));
-
-    if ((recvd = CF_Socket_Recv (sock, buf, sizeof (buf))) < 0)
-    {
-        CF_DEBUG_PRINT (stderr, "failed to recv on client\n");
-        return (CF_THREAD_RETURN)-3;
-    }
-    CF_DEBUG_PRINT (stderr, "CLIENT : recv {%s}\n", buf);
-    CF_Log_Write (gLogCtx, "CLIENT", "recv {%s}\n", buf);
+    for (i = 0 ; i < 100 ; i++)
+    {
+        if (CF_Socket_Send (sock, buf, sizeof (buf)) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to send on client %d\n", errno);
+            return (CF_THREAD_RETURN)-2;
+        }
+        CF_Log_Write (gLogCtx, "CLIENT", "sent {%s}\n", buf);
+
+        memset (buf, 0x00, sizeof (buf));
+
+        if ((recvd = CF_Socket_Recv (sock, buf, sizeof (buf))) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to recv on client\n");
+            return (CF_THREAD_RETURN)-3;
+        }
+        CF_Log_Write (gLogCtx, "CLIENT", "recv {%s}\n", buf);
+    }
 
     CF_Socket_Close (sock);
@@ -267 +311 @@
     for (iter = 0 ; iter < THREAD_POOL ; iter++)
     {
-        CF_DEBUG_PRINT (stderr, "tid[%d] 0x%08x\n", iter, tid[iter]);
         CF_Thread_Join (&tid[iter]);
         CF_Thread_Release (&tid[iter]);
@@ -300 +343 @@
 
     // 4
-    CF_DEBUG_PRINT (stderr, " == MULTI-THREADED SOCKET TEST with MULTI-THREADED LOGGING ==\n");
+    CF_DEBUG_PRINT (stderr, " == MULTI-THREADED SOCKET TEST ==\n");
     test_socket ();