Lines Matching refs:task

434 	int	(*completef)(struct vd_task *task); /* completion func ptr */
533 int (*start)(vd_task_t *task);
534 int (*complete)(vd_task_t *task);
1910 vd_task_t *task = (vd_task_t *)buf->b_private; in vd_bio_task() local
1911 vd_t *vd = task->vd; in vd_bio_task()
1969 vd_start_bio(vd_task_t *task) in vd_start_bio() argument
1972 vd_t *vd = task->vd; in vd_start_bio()
1973 vd_dring_payload_t *request = task->request; in vd_start_bio()
1974 struct buf *buf = &task->buf; in vd_start_bio()
2014 status = ldc_mem_map(task->mhdl, request->cookie, request->ncookies, in vd_start_bio()
2028 status = ldc_mem_acquire(task->mhdl, 0, buflen); in vd_start_bio()
2030 (void) ldc_mem_unmap(task->mhdl); in vd_start_bio()
2158 task->write_index = vd->write_index; in vd_start_bio()
2159 vd->write_queue[task->write_index] = buf; in vd_start_bio()
2164 buf->b_private = task; in vd_start_bio()
2169 (void) ddi_taskq_dispatch(task->vd->ioq, vd_bio_task, buf, in vd_start_bio()
2204 rv = ldc_mem_release(task->mhdl, 0, buflen); in vd_start_bio()
2209 rv = ldc_mem_unmap(task->mhdl); in vd_start_bio()
2412 vd_complete_bio(vd_task_t *task) in vd_complete_bio() argument
2416 vd_t *vd = task->vd; in vd_complete_bio()
2417 vd_dring_payload_t *request = task->request; in vd_complete_bio()
2418 struct buf *buf = &task->buf; in vd_complete_bio()
2424 ASSERT(task->msg != NULL); in vd_complete_bio()
2425 ASSERT(task->msglen >= sizeof (*task->msg)); in vd_complete_bio()
2453 ASSERT(task->request->operation == VD_OP_BWRITE); in vd_complete_bio()
2455 wid = task->write_index; in vd_complete_bio()
2476 DTRACE_PROBE2(flushgrp, vd_task_t *, task, in vd_complete_bio()
2496 status = ldc_mem_release(task->mhdl, 0, buf->b_bufsize); in vd_complete_bio()
2507 status = ldc_mem_unmap(task->mhdl); in vd_complete_bio()
2535 vd_notify(vd_task_t *task) in vd_notify() argument
2539 ASSERT(task != NULL); in vd_notify()
2540 ASSERT(task->vd != NULL); in vd_notify()
2548 (task->msg->tag.vio_subtype == VIO_SUBTYPE_ACK) ? "ACK" : "NACK"); in vd_notify()
2550 status = send_msg(task->vd->ldc_handle, task->msg, task->msglen); in vd_notify()
2555 vd_mark_in_reset(task->vd); in vd_notify()
2559 vd_need_reset(task->vd, B_TRUE); in vd_notify()
2563 DTRACE_PROBE1(task__end, vd_task_t *, task); in vd_notify()
2578 vd_complete_notify(vd_task_t *task) in vd_complete_notify() argument
2581 vd_t *vd = task->vd; in vd_complete_notify()
2582 vd_dring_payload_t *request = task->request; in vd_complete_notify()
2586 status = vd_mark_elem_done(vd, task->index, in vd_complete_notify()
2599 if ((status != 0) || (task->status != 0)) in vd_complete_notify()
2600 task->msg->tag.vio_subtype = VIO_SUBTYPE_NACK; in vd_complete_notify()
2606 if (task->type == VD_NONFINAL_RANGE_TASK) { in vd_complete_notify()
2617 vd_notify(task); in vd_complete_notify()
2635 vd_task_t *task = (vd_task_t *)arg; in vd_serial_notify() local
2637 ASSERT(task != NULL); in vd_serial_notify()
2638 vd_notify(task); in vd_serial_notify()
3590 vd_task_t *task = (vd_task_t *)arg; in vd_complete() local
3592 ASSERT(task != NULL); in vd_complete()
3593 ASSERT(task->status == EINPROGRESS); in vd_complete()
3594 ASSERT(task->completef != NULL); in vd_complete()
3596 task->status = task->completef(task); in vd_complete()
3597 if (task->status) in vd_complete()
3598 PR0("%s: Error %d completing task", __func__, task->status); in vd_complete()
3601 vd_complete_notify(task); in vd_complete()
3605 vd_ioctl(vd_task_t *task) in vd_ioctl() argument
3613 vd_t *vd = task->vd; in vd_ioctl()
3614 vd_dring_payload_t *request = task->request; in vd_ioctl()
3712 vd_get_devid(vd_task_t *task) in vd_get_devid() argument
3714 vd_t *vd = task->vd; in vd_get_devid()
3715 vd_dring_payload_t *request = task->request; in vd_get_devid()
3808 vd_reset(vd_task_t *task) in vd_reset() argument
3810 vd_t *vd = task->vd; in vd_reset()
3811 vd_dring_payload_t *request = task->request; in vd_reset()
3830 vd_get_capacity(vd_task_t *task) in vd_get_capacity() argument
3834 vd_t *vd = task->vd; in vd_get_capacity()
3835 vd_dring_payload_t *request = task->request; in vd_get_capacity()
3873 vd_get_access(vd_task_t *task) in vd_get_access() argument
3878 vd_t *vd = task->vd; in vd_get_access()
3879 vd_dring_payload_t *request = task->request; in vd_get_access()
3912 vd_set_access(vd_task_t *task) in vd_set_access() argument
3917 vd_t *vd = task->vd; in vd_set_access()
3918 vd_dring_payload_t *request = task->request; in vd_set_access()
4138 vd_do_process_task(vd_task_t *task) in vd_do_process_task() argument
4141 vd_t *vd = task->vd; in vd_do_process_task()
4142 vd_dring_payload_t *request = task->request; in vd_do_process_task()
4153 task->completef = vds_operation[i].complete; in vd_do_process_task()
4184 return (vds_operation[i].start(task)); in vd_do_process_task()
4211 vd_process_task(vd_task_t *task) in vd_process_task() argument
4213 vd_t *vd = task->vd; in vd_process_task()
4216 DTRACE_PROBE1(task__start, vd_task_t *, task); in vd_process_task()
4218 task->status = vd_do_process_task(task); in vd_process_task()
4233 if (task->status == EINPROGRESS) { in vd_process_task()
4236 task, DDI_SLEEP); in vd_process_task()
4242 status = vd_mark_elem_done(vd, task->index, in vd_process_task()
4243 task->request->status, task->request->nbytes); in vd_process_task()
4250 return (task->status); in vd_process_task()
5138 vd_task_t task; in vd_process_msg() local
5185 task.vd = vd; in vd_process_msg()
5186 task.msg = msg; in vd_process_msg()
5187 task.msglen = msglen; in vd_process_msg()
5196 &task, DDI_SLEEP); in vd_process_msg()