Changeset 109 in libcf for trunk/test/socket.c
- Timestamp:
- 06/04/13 14:25:10 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
trunk/test/socket.c
r108 r109 39 39 CF_DEBUG_PRINT (stderr, "[SERVER] recv {%s}\n", buf); 40 40 41 if (CF_Socket_Send (clntsock, buf, recvd) < 0)41 if (CF_Socket_Send (clntsock, buf, (size_t)recvd) < 0) 42 42 { 43 43 return -3; … … 100 100 int main () 101 101 { 102 CF_Thread stid[THREAD_POOL];103 CF_Thread ctid[THREAD_POOL];102 CF_Thread_Ctx stid[THREAD_POOL]; 103 CF_Thread_Ctx ctid[THREAD_POOL]; 104 104 105 105 int sock = 0; … … 135 135 for (iter = 0 ; iter < THREAD_POOL ; iter++) 136 136 { 137 if (CF_Thread_Create (&stid[iter], socket_echo_server, &sock) < 0)137 if (CF_Thread_CreateCtx (&stid[iter], socket_echo_server, &sock) < 0) 138 138 { 139 139 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter); … … 145 145 for (iter = 0 ; iter < THREAD_POOL ; iter++) 146 146 { 147 if (CF_Thread_Create (&ctid[iter], socket_echo_client, &sock) < 0)147 if (CF_Thread_CreateCtx (&ctid[iter], socket_echo_client, &sock) < 0) 148 148 { 149 149 CF_DEBUG_PRINT (stderr, "failed to create %dth thread\n", iter); … … 156 156 { 157 157 CF_Thread_Join (&ctid[iter]); 158 CF_Thread_ Release(&ctid[iter]);158 CF_Thread_DestroyCtx (&ctid[iter]); 159 159 160 160 CF_Thread_Join (&stid[iter]); 161 CF_Thread_ Release(&stid[iter]);161 CF_Thread_DestroyCtx (&stid[iter]); 162 162 163 163 CF_Log_Write (LOG_SOCKET, "SOCKET", "join server thread-%d\n", iter);
Note:
See TracChangeset
for help on using the changeset viewer.