varnish-cache/bin/varnishd/cache/cache_mempool.c
0
/*-
1
 * Copyright (c) 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
 * Generic memory pool
30
 */
31
32
#include "config.h"
33
34
#include "cache_varnishd.h"
35
36
#include <stdio.h>
37
#include <stdlib.h>
38
39
#include "vtim.h"
40
41
#include "VSC_mempool.h"
42
43
struct memitem {
44
        unsigned                        magic;
45
#define MEMITEM_MAGIC                   0x42e55401
46
        unsigned                        size;
47
        VTAILQ_ENTRY(memitem)           list;
48
        vtim_real                       touched;        // XXX -> mono?
49
};
50
51
VTAILQ_HEAD(memhead_s, memitem);
52
53
struct mempool {
54
        unsigned                        magic;
55
#define MEMPOOL_MAGIC                   0x37a75a8d
56
        char                            name[12];
57
        struct memhead_s                list;
58
        struct memhead_s                surplus;
59
        struct lock                     mtx;
60
        volatile struct poolparam       *param;
61
        volatile unsigned               *cur_size;
62
        uint64_t                        live;
63
        struct vsc_seg                  *vsc_seg;
64
        struct VSC_mempool              *vsc;
65
        unsigned                        n_pool;
66
        pthread_t                       thread;
67
        vtim_real                       t_now;  // XXX -> mono?
68
        int                             self_destruct;
69
};
70
71
/*---------------------------------------------------------------------
72
 */
73
74
static struct memitem *
75 230964
mpl_alloc(const struct mempool *mpl)
76
{
77
        unsigned tsz;
78
        struct memitem *mi;
79
80 230964
        CHECK_OBJ_NOTNULL(mpl, MEMPOOL_MAGIC);
81 230964
        tsz = *mpl->cur_size;
82 230964
        mi = calloc(1, tsz);
83 230964
        AN(mi);
84 230964
        mi->magic = MEMITEM_MAGIC;
85 230964
        mi->size = tsz;
86 230964
        mpl->vsc->sz_wanted = tsz;
87 230964
        mpl->vsc->sz_actual = tsz - sizeof *mi;
88 230964
        return (mi);
89
}
90
91
/*---------------------------------------------------------------------
92
 * Pool-guard
93
 *   Attempt to keep number of free items in pool inside bounds with
94
 *   minimum locking activity, and keep an eye on items at the tail
95
 *   of the list not getting too old.
96
 */
