DSP与ARM通信的奇怪问题

wwfdzh2012

/ X- m# _5 a4 O
2 N2 m* k! a. ]/ [& u* U* E

项目要求DSP不跑操作系统，arm核上linux3.3，在做双核通信的linux设备驱动时候遇到了一个诡异的问题，只要DSP通过CHIPSIG_INT0触发ARM中断，ARM中的linux内核的其他很多驱动都停止了工作，连自己的led控制驱动都失去了响应，流水灯也失去了闪烁，LCD显示也停止了刷新，但是运行GUI还是可以显示界面，就是界面不能刷新，触摸屏也不懂了。好像是其他驱动都阻塞了！！！！

我的linux设备驱动是这样实现的：使用Tasklet实现软中断，只要DSP的数据一准备好就通过CHIPSIG_INT0触发ARM中断，这时候驱动的tasklet顶半部会立刻响应中断去读取数据，然后调度tasklet的底半部，这样的流程一般是没问题才对，但是现象就是只要顶半部被触发了，其他驱动就异常了，linux也没有任何提示，而且无法恢复，触发重启内核，但是唯独这个驱动完全正常运行，数据照样读取也不丢帧，还有一个现象是DSP触发一次CHIPSIG_INT0中断，ARM核会响应两次，也就是顶半部会触发两次调用！！我的驱动实现如下，麻烦帮忙看下。

1. //头文件省略
   
2. 
   + k) d- {2 b+ F1 G) a
3. //引入其他模块函数和变量
   
4. extern Ping_Pong_Buffer res_buff;
   
5. 
   5 ]$ V; A* N/ c) B" [, d% `2 i1 s
6. extern char k_linkQueue_create(linkQueue *queue, unsigned int dataType, unsigned int blockNumber, unsigned int blockSize);//创建链队列
   
7. extern void k_linkQueue_release(linkQueue *queue);//释放链队列
   
8. extern unsigned int k_linkQueue_insertData(linkQueue *queue, void *data, int force);//链队列插入数据
   
9. extern unsigned int k_linkQueue_getData(linkQueue *queue, void *r_buff);//获取队列的数据
   
10. 
    
11. extern void SHM_ARM_Init(unsigned char* const mem_base);//共享内存初始化
    
12. 
    / Z; ?  o7 A4 v  g) \  Y# Z
13. static int read_quest = 0;//如果有读取数据请求且链队列无数据可读，则置1
    
14. //设置主从设备号
    ' }' X2 p% Y! r1 H- d3 E
