… | |
… | |
1182 | |
1182 | |
1183 | /*****************************************************************************/ |
1183 | /*****************************************************************************/ |
1184 | |
1184 | |
1185 | X_THREAD_PROC (aio_proc) |
1185 | X_THREAD_PROC (aio_proc) |
1186 | { |
1186 | { |
1187 | {//D |
|
|
1188 | aio_req req; |
1187 | aio_req req; |
1189 | struct timespec ts; |
1188 | struct timespec ts; |
1190 | worker *self = (worker *)thr_arg; |
1189 | worker *self = (worker *)thr_arg; |
1191 | |
1190 | |
1192 | /* try to distribute timeouts somewhat randomly */ |
1191 | /* try to distribute timeouts somewhat randomly */ |
… | |
… | |
1352 | X_LOCK (wrklock); |
1351 | X_LOCK (wrklock); |
1353 | worker_free (self); |
1352 | worker_free (self); |
1354 | X_UNLOCK (wrklock); |
1353 | X_UNLOCK (wrklock); |
1355 | |
1354 | |
1356 | return 0; |
1355 | return 0; |
1357 | }//D |
|
|
1358 | } |
1356 | } |
1359 | |
1357 | |
1360 | /*****************************************************************************/ |
1358 | /*****************************************************************************/ |
1361 | |
1359 | |
1362 | static void atfork_prepare (void) |
1360 | static void atfork_prepare (void) |