8250驱动使用workqueue加入RS485控制逻辑

2024-04-03 23:32

本文主要是介绍8250驱动使用workqueue加入RS485控制逻辑,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

项目中使用了RS485,主控是PX30

查看资料,有些前辈的帖子写了用了tasklet 中断服务来做,无法休眠,

于是使用了workqueue来进行延迟检测操作,主要是为了检查是否数据发送完毕,数据发送完后就拉低IO口。

在结构体中新增定义:
 

diff --git a/kernel/include/linux/serial_8250.h b/kernel/include/linux/serial_8250.h
old mode 100644
new mode 100755
index faa0e03..058dafd
--- a/kernel/include/linux/serial_8250.h
+++ b/kernel/include/linux/serial_8250.h
@@ -40,6 +40,7 @@ struct plat_serial8250_port {void            (*pm)(struct uart_port *, unsigned int state,unsigned old);void            (*handle_break)(struct uart_port *);
+};/*
@@ -122,6 +123,12 @@ struct uart_8250_port {/* 8250 specific callbacks */int                     (*dl_read)(struct uart_8250_port *);void                    (*dl_write)(struct uart_8250_port *, int);
+       /*add by laowang, add gpio-rs485 ctrl*/
+       int rs485_gpio;
+       int rs485_enable;
+       struct work_struct rs485x_work;
+       struct workqueue_struct *rs485x_work_delay;
+       /*end of gpio-rs485 ctrl*/      };

 

其中rs485_gpio 和 rs485_enable 通过设备树进行配置,既然是固有的产品上使用,就不使用IOCTL来传参,

让使用者直接当个串口来用。

-
+#include <linux/of_gpio.h>#include <asm/byteorder.h>#include "8250.h"
@@ -67,6 +67,7 @@ struct dw8250_data {unsigned int            skip_autocfg:1;unsigned int            uart_16550_compatible:1;
+};#define BYT_PRV_CLK                    0x800
@@ -402,6 +403,8 @@ static int dw8250_probe(struct platform_device *pdev)struct resource *regs = platform_get_resource(pdev, IORESOURCE_MEM, 0);int irq = platform_get_irq(pdev, 0);struct uart_port *p = &uart.port;
+       struct device_node *np;// = p->dev->of_node;
+struct dw8250_data *data;int err;u32 val;
@@ -543,6 +546,22 @@ static int dw8250_probe(struct platform_device *pdev)uart.dma = &data->dma;}+
+/***********************add rs485 gpio ctrl*********************************/
+       np = p->dev->of_node;
+       of_property_read_u32(np, "rs485enable",&(uart.rs485_enable));
+       if(uart.rs485_enable == 1)
+       {
+               uart.rs485_gpio = of_get_named_gpio(np, "rs485gpio", 0);
+       }
+
+       printk(KERN_INFO "wjxprint uartline: %d (rs485en = %d, rs485gpio = %d)\n",
+               p->line,
+               uart.rs485_enable,
+               uart.rs485_gpio);
+
+/***********************end add rs485 gpio ctrl*********************************/
+data->line = serial8250_register_8250_port(&uart);

 

初始化注册:

        register_dev_spec_attr_grp(up);up->fcr = uart_config[up->port.type].fcr;
