Changeset 49 in libcf

Timestamp:

03/29/13 18:02:55 (11 years ago)

Author:

cheese

Message:

#1 fix test code

File:

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

trunk/test/test.c

@@ -24 +24 @@
 CF_Debug_Ctx        gDebugCtx;
 CF_Debug_CallStack  gDebugCallstack;
+CF_Mutex            globalMutex;
 
 #define LOG_SOCKET      0
@@ -32 +33 @@
 CF_THREAD_RETURN CF_THREAD_CALL test_log_mt (void * arg)
 {
+    static int cnt = 0;
     int i = 0;
-    int th = *((int *)arg);
+    int th = 0;
+    
+    if (CF_Mutex_Lock (&globalMutex) < 0) { // for critical section
+        // error
+    }
+    th = cnt++;
+    if (CF_Mutex_Unlock (&globalMutex) < 0) { // for critical section
+        // error
+    }
+
+    CF_DEBUG_PRINT (stderr, "created %dth thread\n", th);
 
     for (i = 0 ; i < 100000 ; i++)
@@ -39 +51 @@
         CF_Log_Write (LOG_MT, "LOG_MT", "[%d] multi-threadedlogging test %d\n", th, i);
     }
+
+    CF_DEBUG_PRINT (stderr, "end %dth thread\n", th);
 
     return (CF_THREAD_RETURN)0;
@@ -85 +99 @@
         CF_DEBUG_PRINT (stderr, "set multi-threading mode error\n");
 
+    if (CF_Mutex_Create (&globalMutex) < 0) {
+        // error
+    }
+
     for (i = 0 ; i < 10 ; i++)
     {
@@ -92 +110 @@
             return ;
         }
-        CF_DEBUG_PRINT (stderr, "created %dth thread\n", i);
+    }
+
+    if (CF_Mutex_Destory (&globalMutex) < 0) {
+        // error
     }
 
@@ -244 +265 @@
     int sock = 0;
     int iter = 0;
-    int reuse = 1;
 
     /*------------------------------------------------------------*/
@@ -272 +292 @@
     }
     CF_Log_Write (LOG_SOCKET, "SOCKET", "socket ready\n");
-
-    if (CF_Socket_SetOption (sock, SO_REUSEADDR, &reuse, sizeof (reuse)) < 0)
-    {
-        CF_DEBUG_PRINT (stderr, "failed to set option\n");
-        return ;
-    }
-    CF_Log_Write (LOG_SOCKET, "SOCKET", "set socket option\n");
 
     for (iter = 0 ; iter < THREAD_POOL ; iter++)