Annotation of embedaddon/sudo/common/event_select.c, revision 1.1.1.1
1.1 misho 1: /*
2: * Copyright (c) 2013 Todd C. Miller <Todd.Miller@courtesan.com>
3: *
4: * Permission to use, copy, modify, and distribute this software for any
5: * purpose with or without fee is hereby granted, provided that the above
6: * copyright notice and this permission notice appear in all copies.
7: *
8: * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
9: * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
10: * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
11: * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
12: * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
13: * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
14: * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
15: */
16:
17: #include <config.h>
18:
19: #include <sys/param.h> /* for howmany() on Linux */
20: #include <sys/time.h>
21: #ifdef HAVE_SYS_SYSMACROS_H
22: # include <sys/sysmacros.h> /* for howmany() on Solaris */
23: #endif
24: #ifdef HAVE_SYS_SELECT_H
25: # include <sys/select.h>
26: #endif /* HAVE_SYS_SELECT_H */
27: #include <stdio.h>
28: #ifdef STDC_HEADERS
29: # include <stdlib.h>
30: # include <stddef.h>
31: #else
32: # ifdef HAVE_STDLIB_H
33: # include <stdlib.h>
34: # endif
35: #endif /* STDC_HEADERS */
36: #ifdef HAVE_STDBOOL_H
37: # include <stdbool.h>
38: #else
39: # include "compat/stdbool.h"
40: #endif /* HAVE_STDBOOL_H */
41: #ifdef HAVE_STRING_H
42: # include <string.h>
43: #endif /* HAVE_STRING_H */
44: #ifdef HAVE_STRINGS_H
45: # include <strings.h>
46: #endif /* HAVE_STRINGS_H */
47: #ifdef HAVE_UNISTD_H
48: # include <unistd.h>
49: #endif /* HAVE_UNISTD_H */
50: #include <errno.h>
51:
52: #include "missing.h"
53: #include "alloc.h"
54: #include "fatal.h"
55: #include "sudo_debug.h"
56: #include "sudo_event.h"
57: #include "sudo_util.h"
58:
59: /* XXX - use non-exiting allocators? */
60:
61: int
62: sudo_ev_base_alloc_impl(struct sudo_event_base *base)
63: {
64: debug_decl(sudo_ev_base_alloc_impl, SUDO_DEBUG_EVENT)
65:
66: base->maxfd = NFDBITS - 1;
67: base->readfds_in = ecalloc(1, sizeof(fd_mask));
68: base->writefds_in = ecalloc(1, sizeof(fd_mask));
69: base->readfds_out = ecalloc(1, sizeof(fd_mask));
70: base->writefds_out = ecalloc(1, sizeof(fd_mask));
71:
72: debug_return_int(0);
73: }
74:
75: void
76: sudo_ev_base_free_impl(struct sudo_event_base *base)
77: {
78: debug_decl(sudo_ev_base_free_impl, SUDO_DEBUG_EVENT)
79: efree(base->readfds_in);
80: efree(base->writefds_in);
81: efree(base->readfds_out);
82: efree(base->writefds_out);
83: debug_return;
84: }
85:
86: int
87: sudo_ev_add_impl(struct sudo_event_base *base, struct sudo_event *ev)
88: {
89: debug_decl(sudo_ev_add_impl, SUDO_DEBUG_EVENT)
90:
91: /* If out of space in fd sets, realloc. */
92: if (ev->fd > base->maxfd) {
93: const int o = (base->maxfd + 1) / NFDBITS;
94: const int n = howmany(ev->fd + 1, NFDBITS);
95: base->readfds_in = erecalloc(base->readfds_in, o, n, sizeof(fd_mask));
96: base->writefds_in = erecalloc(base->writefds_in, o, n, sizeof(fd_mask));
97: base->readfds_out = erecalloc(base->readfds_out, o, n, sizeof(fd_mask));
98: base->writefds_out = erecalloc(base->writefds_out, o, n, sizeof(fd_mask));
99: base->maxfd = (n * NFDBITS) - 1;
100: }
101:
102: /* Set events and adjust high fd as needed. */
103: if (ISSET(ev->events, SUDO_EV_READ)) {
104: sudo_debug_printf(SUDO_DEBUG_DEBUG, "%s: added fd %d to readfs",
105: __func__, ev->fd);
106: FD_SET(ev->fd, base->readfds_in);
107: }
108: if (ISSET(ev->events, SUDO_EV_WRITE)) {
109: sudo_debug_printf(SUDO_DEBUG_DEBUG, "%s: added fd %d to writefds",
110: __func__, ev->fd);
111: FD_SET(ev->fd, base->writefds_in);
112: }
113: if (ev->fd > base->highfd)
114: base->highfd = ev->fd;
115:
116: debug_return_int(0);
117: }
118:
119: int
120: sudo_ev_del_impl(struct sudo_event_base *base, struct sudo_event *ev)
121: {
122: debug_decl(sudo_ev_del_impl, SUDO_DEBUG_EVENT)
123:
124: /* Remove from readfds and writefds and adjust high fd. */
125: if (ISSET(ev->events, SUDO_EV_READ)) {
126: sudo_debug_printf(SUDO_DEBUG_DEBUG, "%s: removed fd %d from readfds",
127: __func__, ev->fd);
128: FD_CLR(ev->fd, base->readfds_in);
129: }
130: if (ISSET(ev->events, SUDO_EV_WRITE)) {
131: sudo_debug_printf(SUDO_DEBUG_DEBUG, "%s: removed fd %d from writefds",
132: __func__, ev->fd);
133: FD_CLR(ev->fd, base->writefds_in);
134: }
135: if (base->highfd == ev->fd) {
136: for (;;) {
137: if (FD_ISSET(base->highfd, base->readfds_in) ||
138: FD_ISSET(base->highfd, base->writefds_in))
139: break;
140: if (--base->highfd < 0)
141: break;
142: }
143: }
144:
145: debug_return_int(0);
146: }
147:
148: int
149: sudo_ev_scan_impl(struct sudo_event_base *base, int flags)
150: {
151: struct timeval now, tv, *timeout;
152: struct sudo_event *ev;
153: size_t setsize;
154: int nready;
155: debug_decl(sudo_ev_loop, SUDO_DEBUG_EVENT)
156:
157: if ((ev = TAILQ_FIRST(&base->timeouts)) != NULL) {
158: gettimeofday(&now, NULL);
159: sudo_timevalsub(&ev->timeout, &now, &tv);
160: if (tv.tv_sec < 0 || (tv.tv_sec == 0 && tv.tv_usec < 0))
161: sudo_timevalclear(&tv);
162: timeout = &tv;
163: } else {
164: if (ISSET(flags, SUDO_EVLOOP_NONBLOCK)) {
165: sudo_timevalclear(&tv);
166: timeout = &tv;
167: } else {
168: timeout = NULL;
169: }
170: }
171:
172: /* select() overwrites readfds/writefds so make a copy. */
173: setsize = howmany(base->highfd + 1, NFDBITS) * sizeof(fd_mask);
174: memcpy(base->readfds_out, base->readfds_in, setsize);
175: memcpy(base->writefds_out, base->writefds_in, setsize);
176:
177: sudo_debug_printf(SUDO_DEBUG_DEBUG, "%s: select high fd %d",
178: __func__, base->highfd);
179: nready = select(base->highfd + 1, base->readfds_out, base->writefds_out,
180: NULL, timeout);
181: sudo_debug_printf(SUDO_DEBUG_INFO, "%s: %d fds ready", __func__, nready);
182: switch (nready) {
183: case -1:
184: /* Error or interrupted by signal. */
185: debug_return_int(-1);
186: case 0:
187: /* Front end will activate timeout events. */
188: break;
189: default:
190: /* Activate each I/O event that fired. */
191: TAILQ_FOREACH(ev, &base->events, entries) {
192: if (ev->fd >= 0) {
193: int what = 0;
194: if (FD_ISSET(ev->fd, base->readfds_out))
195: what |= (ev->events & SUDO_EV_READ);
196: if (FD_ISSET(ev->fd, base->writefds_out))
197: what |= (ev->events & SUDO_EV_WRITE);
198: if (what != 0) {
199: /* Make event active. */
200: sudo_debug_printf(SUDO_DEBUG_DEBUG,
201: "%s: selected fd %d, events %d, activating %p",
202: __func__, ev->fd, what, ev);
203: ev->revents = what;
204: TAILQ_INSERT_TAIL(&base->active, ev, active_entries);
205: SET(ev->flags, SUDO_EVQ_ACTIVE);
206: }
207: }
208: }
209: break;
210: }
211: debug_return_int(nready);
212: }
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to event_select.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / sudo / common