GCOV - Varnish Cache


/*-
 * Copyright (c) 2006 Verdens Gang AS
 * Copyright (c) 2006-2009 Varnish Software AS
 * All rights reserved.
 *
 * Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
 *
 * SPDX-License-Identifier: BSD-2-Clause
 *
 * Redistribution and use in source and binary forms, with or without
 * modification, are permitted provided that the following conditions
 * are met:
 * 1. Redistributions of source code must retain the above copyright
 *    notice, this list of conditions and the following disclaimer.
 * 2. Redistributions in binary form must reproduce the above copyright
 *    notice, this list of conditions and the following disclaimer in the
 *    documentation and/or other materials provided with the distribution.
 *
 * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
 * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
 * ARE DISCLAIMED.  IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
 * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
 * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
 * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
 * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
 * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
 * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
 * SUCH DAMAGE.
 */

#include "config.h"

#include <time.h>
#include <poll.h>
#include <pthread.h>
#include <signal.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#include "vdef.h"
#include "miniobj.h"
#include "vas.h"

#include "vbh.h"
#include "vev.h"
#include "vtim.h"

#undef DEBUG_EVENTS

/* INFTIM indicates an infinite timeout for poll(2) */
#ifndef INFTIM
#define INFTIM -1
#endif

struct vevsig {
        struct vev_root         *vevb;
        struct vev              *vev;
        struct sigaction        sigact;
        unsigned char           happened;
        siginfo_t               siginfo[1];
};

static struct vevsig            *vev_sigs;
static int                      vev_nsig;

struct vev_root {
        unsigned                magic;
#define VEV_BASE_MAGIC          0x477bcf3d
        unsigned                n_fd_events;
        struct pollfd           *pfd;
        struct vev              **pev;
        unsigned                npfd;
        unsigned                lpfd;
        struct vbh              *binheap;
        unsigned                psig;
        pthread_t               thread;
#ifdef DEBUG_EVENTS
        FILE                    *debug;
#endif
};

/*--------------------------------------------------------------------*/

#ifdef DEBUG_EVENTS
#define DBG(evb, ...) do {                              \
        if ((evb)->debug != NULL)                       \
                fprintf((evb)->debug, __VA_ARGS__);     \
        } while (0);
#else
#define DBG(evb, ...)   /* ... */
//#define DBG(evb, ...) fprintf(stderr, __VA_ARGS__);
#endif

/*--------------------------------------------------------------------*/

static void v_matchproto_(vbh_update_t)
vev_bh_update(void *priv, void *a, unsigned u)
{
        struct vev_root *evb;
        struct vev *e;

        CAST_OBJ_NOTNULL(evb, priv, VEV_BASE_MAGIC);
        CAST_OBJ_NOTNULL(e, a, VEV_MAGIC);
        assert(u < evb->lpfd);
        e->__binheap_idx = u;
        if (u != VBH_NOIDX) {
                evb->pev[u] = e;
                evb->pfd[u].fd = e->fd;
                evb->pfd[u].events =
                    e->fd_flags & (VEV__RD|VEV__WR|VEV__ERR|VEV__HUP);
        }
}

static int v_matchproto_(vbh_cmp_t)
vev_bh_cmp(void *priv, const void *a, const void *b)
{
        struct vev_root *evb;
        const struct vev *ea, *eb;

        CAST_OBJ_NOTNULL(evb, priv, VEV_BASE_MAGIC);
        CAST_OBJ_NOTNULL(ea, a, VEV_MAGIC);
        CAST_OBJ_NOTNULL(eb, b, VEV_MAGIC);
        return (ea->__when < eb->__when);
}

/*--------------------------------------------------------------------*/

