Home
last modified time | relevance | path

Searched refs:kaiocb (Results 1 – 12 of 12) sorted by relevance

/src/sys/sys/
H A Daio.h124 typedef void aio_cancel_fn_t(struct kaiocb *);
125 typedef void aio_handle_fn_t(struct kaiocb *);
136 struct kaiocb { struct
137 TAILQ_ENTRY(kaiocb) list; /* (b) backend-specific list of jobs */
138 TAILQ_ENTRY(kaiocb) plist; /* (a) lists of pending / done jobs */
139 TAILQ_ENTRY(kaiocb) allist; /* (a) list of all jobs in proc */
214 bool aio_cancel_cleared(struct kaiocb *job);
215 void aio_cancel(struct kaiocb *job);
216 bool aio_clear_cancel_function(struct kaiocb *job);
217 void aio_complete(struct kaiocb *job, long status, int error);
[all …]
H A Dprotosw.h53 struct kaiocb;
102 typedef int pr_aio_queue_t(struct socket *, struct kaiocb *);
H A Dfile.h81 struct kaiocb;
134 typedef int fo_aio_queue_t(struct file *fp, struct kaiocb *job);
473 fo_aio_queue(struct file *fp, struct kaiocb *job) in fo_aio_queue()
H A Dsockbuf.h102 TAILQ_HEAD(, kaiocb) sb_aiojobq; /* pending AIO ops */
H A Devent.h324 struct kaiocb *p_aio; /* AIO job pointer */
H A Dsocketvar.h531 int soaio_queue_generic(struct socket *so, struct kaiocb *job);
/src/sys/kern/
H A Dvfs_aio.c267 TAILQ_HEAD(,kaiocb) kaio_all; /* (a) all AIOs in a process */
268 TAILQ_HEAD(,kaiocb) kaio_done; /* (a) done queue for process */
270 TAILQ_HEAD(,kaiocb) kaio_jobqueue; /* (a) job queue for process */
271 TAILQ_HEAD(,kaiocb) kaio_syncqueue; /* (a) queue for aio_fsync */
272 TAILQ_HEAD(,kaiocb) kaio_syncready; /* (a) second q for aio_fsync */
290 int (*aio_copyin)(struct aiocb *ujob, struct kaiocb *kjob, int ty);
301 static TAILQ_HEAD(,kaiocb) aio_jobs; /* (c) Async job list */
307 static int aio_free_entry(struct kaiocb *job);
308 static void aio_process_rw(struct kaiocb *job);
309 static void aio_process_sync(struct kaiocb *job);
[all …]
H A Dsys_socket.c98 static void soo_aio_cancel(struct kaiocb *job);
619 soaio_process_job(struct socket *so, sb_which which, struct kaiocb *job) in soaio_process_job()
727 struct kaiocb *job; in soaio_process_sb()
789 soo_aio_cancel(struct kaiocb *job) in soo_aio_cancel()
823 soo_aio_queue(struct file *fp, struct kaiocb *job) in soo_aio_queue()
831 soaio_queue_generic(struct socket *so, struct kaiocb *job) in soaio_queue_generic()
/src/sys/dev/cxgbe/tom/
H A Dt4_tom.h180 struct kaiocb *job;
205 TAILQ_HEAD(, kaiocb) aiojobq; /* (a) */
210 struct kaiocb *queueing; /* (a) */
246 TAILQ_HEAD(, kaiocb) aiotx_jobq;
519 int t4_aio_queue_aiotx(struct socket *, struct kaiocb *);
561 int t4_aio_queue_ddp(struct socket *, struct kaiocb *);
H A Dt4_ddp.c82 static void t4_aio_cancel_active(struct kaiocb *job);
83 static void t4_aio_cancel_queued(struct kaiocb *job);
164 ddp_complete_one(struct kaiocb *job, int error) in ddp_complete_one()
467 struct kaiocb *job; in insert_ddp_data()
648 struct kaiocb *job; in handle_ddp_data_aio()
1023 struct kaiocb *job; in do_ddp_tcb_rpl()
1095 struct kaiocb *job; in handle_ddp_close()
2177 hold_aio(struct toepcb *toep, struct kaiocb *job, struct pageset **pps) in hold_aio()
2282 struct kaiocb *job; in ddp_complete_all()
2296 aio_ddp_cancel_one(struct kaiocb *job) in aio_ddp_cancel_one()
[all …]
H A Dt4_cpl_io.c78 static void t4_aiotx_cancel(struct kaiocb *job);
2387 jobtotid(struct kaiocb *job) in jobtotid()
2401 aiotx_free_job(struct kaiocb *job) in aiotx_free_job()
2430 struct kaiocb *job; in aiotx_free_pgs()
2453 alloc_aiotx_mbuf(struct kaiocb *job, int len) in alloc_aiotx_mbuf()
2529 t4_aiotx_process_job(struct toepcb *toep, struct socket *so, struct kaiocb *job) in t4_aiotx_process_job()
2709 struct kaiocb *job; in t4_aiotx_task()
2751 t4_aiotx_cancel(struct kaiocb *job) in t4_aiotx_cancel()
2774 t4_aio_queue_aiotx(struct socket *so, struct kaiocb *job) in t4_aio_queue_aiotx()
H A Dt4_tom.c2243 t4_aio_queue_tom(struct socket *so, struct kaiocb *job) in t4_aio_queue_tom()