Lines Matching refs:msg

85 	char msg[];  member
110 struct xsd_sockmsg msg; member
153 ret = copy_to_user(ubuf + i, &rb->msg[rb->cons], sz); in xenbus_file_read()
205 memcpy(rb->msg, data, len); in queue_reply()
378 if (req->msg.type == XS_ERROR) { in xenbus_dev_queue_reply()
387 trans = xenbus_get_transaction(u, req->msg.tx_id); in xenbus_dev_queue_reply()
397 rc = queue_reply(&staging_q, &req->msg, sizeof(req->msg)); in xenbus_dev_queue_reply()
399 rc = queue_reply(&staging_q, req->body, req->msg.len); in xenbus_dev_queue_reply()
425 } msg; in xenbus_command_reply() local
428 msg.hdr = u->u.msg; in xenbus_command_reply()
429 msg.hdr.type = msg_type; in xenbus_command_reply()
430 msg.hdr.len = strlen(reply) + 1; in xenbus_command_reply()
431 if (msg.hdr.len > sizeof(msg.body)) in xenbus_command_reply()
433 memcpy(&msg.body, reply, msg.hdr.len); in xenbus_command_reply()
436 rc = queue_reply(&u->read_buffers, &msg, sizeof(msg.hdr) + msg.hdr.len); in xenbus_command_reply()
454 } *msg = (void *)u->u.buffer; in xenbus_write_transaction() local
464 } else if (msg->hdr.tx_id != 0 && in xenbus_write_transaction()
465 !xenbus_get_transaction(u, msg->hdr.tx_id)) in xenbus_write_transaction()
468 !(msg->hdr.len == 2 && in xenbus_write_transaction()
469 (!strcmp(msg->body, "T") || !strcmp(msg->body, "F")))) in xenbus_write_transaction()
472 trans = xenbus_get_transaction(u, msg->hdr.tx_id); in xenbus_write_transaction()
476 if (!strcmp(msg->body, "T")) in xenbus_write_transaction()
486 rc = xenbus_dev_request_and_reply(&msg->hdr, u); in xenbus_write_transaction()
502 path = u->u.buffer + sizeof(u->u.msg); in xenbus_write_watch()
503 token = memchr(path, 0, u->u.msg.len); in xenbus_write_watch()
509 if (memchr(token, 0, u->u.msg.len - (token - path)) == NULL) { in xenbus_write_watch()
602 if (u->len < sizeof(u->u.msg)) in xenbus_file_write()
607 if ((sizeof(u->u.msg) + u->u.msg.len) > sizeof(u->u.buffer)) { in xenbus_file_write()
613 if (u->len < (sizeof(u->u.msg) + u->u.msg.len)) in xenbus_file_write()
622 msg_type = u->u.msg.type; in xenbus_file_write()