nginx之内存池的实现

目录

一、简介二、数据结构

2.1 内存池主要结构2.2 大内存链2.3 清理任务链



三、内存结构图


3.1 逻辑3.2 实际



四、实现


4.1 创建内存池4.2 从内存池中分配空间4.3 注册清理任务4.4 重置内存池4.5 销毁内存池4.6 大内存释放4.7 分配并清空数据4.8 回调文件清理

一、简介

最新稳定版本nginx1.20.2。

为了能高效、快速的分配内存，以及减少内存碎片等，nginx实现了自己的内存池基础组件。

主要实现文件ngx_palloc.h, ngx_palloc.c

二、数据结构

2.1 内存池主要结构

1. typedef struct {
2.     u_char               *last;
3.     u_char               *end;
4.     ngx_pool_t           *next;
5.     ngx_uint_t            failed;
6. } ngx_pool_data_t;
8. struct ngx_pool_s {
9.     ngx_pool_data_t       d;
10.     size_t                max;
11.     ngx_pool_t           *current;
12.     ngx_chain_t          *chain;
13.     ngx_pool_large_t     *large;
14.     ngx_pool_cleanup_t   *cleanup;
15.     ngx_log_t            *log;
16. };

复制代码 内存池中第一个成员是一个结构体：

使用ngx_pool_data_t结构体来表示当前内存池信息。

last ：下次开始分配的地址

end: 内存池的结束地址

next: 内存池链表，将多个内存池连接起来

max

整个内存池的最大大小

current

指向从当前内存池开始查找可用内存

chain

buffer使用的，这里不涉及

large

当需要的内存大于内存池最大大小时，需要通过malloc直接分配，然后形成链表进行组织

cleanup

清理工作的回调链表

log

日志句柄

2.2 大内存链

当需要分配的内存比内存池的最大大小都大时，内存池无法满足分配，所以直接从系统中分配，然后构成一个链表进行维护。

1. typedef struct ngx_pool_large_s  ngx_pool_large_t;
3. struct ngx_pool_large_s {
4.     ngx_pool_large_t     *next;
5.     void                 *alloc;
6. };

复制代码
2.3 清理任务链

有一个回调任务的链表，当内存池销毁时，将依次遍历此链表，逐一回调handler进行清理工作。

1. typedef void (*ngx_pool_cleanup_pt)(void *data);
3. typedef struct ngx_pool_cleanup_s  ngx_pool_cleanup_t;
5. struct ngx_pool_cleanup_s {
6.     ngx_pool_cleanup_pt   handler;
7.     void                 *data;
8.     ngx_pool_cleanup_t   *next;
9. };

复制代码
三、内存结构图

3.1 逻辑

3.2 实际

可以看出，很多节点都是从内存池中分配的，所以可以把精力都放在实际的数据上而不必在意其他细节上。

四、实现

4.1 创建内存池

1. /*
2. * NGX_MAX_ALLOC_FROM_POOL should be (ngx_pagesize – 1), i.e. 4095 on x86.
3. * On Windows NT it decreases a number of locked pages in a kernel.
4. */
5. #define NGX_MAX_ALLOC_FROM_POOL  (ngx_pagesize – 1)
7. #define NGX_DEFAULT_POOL_SIZE    (16 * 1024)

复制代码

1. ngx_pool_t *
2. ngx_create_pool(size_t size, ngx_log_t *log)
3. {
4.     ngx_pool_t  *p;
6.     p = ngx_memalign(NGX_POOL_ALIGNMENT, size, log);
7.     if (p == NULL) {
8.         return NULL;
9.     }
11.     p->d.last = (u_char *) p + sizeof(ngx_pool_t);
12.     p->d.end = (u_char *) p + size;
13.     p->d.next = NULL;
14.     p->d.failed = 0;
16.     size = size – sizeof(ngx_pool_t);
17.     p->max = (size < NGX_MAX_ALLOC_FROM_POOL) ? size : NGX_MAX_ALLOC_FROM_POOL;
19.     p->current = p;
20.     p->chain = NULL;
21.     p->large = NULL;
22.     p->cleanup = NULL;
23.     p->log = log;
25.     return p;
26. }

