Lines Matching defs:path_tq

430 	ibcm_path_tqargs_t	*path_tq;
442 path_tq = kmem_alloc(len, sleep_flag);
443 if (path_tq == NULL) {
449 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*path_tq))
451 bcopy(attrp, &path_tq->attr, sizeof (ibt_path_attr_t));
454 path_tq->attr.pa_dgids = (ib_gid_t *)(((uchar_t *)path_tq) +
457 bcopy(attrp->pa_dgids, path_tq->attr.pa_dgids,
460 path_tq->attr.pa_dgids = NULL;
472 path_tq->flags = flags;
473 path_tq->max_paths = max_paths;
474 path_tq->paths = paths;
475 path_tq->num_paths_p = num_path_p;
476 path_tq->func = func;
477 path_tq->arg = arg;
479 _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(*path_tq))
484 path_tq, TQ_NOSLEEP) == 0) {
487 kmem_free(path_tq, len);
493 return (ibcm_process_get_paths(path_tq));
4118 ibcm_ip_path_tqargs_t *path_tq;
4129 path_tq = kmem_zalloc(len, sleep_flag);
4130 if (path_tq == NULL) {
4136 _NOTE(NOW_INVISIBLE_TO_OTHER_THREADS(*path_tq))
4137 bcopy(attrp, &path_tq->attr, sizeof (ibt_ip_path_attr_t));
4139 path_tq->attr.ipa_dst_ip = (ibt_ip_addr_t *)(((uchar_t *)path_tq) +
4141 bcopy(attrp->ipa_dst_ip, path_tq->attr.ipa_dst_ip,
4152 path_tq->flags = flags;
4153 path_tq->ibt_hdl = ibt_hdl;
4154 path_tq->paths = paths;
4155 path_tq->src_ip_p = src_ip_p;
4156 path_tq->num_paths_p = num_path_p;
4157 path_tq->func = func;
4158 path_tq->arg = arg;
4159 path_tq->len = len;
4160 path_tq->ip_done = B_FALSE;
4162 mutex_init(&path_tq->ip_lock, NULL, MUTEX_DEFAULT, NULL);
4163 cv_init(&path_tq->ip_cv, NULL, CV_DRIVER, NULL);
4166 _NOTE(NOW_VISIBLE_TO_OTHER_THREADS(*path_tq))
4169 ret = taskq_dispatch(ibcm_taskq, ibcm_process_get_ip_paths, path_tq,
4175 cv_destroy(&path_tq->ip_cv);
4176 mutex_destroy(&path_tq->ip_lock);
4178 kmem_free(path_tq, len);
4186 mutex_enter(&path_tq->ip_lock);
4187 while (path_tq->ip_done != B_TRUE)
4188 cv_wait(&path_tq->ip_cv, &path_tq->ip_lock);
4189 retval = path_tq->retval;
4190 mutex_exit(&path_tq->ip_lock);
4191 cv_destroy(&path_tq->ip_cv);
4192 mutex_destroy(&path_tq->ip_lock);
4193 kmem_free(path_tq, len);