[linux.git] / drivers / net / rionet.c

/*
 * rionet - Ethernet driver over RapidIO messaging services
 *
 * Copyright 2005 MontaVista Software, Inc.
 * Matt Porter <[email protected]>
 *
 * This program is free software; you can redistribute  it and/or modify it
 * under  the terms of  the GNU General  Public License as published by the
 * Free Software Foundation;  either version 2 of the  License, or (at your
 * option) any later version.
 */

#include <linux/module.h>
#include <linux/kernel.h>
#include <linux/dma-mapping.h>
#include <linux/delay.h>
#include <linux/rio.h>
#include <linux/rio_drv.h>
#include <linux/slab.h>
#include <linux/rio_ids.h>

#include <linux/netdevice.h>
#include <linux/etherdevice.h>
#include <linux/skbuff.h>
#include <linux/crc32.h>
#include <linux/ethtool.h>

#define DRV_NAME        "rionet"
#define DRV_VERSION     "0.3"
#define DRV_AUTHOR      "Matt Porter <[email protected]>"
#define DRV_DESC        "Ethernet over RapidIO"

MODULE_AUTHOR(DRV_AUTHOR);
MODULE_DESCRIPTION(DRV_DESC);
MODULE_LICENSE("GPL");

#define RIONET_DEFAULT_MSGLEVEL \
			(NETIF_MSG_DRV          | \
			 NETIF_MSG_LINK         | \
			 NETIF_MSG_RX_ERR       | \
			 NETIF_MSG_TX_ERR)

#define RIONET_DOORBELL_JOIN	0x1000
#define RIONET_DOORBELL_LEAVE	0x1001

#define RIONET_MAILBOX		0

#define RIONET_TX_RING_SIZE	CONFIG_RIONET_TX_SIZE
#define RIONET_RX_RING_SIZE	CONFIG_RIONET_RX_SIZE
#define RIONET_MAX_NETS		8

struct rionet_private {
	struct rio_mport *mport;
	struct sk_buff *rx_skb[RIONET_RX_RING_SIZE];
	struct sk_buff *tx_skb[RIONET_TX_RING_SIZE];
	int rx_slot;
	int tx_slot;
	int tx_cnt;
	int ack_slot;
	spinlock_t lock;
	spinlock_t tx_lock;
	u32 msg_enable;
};

struct rionet_peer {
	struct list_head node;
	struct rio_dev *rdev;
	struct resource *res;
};

struct rionet_net {
	struct net_device *ndev;
	struct list_head peers;
	struct rio_dev **active;
	int nact;	/* number of active peers */
};

static struct rionet_net nets[RIONET_MAX_NETS];

#define is_rionet_capable(src_ops, dst_ops)			\
			((src_ops & RIO_SRC_OPS_DATA_MSG) &&	\
			 (dst_ops & RIO_DST_OPS_DATA_MSG) &&	\
			 (src_ops & RIO_SRC_OPS_DOORBELL) &&	\
			 (dst_ops & RIO_DST_OPS_DOORBELL))
#define dev_rionet_capable(dev) \
	is_rionet_capable(dev->src_ops, dev->dst_ops)

#define RIONET_MAC_MATCH(x)	(!memcmp((x), "\00\01\00\01", 4))
#define RIONET_GET_DESTID(x)	((*((u8 *)x + 4) << 8) | *((u8 *)x + 5))

static int rionet_rx_clean(struct net_device *ndev)
{
	int i;
	int error = 0;
	struct rionet_private *rnet = netdev_priv(ndev);
	void *data;

	i = rnet->rx_slot;

	do {
		if (!rnet->rx_skb[i])
			continue;

		if (!(data = rio_get_inb_message(rnet->mport, RIONET_MAILBOX)))
			break;

		rnet->rx_skb[i]->data = data;
		skb_put(rnet->rx_skb[i], RIO_MAX_MSG_SIZE);
		rnet->rx_skb[i]->protocol =
		    eth_type_trans(rnet->rx_skb[i], ndev);
		error = netif_rx(rnet->rx_skb[i]);

		if (error == NET_RX_DROP) {
			ndev->stats.rx_dropped++;
		} else {
			ndev->stats.rx_packets++;
			ndev->stats.rx_bytes += RIO_MAX_MSG_SIZE;
		}

	} while ((i = (i + 1) % RIONET_RX_RING_SIZE) != rnet->rx_slot);

	return i;
}

static void rionet_rx_fill(struct net_device *ndev, int end)
{
	int i;
	struct rionet_private *rnet = netdev_priv(ndev);

	i = rnet->rx_slot;
	do {
		rnet->rx_skb[i] = dev_alloc_skb(RIO_MAX_MSG_SIZE);

		if (!rnet->rx_skb[i])
			break;

		rio_add_inb_buffer(rnet->mport, RIONET_MAILBOX,
				   rnet->rx_skb[i]->data);
	} while ((i = (i + 1) % RIONET_RX_RING_SIZE) != end);

	rnet->rx_slot = i;
}

static int rionet_queue_tx_msg(struct sk_buff *skb, struct net_device *ndev,
			       struct rio_dev *rdev)
{
	struct rionet_private *rnet = netdev_priv(ndev);

	rio_add_outb_message(rnet->mport, rdev, 0, skb->data, skb->len);
	rnet->tx_skb[rnet->tx_slot] = skb;

	ndev->stats.tx_packets++;
	ndev->stats.tx_bytes += skb->len;

	if (++rnet->tx_cnt == RIONET_TX_RING_SIZE)
		netif_stop_queue(ndev);

	++rnet->tx_slot;
	rnet->tx_slot &= (RIONET_TX_RING_SIZE - 1);

	if (netif_msg_tx_queued(rnet))
		printk(KERN_INFO "%s: queued skb len %8.8x\n", DRV_NAME,
		       skb->len);

	return 0;
}

