1 87d297d1 2024-02-22 op /*
 2 87d297d1 2024-02-22 op  * Copyright (c) 2021, 2024 Omar Polo <op@omarpolo.com>
 3 87d297d1 2024-02-22 op  *
 4 87d297d1 2024-02-22 op  * Permission to use, copy, modify, and distribute this software for any
 5 87d297d1 2024-02-22 op  * purpose with or without fee is hereby granted, provided that the above
 6 87d297d1 2024-02-22 op  * copyright notice and this permission notice appear in all copies.
 7 87d297d1 2024-02-22 op  *
 8 87d297d1 2024-02-22 op  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
 9 87d297d1 2024-02-22 op  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10 87d297d1 2024-02-22 op  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11 87d297d1 2024-02-22 op  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12 87d297d1 2024-02-22 op  * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13 87d297d1 2024-02-22 op  * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14 87d297d1 2024-02-22 op  * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15 87d297d1 2024-02-22 op  */
16 87d297d1 2024-02-22 op 
17 87d297d1 2024-02-22 op #include "compat.h"
18 87d297d1 2024-02-22 op 
19 87d297d1 2024-02-22 op #include "ev.h"
20 87d297d1 2024-02-22 op #include "imsgev.h"
21 87d297d1 2024-02-22 op 
22 87d297d1 2024-02-22 op void
23 87d297d1 2024-02-22 op imsg_event_add(struct imsgev *iev)
24 87d297d1 2024-02-22 op {
25 87d297d1 2024-02-22 op 	iev->events = EV_READ;
26 c8b8dc5c 2025-03-28 op 	if (imsgbuf_queuelen(&iev->ibuf))
27 87d297d1 2024-02-22 op 		iev->events |= EV_WRITE;
28 87d297d1 2024-02-22 op 
29 87d297d1 2024-02-22 op 	ev_add(iev->ibuf.fd, iev->events, iev->handler, iev);
30 87d297d1 2024-02-22 op }
31 87d297d1 2024-02-22 op 
32 87d297d1 2024-02-22 op int
33 87d297d1 2024-02-22 op imsg_compose_event(struct imsgev *iev, uint16_t type, uint32_t peerid,
34 87d297d1 2024-02-22 op     pid_t pid, int fd, const void *data, uint16_t datalen)
35 87d297d1 2024-02-22 op {
36 87d297d1 2024-02-22 op 	int	ret;
37 87d297d1 2024-02-22 op 
38 87d297d1 2024-02-22 op 	if ((ret = imsg_compose(&iev->ibuf, type, peerid, pid, fd, data,
39 87d297d1 2024-02-22 op 	    datalen) != -1))
40 87d297d1 2024-02-22 op 		imsg_event_add(iev);
41 87d297d1 2024-02-22 op 
42 87d297d1 2024-02-22 op 	return ret;
43 87d297d1 2024-02-22 op }
44 87d297d1 2024-02-22 op 
45 87d297d1 2024-02-22 op int
46 87d297d1 2024-02-22 op ibuf_borrow_str(struct ibuf *ibuf, char **data)
47 87d297d1 2024-02-22 op {
48 87d297d1 2024-02-22 op 	size_t		 len;
49 87d297d1 2024-02-22 op 
50 87d297d1 2024-02-22 op 	if ((*data = ibuf_data(ibuf)) == NULL ||
51 87d297d1 2024-02-22 op 	    (len = ibuf_size(ibuf)) == 0 ||
52 87d297d1 2024-02-22 op 	    (*data)[len - 1] != '\0')
53 87d297d1 2024-02-22 op 		return -1;
54 87d297d1 2024-02-22 op 	return 0;
55 87d297d1 2024-02-22 op }