Lines Matching defs:aio

110 MODULE(MODULE_CLASS_MISC, aio, NULL);
267 struct aioproc *aio;
271 aio = kmem_zalloc(sizeof(*aio), KM_SLEEP);
274 error = aiosp_initialize(&aio->aiosp);
276 kmem_free(aio, sizeof(*aio));
280 error = aiocbp_init(&aio->aiosp, 256);
282 aiosp_destroy(&aio->aiosp, NULL);
283 kmem_free(aio, sizeof(*aio));
288 mutex_init(&aio->aio_mtx, MUTEX_DEFAULT, IPL_NONE);
294 aio_exit(p, aio);
297 p->p_aio = aio;
309 struct aioproc *aio;
312 aio = cookie;
313 } else if ((aio = p->p_aio) == NULL) {
317 aiocbp_destroy(&aio->aiosp);
318 aiosp_destroy(&aio->aiosp, NULL);
319 mutex_destroy(&aio->aio_mtx);
320 kmem_free(aio, sizeof(*aio));
606 struct aioproc *aio = p->p_aio;
607 struct aiosp *aiosp = &aio->aiosp;
1573 struct aioproc *aio;
1619 aio = p->p_aio;
1620 if (aio) {
1621 error = aiosp_validate_conflicts(&aio->aiosp, aiocb_uptr);
1635 aio = p->p_aio;
1677 error = aiocbp_insert(&aio->aiosp, aiocbp);
1691 mutex_enter(&aio->aio_mtx);
1693 aio->jobs_count >= aio_listio_max) {
1694 mutex_exit(&aio->aio_mtx);
1699 mutex_exit(&aio->aio_mtx);
1701 error = aiosp_enqueue_job(&aio->aiosp, a_job);
1707 mutex_enter(&aio->aio_mtx);
1708 aio->jobs_count++;
1712 mutex_exit(&aio->aio_mtx);
1716 aiocbp_remove_job(&aio->aiosp, aiocb_uptr, &a_job, NULL);
1737 struct aioproc *aio;
1765 aio = p->p_aio;
1767 aiosp = &aio->aiosp;
1769 mutex_enter(&aio->aio_mtx);
1836 mutex_exit(&aio->aio_mtx);
1846 struct aioproc *aio = p->p_aio;
1848 if (aio == NULL) {
1853 return aiosp_error(&aio->aiosp, uptr, retval);
1883 struct aioproc *aio = p->p_aio;
1884 KASSERT(aio);
1885 return aiosp_distribute_jobs(&aio->aiosp);
1893 struct aioproc *aio = p->p_aio;
1895 if (aio == NULL) {
1900 return aiosp_return(&aio->aiosp, uptr, retval);
1908 struct aioproc *aio = p->p_aio;
1918 if (aio == NULL) {
1936 error = aiosp_suspend(&aio->aiosp, list, nent, SCARG(uap, timeout) ?
1955 struct aioproc *aio = p->p_aio;
1956 KASSERT(aio);
1957 return aiosp_distribute_jobs(&aio->aiosp);
1965 struct aioproc *aio;
1984 aio = p->p_aio;
2027 mutex_enter(&aio->aio_mtx);
2044 error = aiosp_distribute_jobs(&aio->aiosp);
2049 mutex_enter(&aio->aio_mtx);
2058 error = aiosp_suspend(&aio->aiosp, aiocbp_list, nent,
2066 mutex_exit(&aio->aio_mtx);
2124 SYSCTL_SETUP(sysctl_aio_init, "aio sysctl")
2172 struct aioproc *aio;
2182 aio = p->p_aio;
2183 if (aio == NULL) {
2188 sp = &aio->aiosp;
2192 aio->jobs_count);