| … | |
… | |
| 219 | |
219 | |
| 220 | --q->size; |
220 | --q->size; |
| 221 | |
221 | |
| 222 | for (pri = ETP_NUM_PRI; pri--; ) |
222 | for (pri = ETP_NUM_PRI; pri--; ) |
| 223 | { |
223 | { |
| 224 | eio_req *req = q->qs[pri]; |
224 | ETP_REQ *req = q->qs[pri]; |
| 225 | |
225 | |
| 226 | if (req) |
226 | if (req) |
| 227 | { |
227 | { |
| 228 | if (!(q->qs[pri] = (eio_req *)req->next)) |
228 | if (!(q->qs[pri] = (ETP_REQ *)req->next)) |
| 229 | q->qe[pri] = 0; |
229 | q->qe[pri] = 0; |
| 230 | |
230 | |
| 231 | return req; |
231 | return req; |
| 232 | } |
232 | } |
| 233 | } |
233 | } |
| … | |
… | |
| 302 | } |
302 | } |
| 303 | |
303 | |
| 304 | static void ecb_cold |
304 | static void ecb_cold |
| 305 | etp_end_thread (void) |
305 | etp_end_thread (void) |
| 306 | { |
306 | { |
| 307 | eio_req *req = calloc (1, sizeof (eio_req)); /* will be freed by worker */ |
307 | ETP_REQ *req = calloc (1, sizeof (ETP_REQ)); /* will be freed by worker */ |
| 308 | |
308 | |
| 309 | req->type = ETP_TYPE_QUIT; |
309 | req->type = ETP_TYPE_QUIT; |
| 310 | req->pri = ETP_PRI_MAX - ETP_PRI_MIN; |
310 | req->pri = ETP_PRI_MAX - ETP_PRI_MIN; |
| 311 | |
311 | |
| 312 | X_LOCK (reqlock); |
312 | X_LOCK (reqlock); |