97
98
static void *
99 32
mpl_guard(void *priv)
100
{
101
        struct mempool *mpl;
102 32
        struct memitem *mi = NULL;
103
        vtim_dur v_statevariable_(mpl_slp);
104 32
        vtim_real last = 0;
105
106 32
        CAST_OBJ_NOTNULL(mpl, priv, MEMPOOL_MAGIC);
107 32
        THR_SetName(mpl->name);
108 32
        THR_Init();
109 32
        mpl_slp = 0.15; // random
110 243126
        while (1) {
111 283670
                VTIM_sleep(mpl_slp);
112 283670
                mpl_slp = 0.814;        // random
113 283670
                mpl->t_now = VTIM_real();
114
115 283670
                if (mi != NULL && (mpl->n_pool > mpl->param->max_pool ||
116 3
                    mi->size < *mpl->cur_size)) {
117 0
                        CHECK_OBJ(mi, MEMITEM_MAGIC);
118 0
                        FREE_OBJ(mi);
119 0
                }
120
121 283622
                if (mi == NULL && mpl->n_pool < mpl->param->min_pool)
122 228503
                        mi = mpl_alloc(mpl);
123
124 283622
                if (mpl->n_pool < mpl->param->min_pool && mi != NULL) {
125
                        /* can do */
126 283622
                } else if (mpl->n_pool > mpl->param->max_pool && mi == NULL) {
127
                        /* can do */
128 52423
                } else if (!VTAILQ_EMPTY(&mpl->surplus)) {
129
                        /* can do */
130 52308
                } else if (last + .1 * mpl->param->max_age < mpl->t_now) {
131
                        /* should do */
132 52303
                } else if (mpl->self_destruct) {
133
                        /* can do */
134 0
                } else {
135 40250
                        continue;       /* nothing to do */
136
                }
137
138 243372
                mpl_slp = 0.314;        // random
139
140 243372
                if (Lck_Trylock(&mpl->mtx))
141 294
                        continue;
142
143 243078
                if (mpl->self_destruct) {
144 20
                        AZ(mpl->live);
145 220
                        while (1) {
146 220
                                if (mi == NULL) {
147 218
                                        mi = VTAILQ_FIRST(&mpl->list);
148 218
                                        if (mi != NULL) {
149 199
                                                mpl->vsc->pool = --mpl->n_pool;
150 199
                                                VTAILQ_REMOVE(&mpl->list,
151
                                                    mi, list);
152 199
                                        }
153 218
                                }
154 220
                                if (mi == NULL) {
155 20
                                        mi = VTAILQ_FIRST(&mpl->surplus);
156 20
                                        if (mi != NULL)
157 0
                                                VTAILQ_REMOVE(&mpl->surplus,
158
                                                    mi, list);
159 20
                                }
160 220
                                if (mi == NULL)
161 20
                                        break;
162 200
                                CHECK_OBJ(mi, MEMITEM_MAGIC);
163 200
                                FREE_OBJ(mi);
164
                        }
165 20
                        VSC_mempool_Destroy(&mpl->vsc_seg);
166 20
                        Lck_Unlock(&mpl->mtx);
167 20
                        Lck_Delete(&mpl->mtx);
168 20
                        FREE_OBJ(mpl);
169 20
                        break;
170
                }
171
172 474065
                if (mpl->n_pool < mpl->param->min_pool &&
173 231079
                    mi != NULL && mi->size >= *mpl->cur_size) {
174 231023
                        CHECK_OBJ(mi, MEMITEM_MAGIC);
175 231023
                        mpl->vsc->pool = ++mpl->n_pool;
176 231023
                        mi->touched = mpl->t_now;
177 231023
                        VTAILQ_INSERT_HEAD(&mpl->list, mi, list);
178 231023
                        mi = NULL;
179 231023
                        mpl_slp = .01;  // random
180
181 231023
                }
182 243094
                if (mpl->n_pool > mpl->param->max_pool && mi == NULL) {
183 115
                        mi = VTAILQ_FIRST(&mpl->list);
184 115
                        CHECK_OBJ_NOTNULL(mi, MEMITEM_MAGIC);
185 115
                        mpl->vsc->pool = --mpl->n_pool;
186 115
                        mpl->vsc->surplus++;
187 115
                        VTAILQ_REMOVE(&mpl->list, mi, list);
188 115
                        mpl_slp = .01;  // random
189 115
                }
190 243094
                if (mi == NULL) {
191 243007
                        mi = VTAILQ_FIRST(&mpl->surplus);
192 243007
                        if (mi != NULL) {
193 5
                                CHECK_OBJ(mi, MEMITEM_MAGIC);
194 5
                                VTAILQ_REMOVE(&mpl->surplus, mi, list);
195 5
                                mpl_slp = .01;  // random
196 5
                        }
197 243007
                }
198 243094
                if (mi == NULL && mpl->n_pool > mpl->param->min_pool) {
199 1874
                        mi = VTAILQ_LAST(&mpl->list, memhead_s);
200 1874
                        CHECK_OBJ_NOTNULL(mi, MEMITEM_MAGIC);
201 1874
                        if (mi->touched + mpl->param->max_age < mpl->t_now) {
202 762
                                mpl->vsc->pool = --mpl->n_pool;
203 762
                                mpl->vsc->timeout++;
204 762
                                VTAILQ_REMOVE(&mpl->list, mi, list);
205 762
                                mpl_slp = .01;  // random
206 762
                        } else {
207 1112
                                mi = NULL;
208 1112
                                last = mpl->t_now;
209
                        }
210 243094
                } else if (mpl->n_pool <= mpl->param->min_pool) {
211 241147
                        last = mpl->t_now;
212 241147
                }
213
214 243094
                Lck_Unlock(&mpl->mtx);
215
216 243094
                if (mi != NULL) {
217 883
                        CHECK_OBJ(mi, MEMITEM_MAGIC);
218 883
                        FREE_OBJ(mi);
219 883
                }
220
        }
221 20
        return (NULL);
222
}
223
224
/*---------------------------------------------------------------------
225
 * Create a new memory pool, and start the guard thread for it.
226
 */
227
228
struct mempool *
229 22865
MPL_New(const char *name,
230
    volatile struct poolparam *pp, volatile unsigned *cur_size)
