Lines Matching refs:msg

79 	struct xsd_sockmsg msg;  in xenbus_get_reply()  local
90 if (xenstore_buf->rsp_prod - xenstore_buf->rsp_cons < sizeof(msg)) in xenbus_get_reply()
94 memcpy_from_ring(xenstore_buf->rsp, &msg, in xenbus_get_reply()
96 sizeof(msg)); in xenbus_get_reply()
98 if (xenstore_buf->rsp_prod - xenstore_buf->rsp_cons < sizeof(msg) + msg.len) in xenbus_get_reply()
102 BUG_ON(msg.type == XS_WATCH_EVENT); in xenbus_get_reply()
104 *req_reply = malloc(sizeof(msg) + msg.len); in xenbus_get_reply()
107 msg.len + sizeof(msg)); in xenbus_get_reply()
109 xenstore_buf->rsp_cons += msg.len + sizeof(msg); in xenbus_get_reply()
120 char *msg = NULL; in xenbus_switch_state() local
129 msg = xenbus_transaction_start(&xbt); in xenbus_switch_state()
130 if (msg) in xenbus_switch_state()
135 msg = xenbus_read(xbt, path, &current_state); in xenbus_switch_state()
136 if (msg) in xenbus_switch_state()
142 msg = NULL; in xenbus_switch_state()
147 msg = xenbus_write(xbt, path, value); in xenbus_switch_state()
154 if (msg == NULL && msg2 != NULL) in xenbus_switch_state()
155 msg = msg2; in xenbus_switch_state()
160 return msg; in xenbus_switch_state()
166 char *res, *msg; in xenbus_wait_for_state_change() local
169 msg = xenbus_read(XBT_NIL, path, &res); in xenbus_wait_for_state_change()
170 if (msg) in xenbus_wait_for_state_change()
171 return msg; in xenbus_wait_for_state_change()
282 char msg[] = "No reply"; in errmsg() local
283 size_t len = strlen(msg) + 1; in errmsg()
285 return memcpy(malloc(len), msg, len); in errmsg()
305 char **res, *msg; in xenbus_ls() local
308 msg = errmsg(repmsg); in xenbus_ls()
309 if (msg) { in xenbus_ls()
311 return msg; in xenbus_ls()
334 char *res, *msg; in xenbus_read() local
337 msg = errmsg(rep); in xenbus_read()
338 if (msg) { in xenbus_read()
340 return msg; in xenbus_read()
358 char *msg; in xenbus_write() local
361 msg = errmsg(rep); in xenbus_write()
362 if (msg) in xenbus_write()
363 return msg; in xenbus_write()
372 char *msg; in xenbus_rm() local
375 msg = errmsg(rep); in xenbus_rm()
376 if (msg) in xenbus_rm()
377 return msg; in xenbus_rm()
386 char *res, *msg; in xenbus_get_perms() local
389 msg = errmsg(rep); in xenbus_get_perms()
390 if (msg) { in xenbus_get_perms()
392 return msg; in xenbus_get_perms()
412 char *msg; in xenbus_set_perms() local
417 msg = errmsg(rep); in xenbus_set_perms()
418 if (msg) in xenbus_set_perms()
419 return msg; in xenbus_set_perms()