复制代码 从代码中可以看到，内存池最大不超过pagesize的大小

4.2 从内存池中分配空间

分配函数分了内存对齐和内存不对齐，但这只控制了内存池中分配空间，不控制大内存分配。

（1）分配小空间

内存对齐 ngx_palloc内存不对齐 ngx_pnalloc

1. void *
2. ngx_palloc(ngx_pool_t *pool, size_t size)
3. {
4. #if !(NGX_DEBUG_PALLOC)
5.     if (size <= pool->max) {
6.         return ngx_palloc_small(pool, size, 1);
7.     }
8. #endif
10.     return ngx_palloc_large(pool, size);
11. }

复制代码 当需要分配的空间小于max时，将使用小内存分配方式（即从内存池中分配空间），而ngx_pnalloc和ngx_palloc相比只是调用ngx_palloc_small时的最后一个参数为0。

从pool->current指向的内存池开始遍历，寻找满足分配大小的空间，找到则返回首地址

1. static ngx_inline void *
2. ngx_palloc_small(ngx_pool_t *pool, size_t size, ngx_uint_t align)
3. {
4.     u_char      *m;
5.     ngx_pool_t  *p;
7.     p = pool->current;
9.     do {
10.         m = p->d.last;
12.         if (align) {
13.             m = ngx_align_ptr(m, NGX_ALIGNMENT);
14.         }
16.         if ((size_t) (p->d.end – m) >= size) {
17.             p->d.last = m + size;
19.             return m;
20.         }
22.         p = p->d.next;
24.     } while (p);
26.     return ngx_palloc_block(pool, size);
27. }

复制代码 当现有内存池中都无法满足分配条件时，创建新的内存池

1. static void *
2. ngx_palloc_block(ngx_pool_t *pool, size_t size)
3. {
4.     u_char      *m;
5.     size_t       psize;
6.     ngx_pool_t  *p, *new;
8.     psize = (size_t) (pool->d.end – (u_char *) pool);
10.     m = ngx_memalign(NGX_POOL_ALIGNMENT, psize, pool->log);
11.     if (m == NULL) {
12.         return NULL;
13.     }
15.     new = (ngx_pool_t *) m;
17.     new->d.end = m + psize;
18.     new->d.next = NULL;
19.     new->d.failed = 0;
21.     m += sizeof(ngx_pool_data_t);
22.     m = ngx_align_ptr(m, NGX_ALIGNMENT);
23.     new->d.last = m + size;
25.     for (p = pool->current; p->d.next; p = p->d.next) {
26.         if (p->d.failed++ > 4) {
27.             pool->current = p->d.next;
28.         }
29.     }
31.     p->d.next = new;
33.     return m;
34. }

复制代码 其中，创建好新的内存池后，又做了一次遍历，将failed计数加一，当大于4时，将跳过此内存池，下次就不从它开始查找。

即认为超过4次你都不能满足分配，以后都不能满足分配，不再用你了，减少遍历个数，加快成功分配效率

（2）分配大空间

1. static void *
2. ngx_palloc_large(ngx_pool_t *pool, size_t size)
3. {
4.     void              *p;
5.     ngx_uint_t         n;
6.     ngx_pool_large_t  *large;
8.     p = ngx_alloc(size, pool->log);
9.     if (p == NULL) {
10.         return NULL;
11.     }
13.     n = 0;
15.     for (large = pool->large; large; large = large->next) {
16.         if (large->alloc == NULL) {
17.             large->alloc = p;
18.             return p;
19.         }
21.         if (n++ > 3) {
22.             break;
23.         }
24.     }
26.     large = ngx_palloc_small(pool, sizeof(ngx_pool_large_t), 1);
27.     if (large == NULL) {
28.         ngx_free(p);
29.         return NULL;
30.     }
32.     large->alloc = p;
33.     large->next = pool->large;
34.     pool->large = large;
36.     return p;
37. }

复制代码 可以看出，为了避免分配空间，遍历large链查找可重用的节点，但是如果链表过大又可能太慢，所以只查找前三个，如果三个都没有找到，则直接分配（而且节点也是从内存池中分配的，所以后续清理时，不需要管节点，只需要释放申请的大内存本身）

内存对齐

