Find all udp sockets (struct sock *sk)

 udp sockets:

   Iterate from 0 to udp_table->mask and get udp_hslot from hash table:
     for (i = 0; i < udp->table->mask; i++) {
         struct udp_hslot *hslot = udp_table->hash[i];
         ...
     }
   For each hslot iterate over hslot->head null list to get sockets:
     struct sock *sk;
     sk_nulls_for_each(sk, node, &hslot->head) {
         ...
     }

  For each socket iterate over the socket buffers in
  sk_receive_queue and sk_write_queue:

   struct sock {
        ...
        struct sk_buff_head     sk_receive_queue;
        ...
        struct sk_buff_head     sk_write_queue;
        ...
   };

   struct sk_buff_head {
        struct sk_buff  *next;
        struct sk_buff  *prev;
   };

   For each struct sk_buff in the two lists clear the memory referenced
   by skb->data / skb->data_len:

   struct sk_buff {
        ...
        unsigned int            data_len;
        ...
        unsigned char           *data;
        ...
   };


Signed-off-by: Aruna Balakrishnaiah <[email protected]>
---
 eppic_scripts/udp_sk_buf.c |   79 ++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 79 insertions(+)
 create mode 100644 eppic_scripts/udp_sk_buf.c

diff --git a/eppic_scripts/udp_sk_buf.c b/eppic_scripts/udp_sk_buf.c
new file mode 100644
index 0000000..7e64300
--- /dev/null
+++ b/eppic_scripts/udp_sk_buf.c
@@ -0,0 +1,79 @@
+string
+udp_opt()
+{
+           return "l";
+}
+
+string
+udp_usage()
+{
+           return "\n";
+}
+
+static void
+udp_showusage()
+{
+           printf("usage : udp %s", udp_usage());
+}
+
+string
+udp_help()
+{
+           return "Help";
+}
+
+int
+udp()
+{
+       int i;
+       int size;
+       struct udp_table *table;
+       struct sock_common *off = 0;
+
+       table = &udp_table;
+
+       for (i = 0; i < table->mask; i++) {
+               struct hlist_nulls_node *pos;
+
+               pos = table->hash[i].head.first;
+
+               while (!((unsigned long)pos & 1)) {
+                       struct sock *sk;
+                       struct sk_buff *next;
+                       struct sk_buff_head *head;
+                       struct hlist_nulls_node *node;
+
+                       sk  = (struct sock *)((unsigned long)pos - ((unsigned 
long)&(off->skc_dontcopy_begin)));
+
+                       head = (struct sk_buff_head *)&(sk->sk_receive_queue);
+                       next = (struct sk_buff *)sk->sk_receive_queue.next;
+
+                       while (next != head)
+                       {
+                               struct sk_buff *buff = (struct sk_buff *)next;
+
+                               memset((char *)buff->data, 'L', buff->data_len);
+                               memset((char *)&(buff->data_len), 'L', 0x4);
+
+                               next = buff->next;
+                       }
+
+                        head = (struct sk_buff_head *)&(sk->sk_write_queue);
+                       next = (struct sk_buff *)sk->sk_write_queue.next;
+
+                       while (next != head)
+                       {
+                               struct sk_buff *buff = (struct sk_buff *)next;
+
+                               memset((char *)buff->data, 'L', buff->data_len);
+                               memset((char *)&(buff->data_len), 'L', 0x4);
+
+                               next = buff->next;
+                        }
+
+                       node = (struct hlist_nulls_node *)((unsigned long)sk + 
(unsigned long)&(off->skc_dontcopy_begin));
+                       pos = node->next;
+               }
+       }
+       return 1;
+}


_______________________________________________
kexec mailing list
[email protected]
http://lists.infradead.org/mailman/listinfo/kexec

Reply via email to