Lines Matching defs:msg
208 struct xsd_sockmsg msg;
246 if (state.read != sizeof(state.msg)) {
247 err = xb_read((void *)&state.msg + state.read,
248 sizeof(state.msg) - state.read);
252 if (state.read != sizeof(state.msg))
254 if (state.msg.len > XENSTORE_PAYLOAD_MAX) {
260 len = state.msg.len + 1;
261 if (state.msg.type == XS_WATCH_EVENT)
268 if (state.msg.type == XS_WATCH_EVENT)
276 err = xb_read(state.body + state.read, state.msg.len - state.read);
281 if (state.read != state.msg.len)
284 state.body[state.msg.len] = '\0';
286 if (state.msg.type == XS_WATCH_EVENT) {
287 state.watch->len = state.msg.len;
293 if (req->msg.req_id == state.msg.req_id) {
304 req->msg.req_id = req->caller_req_id;
305 req->msg.type = state.msg.type;
306 req->msg.len = state.msg.len;
358 base = &state.req->msg;
359 len = sizeof(state.req->msg);
386 state.req->msg.type = XS_ERROR;