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