nxt_buf.c (613:e5dd7bc63d59) nxt_buf.c (1267:74acbd89400a)
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 193 unchanged lines hidden (view full) ---

202
203 nxt_debug(task, "buf completion: %p %p", b, b->mem.start);
204
205 nxt_assert(data == b->parent);
206
207 mp = b->data;
208 nxt_mp_free(mp, b);
209
1
2/*
3 * Copyright (C) Igor Sysoev
4 * Copyright (C) NGINX, Inc.
5 */
6
7#include <nxt_main.h>
8

--- 193 unchanged lines hidden (view full) ---

202
203 nxt_debug(task, "buf completion: %p %p", b, b->mem.start);
204
205 nxt_assert(data == b->parent);
206
207 mp = b->data;
208 nxt_mp_free(mp, b);
209
210 nxt_buf_parent_completion(task, parent);
211}
212
213
214void
215nxt_buf_parent_completion(nxt_task_t *task, nxt_buf_t *parent)
216{
210 if (parent != NULL) {
211 nxt_debug(task, "parent retain:%uD", parent->retain);
212
213 parent->retain--;
214
215 if (parent->retain == 0) {
216 parent->mem.pos = parent->mem.free;
217

--- 49 unchanged lines hidden (view full) ---

267 nxt_debug(task, "buf ts completion: %p %p", b, b->mem.start);
268
269 nxt_assert(data == b->parent);
270
271 mp = b->data;
272 nxt_mp_free(mp, b);
273 nxt_mp_release(mp);
274
217 if (parent != NULL) {
218 nxt_debug(task, "parent retain:%uD", parent->retain);
219
220 parent->retain--;
221
222 if (parent->retain == 0) {
223 parent->mem.pos = parent->mem.free;
224

--- 49 unchanged lines hidden (view full) ---

274 nxt_debug(task, "buf ts completion: %p %p", b, b->mem.start);
275
276 nxt_assert(data == b->parent);
277
278 mp = b->data;
279 nxt_mp_free(mp, b);
280 nxt_mp_release(mp);
281
275 if (parent != NULL) {
276 nxt_debug(task, "parent retain:%uD", parent->retain);
277
278 parent->retain--;
279
280 if (parent->retain == 0) {
281 parent->mem.pos = parent->mem.free;
282
283 parent->completion_handler(task, parent, parent->parent);
284 }
285 }
282 nxt_buf_parent_completion(task, parent);
286}
287
288
289nxt_buf_t *
290nxt_buf_make_plain(nxt_mp_t *mp, nxt_buf_t *src, size_t size)
291{
292 nxt_buf_t *b, *i;
293

--- 24 unchanged lines hidden --- 		283}
284
285
286nxt_buf_t *
287nxt_buf_make_plain(nxt_mp_t *mp, nxt_buf_t *src, size_t size)
288{
289 nxt_buf_t *b, *i;
290

--- 24 unchanged lines hidden ---