399
网络子系统22_队列规则传输接口
// 调用路径：
// 1.dev_queue_xmit->qdisc_run
// 2.net_tx_action->qdisc_run
// 对于dev->tx_queue_len !=0 的设备，都会有一个与之关联的队列规则，按照队列规则，调用dev->hard_start_xmit
1.1 static inline void qdisc_run(struct net_device *dev)
{
//设备传输队列没有被关闭，即__LINK_STATE_XOFF没有被设置
//结合规则队列完成传输
while (!netif_queue_stopped(dev) && qdisc_restart(dev) < 0);
}
// 结合设备关联的队列规则，完成数据传输
// 调用路径：qdisc_run->qdisc_restart
// 返回值: =0 - queue is empty.
// >0 - queue is not empty, but throttled.
// <0 - queue is not empty. Device is throttled, if dev->tbusy != 0.
// 函数流程：
// 1.使用队列规则出队skb
// 2.对dev->xmit_lock加锁
// 3.检测死锁与冲突；
// 3.1 死锁：锁已被占用，占用者为本cpu，释放skb，返回
// 3.2 冲突：锁被占用，非本cpu，重入队skb，重调度设备
// 4.设置锁的拥有者为本cpu
// 5.对dev->queue_lock解锁
// 6.向ETH_P_ALL类型l3协议传递此skb
// 7.通过驱动程序hard_start_xmit完成传输
// 8.对dev->queue_lock加锁
// 9.对dev->xmit_lock解锁
1.2 int qdisc_restart(struct net_device *dev)
{
//与设备相关的队列规则
struct Qdisc *q = dev->qdisc;
struct sk_buff *skb;
//从规则队列出队skb
if ((skb = q->dequeue(q)) != NULL) {
//驱动特性：NETIF_F_LLTX，表明驱动在被调用hard_start_xmit时不需要上锁
unsigned nolock = (dev->features & NETIF_F_LLTX);
if (!nolock) {//需要上锁
if (!spin_trylock(&dev->xmit_lock)) {//锁已经被获取
collision:
//死锁：
// 锁被占用，但是拥有者为本cpu，将skb丢掉，直接返回-1
if (dev->xmit_lock_owner == smp_processor_id()) {
kfree_skb(skb);
return -1;
}
//冲突：
// 将skb重新入队
goto requeue;
}
//获取锁，将锁的拥有者设置为本cpu
dev->xmit_lock_owner = smp_processor_id();
}
{
spin_unlock(&dev->queue_lock);
if (!netif_queue_stopped(dev)) {//设备可以进行传输
int ret;
//netdev_nit表示ETH_P_ALL类型l3协议的个数
if (netdev_nit)
dev_queue_xmit_nit(skb, dev);
//由驱动程序完成传输
ret = dev->hard_start_xmit(skb, dev);
if (ret == NETDEV_TX_OK) {
if (!nolock) {
dev->xmit_lock_owner = -1;
spin_unlock(&dev->xmit_lock);
}
spin_lock(&dev->queue_lock);
return -1;
}
if (ret == NETDEV_TX_LOCKED && nolock) {
spin_lock(&dev->queue_lock);
goto collision;
}
}
if (!nolock) {
dev->xmit_lock_owner = -1;
spin_unlock(&dev->xmit_lock);
}
spin_lock(&dev->queue_lock);
q = dev->qdisc;
}
requeue:
//将skb重新入队
q->ops->requeue(skb, q);
//调度设备
netif_schedule(dev);
return 1;
}
//返回规则队列中剩余的skb个数
return q->q.qlen;
}
最后更新：2017-04-03 15:22:11