1
2
3
4
5
6
7
8#ifndef __CONNECTOR_H
9#define __CONNECTOR_H
10
11
12#include <linux/refcount.h>
13
14#include <linux/list.h>
15#include <linux/workqueue.h>
16
17#include <net/sock.h>
18#include <uapi/linux/connector.h>
19
20#define CN_CBQ_NAMELEN 32
21
22struct cn_queue_dev {
23 atomic_t refcnt;
24 unsigned char name[CN_CBQ_NAMELEN];
25
26 struct list_head queue_list;
27 spinlock_t queue_lock;
28
29 struct sock *nls;
30};
31
32struct cn_callback_id {
33 unsigned char name[CN_CBQ_NAMELEN];
34 struct cb_id id;
35};
36
37struct cn_callback_entry {
38 struct list_head callback_entry;
39 refcount_t refcnt;
40 struct cn_queue_dev *pdev;
41
42 struct cn_callback_id id;
43 void (*callback) (struct cn_msg *, struct netlink_skb_parms *);
44
45 u32 seq, group;
46};
47
48struct cn_dev {
49 struct cb_id id;
50
51 u32 seq, groups;
52 struct sock *nls;
53 void (*input) (struct sk_buff *skb);
54
55 struct cn_queue_dev *cbdev;
56};
57
58int cn_add_callback(struct cb_id *id, const char *name,
59 void (*callback)(struct cn_msg *, struct netlink_skb_parms *));
60void cn_del_callback(struct cb_id *);
61int cn_netlink_send_mult(struct cn_msg *msg, u16 len, u32 portid, u32 group, gfp_t gfp_mask);
62int cn_netlink_send(struct cn_msg *msg, u32 portid, u32 group, gfp_t gfp_mask);
63
64int cn_queue_add_callback(struct cn_queue_dev *dev, const char *name,
65 struct cb_id *id,
66 void (*callback)(struct cn_msg *, struct netlink_skb_parms *));
67void cn_queue_del_callback(struct cn_queue_dev *dev, struct cb_id *id);
68void cn_queue_release_callback(struct cn_callback_entry *);
69
70struct cn_queue_dev *cn_queue_alloc_dev(const char *name, struct sock *);
71void cn_queue_free_dev(struct cn_queue_dev *dev);
72
73int cn_cb_equal(struct cb_id *, struct cb_id *);
74
75#endif
76