Changeset 122 in libcf for trunk/test/socket.c

Timestamp:

06/12/13 11:05:07 (11 years ago)

Author:

cheese

Message:

#1 modify id to context in thread

File:

• trunk/test/socket.c (modified) (3 diffs)

trunk/test/socket.c

@@ -135 +135 @@
     for (iter = 0 ; iter < THREAD_POOL ; iter++)
     {
-        if (CF_Thread_Create (&stid[iter], socket_echo_server, &sock) < 0)
+        if (CF_Thread_CreateCtx (&stid[iter], socket_echo_server, &sock) < 0)
         {
             CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
@@ -145 +145 @@
     for (iter = 0 ; iter < THREAD_POOL ; iter++)
     {
-        if (CF_Thread_Create (&ctid[iter], socket_echo_client, &sock) < 0)
+        if (CF_Thread_CreateCtx (&ctid[iter], socket_echo_client, &sock) < 0)
         {
             CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter);
@@ -155 +155 @@
     for (iter = 0 ; iter < THREAD_POOL ; iter++)
     {
-        CF_Thread_Join (&ctid[iter]);
-        CF_Thread_DestroyCtx (&ctid[iter]);
+        if (CF_Thread_Start (stid[iter]) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to start %dth thread\n", iter);
+            return -6;
+        }
+    }
 
-        CF_Thread_Join (&stid[iter]);
-        CF_Thread_DestroyCtx (&stid[iter]);
+    for (iter = 0 ; iter < THREAD_POOL ; iter++)
+    {
+        if (CF_Thread_Start (ctid[iter]) < 0)
+        {
+            CF_DEBUG_PRINT (stderr, "failed to start %dth thread\n", iter);
+            return -7;
+        }
+    }
+
+    for (iter = 0 ; iter < THREAD_POOL ; iter++)
+    {
+        CF_Thread_Join (ctid[iter]);
+        CF_Thread_DestroyCtx (ctid[iter]);
+
+        CF_Thread_Join (stid[iter]);
+        CF_Thread_DestroyCtx (stid[iter]);
 
         CF_Log_Write (LOG_SOCKET, "SOCKET", "join server thread-%d\n", iter);