1. void *
2. ngx_pmemalign(ngx_pool_t *pool, size_t size, size_t alignment)
3. {
4.     void              *p;
5.     ngx_pool_large_t  *large;
7.     p = ngx_memalign(alignment, size, pool->log);
8.     if (p == NULL) {
9.         return NULL;
10.     }
12.     large = ngx_palloc_small(pool, sizeof(ngx_pool_large_t), 1);
13.     if (large == NULL) {
14.         ngx_free(p);
15.         return NULL;
16.     }
18.     large->alloc = p;
19.     large->next = pool->large;
20.     pool->large = large;
22.     return p;
23. }

复制代码
4.3 注册清理任务

1. ngx_pool_cleanup_t *
2. ngx_pool_cleanup_add(ngx_pool_t *p, size_t size)
3. {
4.     ngx_pool_cleanup_t  *c;
6.     c = ngx_palloc(p, sizeof(ngx_pool_cleanup_t));
7.     if (c == NULL) {
8.         return NULL;
9.     }
11.     if (size) {
12.         c->data = ngx_palloc(p, size);
13.         if (c->data == NULL) {
14.             return NULL;
15.         }
17.     } else {
18.         c->data = NULL;
19.     }
21.     c->handler = NULL;
22.     c->next = p->cleanup;
24.     p->cleanup = c;
26.     ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, p->log, 0, “add cleanup: %p”, c);
28.     return c;
29. }

复制代码 可以看出，这里只是分配了一个节点，并没有设置handler以及data数据，所以还得看具体的调用方进行设置，因为这里返回了分配的节点。

比如在函数ngx_create_temp_file中

1. ngx_int_t
2. ngx_create_temp_file(ngx_file_t *file, ngx_path_t *path, ngx_pool_t *pool,
3.     ngx_uint_t persistent, ngx_uint_t clean, ngx_uint_t access)
4. {
5.     …
7.     cln = ngx_pool_cleanup_add(pool, sizeof(ngx_pool_cleanup_file_t));
8.     if (cln == NULL) {
9.         return NGX_ERROR;
10.     }
12.        …
13.         file->fd = ngx_open_tempfile(file->name.data, persistent, access);
14.                                 …
15.         if (file->fd != NGX_INVALID_FILE) {
17.             cln->handler = clean ? ngx_pool_delete_file : ngx_pool_cleanup_file;
18.             clnf = cln->data;
20.             clnf->fd = file->fd;
21.             clnf->name = file->name.data;
22.             clnf->log = pool->log;
24.             return NGX_OK;
25.         }
26.                         …
27. }

复制代码 生成临时文件，将fd以及文件名注册到清理任务中，后续文件不使用了则不需要特殊处理，内存内存池释放时将统一清理。

4.4 重置内存池

释放大内存重置内存中last重置failed计数

1. void
2. ngx_reset_pool(ngx_pool_t *pool)
3. {
4.     ngx_pool_t        *p;
5.     ngx_pool_large_t  *l;
7.     for (l = pool->large; l; l = l->next) {
8.         if (l->alloc) {
9.             ngx_free(l->alloc);
10.         }
11.     }
13.     for (p = pool; p; p = p->d.next) {
14.         p->d.last = (u_char *) p + sizeof(ngx_pool_t);
15.         p->d.failed = 0;
16.     }
18.     pool->current = pool;
19.     pool->chain = NULL;
20.     pool->large = NULL;
21. }

复制代码 这里有个现象：

在内存池中空间不足时，将调用ngx_palloc_block创建一个新的内存池，而last指向的是m += sizeof(ngx_pool_data_t);, 因此当前新分配的内存池将比第一个内存池可用大小多了（max,current,chain,large,cleanup,log）这几个字段大小（可能没有那么多，因为要对齐，可能对齐后就完全一样了），而现在重置时，p->d.last = (u_char *) p + sizeof(ngx_pool_t);每个内存池可用大小又变成一样的。

4.5 销毁内存池

回调清理任务释放大内存释放内存池本身

