GCOV - Varnish Cache


/*-
 * Copyright (c) 2008-2011 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.
 *
 * The geniuses who came up with pthreads did not think operations like
 * pthread_assert_mutex_held() were important enough to include them in
 * the API.
 *
 * Build our own locks on top of pthread mutexes and hope that the next
 * civilization is better at such crucial details than this one.
 */

#include "config.h"

#include "cache_varnishd.h"

#include <stdlib.h>
#include <stdio.h>

#include "vtim.h"

#include "VSC_lck.h"

struct ilck {
        unsigned                magic;
#define ILCK_MAGIC              0x7b86c8a5
        int                     held;
        pthread_mutex_t         mtx;
        pthread_t               owner;
        const char              *w;
        struct VSC_lck          *stat;
};

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

static void
Lck_Witness_Lock(const struct ilck *il, const char *p, int l,
    const char *attempt)
{
        char *q, t[10]; //lint -e429
        int emit;

        AN(p);
        q = pthread_getspecific(witness_key);
        if (q == NULL) {
                q = calloc(1, 1024);
                AN(q);
                PTOK(pthread_setspecific(witness_key, q));
        }
        emit = *q != '\0';
        strcat(q, " ");
        strcat(q, il->w);
        strcat(q, attempt);
        strcat(q, ",");
        strcat(q, p);
        strcat(q, ",");
        bprintf(t, "%d", l);
        strcat(q, t);
        if (emit)
                VSL(SLT_Witness, NO_VXID, "%s", q);
}

static void
Lck_Witness_Unlock(const struct ilck *il)
{
        char *q, *r;

        q = pthread_getspecific(witness_key);
        if (q == NULL)
                return;
        r = strrchr(q, ' ');
        if (r == NULL)
                r = q;
        else
                *r++ = '\0';
        if (memcmp(r, il->w, strlen(il->w)))
                VSL(SLT_Witness, NO_VXID, "Unlock %s @ %s <%s>", il->w, r, q);
        else
                *r = '\0';
}

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

void v_matchproto_()
Lck__Lock(struct lock *lck, const char *p, int l)
{
        struct ilck *ilck;
        int r = EINVAL;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        if (DO_DEBUG(DBG_WITNESS))
                Lck_Witness_Lock(ilck, p, l, "");
        if (DO_DEBUG(DBG_LCK)) {
                r = pthread_mutex_trylock(&ilck->mtx);
                assert(r == 0 || r == EBUSY);
        }
        if (r)
                PTOK(pthread_mutex_lock(&ilck->mtx));
        AZ(ilck->held);
        if (r == EBUSY)
                ilck->stat->dbg_busy++;
        ilck->stat->locks++;
        ilck->owner = pthread_self();
        ilck->held = 1;
}

void v_matchproto_()
Lck__Unlock(struct lock *lck, const char *p, int l)
{
        struct ilck *ilck;

        (void)p;
        (void)l;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        assert(pthread_equal(ilck->owner, pthread_self()));
        AN(ilck->held);
        ilck->held = 0;
        /*
         * #ifdef POSIX_STUPIDITY:
         * The pthread_t type has no defined assignment or comparison
         * operators, this is why pthread_equal() is necessary.
         * Unfortunately POSIX forgot to define a NULL value for pthread_t
         * so you can never unset a pthread_t variable.
         * We hack it and fill it with zero bits, hoping for sane
         * implementations of pthread.
         * #endif
         */
#ifdef PTHREAD_NULL
        ilck->owner = PTHREAD_NULL;
#else
        memset(&ilck->owner, 0, sizeof ilck->owner);
#endif
        PTOK(pthread_mutex_unlock(&ilck->mtx));
        if (DO_DEBUG(DBG_WITNESS))
                Lck_Witness_Unlock(ilck);
}

int v_matchproto_()
Lck__Trylock(struct lock *lck, const char *p, int l)
{
        struct ilck *ilck;
        int r;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        if (DO_DEBUG(DBG_WITNESS))
                Lck_Witness_Lock(ilck, p, l, "?");
        r = pthread_mutex_trylock(&ilck->mtx);
        assert(r == 0 || r == EBUSY);
        if (r == 0) {
                AZ(ilck->held);
                ilck->held = 1;
                ilck->stat->locks++;
                ilck->owner = pthread_self();
        } else if (DO_DEBUG(DBG_LCK))
                ilck->stat->dbg_try_fail++;
        return (r);
}

