Lines Matching refs:hp
39 slp_handle_impl_t *hp;
53 slp_handle_impl_t *hp;
61 hp = (slp_handle_impl_t *)hSLP;
64 if ((err = slp_new_target_list(hp, scopes, &targets)) != SLP_OK)
66 if ((err = check_message_fit(hp, targets)) != SLP_OK) {
78 args->hp = hp;
88 hp->q = q;
98 hp->producer_tid = tid;
100 if (hp->async) {
110 hp->cancel = 1;
125 slp_handle_impl_t *hp;
131 hp = args->hp;
133 hp->consumer_tid = thr_self();
138 reply = slp_dequeue(hp->q);
140 cont = args->msg_cb(hp, reply, args->cb, args->cookie,
151 args->msg_cb(hp, NULL, args->cb, args->cookie,
158 hp->cancel = 1;
159 (void) thr_join(hp->producer_tid, NULL, NULL);
162 slp_flush_queue(hp->q, free);
163 slp_destroy_queue(hp->q);
166 slp_end_call(hp);
186 len = slp_hdrlang_length(args->hp);
187 for (i = 0; i < args->hp->msg.iovlen; i++) {
188 len += args->hp->msg.iov[i].iov_len;
200 if (args->hp->cancel)
204 slp_uc_tcp_send(args->hp, t, uc_scopes,
207 slp_uc_udp_send(args->hp, t, uc_scopes);
212 if ((!args->hp->cancel) &&
214 slp_mc_send(args->hp, mc_scopes);
217 if (args->hp->tcp_lock)
218 slp_tcp_wait(args->hp);
223 free(args->hp->msg.iov);
224 free(args->hp->msg.msg);
227 (void) slp_enqueue(args->hp->q, NULL);
237 static SLPError check_message_fit(slp_handle_impl_t *hp,
246 msgSize = slp_hdrlang_length(hp);
247 for (i = 0; i < hp->msg.iovlen; i++) {
248 msgSize += hp->msg.iov[i].iov_len;