1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22#ifndef __CONNECTOR_H
23#define __CONNECTOR_H
24
25#include <linux/types.h>
26
27
28
29
30#define CN_IDX_PROC 0x1
31#define CN_VAL_PROC 0x1
32#define CN_IDX_CIFS 0x2
33#define CN_VAL_CIFS 0x1
34#define CN_W1_IDX 0x3
35#define CN_W1_VAL 0x1
36#define CN_IDX_V86D 0x4
37#define CN_VAL_V86D_UVESAFB 0x1
38#define CN_IDX_BB 0x5
39#define CN_DST_IDX 0x6
40#define CN_DST_VAL 0x1
41#define CN_IDX_DM 0x7
42#define CN_VAL_DM_USERSPACE_LOG 0x1
43#define CN_IDX_DRBD 0x8
44#define CN_VAL_DRBD 0x1
45#define CN_KVP_IDX 0x9
46#define CN_KVP_VAL 0x1
47
48#define CN_NETLINK_USERS 10
49
50
51
52
53#define CONNECTOR_MAX_MSG_SIZE 16384
54
55
56
57
58
59
60
61struct cb_id {
62 __u32 idx;
63 __u32 val;
64};
65
66struct cn_msg {
67 struct cb_id id;
68
69 __u32 seq;
70 __u32 ack;
71
72 __u16 len;
73 __u16 flags;
74 __u8 data[0];
75};
76
77#ifdef __KERNEL__
78
79#include <linux/atomic.h>
80
81#include <linux/list.h>
82#include <linux/workqueue.h>
83
84#include <net/sock.h>
85
86#define CN_CBQ_NAMELEN 32
87
88struct cn_queue_dev {
89 atomic_t refcnt;
90 unsigned char name[CN_CBQ_NAMELEN];
91
92 struct list_head queue_list;
93 spinlock_t queue_lock;
94
95 struct sock *nls;
96};
97
98struct cn_callback_id {
99 unsigned char name[CN_CBQ_NAMELEN];
100 struct cb_id id;
101};
102
103struct cn_callback_entry {
104 struct list_head callback_entry;
105 atomic_t refcnt;
106 struct cn_queue_dev *pdev;
107
108 struct cn_callback_id id;
109 void (*callback) (struct cn_msg *, struct netlink_skb_parms *);
110
111 u32 seq, group;
112};
113
114struct cn_dev {
115 struct cb_id id;
116
117 u32 seq, groups;
118 struct sock *nls;
119 void (*input) (struct sk_buff *skb);
120
121 struct cn_queue_dev *cbdev;
122};
123
124int cn_add_callback(struct cb_id *id, const char *name,
125 void (*callback)(struct cn_msg *, struct netlink_skb_parms *));
126void cn_del_callback(struct cb_id *);
127int cn_netlink_send(struct cn_msg *, u32, gfp_t);
128
129int cn_queue_add_callback(struct cn_queue_dev *dev, const char *name,
130 struct cb_id *id,
131 void (*callback)(struct cn_msg *, struct netlink_skb_parms *));
132void cn_queue_del_callback(struct cn_queue_dev *dev, struct cb_id *id);
133void cn_queue_release_callback(struct cn_callback_entry *);
134
135struct cn_queue_dev *cn_queue_alloc_dev(const char *name, struct sock *);
136void cn_queue_free_dev(struct cn_queue_dev *dev);
137
138int cn_cb_equal(struct cb_id *, struct cb_id *);
139
140#endif
141#endif
142