netlink sample

2023-10-28 20:18
文章标签 sample netlink

本文主要是介绍netlink sample，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

在 Linux 2.4 版以后版本的内核中，几乎全部的中断过程与用户态进程的通信都是使用 netlink套接字实现的，同时还使用 netlink 实现了 ip queue 工具，但 ip queue的使用有其局限性，不能自由地用于各种中断过程。内核的帮助文档和其他一些 Linux 相关文章都没有对 netlink套接字在中断过程和用户空间通信的应用上作详细的说明，使得很多用户对此只有一个模糊的概念。

 

Unicast Communication between Kernel and Application
在下面的例子中,一个用户空间进程发送一个netlink消息给内核模块,内核模块应答一个消息给发送进程,这里是用户空间的代码:

 

 

#include <sys/socket.h>
#include <linux/netlink.h>
#define MAX_PAYLOAD 1024 
struct sockaddr_nl src_addr, dest_addr;
struct msghdr msg;
struct nlmsghdr *nlh = NULL;
struct iovec iov;
int sock_fd;
void main() ...{
 sock_fd = socket(PF_NETLINK,SOCK_RAW,NETLINK_TEST);
 memset(&src_addr, 0,sizeof(src_addr));
 src__addr.nl_family =AF_NETLINK;     
 src_addr.nl_pid =getpid(); 
 src_addr.nl_groups = 0; 
 bind(sock_fd, (structsockaddr*)&src_addr,
     sizeof(src_addr));
 memset(&dest_addr, 0,sizeof(dest_addr));
 dest_addr.nl_family = AF_NETLINK;
 dest_addr.nl_pid =0;  
 dest_addr.nl_groups = 0;
 nlh=(struct nlmsghdr *)malloc(
                        NLMSG_SPACE(MAX_PAYLOAD));
 
 nlh->nlmsg_len =NLMSG_SPACE(MAX_PAYLOAD);
 nlh->nlmsg_pid =getpid(); 
 nlh->nlmsg_flags = 0;
 
 strcpy(NLMSG_DATA(nlh), "Hello you!");
 iov.iov_base = (void *)nlh;
 iov.iov_len =nlh->nlmsg_len;
 msg.msg_name = (void*)&dest_addr;
 msg.msg_namelen = sizeof(dest_addr);
 msg.msg_iov = &iov;
 msg.msg_iovlen = 1;
 sendmsg(fd, &msg, 0);
 
 memset(nlh, 0, NLMSG_SPACE(MAX_PAYLOAD));
 recvmsg(fd, &msg, 0);
 printf(" Received message payload: %s ",
       NLMSG_DATA(nlh));
   
 
 close(sock_fd);
}   
这里是内核代码:

 

 

struct sock *nl_sk = NULL;
void nl_data_ready (struct sock *sk, int len)
...{
 wake_up_interruptible(sk->sleep);
}
void netlink_test() ...{
 struct sk_buff *skb = NULL;
 struct nlmsghdr *nlh = NULL;
 int err;
 u32pid;    
 nl_sk = netlink_kernel_create(NETLINK_TEST,
                                  nl_data_ready);
 
 skb = skb_recv_datagram(nl_sk, 0, 0,&err);
 nlh = (struct nlmsghdr*)skb->data;
 printk("%s: received netlink message payload:%s",
       __FUNCTION__, NLMSG_DATA(nlh));
 pid = nlh->nlmsg_pid;
 NETLINK_CB(skb).groups = 0;
 NETLINK_CB(skb).pid =0;     
 NETLINK_CB(skb).dst_pid = pid;
 NETLINK_CB(skb).dst_groups =0; 
 netlink_unicast(nl_sk, skb, pid,MSG_DONTWAIT);
 sock_release(nl_sk->socket);
}
在内核模块被加载到内核,当我们运行用户程序,我们将看到下面的信息:

Received message payload: Hello you!
 
 

然后用dmesg我们可以看到内核输出:

