+void netpoll_poll(struct netpoll *np)
+{
+ int budget = 1;
+
+ if(!np || !np->dev || !(np->dev->flags & IFF_UP))
+ return;
+ disable_irq(np->dev->irq);
+
+ /* Process pending work on NIC */
+ np->irqfunc(np->dev->irq, np->dev, 0);
+
+ /* If scheduling is stopped, tickle NAPI bits */
+ if(trapped && np->dev->poll &&
+ test_bit(__LINK_STATE_RX_SCHED, &np->dev->state))
+ np->dev->poll(np->dev, &budget);
+
+ enable_irq(np->dev->irq);
+}
+static void refill_skbs(void)
+{
+ struct sk_buff *skb;
+ unsigned long flags;
+
+ spin_lock_irqsave(&skb_list_lock, flags);
+ while (nr_skbs < MAX_SKBS) {
+ skb = alloc_skb(MAX_SKB_SIZE, GFP_ATOMIC);
+ if (!skb)
+ break;
+
+ skb->next = skbs;
+ skbs = skb;
+ nr_skbs++;
+ }
+ spin_unlock_irqrestore(&skb_list_lock, flags);
+}
+static void zap_completion_queue(void)
+{
+ unsigned long flags;
+ struct softnet_data *sd = &get_cpu_var(softnet_data);
+
+ if (sd->completion_queue) {
+ struct sk_buff *clist;
+
+ local_irq_save(flags);
+ clist = sd->completion_queue;
+ sd->completion_queue = NULL;
+ local_irq_save(flags);
+
+ while (clist != NULL) {
+ struct sk_buff *skb = clist;
+ clist = clist->next;
+ __kfree_skb(skb);
+ }
+ }
+
+ put_cpu_var(softnet_data);
+}
+void netpoll_send_skb(struct netpoll *np, struct sk_buff *skb)
+{
+ int status;
+
+repeat:
+ if(!np || !np->dev || !(np->dev->flags & IFF_UP)) {
+ spin_lock(&np->dev->xmit_lock);
+ np->dev->xmit_lock_owner = smp_processor_id();
+
+ if (netif_queue_stopped(np->dev)) {
+ np->dev->xmit_lock_owner = -1;
+ spin_unlock(&np->dev->xmit_lock);
+
+ netpoll_poll(np);
+ zap_completion_queue();
+ goto repeat;
+ }
+
+ status = np->dev->hard_start_xmit(skb, np->dev);
+ np->dev->xmit_lock_owner = -1;
+ spin_unlock(&np->dev->xmit_lock);
+static int rx_hook(struct sk_buff *skb)[...]
diff -puN include/linux/netdevice.h~netpoll-core include/linux/netdevice.h[...]
--- l/include/linux/netdevice.h~netpoll-core 2003-09-22 13:15:31.000000000 -0500
+++ l-mpm/include/linux/netdevice.h 2003-09-22 13:15:31.000000000 -0500
@@ -452,13 +452,13 @@ struct net_device
unsigned char *haddr);
int (*neigh_setup)(struct net_device *dev, struct neigh_parms *);
int (*accept_fastpath)(struct net_device *, struct dst_entry*);
+#ifdef CONFIG_NETPOLL
+ int (*rx_hook)(struct sk_buff *skb);
+#endif
diff -puN net/core/dev.c~netpoll-core net/core/dev.c[...]
--- l/net/core/dev.c~netpoll-core 2003-09-22 13:15:31.000000000 -0500
+++ l-mpm/net/core/dev.c 2003-09-22 13:16:34.000000000 -0500
@@ -1552,6 +1541,13 @@ int netif_receive_skb(struct sk_buff *sk
int ret = NET_RX_DROP;
unsigned short type = skb->protocol;
+#ifdef CONFIG_NETPOLL
+ if (skb->dev->rx_hook && skb->dev->rx_hook(skb)) {
+ kfree_skb(skb);
+ return NET_RX_DROP;
+ }
+#endif