static int rionet_start_xmit(struct sk_buff *skb, struct net_device *ndev)
{
	int i;
	struct rionet_private *rnet = netdev_priv(ndev);
	struct ethhdr *eth = (struct ethhdr *)skb->data;
	u16 destid;
	unsigned long flags;
	int add_num = 1;

	local_irq_save(flags);
	if (!spin_trylock(&rnet->tx_lock)) {
		local_irq_restore(flags);
		return NETDEV_TX_LOCKED;
	}

	if (is_multicast_ether_addr(eth->h_dest))
		add_num = nets[rnet->mport->id].nact;

	if ((rnet->tx_cnt + add_num) > RIONET_TX_RING_SIZE) {
		netif_stop_queue(ndev);
		spin_unlock_irqrestore(&rnet->tx_lock, flags);
		printk(KERN_ERR "%s: BUG! Tx Ring full when queue awake!\n",
		       ndev->name);
		return NETDEV_TX_BUSY;
	}

	if (is_multicast_ether_addr(eth->h_dest)) {
		int count = 0;

		for (i = 0; i < RIO_MAX_ROUTE_ENTRIES(rnet->mport->sys_size);
				i++)
			if (nets[rnet->mport->id].active[i]) {
				rionet_queue_tx_msg(skb, ndev,
					nets[rnet->mport->id].active[i]);
				if (count)
					atomic_inc(&skb->users);
				count++;
			}
	} else if (RIONET_MAC_MATCH(eth->h_dest)) {
		destid = RIONET_GET_DESTID(eth->h_dest);
		if (nets[rnet->mport->id].active[destid])
			rionet_queue_tx_msg(skb, ndev,
					nets[rnet->mport->id].active[destid]);
	}

	spin_unlock_irqrestore(&rnet->tx_lock, flags);

	return NETDEV_TX_OK;
}

static void rionet_dbell_event(struct rio_mport *mport, void *dev_id, u16 sid, u16 tid,
			       u16 info)
{
	struct net_device *ndev = dev_id;
	struct rionet_private *rnet = netdev_priv(ndev);
	struct rionet_peer *peer;

	if (netif_msg_intr(rnet))
		printk(KERN_INFO "%s: doorbell sid %4.4x tid %4.4x info %4.4x",
		       DRV_NAME, sid, tid, info);
	if (info == RIONET_DOORBELL_JOIN) {
		if (!nets[rnet->mport->id].active[sid]) {
			list_for_each_entry(peer,
					   &nets[rnet->mport->id].peers, node) {
				if (peer->rdev->destid == sid) {
					nets[rnet->mport->id].active[sid] =
								peer->rdev;
					nets[rnet->mport->id].nact++;
				}
			}
			rio_mport_send_doorbell(mport, sid,
						RIONET_DOORBELL_JOIN);
		}
	} else if (info == RIONET_DOORBELL_LEAVE) {
		nets[rnet->mport->id].active[sid] = NULL;
		nets[rnet->mport->id].nact--;
	} else {
		if (netif_msg_intr(rnet))
			printk(KERN_WARNING "%s: unhandled doorbell\n",
			       DRV_NAME);
	}
}

static void rionet_inb_msg_event(struct rio_mport *mport, void *dev_id, int mbox, int slot)
{
	int n;
	struct net_device *ndev = dev_id;
	struct rionet_private *rnet = netdev_priv(ndev);

	if (netif_msg_intr(rnet))
		printk(KERN_INFO "%s: inbound message event, mbox %d slot %d\n",
		       DRV_NAME, mbox, slot);

	spin_lock(&rnet->lock);
	if ((n = rionet_rx_clean(ndev)) != rnet->rx_slot)
		rionet_rx_fill(ndev, n);
	spin_unlock(&rnet->lock);
}

static void rionet_outb_msg_event(struct rio_mport *mport, void *dev_id, int mbox, int slot)
{
	struct net_device *ndev = dev_id;
	struct rionet_private *rnet = netdev_priv(ndev);

	spin_lock(&rnet->lock);

	if (netif_msg_intr(rnet))
		printk(KERN_INFO
		       "%s: outbound message event, mbox %d slot %d\n",
		       DRV_NAME, mbox, slot);

	while (rnet->tx_cnt && (rnet->ack_slot != slot)) {
		/* dma unmap single */
		dev_kfree_skb_irq(rnet->tx_skb[rnet->ack_slot]);
		rnet->tx_skb[rnet->ack_slot] = NULL;
		++rnet->ack_slot;
		rnet->ack_slot &= (RIONET_TX_RING_SIZE - 1);
		rnet->tx_cnt--;
	}

	if (rnet->tx_cnt < RIONET_TX_RING_SIZE)
		netif_wake_queue(ndev);

	spin_unlock(&rnet->lock);
}

static int rionet_open(struct net_device *ndev)
{
	int i, rc = 0;
	struct rionet_peer *peer, *tmp;
	struct rionet_private *rnet = netdev_priv(ndev);

	if (netif_msg_ifup(rnet))
		printk(KERN_INFO "%s: open\n", DRV_NAME);

	if ((rc = rio_request_inb_dbell(rnet->mport,
					(void *)ndev,
					RIONET_DOORBELL_JOIN,
					RIONET_DOORBELL_LEAVE,
					rionet_dbell_event)) < 0)
		goto out;

	if ((rc = rio_request_inb_mbox(rnet->mport,
				       (void *)ndev,
				       RIONET_MAILBOX,
				       RIONET_RX_RING_SIZE,
				       rionet_inb_msg_event)) < 0)
		goto out;

	if ((rc = rio_request_outb_mbox(rnet->mport,
					(void *)ndev,
					RIONET_MAILBOX,
					RIONET_TX_RING_SIZE,
					rionet_outb_msg_event)) < 0)
		goto out;

	/* Initialize inbound message ring */
	for (i = 0; i < RIONET_RX_RING_SIZE; i++)
		rnet->rx_skb[i] = NULL;
	rnet->rx_slot = 0;
	rionet_rx_fill(ndev, 0);

	rnet->tx_slot = 0;
	rnet->tx_cnt = 0;
	rnet->ack_slot = 0;

	netif_carrier_on(ndev);
	netif_start_queue(ndev);

	list_for_each_entry_safe(peer, tmp,
				 &nets[rnet->mport->id].peers, node) {
		if (!(peer->res = rio_request_outb_dbell(peer->rdev,
							 RIONET_DOORBELL_JOIN,
							 RIONET_DOORBELL_LEAVE)))
		{
			printk(KERN_ERR "%s: error requesting doorbells\n",
			       DRV_NAME);
			continue;
		}

		/* Send a join message */
		rio_send_doorbell(peer->rdev, RIONET_DOORBELL_JOIN);
	}

      out:
	return rc;
}

