bluetooth/btpand/event.c

52 #define		__event_link(ev) \
54 		TAILQ_INSERT_TAIL(&pending, ev, next); \
55 		ev->flags |= EV_PENDING; \
89 	struct event		*ev;
111 		ev = TAILQ_FIRST(&pending);
112 		event_del(ev);
114 		if (ev->flags & EV_HAS_TIMEOUT) {
115 			if (tv_cmp(&now, &ev->expire) >= 0)
118 				t = ev->expire;
126 		if (ev->fd >= 0) {
127 			if (ev->flags & EV_READ) {
128 				FD_SET(ev->fd, &r);
129 				nfd = (nfd > ev->fd) ? nfd : ev->fd;
132 			if (ev->flags & EV_WRITE) {
133 				FD_SET(ev->fd, &w);
134 				nfd = (nfd > ev->fd) ? nfd : ev->fd;
138 		__event_add_current(ev);
156 		ev = TAILQ_FIRST(&current);
157 		__event_del_current(ev);
160 		if (nfd > 0 && ev->fd >= 0) {
161 			if (FD_ISSET(ev->fd, &r) || FD_ISSET(ev->fd, &w)) {
162 				if (ev->flags & EV_PERSIST) {
163 					if (ev->flags & EV_HAS_TIMEOUT)
164 						event_add(ev, &ev->timeout);
166 						event_add(ev, NULL);
172 					"ev=%p", __func__, ev->cb, ev->fd,
173 					ev->cbarg, ev);
175 				(ev->cb)(ev->fd,
176 					(ev->flags & (EV_READ|EV_WRITE)),
177 					ev->cbarg);
184 		if ((ev->flags & EV_HAS_TIMEOUT) == 0) {
185 			event_add(ev, NULL);
190 		if (tv_cmp(&now, &ev->expire) >= 0) {
191 			if (ev->flags & EV_PERSIST)
192 				event_add(ev, &ev->timeout);
194 			event_log_debug("%s: calling %p(%d, %p), ev=%p",
195 				__func__, ev->cb, ev->fd, ev->cbarg, ev);
197 			(ev->cb)(ev->fd,
198 				(ev->flags & (EV_READ|EV_WRITE)),
199 				ev->cbarg);
204 		assert((ev->flags & (EV_PENDING|EV_CURRENT)) == 0);
205 		__event_link(ev);
212 __event_set(struct event *ev, int fd, short flags,
215 	ev->fd = fd;
216 	ev->flags = flags;
217 	ev->cb = cb;
218 	ev->cbarg = cbarg;
222 __event_add(struct event *ev, const struct timeval *timeout)
224 	assert((ev->flags & (EV_PENDING|EV_CURRENT)) == 0);
227 		gettimeofday(&ev->expire, NULL);
228 		tv_add(&ev->expire, timeout);
229 		ev->timeout = *timeout;
230 		ev->flags |= EV_HAS_TIMEOUT;
232 		ev->flags &= ~EV_HAS_TIMEOUT;
234 	__event_link(ev);
240 __event_del(struct event *ev)
242 	assert((ev->flags & EV_CURRENT) == 0);
244 	if ((ev->flags & EV_PENDING) != 0) {
245 		TAILQ_REMOVE(&pending, ev, next);
246 		ev->flags &= ~EV_PENDING;
253 __event_add_current(struct event *ev)
255 	assert((ev->flags & (EV_PENDING|EV_CURRENT)) == 0);
257 	TAILQ_INSERT_TAIL(&current, ev, next);
258 	ev->flags |= EV_CURRENT;
262 __event_del_current(struct event *ev)
264 	assert((ev->flags & (EV_CURRENT|EV_PENDING)) == EV_CURRENT);
266 	TAILQ_REMOVE(&current, ev, next);
267 	ev->flags &= ~EV_CURRENT;