LKCD Network dump over netpoll patch (2.6.0-test9)
From: Prasanna S Panchamukhi
Date: Mon Nov 10 2003 - 09:04:27 EST
Hi,
Please ignore by previous mail. Below is the actual lkcd-netpoll.patch
This patch includes LKCD networkdump code changes over netpoll API's for
kernel version 2.6.0-test9. Both the netconsole and network dumping can be
achieved. Procedure for netdumping is explained below:
1. Apply the netpoll-core.patch and netconsole.patch (http://www.selenic.com/netpoll/)
2. Download the LKCD code from the cvs using
cvs -d:pserver:anonymous@xxxxxxxxxxxxxxxxxxx:/cvsroot/lkcd login (presee enter key for passwd)
cvs -z3 -d:pserver:anonymous@xxxxxxxxxxxxxxxxxxx:/cvsroot/lkcd co 2.6
cvs -z3 -d:pserver:anonymous@xxxxxxxxxxxxxxxxxxx:/cvsroot/lkcd co lkcdutils
3. Copy the lkcd files to the kernel source directory.
#cp -r ../2.6/* ./linux-2.6-test9/
4. Apply the kernel-changes.patch from the 2.6/patches directory.
5. Apply the pollcontroller.patch from the 2.6/patches
directory now.
6. Apply the lkcd-netpoll.patch(below)
7. Buid the kernel with LKCD network dumping enabled ;reboot and insert the dump_netdev.o module.
8. You also need to install and setup the lkcdutils.
#./configure; make ; make install.
#cd netdump
#make; make install.
9. Configure the netdump fileds in the /etc/sysconfig/dump file.
#you need to specify the local port,remote port, local ip, target ip and device name for netdump.
eg : DUMP_ACTIVE=1
DUMPDEV=eth0
DUMPDIR=/var/log/dump
DUMP_SAVE=1
DUMP_LEVEL=2
DUMP_FLAGS=0x40000000
DUMP_COMPRESS=0
PANIC_TIMEOUT=5
TARGET_HOST=9.182.14.40 #h set this to vaild hostname/IP
TARGET_PORT=6688
SOURCE_PORT=6688
ETH_ADDRESS=00:07:95:E6:08:FB
10. Run lkcd config and now you can try test dumps..
diff -urNp linux.orig/drivers/dump/dump_netdev.c linux-2.6.0-test9/drivers/dump/dump_netdev.c
--- linux.orig/drivers/dump/dump_netdev.c 2003-11-11 06:14:57.000000000 +0530
+++ linux-2.6.0-test9/drivers/dump/dump_netdev.c 2003-11-11 09:50:56.952449656 +0530
@@ -11,6 +11,8 @@
* Nov 2002 - Bharata B. Rao <bharata@xxxxxxxxxx>
* Innumerable code cleanups, simplification and some fixes.
* Netdump configuration done by ioctl instead of using module parameters.
+ * Oct 2003 - Prasanna S Panchamukhi <prasanna@xxxxxxxxxx>
+ * Netdump code modified to use Netpoll API's.
*
* Copyright (C) 2001 Ingo Molnar <mingo@xxxxxxxxxx>
* Copyright (C) 2002 International Business Machines Corp.
@@ -26,24 +28,14 @@
#include <linux/module.h>
#include <linux/dump.h>
#include <linux/dump_netdev.h>
-#include <linux/percpu.h>
#include <asm/unaligned.h>
+
static int startup_handshake;
static int page_counter;
-static struct net_device *dump_ndev;
-static struct in_device *dump_in_dev;
-static u16 source_port, target_port;
-static u32 source_ip, target_ip;
-static unsigned char daddr[6] = {0xff, 0xff, 0xff, 0xff, 0xff, 0xff} ;
-static spinlock_t dump_skb_lock = SPIN_LOCK_UNLOCKED;
-static int dump_nr_skbs;
-static struct sk_buff *dump_skb;
static unsigned long flags_global;
static int netdump_in_progress;
-static char device_name[IFNAMSIZ];
-
/*
* security depends on the trusted path between the netconsole
* server and netconsole client, since none of the packets are
@@ -51,312 +43,27 @@ static char device_name[IFNAMSIZ];
* against spoofing.
*/
static u64 dump_magic;
-
-#define MAX_UDP_CHUNK 1460
-#define MAX_PRINT_CHUNK (MAX_UDP_CHUNK-HEADER_LEN)
-
/*
* We maintain a small pool of fully-sized skbs,
* to make sure the message gets out even in
* extreme OOM situations.
*/
-#define DUMP_MAX_SKBS 32
-
-#define MAX_SKB_SIZE \
- (MAX_UDP_CHUNK + sizeof(struct udphdr) + \
- sizeof(struct iphdr) + sizeof(struct ethhdr))
-
-static void
-dump_refill_skbs(void)
-{
- struct sk_buff *skb;
- unsigned long flags;
-
- spin_lock_irqsave(&dump_skb_lock, flags);
- while (dump_nr_skbs < DUMP_MAX_SKBS) {
- skb = alloc_skb(MAX_SKB_SIZE, GFP_ATOMIC);
- if (!skb)
- break;
- if (dump_skb)
- skb->next = dump_skb;
- else
- skb->next = NULL;
- dump_skb = skb;
- dump_nr_skbs++;
- }
- spin_unlock_irqrestore(&dump_skb_lock, flags);
-}
-
-static struct
-sk_buff * dump_get_skb(void)
-{
- struct sk_buff *skb;
- unsigned long flags;
-
- spin_lock_irqsave(&dump_skb_lock, flags);
- skb = dump_skb;
- if (skb) {
- dump_skb = skb->next;
- skb->next = NULL;
- dump_nr_skbs--;
- }
- spin_unlock_irqrestore(&dump_skb_lock, flags);
-
- return skb;
-}
-
-/*
- * Zap completed output skbs.
- */
-static void
-zap_completion_queue(void)
-{
- int count;
- unsigned long flags;
- struct softnet_data *sd;
-
- count=0;
- 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_restore(flags);
-
- while (clist != NULL) {
- struct sk_buff *skb = clist;
- clist = clist->next;
- __kfree_skb(skb);
- count++;
- if (count > 10000)
- printk("Error in sk list\n");
- }
- }
-}
-
-static void
-dump_send_skb(struct net_device *dev, const char *msg, unsigned int msg_len,
- reply_t *reply)
-{
- int once = 1;
- int total_len, eth_len, ip_len, udp_len, count = 0;
- struct sk_buff *skb;
- struct udphdr *udph;
- struct iphdr *iph;
- struct ethhdr *eth;
-
- udp_len = msg_len + HEADER_LEN + sizeof(*udph);
- ip_len = eth_len = udp_len + sizeof(*iph);
- total_len = eth_len + ETH_HLEN;
-
-repeat_loop:
- zap_completion_queue();
- if (dump_nr_skbs < DUMP_MAX_SKBS)
- dump_refill_skbs();
-
- skb = alloc_skb(total_len, GFP_ATOMIC);
- if (!skb) {
- skb = dump_get_skb();
- if (!skb) {
- count++;
- if (once && (count == 1000000)) {
- printk("possibly FATAL: out of netconsole "
- "skbs!!! will keep retrying.\n");
- once = 0;
- }
- dev->poll_controller(dev);
- goto repeat_loop;
- }
- }
-
- atomic_set(&skb->users, 1);
- skb_reserve(skb, total_len - msg_len - HEADER_LEN);
- skb->data[0] = NETCONSOLE_VERSION;
-
- put_unaligned(htonl(reply->nr), (u32 *) (skb->data + 1));
- put_unaligned(htonl(reply->code), (u32 *) (skb->data + 5));
- put_unaligned(htonl(reply->info), (u32 *) (skb->data + 9));
-
- memcpy(skb->data + HEADER_LEN, msg, msg_len);
- skb->len += msg_len + HEADER_LEN;
-
- udph = (struct udphdr *) skb_push(skb, sizeof(*udph));
- udph->source = source_port;
- udph->dest = target_port;
- udph->len = htons(udp_len);
- udph->check = 0;
-
- iph = (struct iphdr *)skb_push(skb, sizeof(*iph));
-
- iph->version = 4;
- iph->ihl = 5;
- iph->tos = 0;
- iph->tot_len = htons(ip_len);
- iph->id = 0;
- iph->frag_off = 0;
- iph->ttl = 64;
- iph->protocol = IPPROTO_UDP;
- iph->check = 0;
- iph->saddr = source_ip;
- iph->daddr = target_ip;
- iph->check = ip_fast_csum((unsigned char *)iph, iph->ihl);
-
- eth = (struct ethhdr *) skb_push(skb, ETH_HLEN);
-
- eth->h_proto = htons(ETH_P_IP);
- memcpy(eth->h_source, dev->dev_addr, dev->addr_len);
- memcpy(eth->h_dest, daddr, dev->addr_len);
-
- count=0;
-repeat_poll:
- spin_lock(&dev->xmit_lock);
- dev->xmit_lock_owner = smp_processor_id();
-
- count++;
-
-
- if (netif_queue_stopped(dev)) {
- dev->xmit_lock_owner = -1;
- spin_unlock(&dev->xmit_lock);
-
- dev->poll_controller(dev);
- zap_completion_queue();
-
-
- goto repeat_poll;
- }
-
- dev->hard_start_xmit(skb, dev);
-
- dev->xmit_lock_owner = -1;
- spin_unlock(&dev->xmit_lock);
-}
-
-static unsigned short
-udp_check(struct udphdr *uh, int len, unsigned long saddr, unsigned long daddr,
- unsigned long base)
-{
- return csum_tcpudp_magic(saddr, daddr, len, IPPROTO_UDP, base);
-}
-
-static int
-udp_checksum_init(struct sk_buff *skb, struct udphdr *uh,
- unsigned short ulen, u32 saddr, u32 daddr)
-{
- if (uh->check == 0) {
- skb->ip_summed = CHECKSUM_UNNECESSARY;
- } else if (skb->ip_summed == CHECKSUM_HW) {
- skb->ip_summed = CHECKSUM_UNNECESSARY;
- if (!udp_check(uh, ulen, saddr, daddr, skb->csum))
- return 0;
- skb->ip_summed = CHECKSUM_NONE;
- }
- if (skb->ip_summed != CHECKSUM_UNNECESSARY)
- skb->csum = csum_tcpudp_nofold(saddr, daddr, ulen,
- IPPROTO_UDP, 0);
- /* Probably, we should checksum udp header (it should be in cache
- * in any case) and data in tiny packets (< rx copybreak).
- */
- return 0;
-}
-
-static __inline__ int
-__udp_checksum_complete(struct sk_buff *skb)
-{
- return (unsigned short)csum_fold(skb_checksum(skb, 0, skb->len,
- skb->csum));
-}
-
-static __inline__
-int udp_checksum_complete(struct sk_buff *skb)
-{
- return skb->ip_summed != CHECKSUM_UNNECESSARY &&
- __udp_checksum_complete(skb);
-}
+static void rx_hook(struct netpoll *np, int port, char *msg, int size);
int new_req = 0;
static req_t req;
-static int
-dump_rx_hook(struct sk_buff *skb)
+static void rx_hook(struct netpoll *np, int port, char *msg, int size)
{
- int proto;
- struct iphdr *iph;
- struct udphdr *uh;
- __u32 len, saddr, daddr, ulen;
- req_t *__req;
-
+ req_t * __req = (req_t *) msg;
/*
* First check if were are dumping or doing startup handshake, if
* not quickly return.
*/
- if (!netdump_in_progress)
- return NET_RX_SUCCESS;
-
- if (skb->dev->type != ARPHRD_ETHER)
- goto out;
-
- proto = ntohs(skb->mac.ethernet->h_proto);
- if (proto != ETH_P_IP)
- goto out;
-
- if (skb->pkt_type == PACKET_OTHERHOST)
- goto out;
-
- if (skb_shared(skb))
- goto out;
-
- /* IP header correctness testing: */
- iph = (struct iphdr *)skb->data;
- if (!pskb_may_pull(skb, sizeof(struct iphdr)))
- goto out;
-
- if (iph->ihl < 5 || iph->version != 4)
- goto out;
-
- if (!pskb_may_pull(skb, iph->ihl*4))
- goto out;
-
- if (ip_fast_csum((u8 *)iph, iph->ihl) != 0)
- goto out;
-
- len = ntohs(iph->tot_len);
- if (skb->len < len || len < iph->ihl*4)
- goto out;
-
- saddr = iph->saddr;
- daddr = iph->daddr;
- if (iph->protocol != IPPROTO_UDP)
- goto out;
-
- if (source_ip != daddr)
- goto out;
-
- if (target_ip != saddr)
- goto out;
- len -= iph->ihl*4;
- uh = (struct udphdr *)(((char *)iph) + iph->ihl*4);
- ulen = ntohs(uh->len);
-
- if (ulen != len || ulen < (sizeof(*uh) + sizeof(*__req)))
- goto out;
-
- if (udp_checksum_init(skb, uh, ulen, saddr, daddr) < 0)
- goto out;
-
- if (udp_checksum_complete(skb))
- goto out;
-
- if (source_port != uh->dest)
- goto out;
-
- if (target_port != uh->source)
- goto out;
+ if (!netdump_in_progress)
+ return ;
- __req = (req_t *)(uh + 1);
if ((ntohl(__req->command) != COMM_GET_MAGIC) &&
(ntohl(__req->command) != COMM_HELLO) &&
(ntohl(__req->command) != COMM_START_WRITE_NETDUMP_ACK) &&
@@ -371,17 +78,18 @@ dump_rx_hook(struct sk_buff *skb)
req.nr = ntohl(__req->nr);
new_req = 1;
out:
- return NET_RX_DROP;
+ return ;
}
+
+static char tmp_membuf[1024 + HEADER_LEN +1];
static void
-dump_send_mem(struct net_device *dev, req_t *req, const char* buff, size_t len)
+dump_send_mem(struct netpoll *np, req_t *req, const char* buff, size_t len)
{
int i;
int nr_chunks = len/1024;
reply_t reply;
-
reply.nr = req->nr;
reply.info = 0;
@@ -391,7 +99,15 @@ dump_send_mem(struct net_device *dev, re
unsigned int offset = i*1024;
reply.code = REPLY_MEM;
reply.info = offset;
- dump_send_skb(dev, buff + offset, 1024, &reply);
+ tmp_membuf[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp_membuf + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp_membuf + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp_membuf + 9));
+
+ memcpy((tmp_membuf + HEADER_LEN), buff + offset, 1024);
+ netpoll_send_udp(np, tmp_membuf, (1024 + HEADER_LEN));
+
}
}
@@ -409,28 +125,33 @@ dump_handshake(struct dump_dev *net_dev)
{
char tmp[200];
reply_t reply;
- int i, j;
+ int i, j, slen;
if (startup_handshake) {
- sprintf(tmp, "NETDUMP start, waiting for start-ACK.\n");
+ sprintf((tmp + HEADER_LEN), "NETDUMP start, waiting for start-ACK.\n");
reply.code = REPLY_START_NETDUMP;
reply.nr = 0;
reply.info = 0;
} else {
- sprintf(tmp, "NETDUMP start, waiting for start-ACK.\n");
+ sprintf((tmp + HEADER_LEN), "NETDUMP start, waiting for start-ACK.\n");
reply.code = REPLY_START_WRITE_NETDUMP;
reply.nr = net_dev->curr_offset;
reply.info = net_dev->curr_offset;
}
+ slen= strlen("NETDUMP start, waiting for start-ACK.\n");
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
/* send 300 handshake packets before declaring failure */
for (i = 0; i < 300; i++) {
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
-
+ netpoll_send_udp(&net_dev->np, tmp, (slen + HEADER_LEN));
/* wait 1 sec */
for (j = 0; j < 10000; j++) {
udelay(100);
- dump_ndev->poll_controller(dump_ndev);
+ netpoll_poll(&net_dev->np);
zap_completion_queue();
if (new_req)
break;
@@ -474,10 +195,9 @@ do_netdump(struct dump_dev *net_dev, con
reply_t reply;
char tmp[200];
ssize_t ret = 0;
- int repeatCounter, counter, total_loop;
+ int repeatCounter, counter, total_loop, slen;
netdump_in_progress = 1;
-
if (dump_handshake(net_dev) < 0) {
printk("network dump failed due to handshake failure\n");
goto out;
@@ -496,8 +216,9 @@ do_netdump(struct dump_dev *net_dev, con
repeatCounter = 0;
total_loop = 0;
while (1) {
+
if (!new_req) {
- dump_ndev->poll_controller(dump_ndev);
+ netpoll_poll(&net_dev->np);
zap_completion_queue();
}
if (!new_req) {
@@ -530,7 +251,7 @@ do_netdump(struct dump_dev *net_dev, con
break;
case COMM_SEND_MEM:
- dump_send_mem(dump_ndev, &req, buff, len);
+ dump_send_mem(&net_dev->np, &req, buff, len);
break;
case COMM_EXIT:
@@ -539,20 +260,34 @@ do_netdump(struct dump_dev *net_dev, con
goto out;
case COMM_HELLO:
- sprintf(tmp, "Hello, this is netdump version "
+ sprintf((tmp), "Hello, this is netdump version "
+ "0.%02d\n", NETCONSOLE_VERSION);
+ slen= strlen(tmp);
+ sprintf((tmp + HEADER_LEN), "Hello, this is netdump version "
"0.%02d\n", NETCONSOLE_VERSION);
reply.code = REPLY_HELLO;
reply.nr = req.nr;
reply.info = net_dev->curr_offset;
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
break;
case COMM_GET_PAGE_SIZE:
- sprintf(tmp, "PAGE_SIZE: %ld\n", PAGE_SIZE);
+ sprintf((tmp), "PAGE_SIZE: %ld\n", PAGE_SIZE);
+ slen = strlen(tmp);
+ sprintf((tmp + HEADER_LEN), "PAGE_SIZE: %ld\n", PAGE_SIZE);
reply.code = REPLY_PAGE_SIZE;
reply.nr = req.nr;
reply.info = PAGE_SIZE;
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
+ tmp[0] = NETCONSOLE_VERSION;
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
break;
case COMM_GET_NR_PAGES:
@@ -560,25 +295,48 @@ do_netdump(struct dump_dev *net_dev, con
reply.nr = req.nr;
reply.info = num_physpages;
reply.info = page_counter;
- sprintf(tmp, "Number of pages: %ld\n", num_physpages);
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
+ sprintf((tmp), "Number of pages: %ld\n", num_physpages);
+ slen = strlen(tmp);
+ sprintf((tmp + HEADER_LEN), "Number of pages: %ld\n", num_physpages);
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
break;
case COMM_GET_MAGIC:
reply.code = REPLY_MAGIC;
reply.nr = req.nr;
reply.info = NETCONSOLE_VERSION;
- dump_send_skb(dump_ndev, (char *)&dump_magic,
- sizeof(dump_magic), &reply);
+ sprintf((tmp), (char *)&dump_magic, sizeof(dump_magic));
+ slen = strlen(tmp);
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ sprintf((tmp + HEADER_LEN), (char *)&dump_magic, sizeof(dump_magic));
+
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
break;
default:
reply.code = REPLY_ERROR;
reply.nr = req.nr;
reply.info = req.command;
- sprintf(tmp, "Got unknown command code %d!\n",
+ sprintf((tmp), "Got unknown command code %d!\n",
+ req.command);
+ slen = strlen(tmp);
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ sprintf((tmp + HEADER_LEN), "Got unknown command code %d!\n",
req.command);
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
break;
}
}
@@ -588,47 +346,42 @@ out:
}
static int
-dump_validate_config(void)
+dump_validate_config(struct netpoll *np)
{
- source_ip = dump_in_dev->ifa_list->ifa_local;
- if (!source_ip) {
+ if (!np->local_ip) {
printk("network device %s has no local address, "
- "aborting.\n", device_name);
+ "aborting.\n", np->name);
return -1;
}
-#define IP(x) ((unsigned char *)&source_ip)[x]
+ printk("before printing ip\n");
+#define IP(x) ((unsigned char *)&np->local_ip)[x]
printk("Source %d.%d.%d.%d", IP(0), IP(1), IP(2), IP(3));
#undef IP
+ printk("afterprinting ip\n");
- if (!source_port) {
+ if (!np->local_port) {
printk("source_port parameter not specified, aborting.\n");
return -1;
}
- printk(":%i\n", source_port);
- source_port = htons(source_port);
-
- if (!target_ip) {
+ if (!np->remote_ip) {
printk("target_ip parameter not specified, aborting.\n");
return -1;
}
-#define IP(x) ((unsigned char *)&target_ip)[x]
+ np->remote_ip = ntohl(np->remote_ip);
+#define IP(x) ((unsigned char *)&np->remote_ip)[x]
printk("Target %d.%d.%d.%d", IP(0), IP(1), IP(2), IP(3));
#undef IP
-
- if (!target_port) {
+ if (!np->remote_port) {
printk("target_port parameter not specified, aborting.\n");
return -1;
}
- printk(":%i\n", target_port);
- target_port = htons(target_port);
-
printk("Target Ethernet Address %02x:%02x:%02x:%02x:%02x:%02x",
- daddr[0], daddr[1], daddr[2], daddr[3], daddr[4], daddr[5]);
+ np->remote_mac[0], np->remote_mac[1], np->remote_mac[2], np->remote_mac[3], np->remote_mac[4], np->remote_mac[5]);
- if ((daddr[0] & daddr[1] & daddr[2] & daddr[3] & daddr[4] &
- daddr[5]) == 255)
+ if ((np->remote_mac[0] & np->remote_mac[1] & np->remote_mac[2] & np->remote_mac[3] & np->remote_mac[4] &
+ np->remote_mac[5]) == 255)
printk("(Broadcast)");
printk("\n");
return 0;
@@ -645,41 +398,17 @@ dump_net_open(struct dump_dev *net_dev,
{
int retval = 0;
+
/* get the interface name */
- if (copy_from_user(device_name, (void *)arg, IFNAMSIZ))
+ if (copy_from_user(net_dev->np.dev_name, (void *)arg, IFNAMSIZ))
return -EFAULT;
+ net_dev->np.rx_hook = rx_hook;
+ retval = netpoll_setup(&net_dev->np);
- if (!(dump_ndev = dev_get_by_name(device_name))) {
- printk("network device %s does not exist, aborting.\n",
- device_name);
- return -ENODEV;
- }
-
- if (!dump_ndev->poll_controller) {
- printk("network device %s does not implement polling yet, "
- "aborting.\n", device_name);
- retval = -1; /* return proper error */
- goto err1;
- }
-
- if (!(dump_in_dev = in_dev_get(dump_ndev))) {
- printk("network device %s is not an IP protocol device, "
- "aborting.\n", device_name);
- retval = -EINVAL;
- goto err1;
- }
-
- if ((retval = dump_validate_config()) < 0)
- goto err2;
-
+ dump_validate_config(&net_dev->np);
net_dev->curr_offset = 0;
printk("Network device %s successfully configured for dumping\n",
- device_name);
- return retval;
-err2:
- in_dev_put(dump_in_dev);
-err1:
- dev_put(dump_ndev);
+ net_dev->np.dev_name);
return retval;
}
@@ -690,10 +419,8 @@ err1:
static int
dump_net_release(struct dump_dev *net_dev)
{
- if (dump_in_dev)
- in_dev_put(dump_in_dev);
- if (dump_ndev)
- dev_put(dump_ndev);
+
+ netpoll_cleanup(&net_dev->np);
return 0;
}
@@ -704,11 +431,11 @@ dump_net_release(struct dump_dev *net_de
static int
dump_net_silence(struct dump_dev *net_dev)
{
+
local_irq_save(flags_global);
- dump_ndev->rx_hook = dump_rx_hook;
startup_handshake = 1;
net_dev->curr_offset = 0;
- printk("Dumping to network device %s on CPU %d ...\n", device_name,
+ printk("Dumping to network device %s on CPU %d ...\n", net_dev->np.name,
smp_processor_id());
return 0;
}
@@ -721,23 +448,26 @@ dump_net_silence(struct dump_dev *net_de
static int
dump_net_resume(struct dump_dev *net_dev)
{
- int indx;
+ int indx, slen;
reply_t reply;
char tmp[200];
- if (!dump_ndev)
- return (0);
-
- sprintf(tmp, "NETDUMP end.\n");
+ sprintf((tmp), "NETDUMP end.\n");
+ slen = strlen(tmp);
+ sprintf((tmp + HEADER_LEN), "NETDUMP end.\n");
for( indx = 0; indx < 6; indx++) {
reply.code = REPLY_END_NETDUMP;
reply.nr = 0;
reply.info = 0;
- dump_send_skb(dump_ndev, tmp, strlen(tmp), &reply);
+ tmp[0] = NETCONSOLE_VERSION;
+
+ put_unaligned(htonl(reply.nr), (u32 *) (tmp + 1));
+ put_unaligned(htonl(reply.code), (u32 *) (tmp + 5));
+ put_unaligned(htonl(reply.info), (u32 *) (tmp + 9));
+ netpoll_send_udp(&net_dev->np, tmp, slen + HEADER_LEN);
}
printk("NETDUMP END!\n");
local_irq_restore(flags_global);
- dump_ndev->rx_hook = NULL;
startup_handshake = 0;
return 0;
}
@@ -749,11 +479,6 @@ dump_net_resume(struct dump_dev *net_dev
static int
dump_net_seek(struct dump_dev *net_dev, loff_t off)
{
- /*
- * For now using DUMP_HEADER_OFFSET as hard coded value,
- * See dump_block_seekin dump_blockdev.c to know how to
- * do this properly.
- */
net_dev->curr_offset = off;
return 0;
}
@@ -796,16 +521,16 @@ dump_net_ioctl(struct dump_dev *net_dev,
{
switch (cmd) {
case DIOSTARGETIP:
- target_ip = arg;
+ net_dev->np.remote_ip= arg;
break;
case DIOSTARGETPORT:
- target_port = (u16)arg;
+ net_dev->np.remote_port = (u16)arg;
break;
case DIOSSOURCEPORT:
- source_port = (u16)arg;
+ net_dev->np.local_port = (u16)arg;
break;
case DIOSETHADDR:
- return copy_from_user(daddr, (void *)arg, 6);
+ return copy_from_user(net_dev->np.remote_mac, (void *)arg, 6);
break;
case DIOGTARGETIP:
case DIOGTARGETPORT:
@@ -833,14 +558,19 @@ struct dump_dev_ops dump_netdev_ops = {
static struct dump_dev default_dump_netdev = {
.type_name = "networkdev",
.ops = &dump_netdev_ops,
- .curr_offset = 0
+ .curr_offset = 0,
+ .np.name = "netdump",
+ .np.dev_name = "eth0",
+ .np.rx_hook = rx_hook,
+ .np.local_port = 6688,
+ .np.remote_port = 6688,
+ .np.remote_mac = {0xff, 0xff, 0xff, 0xff, 0xff, 0xff},
};
static int __init
dump_netdev_init(void)
{
default_dump_netdev.curr_offset = 0;
-
if (dump_register_device(&default_dump_netdev) < 0) {
printk("network dump device driver registration failed\n");
return -1;
diff -urNp linux.orig/include/linux/dumpdev.h linux-2.6.0-test9/include/linux/dumpdev.h
--- linux.orig/include/linux/dumpdev.h 2003-11-11 06:15:18.000000000 +0530
+++ linux-2.6.0-test9/include/linux/dumpdev.h 2003-11-11 09:50:57.000000000 +0530
@@ -21,6 +21,7 @@
#include <linux/kernel.h>
#include <linux/wait.h>
+#include <linux/netpoll.h>
#include <linux/bio.h>
/* Determined by the dump target (device) type */
@@ -48,6 +49,7 @@ struct dump_dev {
struct dump_dev_ops *ops;
struct list_head list;
loff_t curr_offset;
+ struct netpoll np;
};
/*
diff -urNp linux.orig/include/linux/netpoll.h linux-2.6.0-test9/include/linux/netpoll.h
--- linux.orig/include/linux/netpoll.h 2003-11-11 06:15:18.000000000 +0530
+++ linux-2.6.0-test9/include/linux/netpoll.h 2003-11-11 09:50:57.000000000 +0530
@@ -33,6 +33,7 @@ int netpoll_trap(void);
void netpoll_set_trap(int trap);
void netpoll_cleanup(struct netpoll *np);
int netpoll_rx(struct sk_buff *skb);
+void zap_completion_queue(void);
#endif
diff -urNp linux.orig/net/core/netpoll.c linux-2.6.0-test9/net/core/netpoll.c
--- linux.orig/net/core/netpoll.c 2003-11-11 06:15:16.000000000 +0530
+++ linux-2.6.0-test9/net/core/netpoll.c 2003-11-11 09:51:05.000000000 +0530
@@ -86,7 +86,7 @@ static void refill_skbs(void)
spin_unlock_irqrestore(&skb_list_lock, flags);
}
-static void zap_completion_queue(void)
+void zap_completion_queue(void)
{
unsigned long flags;
struct softnet_data *sd = &get_cpu_var(softnet_data);
@@ -634,3 +634,5 @@ EXPORT_SYMBOL(netpoll_cleanup);
EXPORT_SYMBOL(netpoll_send_skb);
EXPORT_SYMBOL(netpoll_send_udp);
EXPORT_SYMBOL(netpoll_poll);
+EXPORT_SYMBOL(zap_completion_queue);
+
diff -urNp linux.orig/net/Kconfig linux-2.6.0-test9/net/Kconfig
--- linux.orig/net/Kconfig 2003-11-11 06:15:17.000000000 +0530
+++ linux-2.6.0-test9/net/Kconfig 2003-11-11 09:51:05.000000000 +0530
@@ -671,7 +671,7 @@ source "net/irda/Kconfig"
source "net/bluetooth/Kconfig"
config NETPOLL
- def_bool NETCONSOLE
+ def_bool NETCONSOLE || CRASH_DUMP_NETDEV
config NETPOLL_RX
bool "Netpoll support for trapping incoming packets"
--
Thanks & Regards
Prasanna S Panchamukhi
Linux Technology Center
India Software Labs, IBM Bangalore
-
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to majordomo@xxxxxxxxxxxxxxx
More majordomo info at http://vger.kernel.org/majordomo-info.html
Please read the FAQ at http://www.tux.org/lkml/