vpp - Vector Packet Processing

diff options

author	Xiaoming Jiang <jiangxiaoming@outlook.com>	2022-12-08 08:08:41 +0000
committer	Damjan Marion <dmarion@0xa5.net>	2023-03-06 14:07:18 +0000
commit	73507dd1aa1f8ae7573fc73025ed1b9fc0db3532 (patch)
tree	3c439167a5a6c532e1005e0d8ea24128eb94f4da /src/vlib/stats/collector.c
parent	8b213ee652dd69d941865fa59e1f780843016475 (diff)

stats: fix node name compare error when updating stats segment

Type: fix Signed-off-by: Xiaoming Jiang <jiangxiaoming@outlook.com> Change-Id: Ib39aa345415720dd05a1b3e12e3e03eac43c5606

Diffstat (limited to 'src/vlib/stats/collector.c')

-rw-r--r--

src/vlib/stats/collector.c

1 files changed, 1 insertions, 1 deletions

/* * Copyright 2008-2010 Cisco Systems, Inc. All rights reserved. * Copyright 2007 Nuova Systems, Inc. All rights reserved. * * Copyright (c) 2014, Cisco Systems, Inc. * All rights reserved. * * 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 COPYRIGHT HOLDERS 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 THE * COPYRIGHT HOLDER 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. * */ #ifndef _VNIC_CQ_H_ #define _VNIC_CQ_H_ #include <rte_mbuf.h> #include "cq_desc.h" #include "vnic_dev.h" /* Completion queue control */ struct vnic_cq_ctrl { u64 ring_base; /* 0x00 */ u32 ring_size; /* 0x08 */ u32 pad0; u32 flow_control_enable; /* 0x10 */ u32 pad1; u32 color_enable; /* 0x18 */ u32 pad2; u32 cq_head; /* 0x20 */ u32 pad3; u32 cq_tail; /* 0x28 */ u32 pad4; u32 cq_tail_color; /* 0x30 */ u32 pad5; u32 interrupt_enable; /* 0x38 */ u32 pad6; u32 cq_entry_enable; /* 0x40 */ u32 pad7; u32 cq_message_enable; /* 0x48 */ u32 pad8; u32 interrupt_offset; /* 0x50 */ u32 pad9; u64 cq_message_addr; /* 0x58 */ u32 pad10; }; #ifdef ENIC_AIC struct vnic_rx_bytes_counter { unsigned int small_pkt_bytes_cnt; unsigned int large_pkt_bytes_cnt; }; #endif struct vnic_cq { unsigned int index; struct vnic_dev *vdev; struct vnic_cq_ctrl __iomem *ctrl; /* memory-mapped */ struct vnic_dev_ring ring; unsigned int to_clean; unsigned int last_color; unsigned int interrupt_offset; #ifdef ENIC_AIC struct vnic_rx_bytes_counter pkt_size_counter; unsigned int cur_rx_coal_timeval; unsigned int tobe_rx_coal_timeval; ktime_t prev_ts; #endif }; static inline unsigned int vnic_cq_service(struct vnic_cq *cq, unsigned int work_to_do, int (*q_service)(struct vnic_dev *vdev, struct cq_desc *cq_desc, u8 type, u16 q_number, u16 completed_index, void *opaque), void *opaque) { struct cq_desc *cq_desc; unsigned int work_done = 0; u16 q_number, completed_index; u8 type, color; struct rte_mbuf **rx_pkts = opaque; unsigned int ret; cq_desc = (struct cq_desc *)((u8 *)cq->ring.descs + cq->ring.desc_size * cq->to_clean); cq_desc_dec(cq_desc, &type, &color, &q_number, &completed_index); while (color != cq->last_color) { if (opaque) opaque = (void *)&(rx_pkts[work_done]); ret = (*q_service)(cq->vdev, cq_desc, type, q_number, completed_index, opaque); cq->to_clean++; if (cq->to_clean == cq->ring.desc_count) { cq->to_clean = 0; cq->last_color = cq->last_color ? 0 : 1; } cq_desc = (struct cq_desc *)((u8 *)cq->ring.descs + cq->ring.desc_size * cq->to_clean); cq_desc_dec(cq_desc, &type, &color, &q_number, &completed_index); if (ret) work_done++; if (work_done >= work_to_do) break; } return work_done; } void vnic_cq_free(struct vnic_cq *cq); int vnic_cq_alloc(struct vnic_dev *vdev, struct vnic_cq *cq, unsigned int index, unsigned int socket_id, unsigned int desc_count, unsigned int desc_size); void vnic_cq_init(struct vnic_cq *cq, unsigned int flow_control_enable, unsigned int color_enable, unsigned int cq_head, unsigned int cq_tail, unsigned int cq_tail_color, unsigned int interrupt_enable, unsigned int cq_entry_enable, unsigned int message_enable, unsigned int interrupt_offset, u64 message_addr); void vnic_cq_clean(struct vnic_cq *cq); int vnic_cq_mem_size(struct vnic_cq *cq, unsigned int desc_count, unsigned int desc_size); #endif /* _VNIC_CQ_H_ */


context:
space:
mode: