Lines Matching refs:msg

40  *	format params into a char *msg
41 * send this msg to slpd
47 * format the params into a char *msg
52 * caller thread places the reg msg on the reg_q, and returns
54 * msg to slpd
76 struct iovec *msgiov; /* msg contents */
88 struct reg_msg *msg;
99 struct reg_msg *msg;
145 struct reg_msg *msg;
165 /* format params into msg */
168 pcScopeList, pcAttrs, fresh, &msg)) != SLP_OK) {
174 if ((err = reg_common(hSLP, msg, pvUser, callback)) == SLP_OK &&
194 SLPBoolean fresh, struct reg_msg **msg) {
206 *msg = NULL;
207 if (!(*msg = calloc(1, sizeof (**msg)))) {
217 /* srv reg msg */
234 * Create iovec for the msg. The iovec components are layed out thus:
240 if (!((*msg)->msgiov = calloc(4, sizeof (*((*msg)->msgiov))))) {
245 (*msg)->msgiov_len = 4;
261 (*msg)->urlbytes.iov_base = m + len;
266 (*msg)->urlbytes.iov_len = len - tmplen;
268 (*msg)->msgiov[0].iov_base = m;
269 (*msg)->msgiov[0].iov_len = len;
272 err = slp_sign(&((*msg)->urlbytes), 1, ts,
273 (*msg)->msgiov, SLP_URL_AUTH);
278 (*msg)->msgiov[2].iov_base = m + len;
288 (*msg)->attrbytes.iov_base = m + len;
293 (*msg)->attrbytes.iov_len = len - tmplen;
296 (*msg)->msgiov[2].iov_len = len - (*msg)->msgiov[0].iov_len;
299 err = slp_sign(&((*msg)->attrbytes), 1, ts,
300 (*msg)->msgiov, SLP_ATTR_AUTH);
306 msgLen += (*msg)->msgiov[SLP_URL_AUTH].iov_len;
307 msgLen += (*msg)->msgiov[SLP_ATTR_AUTH].iov_len;
319 if (*msg) {
320 if ((*msg)->msgiov) free_msgiov((*msg)->msgiov, 4);
321 free(*msg);
323 *msg = NULL;
330 struct reg_msg *msg;
349 /* format params into msg */
350 if ((err = packSrvDereg(hSLP, pURL, pcScopeList, NULL, &msg))
357 if ((err = reg_common(hSLP, msg, pvUser, callback)) == SLP_OK) {
370 struct reg_msg *msg;
389 /* format params into msg */
390 if ((err = packSrvDereg(hSLP, pURL, pcScopeList, pcAttrs, &msg))
398 return (reg_common(hSLP, msg, pvUser, callback));
403 struct reg_msg **msg) {
409 *msg = NULL;
410 if (!(*msg = calloc(1, sizeof (**msg)))) {
430 * Create iovec for the msg. The iovec components are layed out thus:
435 if (!((*msg)->msgiov = calloc(3, sizeof (*((*msg)->msgiov))))) {
440 (*msg)->msgiov_len = 3;
457 (*msg)->urlbytes.iov_base = m + len;
462 (*msg)->urlbytes.iov_len = len - tmplen;
464 (*msg)->msgiov[0].iov_base = m;
465 (*msg)->msgiov[0].iov_len = len;
468 err = slp_sign(&((*msg)->urlbytes), 1, 0,
469 (*msg)->msgiov, SLP_URL_AUTH);
474 (*msg)->msgiov[2].iov_base = m + len;
481 (*msg)->msgiov[2].iov_len = len - (*msg)->msgiov[0].iov_len;
484 msgLen += (*msg)->msgiov[SLP_URL_AUTH].iov_len;
496 if (*msg) {
497 if ((*msg)->msgiov) free_msgiov((*msg)->msgiov, 3);
498 free(*msg);
500 *msg = NULL;
507 static SLPError reg_common(slp_handle_impl_t *hp, struct reg_msg *msg,
516 err = enqueue_reg(hp, msg, cookie, callback);
518 err = reg_impl(hp, msg, cookie, callback);
530 static SLPError enqueue_reg(slp_handle_impl_t *hp, struct reg_msg *msg,
539 rmsg->msg = msg;
619 (void) reg_impl(rmsg->hp, rmsg->msg, rmsg->cookie, rmsg->cb);
648 static SLPError reg_impl(slp_handle_impl_t *hp, struct reg_msg *msg,
656 if ((err = slp_send2slpd_iov(msg->msgiov, msg->msgiov_len, &reply))
660 /* through with msg, so free it now */
661 free_msgiov(msg->msgiov, msg->msgiov_len);
662 free(msg);
685 * Adds the registration contained in 'msg' to the refresh registration
691 static SLPError add_rereg(const char *url, struct reg_msg *msg,
715 reg->msg = msg;
766 (void) slp_sign(&(p->msg->urlbytes), 1, now + p->lifetime,
767 p->msg->msgiov, 1);
768 (void) slp_sign(&(p->msg->attrbytes), 1, now + p->lifetime,
769 p->msg->msgiov, 3);
772 p->msg->msgiov, p->msg->msgiov_len, &reply);
811 free(p->msg->msgiov[0].iov_base);
813 free(p->msg->msgiov[SLP_URL_AUTH].iov_base);
815 free(p->msg->msgiov[SLP_ATTR_AUTH].iov_base);
817 free(p->msg->msgiov);
819 free(p->msg);