static int
vev_get_pfd(struct vev_root *evb)
{
        unsigned u;

        if (evb->lpfd + 1 < evb->npfd)
                return (0);

        if (evb->npfd < 8)
                u = 8;
        else if (evb->npfd > 256)
                u = evb->npfd + 256;
        else
                u = evb->npfd * 2;
        evb->npfd = u;
        evb->pfd = realloc(evb->pfd, sizeof(*evb->pfd) * u);
        AN(evb->pfd);
        evb->pev = realloc(evb->pev, sizeof(*evb->pev) * u);
        AN(evb->pev);
        return (0);
}

/*--------------------------------------------------------------------*/

static int
vev_get_sig(int sig)
{
        struct vevsig *os;

        if (sig < vev_nsig)
                return (0);

        os = calloc((sig + 1L), sizeof *os);
        if (os == NULL)
                return (ENOMEM);

        if (vev_sigs != NULL) {
                memcpy(os, vev_sigs, vev_nsig * sizeof *os);
                free(vev_sigs);
        }
        vev_sigs = os;
        vev_nsig = sig + 1;

        return (0);
}

/*--------------------------------------------------------------------*/

static void
vev_sigaction(int sig, siginfo_t *siginfo, void *ctx)
{
        struct vevsig *es;

        (void)ctx;
        assert(sig < vev_nsig);
        assert(vev_sigs != NULL);
        es = &vev_sigs[sig];
        if (!es->happened) {
                es->vevb->psig++;
                memcpy(es->siginfo, siginfo, sizeof *es->siginfo);
                es->vev->siginfo = es->siginfo;
        }
        es->happened = 1;
}

/*--------------------------------------------------------------------*/

struct vev_root *
VEV_New(void)
{
        struct vev_root *evb;

        evb = calloc(1, sizeof *evb);
        if (evb == NULL)
                return (evb);
        evb->lpfd = VBH_NOIDX + 1;
        if (vev_get_pfd(evb)) {
                free(evb);
                return (NULL);
        }
        evb->magic = VEV_BASE_MAGIC;
        evb->binheap = VBH_new(evb, vev_bh_cmp, vev_bh_update);
        evb->thread = pthread_self();
#ifdef DEBUG_EVENTS
        evb->debug = fopen("/tmp/_.events", "w");
        AN(evb->debug);
        setbuf(evb->debug, NULL);
        DBG(evb, "\n\nStart debugging\n");
#endif
        return (evb);
}

/*--------------------------------------------------------------------*/

void
VEV_Destroy(struct vev_root **evbp)
{
        struct vev_root *evb;
        struct vev *e;

        TAKE_OBJ_NOTNULL(evb, evbp, VEV_BASE_MAGIC);
        assert(pthread_equal(evb->thread, pthread_self()));
        while ((e = VBH_root(evb->binheap)) != NULL) {
                VEV_Stop(evb, e);
                free(e);
        }
        VBH_destroy(&evb->binheap);
        free(evb->pfd);
        free(evb->pev);
        FREE_OBJ(evb);
}

/*--------------------------------------------------------------------*/

struct vev *
VEV_Alloc(void)
{
        struct vev *e;

        e = calloc(1, sizeof *e);
        if (e != NULL) {
                e->fd = -1;
        }
        return (e);
}

/*--------------------------------------------------------------------*/

int
VEV_Start(struct vev_root *evb, struct vev *e)
{
        struct vevsig *es;

        CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
        assert(e->magic != VEV_MAGIC);
        assert(e->callback != NULL);
        assert(e->sig >= 0);
        assert(e->timeout >= 0.0);
        assert(e->fd < 0 || e->fd_flags);
        assert(pthread_equal(evb->thread, pthread_self()));
        DBG(evb, "ev_add(%p) fd = %d\n", e, e->fd);

        if (vev_get_pfd(evb))
                return (ENOMEM);

        if (e->sig > 0) {
                if (vev_get_sig(e->sig))
                        return (ENOMEM);

                assert(e->fd < 0);
                es = &vev_sigs[e->sig];
                if (es->vev != NULL)
                        return (EBUSY);
                AZ(es->happened);
                es->vev = e;
                es->vevb = evb;
                es->sigact.sa_flags = e->sig_flags | SA_SIGINFO;
                es->sigact.sa_sigaction = vev_sigaction;
        } else {
                es = NULL;
        }

        e->magic = VEV_MAGIC;   /* before VBH_insert() */

        if (e->timeout != 0.0)
                e->__when += VTIM_mono() + e->timeout;
        else
                e->__when = 9e99;

        evb->lpfd++;
        VBH_insert(evb->binheap, e);
        assert(e->__binheap_idx != VBH_NOIDX);

        e->__vevb = evb;
        e->__privflags = 0;

        if (e->sig > 0) {
                assert(es != NULL);
                AZ(sigaction(e->sig, &es->sigact, NULL));
        }

        return (0);
}

