X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvlib%2Fbuffer.c;h=43b1dd6376196820bb8210230953426f69815947;hb=f58571ee6f7b0460392ee6a7f86be2e07e747390;hp=a49200d1b8fb13e558c6239864f40c18a5783d45;hpb=a638c18375f17891a9455e717d8436158af12387;p=vpp.git diff --git a/src/vlib/buffer.c b/src/vlib/buffer.c index a49200d1b8f..43b1dd63761 100644 --- a/src/vlib/buffer.c +++ b/src/vlib/buffer.c @@ -92,7 +92,7 @@ vlib_buffer_length_in_chain_slow_path (vlib_main_t * vm, } u8 * -format_vlib_buffer (u8 * s, va_list * args) +format_vlib_buffer_no_chain (u8 * s, va_list * args) { vlib_buffer_t *b = va_arg (*args, vlib_buffer_t *); u32 indent = format_get_indent (s); @@ -118,9 +118,20 @@ format_vlib_buffer (u8 * s, va_list * args) s = format (s, "\n%U%v", format_white_space, indent, a); vec_free (a); + return s; +} + +u8 * +format_vlib_buffer (u8 * s, va_list * args) +{ + vlib_main_t *vm = vlib_get_main (); + vlib_buffer_t *b = va_arg (*args, vlib_buffer_t *); + u32 indent = format_get_indent (s); + + s = format (s, "%U", format_vlib_buffer_no_chain, b); + while (b->flags & VLIB_BUFFER_NEXT_PRESENT) { - vlib_main_t *vm = vlib_get_main (); u32 next_buffer = b->next_buffer; b = vlib_get_buffer (vm, next_buffer); @@ -552,9 +563,9 @@ vlib_buffer_pool_create (vlib_main_t * vm, char *name, u32 data_size, n_alloc_per_page = (1ULL << m->log2_page_size) / alloc_size; /* preallocate buffer indices memory */ - vec_validate_aligned (bp->buffers, m->n_pages * n_alloc_per_page, - CLIB_CACHE_LINE_BYTES); - vec_reset_length (bp->buffers); + bp->n_buffers = m->n_pages * n_alloc_per_page; + bp->buffers = clib_mem_alloc_aligned (bp->n_buffers * sizeof (u32), + CLIB_CACHE_LINE_BYTES); clib_spinlock_init (&bp->lock); @@ -571,11 +582,11 @@ vlib_buffer_pool_create (vlib_main_t * vm, char *name, u32 data_size, bi = vlib_get_buffer_index (vm, (vlib_buffer_t *) p); - vec_add1_aligned (bp->buffers, bi, CLIB_CACHE_LINE_BYTES); + bp->buffers[bp->n_avail++] = bi; + vlib_get_buffer (vm, bi); } - bp->n_buffers = vec_len (bp->buffers); return bp->index; } @@ -594,14 +605,14 @@ format_vlib_buffer_pool (u8 * s, va_list * va) /* *INDENT-OFF* */ vec_foreach (bpt, bp->threads) - cached += vec_len (bpt->cached_buffers); + cached += bpt->n_cached; /* *INDENT-ON* */ s = format (s, "%-20s%=6d%=6d%=6u%=11u%=6u%=8u%=8u%=8u", bp->name, bp->index, bp->numa_node, bp->data_size + sizeof (vlib_buffer_t) + vm->buffer_main->ext_hdr_size, - bp->data_size, bp->n_buffers, vec_len (bp->buffers), cached, - bp->n_buffers - vec_len (bp->buffers) - cached); + bp->data_size, bp->n_buffers, bp->n_avail, cached, + bp->n_buffers - bp->n_avail - cached); return s; } @@ -693,7 +704,7 @@ retry: } if (error) - return error; + goto done; vec_reset_length (name); name = format (name, "default-numa-%d%c", numa_node, 0); @@ -703,9 +714,14 @@ retry: physmem_map_index); if (*index == (u8) ~ 0) - return clib_error_return (0, "maximum number of buffer pools reached"); + { + error = clib_error_return (0, "maximum number of buffer pools reached"); + goto done; + } - return 0; +done: + vec_free (name); + return error; } void @@ -731,7 +747,7 @@ buffer_get_cached (vlib_buffer_pool_t * bp) /* *INDENT-OFF* */ vec_foreach (bpt, bp->threads) - cached += vec_len (bpt->cached_buffers); + cached += bpt->n_cached; /* *INDENT-ON* */ clib_spinlock_unlock (&bp->lock); @@ -758,7 +774,7 @@ buffer_gauges_update_used_fn (stat_segment_directory_entry_t * e, u32 index) if (!bp) return; - e->value = bp->n_buffers - vec_len (bp->buffers) - buffer_get_cached (bp); + e->value = bp->n_buffers - bp->n_avail - buffer_get_cached (bp); } static void @@ -770,7 +786,7 @@ buffer_gauges_update_available_fn (stat_segment_directory_entry_t * e, if (!bp) return; - e->value = vec_len (bp->buffers); + e->value = bp->n_avail; } static void