netlink_test: received netlink message payload:
Hello you!

Multicast Communication between Kernel and Applications
这个例子中,两个应用程序在监听同一个netlink广播组.内核模块发送一个netlink消息给这个广播组,所用的应用程序都收到它,如下是用户程序代码:

 

#include <sys/socket.h>
#include <linux/netlink.h>
#define MAX_PAYLOAD 1024 
struct sockaddr_nl src_addr, dest_addr;
struct nlmsghdr *nlh = NULL;
struct iovec iov;
int sock_fd;
void main() ...{
 sock_fd=socket(PF_NETLINK, SOCK_RAW,NETLINK_TEST);
 memset(&src_addr, 0,sizeof(local_addr));
 src_addr.nl_family =AF_NETLINK;      
 src_addr.nl_pid =getpid(); 
  
 src_addr.nl_groups = 1;
 bind(sock_fd, (structsockaddr*)&src_addr,
     sizeof(src_addr));
 memset(&dest_addr, 0,sizeof(dest_addr));
 nlh = (struct nlmsghdr *)malloc(
                         NLMSG_SPACE(MAX_PAYLOAD));
 memset(nlh, 0,NLMSG_SPACE(MAX_PAYLOAD));     
   
 iov.iov_base = (void *)nlh;
 iov.iov_len = NLMSG_SPACE(MAX_PAYLOAD);
 msg.msg_name = (void*)&dest_addr;
 msg.msg_namelen = sizeof(dest_addr);
 msg.msg_iov = &iov;
 msg.msg_iovlen = 1;
 printf("Waiting for message from kernel ");
 
 recvmsg(fd, &msg, 0);
 printf(" Received message payload: %s ",
       NLMSG_DATA(nlh));
 close(sock_fd);
} 
 内核代码:

 

 

#define MAX_PAYLOAD 1024
struct sock *nl_sk = NULL;
void netlink_test() ...{
 sturct sk_buff *skb = NULL;
 struct nlmsghdr *nlh;
 int err;
 nl_sk = netlink_kernel_create(NETLINK_TEST,
                              nl_data_ready);
 skb=alloc_skb(NLMSG_SPACE(MAX_PAYLOAD),GFP_KERNEL);
 nlh = (struct nlmsghdr*)skb->data;
 nlh->nlmsg_len =NLMSG_SPACE(MAX_PAYLOAD);
 nlh->nlmsg_pid =0; 
 nlh->nlmsg_flags = 0;
 strcpy(NLMSG_DATA(nlh), "Greeting fromkernel!");
 
 NETLINK_CB(skb).groups = 1;
 NETLINK_CB(skb).pid = 0; 
 NETLINK_CB(skb).dst_pid =0; 
 
 NETLINK_CB(skb).dst_groups = 1;
 
 netlink_broadcast(nl_sk, skb, 0, 1,GFP_KERNEL);
 sock_release(nl_sk->socket);
} 
我们运行用户程序:

 
./nl_recv &
Waiting for message from kernel
./nl_recv &
Waiting for message from kernel
 
然后我们加载内核模块到内核空间,会看到如下信息::

Received message payload: Greeting from kernel!
Received message payload: Greeting from kernel!

以下是一个简单的测试内核事件的应用程序：

 

#defineMAX_PAYLOAD       1024
structsockaddr_nl   src_addr, dest_addr;
char *KernelMsg = NULL;
struct iovec iov;
int sock_fd;
struct msghdr msg;
int msglen;

