Lines Matching refs:mw
151 rc_message_free(message_wrapper_t *mw)
153 xdr_free(xdr_message, (char *)&mw->message);
154 free(mw);
216 for (message_wrapper_t *mw = TAILQ_FIRST(&client->rrc_events);
217 mw != NULL; mw = next) {
218 next = TAILQ_NEXT(mw, node);
219 rc_message_free(mw);
221 for (message_wrapper_t *mw = TAILQ_FIRST(&client->rrc_responses);
222 mw != NULL; mw = next) {
223 next = TAILQ_NEXT(mw, node);
224 rc_message_free(mw);
285 message_wrapper_t *mw = zalloc(sizeof (message_wrapper_t));
286 if (mw == NULL) {
291 !xdr_message(&client->rrc_rxdr, &mw->message)) {
292 free(mw);
296 *mwp = mw;
302 rc_queue_event(rc_conn_t *client, message_wrapper_t *mw)
305 TAILQ_INSERT_TAIL(&client->rrc_events, mw, node);
311 rc_queue_response(rc_conn_t *client, message_wrapper_t *mw)
314 TAILQ_INSERT_TAIL(&client->rrc_responses, mw, node);
323 message_wrapper_t *mw;
324 TAILQ_FOREACH(mw, &client->rrc_responses, node)
325 if (mw->message.serial == serial)
326 return (mw);
333 message_wrapper_t *mw;
337 while ((mw = find_response(client, serial)) == NULL) {
342 if (mw != NULL)
343 TAILQ_REMOVE(&client->rrc_responses, mw, node);
346 return (mw);
359 message_wrapper_t *mw;
360 TAILQ_FOREACH(mw, &client->rrc_events, node)
361 if (strcmp(mw->message.message_u.edata.type, name) == 0)
362 return (mw);
370 message_wrapper_t *mw;
373 while ((mw = find_event(client, name)) == NULL && block &&
376 if (mw != NULL) {
377 TAILQ_REMOVE(&client->rrc_responses, mw, node);
403 message_wrapper_t *mw;
404 if (!radclient_read(client, &mw))
407 if (mw->message.serial != 0)
408 rc_queue_response(client, mw);
410 rc_queue_event(client, mw);
446 message_wrapper_t *mw;
456 if (!radclient_read(client, &mw)) {
461 if (mw->message.serial == 0) {
462 rc_queue_event(client, mw);
467 if (mw->message.serial == serial)
468 return (mw);
473 mw->message.serial, serial);
474 rc_message_free(mw);
506 rc_response_data(message_wrapper_t *mw, adr_data_t **data, adr_type_t *type)
508 response_data *response = &mw->message.message_u.rdata;
511 rc_message_free(mw);
516 rc_response_error(message_wrapper_t *mw, adr_data_t **error, adr_type_t *etype)
518 response_data *fault = &mw->message.message_u.rdata;
521 rc_message_free(mw);
525 radclient_error(message_wrapper_t *mw, adr_type_t *etype, adr_data_t **error)
527 if (mw->message.message_u.rdata.error != 0) {
528 int err = mw->message.message_u.rdata.error;
531 rc_response_error(mw, error, etype);
533 rc_message_free(mw);
548 message_wrapper_t *mw = rc_wait(c, serial);
549 if (mw == NULL)
552 rc_err_t result = radclient_error(mw, etype, errorp);
554 *mwp = mw;
634 message_wrapper_t *mw;
637 if ((err = rc_lookup_common(c, name, &obj, error, &mw)) != 0)
643 mw->message.message_u.rdata.payload.payload_len,
644 mw->message.message_u.rdata.payload.payload_val)) {
647 rc_message_free(mw);
650 rc_message_free(mw);
660 message_wrapper_t *mw;
663 if ((err = rc_lookup_common(c, name, &obj, error, &mw)) != 0)
669 mw->message.message_u.rdata.payload.payload_len,
670 mw->message.message_u.rdata.payload.payload_val)) {
673 rc_message_free(mw);
676 rc_message_free(mw);
688 message_wrapper_t *mw = NULL;
690 c, LIST, xdr_op_list, &listreq, &mw, NULL, error);
695 mw->message.message_u.rdata.payload.payload_len,
696 mw->message.message_u.rdata.payload.payload_val)) {
697 rc_message_free(mw);
700 rc_message_free(mw);
727 message_wrapper_t *mw = NULL;
729 &invokereq, &mw, method->am_error, error);
733 if (rc_response_data(mw, result, method->am_result))
753 message_wrapper_t *mw = NULL;
755 xdr_op_setattr, &setreq, &mw, attr->aa_write_error, error);
759 rc_message_free(mw);
773 message_wrapper_t *mw = NULL;
775 &getreq, &mw, attr->aa_read_error, error);
779 if (rc_response_data(mw, result, attr->aa_type))