15. #define PROTOCOL_MAJOR      1
    ( S* U0 c- B; s
16. #define PROTOCOL_MINOR      0
    
17. 
    % f$ Y  g# S9 S. M# R  A6 d9 ^
18. 
    ! J9 u& a' k2 N  V; V1 F
19. 
    
20. //定义设备驱动的名字或设备节点的名字
    
21. #define     DEVICE_NAME         "protocol_driver"
      I0 F* i4 j3 [! F' K2 y
22. 
    
23. 
    4 C) O7 w" S+ Y) H6 ?
24. //定义全局的循环队列作为数据缓冲区
    + \4 I5 H# c  _
25. k_linkQueue queue;
    
26. 
    ) a2 ?  {4 S/ v( }
27. //寄存器地址映射全局变量
    
28. unsigned int *R_CHIPSIG = NULL;//CHIPSIG寄存器
    
29. unsigned int *R_CHIPSIG_CLR = NULL;//CHIPSIG_CLR寄存器
    + I( V/ \9 P. R7 p* Q6 y3 e
30. 
    
31. //物理内存映射全局变量
    
32. volatile void *mem_base = NULL;
    
33. volatile unsigned char *cur_buf_ptr = NULL;
    - l* l! @7 F9 m8 O/ ?0 Y4 T; X" a$ M
34. volatile unsigned char *data_ready_ptr = NULL;
    & f, r8 S6 l5 `) _5 y; a6 {
35. 
    $ t) k5 e& E4 O: \$ L
36. 
    . Q0 f/ k( L, `, \
37. 
      C3 d0 g+ v- S& P$ C
38. //定义读数据等待队列头，IO阻塞
    4 l- i; e/ r: Q. C
39. DECLARE_WAIT_QUEUE_HEAD(wait_queue_head);
    
40. 
    
41. //定义原子变量
    + h7 k) @) }, o5 A  [5 r1 ?
42. static atomic_t dev_available = ATOMIC_INIT(1);//原子变量的值为1,即只能一个进程打开此设备
    
43. 
    
44. 
    7 u% G- N' @9 j
45. //定义设备类
    
46. static struct class *protocol_class;
    + ?- f1 n6 h4 S7 b7 |
47. struct cdev *protocol_cdev;
    
48. dev_t protocol_dev_no;
    
49. 
    2 z6 a1 T& g$ r$ f7 j
50. /*定义tasklet和声明底半部函数并关联*/
    ! ~4 |1 j& z8 P# D7 v
51. void read_data_tasklet(unsigned long);
    2 G# S9 W' X$ U
52. 
    
53. DECLARE_TASKLET(CHIPINT0_tasklet,read_data,0);
    
54. //将CHIPINT0_tasklet与read_data绑定，传入参数0
    2 u/ `7 g# O. H
55. 
    
56. /*中断处理底半部, 拷贝内存*/
      f& M' B: S' L1 W+ y2 q3 E
57. void read_data(unsigned long a)
    
58. {
    - {/ z  }2 q* f/ h" G1 t
59.     if(read_quest == 1)//如果进程调用了此驱动的read函数且链队列没有数据可读，read_quest将会被赋值为1
    ( R& \7 n1 A* X5 r  t( ]$ M* Z
60.     {
    
61.         read_quest = 0;
    : I1 o" @5 W% ^; b  B
62.         wake_up_interruptible(&wait_queue_head);//唤醒读等待队列
    
63.     }
    
64. 
    8 \* m; B% Q! ?  p
65. }
    
66. 
    
67. /*中断处理顶半部*/
    
68. irqreturn_t CHIPINT0_interrupt(int irq,void *dev_id)
    . e8 B8 `7 P5 H0 f
69. {
    
70.     //只要一触发进入这个程序，其他驱动会出问题，即使这个程序什么都不做也会这样
    * L( T. q& |8 K4 ^3 ^
71.     volatile Buffer_Type *next_read;
    
72.     //如果DSP数据已经ready
    
73.     if(*(res_buff.cur_buffer->data_ready) == 1)
    
74.     {
    3 C/ T+ J( W" T8 O7 l
75.         if(*(res_buff.bufferID_ptr) == BUFF_ID_PING)//切换读buffer
    
76.         {
    ( X$ S3 T2 g  P* J
77.             next_read = &res_buff.pong_buffer;//下一次中断读pong buffer
    % P0 z! ?; `  c9 S6 O- C" `3 q
78.             //printk(KERN_ALERT"read ping\n");
    
79.         }
    
80.         else
    
81.         {
    $ a5 o& |5 |# `
82.             next_read = &res_buff.ping_buffer;//下一次中断读ping buffer
    
83.             //printk(KERN_ALERT"read pong\n");
    . W# d: W0 C2 C2 y
84.         }
    
85.         *(res_buff.bufferID_ptr) ^= BUFF_ID_PING;//切换DSP写另一个buffer
    
86.         //将数据插入链队列
    
87.         k_linkQueue_insertData(&queue, res_buff.cur_buffer->buf_ptr, 0);
    0 e8 X1 @4 |4 G' ^& b, q
88.         //标识位都重置
    # A0 \) T3 B% T6 O5 ^6 I+ ~
89.         *(res_buff.cur_buffer->data_ready) = 0;
    : _1 z4 k2 I/ ^5 P3 G$ X; R
90.         *(res_buff.cur_buffer->data_size) = 0;
    
91.         res_buff.cur_buffer = next_read;
    
92.     }
    
93.     //清楚中断标识
    
94.     *R_CHIPSIG_CLR = 1 << 0;//clear chipint0 status
    " C. B6 u+ @6 J& l
95.     tasklet_schedule(&CHIPINT0_tasklet);//调度底半部     
    2 s4 {5 G: A5 `* P' t
96. 
    
97. 
      m( |6 U3 h2 R' \7 D
98.     return IRQ_HANDLED;
    9 ^' q# v; `9 A  V' F
99. 
    ! _8 Q+ p9 Y+ @* o5 ?" I
100. }
     & c& |$ F' q) v$ p; ?& _, }
101. 
     6 O: K) N5 J' o; F% c2 c1 {
102. //文件打开函数
     $ D( [& O2 d& S1 ^
103. static int protocol_open(struct inode *inode, struct file *file)
       b" o* g5 v% ^
104. {
     . ]% X9 A. Z) l. ~1 l' O2 n1 b3 {
105.     int result = 0;
     " O; R( }  B  y2 r
106.     if(!atomic_dec_and_test(&dev_available))
     - b; U, E, E1 p
107.     {
     
108.         atomic_inc(&dev_available);
     
109.         return -EBUSY;//设备已经被打开
     
110.     }
     
111.     printk (KERN_ALERT "\nprotrol driver open\n");
     $ S& G- ?! h! F2 g& Q% ]; D( L; G
112.     return 0;
     4 t: \; y4 J0 q( ]* ~
113. }
     8 e6 ~% J8 c8 {# `/ M3 f( A
114. 
     
115. //文件释放函数
     + Y' }. A+ [* F, [' h
116. static int protocol_release(struct inode *inode, struct file *filp)
     
117. {
     8 {- T( _( |9 Q" u2 F! Q  w0 q$ y
118.     atomic_inc(&dev_available);//释放设备，原子变量加1
     5 \' ^2 J1 d) Q! b
119.     printk (KERN_ALERT "device released\n");
     ( }; Z$ e7 ?0 H1 e- Q; v
120.     return 0;
     
121. }
     
122. 
     
123. //文件读函数
     
124. static int protocol_read(struct file *filp, char *dst, size_t size, loff_t*offset)
     
125. {
     ) Q% ^5 b" H4 y/ @# j: d
126.     int ret = 0;
     + a! c5 {3 R* c+ ?0 r
127.     //定义等待队列
     
128.     DECLARE_WAITQUEUE(wait_queue, current);//定义等待队列
     ) l0 V4 J% J/ N- Z) D: q: r4 B6 w
129.     add_wait_queue(&wait_queue_head, &wait_queue);//添加等待队列
     ) h4 ?3 t( {, u( S. w
130.     if(queue.remainNumber == queue.blockNumber)//当前buffer没数据
     8 X% s; w# o% c9 v' k9 R$ |& W! y
131.     {
     + u; G2 \$ r) C7 i1 F: i
132.         //printk(KERN_ALERT"\nbuffer no data\n");
     
133.         //如果是非阻塞方式读取，则直接跳出
     0 w% T" z% f2 J" n) x( g
134.         if(filp->f_flags & O_NONBLOCK)
     * w' [& j! {# C  Z
135.         {
     9 F. ^9 |) g* M/ ~2 I5 @- Z
136.             ret = -EAGAIN;
     
137.             goto out;
     
138.         }
     # ]; b6 V  `) B( Y9 V
139.         //阻塞当前进程，放弃cpu资源
     # n" q9 o. C; `: e" `5 B2 o9 E" K
140.         read_quest = 1;
     # Z1 m8 q& k/ Z. E# {7 v" V
141.         __set_current_state(TASK_INTERRUPTIBLE);//改变进程状态为睡眠
     
142.         schedule();//调度其他进程运行
     
143.         if(signal_pending(current))
     
144.         {
     , ^. a; D& m9 _$ t3 i
145.             //如果是因为信号被唤醒，则返回到系统调用之前的地方
     + u. }; |8 p5 K$ K) ?
146.             ret = -ERESTARTSYS;
     8 L; Y! ?( `  o2 z, z/ G1 o, B4 t) X: b
147.             goto out;
     
148.         }
     1 X# j' o+ e; P3 B6 }# s4 n. j1 _+ ^
149.     }
     
150.     //将数据拷贝到用户空间
     
151.     ret = k_linkQueue_getData(&queue, dst);
     1 F7 O; K, }2 W
152.     if(ret == 0)
     2 w" k4 s4 [# W0 @. c6 d" f4 N( o
153.     {
     
154.         //printk(KERN_ALERT"\ncopy data to user space failed :%d\n", ret);
     
155.     }
     
156. out:
     
157.     remove_wait_queue(&wait_queue_head, &wait_queue);//移除等待队列
     
158.     set_current_state(TASK_RUNNING);//设置当前进程为运行状态
     
159.     return ret;
     
160. }
     
161. 
     6 L4 c$ c8 I/ E6 ?" x+ Q" j; D% W
162. 
     2 N9 P; p6 u3 g
163. static long protocol_ioctl(struct file *file, unsigned int cmd, unsigned long value)
     
164. {
     5 D( e% M1 n5 B$ h: L* o- F% e
165.     return 0;
     
166. }
     * A% Z. F- V: e
167. /*驱动文件操作结构体，file_operations结构体中的成员函数会在应用程序进行
     # ~' b& `* ]- ~2 H: G
168. open()、release()、ioctl()协同调用时被调用*/
     3 w  D& h$ N8 i1 F+ a$ ?
169. static const struct file_operations protocol_fops =
     $ V: l: z( I' C% B8 r2 P
170. {
       b% r' P7 h- J7 A; p: @" C
171.   .owner    = THIS_MODULE,
     
172.   .open     = protocol_open,
     , Z) V- a" ]# Y  _
173.   .release  = protocol_release,
     
174.   .read     = protocol_read,
     ! \  M5 Z4 @8 h- g$ U( O
175. //  .write  = protocol_write,
     / A5 S" ~2 S. o* G& k/ F
176.   .unlocked_ioctl=protocol_ioctl,
     3 \) I) M2 ]3 p  P3 t4 T
177. };
       d3 b2 g' T: B+ ^- D
178. 
     3 S  w1 ~3 o7 f' \; ^% Z  L
179. /*设备驱动模块加载函数*/
     
180. int __init protocol_init(void)
     
181. {
     
182.     int ret = 0;
     
183.     int result = 0;
     0 K. D6 B6 }/ `: S% J, |, @* [
184.     //申请注册设备号（动态）
     
185.     ret=alloc_chrdev_region(&protocol_dev_no, PROTOCOL_MINOR, 1, DEVICE_NAME);
     
186.     if(ret < 0)
     : ]/ B$ c2 E3 e: o  c
187.     {
     4 F( F! x& U+ N
188.             printk(KERN_EMERG "alloc_chrdev_region failed\n");
     
189.             return 0;
     
190.     }
     . u3 ~& o& z4 t( ?( E
191.     //分配cdev
     
192.     protocol_cdev = cdev_alloc();
     
193.     if(protocol_cdev == NULL)
     
194.     {
     0 s0 L& X# G6 g% T8 G
195.             printk(KERN_EMERG "Cannot alloc cdev\n");
     7 R8 F, v! H2 g2 [
196.             return 0;
     ! \& A6 g0 {+ o6 {
197.     }
     + T  [6 r% t5 X+ |: t" @  f$ h
198.     //初始化cdev
     - l9 s' y# P0 a6 f" d6 Y9 M
199.     cdev_init(protocol_cdev,&protocol_fops);
     
200.     protocol_cdev->owner=THIS_MODULE;
     " r4 D( I' _- C# b
201.     //注册cdev
     
202.     cdev_add(protocol_cdev, protocol_dev_no, 1);
     ) B& K* `! a! S
203.     //创建一个类
     
204.     protocol_class = class_create(THIS_MODULE, DEVICE_NAME);
     ! q" ?! P. {/ j( ]
205.     //创建设备节点
     : N" L, M% h* p* n2 T2 H: m" x+ {
206.     device_create(protocol_class, NULL, protocol_dev_no, NULL, DEVICE_NAME);
     % P( r! ?7 n' J
207.    
     ' u4 ~- `# B6 M! ]' h4 H" Z
208.    
     
209.     //申请链式循环队列作为缓冲区DSP数据帧的缓冲区
     
210.     k_linkQueue_create(&queue, sizeof(double), 1000, DATA_BLOCK_SIZE);//申请1000个blocksize的队列空间作为帧缓冲区
     
211. 
     + {$ D0 D" B: _: u  a6 n
212. //映射ARM的核间通讯寄存器
     
213.     R_CHIPSIG = ioremap(SOC_SYSCFG_0_REGS + SYSCFG0_CHIPSIG, 4);
     . Z: k5 a) U- q( j
214.     R_CHIPSIG_CLR = ioremap(SOC_SYSCFG_0_REGS + SYSCFG0_CHIPSIG_CLR, 4);
     
215.     //将物理地址映射到内核空间
     ; n5 [1 x. ]4 j) R
216.     mem_base = ioremap(SHARED_BUFFER_ADDR, SHARED_BUFFER_SIZE);
     
217.     //共享内存初始化
     ! L. ^1 Q/ `6 g2 h
218.     SHM_ARM_Init((unsigned char *)mem_base);
     ( A# N2 o9 Y$ c2 c
219.     /*申请中断*/
     . X; i9 z0 X$ P' l) Y0 ]* o
220. 
     + e6 x6 N; ~3 ]) z* d' |; J
221.     result = request_irq(IRQ_DA8XX_CHIPINT0, CHIPINT0_interrupt,IRQF_SHARED,"DSP Signal",&protocol_cdev);
     3 C; q9 l: {. D' h) b' x
222.     if(result != 0)
     0 u! I: Q& z, M8 M) z' C
223.     {
     & k% [! d, D/ r1 y. m
224.         if(result == -EINVAL)
     
225.         {
     
226.             printk(KERN_ALERT "irq request err:-EINVAL\n");
     
227.         }
     ) R! g* L, d+ a
228.         else if(result == -EBUSY)
     3 n" \$ y, z" e, i/ P
229.         {
     
230.             printk(KERN_ALERT "irq request err:--EBUSY\n");
     ( m3 S6 }% |+ |
231.         }
     " Z/ [( Q5 g& A# e
232.         else
       `1 d6 Y$ ^" X/ s6 G! n
233.         {
     : j& I! K* _' D. L2 v7 S% U
234.             printk(KERN_ALERT "irq request err: unknown\n");
     , p' J7 X6 Q: f; ?4 h
235.         }
     
236.         return result;
     
237.     }
     ' R& Q) \- q- ~) [( n; p5 S6 q& c
238.     return 0;
     
239. }
     4 N; A# {* f+ y- r& J% X+ r) k4 Y
240. 
     + S  l9 {; `. R# _- n; Y
241. /*设备驱动模块卸载函数*/
     0 D  g$ N9 b. E$ d% j
242. void __exit protocol_exit(void)
     3 v: c6 j) ?0 U: e; `
243. {
     
244.         /*释放中断*/
     - r7 @) f' c7 u3 E6 s6 B
245.     free_irq(IRQ_DA8XX_CHIPINT0, NULL);
     
246.     //释放帧缓冲的内存
     0 s- c# C, L& c
247.     k_linkQueue_release(&queue);
     
248.     //释放寄存器映射
     0 p4 a, @  b# g
249.     iounmap(R_CHIPSIG);
     
250.     iounmap(R_CHIPSIG_CLR);
     . k! E0 K- c6 |  `. K
251.     cdev_del(protocol_cdev);                            //删除cdev
     
252.     unregister_chrdev_region(protocol_dev_no, 1);   //注销设备号
     
253.     device_destroy(protocol_class, protocol_dev_no);            //销毁设备节点
     
254.     class_destroy(protocol_class);                      //销毁设备类
     
255.     printk(KERN_ALERT "exit success\n");
     ; t5 X# f9 X- H- d7 b) m
256. 
     : I2 I9 @3 T- p! m' e( D
257. }
     5 b1 t0 D8 y/ C: D6 V- |
258. //驱动其他部分省略

复制代码

wwfdzh2012

没有人遇到这个问题吗

human

可以参考一下TL_IPC双核通信例程。
TL_IPC是广州创龙独立开发的一种双核通讯协议。ARM核上运行Linux程序，DSP核上运行裸机或SYS/BIOS程序。基于TL_IPC的开发是指在两个处理间采用以直接触发中断进行异步事件通知，以直接读写共享内存进行数据交换，并结合创龙提供的c674x_irq_events内核模块（用于ARM端程序捕获由DSP触发的中断）实现双核通信的一种双核开发方式。

wwfdzh2012

human 发表于 2017-4-16 18:19
可以参考一下TL_IPC双核通信例程。
TL_IPC是广州创龙独立开发的一种双核通讯协议。ARM核上运行Linux程序，D ...

@human 您好，请问有c674x_irq_events模块的源码吗，光盘没有附带，只提供模块，这个模块还不能满足我的需求，但是我想参考他的中断实现。谢谢

wwfdzh2012

human 发表于 2017-4-16 18:19
# |4 s) j6 O) X2 p可以参考一下TL_IPC双核通信例程。
TL_IPC是广州创龙独立开发的一种双核通讯协议。ARM核上运行Linux程序，D ...

8 M% e  \0 I) h+ ~请问有c674x_irq_events模块的源码吗

wwfdzh2012

问题已解决，驱动没有任何问题，而是DSP端调用了DelayTimerSetup()这个函数导致定时器的状态被改变，从而导致arm端的定时器驱动无法正常工作，而依赖此定时器的其他驱动也就无法正常工作了，这也是双核的弊端吧，两个核共用一些资源，如果一个核在没有告知其他核的情况下改变了一些资源的寄存器就会导致出问题。

wwfdzh2012

至于DSP触发ARM中断两次的问题，这是由于linux的中断机制导致的，可以参考https://e2e.ti.com/support/embedded/linux/f/354/t/234510
: x  R3 [1 w! g5 W9 H! Q1 @, _解决方法：在dsp端触发后立即将clr标志位置1清除中断线，即可解决触发两次的问题

human

加陈工的QQ2942385389获取资料