/*--------------------------------------------------------------------*/

void
VEV_Stop(struct vev_root *evb, struct vev *e)
{
        struct vevsig *es;

        CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
        CHECK_OBJ_NOTNULL(e, VEV_MAGIC);
        DBG(evb, "ev_del(%p) fd = %d i=%u L=%d\n", e, e->fd, e->__binheap_idx, evb->lpfd);
        assert(evb == e->__vevb);
        assert(pthread_equal(evb->thread, pthread_self()));
        assert(evb->pev[e->__binheap_idx] == e);

        assert(e->__binheap_idx != VBH_NOIDX);
        e->fd = -1;
        VBH_delete(evb->binheap, e->__binheap_idx);
        assert(e->__binheap_idx == VBH_NOIDX);
        evb->lpfd--;

        if (e->fd_events) {
                assert(evb->n_fd_events > 0);
                evb->n_fd_events--;
                e->fd_events = 0;
        }

        if (e->sig > 0) {
                assert(e->sig < vev_nsig);
                es = &vev_sigs[e->sig];
                assert(es->vev == e);
                es->vev = NULL;
                es->vevb = NULL;
                es->sigact.sa_flags = 0;
                es->sigact.sa_handler = SIG_DFL;
                AZ(sigaction(e->sig, &es->sigact, NULL));
                es->happened = 0;
        }

        e->__vevb = NULL;
        FINI_OBJ(e);
}

/*--------------------------------------------------------------------*/

int
VEV_Loop(struct vev_root *evb)
{
        int i;

        CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
        assert(pthread_equal(evb->thread, pthread_self()));
        do
                i = VEV_Once(evb);
        while (i == 1);
        return (i);
}

/*--------------------------------------------------------------------*/

static int
vev_sched_timeout(struct vev_root *evb, struct vev *e, vtim_mono t)
{
        int i;


        i = e->callback(e, 0);
        if (i) {
                VEV_Stop(evb, e);
                free(e);
        } else {
                e->__when = t + e->timeout;
                VBH_delete(evb->binheap, e->__binheap_idx);
                VBH_insert(evb->binheap, e);
        }
        return (1);
}

static int
vev_sched_signal(struct vev_root *evb)
{
        int i, j, retval = 1;
        struct vevsig *es;
        struct vev *e;

        es = vev_sigs;
        for (j = 0; j < vev_nsig; j++, es++) {
                if (!es->happened || es->vevb != evb)
                        continue;
                evb->psig--;
                es->happened = 0;
                e = es->vev;
                assert(e != NULL);
                i = e->callback(e, VEV__SIG);
                if (e->siginfo != NULL) {
                        e->siginfo = NULL;
                        memset(es->siginfo, 0, sizeof *es->siginfo);
                }
                if (i) {
                        VEV_Stop(evb, e);
                        free(e);
                }
                if (i < 0)
                        retval = i;
        }
        return (retval);
}