1. void
2. ngx_destroy_pool(ngx_pool_t *pool)
3. {
4.     ngx_pool_t          *p, *n;
5.     ngx_pool_large_t    *l;
6.     ngx_pool_cleanup_t  *c;
8.     for (c = pool->cleanup; c; c = c->next) {
9.         if (c->handler) {
10.             ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, pool->log, 0,
11.                            “run cleanup: %p”, c);
12.             c->handler(c->data);
13.         }
14.     }
16.     for (l = pool->large; l; l = l->next) {
17.         if (l->alloc) {
18.             ngx_free(l->alloc);
19.         }
20.     }
22.     for (p = pool, n = pool->d.next; /* void */; p = n, n = n->d.next) {
23.         ngx_free(p);
25.         if (n == NULL) {
26.             break;
27.         }
28.     }
29. }

复制代码
4.6 大内存释放

通过遍历找到要释放的节点，将内存释放，并且将alloc设置成NULL,则有了节点重用的情况。

1. ngx_int_t
2. ngx_pfree(ngx_pool_t *pool, void *p)
3. {
4.     ngx_pool_large_t  *l;
6.     for (l = pool->large; l; l = l->next) {
7.         if (p == l->alloc) {
8.             ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, pool->log, 0,
9.                            “free: %p”, l->alloc);
10.             ngx_free(l->alloc);
11.             l->alloc = NULL;
13.             return NGX_OK;
14.         }
15.     }
17.     return NGX_DECLINED;
18. }

复制代码
4.7 分配并清空数据

1. void *
2. ngx_pcalloc(ngx_pool_t *pool, size_t size)
3. {
4.     void *p;
6.     p = ngx_palloc(pool, size);
7.     if (p) {
8.         ngx_memzero(p, size);
9.     }
11.     return p;
12. }

复制代码 正常分配的空间中都是X数据，所以当前函数在分配空间后，将分配的空间清零。

4.8 回调文件清理

(1) 手动关闭指定fd

遍历清理任务，找到ngx_pool_cleanup_file的handler，如果是要关闭的fd，则回调

1. void
2. ngx_pool_run_cleanup_file(ngx_pool_t *p, ngx_fd_t fd)
3. {
4.     ngx_pool_cleanup_t       *c;
5.     ngx_pool_cleanup_file_t  *cf;
7.     for (c = p->cleanup; c; c = c->next) {
8.         if (c->handler == ngx_pool_cleanup_file) {
10.             cf = c->data;
12.             if (cf->fd == fd) {
13.                 c->handler(cf);
14.                 c->handler = NULL;
15.                 return;
16.             }
17.         }
18.     }
19. }

复制代码 (2) 关闭fd

1. void
2. ngx_pool_cleanup_file(void *data)
3. {
4.     ngx_pool_cleanup_file_t  *c = data;
6.     ngx_log_debug1(NGX_LOG_DEBUG_ALLOC, c->log, 0, “file cleanup: fd:%d”,
7.                    c->fd);
9.     if (ngx_close_file(c->fd) == NGX_FILE_ERROR) {
10.         ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno,
11.                       ngx_close_file_n ” “%s” failed”, c->name);
12.     }
13. }

复制代码 (3) 删除文件并关闭fd

1. void
2. ngx_pool_delete_file(void *data)
3. {
4.     ngx_pool_cleanup_file_t  *c = data;
6.     ngx_err_t  err;
8.     ngx_log_debug2(NGX_LOG_DEBUG_ALLOC, c->log, 0, “file cleanup: fd:%d %s”,
9.                    c->fd, c->name);
11.     if (ngx_delete_file(c->name) == NGX_FILE_ERROR) {
12.         err = ngx_errno;
14.         if (err != NGX_ENOENT) {
15.             ngx_log_error(NGX_LOG_CRIT, c->log, err,
16.                           ngx_delete_file_n ” “%s” failed”, c->name);
17.         }
18.     }
20.     if (ngx_close_file(c->fd) == NGX_FILE_ERROR) {
21.         ngx_log_error(NGX_LOG_ALERT, c->log, ngx_errno,
22.                       ngx_close_file_n ” “%s” failed”, c->name);
23.     }
24. }

复制代码 到此这篇关于nginx之内存池的实现的文章就介绍到这了,更多相关nginx 内存池内容请搜索软件技术网以前的文章或继续浏览下面的相关文章希望大家以后多多支持软件技术网！