【C语言】linux内核packet_setsockopt

news2024/11/15 11:14:11

一、中文注释

// 发送数据包函数。它尝试通过特定的网络设备队列直接传输一个skb(socket缓冲区)。
static int packet_direct_xmit(struct sk_buff *skb)
{
    return dev_direct_xmit(skb, packet_pick_tx_queue(skb)); // 调用dev_direct_xmit函数,并传入skb和通过packet_pick_tx_queue选择的发送队列。
}

// 设置socket选项的函数。这个函数负责处理网络层的各种选项设置。
static int
packet_setsockopt(struct socket *sock, int level, int optname, char __user *optval, unsigned int optlen)
{
    struct sock *sk = sock->sk; // 从socket结构中获取sock结构。
    struct packet_sock *po = pkt_sk(sk); // 将sock结构转换为packet_sock结构体。
    int ret;

    if (level != SOL_PACKET)
        return -ENOPROTOOPT; // 如果层级不是SOL_PACKET,返回错误。

    // 根据选项名称执行相应的操作。
    switch (optname) {
    case PACKET_ADD_MEMBERSHIP:
    case PACKET_DROP_MEMBERSHIP:
    {
        struct packet_mreq_max mreq; // 定义多播请求结构。
        int len = optlen; // 获取选项长度。
        memset(&mreq, 0, sizeof(mreq)); // 初始化多播请求结构。
        if (len < sizeof(struct packet_mreq))
            return -EINVAL; // 如果传入的长度小于packet_mreq结构大小,返回无效参数错误。
        if (len > sizeof(mreq))
            len = sizeof(mreq); // 如果传入的长度大于packet_mreq_max结构大小,调整为packet_mreq_max结构大小。
        if (copy_from_user(&mreq, optval, len))
            return -EFAULT; // 从用户空间拷贝数据失败,则返回错误。
        if (len < (mreq.mr_alen + offsetof(struct packet_mreq, mr_address)))
            return -EINVAL; // 如果长度小于mreq结构中mr_address成员起始位置加上地址长度,则返回无效参数错误。
        if (optname == PACKET_ADD_MEMBERSHIP)
            ret = packet_mc_add(sk, &mreq); // 添加多播组成员。
        else
            ret = packet_mc_drop(sk, &mreq); // 删除多播组成员。
        return ret; // 返回操作结果。
    }

    case PACKET_RX_RING:
    case PACKET_TX_RING:
    {
        union tpacket_req_u req_u;
        int len;

        lock_sock(sk); // 锁定sock结构。
        switch (po->tp_version) {
        case TPACKET_V1:
        case TPACKET_V2:
            len = sizeof(req_u.req); // 设置请求结构大小。
            break;
        case TPACKET_V3:
        default:
            len = sizeof(req_u.req3); // 设置请求结构大小。
            break;
        }
        if (optlen < len) {
            ret = -EINVAL; // 如果传入长度小于请求结构大小,返回无效参数错误。
        } else {
            if (copy_from_user(&req_u.req, optval, len))
                ret = -EFAULT; // 从用户空间拷贝数据失败,则返回错误。
            else
                ret = packet_set_ring(sk, &req_u, 0, 
                            optname == PACKET_TX_RING); // 设置环形缓冲区。
        }
        release_sock(sk); // 释放sock结构锁。
        return ret; // 返回操作结果。
    }

// 设置数据包复制阈值,当skb长度小于此值时复制数据。
case PACKET_COPY_THRESH:
{
    int val;

    if (optlen != sizeof(val))
        return -EINVAL; // 如果选项长度不合法,返回错误。
    if (copy_from_user(&val, optval, sizeof(val)))
        return -EFAULT; // 如果用户空间数据拷贝失败,返回错误。

    pkt_sk(sk)->copy_thresh = val; // 设置数据包复制阈值。
    return 0;
}
// ...
// 设置packet socket的版本号。
case PACKET_VERSION:
{
    int val;

    if (optlen != sizeof(val))
        return -EINVAL; // 如果选项长度不合法,返回错误。
    if (copy_from_user(&val, optval, sizeof(val)))
        return -EFAULT; // 如果用户空间数据拷贝失败,返回错误。
    switch (val) {
    case TPACKET_V1:
    case TPACKET_V2:
    case TPACKET_V3:
        break; // 如果为有效版本,继续执行。
    default:
        return -EINVAL; // 如果为无效版本,返回错误。
    }
    lock_sock(sk); // 锁定sock结构。
    if (po->rx_ring.pg_vec || po->tx_ring.pg_vec) {
        ret = -EBUSY; // 如果已经设置了环形缓冲区,则返回忙。
    } else {
        po->tp_version = val; // 设置协议版本。
        ret = 0;
    }
    release_sock(sk); // 释放sock结构锁。
    return ret; // 返回操作结果。
}
// ...
// 设置packet socket是否绕过队列规则处理。
case PACKET_QDISC_BYPASS:
{
    int val;

    if (optlen != sizeof(val))
        return -EINVAL; // 如果选项长度不合法,返回错误。
    if (copy_from_user(&val, optval, sizeof(val)))
        return -EFAULT; // 如果用户空间数据拷贝失败,返回错误。

    po->xmit = val ? packet_direct_xmit : dev_queue_xmit; // 根据val的值选择是直接传输还是进入队列规则处理。
    return 0;
}
// ...
// 默认case,如果没有匹配到任何选项,代表不支持该协议选项。
default:
    return -ENOPROTOOPT; // 返回不支持的协议选项错误。
// 所有case分支的目的都是处理socket层的不同选项设置,如添加/删除多播组,设置缓冲区大小和环形配置,调整性能选项等。
// 每个case分支以处理特定选项名(optname)为基础,对socket结构的特定成员进行赋值或执行相关操作函数。
    }
}