+
+
+        if (up->rs485_enable)
+        {
+        printk(KERN_INFO "uart %d set 485 on address %lx\n", up->port.line,(unsigned long)port);
+               switch(up->port.line)
+               {
+                       case 0:
+                       up->rs485x_work_delay = create_singlethread_workqueue("rs4853_work_delay");
+                       flush_workqueue(up->rs485x_work_delay);
+                       INIT_WORK(&up->rs485x_work, serial8250_4853_do_workqueue);
+                       break;

这里注册了一个工作队列。

 

发送数据前拉高IO:

@@ -1489,6 +1635,17 @@ void serial8250_tx_chars(struct uart_8250_port *up)}count = up->tx_loadsz;
+       if(count > 0)
+       {
+               if(up->rs485_enable == 1)
+               {
+               //      printk(KERN_WARNING "ttyS: serial8250_start_tx: in line %d \n",up->port.line);
+                       gpio_set_value(up->rs485_gpio,1);
+
+               //      udelay(100);
+               }
+       }
+do {serial_out(up, UART_TX, xmit->buf[xmit->tail]);xmit->tail = (xmit->tail + 1) & (UART_XMIT_SIZE - 1);

发送数据结束触发工作队列:

        if (uart_circ_chars_pending(xmit) < WAKEUP_CHARS)
@@ -1513,7 +1671,18 @@ void serial8250_tx_chars(struct uart_8250_port *up)* the interrupt and RPM in __stop_tx()*/if (uart_circ_empty(xmit) && !(up->capabilities & UART_CAP_RPM))
+       {__stop_tx(up);
+               
+               if(up->rs485_enable == 1)
+               {
+               //      printk(KERN_WARNING
+               //             "ttyS%d: __stop_tx end print by wjx \n",
+               //             up->port.line);
+               //      tasklet_hi_schedule(&(up->rs485x_tasklet));
+                       queue_work(up->rs485x_work_delay, &(up->rs485x_work));
+               }
+       }}EXPORT_SYMBOL_GPL(serial8250_tx_chars);

服务程序:

+static void serial8250_4851_do_workqueue(struct work_struct *work);
+
+static inline void handl_tx_485x(struct uart_8250_port * param)
+{
+       struct uart_8250_port *p ;//= up_to_u8250p((struct uart_port *)param);
+       struct uart_port *port = 0 ;
+       
+
+    struct uart_state *state = 0;
+    struct tty_struct *tty = 0;
+    struct ktermios termios;
+    unsigned int baud = 0;
+       int bit_width = 0;
+
+    struct circ_buf *xmit;// = &port->state->xmit;
+    unsigned long flags;
+       unsigned int lsr;
+//     printk(KERN_WARNING "ttyS: serial8250_4851_do_tasklet port in param: %lx \n",(unsigned long )&(param->port));
+       p = param;
+       //p = up_to_u8250p(port);
+       port = &(p->port);
+       
+       if(port == 0)
+       {
+               printk(KERN_WARNING "error in port ttyS: handl_tx_485x  port in param: line is %lx :%d \n",(unsigned long )param,p->port.line);
+               return;
+       }
+
+       //p = up_to_u8250p((struct uart_port *)param);
+
+       xmit = &port->state->xmit;
+
+       //printk(KERN_WARNING "ttyS: serial8250_4851_do_tasklet port in param: line is %lx :%d \n",param,p->port.line);
+       #if 1
+    while (1)
+    {
+               
+        spin_lock_irqsave(&port->lock, flags);
+        lsr = serial_port_in(port, UART_LSR);
+        spin_unlock_irqrestore(&port->lock, flags);
+
+        if (uart_circ_empty(xmit) && ((lsr & BOTH_EMPTY) == BOTH_EMPTY))
+        {
+            break;
+        }
+       //      if(serial8250_tx_empty(port) == TIOCSER_TEMT)
+       //      {
+       //              break;
+       //      }
+       //      else
+       //      {
+       //              udelay(10);
+       //      }
+               
+    }
+    #else
+    while (port->ops->tx_empty(port) != TIOCSER_TEMT)
+    {
+        ;
+    }
+       #endif
+    
+    state = port->state;//container_of(port, struct uart_state, uart_port);
+    tty =  port->state->port.tty; //container_of(state, struct tty_struct, driver_data);
+    termios = tty->termios;
+    baud = uart_get_baud_rate(port, &termios, NULL, 1200, 115200); 
+    bit_width = (baud > 0) ? 1000000/baud : 0;
+   // bit_width = (bit_width > 50) ? (bit_width-50) : 0;  // Measured delay value is 50 us
+
+    udelay(bit_width);  // a stop bit
+       //printk(KERN_WARNING "ttyS: serial8250_4851_do_tasklet bit_width : %d \n",bit_width);
+       gpio_set_value(p->rs485_gpio,0);
+    //gpio_485_set_value(false);
+
+}
+
+
+static void serial8250_4851_do_workqueue(struct work_struct *work)
+{
+       struct uart_8250_port *data = container_of(work, struct uart_8250_port,
+                               rs485x_work);
+       handl_tx_485x(data);    
+
+}

 

 

当前测试收发正常稳定。

但是我系统里有4个串口都需要做485,搞了笨方法,4个workqueue,不知是否有更好的方案可以做。

 

 

 

 

 

这篇关于8250驱动使用workqueue加入RS485控制逻辑的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/874262

相关文章

sky-take-out项目中Redis的使用示例详解

《sky-take-out项目中Redis的使用示例详解》SpringCache是Spring的缓存抽象层,通过注解简化缓存管理,支持Redis等提供者,适用于方法结果缓存、更新和删除操作,但无法实现... 目录Spring Cache主要特性核心注解1.@Cacheable2.@CachePut3.@Ca

C#下Newtonsoft.Json的具体使用

《C#下Newtonsoft.Json的具体使用》Newtonsoft.Json是一个非常流行的C#JSON序列化和反序列化库,它可以方便地将C#对象转换为JSON格式,或者将JSON数据解析为C#对... 目录安装 Newtonsoft.json基本用法1. 序列化 C# 对象为 JSON2. 反序列化

RabbitMQ 延时队列插件安装与使用示例详解(基于 Delayed Message Plugin)

《RabbitMQ延时队列插件安装与使用示例详解(基于DelayedMessagePlugin)》本文详解RabbitMQ通过安装rabbitmq_delayed_message_exchan... 目录 一、什么是 RabbitMQ 延时队列? 二、安装前准备✅ RabbitMQ 环境要求 三、安装延时队

Python ORM神器之SQLAlchemy基本使用完全指南

《PythonORM神器之SQLAlchemy基本使用完全指南》SQLAlchemy是Python主流ORM框架,通过对象化方式简化数据库操作,支持多数据库,提供引擎、会话、模型等核心组件,实现事务... 目录一、什么是SQLAlchemy?二、安装SQLAlchemy三、核心概念1. Engine(引擎)

Java Stream 并行流简介、使用与注意事项小结

《JavaStream并行流简介、使用与注意事项小结》Java8并行流基于StreamAPI,利用多核CPU提升计算密集型任务效率,但需注意线程安全、顺序不确定及线程池管理,可通过自定义线程池与C... 目录1. 并行流简介​特点:​2. 并行流的简单使用​示例:并行流的基本使用​3. 配合自定义线程池​示

GO语言中函数命名返回值的使用

《GO语言中函数命名返回值的使用》在Go语言中,函数可以为其返回值指定名称,这被称为命名返回值或命名返回参数,这种特性可以使代码更清晰,特别是在返回多个值时,感兴趣的可以了解一下... 目录基本语法函数命名返回特点代码示例命名特点基本语法func functionName(parameters) (nam

使用shardingsphere实现mysql数据库分片方式

《使用shardingsphere实现mysql数据库分片方式》本文介绍如何使用ShardingSphere-JDBC在SpringBoot中实现MySQL水平分库,涵盖分片策略、路由算法及零侵入配置... 目录一、ShardingSphere 简介1.1 对比1.2 核心概念1.3 Sharding-Sp

Java 正则表达式的使用实战案例

《Java正则表达式的使用实战案例》本文详细介绍了Java正则表达式的使用方法,涵盖语法细节、核心类方法、高级特性及实战案例,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要... 目录一、正则表达式语法详解1. 基础字符匹配2. 字符类([]定义)3. 量词(控制匹配次数)4. 边

Python Counter 函数使用案例

《PythonCounter函数使用案例》Counter是collections模块中的一个类,专门用于对可迭代对象中的元素进行计数,接下来通过本文给大家介绍PythonCounter函数使用案例... 目录一、Counter函数概述二、基本使用案例(一)列表元素计数(二)字符串字符计数(三)元组计数三、C

Java+AI驱动实现PDF文件数据提取与解析

《Java+AI驱动实现PDF文件数据提取与解析》本文将和大家分享一套基于AI的体检报告智能评估方案,详细介绍从PDF上传、内容提取到AI分析、数据存储的全流程自动化实现方法,感兴趣的可以了解下... 目录一、核心流程:从上传到评估的完整链路二、第一步:解析 PDF,提取体检报告内容1. 引入依赖2. 封装