#defineDEVICE_ADD           "add"
#defineDEVICE_REMOVE       "remove"
#defineDEVICE_NAME           "event0"
#defineDEVICE_NAMELEN   6
void * DeviceManagement(void *arg)
...{
    sock_fd =socket(PF_NETLINK, SOCK_RAW, NETLINK_KOBJECT_UEVENT);
    intmsgle;
   
   memset(&src_addr, 0, sizeof(src_addr));
   src_addr.nl_family = AF_NETLINK;
   src_addr.nl_pid = pthread_self() <<16 | getpid();
   src_addr.nl_groups = 1;
   bind(sock_fd, (struct sockaddr *)&src_addr,sizeof(src_addr));
   
   memset(&dest_addr, 0, sizeof(dest_addr));
    KernelMsg =(struct nlmsghdr *)malloc(MAX_PAYLOAD);
   memset(KernelMsg,0,    MAX_PAYLOAD);
   
    iov.iov_base= (void *)KernelMsg;
    iov.iov_len= MAX_PAYLOAD;
    msg.msg_name= (void *)&dest_addr;
   msg.msg_namelen = sizeof(dest_addr);
    msg.msg_iov= &iov;
   msg.msg_iovlen = 1;
   
    while(1)...{
       //printf("Waiting for message from kernel ");
       recvmsg(sock_fd, &msg, 0);
       //printf("Receved message payload: %s ", KernelMsg);
       msglen = strlen(KernelMsg);
       //printf("Device: %s ", KernelMsg+msglen-DEVICE_NAMELEN);
       if(!strncmp(DEVICE_NAME, KernelMsg+msglen-DEVICE_NAMELEN,DEVICE_NAMELEN)) ...{
           if(!strncmp(DEVICE_ADD, KernelMsg, strlen(DEVICE_ADD)))
           ...{
               printf("Add event0 device ");
               USBKeyboardReady = 1;
           }
           else if(!strncmp(DEVICE_REMOVE, KernelMsg, strlen(DEVICE_REMOVE)))...{
               printf("Remove event0 device ");
               USBKeyboardReady = 0;
           }
       }
    }
   close(sock_fd);
   
}

示例：一个用户进程发送数据到内核，然后通过内核发送给另一个用户进程。

内核进程：netlink-exam-kern.c

 

//kernel module: netlink-exam-kern.c
#ifndef __KERNEL__
#define __KERNEL__
#endif

#ifndef MODULE
#define MODULE
#endif

#include <linux/config.h>
#include <linux/module.h>
#include <linux/netlink.h>
#include <linux/sched.h>
#include <net/sock.h>
#include <linux/proc_fs.h>

#define BUF_SIZE 16384
#define NL 30

static struct sock *netlink_exam_sock;
static unsigned char buffer[BUF_SIZE];
static unsigned int buffer_tail = 0;
static int exit_flag = 0;

static DECLARE_COMPLETION(exit_completion);

static void recv_handler(struct sock * sk, int length)
...{
       wake_up(sk->sk_sleep);
}

static int process_message_thread(void * data)
...{
       struct sk_buff * skb = NULL;
       struct nlmsghdr * nlhdr = NULL;
       int len;
       DEFINE_WAIT(wait);

       daemonize("mynetlink");

       while (exit_flag == 0) ...{
               prepare_to_wait(netlink_exam_sock->sk_sleep,&wait, TASK_INTERRUPTIBLE);
               schedule();
               finish_wait(netlink_exam_sock->sk_sleep,&wait);

               while ((skb =skb_dequeue(&netlink_exam_sock->sk_receive_queue))
                        != NULL) ...{
                       nlhdr = (struct nlmsghdr *)skb->data;
                       if (nlhdr->nlmsg_len < sizeof(structnlmsghdr)) ...{
                               printk("Corrupt netlink message. ");
                               continue;
                       }
                       len = nlhdr->nlmsg_len - NLMSG_LENGTH(0);
                       if (len + buffer_tail > BUF_SIZE) ...{
                               printk("netlink buffer is full. ");
                       }
                       else ...{
                               memcpy(buffer + buffer_tail, NLMSG_DATA(nlhdr), len);
                               buffer_tail += len;
                       }
                       nlhdr->nlmsg_pid = 0;
                       nlhdr->nlmsg_flags = 0;
                       NETLINK_CB(skb).pid = 0;
                       NETLINK_CB(skb).dst_pid = 0;
                       NETLINK_CB(skb).dst_group = 1;
                       netlink_broadcast(netlink_exam_sock, skb, 0, 1, GFP_KERNEL);
               }
       }
       complete(&exit_completion);
       return 0;
}

