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