static int rionet_close(struct net_device *ndev)
{
	struct rionet_private *rnet = netdev_priv(ndev);
	struct rionet_peer *peer, *tmp;
	int i;

	if (netif_msg_ifup(rnet))
		printk(KERN_INFO "%s: close %s\n", DRV_NAME, ndev->name);

	netif_stop_queue(ndev);
	netif_carrier_off(ndev);

	for (i = 0; i < RIONET_RX_RING_SIZE; i++)
		kfree_skb(rnet->rx_skb[i]);

	list_for_each_entry_safe(peer, tmp,
				 &nets[rnet->mport->id].peers, node) {
		if (nets[rnet->mport->id].active[peer->rdev->destid]) {
			rio_send_doorbell(peer->rdev, RIONET_DOORBELL_LEAVE);
			nets[rnet->mport->id].active[peer->rdev->destid] = NULL;
		}
		rio_release_outb_dbell(peer->rdev, peer->res);
	}

	rio_release_inb_dbell(rnet->mport, RIONET_DOORBELL_JOIN,
			      RIONET_DOORBELL_LEAVE);
	rio_release_inb_mbox(rnet->mport, RIONET_MAILBOX);
	rio_release_outb_mbox(rnet->mport, RIONET_MAILBOX);

	return 0;
}

static void rionet_remove(struct rio_dev *rdev)
{
	struct net_device *ndev = rio_get_drvdata(rdev);
	unsigned char netid = rdev->net->hport->id;
	struct rionet_peer *peer, *tmp;

	unregister_netdev(ndev);

	free_pages((unsigned long)nets[netid].active, get_order(sizeof(void *) *
			RIO_MAX_ROUTE_ENTRIES(rdev->net->hport->sys_size)));
	nets[netid].active = NULL;

	list_for_each_entry_safe(peer, tmp, &nets[netid].peers, node) {
		list_del(&peer->node);
		kfree(peer);
	}

	free_netdev(ndev);
}

static void rionet_get_drvinfo(struct net_device *ndev,
			       struct ethtool_drvinfo *info)
{
	struct rionet_private *rnet = netdev_priv(ndev);

	strcpy(info->driver, DRV_NAME);
	strcpy(info->version, DRV_VERSION);
	strcpy(info->fw_version, "n/a");
	strcpy(info->bus_info, rnet->mport->name);
}

static u32 rionet_get_msglevel(struct net_device *ndev)
{
	struct rionet_private *rnet = netdev_priv(ndev);

	return rnet->msg_enable;
}

static void rionet_set_msglevel(struct net_device *ndev, u32 value)
{
	struct rionet_private *rnet = netdev_priv(ndev);

	rnet->msg_enable = value;
}

static const struct ethtool_ops rionet_ethtool_ops = {
	.get_drvinfo = rionet_get_drvinfo,
	.get_msglevel = rionet_get_msglevel,
	.set_msglevel = rionet_set_msglevel,
	.get_link = ethtool_op_get_link,
};

static const struct net_device_ops rionet_netdev_ops = {
	.ndo_open		= rionet_open,
	.ndo_stop		= rionet_close,
	.ndo_start_xmit		= rionet_start_xmit,
	.ndo_change_mtu		= eth_change_mtu,
	.ndo_validate_addr	= eth_validate_addr,
	.ndo_set_mac_address	= eth_mac_addr,
};

static int rionet_setup_netdev(struct rio_mport *mport, struct net_device *ndev)
{
	int rc = 0;
	struct rionet_private *rnet;
	u16 device_id;
	const size_t rionet_active_bytes = sizeof(void *) *
				RIO_MAX_ROUTE_ENTRIES(mport->sys_size);

	nets[mport->id].active = (struct rio_dev **)__get_free_pages(GFP_KERNEL,
						get_order(rionet_active_bytes));
	if (!nets[mport->id].active) {
		rc = -ENOMEM;
		goto out;
	}
	memset((void *)nets[mport->id].active, 0, rionet_active_bytes);

	/* Set up private area */
	rnet = netdev_priv(ndev);
	rnet->mport = mport;

	/* Set the default MAC address */
	device_id = rio_local_get_device_id(mport);
	ndev->dev_addr[0] = 0x00;
	ndev->dev_addr[1] = 0x01;
	ndev->dev_addr[2] = 0x00;
	ndev->dev_addr[3] = 0x01;
	ndev->dev_addr[4] = device_id >> 8;
	ndev->dev_addr[5] = device_id & 0xff;

	ndev->netdev_ops = &rionet_netdev_ops;
	ndev->mtu = RIO_MAX_MSG_SIZE - 14;
	ndev->features = NETIF_F_LLTX;
	SET_ETHTOOL_OPS(ndev, &rionet_ethtool_ops);

	spin_lock_init(&rnet->lock);
	spin_lock_init(&rnet->tx_lock);

	rnet->msg_enable = RIONET_DEFAULT_MSGLEVEL;

	rc = register_netdev(ndev);
	if (rc != 0)
		goto out;

	printk(KERN_INFO "%s: %s %s Version %s, MAC %pM, %s\n",
	       ndev->name,
	       DRV_NAME,
	       DRV_DESC,
	       DRV_VERSION,
	       ndev->dev_addr,
	       mport->name);

      out:
	return rc;
}