static int netlink_exam_readproc(char *page, char **start, off_toff,
                         int count, int *eof, void *data)
...{
       int len;

       if (off >= buffer_tail) ...{
               * eof = 1;
               return 0;
       }
       else ...{
               len = count;
               if (count > PAGE_SIZE) ...{
                       len = PAGE_SIZE;
               }
               if (len > buffer_tail - off) ...{
                       len = buffer_tail - off;
               }
               memcpy(page, buffer + off, len);
               *start = page;
               return len;
       }

}

static int __init netlink_exam_init(void)
...{
       netlink_exam_sock = netlink_kernel_create(NL, 0, recv_handler,THIS_MODULE);
       if (!netlink_exam_sock) ...{
               printk("Fail to create netlink socket. ");
               return 1;
       }
       kernel_thread(process_message_thread, NULL, CLONE_KERNEL);
       create_proc_read_entry("netlink_exam_buffer", 0444, NULL,netlink_exam_readproc, 0);
       return 0;
}

static void __exit netlink_exam_exit(void)
...{
       exit_flag = 1;
       wake_up(netlink_exam_sock->sk_sleep);
       wait_for_completion(&exit_completion);
       sock_release(netlink_exam_sock->sk_socket);
}

module_init(netlink_exam_init);
module_exit(netlink_exam_exit);
MODULE_LICENSE("GPL");
编译成模块：

 

ifneq ($(KERNELRELEASE),)
debug-objs := netlink-exam-kern.o
obj-m := netlink-exam-kern1.o
CFLAGS += -w -Wimplicit-function-declaration
else
PWD := $(shell pwd)
KVER ?= $(shell uname -r)
KDIR := /lib/modules/$(KVER)/build
all:
       $(MAKE) -C $(KDIR) M=$(PWD)
clean:
       rm -rf .*.cmd *.o *.mod.c *.ko .tmp_versions
endif
用户发送进程：netlink-exam-user-send.c

 

 

//application sender: netlink-exam-user-send.c
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <linux/netlink.h>

#define MAX_MSGSIZE 1024


int main(int argc, char * argv[])
...{
       FILE * fp;
       struct sockaddr_nl saddr, daddr;
       struct nlmsghdr *nlhdr = NULL;
       struct msghdr msg;
       struct iovec iov;
       int sd;
       char text_line[MAX_MSGSIZE];
       int ret = -1;

       if (argc < 2) ...{
               printf("Usage: %s atextfilename ", argv[0]);
               exit(1);
       }

       if ((fp = fopen(argv[1], "r")) == NULL) ...{
               printf("File %s dosen''t exist. ");
               exit(1);
       }

       sd = socket(AF_NETLINK, SOCK_RAW, 30);
       memset(&saddr, 0, sizeof(saddr));
       memset(&daddr, 0, sizeof(daddr));

       saddr.nl_family = AF_NETLINK;
       saddr.nl_pid = getpid();
       saddr.nl_groups = 0;
       bind(sd, (struct sockaddr*)&saddr,sizeof(saddr));

       daddr.nl_family = AF_NETLINK;
       daddr.nl_pid = 0;
       daddr.nl_groups = 0;

       nlhdr = (struct nlmsghdr *)malloc(NLMSG_SPACE(MAX_MSGSIZE));

       while (fgets(text_line, MAX_MSGSIZE, fp)) ...{
               memcpy(NLMSG_DATA(nlhdr), text_line, strlen(text_line));
               memset(&msg, 0 ,sizeof(struct msghdr));

               nlhdr->nlmsg_len =NLMSG_LENGTH(strlen(text_line));
               nlhdr->nlmsg_pid = getpid(); 
               nlhdr->nlmsg_flags = 0;

               iov.iov_base = (void *)nlhdr;
               iov.iov_len = nlhdr->nlmsg_len;
               msg.msg_name = (void *)&daddr;
               msg.msg_namelen = sizeof(daddr);
               msg.msg_iov = &iov;
               msg.msg_iovlen = 1;
               ret = sendmsg(sd, &msg, 0);
               if (ret == -1) ...{
                       perror("sendmsg error:");
               }
       }

       close(sd);
       return 0;
}

