Lines Matching refs:pend
1081 struct hl_user_pending_interrupt *pend, *temp;
1084 list_for_each_entry_safe(pend, temp, &interrupt->wait_list_head, wait_list_node) {
1085 if (pend->ts_reg_info.buf) {
1086 list_del(&pend->wait_list_node);
1087 hl_mmap_mem_buf_put(pend->ts_reg_info.buf);
1088 hl_cb_put(pend->ts_reg_info.cq_cb);
1090 pend->fence.error = -EIO;
1091 complete_all(&pend->fence.completion);
3204 struct hl_user_pending_interrupt **pend)
3274 *pend = requested_offset_record;
3288 struct hl_user_pending_interrupt *pend;
3324 &interrupt->wait_list_lock, &pend);
3328 pend = kzalloc(sizeof(*pend), GFP_KERNEL);
3329 if (!pend) {
3333 hl_fence_init(&pend->fence, ULONG_MAX);
3334 pend->cq_kernel_addr = (u64 *) cq_cb->kernel_address + cq_counters_offset;
3335 pend->cq_target_value = target_value;
3343 if (*pend->cq_kernel_addr >= target_value) {
3345 pend->ts_reg_info.in_use = 0;
3351 *pend->ts_reg_info.timestamp_kernel_addr = ktime_get_ns();
3354 pend->fence.timestamp = ktime_get();
3360 pend->fence.timestamp = ktime_get();
3380 pend->ts_reg_info.in_use = 1;
3382 list_add_tail(&pend->wait_list_node, &interrupt->wait_list_head);
3391 completion_rc = wait_for_completion_interruptible_timeout(&pend->fence.completion,
3403 if (pend->fence.error == -EIO) {
3406 pend->fence.error);
3428 list_del(&pend->wait_list_node);
3432 *timestamp = ktime_to_ns(pend->fence.timestamp);
3433 kfree(pend);
3456 struct hl_user_pending_interrupt *pend;
3466 pend = kzalloc(sizeof(*pend), GFP_KERNEL);
3467 if (!pend) {
3472 hl_fence_init(&pend->fence, ULONG_MAX);
3478 list_add_tail(&pend->wait_list_node, &interrupt->wait_list_head);
3493 pend->fence.timestamp = ktime_get();
3503 completion_rc = wait_for_completion_interruptible_timeout(&pend->fence.completion,
3516 reinit_completion(&pend->fence.completion);
3528 } else if (pend->fence.error) {
3531 pend->fence.error);
3555 list_del(&pend->wait_list_node);
3558 *timestamp = ktime_to_ns(pend->fence.timestamp);
3560 kfree(pend);