这段代码是Linux内核网络栈中的一部分,提供对原始套接字层的操作。`packet_direct_xmit` 函数用于直接通过指定的网络队列发送数据包。`packet_setsockopt` 函数是一个针对`SOL_PACKET`套接字层级的设置选项的函数,可以添加或删除多播组成员,设置缓冲区环区域,修改某些性能参数等。这些操作通常是由网络程序进行socket编程时所使用。

每个 case 分支处理一个特定的套接字选项,例如 PACKET_RX_RING 或 PACKET_TX_RING 用于分配或释放环形缓冲区,而 PACKET_COPY_THRESH 用于设置包拷贝阈值等。每个分支内部通常会首先验证用户提供的参数长度是否合法,然后从用户空间拷贝数据到内核空间,接着进行相应的设置修改,某些情况下还需要在操作前后获取和释放锁,以保护数据结构的一致性。如果选项设置成功,通常会返回 0,否则返回错误码。

二、中文讲解

第一个函数 packet_direct_xmit:

static int packet_direct_xmit(struct sk_buff *skb)
{
    return dev_direct_xmit(skb, packet_pick_tx_queue(skb));
}

packet_direct_xmit 函数是一个非常简单的函数,它接收一个 sk_buff 结构体指针 skb(代表网络数据包),调用 dev_direct_xmit 函数直接将这个数据包发送出去。发送的队列是由 packet_pick_tx_queue(skb) 函数返回的。通常这个函数被用作数据包的直接传输,规避了一些队列管理机制。

第二个函数 packet_setsockopt:

static int packet_setsockopt(struct socket *sock, int level, int optname, char __user *optval, unsigned int optlen)
{
    // ...
}

packet_setsockopt 函数用于设置给定套接字 sock 的某些选项。函数参数 level 表示选项的级别,这里必须是 SOL_PACKET,否则返回 -ENOPROTOOPT 错误。`optname` 指定了要设置的选项的名称,`optval` 是指向包含选项值的用户空间缓冲区的指针,而 optlen 表示缓冲区的长度。
函数体内是一个 switch 语句,根据 optname 的不同,执行不同的操作:
1. PACKET_ADD_MEMBERSHIP 和 PACKET_DROP_MEMBERSHIP:用于管理数据包多播成员资格。
2. PACKET_RX_RING 和 PACKET_TX_RING:设置接收和发送环形缓冲区,这些操作涉及到性能优化,以高效处理网络数据包。
3. PACKET_COPY_THRESH:设置数据包复制阈值。
4. PACKET_VERSION:指定环形缓冲区版本(TPACKET_V1, TPACKET_V2, 或 TPACKET_V3)。
5. PACKET_RESERVE:为环形缓冲区中每个帧预留空间。
6. PACKET_LOSS:设置丢包选项,以模拟网络丢包情况。
7. PACKET_AUXDATA:启用或禁用附加数据。
8. PACKET_ORIGDEV:路由过程中获取原始设备信息的选项。
9. PACKET_VNET_HDR:用于虚拟网络设备头部的选项。
10. PACKET_TIMESTAMP:设置数据包的时间戳类型。
11. PACKET_FANOUT 和 PACKET_FANOUT_DATA:用于将数据包分发到多个程序。
12. PACKET_TX_HAS_OFF:设置是否启用硬件校验和。
13. PACKET_QDISC_BYPASS:设置是否绕过队列规则直接发送数据包。
对于每种情况,在设置选项前都有一些校验逻辑来保证输入参数的有效性。如果输入参数无效,函数会返回相应的错误代码(例如 -EINVAL 表示无效参数)。各种选项设置可能涉及到从用户空间复制数据到内核空间(使用 copy_from_user),也可能对套接字状态加锁来确保线程安全。成功执行操作后,函数通常返回 0 表示成功。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1487081.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