static unsigned long net_table[RIONET_MAX_NETS/sizeof(unsigned long) + 1];

static int rionet_probe(struct rio_dev *rdev, const struct rio_device_id *id)
{
	int rc = -ENODEV;
	u32 lsrc_ops, ldst_ops;
	struct rionet_peer *peer;
	struct net_device *ndev = NULL;
	unsigned char netid = rdev->net->hport->id;
	int oldnet;

	if (netid >= RIONET_MAX_NETS)
		return rc;

	oldnet = test_and_set_bit(netid, net_table);

	/*
	 * First time through, make sure local device is rionet
	 * capable, setup netdev (will be skipped on later probes)
	 */
	if (!oldnet) {
		rio_local_read_config_32(rdev->net->hport, RIO_SRC_OPS_CAR,
					 &lsrc_ops);
		rio_local_read_config_32(rdev->net->hport, RIO_DST_OPS_CAR,
					 &ldst_ops);
		if (!is_rionet_capable(lsrc_ops, ldst_ops)) {
			printk(KERN_ERR
			       "%s: local device %s is not network capable\n",
			       DRV_NAME, rdev->net->hport->name);
			goto out;
		}

		/* Allocate our net_device structure */
		ndev = alloc_etherdev(sizeof(struct rionet_private));
		if (ndev == NULL) {
			rc = -ENOMEM;
			goto out;
		}
		nets[netid].ndev = ndev;
		rc = rionet_setup_netdev(rdev->net->hport, ndev);
		INIT_LIST_HEAD(&nets[netid].peers);
		nets[netid].nact = 0;
	} else if (nets[netid].ndev == NULL)
		goto out;

	/*
	 * If the remote device has mailbox/doorbell capabilities,
	 * add it to the peer list.
	 */
	if (dev_rionet_capable(rdev)) {
		if (!(peer = kmalloc(sizeof(struct rionet_peer), GFP_KERNEL))) {
			rc = -ENOMEM;
			goto out;
		}
		peer->rdev = rdev;
		list_add_tail(&peer->node, &nets[netid].peers);
	}

	rio_set_drvdata(rdev, nets[netid].ndev);

      out:
	return rc;
}

static struct rio_device_id rionet_id_table[] = {
	{RIO_DEVICE(RIO_ANY_ID, RIO_ANY_ID)}
};

static struct rio_driver rionet_driver = {
	.name = "rionet",
	.id_table = rionet_id_table,
	.probe = rionet_probe,
	.remove = rionet_remove,
};

static int __init rionet_init(void)
{
	return rio_register_driver(&rionet_driver);
}

static void __exit rionet_exit(void)
{
	rio_unregister_driver(&rionet_driver);
}

late_initcall(rionet_init);
module_exit(rionet_exit);
Commit	Line	Data
f89efd52 MP	1	/*
	2	* rionet - Ethernet driver over RapidIO messaging services
	3	*
	4	* Copyright 2005 MontaVista Software, Inc.
	5	* Matt Porter <[email protected]>
	6	*
	7	* This program is free software; you can redistribute it and/or modify it
	8	* under the terms of the GNU General Public License as published by the
	9	* Free Software Foundation; either version 2 of the License, or (at your
	10	* option) any later version.
	11	*/
	12
	13	#include <linux/module.h>
	14	#include <linux/kernel.h>
	15	#include <linux/dma-mapping.h>
	16	#include <linux/delay.h>
	17	#include <linux/rio.h>
	18	#include <linux/rio_drv.h>
5a0e3ad6	19	#include <linux/slab.h>
f89efd52 MP	20	#include <linux/rio_ids.h>
	21
	22	#include <linux/netdevice.h>
	23	#include <linux/etherdevice.h>
	24	#include <linux/skbuff.h>
	25	#include <linux/crc32.h>
	26	#include <linux/ethtool.h>
	27
	28	#define DRV_NAME "rionet"
2fb717ec	29	#define DRV_VERSION "0.3"
f89efd52 MP	30	#define DRV_AUTHOR "Matt Porter <[email protected]>"
	31	#define DRV_DESC "Ethernet over RapidIO"
	32
	33	MODULE_AUTHOR(DRV_AUTHOR);
	34	MODULE_DESCRIPTION(DRV_DESC);
	35	MODULE_LICENSE("GPL");
	36
	37	#define RIONET_DEFAULT_MSGLEVEL \
	38	(NETIF_MSG_DRV \| \
	39	NETIF_MSG_LINK \| \
	40	NETIF_MSG_RX_ERR \| \
	41	NETIF_MSG_TX_ERR)
	42
	43	#define RIONET_DOORBELL_JOIN 0x1000
	44	#define RIONET_DOORBELL_LEAVE 0x1001
	45
	46	#define RIONET_MAILBOX 0
	47
	48	#define RIONET_TX_RING_SIZE CONFIG_RIONET_TX_SIZE
	49	#define RIONET_RX_RING_SIZE CONFIG_RIONET_RX_SIZE
2fb717ec	50	#define RIONET_MAX_NETS 8
f89efd52 MP	51
	52	struct rionet_private {
	53	struct rio_mport *mport;
	54	struct sk_buff *rx_skb[RIONET_RX_RING_SIZE];
	55	struct sk_buff *tx_skb[RIONET_TX_RING_SIZE];
f89efd52 MP	56	int rx_slot;
	57	int tx_slot;
	58	int tx_cnt;
	59	int ack_slot;
	60	spinlock_t lock;
	61	spinlock_t tx_lock;
	62	u32 msg_enable;
	63	};
	64
	65	struct rionet_peer {
	66	struct list_head node;
	67	struct rio_dev *rdev;
	68	struct resource *res;
	69	};
	70