int
Lck__Held(const struct lock *lck)
{
        struct ilck *ilck;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        return (ilck->held);
}

int
Lck__Owned(const struct lock *lck)
{
        struct ilck *ilck;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        AN(ilck->held);
        return (pthread_equal(ilck->owner, pthread_self()));
}

int v_matchproto_()
Lck_CondWait(pthread_cond_t *cond, struct lock *lck)
{
       return (Lck_CondWaitUntil(cond, lck, INFINITY));
}

int v_matchproto_()
Lck_CondWaitTimeout(pthread_cond_t *cond, struct lock *lck, vtim_dur timeout)
{

        if (isinf(timeout))
                return (Lck_CondWaitUntil(cond, lck, INFINITY));

        assert(timeout >= 0);
        assert(timeout <= 3600);
        timeout = vmax(timeout, 1e-3);
        return (Lck_CondWaitUntil(cond, lck, VTIM_real() + timeout));
}

int v_matchproto_()
Lck_CondWaitUntil(pthread_cond_t *cond, struct lock *lck, vtim_real when)
{
        struct ilck *ilck;
        struct timespec ts;

        AN(lck);
        CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
        AN(ilck->held);
        assert(pthread_equal(ilck->owner, pthread_self()));
        ilck->held = 0;
        if (isinf(when)) {
                errno = pthread_cond_wait(cond, &ilck->mtx);
                AZ(errno);
        } else {
                assert(when > 1e9);
                ts = VTIM_timespec(when);
                assert(ts.tv_nsec >= 0 && ts.tv_nsec <= 999999999);
                errno = pthread_cond_timedwait(cond, &ilck->mtx, &ts);
#if defined (__APPLE__)
                /*
                 * I hate woo-doo programming in all it's forms and all it's
                 * manifestations, but for reasons I utterly fail to isolate,
                 * OSX sometimes throws an EINVAL.
                 *
                 * I have tried very hard to determine if any of the three
                 * arguments are in fact invalid, and found nothing which
                 * even hints that it might be the case.
                 *
                 * So far I have yet to see a failure if the exact same
                 * call is repeated after a very short sleep.
                 *
                 * Calling pthread_yield_np() instead of sleeping /mostly/
                 * works as well, but still fails sometimes.
                 *
                 * Env:
                 *      Darwin Kernel Version 20.5.0:
                 *      Sat May  8 05:10:31 PDT 2021;
                 *      root:xnu-7195.121.3~9/RELEASE_ARM64_T8101 arm64
                 *
                 * 20220329 /phk
                 */
                if (errno == EINVAL) {
                        usleep(100);
                        errno = pthread_cond_timedwait(cond, &ilck->mtx, &ts);
                }
#endif
                /* We should never observe EINTR, but we have in the past. For
                 * example when sanitizers are enabled.
                 */
                assert(errno == 0 ||
                    errno == ETIMEDOUT ||
                    errno == EINTR);
        }
        AZ(ilck->held);
        ilck->held = 1;
        ilck->owner = pthread_self();
        return (errno);
}

void
Lck__New(struct lock *lck, struct VSC_lck *st, const char *w)
{
        struct ilck *ilck;

        AN(st);
        AN(w);
        AN(lck);
        AZ(lck->priv);
        ALLOC_OBJ(ilck, ILCK_MAGIC);
        AN(ilck);
        ilck->w = w;
        ilck->stat = st;
        ilck->stat->creat++;
        PTOK(pthread_mutex_init(&ilck->mtx, &mtxattr_errorcheck));
        lck->priv = ilck;
}

void
Lck_Delete(struct lock *lck)
{
        struct ilck *ilck;

        AN(lck);
        TAKE_OBJ_NOTNULL(ilck, &lck->priv, ILCK_MAGIC);
        ilck->stat->destroy++;
        PTOK(pthread_mutex_destroy(&ilck->mtx));
        FREE_OBJ(ilck);
}

struct VSC_lck *
Lck_CreateClass(struct vsc_seg **sg, const char *name)
{
        return (VSC_lck_New(NULL, sg, name));
}

