Lines Matching refs:msg
119 req->type = req->msg.type; in xs_request_enter()
143 if ((req->type == XS_TRANSACTION_START && req->msg.type == XS_ERROR) || in xs_request_exit()
145 !WARN_ON_ONCE(req->msg.type == XS_ERROR && in xs_request_exit()
227 static void xs_send(struct xb_req_data *req, struct xsd_sockmsg *msg) in xs_send() argument
231 req->msg = *msg; in xs_send()
237 req->caller_req_id = req->msg.req_id; in xs_send()
238 req->msg.req_id = xs_request_enter(req); in xs_send()
249 static void *xs_wait_for_reply(struct xb_req_data *req, struct xsd_sockmsg *msg) in xs_wait_for_reply() argument
257 msg->type = req->msg.type; in xs_wait_for_reply()
258 msg->len = req->msg.len; in xs_wait_for_reply()
276 int xenbus_dev_request_and_reply(struct xsd_sockmsg *msg, void *par) in xenbus_dev_request_and_reply() argument
286 vec->iov_len = msg->len; in xenbus_dev_request_and_reply()
287 vec->iov_base = msg + 1; in xenbus_dev_request_and_reply()
295 xs_send(req, msg); in xenbus_dev_request_and_reply()
309 struct xsd_sockmsg msg; in xs_talkv() local
323 msg.req_id = 0; in xs_talkv()
324 msg.tx_id = t.id; in xs_talkv()
325 msg.type = type; in xs_talkv()
326 msg.len = 0; in xs_talkv()
328 msg.len += iovec[i].iov_len; in xs_talkv()
330 xs_send(req, &msg); in xs_talkv()
332 ret = xs_wait_for_reply(req, &msg); in xs_talkv()
334 *len = msg.len; in xs_talkv()
339 if (msg.type == XS_ERROR) { in xs_talkv()
345 if (msg.type != type) { in xs_talkv()
347 msg.type, type); in xs_talkv()