lib/libopenbsd/imsg.c

36 imsg_init(struct imsgbuf *ibuf, int fd)
38 	msgbuf_init(&ibuf->w);
39 	memset(&ibuf->r, 0, sizeof(ibuf->r));
40 	ibuf->fd = fd;
41 	ibuf->w.fd = fd;
42 	ibuf->pid = getpid();
43 	TAILQ_INIT(&ibuf->fds);
47 imsg_read(struct imsgbuf *ibuf)
63 	iov.iov_base = ibuf->r.buf + ibuf->r.wpos;
64 	iov.iov_len = sizeof(ibuf->r.buf) - ibuf->r.wpos;
82 	if ((n = recvmsg(ibuf->fd, &msg, 0)) == -1) {
88 	ibuf->r.wpos += n;
108 					TAILQ_INSERT_TAIL(&ibuf->fds, ifd,
124 imsg_get(struct imsgbuf *ibuf, struct imsg *imsg)
128 	av = ibuf->r.wpos;
133 	memcpy(&imsg->hdr, ibuf->r.buf, sizeof(imsg->hdr));
142 	ibuf->r.rptr = ibuf->r.buf + IMSG_HEADER_SIZE;
149 		imsg->fd = imsg_get_fd(ibuf);
153 	memcpy(imsg->data, ibuf->r.rptr, datalen);
157 		memmove(&ibuf->r.buf, ibuf->r.buf + imsg->hdr.len, left);
158 		ibuf->r.wpos = left;
160 		ibuf->r.wpos = 0;
166 imsg_compose(struct imsgbuf *ibuf, u_int32_t type, u_int32_t peerid,
169 	struct ibuf	*wbuf;
171 	if ((wbuf = imsg_create(ibuf, type, peerid, pid, datalen)) == NULL)
179 	imsg_close(ibuf, wbuf);
185 imsg_composev(struct imsgbuf *ibuf, u_int32_t type, u_int32_t peerid,
188 	struct ibuf	*wbuf;
194 	if ((wbuf = imsg_create(ibuf, type, peerid, pid, datalen)) == NULL)
203 	imsg_close(ibuf, wbuf);
209 struct ibuf *
210 imsg_create(struct imsgbuf *ibuf, u_int32_t type, u_int32_t peerid,
213 	struct ibuf	*wbuf;
226 		hdr.pid = ibuf->pid;
237 imsg_add(struct ibuf *msg, const void *data, u_int16_t datalen)
248 imsg_close(struct imsgbuf *ibuf, struct ibuf *msg)
260 	ibuf_close(&ibuf->w, msg);
270 imsg_get_fd(struct imsgbuf *ibuf)
275 	if ((ifd = TAILQ_FIRST(&ibuf->fds)) == NULL)
279 	TAILQ_REMOVE(&ibuf->fds, ifd, entry);
286 imsg_flush(struct imsgbuf *ibuf)
288 	while (ibuf->w.queued)
289 		if (msgbuf_write(&ibuf->w) <= 0)
295 imsg_clear(struct imsgbuf *ibuf)
299 	msgbuf_clear(&ibuf->w);
300 	while ((fd = imsg_get_fd(ibuf)) != -1)