int
VEV_Once(struct vev_root *evb)
{
        double t;
        struct vev *e;
        int i, k, tmo, retval = 1;
        unsigned u;
        int progress;

        CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
        assert(pthread_equal(evb->thread, pthread_self()));
        assert(evb->lpfd < evb->npfd);

        if (evb->psig)
                return (vev_sched_signal(evb));

        tmo = INFTIM;
        e = VBH_root(evb->binheap);
        if (e != NULL) {
                CHECK_OBJ(e, VEV_MAGIC);
                assert(e->__binheap_idx == VBH_NOIDX + 1);
                t = VTIM_mono();
                if (e->__when <= t)
                        return (vev_sched_timeout(evb, e, t));
                if (e->__when < 9e99)
                        tmo = (int)((e->__when - t) * 1e3);
                if (tmo == 0)
                        tmo = 1;
        }

        if (tmo == INFTIM && evb->lpfd == VBH_NOIDX + 1)
                return (0);

        i = poll(evb->pfd + 1, evb->lpfd - 1, tmo);
        if (i == -1 && errno == EINTR)
                return (vev_sched_signal(evb));
        if (i == -1)
                return (-1);

        if (i == 0) {
                assert(e != NULL);
                t = VTIM_mono();
                if (e->__when <= t)
                        return (vev_sched_timeout(evb, e, t));
        }

        AZ(evb->n_fd_events);
        for (u = 1; u < evb->lpfd; u++) {
                AZ(evb->pev[u]->fd_events);
                evb->pev[u]->fd_events = evb->pfd[u].revents;
                if (evb->pev[u]->fd_events)
                        evb->n_fd_events++;
        }
        assert(evb->n_fd_events == i);

        DBG(evb, "EVENTS %d\n", i);
        while (evb->n_fd_events > 0) {
                progress = 0;
                for (u = VBH_NOIDX + 1; u < evb->lpfd; u++) {
                        e = evb->pev[u];
                        if (e->fd_events == 0)
                                continue;
                        DBG(evb, "EVENT %p u=%u fd=%d ev=0x%x %d\n",
                            e, u, e->fd, e->fd_events, i);
                        k = e->callback(e, e->fd_events);
                        e->fd_events = 0;
                        assert(evb->n_fd_events > 0);
                        evb->n_fd_events--;
                        progress++;
                        if (k) {
                                VEV_Stop(evb, e);
                                free(e);
                        }
                        if (k < 0)
                                retval = k;
                }
                assert(progress > 0);
        }

        return (retval);
}

		varnish-cache/lib/libvarnish/vev.c