2fb717ec AB	71	struct rionet_net {
	72	struct net_device *ndev;
	73	struct list_head peers;
	74	struct rio_dev **active;
	75	int nact; /* number of active peers */
	76	};
f89efd52	77
2fb717ec	78	static struct rionet_net nets[RIONET_MAX_NETS];
f89efd52	79
284fb68d AB	80	#define is_rionet_capable(src_ops, dst_ops) \
	81	((src_ops & RIO_SRC_OPS_DATA_MSG) && \
	82	(dst_ops & RIO_DST_OPS_DATA_MSG) && \
f89efd52 MP	83	(src_ops & RIO_SRC_OPS_DOORBELL) && \
	84	(dst_ops & RIO_DST_OPS_DOORBELL))
	85	#define dev_rionet_capable(dev) \
284fb68d	86	is_rionet_capable(dev->src_ops, dev->dst_ops)
f89efd52	87
e0c87bd9 AB	88	#define RIONET_MAC_MATCH(x) (!memcmp((x), "\00\01\00\01", 4))
e0c87bd9 AB	89	#define RIONET_GET_DESTID(x) ((((u8 )x + 4) << 8) \| ((u8 )x + 5))
f89efd52	90
f89efd52 MP	91	static int rionet_rx_clean(struct net_device *ndev)
	92	{
	93	int i;
	94	int error = 0;
4cf1653a	95	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	96	void *data;
	97
	98	i = rnet->rx_slot;
	99
	100	do {
	101	if (!rnet->rx_skb[i])
	102	continue;
	103
	104	if (!(data = rio_get_inb_message(rnet->mport, RIONET_MAILBOX)))
	105	break;
	106
	107	rnet->rx_skb[i]->data = data;
	108	skb_put(rnet->rx_skb[i], RIO_MAX_MSG_SIZE);
f89efd52 MP	109	rnet->rx_skb[i]->protocol =
	110	eth_type_trans(rnet->rx_skb[i], ndev);
	111	error = netif_rx(rnet->rx_skb[i]);
	112
	113	if (error == NET_RX_DROP) {
09f75cd7	114	ndev->stats.rx_dropped++;
f89efd52	115	} else {
09f75cd7 JG	116	ndev->stats.rx_packets++;
09f75cd7 JG	117	ndev->stats.rx_bytes += RIO_MAX_MSG_SIZE;
f89efd52 MP	118	}
	119
	120	} while ((i = (i + 1) % RIONET_RX_RING_SIZE) != rnet->rx_slot);
	121
	122	return i;
	123	}
	124
	125	static void rionet_rx_fill(struct net_device *ndev, int end)
	126	{
	127	int i;
4cf1653a	128	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	129
	130	i = rnet->rx_slot;
	131	do {
	132	rnet->rx_skb[i] = dev_alloc_skb(RIO_MAX_MSG_SIZE);
	133
	134	if (!rnet->rx_skb[i])
	135	break;
	136
	137	rio_add_inb_buffer(rnet->mport, RIONET_MAILBOX,
	138	rnet->rx_skb[i]->data);
	139	} while ((i = (i + 1) % RIONET_RX_RING_SIZE) != end);
	140
	141	rnet->rx_slot = i;
	142	}
	143
	144	static int rionet_queue_tx_msg(struct sk_buff skb, struct net_device ndev,
	145	struct rio_dev *rdev)
	146	{
4cf1653a	147	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	148
	149	rio_add_outb_message(rnet->mport, rdev, 0, skb->data, skb->len);
	150	rnet->tx_skb[rnet->tx_slot] = skb;
	151
09f75cd7 JG	152	ndev->stats.tx_packets++;
09f75cd7 JG	153	ndev->stats.tx_bytes += skb->len;
f89efd52 MP	154
	155	if (++rnet->tx_cnt == RIONET_TX_RING_SIZE)
	156	netif_stop_queue(ndev);
	157
	158	++rnet->tx_slot;
	159	rnet->tx_slot &= (RIONET_TX_RING_SIZE - 1);
	160
	161	if (netif_msg_tx_queued(rnet))
8df8a475 DM	162	printk(KERN_INFO "%s: queued skb len %8.8x\n", DRV_NAME,
8df8a475 DM	163	skb->len);
f89efd52 MP	164
	165	return 0;
	166	}
	167
	168	static int rionet_start_xmit(struct sk_buff skb, struct net_device ndev)
	169	{
	170	int i;
4cf1653a	171	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	172	struct ethhdr eth = (struct ethhdr )skb->data;
	173	u16 destid;
	174	unsigned long flags;
7c4a6106	175	int add_num = 1;
f89efd52 MP	176
	177	local_irq_save(flags);
	178	if (!spin_trylock(&rnet->tx_lock)) {
	179	local_irq_restore(flags);
	180	return NETDEV_TX_LOCKED;
	181	}
	182
7c4a6106	183	if (is_multicast_ether_addr(eth->h_dest))
2fb717ec	184	add_num = nets[rnet->mport->id].nact;
7c4a6106 AB	185
7c4a6106 AB	186	if ((rnet->tx_cnt + add_num) > RIONET_TX_RING_SIZE) {
f89efd52 MP	187	netif_stop_queue(ndev);
	188	spin_unlock_irqrestore(&rnet->tx_lock, flags);
	189	printk(KERN_ERR "%s: BUG! Tx Ring full when queue awake!\n",
	190	ndev->name);
	191	return NETDEV_TX_BUSY;
	192	}
	193
abfc89c7	194	if (is_multicast_ether_addr(eth->h_dest)) {
7c4a6106	195	int count = 0;
2fb717ec	196
e0423236 ZW	197	for (i = 0; i < RIO_MAX_ROUTE_ENTRIES(rnet->mport->sys_size);
e0423236 ZW	198	i++)
2fb717ec	199	if (nets[rnet->mport->id].active[i]) {
f89efd52	200	rionet_queue_tx_msg(skb, ndev,
2fb717ec	201	nets[rnet->mport->id].active[i]);
7c4a6106 AB	202	if (count)
	203	atomic_inc(&skb->users);
	204	count++;
	205	}
f89efd52 MP	206	} else if (RIONET_MAC_MATCH(eth->h_dest)) {
f89efd52 MP	207	destid = RIONET_GET_DESTID(eth->h_dest);
2fb717ec AB	208	if (nets[rnet->mport->id].active[destid])
	209	rionet_queue_tx_msg(skb, ndev,
	210	nets[rnet->mport->id].active[destid]);
f89efd52 MP	211	}
	212
	213	spin_unlock_irqrestore(&rnet->tx_lock, flags);
	214
6ed10654	215	return NETDEV_TX_OK;
f89efd52 MP	216	}
	217
	218	static void rionet_dbell_event(struct rio_mport mport, void dev_id, u16 sid, u16 tid,
	219	u16 info)
	220	{
	221	struct net_device *ndev = dev_id;
4cf1653a	222	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	223	struct rionet_peer *peer;
	224
	225	if (netif_msg_intr(rnet))
	226	printk(KERN_INFO "%s: doorbell sid %4.4x tid %4.4x info %4.4x",
	227	DRV_NAME, sid, tid, info);
	228	if (info == RIONET_DOORBELL_JOIN) {
2fb717ec AB	229	if (!nets[rnet->mport->id].active[sid]) {
	230	list_for_each_entry(peer,
	231	&nets[rnet->mport->id].peers, node) {
7c4a6106	232	if (peer->rdev->destid == sid) {
2fb717ec AB	233	nets[rnet->mport->id].active[sid] =
	234	peer->rdev;
	235	nets[rnet->mport->id].nact++;
7c4a6106	236	}
f89efd52 MP	237	}
	238	rio_mport_send_doorbell(mport, sid,
	239	RIONET_DOORBELL_JOIN);
	240	}
	241	} else if (info == RIONET_DOORBELL_LEAVE) {
2fb717ec AB	242	nets[rnet->mport->id].active[sid] = NULL;
2fb717ec AB	243	nets[rnet->mport->id].nact--;
f89efd52 MP	244	} else {
	245	if (netif_msg_intr(rnet))
	246	printk(KERN_WARNING "%s: unhandled doorbell\n",
	247	DRV_NAME);
	248	}
	249	}
	250
	251	static void rionet_inb_msg_event(struct rio_mport mport, void dev_id, int mbox, int slot)
	252	{
	253	int n;
	254	struct net_device *ndev = dev_id;
4cf1653a	255	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	256
	257	if (netif_msg_intr(rnet))
	258	printk(KERN_INFO "%s: inbound message event, mbox %d slot %d\n",
	259	DRV_NAME, mbox, slot);
	260
	261	spin_lock(&rnet->lock);
	262	if ((n = rionet_rx_clean(ndev)) != rnet->rx_slot)
	263	rionet_rx_fill(ndev, n);
	264	spin_unlock(&rnet->lock);
	265	}
	266
	267	static void rionet_outb_msg_event(struct rio_mport mport, void dev_id, int mbox, int slot)
	268	{
	269	struct net_device *ndev = dev_id;
4cf1653a	270	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	271
	272	spin_lock(&rnet->lock);
	273
	274	if (netif_msg_intr(rnet))
	275	printk(KERN_INFO
	276	"%s: outbound message event, mbox %d slot %d\n",
	277	DRV_NAME, mbox, slot);
	278
	279	while (rnet->tx_cnt && (rnet->ack_slot != slot)) {
	280	/* dma unmap single */
	281	dev_kfree_skb_irq(rnet->tx_skb[rnet->ack_slot]);
	282	rnet->tx_skb[rnet->ack_slot] = NULL;
	283	++rnet->ack_slot;
	284	rnet->ack_slot &= (RIONET_TX_RING_SIZE - 1);
	285	rnet->tx_cnt--;
	286	}
	287
	288	if (rnet->tx_cnt < RIONET_TX_RING_SIZE)
	289	netif_wake_queue(ndev);
	290
	291	spin_unlock(&rnet->lock);
	292	}
	293
	294	static int rionet_open(struct net_device *ndev)
	295	{
	296	int i, rc = 0;
	297	struct rionet_peer peer, tmp;
4cf1653a	298	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	299
	300	if (netif_msg_ifup(rnet))
	301	printk(KERN_INFO "%s: open\n", DRV_NAME);
	302
	303	if ((rc = rio_request_inb_dbell(rnet->mport,
	304	(void *)ndev,
	305	RIONET_DOORBELL_JOIN,
	306	RIONET_DOORBELL_LEAVE,
	307	rionet_dbell_event)) < 0)
	308	goto out;
	309
	310	if ((rc = rio_request_inb_mbox(rnet->mport,
	311	(void *)ndev,
	312	RIONET_MAILBOX,
	313	RIONET_RX_RING_SIZE,
	314	rionet_inb_msg_event)) < 0)
	315	goto out;
	316
	317	if ((rc = rio_request_outb_mbox(rnet->mport,
	318	(void *)ndev,
	319	RIONET_MAILBOX,
	320	RIONET_TX_RING_SIZE,
	321	rionet_outb_msg_event)) < 0)
	322	goto out;
	323
	324	/* Initialize inbound message ring */
	325	for (i = 0; i < RIONET_RX_RING_SIZE; i++)
	326	rnet->rx_skb[i] = NULL;
	327	rnet->rx_slot = 0;
	328	rionet_rx_fill(ndev, 0);
	329
	330	rnet->tx_slot = 0;
	331	rnet->tx_cnt = 0;
	332	rnet->ack_slot = 0;
	333
	334	netif_carrier_on(ndev);
	335	netif_start_queue(ndev);
	336
2fb717ec AB	337	list_for_each_entry_safe(peer, tmp,
2fb717ec AB	338	&nets[rnet->mport->id].peers, node) {
f89efd52 MP	339	if (!(peer->res = rio_request_outb_dbell(peer->rdev,
	340	RIONET_DOORBELL_JOIN,
	341	RIONET_DOORBELL_LEAVE)))
	342	{
	343	printk(KERN_ERR "%s: error requesting doorbells\n",
	344	DRV_NAME);
	345	continue;
	346	}
	347
284fb68d AB	348	/* Send a join message */
284fb68d AB	349	rio_send_doorbell(peer->rdev, RIONET_DOORBELL_JOIN);
f89efd52 MP	350	}
	351
	352	out:
	353	return rc;
	354	}
	355
	356	static int rionet_close(struct net_device *ndev)
	357	{
4cf1653a	358	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	359	struct rionet_peer peer, tmp;
	360	int i;
	361
	362	if (netif_msg_ifup(rnet))
2fb717ec	363	printk(KERN_INFO "%s: close %s\n", DRV_NAME, ndev->name);
f89efd52 MP	364
	365	netif_stop_queue(ndev);
	366	netif_carrier_off(ndev);
	367
	368	for (i = 0; i < RIONET_RX_RING_SIZE; i++)
aaff1e19	369	kfree_skb(rnet->rx_skb[i]);
f89efd52	370
2fb717ec AB	371	list_for_each_entry_safe(peer, tmp,
	372	&nets[rnet->mport->id].peers, node) {
	373	if (nets[rnet->mport->id].active[peer->rdev->destid]) {
f89efd52	374	rio_send_doorbell(peer->rdev, RIONET_DOORBELL_LEAVE);
2fb717ec	375	nets[rnet->mport->id].active[peer->rdev->destid] = NULL;
f89efd52 MP	376	}
	377	rio_release_outb_dbell(peer->rdev, peer->res);
	378	}
	379
	380	rio_release_inb_dbell(rnet->mport, RIONET_DOORBELL_JOIN,
	381	RIONET_DOORBELL_LEAVE);
	382	rio_release_inb_mbox(rnet->mport, RIONET_MAILBOX);
	383	rio_release_outb_mbox(rnet->mport, RIONET_MAILBOX);
	384
	385	return 0;
	386	}
	387
	388	static void rionet_remove(struct rio_dev *rdev)
	389	{
55caa924	390	struct net_device *ndev = rio_get_drvdata(rdev);
2fb717ec	391	unsigned char netid = rdev->net->hport->id;
f89efd52 MP	392	struct rionet_peer peer, tmp;
	393
	394	unregister_netdev(ndev);
f89efd52	395
2fb717ec AB	396	free_pages((unsigned long)nets[netid].active, get_order(sizeof(void )
	397	RIO_MAX_ROUTE_ENTRIES(rdev->net->hport->sys_size)));
	398	nets[netid].active = NULL;
	399
	400	list_for_each_entry_safe(peer, tmp, &nets[netid].peers, node) {
f89efd52 MP	401	list_del(&peer->node);
	402	kfree(peer);
	403	}
2fb717ec AB	404
2fb717ec AB	405	free_netdev(ndev);
f89efd52 MP	406	}
	407
	408	static void rionet_get_drvinfo(struct net_device *ndev,
	409	struct ethtool_drvinfo *info)
	410	{
4cf1653a	411	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	412
	413	strcpy(info->driver, DRV_NAME);
	414	strcpy(info->version, DRV_VERSION);
	415	strcpy(info->fw_version, "n/a");
	416	strcpy(info->bus_info, rnet->mport->name);
	417	}
	418
	419	static u32 rionet_get_msglevel(struct net_device *ndev)
	420	{
4cf1653a	421	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	422
	423	return rnet->msg_enable;
	424	}
	425
	426	static void rionet_set_msglevel(struct net_device *ndev, u32 value)
	427	{
4cf1653a	428	struct rionet_private *rnet = netdev_priv(ndev);
f89efd52 MP	429
	430	rnet->msg_enable = value;
	431	}
	432