上位机图像处理和嵌入式模块部署(上、下位机通信的三个注意点)

【 声明&#xff1a;版权所有&#xff0c;欢迎转载&#xff0c;请勿用于商业用途。 联系信箱&#xff1a;feixiaoxing 163.com】 如果最终部署在客户现场的是一个嵌入式设备&#xff0c;那么上位机在做好了算法编辑和算法部署之后&#xff0c;很重要的一步就是处理上位机和下位…

Intel FPGA IP之LVDS SerDes IP学习

FPGA 视频数据输入输出直通工程&#xff1a; 屏&#xff1a;13.2吋8bit色深&#xff0c;屏幕分辨率为1440*192060&#xff0c;具有两个Port&#xff0c;每个Port有4个差分数据对与1个差分时钟对&#xff0c;差分对均支持LVDS协议芯片&#xff1a;Cyclone V系列FPGA目的&#x…

分布式ID生成策略-雪花算法Snowflake

分布式ID生成策略-雪花算法Snowflake 一、其他分布式ID策略1.UUID2.数据库自增与优化2.1 优化1 - 共用id自增表2.2 优化2 - 分段获取id 3.Reids的incr和incrby 二、雪花算法Snowflake1.雪花算法的定义2.基础雪花算法源码解读3.并发1000测试4.如何设置机房和机器id4.雪花算法时钟…

在Ubuntu22.04安装Fcitx5中文输入法教程(十分详细)

前言 书接上回&#xff0c;一时兴起将主力机的 Ubuntu 20.04 LTS 升级至了刚刚发布的 22.04 LTS。从 X 切换到 Wayland 、GNOME 从 3.36 升级至 42、Python 默认为 3.10 等等……使用太新的软件包反而暂时带来了麻烦&#xff0c;部分原有的软件和插件都不可用了。这其中就包括…

浅谈马尔科夫链蒙特卡罗方法(MCMC)算法的理解

1.解决的问题 计算机怎么在任意给定的概率分布P上采样&#xff1f;首先可以想到把它拆成两步&#xff1a; &#xff08;1&#xff09;首先等概率的从采样区间里取一个待定样本x&#xff0c;并得到它的概率为p(x) &#xff08;2&#xff09;然后在均匀分布U[0,1]上取一个值&a…

可视化管理的kanban插件 | Obsidian实践

继上一篇文章之后&#xff0c;有朋友提问说&#xff1a; 刚好&#xff0c;关于kanban插件的素材&#xff0c;是之前一早就准备好的&#xff0c;便快速整理成文&#xff0c;简单分享一下个人实践。 Prompt&#xff1a;项目流程管理看板&#xff0c;色彩鲜艳。by 通义万象 看板管…

C++调用lua函数

