Lines Matching defs:m
348 m_msg(struct msg *m, struct imsg *imsg)
351 m->pos = imsg->data;
352 m->end = m->pos + (imsg->hdr.len - sizeof(imsg->hdr));
356 m_end(struct msg *m)
358 if (m->pos != m->end)
363 m_is_eom(struct msg *m)
365 return (m->pos == m->end);
369 m_get(struct msg *m, void *dst, size_t sz)
372 m->end - m->pos < (ssize_t)sz)
375 memmove(dst, m->pos, sz);
376 m->pos += sz;
380 m_add_int(struct mproc *m, int v)
382 m_add(m, &v, sizeof(v));
386 m_add_u32(struct mproc *m, uint32_t u32)
388 m_add(m, &u32, sizeof(u32));
392 m_add_size(struct mproc *m, size_t sz)
394 m_add(m, &sz, sizeof(sz));
398 m_add_time(struct mproc *m, time_t v)
400 m_add(m, &v, sizeof(v));
404 m_add_timeval(struct mproc *m, struct timeval *tv)
406 m_add(m, tv, sizeof(*tv));
411 m_add_string(struct mproc *m, const char *v)
414 m_add(m, "s", 1);
415 m_add(m, v, strlen(v) + 1);
418 m_add(m, "\0", 1);
422 m_add_data(struct mproc *m, const void *v, size_t len)
424 m_add_size(m, len);
425 m_add(m, v, len);
429 m_add_id(struct mproc *m, uint64_t v)
431 m_add(m, &v, sizeof(v));
435 m_add_evpid(struct mproc *m, uint64_t v)
437 m_add(m, &v, sizeof(v));
441 m_add_msgid(struct mproc *m, uint32_t v)
443 m_add(m, &v, sizeof(v));
447 m_add_sockaddr(struct mproc *m, const struct sockaddr *sa)
449 m_add_size(m, sa->sa_len);
450 m_add(m, sa, sa->sa_len);
454 m_add_mailaddr(struct mproc *m, const struct mailaddr *maddr)
456 m_add(m, maddr, sizeof(*maddr));
460 m_add_envelope(struct mproc *m, const struct envelope *evp)
465 m_add_evpid(m, evp->id);
466 m_add_string(m, buf);
470 m_add_params(struct mproc *m, struct dict *d)
477 m_add_size(m, 0);
480 m_add_size(m, dict_count(d));
483 m_add_string(m, key);
484 m_add_string(m, value);
489 m_get_int(struct msg *m, int *i)
491 m_get(m, i, sizeof(*i));
495 m_get_u32(struct msg *m, uint32_t *u32)
497 m_get(m, u32, sizeof(*u32));
501 m_get_size(struct msg *m, size_t *sz)
503 m_get(m, sz, sizeof(*sz));
507 m_get_time(struct msg *m, time_t *t)
509 m_get(m, t, sizeof(*t));
513 m_get_timeval(struct msg *m, struct timeval *tv)
515 m_get(m, tv, sizeof(*tv));
519 m_get_string(struct msg *m, const char **s)
524 if (m->pos >= m->end)
527 c = *m->pos++;
533 if (m->pos >= m->end)
535 end = memchr(m->pos, 0, m->end - m->pos);
539 *s = m->pos;
540 m->pos = end + 1;
544 m_get_data(struct msg *m, const void **data, size_t *sz)
546 m_get_size(m, sz);
553 if (m->pos + *sz > m->end)
556 *data = m->pos;
557 m->pos += *sz;
561 m_get_evpid(struct msg *m, uint64_t *evpid)
563 m_get(m, evpid, sizeof(*evpid));
567 m_get_msgid(struct msg *m, uint32_t *msgid)
569 m_get(m, msgid, sizeof(*msgid));
573 m_get_id(struct msg *m, uint64_t *id)
575 m_get(m, id, sizeof(*id));
579 m_get_sockaddr(struct msg *m, struct sockaddr *sa)
583 m_get_size(m, &len);
584 m_get(m, sa, len);
588 m_get_mailaddr(struct msg *m, struct mailaddr *maddr)
590 m_get(m, maddr, sizeof(*maddr));
594 m_get_envelope(struct msg *m, struct envelope *evp)
599 m_get_evpid(m, &evpid);
600 m_get_string(m, &buf);
610 m_get_params(struct msg *m, struct dict *d)
619 m_get_size(m, &c);
622 m_get_string(m, &key);
623 m_get_string(m, &value);