| … | |
… | |
| 1032 | req->dataptr = SvPVbyte_nolen (req->data); |
1032 | req->dataptr = SvPVbyte_nolen (req->data); |
| 1033 | |
1033 | |
| 1034 | send_req (req); |
1034 | send_req (req); |
| 1035 | } |
1035 | } |
| 1036 | |
1036 | |
|
|
1037 | #if 0 |
|
|
1038 | |
|
|
1039 | # undocumented, because it does not cancel active requests |
|
|
1040 | void |
|
|
1041 | cancel_most_requests () |
|
|
1042 | PROTOTYPE: |
|
|
1043 | CODE: |
|
|
1044 | { |
|
|
1045 | aio_req *req; |
|
|
1046 | |
|
|
1047 | pthread_mutex_lock (&reqlock); |
|
|
1048 | for (req = reqs; req; req = req->next) |
|
|
1049 | req->flags |= 1; |
|
|
1050 | pthread_mutex_unlock (&reqlock); |
|
|
1051 | |
|
|
1052 | pthread_mutex_lock (&reslock); |
|
|
1053 | for (req = ress; req; req = req->next) |
|
|
1054 | req->flags |= 1; |
|
|
1055 | pthread_mutex_unlock (&reslock); |
|
|
1056 | } |
|
|
1057 | |
|
|
1058 | #endif |
|
|
1059 | |
| 1037 | void |
1060 | void |
| 1038 | flush () |
1061 | flush () |
| 1039 | PROTOTYPE: |
1062 | PROTOTYPE: |
| 1040 | CODE: |
1063 | CODE: |
| 1041 | while (nreqs) |
1064 | while (nreqs) |
