Lines Matching refs:msg
102 if (trans->tx_id == dc->wbuf.msg.tx_id)
171 dc->wbuf.buffer + sizeof(dc->wbuf.msg),
172 dc->wbuf_used - sizeof(dc->wbuf.msg),
175 make_request(dc, req, dc->wbuf.msg.tx_id, &wreq, 1);
193 watch_message_parse(const struct xsd_sockmsg *msg,
196 const char *begin = (const char*)msg;
197 const char *p = begin + sizeof(*msg);
198 const char *end = p + msg->len;
217 dc,du, dc->wbuf.msg.type));
224 req->user_id = dc->wbuf.msg.req_id;
225 req->req_type = dc->wbuf.msg.type;
227 switch (dc->wbuf.msg.type) {
237 if (dc->wbuf.msg.tx_id) {
238 if (!find_transaction(dc, dc->wbuf.msg.tx_id))
245 if (dc->wbuf.msg.tx_id)
256 if (!dc->wbuf.msg.tx_id)
258 req->u.trans = trans = find_transaction(dc, dc->wbuf.msg.tx_id);
266 if (dc->wbuf.msg.tx_id)
268 if (!watch_message_parse(&dc->wbuf.msg, &wpath, &wtoken))
290 make_watch_request(dc, req, dc->wbuf.msg.tx_id, watch);
294 if (dc->wbuf.msg.tx_id)
296 if (!watch_message_parse(&dc->wbuf.msg, &wpath, &wtoken))
304 make_watch_request(dc, req, dc->wbuf.msg.tx_id, watch);
402 struct xsd_sockmsg *msg = req->xb.reply;
404 msg->req_id = req->user_id;
406 _Bool error = msg->type == XS_ERROR;
407 KASSERT(error || msg->type == req->req_type);
410 " response, req_type=%d msg->type=%d\n",
411 dc,du, req->req_type, msg->type));
418 KASSERT(msg->len >= 2);
419 KASSERT(!((uint8_t*)(msg+1))[msg->len-1]);
421 strtoul((char*)&msg + sizeof(*msg),
456 return msg;