DPDK patches and discussions
 help / color / mirror / Atom feed
From: "Carew, Alan" <alan.carew@intel.com>
To: Stephen Hemminger <stephen@networkplumber.org>,
	"dev@dpdk.org" <dev@dpdk.org>
Subject: Re: [dpdk-dev] [PATCH 1/2] virtio: checkpatch cleanups
Date: Fri, 20 Jun 2014 13:34:37 +0000	[thread overview]
Message-ID: <0E29434AEE0C3A4180987AB476A6F630593A81EC@IRSMSX101.ger.corp.intel.com> (raw)
In-Reply-To: <20140612183240.1067d5be@nehalam.linuxnetplumber.net>

Acked-by: Alan Carew <alan.carew@intel.com>

> -----Original Message-----
> From: dev [mailto:dev-bounces@dpdk.org] On Behalf Of Stephen Hemminger
> Sent: Friday, June 13, 2014 2:33 AM
> To: dev@dpdk.org
> Subject: [dpdk-dev] [PATCH 1/2] virtio: checkpatch cleanups
> 
> 
> This fixes style problems reported by checkpatch including:
>   * extra whitespace
>   * spaces before tabs
>   * strings broken across lines
>   * excessively long lines
>   * missing spaces after keywords
>   * unnecessary paren's in return statements
> 
> Signed-off-by: Stephen Hemminger <shemming@brocade.com>
> 
> ---
>  lib/librte_pmd_virtio/virtio_ethdev.c |  127 ++++++++++++++++++----------------
>  lib/librte_pmd_virtio/virtio_ethdev.h |    2
>  lib/librte_pmd_virtio/virtio_pci.c    |    4 -
>  lib/librte_pmd_virtio/virtio_pci.h    |   10 +-
>  lib/librte_pmd_virtio/virtio_ring.h   |    4 -
>  lib/librte_pmd_virtio/virtio_rxtx.c   |   32 ++++----
>  lib/librte_pmd_virtio/virtqueue.c     |    4 -
>  lib/librte_pmd_virtio/virtqueue.h     |   35 ++++-----
>  8 files changed, 115 insertions(+), 103 deletions(-)
> 
> --- a/lib/librte_pmd_virtio/virtio_ethdev.c	2014-06-12
> 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtio_ethdev.c	2014-06-12
> 17:51:34.000000000 -0700
> @@ -110,8 +110,9 @@ virtio_send_command(struct virtqueue *vq
>  	ctrl->status = status;
> 
>  	if (!vq->hw->cvq) {
> -		PMD_INIT_LOG(ERR, "%s(): Control queue is "
> -			"not supported by this device.\n", __func__);
> +		PMD_INIT_LOG(ERR,
> +			     "%s(): Control queue is not supported.\n",
> +			     __func__);
>  		return -1;
>  	}
> 
> @@ -257,10 +258,10 @@ int virtio_dev_queue_setup(struct rte_et
>  		nb_desc = vq_size;
>  	if (vq_size == 0) {
>  		PMD_INIT_LOG(ERR, "%s: virtqueue does not exist\n",
> __func__);
> -		return (-EINVAL);
> +		return -EINVAL;
>  	} else if (!rte_is_power_of_2(vq_size)) {
>  		PMD_INIT_LOG(ERR, "%s: virtqueue size is not powerof 2\n",
> __func__);
> -		return (-EINVAL);
> +		return -EINVAL;
>  	} else if (nb_desc != vq_size) {
>  		PMD_INIT_LOG(ERR, "Warning: nb_desc(%d) is not equal to vq
> size (%d), fall to vq size\n",
>  			nb_desc, vq_size);
> @@ -273,13 +274,13 @@ int virtio_dev_queue_setup(struct rte_et
>  		vq = rte_zmalloc(vq_name, sizeof(struct virtqueue) +
>  			vq_size * sizeof(struct vq_desc_extra),
> CACHE_LINE_SIZE);
>  		memcpy(vq->vq_name, vq_name, sizeof(vq->vq_name));
> -	} else if(queue_type == VTNET_TQ) {
> +	} else if (queue_type == VTNET_TQ) {
>  		rte_snprintf(vq_name, sizeof(vq_name), "port%d_tvq%d",
>  			dev->data->port_id, queue_idx);
>  		vq = rte_zmalloc(vq_name, sizeof(struct virtqueue) +
>  			vq_size * sizeof(struct vq_desc_extra),
> CACHE_LINE_SIZE);
>  		memcpy(vq->vq_name, vq_name, sizeof(vq->vq_name));
> -	} else if(queue_type == VTNET_CQ) {
> +	} else if (queue_type == VTNET_CQ) {
>  		rte_snprintf(vq_name, sizeof(vq_name), "port%d_cvq",
>  			dev->data->port_id);
>  		vq = rte_zmalloc(vq_name, sizeof(struct virtqueue) +
> @@ -311,7 +312,7 @@ int virtio_dev_queue_setup(struct rte_et
>  		socket_id, 0, VIRTIO_PCI_VRING_ALIGN);
>  	if (mz == NULL) {
>  		rte_free(vq);
> -		return (-ENOMEM);
> +		return -ENOMEM;
>  	}
> 
>  	/*
> @@ -319,10 +320,10 @@ int virtio_dev_queue_setup(struct rte_et
>  	 * and only accepts 32 bit page frame number.
>  	 * Check if the allocated physical memory exceeds 16TB.
>  	 */
> -	if ( (mz->phys_addr + vq->vq_ring_size - 1) >>
> (VIRTIO_PCI_QUEUE_ADDR_SHIFT + 32) ) {
> +	if ((mz->phys_addr + vq->vq_ring_size - 1) >>
> (VIRTIO_PCI_QUEUE_ADDR_SHIFT + 32)) {
>  		PMD_INIT_LOG(ERR, "vring address shouldn't be above
> 16TB!\n");
>  		rte_free(vq);
> -		return (-ENOMEM);
> +		return -ENOMEM;
>  	}
> 
>  	memset(mz->addr, 0, sizeof(mz->len));
> @@ -429,7 +430,7 @@ static struct eth_dev_ops virtio_eth_dev
>  	/* meaningfull only to multiple queue */
>  	.tx_queue_release        = virtio_dev_tx_queue_release,
>  	/* collect stats per queue */
> -	.queue_stats_mapping_set = virtio_dev_queue_stats_mapping_set
> +	.queue_stats_mapping_set = virtio_dev_queue_stats_mapping_set,
>  };
> 
>  static inline int
> @@ -441,9 +442,9 @@ virtio_dev_atomic_read_link_status(struc
> 
>  	if (rte_atomic64_cmpset((uint64_t *)dst, *(uint64_t *)dst,
>  			*(uint64_t *)src) == 0)
> -		return (-1);
> +		return -1;
> 
> -	return (0);
> +	return 0;
>  }
> 
>  /**
> @@ -467,9 +468,9 @@ virtio_dev_atomic_write_link_status(stru
> 
>  	if (rte_atomic64_cmpset((uint64_t *)dst, *(uint64_t *)dst,
>  					*(uint64_t *)src) == 0)
> -		return (-1);
> +		return -1;
> 
> -	return (0);
> +	return 0;
>  }
> 
>  static void
> @@ -477,7 +478,7 @@ virtio_dev_stats_get(struct rte_eth_dev
>  {
>  	struct virtio_hw *hw =
>  		VIRTIO_DEV_PRIVATE_TO_HW(dev->data->dev_private);
> -	if(stats)
> +	if (stats)
>  		memcpy(stats, &hw->eth_stats, sizeof(*stats));
>  }
> 
> @@ -516,8 +517,9 @@ static void
>  virtio_negotiate_features(struct virtio_hw *hw)
>  {
>  	uint32_t guest_features, mask;
> +
>  	mask = VIRTIO_NET_F_CTRL_RX | VIRTIO_NET_F_CTRL_VLAN;
> -	mask |= VIRTIO_NET_F_CSUM | VIRTIO_NET_F_GUEST_CSUM ;
> +	mask |= VIRTIO_NET_F_CSUM | VIRTIO_NET_F_GUEST_CSUM;
> 
>  	/* TSO and LRO are only available when their corresponding
>  	 * checksum offload feature is also negotiated.
> @@ -559,7 +561,8 @@ parse_sysfs_value(const char *filename,
>  	char buf[BUFSIZ];
>  	char *end = NULL;
> 
> -	if ((f = fopen(filename, "r")) == NULL) {
> +	f = fopen(filename, "r");
> +	if (f == NULL) {
>  		PMD_INIT_LOG(ERR, "%s(): cannot open sysfs value %s\n",
>  			     __func__, filename);
>  		return -1;
> @@ -592,14 +595,14 @@ static int get_uio_dev(struct rte_pci_ad
>  	/* depending on kernel version, uio can be located in uio/uioX
>  	 * or uio:uioX */
>  	rte_snprintf(dirname, sizeof(dirname),
> -	         SYSFS_PCI_DEVICES "/" PCI_PRI_FMT "/uio",
> -	         loc->domain, loc->bus, loc->devid, loc->function);
> +		     SYSFS_PCI_DEVICES "/" PCI_PRI_FMT "/uio",
> +		     loc->domain, loc->bus, loc->devid, loc->function);
>  	dir = opendir(dirname);
>  	if (dir == NULL) {
>  		/* retry with the parent directory */
>  		rte_snprintf(dirname, sizeof(dirname),
> -		         SYSFS_PCI_DEVICES "/" PCI_PRI_FMT,
> -		         loc->domain, loc->bus, loc->devid, loc->function);
> +			     SYSFS_PCI_DEVICES "/" PCI_PRI_FMT,
> +			     loc->domain, loc->bus, loc->devid, loc->function);
>  		dir = opendir(dirname);
> 
>  		if (dir == NULL) {
> @@ -663,23 +666,23 @@ eth_virtio_dev_init(__rte_unused struct
>  	struct virtio_hw *hw =
>  		VIRTIO_DEV_PRIVATE_TO_HW(eth_dev->data->dev_private);
> 
> -	if (RTE_PKTMBUF_HEADROOM < sizeof(struct virtio_net_hdr) ) {
> +	if (RTE_PKTMBUF_HEADROOM < sizeof(struct virtio_net_hdr)) {
>  		PMD_INIT_LOG(ERR,
>  			"MBUF HEADROOM should be enough to hold virtio net
> hdr\n");
> -		return (-1);
> +		return -1;
>  	}
> 
> -	if (! (rte_eal_get_configuration()->flags & EAL_FLG_HIGH_IOPL)) {
> +	if (!(rte_eal_get_configuration()->flags & EAL_FLG_HIGH_IOPL)) {
>  		PMD_INIT_LOG(ERR,
>  			"IOPL call failed in EAL init - cannot use virtio PMD
> driver\n");
> -		return (-1);
> +		return -1;
>  	}
> 
>  	eth_dev->dev_ops = &virtio_eth_dev_ops;
>  	eth_dev->rx_pkt_burst = &virtio_recv_pkts;
>  	eth_dev->tx_pkt_burst = &virtio_xmit_pkts;
> 
> -	if(rte_eal_process_type() == RTE_PROC_SECONDARY)
> +	if (rte_eal_process_type() == RTE_PROC_SECONDARY)
>  		return 0;
> 
>  	pci_dev = eth_dev->pci_dev;
> @@ -690,7 +693,7 @@ eth_virtio_dev_init(__rte_unused struct
>  	{
>  		char dirname[PATH_MAX];
>  		char filename[PATH_MAX];
> -		unsigned long start,size;
> +		unsigned long start, size;
> 
>  		if (get_uio_dev(&pci_dev->addr, dirname, sizeof(dirname)) < 0)
>  			return -1;
> @@ -714,8 +717,9 @@ eth_virtio_dev_init(__rte_unused struct
>  		}
>  		pci_dev->mem_resource[0].addr = (void *)(uintptr_t)start;
>  		pci_dev->mem_resource[0].len =  (uint64_t)size;
> -		PMD_INIT_LOG(DEBUG, "PCI Port IO found start=0x%lx with "
> -			     "size=0x%lx\n", start, size);
> +		PMD_INIT_LOG(DEBUG,
> +			     "PCI Port IO found start=0x%lx with size=0x%lx\n",
> +			     start, size);
>  	}
>  #endif
>  	hw->io_base = (uint32_t)(uintptr_t)pci_dev->mem_resource[0].addr;
> @@ -731,7 +735,7 @@ eth_virtio_dev_init(__rte_unused struct
>  	virtio_negotiate_features(hw);
> 
>  	/* Setting up rx_header size for the device */
> -	if(vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF))
> +	if (vtpci_with_feature(hw, VIRTIO_NET_F_MRG_RXBUF))
>  		hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr_mrg_rxbuf);
>  	else
>  		hw->vtnet_hdr_size = sizeof(struct virtio_net_hdr);
> @@ -742,15 +746,17 @@ eth_virtio_dev_init(__rte_unused struct
>  		PMD_INIT_LOG(ERR,
>  			"Failed to allocate %d bytes needed to store MAC
> addresses",
>  			ETHER_ADDR_LEN);
> -		return (-ENOMEM);
> +		return -ENOMEM;
>  	}
> 
>  	/* Copy the permanent MAC address to: virtio_hw */
>  	virtio_get_hwaddr(hw);
>  	ether_addr_copy((struct ether_addr *) hw->mac_addr,
>  			&eth_dev->data->mac_addrs[0]);
> -	PMD_INIT_LOG(DEBUG, "PORT MAC:
> %02X:%02X:%02X:%02X:%02X:%02X\n", hw->mac_addr[0],
> -			hw->mac_addr[1],hw->mac_addr[2], hw-
> >mac_addr[3], hw->mac_addr[4], hw->mac_addr[5]);
> +	PMD_INIT_LOG(DEBUG,
> +		     "PORT MAC: %02X:%02X:%02X:%02X:%02X:%02X\n",
> +		     hw->mac_addr[0], hw->mac_addr[1], hw->mac_addr[2],
> +		     hw->mac_addr[3], hw->mac_addr[4], hw->mac_addr[5]);
> 
>  	if (vtpci_with_feature(hw, VIRTIO_NET_F_CTRL_VQ)) {
>  		config = &local_config;
> @@ -758,16 +764,16 @@ eth_virtio_dev_init(__rte_unused struct
>  		if (vtpci_with_feature(hw, VIRTIO_NET_F_STATUS)) {
>  			offset_conf += sizeof(config->status);
>  		} else {
> -			PMD_INIT_LOG(DEBUG, "VIRTIO_NET_F_STATUS is "
> -				"not supported\n");
> +			PMD_INIT_LOG(DEBUG,
> +				     "VIRTIO_NET_F_STATUS is not
> supported\n");
>  			config->status = 0;
>  		}
> 
>  		if (vtpci_with_feature(hw, VIRTIO_NET_F_MQ)) {
>  			offset_conf += sizeof(config->max_virtqueue_pairs);
>  		} else {
> -			PMD_INIT_LOG(DEBUG, "VIRTIO_NET_F_MQ is "
> -				"not supported\n");
> +			PMD_INIT_LOG(DEBUG,
> +				     "VIRTIO_NET_F_MQ is not supported\n");
>  			config->max_virtqueue_pairs = 1;
>  		}
> 
> @@ -828,7 +834,7 @@ static int
>  rte_virtio_pmd_init(const char *name __rte_unused, const char *param
> __rte_unused)
>  {
>  	rte_eth_driver_register(&rte_virtio_pmd);
> -	return (0);
> +	return 0;
>  }
> 
>  /*
> @@ -851,7 +857,7 @@ virtio_dev_tx_queue_release(__rte_unused
>  static int
>  virtio_dev_configure(__rte_unused struct rte_eth_dev *dev)
>  {
> -	return (0);
> +	return 0;
>  }
> 
> 
> @@ -877,13 +883,13 @@ virtio_dev_start(struct rte_eth_dev *dev
>  	virtio_dev_rxtx_start(dev);
> 
>  	/* Check VIRTIO_NET_F_STATUS for link status*/
> -	if(vtpci_with_feature(hw, VIRTIO_NET_F_STATUS)) {
> +	if (vtpci_with_feature(hw, VIRTIO_NET_F_STATUS)) {
>  		vtpci_read_dev_config(hw,
>  				offsetof(struct virtio_net_config, status),
>  				&status, sizeof(status));
> -		if((status & VIRTIO_NET_S_LINK_UP) == 0) {
> +		if ((status & VIRTIO_NET_S_LINK_UP) == 0) {
>  			PMD_INIT_LOG(ERR,     "Port: %d Link is DOWN\n",
> dev->data->port_id);
> -			return (-EIO);
> +			return -EIO;
>  		} else {
>  			PMD_INIT_LOG(DEBUG, "Port: %d Link is UP\n",  dev-
> >data->port_id);
>  		}
> @@ -920,9 +926,10 @@ static void virtio_dev_free_mbufs(struct
>  {
>  	struct rte_mbuf *buf;
>  	int i, mbuf_num = 0;
> +
>  	for (i = 0; i < dev->data->nb_rx_queues; i++) {
> -		PMD_INIT_LOG(DEBUG, "Before freeing rxq[%d] used and "
> -			"unused buf\n", i);
> +		PMD_INIT_LOG(DEBUG,
> +			     "Before freeing rxq[%d] used and unused buf\n", i);
>  		VIRTQUEUE_DUMP((struct virtqueue *)dev->data-
> >rx_queues[i]);
> 
>  		while ((buf = (struct rte_mbuf *)virtqueue_detatch_unused(
> @@ -932,14 +939,15 @@ static void virtio_dev_free_mbufs(struct
>  		}
> 
>  		PMD_INIT_LOG(DEBUG, "free %d mbufs\n", mbuf_num);
> -		PMD_INIT_LOG(DEBUG, "After freeing rxq[%d] used and "
> -			"unused buf\n", i);
> +		PMD_INIT_LOG(DEBUG,
> +			     "After freeing rxq[%d] used and unused buf\n", i);
>  		VIRTQUEUE_DUMP((struct virtqueue *)dev->data-
> >rx_queues[i]);
>  	}
> 
>  	for (i = 0; i < dev->data->nb_tx_queues; i++) {
> -		PMD_INIT_LOG(DEBUG, "Before freeing txq[%d] used and "
> -			"unused bufs\n", i);
> +		PMD_INIT_LOG(DEBUG,
> +			     "Before freeing txq[%d] used and unused bufs\n",
> +			     i);
>  		VIRTQUEUE_DUMP((struct virtqueue *)dev->data-
> >tx_queues[i]);
> 
>  		mbuf_num = 0;
> @@ -980,34 +988,37 @@ virtio_dev_link_update(struct rte_eth_de
>  	memset(&link, 0, sizeof(link));
>  	virtio_dev_atomic_read_link_status(dev, &link);
>  	old = link;
> -	link.link_duplex = FULL_DUPLEX ;
> -	link.link_speed  = SPEED_10G ;
> -	if(vtpci_with_feature(hw, VIRTIO_NET_F_STATUS)) {
> +	link.link_duplex = FULL_DUPLEX;
> +	link.link_speed  = SPEED_10G;
> +	if (vtpci_with_feature(hw, VIRTIO_NET_F_STATUS)) {
>  		PMD_INIT_LOG(DEBUG, "Get link status from hw\n");
>  		vtpci_read_dev_config(hw,
>  				offsetof(struct virtio_net_config, status),
>  				&status, sizeof(status));
> -		if((status & VIRTIO_NET_S_LINK_UP) == 0) {
> +		if ((status & VIRTIO_NET_S_LINK_UP) == 0) {
>  			link.link_status = 0;
> -			PMD_INIT_LOG(DEBUG, "Port %d is down\n",dev-
> >data->port_id);
> +			PMD_INIT_LOG(DEBUG, "Port %d is down\n",
> +				     dev->data->port_id);
>  		} else {
>  			link.link_status = 1;
> -			PMD_INIT_LOG(DEBUG, "Port %d is up\n",dev->data-
> >port_id);
> +			PMD_INIT_LOG(DEBUG, "Port %d is up\n",
> +				     dev->data->port_id);
>  		}
>  	} else {
> -		link.link_status = 1;   //Link up
> +		link.link_status = 1;   /* Link up */
>  	}
>  	virtio_dev_atomic_write_link_status(dev, &link);
> -	if(old.link_status == link.link_status)
> -		return (-1);
> +	if (old.link_status == link.link_status)
> +		return -1;
>  	/*changed*/
> -	return (0);
> +	return 0;
>  }
> 
>  static void
>  virtio_dev_info_get(struct rte_eth_dev *dev, struct rte_eth_dev_info
> *dev_info)
>  {
>  	struct virtio_hw *hw = VIRTIO_DEV_PRIVATE_TO_HW(dev->data-
> >dev_private);
> +
>  	dev_info->driver_name = dev->driver->pci_drv.name;
>  	dev_info->max_rx_queues = (uint16_t)hw->max_rx_queues;
>  	dev_info->max_tx_queues = (uint16_t)hw->max_tx_queues;
> --- a/lib/librte_pmd_virtio/virtio_ethdev.h	2014-06-12
> 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtio_ethdev.h	2014-06-12
> 17:41:20.297298905 -0700
> @@ -123,7 +123,7 @@ struct virtio_adapter {
>   * via tcp_lro_rx().
>   */
>  #define VTNET_LRO_FEATURES (VIRTIO_NET_F_GUEST_TSO4 | \
> -    VIRTIO_NET_F_GUEST_TSO6 | VIRTIO_NET_F_GUEST_ECN)
> +			    VIRTIO_NET_F_GUEST_TSO6 |
> VIRTIO_NET_F_GUEST_ECN)
> 
> 
>  #endif /* _VIRTIO_ETHDEV_H_ */
> --- a/lib/librte_pmd_virtio/virtio_pci.c	2014-06-12 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtio_pci.c	2014-06-12 17:41:20.297298905 -0700
> @@ -92,7 +92,7 @@ vtpci_negotiate_features(struct virtio_h
>  	features = (hw->host_features) & guest_features;
> 
>  	VIRTIO_WRITE_REG_4(hw, VIRTIO_PCI_GUEST_FEATURES, features);
> -	return (features);
> +	return features;
>  }
> 
> 
> @@ -116,7 +116,7 @@ vtpci_reinit_complete(struct virtio_hw *
>  uint8_t
>  vtpci_get_status(struct virtio_hw *hw)
>  {
> -	return (VIRTIO_READ_REG_1(hw, VIRTIO_PCI_STATUS));
> +	return VIRTIO_READ_REG_1(hw, VIRTIO_PCI_STATUS);
>  }
> 
>  void
> --- a/lib/librte_pmd_virtio/virtio_ring.h	2014-06-12 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtio_ring.h	2014-06-12 17:47:23.323539780 -0700
> @@ -133,7 +133,7 @@ vring_size(unsigned int num, unsigned lo
>  	size = RTE_ALIGN_CEIL(size, align);
>  	size += sizeof(struct vring_used) +
>  		(num * sizeof(struct vring_used_elem));
> -	return (size);
> +	return size;
>  }
> 
>  static inline void
> @@ -145,7 +145,7 @@ vring_init(struct vring *vr, unsigned in
>  	vr->avail = (struct vring_avail *) (p +
>  		num * sizeof(struct vring_desc));
>  	vr->used = (void *)
> -		RTE_ALIGN_CEIL( (uintptr_t)(&vr->avail->ring[num]), align);
> +		RTE_ALIGN_CEIL((uintptr_t)(&vr->avail->ring[num]), align);
>  }
> 
>  /*
> --- a/lib/librte_pmd_virtio/virtio_rxtx.c	2014-06-12 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtio_rxtx.c	2014-06-12 17:49:48.428390399 -0700
> @@ -54,7 +54,7 @@
>  #include "virtio_ethdev.h"
>  #include "virtqueue.h"
> 
> -#ifdef  RTE_LIBRTE_VIRTIO_DEBUG_DUMP
> +#ifdef RTE_LIBRTE_VIRTIO_DEBUG_DUMP
>  #define VIRTIO_DUMP_PACKET(m, len) rte_pktmbuf_dump(m, len)
>  #else
>  #define  VIRTIO_DUMP_PACKET(m, len) do { } while (0)
> @@ -68,7 +68,7 @@ rte_rxmbuf_alloc(struct rte_mempool *mp)
>  	m = __rte_mbuf_raw_alloc(mp);
>  	__rte_mbuf_sanity_check_raw(m, RTE_MBUF_PKT, 0);
> 
> -	return (m);
> +	return m;
>  }
> 
>  static void
> @@ -175,6 +175,7 @@ virtio_dev_rxtx_start(struct rte_eth_dev
>  	 *
>  	 */
>  	int i;
> +
>  	PMD_INIT_FUNC_TRACE();
> 
>  	/* Start rx vring. */
> @@ -214,7 +215,7 @@ virtio_dev_rx_queue_setup(struct rte_eth
>  	vq->mpool = mp;
> 
>  	dev->data->rx_queues[queue_idx] = vq;
> -	return (0);
> +	return 0;
>  }
> 
>  /*
> @@ -244,7 +245,7 @@ virtio_dev_tx_queue_setup(struct rte_eth
>  	}
> 
>  	dev->data->tx_queues[queue_idx] = vq;
> -	return (0);
> +	return 0;
>  }
> 
>  static void
> @@ -285,17 +286,18 @@ virtio_recv_pkts(void *rx_queue, struct
>  	if (likely(num > DESC_PER_CACHELINE))
>  		num = num - ((rxvq->vq_used_cons_idx + num) %
> DESC_PER_CACHELINE);
> 
> -	if(num == 0) return 0;
> +	if (num == 0)
> +		return 0;
> 
>  	num = virtqueue_dequeue_burst_rx(rxvq, rcv_pkts, len, num);
>  	PMD_RX_LOG(DEBUG, "used:%d dequeue:%d\n", nb_used, num);
> -	for (i = 0; i < num ; i ++) {
> +	for (i = 0; i < num ; i++) {
>  		rxm = rcv_pkts[i];
> 
>  		PMD_RX_LOG(DEBUG, "packet len:%d\n", len[i]);
> 
>  		if (unlikely(len[i]
> -			< (uint32_t)hw->vtnet_hdr_size + ETHER_HDR_LEN)) {
> +			     < (uint32_t)hw->vtnet_hdr_size + ETHER_HDR_LEN))
> {
>  			PMD_RX_LOG(ERR, "Packet drop\n");
>  			nb_enqueued++;
>  			virtio_discard_rxbuf(rxvq, rxm);
> @@ -308,9 +310,9 @@ virtio_recv_pkts(void *rx_queue, struct
>  		rxm->pkt.nb_segs = 1;
>  		rxm->pkt.next = NULL;
>  		rxm->pkt.pkt_len  = (uint32_t)(len[i]
> -			- sizeof(struct virtio_net_hdr));
> +					       - sizeof(struct virtio_net_hdr));
>  		rxm->pkt.data_len = (uint16_t)(len[i]
> -			- sizeof(struct virtio_net_hdr));
> +					       - sizeof(struct virtio_net_hdr));
> 
>  		VIRTIO_DUMP_PACKET(rxm, rxm->pkt.data_len);
> 
> @@ -336,7 +338,7 @@ virtio_recv_pkts(void *rx_queue, struct
>  			rte_pktmbuf_free_seg(new_mbuf);
>  			break;
>  		}
> -		nb_enqueued ++;
> +		nb_enqueued++;
>  	}
>  	if (likely(nb_enqueued)) {
>  		if (unlikely(virtqueue_kick_prepare(rxvq))) {
> @@ -347,7 +349,7 @@ virtio_recv_pkts(void *rx_queue, struct
> 
>  	vq_update_avail_idx(rxvq);
> 
> -	return (nb_rx);
> +	return nb_rx;
>  }
> 
>  uint16_t
> @@ -362,7 +364,7 @@ virtio_xmit_pkts(void *tx_queue, struct
>  	nb_tx = 0;
> 
>  	if (unlikely(nb_pkts < 1))
> -		return (nb_pkts);
> +		return nb_pkts;
> 
>  	PMD_TX_LOG(DEBUG, "%d packets to xmit", nb_pkts);
>  	nb_used = VIRTQUEUE_NUSED(txvq);
> @@ -378,7 +380,7 @@ virtio_xmit_pkts(void *tx_queue, struct
>  			num--;
>  		}
> 
> -		if(!virtqueue_full(txvq)) {
> +		if (!virtqueue_full(txvq)) {
>  			txm = tx_pkts[nb_tx];
>  			/* Enqueue Packet buffers */
>  			error = virtqueue_enqueue_xmit(txvq, txm);
> @@ -405,10 +407,10 @@ virtio_xmit_pkts(void *tx_queue, struct
>  	hw->eth_stats.opackets += nb_tx;
>  	hw->eth_stats.q_opackets[txvq->queue_id] += nb_tx;
> 
> -	if(unlikely(virtqueue_kick_prepare(txvq))) {
> +	if (unlikely(virtqueue_kick_prepare(txvq))) {
>  		virtqueue_notify(txvq);
>  		PMD_TX_LOG(DEBUG, "Notified backend after xmit\n");
>  	}
> 
> -	return (nb_tx);
> +	return nb_tx;
>  }
> --- a/lib/librte_pmd_virtio/virtqueue.c	2014-06-12 17:41:20.305298960 -0700
> +++ b/lib/librte_pmd_virtio/virtqueue.c	2014-06-12 17:41:20.297298905 -0700
> @@ -60,11 +60,11 @@ virtqueue_detatch_unused(struct virtqueu
>  	struct rte_mbuf *cookie;
>  	int idx;
> 
> -	for(idx = 0; idx < vq->vq_nentries; idx++) {
> +	for (idx = 0; idx < vq->vq_nentries; idx++) {
>  		if ((cookie = vq->vq_descx[idx].cookie) != NULL) {
>  			vq->vq_descx[idx].cookie = NULL;
>  			return cookie;
>  		}
>  	}
> -	return (NULL);
> +	return NULL;
>  }
> --- a/lib/librte_pmd_virtio/virtio_pci.h	2014-06-12 17:38:02.843929358 -0700
> +++ b/lib/librte_pmd_virtio/virtio_pci.h	2014-06-12 17:46:57.739390234 -0700
> @@ -65,12 +65,12 @@ struct virtqueue;
>  #define VIRTIO_PCI_QUEUE_SEL      14 /* current VQ selection (16, RW) */
>  #define VIRTIO_PCI_QUEUE_NOTIFY   16 /* notify host regarding VQ (16, RW)
> */
>  #define VIRTIO_PCI_STATUS         18 /* device status register (8, RW) */
> -#define VIRTIO_PCI_ISR            19 /* interrupt status register, reading
> -                                      * also clears the register (8, RO) */
> +#define VIRTIO_PCI_ISR		  19 /* interrupt status register, reading
> +				      * also clears the register (8, RO) */
>  /* Only if MSIX is enabled: */
>  #define VIRTIO_MSI_CONFIG_VECTOR  20 /* configuration change vector (16,
> RW) */
> -#define VIRTIO_MSI_QUEUE_VECTOR   22 /* vector for selected VQ
> notifications
> -                                      (16, RW) */
> +#define VIRTIO_MSI_QUEUE_VECTOR	  22 /* vector for selected VQ
> notifications
> +				      (16, RW) */
> 
>  /* The bit of the ISR which indicates a device has an interrupt. */
>  #define VIRTIO_PCI_ISR_INTR   0x1
> @@ -255,7 +255,7 @@ outl_p(unsigned int data, unsigned int p
>  static inline int
>  vtpci_with_feature(struct virtio_hw *hw, uint32_t feature)
>  {
> -	return ((hw->guest_features & feature) != 0);
> +	return (hw->guest_features & feature) != 0;
>  }
> 
>  /*
> --- a/lib/librte_pmd_virtio/virtqueue.h	2014-06-12 17:38:02.843929358 -0700
> +++ b/lib/librte_pmd_virtio/virtqueue.h	2014-06-12 17:51:39.225042642 -0700
> @@ -209,12 +209,12 @@ void virtqueue_dump(struct virtqueue *vq
>  /**
>   *  Get all mbufs to be freed.
>   */
> -struct rte_mbuf * virtqueue_detatch_unused(struct virtqueue *vq);
> +struct rte_mbuf *virtqueue_detatch_unused(struct virtqueue *vq);
> 
>  static inline int
>  virtqueue_full(const struct virtqueue *vq)
>  {
> -	return (vq->vq_free_cnt == 0);
> +	return vq->vq_free_cnt == 0;
>  }
> 
>  #define VIRTQUEUE_NUSED(vq) ((uint16_t)((vq)->vq_ring.used->idx - (vq)-
> >vq_used_cons_idx))
> @@ -243,7 +243,7 @@ vq_update_avail_ring(struct virtqueue *v
>  }
> 
>  static inline int __attribute__((always_inline))
> -virtqueue_kick_prepare(struct virtqueue * vq)
> +virtqueue_kick_prepare(struct virtqueue *vq)
>  {
>  	return !(vq->vq_ring.used->flags & VRING_USED_F_NO_NOTIFY);
>  }
> @@ -298,18 +298,17 @@ virtqueue_enqueue_recv_refill(struct vir
>  {
>  	struct vq_desc_extra *dxp;
>  	struct vring_desc *start_dp;
> -	uint16_t needed;
> +	uint16_t needed = 1;
>  	uint16_t head_idx, idx;
> -	needed = 1;
> 
>  	if (unlikely(vq->vq_free_cnt == 0))
> -		return (-ENOSPC);
> +		return -ENOSPC;
>  	if (unlikely(vq->vq_free_cnt < needed))
> -		return (-EMSGSIZE);
> +		return -EMSGSIZE;
> 
>  	head_idx = vq->vq_desc_head_idx;
>  	if (unlikely(head_idx >= vq->vq_nentries))
> -		return (-EFAULT);
> +		return -EFAULT;
> 
>  	idx = head_idx;
>  	dxp = &vq->vq_descx[idx];
> @@ -328,7 +327,7 @@ virtqueue_enqueue_recv_refill(struct vir
>  	vq->vq_free_cnt = (uint16_t)(vq->vq_free_cnt - needed);
>  	vq_update_avail_ring(vq, head_idx);
> 
> -	return (0);
> +	return 0;
>  }
> 
>  static inline int __attribute__((always_inline))
> @@ -336,16 +335,16 @@ virtqueue_enqueue_xmit(struct virtqueue
>  {
>  	struct vq_desc_extra *dxp;
>  	struct vring_desc *start_dp;
> -	uint16_t needed;
> +	uint16_t needed = 2;
>  	uint16_t head_idx, idx;
> -	needed = 2;
> +
>  	if (unlikely(txvq->vq_free_cnt == 0))
> -		return (-ENOSPC);
> +		return -ENOSPC;
>  	if (unlikely(txvq->vq_free_cnt < needed))
> -		return (-EMSGSIZE);
> +		return -EMSGSIZE;
>  	head_idx = txvq->vq_desc_head_idx;
>  	if (unlikely(head_idx >= txvq->vq_nentries))
> -		return (-EFAULT);
> +		return -EFAULT;
> 
>  	idx = head_idx;
>  	dxp = &txvq->vq_descx[idx];
> @@ -369,7 +368,7 @@ virtqueue_enqueue_xmit(struct virtqueue
>  	txvq->vq_free_cnt = (uint16_t)(txvq->vq_free_cnt - needed);
>  	vq_update_avail_ring(txvq, head_idx);
> 
> -	return (0);
> +	return 0;
>  }
> 
>  static inline uint16_t __attribute__((always_inline))
> @@ -381,7 +380,7 @@ virtqueue_dequeue_burst_rx(struct virtqu
>  	uint16_t i;
> 
>  	/*  Caller does the check */
> -	for (i = 0; i < num ; i ++) {
> +	for (i = 0; i < num; i++) {
>  		used_idx = (uint16_t)(vq->vq_used_cons_idx & (vq->vq_nentries
> - 1));
>  		uep = &vq->vq_ring.used->ring[used_idx];
>  		desc_idx = (uint16_t) uep->id;
> @@ -402,7 +401,7 @@ virtqueue_dequeue_burst_rx(struct virtqu
>  		vq->vq_descx[desc_idx].cookie = NULL;
>  	}
> 
> -	return (i);
> +	return i;
>  }
> 
>  static inline uint16_t __attribute__((always_inline))
> @@ -420,7 +419,7 @@ virtqueue_dequeue_pkt_tx(struct virtqueu
>  	return 0;
>  }
> 
> -#ifdef  RTE_LIBRTE_VIRTIO_DEBUG_DUMP
> +#ifdef RTE_LIBRTE_VIRTIO_DEBUG_DUMP
>  #define VIRTQUEUE_DUMP(vq) do { \
>  	uint16_t used_idx, nused; \
>  	used_idx = (vq)->vq_ring.used->idx; \

  parent reply	other threads:[~2014-06-20 13:37 UTC|newest]

Thread overview: 5+ messages / expand[flat|nested]  mbox.gz  Atom feed  top
2014-06-13  1:32 Stephen Hemminger
2014-06-13  1:59 ` Ouyang, Changchun
2014-06-13  9:21 ` Thomas Monjalon
2014-06-20 13:34 ` Carew, Alan [this message]
2014-06-20 13:57   ` Thomas Monjalon

Reply instructions:

You may reply publicly to this message via plain-text email
using any one of the following methods:

* Save the following mbox file, import it into your mail client,
  and reply-to-all from there: mbox

  Avoid top-posting and favor interleaved quoting:
  https://en.wikipedia.org/wiki/Posting_style#Interleaved_style

* Reply using the --to, --cc, and --in-reply-to
  switches of git-send-email(1):

  git send-email \
    --in-reply-to=0E29434AEE0C3A4180987AB476A6F630593A81EC@IRSMSX101.ger.corp.intel.com \
    --to=alan.carew@intel.com \
    --cc=dev@dpdk.org \
    --cc=stephen@networkplumber.org \
    /path/to/YOUR_REPLY

  https://kernel.org/pub/software/scm/git/docs/git-send-email.html

* If your mail client supports setting the In-Reply-To header
  via mailto: links, try the mailto: link
Be sure your reply has a Subject: header at the top and a blank line before the message body.
This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for NNTP newsgroup(s).