7282d491	433	static const struct ethtool_ops rionet_ethtool_ops = {
f89efd52 MP	434	.get_drvinfo = rionet_get_drvinfo,
	435	.get_msglevel = rionet_get_msglevel,
	436	.set_msglevel = rionet_set_msglevel,
	437	.get_link = ethtool_op_get_link,
	438	};
	439
a33a2bb3 AB	440	static const struct net_device_ops rionet_netdev_ops = {
	441	.ndo_open = rionet_open,
	442	.ndo_stop = rionet_close,
	443	.ndo_start_xmit = rionet_start_xmit,
	444	.ndo_change_mtu = eth_change_mtu,
	445	.ndo_validate_addr = eth_validate_addr,
	446	.ndo_set_mac_address = eth_mac_addr,
	447	};
	448
55caa924	449	static int rionet_setup_netdev(struct rio_mport mport, struct net_device ndev)
f89efd52 MP	450	{
f89efd52 MP	451	int rc = 0;
f89efd52 MP	452	struct rionet_private *rnet;
f89efd52 MP	453	u16 device_id;
acc65632 AM	454	const size_t rionet_active_bytes = sizeof(void )
acc65632 AM	455	RIO_MAX_ROUTE_ENTRIES(mport->sys_size);
f89efd52	456
2fb717ec AB	457	nets[mport->id].active = (struct rio_dev **)__get_free_pages(GFP_KERNEL,
	458	get_order(rionet_active_bytes));
	459	if (!nets[mport->id].active) {
e0423236 ZW	460	rc = -ENOMEM;
	461	goto out;
	462	}
2fb717ec	463	memset((void *)nets[mport->id].active, 0, rionet_active_bytes);
e0423236	464
f89efd52	465	/* Set up private area */
4cf1653a	466	rnet = netdev_priv(ndev);
f89efd52 MP	467	rnet->mport = mport;
	468
	469	/* Set the default MAC address */
	470	device_id = rio_local_get_device_id(mport);
	471	ndev->dev_addr[0] = 0x00;
	472	ndev->dev_addr[1] = 0x01;
	473	ndev->dev_addr[2] = 0x00;
	474	ndev->dev_addr[3] = 0x01;
	475	ndev->dev_addr[4] = device_id >> 8;
	476	ndev->dev_addr[5] = device_id & 0xff;
	477
a33a2bb3	478	ndev->netdev_ops = &rionet_netdev_ops;
f89efd52 MP	479	ndev->mtu = RIO_MAX_MSG_SIZE - 14;
	480	ndev->features = NETIF_F_LLTX;
	481	SET_ETHTOOL_OPS(ndev, &rionet_ethtool_ops);
	482
f89efd52 MP	483	spin_lock_init(&rnet->lock);
	484	spin_lock_init(&rnet->tx_lock);
	485
	486	rnet->msg_enable = RIONET_DEFAULT_MSGLEVEL;
	487
	488	rc = register_netdev(ndev);
	489	if (rc != 0)
	490	goto out;
	491
2fb717ec	492	printk(KERN_INFO "%s: %s %s Version %s, MAC %pM, %s\n",
f89efd52 MP	493	ndev->name,
	494	DRV_NAME,
	495	DRV_DESC,
	496	DRV_VERSION,
2fb717ec AB	497	ndev->dev_addr,
2fb717ec AB	498	mport->name);
f89efd52 MP	499
	500	out:
	501	return rc;
	502	}
	503
