Lines Matching refs:hp
37 slp_handle_impl_t *hp; member
51 slp_handle_impl_t *hp; in slp_ua_common() local
59 hp = (slp_handle_impl_t *)hSLP; in slp_ua_common()
62 if ((err = slp_new_target_list(hp, scopes, &targets)) != SLP_OK) in slp_ua_common()
64 if ((err = check_message_fit(hp, targets)) != SLP_OK) { in slp_ua_common()
76 args->hp = hp; in slp_ua_common()
86 hp->q = q; in slp_ua_common()
95 hp->producer_tid = tid; in slp_ua_common()
97 if (hp->async) { in slp_ua_common()
106 hp->cancel = 1; in slp_ua_common()
123 slp_handle_impl_t *hp; in consumer() local
129 hp = args->hp; in consumer()
131 hp->consumer_tid = thr_self(); in consumer()
136 reply = slp_dequeue(hp->q); in consumer()
138 cont = args->msg_cb(hp, reply, args->cb, args->cookie, in consumer()
149 args->msg_cb(hp, NULL, args->cb, args->cookie, in consumer()
156 hp->cancel = 1; in consumer()
157 (void) thr_join(hp->producer_tid, NULL, NULL); in consumer()
160 slp_flush_queue(hp->q, free); in consumer()
161 slp_destroy_queue(hp->q); in consumer()
164 slp_end_call(hp); in consumer()
186 len = slp_hdrlang_length(args->hp); in slp_call()
187 for (i = 0; i < args->hp->msg.iovlen; i++) { in slp_call()
188 len += args->hp->msg.iov[i].iov_len; in slp_call()
198 if (args->hp->cancel) in slp_call()
202 slp_uc_tcp_send(args->hp, t, uc_scopes, in slp_call()
205 slp_uc_udp_send(args->hp, t, uc_scopes); in slp_call()
210 if ((!args->hp->cancel) && in slp_call()
212 slp_mc_send(args->hp, mc_scopes); in slp_call()
215 if (args->hp->tcp_lock) in slp_call()
216 slp_tcp_wait(args->hp); in slp_call()
221 free(args->hp->msg.iov); in slp_call()
222 free(args->hp->msg.msg); in slp_call()
225 (void) slp_enqueue(args->hp->q, NULL); in slp_call()
235 static SLPError check_message_fit(slp_handle_impl_t *hp, in check_message_fit() argument
244 msgSize = slp_hdrlang_length(hp); in check_message_fit()
245 for (i = 0; i < hp->msg.iovlen; i++) { in check_message_fit()
246 msgSize += hp->msg.iov[i].iov_len; in check_message_fit()