C 调用Lua全局变量(普通) lua_getglobal(lua, "width");int width lua_tointeger(lua,-1);lua_pop(lua,1);std::cout << width << std::endl;lua_close(lua); 这几行代码要放到lua_pcall(lua, 0,0,0);之后才可以. C给lua传递变量 lua_pushstring(lua, …

三、低代码平台-单据配置(单表增删改查)

一、业务效果图 主界面 二、配置过程简介 配置流程&#xff1a;业务表设计 -》业务对象建立-》业务单据配置-》菜单配置。 a、业务表设计 b、业务对象建立 c、业务单据配置 功能路径&#xff1a;低代码开发平台/业务开发配置/单据配置维护 d、菜单配置

【JavaEE】_Spring MVC 项目传参问题

目录 1. 传递单个参数 1.1 关于参数名的问题 2. 传递多个参数 2.1 关于参数顺序的问题 2.2 关于基本类型与包装类的问题 3. 使用对象传参 4. 后端参数重命名问题 4.1 关于RequestPara注解 1. 传递单个参数 现创建Spring MVC项目&#xff0c;.java文件内容如下&#xff…

【k8s存储--使用OpenEBS做持久化存储】

1、简介 使用OpenEBS&#xff0c;你可以将有持久化数据的容器&#xff0c;像对待其他普通容器一样来对待。OpenEBS本身也是通过容器来部署的&#xff0c;支持Kubernetes、Swarm、Mesos、Rancher编排调度&#xff0c;存储服务可以分派给每个pod、应用程序、集群或者容器级别&am…

Mybatis plus拓展功能-JSON处理器

目录 1 前言 2 使用方法 2.1 定义json实体类 2.2 在实体类中使用 1 前言 这是我最近学到的比较新奇的一个东西&#xff0c;数据库居然还可以存储JSON格式的数据&#xff0c;如下。虽然我感觉一般也没谁会这样干&#xff0c;但是既然有&#xff0c;那就当个科普讲一下Mybat…

【自然语言处理】NLP入门(三):1、正则表达式与Python中的实现(3):字符转义符及进制转换

文章目录 一、前言二、正则表达式与Python中的实现1.字符串构造2. 字符串截取3. 字符串格式化输出4. 字符转义符a. 常用字符转义符续行符换行符制表符双引号单引号反斜杠符号回车符退格符 b. ASCII编码转义字符进制转换2 进制8 进制10 进制16 进制进制转换函数 c. Unicode字符\…

每天学习一个Linux命令之gunzip

每天学习一个Linux命令之gunzip 在Linux系统中&#xff0c;有许多强大且常用的命令&#xff0c;其中之一是gunzip。gunzip命令用于解压缩.gz文件&#xff0c;它是gzip的伴生命令之一。本篇博客将详细介绍gunzip命令及其可用的选项&#xff0c;以帮助您更好地理解和使用这个命令…

运放设计选型中关注的参数-运算放大器选型参数

1、直流增益&#xff08;AVD&#xff09; 直流增益是运放最重要一个属性之一&#xff0c;其定义为输出电压的变化与输入电压变化之比值&#xff0c;通常用V/mV表示这个比值&#xff0c;例如&#xff0c;增益为30000&#xff0c;可表示为30V/mV&#xff0c;有些地方也会把增益用…

实践航拍小目标检测,基于轻量级YOLOv7tiny开发构建无人机航拍场景下的小目标检测识别分析系统

关于无人机相关的场景在我们之前的博文也有一些比较早期的实践&#xff0c;感兴趣的话可以自行移步阅读即可&#xff1a; 《deepLabV3Plus实现无人机航拍目标分割识别系统》 《基于目标检测的无人机航拍场景下小目标检测实践》 《助力环保河道水质监测&#xff0c;基于yolov…

搜索旋转排序数组[中等]

优质博文IT-BLOG-CN 一、题目 整数数组nums按升序排列&#xff0c;数组中的值 互不相同 。 在传递给函数之前&#xff0c;nums在预先未知的某个下标k&#xff08;0 < k < nums.length&#xff09;上进行了 旋转&#xff0c;使数组变为[nums[k], nums[k1], ..., nums[n-…

AI蠕虫病毒威胁升级,揭示AI安全新危机

一组研究人员成功研发出首个能够通过电子邮件客户端窃取数据、传播恶意软件以及向他人发送垃圾邮件的AI蠕虫&#xff0c;并在使用流行的大规模语言模型&#xff08;LLMs&#xff09;的测试环境中展示了其按设计功能运作的能力。基于他们的研究成果&#xff0c;研究人员向生成式…

HTML+CSS+JS:日夜交替

效果演示 实现了一个简单的日夜交替效果的动画。页面中包含了太阳、月亮和海洋的元素&#xff0c;通过切换按钮可以切换页面的主题&#xff0c;从白天切换到黑夜&#xff0c;或者从黑夜切换到白天。 Code <div class"btn-box"><div class"sunBtn"…

Docker将本地的镜像上传到私有仓库

使用register镜像创建私有仓库 [rootopenEuler-node1 ~]# docker run --restartalways -d -p 5000:5000 -v /opt/data/regostry:/var/lib/registry registry:2[rootopenEuler-node1 ~]# docker images REPOSITORY TAG IMAGE…