IVMSHM socket and network drivers DRAFT

W/README.md

@@ -0,0 +1 @@
+Shared memory networking and sockets drivers WIP

W/ivshmem-server/cmd

@@ -0,0 +1,5 @@
+sudo ./ivshmem-server -vF -n 10 -M shM  -l 16M&
+sleep 3
+sudo chmod a+rwx /tmp/ivsh*
+sudo chmod a+rwx /dev/shm/*
+sudo ./ivshmem-client -v 

W/ivshmem-server/cmd.huge

@@ -0,0 +1,4 @@
+sudo ./ivshmem-server -vF -n 10 -m /dev/hugepages -l 16M &
+sleep 3
+sudo chmod a+rwx /tmp/ivsh*
+sudo ./ivshmem-client -v 

W/ivshmem-server/cmd.no_mem

@@ -0,0 +1,5 @@
+sudo ./ivshmem-server -vF -n 10 &
+sleep 3
+sudo chmod a+rwx /tmp/ivsh*
+sudo chmod a+rwx /dev/shm/*
+sudo ./ivshmem-client -v 

W/ivshmem-server/cmd.orig

@@ -0,0 +1,4 @@
+sudo ./ivshmem-server -vF -n 10 -m /dev/shm -l 16M&
+sleep 3
+sudo chmod a+rwx /tmp/ivsh*
+sudo ./ivshmem-client -v 

W/ivshmem-server/cmd_jk

@@ -0,0 +1,4 @@
+./ivshmem-server -vF -n 10 -M shM  -l 16M&
+sleep 3
+chmod a+rwx /tmp/ivsh*
+./ivshmem-client -v 

W/p2p/Makefile

@@ -0,0 +1,8 @@
+obj-m += p2pnet.o
+
+all:
+	make -C /lib/modules/$(shell uname -r)/build M=$(PWD) modules
+
+clean:
+	make -C /lib/modules/$(shell uname -r)/build M=$(PWD) clean
+

W/p2p/modules.order

@@ -0,0 +1 @@
+/home/vadikas/W/p2p/p2pnet.o

W/p2p/p2pnet.c

@@ -0,0 +1,103 @@
+#include <linux/module.h>
+#include <linux/netdevice.h>
+#include <linux/etherdevice.h> // For alloc_etherdev and ethernet operations
+
+#define DRV_NAME "p2pnet"
+
+MODULE_LICENSE("GPL");
+MODULE_AUTHOR("Your Name");
+MODULE_DESCRIPTION("A simple Linux network driver for P2P networking");
+MODULE_VERSION("0.1");
+
+static struct net_device *p2p_net_dev;
+
+// Function prototypes
+static int p2p_open(struct net_device *dev);
+static int p2p_stop(struct net_device *dev);
+static netdev_tx_t p2p_start_xmit(struct sk_buff *skb, struct net_device *dev);
+static int p2p_config(struct net_device *dev, struct ifmap *map);
+static void p2p_tx_timeout(struct net_device *dev, unsigned int i);
+
+// The net_device_ops structure
+static const struct net_device_ops p2p_netdev_ops = {
+    .ndo_open = p2p_open,
+    .ndo_stop = p2p_stop,
+    .ndo_start_xmit = p2p_start_xmit,
+    .ndo_set_config = p2p_config,
+    .ndo_tx_timeout = p2p_tx_timeout,
+};
+
+// This function is called to open the device
+static int p2p_open(struct net_device *dev) {
+    netif_start_queue(dev);
+    printk(KERN_INFO "%s: device opened\n", DRV_NAME);
+    return 0; // success
+}
+
+// This function is called to stop the device
+static int p2p_stop(struct net_device *dev) {
+    netif_stop_queue(dev);
+    printk(KERN_INFO "%s: device stopped\n", DRV_NAME);
+    return 0; // success
+}
+
+// This function is called when a packet needs to be transmitted
+static netdev_tx_t p2p_start_xmit(struct sk_buff *skb, struct net_device *dev) {
+    // Packet transmission code here
+    // For P2P, you might want to handle packet routing to the correct peer here
+
+    dev_kfree_skb(skb); // Free the skb memory
+    return NETDEV_TX_OK;
+}
+
+// This function is called to configure the device
+static int p2p_config(struct net_device *dev, struct ifmap *map) {
+    printk(KERN_INFO "%s: device config \n", DRV_NAME);
+    if (dev->flags & IFF_UP) {
+        return -EBUSY;
+    }
+    // Config code here
+    return 0;
+}
+
+// This function is called on transmission timeout
+static void p2p_tx_timeout(struct net_device *dev,unsigned  int i) {
+    printk(KERN_WARNING "%s: transmit timeout\n", DRV_NAME);
+    // Timeout handling code here
+}
+
+// Module initialization function
+static int __init p2p_init_module(void) {
+    // Allocate the net_device structure
+    p2p_net_dev = alloc_etherdev(0);
+    if (!p2p_net_dev) {
+        return -ENOMEM;
+    }
+
+    // Set the interface name
+    strncpy(p2p_net_dev->name, "p2p%d", IFNAMSIZ);
+
+    // Set the net_device_ops structure
+    p2p_net_dev->netdev_ops = &p2p_netdev_ops;
+
+    // Register the network device
+    if (register_netdev(p2p_net_dev)) {
+        printk(KERN_ALERT "%s: error registering net device\n", DRV_NAME);
+        free_netdev(p2p_net_dev);
+        return -ENODEV;
+    }
+
+    printk(KERN_INFO "%s: P2P network device registered\n", DRV_NAME);
+    return 0;
+}
+
+// Module cleanup function
+static void __exit p2p_cleanup_module(void) {
+    unregister_netdev(p2p_net_dev);
+    free_netdev(p2p_net_dev);
+    printk(KERN_INFO "%s: P2P network device unregistered\n", DRV_NAME);
+}
+
+module_init(p2p_init_module);
+module_exit(p2p_cleanup_module);
+

W/p2p/p2pnet.mod

@@ -0,0 +1 @@
+/home/vadikas/W/p2p/p2pnet.o

W/p2p/p2pnet.mod.c

@@ -0,0 +1,51 @@
+#include <linux/module.h>
+#define INCLUDE_VERMAGIC
+#include <linux/build-salt.h>
+#include <linux/elfnote-lto.h>
+#include <linux/export-internal.h>
+#include <linux/vermagic.h>
+#include <linux/compiler.h>
+
+#ifdef CONFIG_UNWINDER_ORC
+#include <asm/orc_header.h>
+ORC_HEADER;
+#endif
+
+BUILD_SALT;
+BUILD_LTO_INFO;
+
+MODULE_INFO(vermagic, VERMAGIC_STRING);
+MODULE_INFO(name, KBUILD_MODNAME);
+
+__visible struct module __this_module
+__section(".gnu.linkonce.this_module") = {
+	.name = KBUILD_MODNAME,
+	.init = init_module,
+#ifdef CONFIG_MODULE_UNLOAD
+	.exit = cleanup_module,
+#endif
+	.arch = MODULE_ARCH_INIT,
+};
+
+#ifdef CONFIG_RETPOLINE
+MODULE_INFO(retpoline, "Y");
+#endif
+
+
+
+static const struct modversion_info ____versions[]
+__used __section("__versions") = {
+	{ 0x122c3a7e, "_printk" },
+	{ 0xa2c54569, "consume_skb" },
+	{ 0x4d0decbc, "alloc_etherdev_mqs" },
+	{ 0x7e722be1, "register_netdev" },
+	{ 0xf5617bc3, "free_netdev" },
+	{ 0xa08af381, "unregister_netdev" },
+	{ 0xa65c6def, "alt_cb_patch_nops" },
+	{ 0xb0bb5523, "module_layout" },
+};
+
+MODULE_INFO(depends, "");
+
+
+MODULE_INFO(srcversion, "6520547521D5AAA3151D66E");