2fb717ec AB	504	static unsigned long net_table[RIONET_MAX_NETS/sizeof(unsigned long) + 1];
2fb717ec AB	505
f89efd52 MP	506	static int rionet_probe(struct rio_dev rdev, const struct rio_device_id id)
	507	{
	508	int rc = -ENODEV;
284fb68d	509	u32 lsrc_ops, ldst_ops;
f89efd52	510	struct rionet_peer *peer;
55caa924	511	struct net_device *ndev = NULL;
2fb717ec AB	512	unsigned char netid = rdev->net->hport->id;
2fb717ec AB	513	int oldnet;
f89efd52	514
2fb717ec AB	515	if (netid >= RIONET_MAX_NETS)
2fb717ec AB	516	return rc;
f89efd52	517
2fb717ec	518	oldnet = test_and_set_bit(netid, net_table);
55caa924	519
f89efd52 MP	520	/*
f89efd52 MP	521	* First time through, make sure local device is rionet
2fb717ec	522	* capable, setup netdev (will be skipped on later probes)
f89efd52	523	*/
2fb717ec	524	if (!oldnet) {
f89efd52 MP	525	rio_local_read_config_32(rdev->net->hport, RIO_SRC_OPS_CAR,
	526	&lsrc_ops);
	527	rio_local_read_config_32(rdev->net->hport, RIO_DST_OPS_CAR,
	528	&ldst_ops);
284fb68d	529	if (!is_rionet_capable(lsrc_ops, ldst_ops)) {
f89efd52	530	printk(KERN_ERR
2fb717ec AB	531	"%s: local device %s is not network capable\n",
2fb717ec AB	532	DRV_NAME, rdev->net->hport->name);
f89efd52 MP	533	goto out;
	534	}
	535
2fb717ec AB	536	/* Allocate our net_device structure */
	537	ndev = alloc_etherdev(sizeof(struct rionet_private));
	538	if (ndev == NULL) {
	539	rc = -ENOMEM;
	540	goto out;
	541	}
	542	nets[netid].ndev = ndev;
55caa924	543	rc = rionet_setup_netdev(rdev->net->hport, ndev);
2fb717ec AB	544	INIT_LIST_HEAD(&nets[netid].peers);
	545	nets[netid].nact = 0;
	546	} else if (nets[netid].ndev == NULL)
	547	goto out;
f89efd52 MP	548
	549	/*
	550	* If the remote device has mailbox/doorbell capabilities,
	551	* add it to the peer list.
	552	*/
	553	if (dev_rionet_capable(rdev)) {
	554	if (!(peer = kmalloc(sizeof(struct rionet_peer), GFP_KERNEL))) {
	555	rc = -ENOMEM;
	556	goto out;
	557	}
	558	peer->rdev = rdev;
2fb717ec	559	list_add_tail(&peer->node, &nets[netid].peers);
f89efd52 MP	560	}
f89efd52 MP	561
2fb717ec	562	rio_set_drvdata(rdev, nets[netid].ndev);
55caa924	563
f89efd52 MP	564	out:
	565	return rc;
	566	}
	567
	568	static struct rio_device_id rionet_id_table[] = {
	569	{RIO_DEVICE(RIO_ANY_ID, RIO_ANY_ID)}
	570	};
	571
	572	static struct rio_driver rionet_driver = {
	573	.name = "rionet",
	574	.id_table = rionet_id_table,
	575	.probe = rionet_probe,
	576	.remove = rionet_remove,
	577	};
	578
	579	static int __init rionet_init(void)
	580	{
	581	return rio_register_driver(&rionet_driver);
	582	}
	583
	584	static void __exit rionet_exit(void)
	585	{
	586	rio_unregister_driver(&rionet_driver);
	587	}
	588
2f809985	589	late_initcall(rionet_init);
f89efd52	590	module_exit(rionet_exit);