用户接收进程：netlink-exam-user-recv.c

 

 

//application sender: netlink-exam-user-send.c
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <linux/netlink.h>

#define MAX_MSGSIZE 1024


int main(int argc, char * argv[])
...{
       FILE * fp;
       struct sockaddr_nl saddr, daddr;
       struct nlmsghdr *nlhdr = NULL;
       struct msghdr msg;
       struct iovec iov;
       int sd;
       char text_line[MAX_MSGSIZE];
       int ret = -1;

       if (argc < 2) ...{
               printf("Usage: %s atextfilename ", argv[0]);
               exit(1);
       }

       if ((fp = fopen(argv[1], "r")) == NULL) ...{
               printf("File %s dosen''t exist. ");
               exit(1);
       }

       sd = socket(AF_NETLINK, SOCK_RAW, 30);
       memset(&saddr, 0, sizeof(saddr));
       memset(&daddr, 0, sizeof(daddr));

       saddr.nl_family = AF_NETLINK;
       saddr.nl_pid = getpid();
       saddr.nl_groups = 0;
       bind(sd, (struct sockaddr*)&saddr,sizeof(saddr));

       daddr.nl_family = AF_NETLINK;
       daddr.nl_pid = 0;
       daddr.nl_groups = 0;

       nlhdr = (struct nlmsghdr *)malloc(NLMSG_SPACE(MAX_MSGSIZE));

       while (fgets(text_line, MAX_MSGSIZE, fp)) ...{
               memcpy(NLMSG_DATA(nlhdr), text_line, strlen(text_line));
               memset(&msg, 0 ,sizeof(struct msghdr));

               nlhdr->nlmsg_len =NLMSG_LENGTH(strlen(text_line));
               nlhdr->nlmsg_pid = getpid(); 
               nlhdr->nlmsg_flags = 0;

               iov.iov_base = (void *)nlhdr;
               iov.iov_len = nlhdr->nlmsg_len;
               msg.msg_name = (void *)&daddr;
               msg.msg_namelen = sizeof(daddr);
               msg.msg_iov = &iov;
               msg.msg_iovlen = 1;
               ret = sendmsg(sd, &msg, 0);
               if (ret == -1) ...{
                       perror("sendmsg error:");
               }
       }

       close(sd);
       return 0;
}

文章出处：http://www.diybl.com/course/6_system/linux/Linuxjs/20071226/94120.html

这篇关于netlink sample的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/295684。

相关文章

解决树莓派IOError: [Errno Invalid sample rate] -9997 采样率16K错误

解决树莓派IOError: [Errno Invalid sample rate] -9997 采样率16K错误

树莓派在基于pyaudio录音的时候会提示如上错误，这主要是使用的树莓派声卡不支持当前的采用率，没关系，其实在alsa架构下我们可以通过声卡的插件实现转换。在树莓派下家目录创建一个声卡隐藏配置文件 .asoundrc。特别说明，不要在你的pyaudio里面设置打开声卡的编号因为下面的配置已经配置了。 1.安装 sudo apt-get install pulseaudio 2.在家目录创
阅读更多...
理解Pytorch中的grid_sample函数

理解Pytorch中的grid_sample函数

