| 941 | } |
| 942 | |
| 943 | static void |
| 944 | aio_schedule_fsync(void *context, int pending) |
| 945 | { |
| 946 | struct kaioinfo *ki; |
| 947 | struct kaiocb *job; |
| 948 | |
| 949 | ki = context; |
| 950 | AIO_LOCK(ki); |
| 951 | while (!TAILQ_EMPTY(&ki->kaio_syncready)) { |
| 952 | job = TAILQ_FIRST(&ki->kaio_syncready); |
| 953 | TAILQ_REMOVE(&ki->kaio_syncready, job, list); |
| 954 | AIO_UNLOCK(ki); |
| 955 | aio_schedule(job, aio_process_sync); |
| 956 | AIO_LOCK(ki); |
| 957 | } |
| 958 | AIO_UNLOCK(ki); |
| 959 | } |
| 960 | |
| 961 | bool |
| 962 | aio_cancel_cleared(struct kaiocb *job) |
nothing calls this directly
no test coverage detected