void
Lck_DestroyClass(struct vsc_seg **sg)
{
        VSC_lck_Destroy(sg);
}

#define LOCK(nam) struct VSC_lck *lck_##nam;
#include "tbl/locks.h"

void
LCK_Init(void)
{

#define LOCK(nam)       lck_##nam = Lck_CreateClass(NULL, #nam);
#include "tbl/locks.h"
}

		varnish-cache/bin/varnishd/cache/cache_lck.c
0		/*-
1		* Copyright (c) 2008-2011 Varnish Software AS
2		* All rights reserved.
3		*
4		* Author: Poul-Henning Kamp <phk@phk.freebsd.dk>
5		*
6		* SPDX-License-Identifier: BSD-2-Clause
7		*
8		* Redistribution and use in source and binary forms, with or without
9		* modification, are permitted provided that the following conditions
10		* are met:
11		* 1. Redistributions of source code must retain the above copyright
12		* notice, this list of conditions and the following disclaimer.
13		* 2. Redistributions in binary form must reproduce the above copyright
14		* notice, this list of conditions and the following disclaimer in the
15		* documentation and/or other materials provided with the distribution.
16		*
17		* THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
18		* ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
19		* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
20		* ARE DISCLAIMED. IN NO EVENT SHALL AUTHOR OR CONTRIBUTORS BE LIABLE
21		* FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
22		* DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
23		* OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
24		* HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
25		* LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
26		* OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
27		* SUCH DAMAGE.
28		*
29		* The geniuses who came up with pthreads did not think operations like
30		* pthread_assert_mutex_held() were important enough to include them in
31		* the API.
32		*
33		* Build our own locks on top of pthread mutexes and hope that the next
34		* civilization is better at such crucial details than this one.
35		*/
36
37		#include "config.h"
38
39		#include "cache_varnishd.h"
40
41		#include <stdlib.h>
42		#include <stdio.h>
43
44		#include "vtim.h"
45
46		#include "VSC_lck.h"
47
48		struct ilck {
49		unsigned magic;
50		#define ILCK_MAGIC 0x7b86c8a5
51		int held;
52		pthread_mutex_t mtx;
53		pthread_t owner;
54		const char *w;
55		struct VSC_lck *stat;
56		};
57
58		/--------------------------------------------------------------------/
59
60		static void
61	8177	Lck_Witness_Lock(const struct ilck il, const char p, int l,
62		const char *attempt)
63		{
64		char *q, t[10]; //lint -e429
65		int emit;
66
67	8177	AN(p);
68	8177	q = pthread_getspecific(witness_key);
69	8177	if (q == NULL) {
70	1011	q = calloc(1, 1024);
71	1011	AN(q);
72	1011	PTOK(pthread_setspecific(witness_key, q));
73	1011	}
74	8177	emit = *q != '\0';
75	8177	strcat(q, " ");
76	8177	strcat(q, il->w);
77	8177	strcat(q, attempt);
78	8177	strcat(q, ",");
79	8177	strcat(q, p);
80	8177	strcat(q, ",");
81	8177	bprintf(t, "%d", l);
82	8177	strcat(q, t);
83	8177	if (emit)
84	720	VSL(SLT_Witness, NO_VXID, "%s", q);
85	8177	}
86
87		static void
88	8320	Lck_Witness_Unlock(const struct ilck *il)
89		{
90		char q, r;
91
92	8320	q = pthread_getspecific(witness_key);
93	8320	if (q == NULL)
94	531	return;
95	7789	r = strrchr(q, ' ');
96	7789	if (r == NULL)
97	0	r = q;
98		else
99	7789	*r++ = '\0';
100	7789	if (memcmp(r, il->w, strlen(il->w)))
101	0	VSL(SLT_Witness, NO_VXID, "Unlock %s @ %s <%s>", il->w, r, q);
102		else
103	7789	*r = '\0';
104	8320	}
105
106		/--------------------------------------------------------------------/
107
108		void v_matchproto_()
109	12256688	Lck__Lock(struct lock lck, const char p, int l)
110		{
111		struct ilck *ilck;
112	12256688	int r = EINVAL;
113
114	12256688	AN(lck);
115	12256688	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
116	12256688	if (DO_DEBUG(DBG_WITNESS))
117	7977	Lck_Witness_Lock(ilck, p, l, "");
118	12256688	if (DO_DEBUG(DBG_LCK)) {
119	0	r = pthread_mutex_trylock(&ilck->mtx);
120	0	assert(r == 0 \|\| r == EBUSY);
121	0	}
122	12256688	if (r)
123	12256520	PTOK(pthread_mutex_lock(&ilck->mtx));
124	12256688	AZ(ilck->held);
125	12256418	if (r == EBUSY)
126	0	ilck->stat->dbg_busy++;
127	12256418	ilck->stat->locks++;
128	12256418	ilck->owner = pthread_self();
129	12256418	ilck->held = 1;
130	12256418	}
131
132		void v_matchproto_()
133	13417003	Lck__Unlock(struct lock lck, const char p, int l)
134		{
135		struct ilck *ilck;
136
137	13417003	(void)p;
138	13417003	(void)l;
139
140	13417003	AN(lck);
141	13417003	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
142	13417003	assert(pthread_equal(ilck->owner, pthread_self()));
143	13417003	AN(ilck->held);
144	13417003	ilck->held = 0;
145		/*
146		* #ifdef POSIX_STUPIDITY:
147		* The pthread_t type has no defined assignment or comparison
148		* operators, this is why pthread_equal() is necessary.
149		* Unfortunately POSIX forgot to define a NULL value for pthread_t
150		* so you can never unset a pthread_t variable.
151		* We hack it and fill it with zero bits, hoping for sane
152		* implementations of pthread.
153		* #endif
154		*/
155		#ifdef PTHREAD_NULL
156		ilck->owner = PTHREAD_NULL;
157		#else
158	13417003	memset(&ilck->owner, 0, sizeof ilck->owner);
159		#endif
160	13417003	PTOK(pthread_mutex_unlock(&ilck->mtx));
161	13417003	if (DO_DEBUG(DBG_WITNESS))
162	8315	Lck_Witness_Unlock(ilck);
163	13417003	}
164
165		int v_matchproto_()
166	1939989	Lck__Trylock(struct lock lck, const char p, int l)
167		{
168		struct ilck *ilck;
169		int r;
170
171	1939989	AN(lck);
172	1939989	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
173	1939989	if (DO_DEBUG(DBG_WITNESS))
174	200	Lck_Witness_Lock(ilck, p, l, "?");
175	1939989	r = pthread_mutex_trylock(&ilck->mtx);
176	1939989	assert(r == 0 \|\| r == EBUSY);
177	1939989	if (r == 0) {
178	1939983	AZ(ilck->held);
179	1939983	ilck->held = 1;
180	1939983	ilck->stat->locks++;
181	1939983	ilck->owner = pthread_self();
182	1939989	} else if (DO_DEBUG(DBG_LCK))
183	0	ilck->stat->dbg_try_fail++;
184	1939989	return (r);
185		}
186
187		int
188	2497974	Lck__Held(const struct lock *lck)
189		{
190		struct ilck *ilck;
191
192	2497974	AN(lck);
193	2497974	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
194	2497974	return (ilck->held);
195		}
196
197		int
198	2498010	Lck__Owned(const struct lock *lck)
199		{
200		struct ilck *ilck;
201
202	2498010	AN(lck);
203	2498010	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
204	2498010	AN(ilck->held);
205	2498010	return (pthread_equal(ilck->owner, pthread_self()));
206		}
207
208		int v_matchproto_()
209	1261059	Lck_CondWait(pthread_cond_t cond, struct lock lck)
210		{
211	1261059	return (Lck_CondWaitUntil(cond, lck, INFINITY));
212		}
213
214		int v_matchproto_()
215	298154	Lck_CondWaitTimeout(pthread_cond_t cond, struct lock lck, vtim_dur timeout)
216		{
217
218	298154	if (isinf(timeout))
219	0	return (Lck_CondWaitUntil(cond, lck, INFINITY));
220
221	298154	assert(timeout >= 0);
222	298154	assert(timeout <= 3600);
223	298154	timeout = vmax(timeout, 1e-3);
224	298154	return (Lck_CondWaitUntil(cond, lck, VTIM_real() + timeout));
225	298154	}
226
227		int v_matchproto_()
228	1908555	Lck_CondWaitUntil(pthread_cond_t cond, struct lock lck, vtim_real when)
229		{
230		struct ilck *ilck;
231		struct timespec ts;
232
233	1908555	AN(lck);
234	1908555	CAST_OBJ_NOTNULL(ilck, lck->priv, ILCK_MAGIC);
235	1908555	AN(ilck->held);
236	1908555	assert(pthread_equal(ilck->owner, pthread_self()));
237	1908555	ilck->held = 0;
238	1908555	if (isinf(when)) {
239	1491145	errno = pthread_cond_wait(cond, &ilck->mtx);
240	1491145	AZ(errno);
241	1491145	} else {
242	417410	assert(when > 1e9);
243	417410	ts = VTIM_timespec(when);
244	417410	assert(ts.tv_nsec >= 0 && ts.tv_nsec <= 999999999);
245	417410	errno = pthread_cond_timedwait(cond, &ilck->mtx, &ts);
246		#if defined (__APPLE__)
247		/*
248		* I hate woo-doo programming in all it's forms and all it's
249		* manifestations, but for reasons I utterly fail to isolate,
250		* OSX sometimes throws an EINVAL.
251		*
252		* I have tried very hard to determine if any of the three
253		* arguments are in fact invalid, and found nothing which
254		* even hints that it might be the case.
255		*
256		* So far I have yet to see a failure if the exact same
257		* call is repeated after a very short sleep.
258		*
259		* Calling pthread_yield_np() instead of sleeping /mostly/
260		* works as well, but still fails sometimes.
261		*
262		* Env:
263		* Darwin Kernel Version 20.5.0:
264		* Sat May 8 05:10:31 PDT 2021;
265		* root:xnu-7195.121.3~9/RELEASE_ARM64_T8101 arm64
266		*
267		* 20220329 /phk
268		*/
269		if (errno == EINVAL) {
270		usleep(100);
271		errno = pthread_cond_timedwait(cond, &ilck->mtx, &ts);
272		}
273		#endif
274		/* We should never observe EINTR, but we have in the past. For
275		* example when sanitizers are enabled.
276		*/
277	417410	assert(errno == 0 \|\|
278		errno == ETIMEDOUT \|\|
279		errno == EINTR);
280		}
281	1908555	AZ(ilck->held);
282	1908555	ilck->held = 1;
283	1908555	ilck->owner = pthread_self();
284	1908555	return (errno);
285		}
286
287		void
288	1364057	Lck__New(struct lock lck, struct VSC_lck st, const char *w)
289		{
290		struct ilck *ilck;
291
292	1364057	AN(st);
293	1364057	AN(w);
294	1364057	AN(lck);
295	1364057	AZ(lck->priv);
296	1364057	ALLOC_OBJ(ilck, ILCK_MAGIC);
297	1364057	AN(ilck);
298	1364057	ilck->w = w;
299	1364057	ilck->stat = st;
300	1364057	ilck->stat->creat++;
301	1364057	PTOK(pthread_mutex_init(&ilck->mtx, &mtxattr_errorcheck));
302	1364057	lck->priv = ilck;
303	1364057	}
304
305		void
306	215563	Lck_Delete(struct lock *lck)
307		{
308		struct ilck *ilck;
309
310	215563	AN(lck);
311	215563	TAKE_OBJ_NOTNULL(ilck, &lck->priv, ILCK_MAGIC);
312	215563	ilck->stat->destroy++;
313	215563	PTOK(pthread_mutex_destroy(&ilck->mtx));
314	215563	FREE_OBJ(ilck);
315	215563	}
316
317		struct VSC_lck *
318	807171	Lck_CreateClass(struct vsc_seg *sg, const char name)
319		{
320	807171	return (VSC_lck_New(NULL, sg, name));
321		}
322
323		void
324	0	Lck_DestroyClass(struct vsc_seg **sg)
325		{
326	0	VSC_lck_Destroy(sg);
327	0	}
328
329		#define LOCK(nam) struct VSC_lck *lck_##nam;
330		#include "tbl/locks.h"
331
332		void
333	36630	LCK_Init(void)
334		{
335
336		#define LOCK(nam) lck_##nam = Lck_CreateClass(NULL, #nam);
337		#include "tbl/locks.h"
338		}