文章目录 函数签名参数说明示意图 grid_sample是 PyTorch 提供的一个函数，用于执行采样操作，通常用于图像处理。它允许通过给定的采样坐标从输入张量中获取相应的值。采样坐标可以包含小数，这时 grid_sample 会使用插值方法计算出对应的值。 torch.nn.functional.grid_sample 是 PyTorch 中用于从输入特征图中采样的函数
阅读更多...
ATSS论文要点总结（Adaptive Training Sample Selection）

ATSS论文要点总结（Adaptive Training Sample Selection）

“ATSS” 全称为 “Adaptive Training Sample Selection”，意为自适应训练样本选择，相关论文的主要内容如下： 核心观点：在目标检测中，anchor-based 和 anchor-free 检测器性能差异的关键在于正负样本的定义方式。如果训练过程中使用相同的正负样本定义，两者性能将无明显差异。基于此，作者提出 ATSS 方法，根据目标的统计特征自动选择正负样本，
阅读更多...
点云处理中阶 Sample Consensus（二）

点云处理中阶 Sample Consensus（二）

目录 一、深入理解RSNSAC 二、RANSAC的缺点 三、PCL中常用的Sample Consensus 算法 四、参考资料 一、深入理解RSNSAC RANSAC是“RANdom SAmple Consensus”（随机抽样共识或采样一致性）的缩写，它是一种迭代方法，用于从包含异常值的一组数据中估计数学模型的参数。该算法由Fischler和Bolles于1981年发布。
阅读更多...
Linux 用户态与内核态的交互 ——netlink 篇

Linux 用户态与内核态的交互 ——netlink 篇

作者：Kendo 2006-9-3 这是一篇学习笔记，主要是对《Linux 系统内核空间与用户空间通信的实现与分析》中的源码imp2的分析。其中的源码，可以到以下URL下载： http://www-128.ibm.com/developerworks/cn/linux/l-netlink/imp2.tar.gz 参考文档 《Linux 系统内核空间与用户空间通
阅读更多...
Direct3D Tutorial Win32 Sample 详解 - 7

Direct3D Tutorial Win32 Sample 详解 - 7

实现效果： 在cube上实现纹理映射 process： 将纹理坐标附加到顶点信息中； 使用工具将JPG等图片转化为DDS格式； 使用DDSTextureLoader module加载DDS，得到ID3D11ShaderResourceView。 填充D3D11_SAMPLER_DESC来创建ID3D11SamplerState 着色器代码如下： Texture2D txDiffuse : r
阅读更多...
Direct3D Tutorial Win32 Sample 详解 - 6

Direct3D Tutorial Win32 Sample 详解 - 6

实现效果 在tutorial 5的基础之上实现光照 不同光源及其属性 平行光 属性：方向，平行光不会随距离衰减 struct DirectionalLight{DirectionalLight() { memset(this, 0, sizeof(DirectionalLight)); }DirectX::XMFLOAT4 Ambient;DirectX::XMFLOAT4 Diffu
阅读更多...
Direct3D Tutorial Win32 Sample 详解 - 5

Direct3D Tutorial Win32 Sample 详解 - 5

实现效果： 一个cube自转，另一个cube自转同时，绕中心轴公转 要点 Transform 平移之后，坐标原点就不在物体的中心了。平移之后一定方向上的旋转就是公转。 两个立方体的transform过程如下： // 1st Cube: Rotate around the origin// 绕Y轴旋转即可g_World1 = XMMatrixRotationY( t );// 2n
阅读更多...
android-percent-support-lib-sample

android-percent-support-lib-sample

https://github.com/JulienGenoud/android-percent-support-lib-sample
阅读更多...
linux mtd分区应用操作sample之某分区擦除

linux mtd分区应用操作sample之某分区擦除

什么是擦除? 把flash相关的区域数据bit置为1的过程 #include <mtd/mtd-user.h>#include <mtd/mtd-abi.h>struct erase_info_user {__u32 start; // 起点 __u32 length; //长度 块大小对齐 不然报参数失败 };struct erase_info_user64 {
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2