231
{
232
        struct mempool *mpl;
233
234 22865
        ALLOC_OBJ(mpl, MEMPOOL_MAGIC);
235 22865
        AN(mpl);
236 22865
        bprintf(mpl->name, "MPL_%s", name);
237 22865
        mpl->param = pp;
238 22865
        mpl->cur_size = cur_size;
239 22865
        VTAILQ_INIT(&mpl->list);
240 22865
        VTAILQ_INIT(&mpl->surplus);
241 22865
        Lck_New(&mpl->mtx, lck_mempool);
242
        /* XXX: prealloc min_pool */
243 22865
        mpl->vsc = VSC_mempool_New(NULL, &mpl->vsc_seg, mpl->name + 4);
244 22865
        AN(mpl->vsc);
245 22865
        PTOK(pthread_create(&mpl->thread, NULL, mpl_guard, mpl));
246 22865
        PTOK(pthread_detach(mpl->thread));
247 22865
        return (mpl);
248
}
249
250
/*---------------------------------------------------------------------
251
 * Destroy a memory pool.  There must be no live items, and we cheat
252
 * and leave all the hard work to the guard thread.
253
 */
254
255
void
256 20
MPL_Destroy(struct mempool **mpp)
257
{
258
        struct mempool *mpl;
259
260 20
        TAKE_OBJ_NOTNULL(mpl, mpp, MEMPOOL_MAGIC);
261 20
        Lck_Lock(&mpl->mtx);
262 20
        AZ(mpl->live);
263 20
        mpl->self_destruct = 1;
264 20
        Lck_Unlock(&mpl->mtx);
265 20
}
266
267
/*---------------------------------------------------------------------
268
 */
269
270
void *
271 36565
MPL_Get(struct mempool *mpl, unsigned *size)
272
{
273
        struct memitem *mi;
274
275 36565
        CHECK_OBJ_NOTNULL(mpl, MEMPOOL_MAGIC);
276 36565
        AN(size);
277
278 36565
        Lck_Lock(&mpl->mtx);
279
280 36565
        mpl->vsc->allocs++;
281 36565
        mpl->vsc->live = ++mpl->live;
282
283 36565
        do {
284 36570
                mi = VTAILQ_FIRST(&mpl->list);
285 36570
                if (mi == NULL) {
286 65
                        mpl->vsc->randry++;
287 65
                        break;
288
                }
289 36505
                mpl->vsc->pool = --mpl->n_pool;
290 36505
                CHECK_OBJ(mi, MEMITEM_MAGIC);
291 36505
                VTAILQ_REMOVE(&mpl->list, mi, list);
292 36505
                if (mi->size < *mpl->cur_size) {
293 5
                        mpl->vsc->toosmall++;
294 5
                        VTAILQ_INSERT_HEAD(&mpl->surplus, mi, list);
295 5
                        mi = NULL;
296 5
                } else {
297 36500
                        mpl->vsc->recycle++;
298
                }
299 36505
        } while (mi == NULL);
300
301 36565
        Lck_Unlock(&mpl->mtx);
302
303 36565
        if (mi == NULL)
304 65
                mi = mpl_alloc(mpl);
305 36565
        *size = mi->size - sizeof *mi;
306
307 36565
        CHECK_OBJ(mi, MEMITEM_MAGIC);
308
        /* Throw away sizeof info for FlexeLint: */
309 36565
        return ((void *)(uintptr_t)(mi + 1));
310
}
311
312
void
313 36343
MPL_Free(struct mempool *mpl, void *item)
314
{
315
        struct memitem *mi;
316
317 36343
        CHECK_OBJ_NOTNULL(mpl, MEMPOOL_MAGIC);
318 36343
        AN(item);
319
320 36343
        mi = (void*)((uintptr_t)item - sizeof(*mi));
321 36343
        CHECK_OBJ_NOTNULL(mi, MEMITEM_MAGIC);
322 36343
        memset(item, 0, mi->size - sizeof *mi);
323
324 36343
        Lck_Lock(&mpl->mtx);
325
326 36343
        mpl->vsc->frees++;
327 36343
        mpl->vsc->live = --mpl->live;
328
329 36343
        if (mi->size < *mpl->cur_size) {
330 0
                mpl->vsc->toosmall++;
331 0
                VTAILQ_INSERT_HEAD(&mpl->surplus, mi, list);
332 0
        } else {
333 36343
                mpl->vsc->pool = ++mpl->n_pool;
334 36343
                mi->touched = mpl->t_now;
335 36343
                VTAILQ_INSERT_HEAD(&mpl->list, mi, list);
336
        }
337
338 36343
        Lck_Unlock(&mpl->mtx);
339 36343
}
340
341
void
342 14603
MPL_AssertSane(const void *item)
343
{
344
        struct memitem *mi;
345 14603
        mi = (void*)((uintptr_t)item - sizeof(*mi));
346 14603
        CHECK_OBJ_NOTNULL(mi, MEMITEM_MAGIC);
347 14603
}