0		/*-
1		* Copyright (c) 2006 Verdens Gang AS
2		* Copyright (c) 2006-2009 Varnish Software AS
3		* All rights reserved.
4		*
5		* Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
6		*
7		* SPDX-License-Identifier: BSD-2-Clause
8		*
9		* Redistribution and use in source and binary forms, with or without
10		* modification, are permitted provided that the following conditions
11		* are met:
12		* 1. Redistributions of source code must retain the above copyright
13		* notice, this list of conditions and the following disclaimer.
14		* 2. Redistributions in binary form must reproduce the above copyright
15		* notice, this list of conditions and the following disclaimer in the
16		* documentation and/or other materials provided with the distribution.
17		*
18		* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
19		* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
20		* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
21		* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
22		* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
23		* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
24		* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
25		* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
26		* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
27		* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
28		* SUCH DAMAGE.
29		*/
30
31		#include "config.h"
32
33		#include <time.h>
34		#include <poll.h>
35		#include <pthread.h>
36		#include <signal.h>
37		#include <stdio.h>
38		#include <stdlib.h>
39		#include <string.h>
40
41		#include "vdef.h"
42		#include "miniobj.h"
43		#include "vas.h"
44
45		#include "vbh.h"
46		#include "vev.h"
47		#include "vtim.h"
48
49		#undef DEBUG_EVENTS
50
51		/* INFTIM indicates an infinite timeout for poll(2) */
52		#ifndef INFTIM
53		#define INFTIM -1
54		#endif
55
56		struct vevsig {
57		struct vev_root *vevb;
58		struct vev *vev;
59		struct sigaction sigact;
60		unsigned char happened;
61		siginfo_t siginfo[1];
62		};
63
64		static struct vevsig *vev_sigs;
65		static int vev_nsig;
66
67		struct vev_root {
68		unsigned magic;
69		#define VEV_BASE_MAGIC 0x477bcf3d
70		unsigned n_fd_events;
71		struct pollfd *pfd;
72		struct vev **pev;
73		unsigned npfd;
74		unsigned lpfd;
75		struct vbh *binheap;
76		unsigned psig;
77		pthread_t thread;
78		#ifdef DEBUG_EVENTS
79		FILE *debug;
80		#endif
81		};
82
83		/--------------------------------------------------------------------/
84
85		#ifdef DEBUG_EVENTS
86		#define DBG(evb, ...) do { \
87		if ((evb)->debug != NULL) \
88		fprintf((evb)->debug, __VA_ARGS__); \
89		} while (0);
90		#else
91		#define DBG(evb, ...) /* ... */
92		//#define DBG(evb, ...) fprintf(stderr, __VA_ARGS__);
93		#endif
94
95		/--------------------------------------------------------------------/
96
97		static void v_matchproto_(vbh_update_t)
98	5038445	vev_bh_update(void priv, void a, unsigned u)
99		{
100		struct vev_root *evb;
101		struct vev *e;
102
103	5038445	CAST_OBJ_NOTNULL(evb, priv, VEV_BASE_MAGIC);
104	5038445	CAST_OBJ_NOTNULL(e, a, VEV_MAGIC);
105	5038445	assert(u < evb->lpfd);
106	5038445	e->__binheap_idx = u;
107	5038445	if (u != VBH_NOIDX) {
108	4251266	evb->pev[u] = e;
109	4251266	evb->pfd[u].fd = e->fd;
110	4251266	evb->pfd[u].events =
111	4251266	e->fd_flags & (VEV__RD\|VEV__WR\|VEV__ERR\|VEV__HUP);
112	4251266	}
113	5038445	}
114
115		static int v_matchproto_(vbh_cmp_t)
116	2898508	vev_bh_cmp(void priv, const void a, const void *b)
117		{
118		struct vev_root *evb;
119		const struct vev ea, eb;
120
121	2898508	CAST_OBJ_NOTNULL(evb, priv, VEV_BASE_MAGIC);
122	2898508	CAST_OBJ_NOTNULL(ea, a, VEV_MAGIC);
123	2898508	CAST_OBJ_NOTNULL(eb, b, VEV_MAGIC);
124	2898508	return (ea->__when < eb->__when);
125		}
126
127		/--------------------------------------------------------------------/
128
129		static int
130	695280	vev_get_pfd(struct vev_root *evb)
131		{
132		unsigned u;
133
134	695280	if (evb->lpfd + 1 < evb->npfd)
135	533240	return (0);
136
137	162040	if (evb->npfd < 8)
138	123800	u = 8;
139	38240	else if (evb->npfd > 256)
140	0	u = evb->npfd + 256;
141		else
142	38240	u = evb->npfd * 2;
143	162040	evb->npfd = u;
144	162040	evb->pfd = realloc(evb->pfd, sizeof(evb->pfd) u);
145	162040	AN(evb->pfd);
146	162040	evb->pev = realloc(evb->pev, sizeof(evb->pev) u);
147	162040	AN(evb->pev);
148	162040	return (0);
149	695280	}
150
151		/--------------------------------------------------------------------/
152
153		static int
154	75920	vev_get_sig(int sig)
155		{
156		struct vevsig *os;
157
158	75920	if (sig < vev_nsig)
159	37960	return (0);
160
161	37960	os = calloc((sig + 1L), sizeof *os);
162	37960	if (os == NULL)
163	0	return (ENOMEM);
164
165	37960	if (vev_sigs != NULL) {
166	0	memcpy(os, vev_sigs, vev_nsig * sizeof *os);
167	0	free(vev_sigs);
168	0	}
169	37960	vev_sigs = os;
170	37960	vev_nsig = sig + 1;
171
172	37960	return (0);
173	75920	}
174
175		/--------------------------------------------------------------------/
176
177		static void
178	200	vev_sigaction(int sig, siginfo_t siginfo, void ctx)
179		{
180		struct vevsig *es;
181
182	200	(void)ctx;
183	200	assert(sig < vev_nsig);
184	200	assert(vev_sigs != NULL);
185	200	es = &vev_sigs[sig];
186	200	if (!es->happened) {
187	200	es->vevb->psig++;
188	200	memcpy(es->siginfo, siginfo, sizeof *es->siginfo);
189	200	es->vev->siginfo = es->siginfo;
190	200	}
191	200	es->happened = 1;
192	200	}
193
194		/--------------------------------------------------------------------/
195
196		struct vev_root *
197	123800	VEV_New(void)
198		{
199		struct vev_root *evb;
200
201	123800	evb = calloc(1, sizeof *evb);
202	123800	if (evb == NULL)
203	0	return (evb);
204	123800	evb->lpfd = VBH_NOIDX + 1;
205	123800	if (vev_get_pfd(evb)) {
206	0	free(evb);
207	0	return (NULL);
208		}
209	123800	evb->magic = VEV_BASE_MAGIC;
210	123800	evb->binheap = VBH_new(evb, vev_bh_cmp, vev_bh_update);
211	123800	evb->thread = pthread_self();
212		#ifdef DEBUG_EVENTS
213		evb->debug = fopen("/tmp/_.events", "w");
214		AN(evb->debug);
215		setbuf(evb->debug, NULL);
216		DBG(evb, "\n\nStart debugging\n");
217		#endif
218	123800	return (evb);
219	123800	}
220
221		/--------------------------------------------------------------------/
222
223		void
224	40720	VEV_Destroy(struct vev_root **evbp)
225		{
226		struct vev_root *evb;
227		struct vev *e;
228
229	40720	TAKE_OBJ_NOTNULL(evb, evbp, VEV_BASE_MAGIC);
230	40720	assert(pthread_equal(evb->thread, pthread_self()));
231	310415	while ((e = VBH_root(evb->binheap)) != NULL) {
232	269695	VEV_Stop(evb, e);
233	269695	free(e);
234		}
235	40720	VBH_destroy(&evb->binheap);
236	40720	free(evb->pfd);
237	40720	free(evb->pev);
238	40720	FREE_OBJ(evb);
239	40720	}
240
241		/--------------------------------------------------------------------/
242
243		struct vev *
244	571480	VEV_Alloc(void)
245		{
246		struct vev *e;
247
248	571480	e = calloc(1, sizeof *e);
249	571480	if (e != NULL) {
250	571480	e->fd = -1;
251	571480	}
252	571480	return (e);
253		}
254
255		/--------------------------------------------------------------------/
256
257		int
258	571480	VEV_Start(struct vev_root evb, struct vev e)
259		{
260		struct vevsig *es;
261
262	571480	CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
263	571480	assert(e->magic != VEV_MAGIC);
264	571480	assert(e->callback != NULL);
265	571480	assert(e->sig >= 0);
266	571480	assert(e->timeout >= 0.0);
267	571480	assert(e->fd < 0 \|\| e->fd_flags);
268	571480	assert(pthread_equal(evb->thread, pthread_self()));
269		DBG(evb, "ev_add(%p) fd = %d\n", e, e->fd);
270
271	571480	if (vev_get_pfd(evb))
272	0	return (ENOMEM);
273
274	571480	if (e->sig > 0) {
275	75920	if (vev_get_sig(e->sig))
276	0	return (ENOMEM);
277
278	75920	assert(e->fd < 0);
279	75920	es = &vev_sigs[e->sig];
280	75920	if (es->vev != NULL)
281	0	return (EBUSY);
282	75920	AZ(es->happened);
283	75920	es->vev = e;
284	75920	es->vevb = evb;
285	75920	es->sigact.sa_flags = e->sig_flags \| SA_SIGINFO;
286	75920	es->sigact.sa_sigaction = vev_sigaction;
287	75920	} else {
288	495560	es = NULL;
289		}
290
291	571480	e->magic = VEV_MAGIC; /* before VBH_insert() */
292
293	571480	if (e->timeout != 0.0)
294	206200	e->__when += VTIM_mono() + e->timeout;
295		else
296	365280	e->__when = 9e99;
297
298	571480	evb->lpfd++;
299	571480	VBH_insert(evb->binheap, e);
300	571480	assert(e->__binheap_idx != VBH_NOIDX);
301
302	571480	e->__vevb = evb;
303	571480	e->__privflags = 0;
304
305	571480	if (e->sig > 0) {
306	75920	assert(es != NULL);
307	75920	AZ(sigaction(e->sig, &es->sigact, NULL));
308	75920	}
309
310	571480	return (0);
311	571480	}
312
313		/--------------------------------------------------------------------/
314
315		void
316	568004	VEV_Stop(struct vev_root evb, struct vev e)
317		{
318		struct vevsig *es;
319
320	568004	CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
321	568004	CHECK_OBJ_NOTNULL(e, VEV_MAGIC);
322		DBG(evb, "ev_del(%p) fd = %d i=%u L=%d\n", e, e->fd, e->__binheap_idx, evb->lpfd);
323	568004	assert(evb == e->__vevb);
324	568004	assert(pthread_equal(evb->thread, pthread_self()));
325	568004	assert(evb->pev[e->__binheap_idx] == e);
326
327	568004	assert(e->__binheap_idx != VBH_NOIDX);
328	568004	e->fd = -1;
329	568004	VBH_delete(evb->binheap, e->__binheap_idx);
330	568004	assert(e->__binheap_idx == VBH_NOIDX);
331	568004	evb->lpfd--;
332
333	568004	if (e->fd_events) {
334	0	assert(evb->n_fd_events > 0);
335	0	evb->n_fd_events--;
336	0	e->fd_events = 0;
337	0	}
338
339	568004	if (e->sig > 0) {
340	75920	assert(e->sig < vev_nsig);
341	75920	es = &vev_sigs[e->sig];
342	75920	assert(es->vev == e);
343	75920	es->vev = NULL;
344	75920	es->vevb = NULL;
345	75920	es->sigact.sa_flags = 0;
346	75920	es->sigact.sa_handler = SIG_DFL;
347	75920	AZ(sigaction(e->sig, &es->sigact, NULL));
348	75920	es->happened = 0;
349	75920	}
350
351	568004	e->__vevb = NULL;
352	568004	FINI_OBJ(e);
353	568004	}
354
355		/--------------------------------------------------------------------/
356
357		int
358	37960	VEV_Loop(struct vev_root *evb)
359		{
360		int i;
361
362	37960	CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
363	37960	assert(pthread_equal(evb->thread, pthread_self()));
364	37960	do
365	1389516	i = VEV_Once(evb);
366	1389516	while (i == 1);
367	37960	return (i);
368		}
369
370		/--------------------------------------------------------------------/
371
372		static int
373	219175	vev_sched_timeout(struct vev_root evb, struct vev e, vtim_mono t)
374		{
375		int i;
376
377
378	219175	i = e->callback(e, 0);
379	219175	if (i) {
380	0	VEV_Stop(evb, e);
381	0	free(e);
382	0	} else {
383	219175	e->__when = t + e->timeout;
384	219175	VBH_delete(evb->binheap, e->__binheap_idx);
385	219175	VBH_insert(evb->binheap, e);
386		}
387	219175	return (1);
388		}
389
390		static int
391	160	vev_sched_signal(struct vev_root *evb)
392		{
393	160	int i, j, retval = 1;
394		struct vevsig *es;
395		struct vev *e;
396
397	160	es = vev_sigs;
398	2720	for (j = 0; j < vev_nsig; j++, es++) {
399	2560	if (!es->happened \|\| es->vevb != evb)
400	2400	continue;
401	160	evb->psig--;
402	160	es->happened = 0;
403	160	e = es->vev;
404	160	assert(e != NULL);
405	160	i = e->callback(e, VEV__SIG);
406	160	if (e->siginfo != NULL) {
407	160	e->siginfo = NULL;
408	160	memset(es->siginfo, 0, sizeof *es->siginfo);
409	160	}
410	160	if (i) {
411	160	VEV_Stop(evb, e);
412	160	free(e);
413	160	}
414	160	if (i < 0)
415	160	retval = i;
416	160	}
417	160	return (retval);
418		}
419
420		int
421	1655734	VEV_Once(struct vev_root *evb)
422		{
423		double t;
424		struct vev *e;
425	1655734	int i, k, tmo, retval = 1;
426		unsigned u;
427		int progress;
428
429	1655734	CHECK_OBJ_NOTNULL(evb, VEV_BASE_MAGIC);
430	1655734	assert(pthread_equal(evb->thread, pthread_self()));
431	1655734	assert(evb->lpfd < evb->npfd);
432
433	1655734	if (evb->psig)
434	0	return (vev_sched_signal(evb));
435
436	1655734	tmo = INFTIM;
437	1655734	e = VBH_root(evb->binheap);
438	1655734	if (e != NULL) {
439	1613734	CHECK_OBJ(e, VEV_MAGIC);
440	1613734	assert(e->__binheap_idx == VBH_NOIDX + 1);
441	1613734	t = VTIM_mono();
442	1613734	if (e->__when <= t)
443	53648	return (vev_sched_timeout(evb, e, t));
444	1560086	if (e->__when < 9e99)
445	1388448	tmo = (int)((e->__when - t) * 1e3);
446	1560086	if (tmo == 0)
447	8870	tmo = 1;
448	1560086	}
449
450	1602086	if (tmo == INFTIM && evb->lpfd == VBH_NOIDX + 1)
451	42200	return (0);
452
453	1559886	i = poll(evb->pfd + 1, evb->lpfd - 1, tmo);
454	1559886	if (i == -1 && errno == EINTR)
455	160	return (vev_sched_signal(evb));
456	1559726	if (i == -1)
457	0	return (-1);
458
459	1559726	if (i == 0) {
460	173009	assert(e != NULL);
461	173009	t = VTIM_mono();
462	173009	if (e->__when <= t)
463	165527	return (vev_sched_timeout(evb, e, t));
464	7482	}
465
466	1394199	AZ(evb->n_fd_events);
467	13465750	for (u = 1; u < evb->lpfd; u++) {
468	12071551	AZ(evb->pev[u]->fd_events);
469	12071551	evb->pev[u]->fd_events = evb->pfd[u].revents;
470	12071551	if (evb->pev[u]->fd_events)
471	1423409	evb->n_fd_events++;
472	12071551	}
473	1394199	assert(evb->n_fd_events == i);
474
475		DBG(evb, "EVENTS %d\n", i);
476	2784281	while (evb->n_fd_events > 0) {
477	1390082	progress = 0;
478	13345737	for (u = VBH_NOIDX + 1; u < evb->lpfd; u++) {
479	11955655	e = evb->pev[u];
480	11955655	if (e->fd_events == 0)
481	10532445	continue;
482		DBG(evb, "EVENT %p u=%u fd=%d ev=0x%x %d\n",
483		e, u, e->fd, e->fd_events, i);
484	1423210	k = e->callback(e, e->fd_events);
485	1423210	e->fd_events = 0;
486	1423210	assert(evb->n_fd_events > 0);
487	1423210	evb->n_fd_events--;
488	1423210	progress++;
489	1423210	if (k) {
490	169607	VEV_Stop(evb, e);
491	169607	free(e);
492	169607	}
493	1423210	if (k < 0)
494	37800	retval = k;
495	1423210	}
496	1390082	assert(progress > 0);
497		}
498
499	1394199	return (retval);