1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
#ifndef __CCCI_CHRDEV_H__
#define __CCCI_CHRDEV_H__
#include <linux/list.h>
#include <linux/spinlock.h>
#include <linux/wait.h>
#include <asm/atomic.h>
#include <linux/cdev.h>
#include <ccci_layer.h>
#define MAX_BUFFER_MESSAGES ((1<<20)/sizeof(CCCI_BUFF_T))
#define DEFAULT_BUFFER (CCCI_FIFO_MAX_LEN*2)
#define recv_array_is_full(array) ({ \
unsigned int __nr=(array)->nr; \
unsigned int __idx=(array)->in_idx; \
WARN_ON(__idx>__nr); \
__nr==__idx ; })
#define recv_array_is_empty(array) ({ \
unsigned int __nr=(array)->in_idx; \
unsigned int __idx=(array)->out_idx; \
WARN_ON(__idx>__nr); \
__nr==__idx ; })
#define reset_recv_array(array) ({ \
(array)->in_idx=0; \
(array)->out_idx=0; })
#define get_first_entry(list,type,mem) ({ \
type * __ret;\
if (list_empty(list)) __ret=NULL;\
else __ret=list_entry((list)->next,type,mem);\
__ret; })
#define get_last_entry(list,type,mem) ({ \
type * __ret;\
if (list_empty(list)) __ret=NULL;\
else __ret=list_entry((list)->prev,type,mem);\
__ret; })
#define ccci_get_first(_list) get_first_entry(_list,struct recv_array,list)
#define ccci_get_last(_list) get_last_entry(_list,struct recv_array,list)
#define ccci_is_last_recv(list) list_is_last((list)->next,list)
struct recv_array{
CCCI_BUFF_T *array;
unsigned int nr;
unsigned int in_idx;
unsigned int out_idx;
struct list_head list;
};
struct ccci_dev_client{
spinlock_t lock;
atomic_t user;
pid_t pid;
int ch_num;
struct list_head dev_list;
wait_queue_head_t wait_q;
int md_id;
void *ctlb;
struct fasync_struct *fasync;
volatile unsigned int wakeup_waitq;
};
typedef struct _chr_ctl_block
{
int md_id;
struct mutex chr_dev_mutex;
struct list_head chr_dev_list;
struct cdev ccci_chrdev;
int major;
int minor;
}chr_ctl_block_t;
typedef struct _ccci_vir_client{
spinlock_t lock;
atomic_t user;
pid_t pid;
int index;
struct list_head dev_list;
wait_queue_head_t wait_q;
int md_id;
void *ctlb;
struct fasync_struct *fasync;
volatile unsigned int wakeup_waitq;
struct kfifo private_fifo;
int fifo_ready;
}ccci_vir_client_t;
typedef struct _vir_chr_ctl_block
{
int md_id;
struct mutex chr_dev_mutex;
struct list_head chr_dev_list;
struct cdev ccci_chrdev;
int major;
int minor;
spinlock_t bind_lock;
ccci_vir_client_t *system_msg_client;
}vir_ctl_block_t;
extern int ccci_chrdev_init(int);
extern void ccci_chrdev_exit(int);
#endif //__CCCI_CHRDEV_H__
|
