diff options
Diffstat (limited to 'include/net')
58 files changed, 1564 insertions, 227 deletions
diff --git a/include/net/9p/client.h b/include/net/9p/client.h index fb00b329f0d3..4f3760afc20f 100644 --- a/include/net/9p/client.h +++ b/include/net/9p/client.h | |||
@@ -29,6 +29,19 @@ | |||
29 | /* Number of requests per row */ | 29 | /* Number of requests per row */ |
30 | #define P9_ROW_MAXTAG 255 | 30 | #define P9_ROW_MAXTAG 255 |
31 | 31 | ||
32 | /** enum p9_proto_versions - 9P protocol versions | ||
33 | * @p9_proto_legacy: 9P Legacy mode, pre-9P2000.u | ||
34 | * @p9_proto_2000u: 9P2000.u extension | ||
35 | * @p9_proto_2000L: 9P2000.L extension | ||
36 | */ | ||
37 | |||
38 | enum p9_proto_versions{ | ||
39 | p9_proto_legacy = 0, | ||
40 | p9_proto_2000u = 1, | ||
41 | p9_proto_2000L = 2, | ||
42 | }; | ||
43 | |||
44 | |||
32 | /** | 45 | /** |
33 | * enum p9_trans_status - different states of underlying transports | 46 | * enum p9_trans_status - different states of underlying transports |
34 | * @Connected: transport is connected and healthy | 47 | * @Connected: transport is connected and healthy |
@@ -41,6 +54,7 @@ | |||
41 | 54 | ||
42 | enum p9_trans_status { | 55 | enum p9_trans_status { |
43 | Connected, | 56 | Connected, |
57 | BeginDisconnect, | ||
44 | Disconnected, | 58 | Disconnected, |
45 | Hung, | 59 | Hung, |
46 | }; | 60 | }; |
@@ -111,6 +125,7 @@ struct p9_req_t { | |||
111 | * @lock: protect @fidlist | 125 | * @lock: protect @fidlist |
112 | * @msize: maximum data size negotiated by protocol | 126 | * @msize: maximum data size negotiated by protocol |
113 | * @dotu: extension flags negotiated by protocol | 127 | * @dotu: extension flags negotiated by protocol |
128 | * @proto_version: 9P protocol version to use | ||
114 | * @trans_mod: module API instantiated with this client | 129 | * @trans_mod: module API instantiated with this client |
115 | * @trans: tranport instance state and API | 130 | * @trans: tranport instance state and API |
116 | * @conn: connection state information used by trans_fd | 131 | * @conn: connection state information used by trans_fd |
@@ -137,7 +152,7 @@ struct p9_req_t { | |||
137 | struct p9_client { | 152 | struct p9_client { |
138 | spinlock_t lock; /* protect client structure */ | 153 | spinlock_t lock; /* protect client structure */ |
139 | int msize; | 154 | int msize; |
140 | unsigned char dotu; | 155 | unsigned char proto_version; |
141 | struct p9_trans_module *trans_mod; | 156 | struct p9_trans_module *trans_mod; |
142 | enum p9_trans_status status; | 157 | enum p9_trans_status status; |
143 | void *trans; | 158 | void *trans; |
@@ -184,6 +199,7 @@ int p9_client_version(struct p9_client *); | |||
184 | struct p9_client *p9_client_create(const char *dev_name, char *options); | 199 | struct p9_client *p9_client_create(const char *dev_name, char *options); |
185 | void p9_client_destroy(struct p9_client *clnt); | 200 | void p9_client_destroy(struct p9_client *clnt); |
186 | void p9_client_disconnect(struct p9_client *clnt); | 201 | void p9_client_disconnect(struct p9_client *clnt); |
202 | void p9_client_begin_disconnect(struct p9_client *clnt); | ||
187 | struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid, | 203 | struct p9_fid *p9_client_attach(struct p9_client *clnt, struct p9_fid *afid, |
188 | char *uname, u32 n_uname, char *aname); | 204 | char *uname, u32 n_uname, char *aname); |
189 | struct p9_fid *p9_client_auth(struct p9_client *clnt, char *uname, | 205 | struct p9_fid *p9_client_auth(struct p9_client *clnt, char *uname, |
@@ -209,5 +225,7 @@ int p9_parse_header(struct p9_fcall *, int32_t *, int8_t *, int16_t *, int); | |||
209 | int p9stat_read(char *, int, struct p9_wstat *, int); | 225 | int p9stat_read(char *, int, struct p9_wstat *, int); |
210 | void p9stat_free(struct p9_wstat *); | 226 | void p9stat_free(struct p9_wstat *); |
211 | 227 | ||
228 | int p9_is_proto_dotu(struct p9_client *clnt); | ||
229 | int p9_is_proto_dotl(struct p9_client *clnt); | ||
212 | 230 | ||
213 | #endif /* NET_9P_CLIENT_H */ | 231 | #endif /* NET_9P_CLIENT_H */ |
diff --git a/include/net/af_unix.h b/include/net/af_unix.h index 1614d78c60ed..20725e213aee 100644 --- a/include/net/af_unix.h +++ b/include/net/af_unix.h | |||
@@ -30,7 +30,7 @@ struct unix_skb_parms { | |||
30 | #endif | 30 | #endif |
31 | }; | 31 | }; |
32 | 32 | ||
33 | #define UNIXCB(skb) (*(struct unix_skb_parms*)&((skb)->cb)) | 33 | #define UNIXCB(skb) (*(struct unix_skb_parms *)&((skb)->cb)) |
34 | #define UNIXCREDS(skb) (&UNIXCB((skb)).creds) | 34 | #define UNIXCREDS(skb) (&UNIXCB((skb)).creds) |
35 | #define UNIXSID(skb) (&UNIXCB((skb)).secid) | 35 | #define UNIXSID(skb) (&UNIXCB((skb)).secid) |
36 | 36 | ||
@@ -45,21 +45,23 @@ struct unix_skb_parms { | |||
45 | struct unix_sock { | 45 | struct unix_sock { |
46 | /* WARNING: sk has to be the first member */ | 46 | /* WARNING: sk has to be the first member */ |
47 | struct sock sk; | 47 | struct sock sk; |
48 | struct unix_address *addr; | 48 | struct unix_address *addr; |
49 | struct dentry *dentry; | 49 | struct dentry *dentry; |
50 | struct vfsmount *mnt; | 50 | struct vfsmount *mnt; |
51 | struct mutex readlock; | 51 | struct mutex readlock; |
52 | struct sock *peer; | 52 | struct sock *peer; |
53 | struct sock *other; | 53 | struct sock *other; |
54 | struct list_head link; | 54 | struct list_head link; |
55 | atomic_long_t inflight; | 55 | atomic_long_t inflight; |
56 | spinlock_t lock; | 56 | spinlock_t lock; |
57 | unsigned int gc_candidate : 1; | 57 | unsigned int gc_candidate : 1; |
58 | unsigned int gc_maybe_cycle : 1; | 58 | unsigned int gc_maybe_cycle : 1; |
59 | wait_queue_head_t peer_wait; | 59 | struct socket_wq peer_wq; |
60 | }; | 60 | }; |
61 | #define unix_sk(__sk) ((struct unix_sock *)__sk) | 61 | #define unix_sk(__sk) ((struct unix_sock *)__sk) |
62 | 62 | ||
63 | #define peer_wait peer_wq.wait | ||
64 | |||
63 | #ifdef CONFIG_SYSCTL | 65 | #ifdef CONFIG_SYSCTL |
64 | extern int unix_sysctl_register(struct net *net); | 66 | extern int unix_sysctl_register(struct net *net); |
65 | extern void unix_sysctl_unregister(struct net *net); | 67 | extern void unix_sysctl_unregister(struct net *net); |
diff --git a/include/net/ax25.h b/include/net/ax25.h index 717e2192d521..206d22297ac3 100644 --- a/include/net/ax25.h +++ b/include/net/ax25.h | |||
@@ -10,6 +10,7 @@ | |||
10 | #include <linux/spinlock.h> | 10 | #include <linux/spinlock.h> |
11 | #include <linux/timer.h> | 11 | #include <linux/timer.h> |
12 | #include <linux/list.h> | 12 | #include <linux/list.h> |
13 | #include <linux/slab.h> | ||
13 | #include <asm/atomic.h> | 14 | #include <asm/atomic.h> |
14 | 15 | ||
15 | #define AX25_T1CLAMPLO 1 | 16 | #define AX25_T1CLAMPLO 1 |
diff --git a/include/net/bluetooth/bluetooth.h b/include/net/bluetooth/bluetooth.h index 04a6908e38d2..ff77e8f882f1 100644 --- a/include/net/bluetooth/bluetooth.h +++ b/include/net/bluetooth/bluetooth.h | |||
@@ -176,6 +176,6 @@ extern void hci_sock_cleanup(void); | |||
176 | extern int bt_sysfs_init(void); | 176 | extern int bt_sysfs_init(void); |
177 | extern void bt_sysfs_cleanup(void); | 177 | extern void bt_sysfs_cleanup(void); |
178 | 178 | ||
179 | extern struct class *bt_class; | 179 | extern struct dentry *bt_debugfs; |
180 | 180 | ||
181 | #endif /* __BLUETOOTH_H */ | 181 | #endif /* __BLUETOOTH_H */ |
diff --git a/include/net/bluetooth/hci_core.h b/include/net/bluetooth/hci_core.h index ce3c99e5fa25..e42f6ed5421c 100644 --- a/include/net/bluetooth/hci_core.h +++ b/include/net/bluetooth/hci_core.h | |||
@@ -107,6 +107,8 @@ struct hci_dev { | |||
107 | unsigned long acl_last_tx; | 107 | unsigned long acl_last_tx; |
108 | unsigned long sco_last_tx; | 108 | unsigned long sco_last_tx; |
109 | 109 | ||
110 | struct workqueue_struct *workqueue; | ||
111 | |||
110 | struct tasklet_struct cmd_task; | 112 | struct tasklet_struct cmd_task; |
111 | struct tasklet_struct rx_task; | 113 | struct tasklet_struct rx_task; |
112 | struct tasklet_struct tx_task; | 114 | struct tasklet_struct tx_task; |
@@ -636,8 +638,8 @@ int hci_register_notifier(struct notifier_block *nb); | |||
636 | int hci_unregister_notifier(struct notifier_block *nb); | 638 | int hci_unregister_notifier(struct notifier_block *nb); |
637 | 639 | ||
638 | int hci_send_cmd(struct hci_dev *hdev, __u16 opcode, __u32 plen, void *param); | 640 | int hci_send_cmd(struct hci_dev *hdev, __u16 opcode, __u32 plen, void *param); |
639 | int hci_send_acl(struct hci_conn *conn, struct sk_buff *skb, __u16 flags); | 641 | void hci_send_acl(struct hci_conn *conn, struct sk_buff *skb, __u16 flags); |
640 | int hci_send_sco(struct hci_conn *conn, struct sk_buff *skb); | 642 | void hci_send_sco(struct hci_conn *conn, struct sk_buff *skb); |
641 | 643 | ||
642 | void *hci_sent_cmd_data(struct hci_dev *hdev, __u16 opcode); | 644 | void *hci_sent_cmd_data(struct hci_dev *hdev, __u16 opcode); |
643 | 645 | ||
diff --git a/include/net/bluetooth/l2cap.h b/include/net/bluetooth/l2cap.h index 17a689f27a6a..7c695bfd853c 100644 --- a/include/net/bluetooth/l2cap.h +++ b/include/net/bluetooth/l2cap.h | |||
@@ -30,11 +30,12 @@ | |||
30 | #define L2CAP_DEFAULT_MIN_MTU 48 | 30 | #define L2CAP_DEFAULT_MIN_MTU 48 |
31 | #define L2CAP_DEFAULT_FLUSH_TO 0xffff | 31 | #define L2CAP_DEFAULT_FLUSH_TO 0xffff |
32 | #define L2CAP_DEFAULT_TX_WINDOW 63 | 32 | #define L2CAP_DEFAULT_TX_WINDOW 63 |
33 | #define L2CAP_DEFAULT_NUM_TO_ACK (L2CAP_DEFAULT_TX_WINDOW/5) | ||
34 | #define L2CAP_DEFAULT_MAX_TX 3 | 33 | #define L2CAP_DEFAULT_MAX_TX 3 |
35 | #define L2CAP_DEFAULT_RETRANS_TO 1000 /* 1 second */ | 34 | #define L2CAP_DEFAULT_RETRANS_TO 1000 /* 1 second */ |
36 | #define L2CAP_DEFAULT_MONITOR_TO 12000 /* 12 seconds */ | 35 | #define L2CAP_DEFAULT_MONITOR_TO 12000 /* 12 seconds */ |
37 | #define L2CAP_DEFAULT_MAX_PDU_SIZE 672 | 36 | #define L2CAP_DEFAULT_MAX_PDU_SIZE 672 |
37 | #define L2CAP_DEFAULT_ACK_TO 200 | ||
38 | #define L2CAP_LOCAL_BUSY_TRIES 12 | ||
38 | 39 | ||
39 | #define L2CAP_CONN_TIMEOUT (40000) /* 40 seconds */ | 40 | #define L2CAP_CONN_TIMEOUT (40000) /* 40 seconds */ |
40 | #define L2CAP_INFO_TIMEOUT (4000) /* 4 seconds */ | 41 | #define L2CAP_INFO_TIMEOUT (4000) /* 4 seconds */ |
@@ -55,6 +56,8 @@ struct l2cap_options { | |||
55 | __u16 flush_to; | 56 | __u16 flush_to; |
56 | __u8 mode; | 57 | __u8 mode; |
57 | __u8 fcs; | 58 | __u8 fcs; |
59 | __u8 max_tx; | ||
60 | __u16 txwin_size; | ||
58 | }; | 61 | }; |
59 | 62 | ||
60 | #define L2CAP_CONNINFO 0x02 | 63 | #define L2CAP_CONNINFO 0x02 |
@@ -292,6 +295,7 @@ struct l2cap_conn { | |||
292 | #define l2cap_pi(sk) ((struct l2cap_pinfo *) sk) | 295 | #define l2cap_pi(sk) ((struct l2cap_pinfo *) sk) |
293 | #define TX_QUEUE(sk) (&l2cap_pi(sk)->tx_queue) | 296 | #define TX_QUEUE(sk) (&l2cap_pi(sk)->tx_queue) |
294 | #define SREJ_QUEUE(sk) (&l2cap_pi(sk)->srej_queue) | 297 | #define SREJ_QUEUE(sk) (&l2cap_pi(sk)->srej_queue) |
298 | #define BUSY_QUEUE(sk) (&l2cap_pi(sk)->busy_queue) | ||
295 | #define SREJ_LIST(sk) (&l2cap_pi(sk)->srej_l.list) | 299 | #define SREJ_LIST(sk) (&l2cap_pi(sk)->srej_l.list) |
296 | 300 | ||
297 | struct srej_list { | 301 | struct srej_list { |
@@ -320,7 +324,7 @@ struct l2cap_pinfo { | |||
320 | __u8 conf_req[64]; | 324 | __u8 conf_req[64]; |
321 | __u8 conf_len; | 325 | __u8 conf_len; |
322 | __u8 conf_state; | 326 | __u8 conf_state; |
323 | __u8 conn_state; | 327 | __u16 conn_state; |
324 | 328 | ||
325 | __u8 next_tx_seq; | 329 | __u8 next_tx_seq; |
326 | __u8 expected_ack_seq; | 330 | __u8 expected_ack_seq; |
@@ -328,27 +332,35 @@ struct l2cap_pinfo { | |||
328 | __u8 buffer_seq; | 332 | __u8 buffer_seq; |
329 | __u8 buffer_seq_srej; | 333 | __u8 buffer_seq_srej; |
330 | __u8 srej_save_reqseq; | 334 | __u8 srej_save_reqseq; |
335 | __u8 frames_sent; | ||
331 | __u8 unacked_frames; | 336 | __u8 unacked_frames; |
332 | __u8 retry_count; | 337 | __u8 retry_count; |
333 | __u8 num_to_ack; | 338 | __u8 num_acked; |
334 | __u16 sdu_len; | 339 | __u16 sdu_len; |
335 | __u16 partial_sdu_len; | 340 | __u16 partial_sdu_len; |
336 | struct sk_buff *sdu; | 341 | struct sk_buff *sdu; |
337 | 342 | ||
338 | __u8 ident; | 343 | __u8 ident; |
339 | 344 | ||
345 | __u8 tx_win; | ||
346 | __u8 max_tx; | ||
340 | __u8 remote_tx_win; | 347 | __u8 remote_tx_win; |
341 | __u8 remote_max_tx; | 348 | __u8 remote_max_tx; |
342 | __u16 retrans_timeout; | 349 | __u16 retrans_timeout; |
343 | __u16 monitor_timeout; | 350 | __u16 monitor_timeout; |
344 | __u16 max_pdu_size; | 351 | __u16 remote_mps; |
352 | __u16 mps; | ||
345 | 353 | ||
346 | __le16 sport; | 354 | __le16 sport; |
347 | 355 | ||
356 | spinlock_t send_lock; | ||
348 | struct timer_list retrans_timer; | 357 | struct timer_list retrans_timer; |
349 | struct timer_list monitor_timer; | 358 | struct timer_list monitor_timer; |
359 | struct timer_list ack_timer; | ||
350 | struct sk_buff_head tx_queue; | 360 | struct sk_buff_head tx_queue; |
351 | struct sk_buff_head srej_queue; | 361 | struct sk_buff_head srej_queue; |
362 | struct sk_buff_head busy_queue; | ||
363 | struct work_struct busy_work; | ||
352 | struct srej_list srej_l; | 364 | struct srej_list srej_l; |
353 | struct l2cap_conn *conn; | 365 | struct l2cap_conn *conn; |
354 | struct sock *next_c; | 366 | struct sock *next_c; |
@@ -367,19 +379,24 @@ struct l2cap_pinfo { | |||
367 | #define L2CAP_CONF_MAX_CONF_REQ 2 | 379 | #define L2CAP_CONF_MAX_CONF_REQ 2 |
368 | #define L2CAP_CONF_MAX_CONF_RSP 2 | 380 | #define L2CAP_CONF_MAX_CONF_RSP 2 |
369 | 381 | ||
370 | #define L2CAP_CONN_SAR_SDU 0x01 | 382 | #define L2CAP_CONN_SAR_SDU 0x0001 |
371 | #define L2CAP_CONN_SREJ_SENT 0x02 | 383 | #define L2CAP_CONN_SREJ_SENT 0x0002 |
372 | #define L2CAP_CONN_WAIT_F 0x04 | 384 | #define L2CAP_CONN_WAIT_F 0x0004 |
373 | #define L2CAP_CONN_SREJ_ACT 0x08 | 385 | #define L2CAP_CONN_SREJ_ACT 0x0008 |
374 | #define L2CAP_CONN_SEND_PBIT 0x10 | 386 | #define L2CAP_CONN_SEND_PBIT 0x0010 |
375 | #define L2CAP_CONN_REMOTE_BUSY 0x20 | 387 | #define L2CAP_CONN_REMOTE_BUSY 0x0020 |
376 | #define L2CAP_CONN_LOCAL_BUSY 0x40 | 388 | #define L2CAP_CONN_LOCAL_BUSY 0x0040 |
377 | #define L2CAP_CONN_REJ_ACT 0x80 | 389 | #define L2CAP_CONN_REJ_ACT 0x0080 |
390 | #define L2CAP_CONN_SEND_FBIT 0x0100 | ||
391 | #define L2CAP_CONN_RNR_SENT 0x0200 | ||
392 | #define L2CAP_CONN_SAR_RETRY 0x0400 | ||
378 | 393 | ||
379 | #define __mod_retrans_timer() mod_timer(&l2cap_pi(sk)->retrans_timer, \ | 394 | #define __mod_retrans_timer() mod_timer(&l2cap_pi(sk)->retrans_timer, \ |
380 | jiffies + msecs_to_jiffies(L2CAP_DEFAULT_RETRANS_TO)); | 395 | jiffies + msecs_to_jiffies(L2CAP_DEFAULT_RETRANS_TO)); |
381 | #define __mod_monitor_timer() mod_timer(&l2cap_pi(sk)->monitor_timer, \ | 396 | #define __mod_monitor_timer() mod_timer(&l2cap_pi(sk)->monitor_timer, \ |
382 | jiffies + msecs_to_jiffies(L2CAP_DEFAULT_MONITOR_TO)); | 397 | jiffies + msecs_to_jiffies(L2CAP_DEFAULT_MONITOR_TO)); |
398 | #define __mod_ack_timer() mod_timer(&l2cap_pi(sk)->ack_timer, \ | ||
399 | jiffies + msecs_to_jiffies(L2CAP_DEFAULT_ACK_TO)); | ||
383 | 400 | ||
384 | static inline int l2cap_tx_window_full(struct sock *sk) | 401 | static inline int l2cap_tx_window_full(struct sock *sk) |
385 | { | 402 | { |
diff --git a/include/net/caif/caif_dev.h b/include/net/caif/caif_dev.h new file mode 100644 index 000000000000..318ab9478a44 --- /dev/null +++ b/include/net/caif/caif_dev.h | |||
@@ -0,0 +1,103 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/ sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CAIF_DEV_H_ | ||
8 | #define CAIF_DEV_H_ | ||
9 | |||
10 | #include <net/caif/caif_layer.h> | ||
11 | #include <net/caif/cfcnfg.h> | ||
12 | #include <linux/caif/caif_socket.h> | ||
13 | #include <linux/if.h> | ||
14 | |||
15 | /** | ||
16 | * struct caif_param - CAIF parameters. | ||
17 | * @size: Length of data | ||
18 | * @data: Binary Data Blob | ||
19 | */ | ||
20 | struct caif_param { | ||
21 | u16 size; | ||
22 | u8 data[256]; | ||
23 | }; | ||
24 | |||
25 | /** | ||
26 | * struct caif_connect_request - Request data for CAIF channel setup. | ||
27 | * @protocol: Type of CAIF protocol to use (at, datagram etc) | ||
28 | * @sockaddr: Socket address to connect. | ||
29 | * @priority: Priority of the connection. | ||
30 | * @link_selector: Link selector (high bandwidth or low latency) | ||
31 | * @link_name: Name of the CAIF Link Layer to use. | ||
32 | * @param: Connect Request parameters (CAIF_SO_REQ_PARAM). | ||
33 | * | ||
34 | * This struct is used when connecting a CAIF channel. | ||
35 | * It contains all CAIF channel configuration options. | ||
36 | */ | ||
37 | struct caif_connect_request { | ||
38 | enum caif_protocol_type protocol; | ||
39 | struct sockaddr_caif sockaddr; | ||
40 | enum caif_channel_priority priority; | ||
41 | enum caif_link_selector link_selector; | ||
42 | char link_name[16]; | ||
43 | struct caif_param param; | ||
44 | }; | ||
45 | |||
46 | /** | ||
47 | * caif_connect_client - Connect a client to CAIF Core Stack. | ||
48 | * @config: Channel setup parameters, specifying what address | ||
49 | * to connect on the Modem. | ||
50 | * @client_layer: User implementation of client layer. This layer | ||
51 | * MUST have receive and control callback functions | ||
52 | * implemented. | ||
53 | * | ||
54 | * This function connects a CAIF channel. The Client must implement | ||
55 | * the struct cflayer. This layer represents the Client layer and holds | ||
56 | * receive functions and control callback functions. Control callback | ||
57 | * function will receive information about connect/disconnect responses, | ||
58 | * flow control etc (see enum caif_control). | ||
59 | * E.g. CAIF Socket will call this function for each socket it connects | ||
60 | * and have one client_layer instance for each socket. | ||
61 | */ | ||
62 | int caif_connect_client(struct caif_connect_request *config, | ||
63 | struct cflayer *client_layer); | ||
64 | |||
65 | /** | ||
66 | * caif_disconnect_client - Disconnects a client from the CAIF stack. | ||
67 | * | ||
68 | * @client_layer: Client layer to be removed. | ||
69 | */ | ||
70 | int caif_disconnect_client(struct cflayer *client_layer); | ||
71 | |||
72 | /** | ||
73 | * caif_release_client - Release adaptation layer reference to client. | ||
74 | * | ||
75 | * @client_layer: Client layer. | ||
76 | * | ||
77 | * Releases a client/adaptation layer use of the caif stack. | ||
78 | * This function must be used after caif_disconnect_client to | ||
79 | * decrease the reference count of the service layer. | ||
80 | */ | ||
81 | void caif_release_client(struct cflayer *client_layer); | ||
82 | |||
83 | /** | ||
84 | * connect_req_to_link_param - Translate configuration parameters | ||
85 | * from socket format to internal format. | ||
86 | * @cnfg: Pointer to configuration handler | ||
87 | * @con_req: Configuration parameters supplied in function | ||
88 | * caif_connect_client | ||
89 | * @channel_setup_param: Parameters supplied to the CAIF Core stack for | ||
90 | * setting up channels. | ||
91 | * | ||
92 | */ | ||
93 | int connect_req_to_link_param(struct cfcnfg *cnfg, | ||
94 | struct caif_connect_request *con_req, | ||
95 | struct cfctrl_link_param *channel_setup_param); | ||
96 | |||
97 | /** | ||
98 | * get_caif_conf() - Get the configuration handler. | ||
99 | */ | ||
100 | struct cfcnfg *get_caif_conf(void); | ||
101 | |||
102 | |||
103 | #endif /* CAIF_DEV_H_ */ | ||
diff --git a/include/net/caif/caif_device.h b/include/net/caif/caif_device.h new file mode 100644 index 000000000000..d02f044adb8a --- /dev/null +++ b/include/net/caif/caif_device.h | |||
@@ -0,0 +1,55 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/ sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CAIF_DEVICE_H_ | ||
8 | #define CAIF_DEVICE_H_ | ||
9 | #include <linux/kernel.h> | ||
10 | #include <linux/net.h> | ||
11 | #include <linux/netdevice.h> | ||
12 | #include <linux/caif/caif_socket.h> | ||
13 | #include <net/caif/caif_device.h> | ||
14 | |||
15 | /** | ||
16 | * struct caif_dev_common - data shared between CAIF drivers and stack. | ||
17 | * @flowctrl: Flow Control callback function. This function is | ||
18 | * supplied by CAIF Core Stack and is used by CAIF | ||
19 | * Link Layer to send flow-stop to CAIF Core. | ||
20 | * The flow information will be distributed to all | ||
21 | * clients of CAIF. | ||
22 | * | ||
23 | * @link_select: Profile of device, either high-bandwidth or | ||
24 | * low-latency. This member is set by CAIF Link | ||
25 | * Layer Device in order to indicate if this device | ||
26 | * is a high bandwidth or low latency device. | ||
27 | * | ||
28 | * @use_frag: CAIF Frames may be fragmented. | ||
29 | * Is set by CAIF Link Layer in order to indicate if the | ||
30 | * interface receives fragmented frames that must be | ||
31 | * assembled by CAIF Core Layer. | ||
32 | * | ||
33 | * @use_fcs: Indicate if Frame CheckSum (fcs) is used. | ||
34 | * Is set if the physical interface is | ||
35 | * using Frame Checksum on the CAIF Frames. | ||
36 | * | ||
37 | * @use_stx: Indicate STart of frame eXtension (stx) in use. | ||
38 | * Is set if the CAIF Link Layer expects | ||
39 | * CAIF Frames to start with the STX byte. | ||
40 | * | ||
41 | * This structure is shared between the CAIF drivers and the CAIF stack. | ||
42 | * It is used by the device to register its behavior. | ||
43 | * CAIF Core layer must set the member flowctrl in order to supply | ||
44 | * CAIF Link Layer with the flow control function. | ||
45 | * | ||
46 | */ | ||
47 | struct caif_dev_common { | ||
48 | void (*flowctrl)(struct net_device *net, int on); | ||
49 | enum caif_link_selector link_select; | ||
50 | int use_frag; | ||
51 | int use_fcs; | ||
52 | int use_stx; | ||
53 | }; | ||
54 | |||
55 | #endif /* CAIF_DEVICE_H_ */ | ||
diff --git a/include/net/caif/caif_layer.h b/include/net/caif/caif_layer.h new file mode 100644 index 000000000000..25c472f0e5b8 --- /dev/null +++ b/include/net/caif/caif_layer.h | |||
@@ -0,0 +1,283 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland / sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CAIF_LAYER_H_ | ||
8 | #define CAIF_LAYER_H_ | ||
9 | |||
10 | #include <linux/list.h> | ||
11 | |||
12 | struct cflayer; | ||
13 | struct cfpkt; | ||
14 | struct cfpktq; | ||
15 | struct caif_payload_info; | ||
16 | struct caif_packet_funcs; | ||
17 | |||
18 | #define CAIF_MAX_FRAMESIZE 4096 | ||
19 | #define CAIF_MAX_PAYLOAD_SIZE (4096 - 64) | ||
20 | #define CAIF_NEEDED_HEADROOM (10) | ||
21 | #define CAIF_NEEDED_TAILROOM (2) | ||
22 | |||
23 | #define CAIF_LAYER_NAME_SZ 16 | ||
24 | #define CAIF_SUCCESS 1 | ||
25 | #define CAIF_FAILURE 0 | ||
26 | |||
27 | /** | ||
28 | * caif_assert() - Assert function for CAIF. | ||
29 | * @assert: expression to evaluate. | ||
30 | * | ||
31 | * This function will print a error message and a do WARN_ON if the | ||
32 | * assertion failes. Normally this will do a stack up at the current location. | ||
33 | */ | ||
34 | #define caif_assert(assert) \ | ||
35 | do { \ | ||
36 | if (!(assert)) { \ | ||
37 | pr_err("caif:Assert detected:'%s'\n", #assert); \ | ||
38 | WARN_ON(!(assert)); \ | ||
39 | } \ | ||
40 | } while (0) | ||
41 | |||
42 | |||
43 | /** | ||
44 | * enum caif_ctrlcmd - CAIF Stack Control Signaling sent in layer.ctrlcmd(). | ||
45 | * | ||
46 | * @CAIF_CTRLCMD_FLOW_OFF_IND: Flow Control is OFF, transmit function | ||
47 | * should stop sending data | ||
48 | * | ||
49 | * @CAIF_CTRLCMD_FLOW_ON_IND: Flow Control is ON, transmit function | ||
50 | * can start sending data | ||
51 | * | ||
52 | * @CAIF_CTRLCMD_REMOTE_SHUTDOWN_IND: Remote end modem has decided to close | ||
53 | * down channel | ||
54 | * | ||
55 | * @CAIF_CTRLCMD_INIT_RSP: Called initially when the layer below | ||
56 | * has finished initialization | ||
57 | * | ||
58 | * @CAIF_CTRLCMD_DEINIT_RSP: Called when de-initialization is | ||
59 | * complete | ||
60 | * | ||
61 | * @CAIF_CTRLCMD_INIT_FAIL_RSP: Called if initialization fails | ||
62 | * | ||
63 | * @_CAIF_CTRLCMD_PHYIF_FLOW_OFF_IND: CAIF Link layer temporarily cannot | ||
64 | * send more packets. | ||
65 | * @_CAIF_CTRLCMD_PHYIF_FLOW_ON_IND: Called if CAIF Link layer is able | ||
66 | * to send packets again. | ||
67 | * @_CAIF_CTRLCMD_PHYIF_DOWN_IND: Called if CAIF Link layer is going | ||
68 | * down. | ||
69 | * | ||
70 | * These commands are sent upwards in the CAIF stack to the CAIF Client. | ||
71 | * They are used for signaling originating from the modem or CAIF Link Layer. | ||
72 | * These are either responses (*_RSP) or events (*_IND). | ||
73 | */ | ||
74 | enum caif_ctrlcmd { | ||
75 | CAIF_CTRLCMD_FLOW_OFF_IND, | ||
76 | CAIF_CTRLCMD_FLOW_ON_IND, | ||
77 | CAIF_CTRLCMD_REMOTE_SHUTDOWN_IND, | ||
78 | CAIF_CTRLCMD_INIT_RSP, | ||
79 | CAIF_CTRLCMD_DEINIT_RSP, | ||
80 | CAIF_CTRLCMD_INIT_FAIL_RSP, | ||
81 | _CAIF_CTRLCMD_PHYIF_FLOW_OFF_IND, | ||
82 | _CAIF_CTRLCMD_PHYIF_FLOW_ON_IND, | ||
83 | _CAIF_CTRLCMD_PHYIF_DOWN_IND, | ||
84 | }; | ||
85 | |||
86 | /** | ||
87 | * enum caif_modemcmd - Modem Control Signaling, sent from CAIF Client | ||
88 | * to the CAIF Link Layer or modem. | ||
89 | * | ||
90 | * @CAIF_MODEMCMD_FLOW_ON_REQ: Flow Control is ON, transmit function | ||
91 | * can start sending data. | ||
92 | * | ||
93 | * @CAIF_MODEMCMD_FLOW_OFF_REQ: Flow Control is OFF, transmit function | ||
94 | * should stop sending data. | ||
95 | * | ||
96 | * @_CAIF_MODEMCMD_PHYIF_USEFULL: Notify physical layer that it is in use | ||
97 | * | ||
98 | * @_CAIF_MODEMCMD_PHYIF_USELESS: Notify physical layer that it is | ||
99 | * no longer in use. | ||
100 | * | ||
101 | * These are requests sent 'downwards' in the stack. | ||
102 | * Flow ON, OFF can be indicated to the modem. | ||
103 | */ | ||
104 | enum caif_modemcmd { | ||
105 | CAIF_MODEMCMD_FLOW_ON_REQ = 0, | ||
106 | CAIF_MODEMCMD_FLOW_OFF_REQ = 1, | ||
107 | _CAIF_MODEMCMD_PHYIF_USEFULL = 3, | ||
108 | _CAIF_MODEMCMD_PHYIF_USELESS = 4 | ||
109 | }; | ||
110 | |||
111 | /** | ||
112 | * enum caif_direction - CAIF Packet Direction. | ||
113 | * Indicate if a packet is to be sent out or to be received in. | ||
114 | * @CAIF_DIR_IN: Incoming packet received. | ||
115 | * @CAIF_DIR_OUT: Outgoing packet to be transmitted. | ||
116 | */ | ||
117 | enum caif_direction { | ||
118 | CAIF_DIR_IN = 0, | ||
119 | CAIF_DIR_OUT = 1 | ||
120 | }; | ||
121 | |||
122 | /** | ||
123 | * struct cflayer - CAIF Stack layer. | ||
124 | * Defines the framework for the CAIF Core Stack. | ||
125 | * @up: Pointer up to the layer above. | ||
126 | * @dn: Pointer down to the layer below. | ||
127 | * @node: List node used when layer participate in a list. | ||
128 | * @receive: Packet receive function. | ||
129 | * @transmit: Packet transmit funciton. | ||
130 | * @ctrlcmd: Used for control signalling upwards in the stack. | ||
131 | * @modemcmd: Used for control signaling downwards in the stack. | ||
132 | * @prio: Priority of this layer. | ||
133 | * @id: The identity of this layer | ||
134 | * @type: The type of this layer | ||
135 | * @name: Name of the layer. | ||
136 | * | ||
137 | * This structure defines the layered structure in CAIF. | ||
138 | * | ||
139 | * It defines CAIF layering structure, used by all CAIF Layers and the | ||
140 | * layers interfacing CAIF. | ||
141 | * | ||
142 | * In order to integrate with CAIF an adaptation layer on top of the CAIF stack | ||
143 | * and PHY layer below the CAIF stack | ||
144 | * must be implemented. These layer must follow the design principles below. | ||
145 | * | ||
146 | * Principles for layering of protocol layers: | ||
147 | * - All layers must use this structure. If embedding it, then place this | ||
148 | * structure first in the layer specific structure. | ||
149 | * | ||
150 | * - Each layer should not depend on any others layer private data. | ||
151 | * | ||
152 | * - In order to send data upwards do | ||
153 | * layer->up->receive(layer->up, packet); | ||
154 | * | ||
155 | * - In order to send data downwards do | ||
156 | * layer->dn->transmit(layer->dn, info, packet); | ||
157 | */ | ||
158 | struct cflayer { | ||
159 | struct cflayer *up; | ||
160 | struct cflayer *dn; | ||
161 | struct list_head node; | ||
162 | |||
163 | /* | ||
164 | * receive() - Receive Function. | ||
165 | * Contract: Each layer must implement a receive function passing the | ||
166 | * CAIF packets upwards in the stack. | ||
167 | * Packet handling rules: | ||
168 | * - The CAIF packet (cfpkt) cannot be accessed after | ||
169 | * passing it to the next layer using up->receive(). | ||
170 | * - If parsing of the packet fails, the packet must be | ||
171 | * destroyed and -1 returned from the function. | ||
172 | * - If parsing succeeds (and above layers return OK) then | ||
173 | * the function must return a value > 0. | ||
174 | * | ||
175 | * Returns result < 0 indicates an error, 0 or positive value | ||
176 | * indicates success. | ||
177 | * | ||
178 | * @layr: Pointer to the current layer the receive function is | ||
179 | * implemented for (this pointer). | ||
180 | * @cfpkt: Pointer to CaifPacket to be handled. | ||
181 | */ | ||
182 | int (*receive)(struct cflayer *layr, struct cfpkt *cfpkt); | ||
183 | |||
184 | /* | ||
185 | * transmit() - Transmit Function. | ||
186 | * Contract: Each layer must implement a transmit function passing the | ||
187 | * CAIF packet downwards in the stack. | ||
188 | * Packet handling rules: | ||
189 | * - The CAIF packet (cfpkt) ownership is passed to the | ||
190 | * transmit function. This means that the the packet | ||
191 | * cannot be accessed after passing it to the below | ||
192 | * layer using dn->transmit(). | ||
193 | * | ||
194 | * - If transmit fails, however, the ownership is returned | ||
195 | * to thecaller. The caller of "dn->transmit()" must | ||
196 | * destroy or resend packet. | ||
197 | * | ||
198 | * - Return value less than zero means error, zero or | ||
199 | * greater than zero means OK. | ||
200 | * | ||
201 | * result < 0 indicates an error, 0 or positive value | ||
202 | * indicate success. | ||
203 | * | ||
204 | * @layr: Pointer to the current layer the receive function | ||
205 | * isimplemented for (this pointer). | ||
206 | * @cfpkt: Pointer to CaifPacket to be handled. | ||
207 | */ | ||
208 | int (*transmit) (struct cflayer *layr, struct cfpkt *cfpkt); | ||
209 | |||
210 | /* | ||
211 | * cttrlcmd() - Control Function upwards in CAIF Stack. | ||
212 | * Used for signaling responses (CAIF_CTRLCMD_*_RSP) | ||
213 | * and asynchronous events from the modem (CAIF_CTRLCMD_*_IND) | ||
214 | * | ||
215 | * @layr: Pointer to the current layer the receive function | ||
216 | * is implemented for (this pointer). | ||
217 | * @ctrl: Control Command. | ||
218 | */ | ||
219 | void (*ctrlcmd) (struct cflayer *layr, enum caif_ctrlcmd ctrl, | ||
220 | int phyid); | ||
221 | |||
222 | /* | ||
223 | * modemctrl() - Control Function used for controlling the modem. | ||
224 | * Used to signal down-wards in the CAIF stack. | ||
225 | * Returns 0 on success, < 0 upon failure. | ||
226 | * | ||
227 | * @layr: Pointer to the current layer the receive function | ||
228 | * is implemented for (this pointer). | ||
229 | * @ctrl: Control Command. | ||
230 | */ | ||
231 | int (*modemcmd) (struct cflayer *layr, enum caif_modemcmd ctrl); | ||
232 | |||
233 | unsigned short prio; | ||
234 | unsigned int id; | ||
235 | unsigned int type; | ||
236 | char name[CAIF_LAYER_NAME_SZ]; | ||
237 | }; | ||
238 | |||
239 | /** | ||
240 | * layer_set_up() - Set the up pointer for a specified layer. | ||
241 | * @layr: Layer where up pointer shall be set. | ||
242 | * @above: Layer above. | ||
243 | */ | ||
244 | #define layer_set_up(layr, above) ((layr)->up = (struct cflayer *)(above)) | ||
245 | |||
246 | /** | ||
247 | * layer_set_dn() - Set the down pointer for a specified layer. | ||
248 | * @layr: Layer where down pointer shall be set. | ||
249 | * @below: Layer below. | ||
250 | */ | ||
251 | #define layer_set_dn(layr, below) ((layr)->dn = (struct cflayer *)(below)) | ||
252 | |||
253 | /** | ||
254 | * struct dev_info - Physical Device info information about physical layer. | ||
255 | * @dev: Pointer to native physical device. | ||
256 | * @id: Physical ID of the physical connection used by the | ||
257 | * logical CAIF connection. Used by service layers to | ||
258 | * identify their physical id to Caif MUX (CFMUXL)so | ||
259 | * that the MUX can add the correct physical ID to the | ||
260 | * packet. | ||
261 | */ | ||
262 | struct dev_info { | ||
263 | void *dev; | ||
264 | unsigned int id; | ||
265 | }; | ||
266 | |||
267 | /** | ||
268 | * struct caif_payload_info - Payload information embedded in packet (sk_buff). | ||
269 | * | ||
270 | * @dev_info: Information about the receiving device. | ||
271 | * | ||
272 | * @hdr_len: Header length, used to align pay load on 32bit boundary. | ||
273 | * | ||
274 | * @channel_id: Channel ID of the logical CAIF connection. | ||
275 | * Used by mux to insert channel id into the caif packet. | ||
276 | */ | ||
277 | struct caif_payload_info { | ||
278 | struct dev_info *dev_info; | ||
279 | unsigned short hdr_len; | ||
280 | unsigned short channel_id; | ||
281 | }; | ||
282 | |||
283 | #endif /* CAIF_LAYER_H_ */ | ||
diff --git a/include/net/caif/cfcnfg.h b/include/net/caif/cfcnfg.h new file mode 100644 index 000000000000..9fc2fc20b884 --- /dev/null +++ b/include/net/caif/cfcnfg.h | |||
@@ -0,0 +1,140 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFCNFG_H_ | ||
8 | #define CFCNFG_H_ | ||
9 | #include <linux/spinlock.h> | ||
10 | #include <net/caif/caif_layer.h> | ||
11 | #include <net/caif/cfctrl.h> | ||
12 | |||
13 | struct cfcnfg; | ||
14 | |||
15 | /** | ||
16 | * enum cfcnfg_phy_type - Types of physical layers defined in CAIF Stack | ||
17 | * | ||
18 | * @CFPHYTYPE_FRAG: Fragmented frames physical interface. | ||
19 | * @CFPHYTYPE_CAIF: Generic CAIF physical interface | ||
20 | */ | ||
21 | enum cfcnfg_phy_type { | ||
22 | CFPHYTYPE_FRAG = 1, | ||
23 | CFPHYTYPE_CAIF, | ||
24 | CFPHYTYPE_MAX | ||
25 | }; | ||
26 | |||
27 | /** | ||
28 | * enum cfcnfg_phy_preference - Physical preference HW Abstraction | ||
29 | * | ||
30 | * @CFPHYPREF_UNSPECIFIED: Default physical interface | ||
31 | * | ||
32 | * @CFPHYPREF_LOW_LAT: Default physical interface for low-latency | ||
33 | * traffic | ||
34 | * @CFPHYPREF_HIGH_BW: Default physical interface for high-bandwidth | ||
35 | * traffic | ||
36 | * @CFPHYPREF_LOOP: TEST only Loopback interface simulating modem | ||
37 | * responses. | ||
38 | * | ||
39 | */ | ||
40 | enum cfcnfg_phy_preference { | ||
41 | CFPHYPREF_UNSPECIFIED, | ||
42 | CFPHYPREF_LOW_LAT, | ||
43 | CFPHYPREF_HIGH_BW, | ||
44 | CFPHYPREF_LOOP | ||
45 | }; | ||
46 | |||
47 | /** | ||
48 | * cfcnfg_create() - Create the CAIF configuration object. | ||
49 | */ | ||
50 | struct cfcnfg *cfcnfg_create(void); | ||
51 | |||
52 | /** | ||
53 | * cfcnfg_remove() - Remove the CFCNFG object | ||
54 | * @cfg: config object | ||
55 | */ | ||
56 | void cfcnfg_remove(struct cfcnfg *cfg); | ||
57 | |||
58 | /** | ||
59 | * cfcnfg_add_phy_layer() - Adds a physical layer to the CAIF stack. | ||
60 | * @cnfg: Pointer to a CAIF configuration object, created by | ||
61 | * cfcnfg_create(). | ||
62 | * @phy_type: Specifies the type of physical interface, e.g. | ||
63 | * CFPHYTYPE_FRAG. | ||
64 | * @dev: Pointer to link layer device | ||
65 | * @phy_layer: Specify the physical layer. The transmit function | ||
66 | * MUST be set in the structure. | ||
67 | * @phyid: The assigned physical ID for this layer, used in | ||
68 | * cfcnfg_add_adapt_layer to specify PHY for the link. | ||
69 | * @pref: The phy (link layer) preference. | ||
70 | * @fcs: Specify if checksum is used in CAIF Framing Layer. | ||
71 | * @stx: Specify if Start Of Frame eXtention is used. | ||
72 | */ | ||
73 | |||
74 | void | ||
75 | cfcnfg_add_phy_layer(struct cfcnfg *cnfg, enum cfcnfg_phy_type phy_type, | ||
76 | void *dev, struct cflayer *phy_layer, u16 *phyid, | ||
77 | enum cfcnfg_phy_preference pref, | ||
78 | bool fcs, bool stx); | ||
79 | |||
80 | /** | ||
81 | * cfcnfg_del_phy_layer - Deletes an phy layer from the CAIF stack. | ||
82 | * | ||
83 | * @cnfg: Pointer to a CAIF configuration object, created by | ||
84 | * cfcnfg_create(). | ||
85 | * @phy_layer: Adaptation layer to be removed. | ||
86 | */ | ||
87 | int cfcnfg_del_phy_layer(struct cfcnfg *cnfg, struct cflayer *phy_layer); | ||
88 | |||
89 | /** | ||
90 | * cfcnfg_disconn_adapt_layer - Disconnects an adaptation layer. | ||
91 | * | ||
92 | * @cnfg: Pointer to a CAIF configuration object, created by | ||
93 | * cfcnfg_create(). | ||
94 | * @adap_layer: Adaptation layer to be removed. | ||
95 | */ | ||
96 | int cfcnfg_disconn_adapt_layer(struct cfcnfg *cnfg, | ||
97 | struct cflayer *adap_layer); | ||
98 | |||
99 | /** | ||
100 | * cfcnfg_release_adap_layer - Used by client to release the adaptation layer. | ||
101 | * | ||
102 | * @adap_layer: Adaptation layer. | ||
103 | */ | ||
104 | void cfcnfg_release_adap_layer(struct cflayer *adap_layer); | ||
105 | |||
106 | /** | ||
107 | * cfcnfg_add_adaptation_layer - Add an adaptation layer to the CAIF stack. | ||
108 | * | ||
109 | * The adaptation Layer is where the interface to application or higher-level | ||
110 | * driver functionality is implemented. | ||
111 | * | ||
112 | * @cnfg: Pointer to a CAIF configuration object, created by | ||
113 | * cfcnfg_create(). | ||
114 | * @param: Link setup parameters. | ||
115 | * @adap_layer: Specify the adaptation layer; the receive and | ||
116 | * flow-control functions MUST be set in the structure. | ||
117 | * | ||
118 | */ | ||
119 | int cfcnfg_add_adaptation_layer(struct cfcnfg *cnfg, | ||
120 | struct cfctrl_link_param *param, | ||
121 | struct cflayer *adap_layer); | ||
122 | |||
123 | /** | ||
124 | * cfcnfg_get_phyid() - Get physical ID, given type. | ||
125 | * Returns one of the physical interfaces matching the given type. | ||
126 | * Zero if no match is found. | ||
127 | * @cnfg: Configuration object | ||
128 | * @phy_pref: Caif Link Layer preference | ||
129 | */ | ||
130 | struct dev_info *cfcnfg_get_phyid(struct cfcnfg *cnfg, | ||
131 | enum cfcnfg_phy_preference phy_pref); | ||
132 | |||
133 | /** | ||
134 | * cfcnfg_get_named() - Get the Physical Identifier of CAIF Link Layer | ||
135 | * @cnfg: Configuration object | ||
136 | * @name: Name of the Physical Layer (Caif Link Layer) | ||
137 | */ | ||
138 | int cfcnfg_get_named(struct cfcnfg *cnfg, char *name); | ||
139 | |||
140 | #endif /* CFCNFG_H_ */ | ||
diff --git a/include/net/caif/cfctrl.h b/include/net/caif/cfctrl.h new file mode 100644 index 000000000000..997603f2bf4c --- /dev/null +++ b/include/net/caif/cfctrl.h | |||
@@ -0,0 +1,139 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFCTRL_H_ | ||
8 | #define CFCTRL_H_ | ||
9 | #include <net/caif/caif_layer.h> | ||
10 | #include <net/caif/cfsrvl.h> | ||
11 | |||
12 | /* CAIF Control packet commands */ | ||
13 | enum cfctrl_cmd { | ||
14 | CFCTRL_CMD_LINK_SETUP = 0, | ||
15 | CFCTRL_CMD_LINK_DESTROY = 1, | ||
16 | CFCTRL_CMD_LINK_ERR = 2, | ||
17 | CFCTRL_CMD_ENUM = 3, | ||
18 | CFCTRL_CMD_SLEEP = 4, | ||
19 | CFCTRL_CMD_WAKE = 5, | ||
20 | CFCTRL_CMD_LINK_RECONF = 6, | ||
21 | CFCTRL_CMD_START_REASON = 7, | ||
22 | CFCTRL_CMD_RADIO_SET = 8, | ||
23 | CFCTRL_CMD_MODEM_SET = 9, | ||
24 | CFCTRL_CMD_MASK = 0xf | ||
25 | }; | ||
26 | |||
27 | /* Channel types */ | ||
28 | enum cfctrl_srv { | ||
29 | CFCTRL_SRV_DECM = 0, | ||
30 | CFCTRL_SRV_VEI = 1, | ||
31 | CFCTRL_SRV_VIDEO = 2, | ||
32 | CFCTRL_SRV_DBG = 3, | ||
33 | CFCTRL_SRV_DATAGRAM = 4, | ||
34 | CFCTRL_SRV_RFM = 5, | ||
35 | CFCTRL_SRV_UTIL = 6, | ||
36 | CFCTRL_SRV_MASK = 0xf | ||
37 | }; | ||
38 | |||
39 | #define CFCTRL_RSP_BIT 0x20 | ||
40 | #define CFCTRL_ERR_BIT 0x10 | ||
41 | |||
42 | struct cfctrl_rsp { | ||
43 | void (*linksetup_rsp)(struct cflayer *layer, u8 linkid, | ||
44 | enum cfctrl_srv serv, u8 phyid, | ||
45 | struct cflayer *adapt_layer); | ||
46 | void (*linkdestroy_rsp)(struct cflayer *layer, u8 linkid); | ||
47 | void (*linkerror_ind)(void); | ||
48 | void (*enum_rsp)(void); | ||
49 | void (*sleep_rsp)(void); | ||
50 | void (*wake_rsp)(void); | ||
51 | void (*restart_rsp)(void); | ||
52 | void (*radioset_rsp)(void); | ||
53 | void (*reject_rsp)(struct cflayer *layer, u8 linkid, | ||
54 | struct cflayer *client_layer);; | ||
55 | }; | ||
56 | |||
57 | /* Link Setup Parameters for CAIF-Links. */ | ||
58 | struct cfctrl_link_param { | ||
59 | enum cfctrl_srv linktype;/* (T3,T0) Type of Channel */ | ||
60 | u8 priority; /* (P4,P0) Priority of the channel */ | ||
61 | u8 phyid; /* (U2-U0) Physical interface to connect */ | ||
62 | u8 endpoint; /* (E1,E0) Endpoint for data channels */ | ||
63 | u8 chtype; /* (H1,H0) Channel-Type, applies to | ||
64 | * VEI, DEBUG */ | ||
65 | union { | ||
66 | struct { | ||
67 | u8 connid; /* (D7,D0) Video LinkId */ | ||
68 | } video; | ||
69 | |||
70 | struct { | ||
71 | u32 connid; /* (N31,Ngit0) Connection ID used | ||
72 | * for Datagram */ | ||
73 | } datagram; | ||
74 | |||
75 | struct { | ||
76 | u32 connid; /* Connection ID used for RFM */ | ||
77 | char volume[20]; /* Volume to mount for RFM */ | ||
78 | } rfm; /* Configuration for RFM */ | ||
79 | |||
80 | struct { | ||
81 | u16 fifosize_kb; /* Psock FIFO size in KB */ | ||
82 | u16 fifosize_bufs; /* Psock # signal buffers */ | ||
83 | char name[16]; /* Name of the PSOCK service */ | ||
84 | u8 params[255]; /* Link setup Parameters> */ | ||
85 | u16 paramlen; /* Length of Link Setup | ||
86 | * Parameters */ | ||
87 | } utility; /* Configuration for Utility Links (Psock) */ | ||
88 | } u; | ||
89 | }; | ||
90 | |||
91 | /* This structure is used internally in CFCTRL */ | ||
92 | struct cfctrl_request_info { | ||
93 | int sequence_no; | ||
94 | enum cfctrl_cmd cmd; | ||
95 | u8 channel_id; | ||
96 | struct cfctrl_link_param param; | ||
97 | struct cfctrl_request_info *next; | ||
98 | struct cflayer *client_layer; | ||
99 | }; | ||
100 | |||
101 | struct cfctrl { | ||
102 | struct cfsrvl serv; | ||
103 | struct cfctrl_rsp res; | ||
104 | atomic_t req_seq_no; | ||
105 | atomic_t rsp_seq_no; | ||
106 | struct cfctrl_request_info *first_req; | ||
107 | /* Protects from simultaneous access to first_req list */ | ||
108 | spinlock_t info_list_lock; | ||
109 | #ifndef CAIF_NO_LOOP | ||
110 | u8 loop_linkid; | ||
111 | int loop_linkused[256]; | ||
112 | /* Protects simultaneous access to loop_linkid and loop_linkused */ | ||
113 | spinlock_t loop_linkid_lock; | ||
114 | #endif | ||
115 | |||
116 | }; | ||
117 | |||
118 | void cfctrl_enum_req(struct cflayer *cfctrl, u8 physlinkid); | ||
119 | int cfctrl_linkup_request(struct cflayer *cfctrl, | ||
120 | struct cfctrl_link_param *param, | ||
121 | struct cflayer *user_layer); | ||
122 | int cfctrl_linkdown_req(struct cflayer *cfctrl, u8 linkid, | ||
123 | struct cflayer *client); | ||
124 | void cfctrl_sleep_req(struct cflayer *cfctrl); | ||
125 | void cfctrl_wake_req(struct cflayer *cfctrl); | ||
126 | void cfctrl_getstartreason_req(struct cflayer *cfctrl); | ||
127 | struct cflayer *cfctrl_create(void); | ||
128 | void cfctrl_set_dnlayer(struct cflayer *this, struct cflayer *dn); | ||
129 | void cfctrl_set_uplayer(struct cflayer *this, struct cflayer *up); | ||
130 | struct cfctrl_rsp *cfctrl_get_respfuncs(struct cflayer *layer); | ||
131 | bool cfctrl_req_eq(struct cfctrl_request_info *r1, | ||
132 | struct cfctrl_request_info *r2); | ||
133 | void cfctrl_insert_req(struct cfctrl *ctrl, | ||
134 | struct cfctrl_request_info *req); | ||
135 | struct cfctrl_request_info *cfctrl_remove_req(struct cfctrl *ctrl, | ||
136 | struct cfctrl_request_info *req); | ||
137 | void cfctrl_cancel_req(struct cflayer *layr, struct cflayer *adap_layer); | ||
138 | |||
139 | #endif /* CFCTRL_H_ */ | ||
diff --git a/include/net/caif/cffrml.h b/include/net/caif/cffrml.h new file mode 100644 index 000000000000..3f14d2e1ce61 --- /dev/null +++ b/include/net/caif/cffrml.h | |||
@@ -0,0 +1,16 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFFRML_H_ | ||
8 | #define CFFRML_H_ | ||
9 | #include <net/caif/caif_layer.h> | ||
10 | |||
11 | struct cffrml; | ||
12 | struct cflayer *cffrml_create(u16 phyid, bool DoFCS); | ||
13 | void cffrml_set_uplayer(struct cflayer *this, struct cflayer *up); | ||
14 | void cffrml_set_dnlayer(struct cflayer *this, struct cflayer *dn); | ||
15 | |||
16 | #endif /* CFFRML_H_ */ | ||
diff --git a/include/net/caif/cfmuxl.h b/include/net/caif/cfmuxl.h new file mode 100644 index 000000000000..4e1b4f33423e --- /dev/null +++ b/include/net/caif/cfmuxl.h | |||
@@ -0,0 +1,22 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFMUXL_H_ | ||
8 | #define CFMUXL_H_ | ||
9 | #include <net/caif/caif_layer.h> | ||
10 | |||
11 | struct cfsrvl; | ||
12 | struct cffrml; | ||
13 | |||
14 | struct cflayer *cfmuxl_create(void); | ||
15 | int cfmuxl_set_uplayer(struct cflayer *layr, struct cflayer *up, u8 linkid); | ||
16 | struct cflayer *cfmuxl_remove_dnlayer(struct cflayer *layr, u8 phyid); | ||
17 | int cfmuxl_set_dnlayer(struct cflayer *layr, struct cflayer *up, u8 phyid); | ||
18 | struct cflayer *cfmuxl_remove_uplayer(struct cflayer *layr, u8 linkid); | ||
19 | bool cfmuxl_is_phy_inuse(struct cflayer *layr, u8 phyid); | ||
20 | u8 cfmuxl_get_phyid(struct cflayer *layr, u8 channel_id); | ||
21 | |||
22 | #endif /* CFMUXL_H_ */ | ||
diff --git a/include/net/caif/cfpkt.h b/include/net/caif/cfpkt.h new file mode 100644 index 000000000000..fbc681beff52 --- /dev/null +++ b/include/net/caif/cfpkt.h | |||
@@ -0,0 +1,274 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFPKT_H_ | ||
8 | #define CFPKT_H_ | ||
9 | #include <net/caif/caif_layer.h> | ||
10 | #include <linux/types.h> | ||
11 | struct cfpkt; | ||
12 | |||
13 | /* Create a CAIF packet. | ||
14 | * len: Length of packet to be created | ||
15 | * @return New packet. | ||
16 | */ | ||
17 | struct cfpkt *cfpkt_create(u16 len); | ||
18 | |||
19 | /* Create a CAIF packet. | ||
20 | * data Data to copy. | ||
21 | * len Length of packet to be created | ||
22 | * @return New packet. | ||
23 | */ | ||
24 | struct cfpkt *cfpkt_create_uplink(const unsigned char *data, unsigned int len); | ||
25 | /* | ||
26 | * Destroy a CAIF Packet. | ||
27 | * pkt Packet to be destoyed. | ||
28 | */ | ||
29 | void cfpkt_destroy(struct cfpkt *pkt); | ||
30 | |||
31 | /* | ||
32 | * Extract header from packet. | ||
33 | * | ||
34 | * pkt Packet to extract header data from. | ||
35 | * data Pointer to copy the header data into. | ||
36 | * len Length of head data to copy. | ||
37 | * @return zero on success and error code upon failure | ||
38 | */ | ||
39 | int cfpkt_extr_head(struct cfpkt *pkt, void *data, u16 len); | ||
40 | |||
41 | /* | ||
42 | * Peek header from packet. | ||
43 | * Reads data from packet without changing packet. | ||
44 | * | ||
45 | * pkt Packet to extract header data from. | ||
46 | * data Pointer to copy the header data into. | ||
47 | * len Length of head data to copy. | ||
48 | * @return zero on success and error code upon failure | ||
49 | */ | ||
50 | int cfpkt_peek_head(struct cfpkt *pkt, void *data, u16 len); | ||
51 | |||
52 | /* | ||
53 | * Extract header from trailer (end of packet). | ||
54 | * | ||
55 | * pkt Packet to extract header data from. | ||
56 | * data Pointer to copy the trailer data into. | ||
57 | * len Length of header data to copy. | ||
58 | * @return zero on success and error code upon failure | ||
59 | */ | ||
60 | int cfpkt_extr_trail(struct cfpkt *pkt, void *data, u16 len); | ||
61 | |||
62 | /* | ||
63 | * Add header to packet. | ||
64 | * | ||
65 | * | ||
66 | * pkt Packet to add header data to. | ||
67 | * data Pointer to data to copy into the header. | ||
68 | * len Length of header data to copy. | ||
69 | * @return zero on success and error code upon failure | ||
70 | */ | ||
71 | int cfpkt_add_head(struct cfpkt *pkt, const void *data, u16 len); | ||
72 | |||
73 | /* | ||
74 | * Add trailer to packet. | ||
75 | * | ||
76 | * | ||
77 | * pkt Packet to add trailer data to. | ||
78 | * data Pointer to data to copy into the trailer. | ||
79 | * len Length of trailer data to copy. | ||
80 | * @return zero on success and error code upon failure | ||
81 | */ | ||
82 | int cfpkt_add_trail(struct cfpkt *pkt, const void *data, u16 len); | ||
83 | |||
84 | /* | ||
85 | * Pad trailer on packet. | ||
86 | * Moves data pointer in packet, no content copied. | ||
87 | * | ||
88 | * pkt Packet in which to pad trailer. | ||
89 | * len Length of padding to add. | ||
90 | * @return zero on success and error code upon failure | ||
91 | */ | ||
92 | int cfpkt_pad_trail(struct cfpkt *pkt, u16 len); | ||
93 | |||
94 | /* | ||
95 | * Add a single byte to packet body (tail). | ||
96 | * | ||
97 | * pkt Packet in which to add byte. | ||
98 | * data Byte to add. | ||
99 | * @return zero on success and error code upon failure | ||
100 | */ | ||
101 | int cfpkt_addbdy(struct cfpkt *pkt, const u8 data); | ||
102 | |||
103 | /* | ||
104 | * Add a data to packet body (tail). | ||
105 | * | ||
106 | * pkt Packet in which to add data. | ||
107 | * data Pointer to data to copy into the packet body. | ||
108 | * len Length of data to add. | ||
109 | * @return zero on success and error code upon failure | ||
110 | */ | ||
111 | int cfpkt_add_body(struct cfpkt *pkt, const void *data, u16 len); | ||
112 | |||
113 | /* | ||
114 | * Checks whether there are more data to process in packet. | ||
115 | * pkt Packet to check. | ||
116 | * @return true if more data are available in packet false otherwise | ||
117 | */ | ||
118 | bool cfpkt_more(struct cfpkt *pkt); | ||
119 | |||
120 | /* | ||
121 | * Checks whether the packet is erroneous, | ||
122 | * i.e. if it has been attempted to extract more data than available in packet | ||
123 | * or writing more data than has been allocated in cfpkt_create(). | ||
124 | * pkt Packet to check. | ||
125 | * @return true on error false otherwise | ||
126 | */ | ||
127 | bool cfpkt_erroneous(struct cfpkt *pkt); | ||
128 | |||
129 | /* | ||
130 | * Get the packet length. | ||
131 | * pkt Packet to get length from. | ||
132 | * @return Number of bytes in packet. | ||
133 | */ | ||
134 | u16 cfpkt_getlen(struct cfpkt *pkt); | ||
135 | |||
136 | /* | ||
137 | * Set the packet length, by adjusting the trailer pointer according to length. | ||
138 | * pkt Packet to set length. | ||
139 | * len Packet length. | ||
140 | * @return Number of bytes in packet. | ||
141 | */ | ||
142 | int cfpkt_setlen(struct cfpkt *pkt, u16 len); | ||
143 | |||
144 | /* | ||
145 | * cfpkt_append - Appends a packet's data to another packet. | ||
146 | * dstpkt: Packet to append data into, WILL BE FREED BY THIS FUNCTION | ||
147 | * addpkt: Packet to be appended and automatically released, | ||
148 | * WILL BE FREED BY THIS FUNCTION. | ||
149 | * expectlen: Packet's expected total length. This should be considered | ||
150 | * as a hint. | ||
151 | * NB: Input packets will be destroyed after appending and cannot be used | ||
152 | * after calling this function. | ||
153 | * @return The new appended packet. | ||
154 | */ | ||
155 | struct cfpkt *cfpkt_append(struct cfpkt *dstpkt, struct cfpkt *addpkt, | ||
156 | u16 expectlen); | ||
157 | |||
158 | /* | ||
159 | * cfpkt_split - Split a packet into two packets at the specified split point. | ||
160 | * pkt: Packet to be split (will contain the first part of the data on exit) | ||
161 | * pos: Position to split packet in two parts. | ||
162 | * @return The new packet, containing the second part of the data. | ||
163 | */ | ||
164 | struct cfpkt *cfpkt_split(struct cfpkt *pkt, u16 pos); | ||
165 | |||
166 | /* | ||
167 | * Iteration function, iterates the packet buffers from start to end. | ||
168 | * | ||
169 | * Checksum iteration function used to iterate buffers | ||
170 | * (we may have packets consisting of a chain of buffers) | ||
171 | * pkt: Packet to calculate checksum for | ||
172 | * iter_func: Function pointer to iteration function | ||
173 | * chks: Checksum calculated so far. | ||
174 | * buf: Pointer to the buffer to checksum | ||
175 | * len: Length of buf. | ||
176 | * data: Initial checksum value. | ||
177 | * @return Checksum of buffer. | ||
178 | */ | ||
179 | |||
180 | u16 cfpkt_iterate(struct cfpkt *pkt, | ||
181 | u16 (*iter_func)(u16 chks, void *buf, u16 len), | ||
182 | u16 data); | ||
183 | |||
184 | /* Append by giving user access to packet buffer | ||
185 | * cfpkt Packet to append to | ||
186 | * buf Buffer inside pkt that user shall copy data into | ||
187 | * buflen Length of buffer and number of bytes added to packet | ||
188 | * @return 0 on error, 1 on success | ||
189 | */ | ||
190 | int cfpkt_raw_append(struct cfpkt *cfpkt, void **buf, unsigned int buflen); | ||
191 | |||
192 | /* Extract by giving user access to packet buffer | ||
193 | * cfpkt Packet to extract from | ||
194 | * buf Buffer inside pkt that user shall copy data from | ||
195 | * buflen Length of buffer and number of bytes removed from packet | ||
196 | * @return 0 on error, 1 on success | ||
197 | */ | ||
198 | int cfpkt_raw_extract(struct cfpkt *cfpkt, void **buf, unsigned int buflen); | ||
199 | |||
200 | /* Map from a "native" packet (e.g. Linux Socket Buffer) to a CAIF packet. | ||
201 | * dir - Direction indicating whether this packet is to be sent or received. | ||
202 | * nativepkt - The native packet to be transformed to a CAIF packet | ||
203 | * @return The mapped CAIF Packet CFPKT. | ||
204 | */ | ||
205 | struct cfpkt *cfpkt_fromnative(enum caif_direction dir, void *nativepkt); | ||
206 | |||
207 | /* Map from a CAIF packet to a "native" packet (e.g. Linux Socket Buffer). | ||
208 | * pkt - The CAIF packet to be transformed into a "native" packet. | ||
209 | * @return The native packet transformed from a CAIF packet. | ||
210 | */ | ||
211 | void *cfpkt_tonative(struct cfpkt *pkt); | ||
212 | |||
213 | /* | ||
214 | * Insert a packet in the packet queue. | ||
215 | * pktq Packet queue to insert into | ||
216 | * pkt Packet to be inserted in queue | ||
217 | * prio Priority of packet | ||
218 | */ | ||
219 | void cfpkt_queue(struct cfpktq *pktq, struct cfpkt *pkt, | ||
220 | unsigned short prio); | ||
221 | |||
222 | /* | ||
223 | * Remove a packet from the packet queue. | ||
224 | * pktq Packet queue to fetch packets from. | ||
225 | * @return Dequeued packet. | ||
226 | */ | ||
227 | struct cfpkt *cfpkt_dequeue(struct cfpktq *pktq); | ||
228 | |||
229 | /* | ||
230 | * Peek into a packet from the packet queue. | ||
231 | * pktq Packet queue to fetch packets from. | ||
232 | * @return Peeked packet. | ||
233 | */ | ||
234 | struct cfpkt *cfpkt_qpeek(struct cfpktq *pktq); | ||
235 | |||
236 | /* | ||
237 | * Initiates the packet queue. | ||
238 | * @return Pointer to new packet queue. | ||
239 | */ | ||
240 | struct cfpktq *cfpktq_create(void); | ||
241 | |||
242 | /* | ||
243 | * Get the number of packets in the queue. | ||
244 | * pktq Packet queue to fetch count from. | ||
245 | * @return Number of packets in queue. | ||
246 | */ | ||
247 | int cfpkt_qcount(struct cfpktq *pktq); | ||
248 | |||
249 | /* | ||
250 | * Put content of packet into buffer for debuging purposes. | ||
251 | * pkt Packet to copy data from | ||
252 | * buf Buffer to copy data into | ||
253 | * buflen Length of data to copy | ||
254 | * @return Pointer to copied data | ||
255 | */ | ||
256 | char *cfpkt_log_pkt(struct cfpkt *pkt, char *buf, int buflen); | ||
257 | |||
258 | /* | ||
259 | * Clones a packet and releases the original packet. | ||
260 | * This is used for taking ownership of a packet e.g queueing. | ||
261 | * pkt Packet to clone and release. | ||
262 | * @return Cloned packet. | ||
263 | */ | ||
264 | struct cfpkt *cfpkt_clone_release(struct cfpkt *pkt); | ||
265 | |||
266 | |||
267 | /* | ||
268 | * Returns packet information for a packet. | ||
269 | * pkt Packet to get info from; | ||
270 | * @return Packet information | ||
271 | */ | ||
272 | struct caif_payload_info *cfpkt_info(struct cfpkt *pkt); | ||
273 | /*! @} */ | ||
274 | #endif /* CFPKT_H_ */ | ||
diff --git a/include/net/caif/cfserl.h b/include/net/caif/cfserl.h new file mode 100644 index 000000000000..b8374321b362 --- /dev/null +++ b/include/net/caif/cfserl.h | |||
@@ -0,0 +1,12 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFSERL_H_ | ||
8 | #define CFSERL_H_ | ||
9 | #include <net/caif/caif_layer.h> | ||
10 | |||
11 | struct cflayer *cfserl_create(int type, int instance, bool use_stx); | ||
12 | #endif /* CFSERL_H_ */ | ||
diff --git a/include/net/caif/cfsrvl.h b/include/net/caif/cfsrvl.h new file mode 100644 index 000000000000..2dc9eb193ecf --- /dev/null +++ b/include/net/caif/cfsrvl.h | |||
@@ -0,0 +1,56 @@ | |||
1 | /* | ||
2 | * Copyright (C) ST-Ericsson AB 2010 | ||
3 | * Author: Sjur Brendeland/sjur.brandeland@stericsson.com | ||
4 | * License terms: GNU General Public License (GPL) version 2 | ||
5 | */ | ||
6 | |||
7 | #ifndef CFSRVL_H_ | ||
8 | #define CFSRVL_H_ | ||
9 | #include <linux/list.h> | ||
10 | #include <linux/stddef.h> | ||
11 | #include <linux/types.h> | ||
12 | #include <linux/kref.h> | ||
13 | |||
14 | struct cfsrvl { | ||
15 | struct cflayer layer; | ||
16 | bool open; | ||
17 | bool phy_flow_on; | ||
18 | bool modem_flow_on; | ||
19 | struct dev_info dev_info; | ||
20 | struct kref ref; | ||
21 | }; | ||
22 | |||
23 | void cfsrvl_release(struct kref *kref); | ||
24 | struct cflayer *cfvei_create(u8 linkid, struct dev_info *dev_info); | ||
25 | struct cflayer *cfdgml_create(u8 linkid, struct dev_info *dev_info); | ||
26 | struct cflayer *cfutill_create(u8 linkid, struct dev_info *dev_info); | ||
27 | struct cflayer *cfvidl_create(u8 linkid, struct dev_info *dev_info); | ||
28 | struct cflayer *cfrfml_create(u8 linkid, struct dev_info *dev_info); | ||
29 | struct cflayer *cfdbgl_create(u8 linkid, struct dev_info *dev_info); | ||
30 | bool cfsrvl_phyid_match(struct cflayer *layer, int phyid); | ||
31 | void cfservl_destroy(struct cflayer *layer); | ||
32 | void cfsrvl_init(struct cfsrvl *service, | ||
33 | u8 channel_id, | ||
34 | struct dev_info *dev_info); | ||
35 | bool cfsrvl_ready(struct cfsrvl *service, int *err); | ||
36 | u8 cfsrvl_getphyid(struct cflayer *layer); | ||
37 | |||
38 | static inline void cfsrvl_get(struct cflayer *layr) | ||
39 | { | ||
40 | struct cfsrvl *s; | ||
41 | if (layr == NULL) | ||
42 | return; | ||
43 | s = container_of(layr, struct cfsrvl, layer); | ||
44 | kref_get(&s->ref); | ||
45 | } | ||
46 | |||
47 | static inline void cfsrvl_put(struct cflayer *layr) | ||
48 | { | ||
49 | struct cfsrvl *s; | ||
50 | if (layr == NULL) | ||
51 | return; | ||
52 | s = container_of(layr, struct cfsrvl, layer); | ||
53 | kref_put(&s->ref, cfsrvl_release); | ||
54 | } | ||
55 | |||
56 | #endif /* CFSRVL_H_ */ | ||
diff --git a/include/net/dn_fib.h b/include/net/dn_fib.h index 52da6c3dd50d..bbcde3238e58 100644 --- a/include/net/dn_fib.h +++ b/include/net/dn_fib.h | |||
@@ -50,10 +50,6 @@ struct dn_fib_info { | |||
50 | __le16 fib_prefsrc; | 50 | __le16 fib_prefsrc; |
51 | __u32 fib_priority; | 51 | __u32 fib_priority; |
52 | __u32 fib_metrics[RTAX_MAX]; | 52 | __u32 fib_metrics[RTAX_MAX]; |
53 | #define dn_fib_mtu fib_metrics[RTAX_MTU-1] | ||
54 | #define dn_fib_window fib_metrics[RTAX_WINDOW-1] | ||
55 | #define dn_fib_rtt fib_metrics[RTAX_RTT-1] | ||
56 | #define dn_fib_advmss fib_metrics[RTAX_ADVMSS-1] | ||
57 | int fib_nhs; | 53 | int fib_nhs; |
58 | int fib_power; | 54 | int fib_power; |
59 | struct dn_fib_nh fib_nh[0]; | 55 | struct dn_fib_nh fib_nh[0]; |
diff --git a/include/net/dst.h b/include/net/dst.h index ce078cda6b74..aac5a5fcfda9 100644 --- a/include/net/dst.h +++ b/include/net/dst.h | |||
@@ -225,21 +225,6 @@ static inline void dst_confirm(struct dst_entry *dst) | |||
225 | neigh_confirm(dst->neighbour); | 225 | neigh_confirm(dst->neighbour); |
226 | } | 226 | } |
227 | 227 | ||
228 | static inline void dst_negative_advice(struct dst_entry **dst_p, | ||
229 | struct sock *sk) | ||
230 | { | ||
231 | struct dst_entry * dst = *dst_p; | ||
232 | if (dst && dst->ops->negative_advice) { | ||
233 | *dst_p = dst->ops->negative_advice(dst); | ||
234 | |||
235 | if (dst != *dst_p) { | ||
236 | extern void sk_reset_txq(struct sock *sk); | ||
237 | |||
238 | sk_reset_txq(sk); | ||
239 | } | ||
240 | } | ||
241 | } | ||
242 | |||
243 | static inline void dst_link_failure(struct sk_buff *skb) | 228 | static inline void dst_link_failure(struct sk_buff *skb) |
244 | { | 229 | { |
245 | struct dst_entry *dst = skb_dst(skb); | 230 | struct dst_entry *dst = skb_dst(skb); |
diff --git a/include/net/fib_rules.h b/include/net/fib_rules.h index c07ac9650ebc..e8923bc20f9f 100644 --- a/include/net/fib_rules.h +++ b/include/net/fib_rules.h | |||
@@ -2,6 +2,7 @@ | |||
2 | #define __NET_FIB_RULES_H | 2 | #define __NET_FIB_RULES_H |
3 | 3 | ||
4 | #include <linux/types.h> | 4 | #include <linux/types.h> |
5 | #include <linux/slab.h> | ||
5 | #include <linux/netdevice.h> | 6 | #include <linux/netdevice.h> |
6 | #include <linux/fib_rules.h> | 7 | #include <linux/fib_rules.h> |
7 | #include <net/flow.h> | 8 | #include <net/flow.h> |
@@ -103,7 +104,7 @@ static inline u32 frh_get_table(struct fib_rule_hdr *frh, struct nlattr **nla) | |||
103 | return frh->table; | 104 | return frh->table; |
104 | } | 105 | } |
105 | 106 | ||
106 | extern struct fib_rules_ops *fib_rules_register(struct fib_rules_ops *, struct net *); | 107 | extern struct fib_rules_ops *fib_rules_register(const struct fib_rules_ops *, struct net *); |
107 | extern void fib_rules_unregister(struct fib_rules_ops *); | 108 | extern void fib_rules_unregister(struct fib_rules_ops *); |
108 | extern void fib_rules_cleanup_ops(struct fib_rules_ops *); | 109 | extern void fib_rules_cleanup_ops(struct fib_rules_ops *); |
109 | 110 | ||
@@ -113,4 +114,5 @@ extern int fib_rules_lookup(struct fib_rules_ops *, | |||
113 | extern int fib_default_rule_add(struct fib_rules_ops *, | 114 | extern int fib_default_rule_add(struct fib_rules_ops *, |
114 | u32 pref, u32 table, | 115 | u32 pref, u32 table, |
115 | u32 flags); | 116 | u32 flags); |
117 | extern u32 fib_default_rule_pref(struct fib_rules_ops *ops); | ||
116 | #endif | 118 | #endif |
diff --git a/include/net/flow.h b/include/net/flow.h index 809970b7dfee..bb08692a20b0 100644 --- a/include/net/flow.h +++ b/include/net/flow.h | |||
@@ -86,11 +86,26 @@ struct flowi { | |||
86 | 86 | ||
87 | struct net; | 87 | struct net; |
88 | struct sock; | 88 | struct sock; |
89 | typedef int (*flow_resolve_t)(struct net *net, struct flowi *key, u16 family, | 89 | struct flow_cache_ops; |
90 | u8 dir, void **objp, atomic_t **obj_refp); | 90 | |
91 | struct flow_cache_object { | ||
92 | const struct flow_cache_ops *ops; | ||
93 | }; | ||
94 | |||
95 | struct flow_cache_ops { | ||
96 | struct flow_cache_object *(*get)(struct flow_cache_object *); | ||
97 | int (*check)(struct flow_cache_object *); | ||
98 | void (*delete)(struct flow_cache_object *); | ||
99 | }; | ||
100 | |||
101 | typedef struct flow_cache_object *(*flow_resolve_t)( | ||
102 | struct net *net, struct flowi *key, u16 family, | ||
103 | u8 dir, struct flow_cache_object *oldobj, void *ctx); | ||
104 | |||
105 | extern struct flow_cache_object *flow_cache_lookup( | ||
106 | struct net *net, struct flowi *key, u16 family, | ||
107 | u8 dir, flow_resolve_t resolver, void *ctx); | ||
91 | 108 | ||
92 | extern void *flow_cache_lookup(struct net *net, struct flowi *key, u16 family, | ||
93 | u8 dir, flow_resolve_t resolver); | ||
94 | extern void flow_cache_flush(void); | 109 | extern void flow_cache_flush(void); |
95 | extern atomic_t flow_cache_genid; | 110 | extern atomic_t flow_cache_genid; |
96 | 111 | ||
diff --git a/include/net/icmp.h b/include/net/icmp.h index 15b3dfe9fce8..6e991e0d0d6f 100644 --- a/include/net/icmp.h +++ b/include/net/icmp.h | |||
@@ -48,15 +48,4 @@ extern void icmp_out_count(struct net *net, unsigned char type); | |||
48 | /* Move into dst.h ? */ | 48 | /* Move into dst.h ? */ |
49 | extern int xrlim_allow(struct dst_entry *dst, int timeout); | 49 | extern int xrlim_allow(struct dst_entry *dst, int timeout); |
50 | 50 | ||
51 | struct raw_sock { | ||
52 | /* inet_sock has to be the first member */ | ||
53 | struct inet_sock inet; | ||
54 | struct icmp_filter filter; | ||
55 | }; | ||
56 | |||
57 | static inline struct raw_sock *raw_sk(const struct sock *sk) | ||
58 | { | ||
59 | return (struct raw_sock *)sk; | ||
60 | } | ||
61 | |||
62 | #endif /* _ICMP_H */ | 51 | #endif /* _ICMP_H */ |
diff --git a/include/net/if_inet6.h b/include/net/if_inet6.h index 545d8b059bef..13f9fc086d54 100644 --- a/include/net/if_inet6.h +++ b/include/net/if_inet6.h | |||
@@ -54,16 +54,17 @@ struct inet6_ifaddr { | |||
54 | struct inet6_dev *idev; | 54 | struct inet6_dev *idev; |
55 | struct rt6_info *rt; | 55 | struct rt6_info *rt; |
56 | 56 | ||
57 | struct inet6_ifaddr *lst_next; /* next addr in addr_lst */ | 57 | struct hlist_node addr_lst; |
58 | struct inet6_ifaddr *if_next; /* next addr in inet6_dev */ | 58 | struct list_head if_list; |
59 | 59 | ||
60 | #ifdef CONFIG_IPV6_PRIVACY | 60 | #ifdef CONFIG_IPV6_PRIVACY |
61 | struct inet6_ifaddr *tmp_next; /* next addr in tempaddr_lst */ | 61 | struct list_head tmp_list; |
62 | struct inet6_ifaddr *ifpub; | 62 | struct inet6_ifaddr *ifpub; |
63 | int regen_count; | 63 | int regen_count; |
64 | #endif | 64 | #endif |
65 | 65 | ||
66 | int dead; | 66 | int dead; |
67 | struct rcu_head rcu; | ||
67 | }; | 68 | }; |
68 | 69 | ||
69 | struct ip6_sf_socklist { | 70 | struct ip6_sf_socklist { |
@@ -151,9 +152,9 @@ struct ipv6_devstat { | |||
151 | }; | 152 | }; |
152 | 153 | ||
153 | struct inet6_dev { | 154 | struct inet6_dev { |
154 | struct net_device *dev; | 155 | struct net_device *dev; |
155 | 156 | ||
156 | struct inet6_ifaddr *addr_list; | 157 | struct list_head addr_list; |
157 | 158 | ||
158 | struct ifmcaddr6 *mc_list; | 159 | struct ifmcaddr6 *mc_list; |
159 | struct ifmcaddr6 *mc_tomb; | 160 | struct ifmcaddr6 *mc_tomb; |
@@ -175,7 +176,7 @@ struct inet6_dev { | |||
175 | #ifdef CONFIG_IPV6_PRIVACY | 176 | #ifdef CONFIG_IPV6_PRIVACY |
176 | u8 rndid[8]; | 177 | u8 rndid[8]; |
177 | struct timer_list regen_timer; | 178 | struct timer_list regen_timer; |
178 | struct inet6_ifaddr *tempaddr_list; | 179 | struct list_head tempaddr_list; |
179 | #endif | 180 | #endif |
180 | 181 | ||
181 | struct neigh_parms *nd_parms; | 182 | struct neigh_parms *nd_parms; |
diff --git a/include/net/inet6_connection_sock.h b/include/net/inet6_connection_sock.h index f13ddc2543b1..aae08f686633 100644 --- a/include/net/inet6_connection_sock.h +++ b/include/net/inet6_connection_sock.h | |||
@@ -38,5 +38,5 @@ extern void inet6_csk_reqsk_queue_hash_add(struct sock *sk, | |||
38 | 38 | ||
39 | extern void inet6_csk_addr2sockaddr(struct sock *sk, struct sockaddr *uaddr); | 39 | extern void inet6_csk_addr2sockaddr(struct sock *sk, struct sockaddr *uaddr); |
40 | 40 | ||
41 | extern int inet6_csk_xmit(struct sk_buff *skb, int ipfragok); | 41 | extern int inet6_csk_xmit(struct sk_buff *skb); |
42 | #endif /* _INET6_CONNECTION_SOCK_H */ | 42 | #endif /* _INET6_CONNECTION_SOCK_H */ |
diff --git a/include/net/inet_connection_sock.h b/include/net/inet_connection_sock.h index 696d6e4ce68a..b6d3b55da19b 100644 --- a/include/net/inet_connection_sock.h +++ b/include/net/inet_connection_sock.h | |||
@@ -36,9 +36,8 @@ struct tcp_congestion_ops; | |||
36 | * (i.e. things that depend on the address family) | 36 | * (i.e. things that depend on the address family) |
37 | */ | 37 | */ |
38 | struct inet_connection_sock_af_ops { | 38 | struct inet_connection_sock_af_ops { |
39 | int (*queue_xmit)(struct sk_buff *skb, int ipfragok); | 39 | int (*queue_xmit)(struct sk_buff *skb); |
40 | void (*send_check)(struct sock *sk, int len, | 40 | void (*send_check)(struct sock *sk, struct sk_buff *skb); |
41 | struct sk_buff *skb); | ||
42 | int (*rebuild_header)(struct sock *sk); | 41 | int (*rebuild_header)(struct sock *sk); |
43 | int (*conn_request)(struct sock *sk, struct sk_buff *skb); | 42 | int (*conn_request)(struct sock *sk, struct sk_buff *skb); |
44 | struct sock *(*syn_recv_sock)(struct sock *sk, struct sk_buff *skb, | 43 | struct sock *(*syn_recv_sock)(struct sock *sk, struct sk_buff *skb, |
diff --git a/include/net/inet_sock.h b/include/net/inet_sock.h index 83fd34437cf1..1653de515cee 100644 --- a/include/net/inet_sock.h +++ b/include/net/inet_sock.h | |||
@@ -21,6 +21,7 @@ | |||
21 | #include <linux/string.h> | 21 | #include <linux/string.h> |
22 | #include <linux/types.h> | 22 | #include <linux/types.h> |
23 | #include <linux/jhash.h> | 23 | #include <linux/jhash.h> |
24 | #include <linux/netdevice.h> | ||
24 | 25 | ||
25 | #include <net/flow.h> | 26 | #include <net/flow.h> |
26 | #include <net/sock.h> | 27 | #include <net/sock.h> |
diff --git a/include/net/inet_timewait_sock.h b/include/net/inet_timewait_sock.h index 79f67eae8a7e..a066fdd50da6 100644 --- a/include/net/inet_timewait_sock.h +++ b/include/net/inet_timewait_sock.h | |||
@@ -224,7 +224,9 @@ static inline | |||
224 | struct net *twsk_net(const struct inet_timewait_sock *twsk) | 224 | struct net *twsk_net(const struct inet_timewait_sock *twsk) |
225 | { | 225 | { |
226 | #ifdef CONFIG_NET_NS | 226 | #ifdef CONFIG_NET_NS |
227 | return rcu_dereference(twsk->tw_net); | 227 | return rcu_dereference_raw(twsk->tw_net); /* protected by locking, */ |
228 | /* reference counting, */ | ||
229 | /* initialization, or RCU. */ | ||
228 | #else | 230 | #else |
229 | return &init_net; | 231 | return &init_net; |
230 | #endif | 232 | #endif |
diff --git a/include/net/ip.h b/include/net/ip.h index 503994a38ed1..8149b77cea9b 100644 --- a/include/net/ip.h +++ b/include/net/ip.h | |||
@@ -101,7 +101,7 @@ extern int ip_do_nat(struct sk_buff *skb); | |||
101 | extern void ip_send_check(struct iphdr *ip); | 101 | extern void ip_send_check(struct iphdr *ip); |
102 | extern int __ip_local_out(struct sk_buff *skb); | 102 | extern int __ip_local_out(struct sk_buff *skb); |
103 | extern int ip_local_out(struct sk_buff *skb); | 103 | extern int ip_local_out(struct sk_buff *skb); |
104 | extern int ip_queue_xmit(struct sk_buff *skb, int ipfragok); | 104 | extern int ip_queue_xmit(struct sk_buff *skb); |
105 | extern void ip_init(void); | 105 | extern void ip_init(void); |
106 | extern int ip_append_data(struct sock *sk, | 106 | extern int ip_append_data(struct sock *sk, |
107 | int getfrag(void *from, char *to, int offset, int len, | 107 | int getfrag(void *from, char *to, int offset, int len, |
@@ -393,6 +393,7 @@ extern int ip_options_rcv_srr(struct sk_buff *skb); | |||
393 | * Functions provided by ip_sockglue.c | 393 | * Functions provided by ip_sockglue.c |
394 | */ | 394 | */ |
395 | 395 | ||
396 | extern int ip_queue_rcv_skb(struct sock *sk, struct sk_buff *skb); | ||
396 | extern void ip_cmsg_recv(struct msghdr *msg, struct sk_buff *skb); | 397 | extern void ip_cmsg_recv(struct msghdr *msg, struct sk_buff *skb); |
397 | extern int ip_cmsg_send(struct net *net, | 398 | extern int ip_cmsg_send(struct net *net, |
398 | struct msghdr *msg, struct ipcm_cookie *ipc); | 399 | struct msghdr *msg, struct ipcm_cookie *ipc); |
diff --git a/include/net/ip6_fib.h b/include/net/ip6_fib.h index 86f46c49e318..4b1dc1161c37 100644 --- a/include/net/ip6_fib.h +++ b/include/net/ip6_fib.h | |||
@@ -88,34 +88,37 @@ struct rt6_info { | |||
88 | struct dst_entry dst; | 88 | struct dst_entry dst; |
89 | } u; | 89 | } u; |
90 | 90 | ||
91 | struct inet6_dev *rt6i_idev; | ||
92 | |||
93 | #define rt6i_dev u.dst.dev | 91 | #define rt6i_dev u.dst.dev |
94 | #define rt6i_nexthop u.dst.neighbour | 92 | #define rt6i_nexthop u.dst.neighbour |
95 | #define rt6i_expires u.dst.expires | 93 | #define rt6i_expires u.dst.expires |
96 | 94 | ||
95 | /* | ||
96 | * Tail elements of dst_entry (__refcnt etc.) | ||
97 | * and these elements (rarely used in hot path) are in | ||
98 | * the same cache line. | ||
99 | */ | ||
100 | struct fib6_table *rt6i_table; | ||
97 | struct fib6_node *rt6i_node; | 101 | struct fib6_node *rt6i_node; |
98 | 102 | ||
99 | struct in6_addr rt6i_gateway; | 103 | struct in6_addr rt6i_gateway; |
100 | |||
101 | u32 rt6i_flags; | ||
102 | u32 rt6i_metric; | ||
103 | atomic_t rt6i_ref; | ||
104 | 104 | ||
105 | /* more non-fragment space at head required */ | 105 | atomic_t rt6i_ref; |
106 | unsigned short rt6i_nfheader_len; | ||
107 | |||
108 | u8 rt6i_protocol; | ||
109 | 106 | ||
110 | struct fib6_table *rt6i_table; | 107 | /* These are in a separate cache line. */ |
108 | struct rt6key rt6i_dst ____cacheline_aligned_in_smp; | ||
109 | u32 rt6i_flags; | ||
110 | struct rt6key rt6i_src; | ||
111 | u32 rt6i_metric; | ||
111 | 112 | ||
112 | struct rt6key rt6i_dst; | 113 | struct inet6_dev *rt6i_idev; |
113 | 114 | ||
114 | #ifdef CONFIG_XFRM | 115 | #ifdef CONFIG_XFRM |
115 | u32 rt6i_flow_cache_genid; | 116 | u32 rt6i_flow_cache_genid; |
116 | #endif | 117 | #endif |
118 | /* more non-fragment space at head required */ | ||
119 | unsigned short rt6i_nfheader_len; | ||
117 | 120 | ||
118 | struct rt6key rt6i_src; | 121 | u8 rt6i_protocol; |
119 | }; | 122 | }; |
120 | 123 | ||
121 | static inline struct inet6_dev *ip6_dst_idev(struct dst_entry *dst) | 124 | static inline struct inet6_dev *ip6_dst_idev(struct dst_entry *dst) |
diff --git a/include/net/ip6_route.h b/include/net/ip6_route.h index 68f67836e146..278312c95f96 100644 --- a/include/net/ip6_route.h +++ b/include/net/ip6_route.h | |||
@@ -152,9 +152,9 @@ static inline void __ip6_dst_store(struct sock *sk, struct dst_entry *dst, | |||
152 | static inline void ip6_dst_store(struct sock *sk, struct dst_entry *dst, | 152 | static inline void ip6_dst_store(struct sock *sk, struct dst_entry *dst, |
153 | struct in6_addr *daddr, struct in6_addr *saddr) | 153 | struct in6_addr *daddr, struct in6_addr *saddr) |
154 | { | 154 | { |
155 | write_lock(&sk->sk_dst_lock); | 155 | spin_lock(&sk->sk_dst_lock); |
156 | __ip6_dst_store(sk, dst, daddr, saddr); | 156 | __ip6_dst_store(sk, dst, daddr, saddr); |
157 | write_unlock(&sk->sk_dst_lock); | 157 | spin_unlock(&sk->sk_dst_lock); |
158 | } | 158 | } |
159 | 159 | ||
160 | static inline int ipv6_unicast_destination(struct sk_buff *skb) | 160 | static inline int ipv6_unicast_destination(struct sk_buff *skb) |
diff --git a/include/net/ip6_tunnel.h b/include/net/ip6_tunnel.h index 83b4e008b16d..fbf9d1cda27b 100644 --- a/include/net/ip6_tunnel.h +++ b/include/net/ip6_tunnel.h | |||
@@ -15,7 +15,6 @@ | |||
15 | struct ip6_tnl { | 15 | struct ip6_tnl { |
16 | struct ip6_tnl *next; /* next tunnel in list */ | 16 | struct ip6_tnl *next; /* next tunnel in list */ |
17 | struct net_device *dev; /* virtual device associated with tunnel */ | 17 | struct net_device *dev; /* virtual device associated with tunnel */ |
18 | int recursion; /* depth of hard_start_xmit recursion */ | ||
19 | struct ip6_tnl_parm parms; /* tunnel configuration parameters */ | 18 | struct ip6_tnl_parm parms; /* tunnel configuration parameters */ |
20 | struct flowi fl; /* flowi template for xmit */ | 19 | struct flowi fl; /* flowi template for xmit */ |
21 | struct dst_entry *dst_cache; /* cached dst */ | 20 | struct dst_entry *dst_cache; /* cached dst */ |
diff --git a/include/net/ipv6.h b/include/net/ipv6.h index e72fb10ce573..eba5cc00325a 100644 --- a/include/net/ipv6.h +++ b/include/net/ipv6.h | |||
@@ -422,7 +422,7 @@ static inline int __ipv6_addr_diff(const void *token1, const void *token2, int a | |||
422 | for (i = 0; i < addrlen; i++) { | 422 | for (i = 0; i < addrlen; i++) { |
423 | __be32 xb = a1[i] ^ a2[i]; | 423 | __be32 xb = a1[i] ^ a2[i]; |
424 | if (xb) | 424 | if (xb) |
425 | return i * 32 + 32 - fls(ntohl(xb)); | 425 | return i * 32 + 31 - __fls(ntohl(xb)); |
426 | } | 426 | } |
427 | 427 | ||
428 | /* | 428 | /* |
@@ -482,8 +482,7 @@ extern int ip6_rcv_finish(struct sk_buff *skb); | |||
482 | extern int ip6_xmit(struct sock *sk, | 482 | extern int ip6_xmit(struct sock *sk, |
483 | struct sk_buff *skb, | 483 | struct sk_buff *skb, |
484 | struct flowi *fl, | 484 | struct flowi *fl, |
485 | struct ipv6_txoptions *opt, | 485 | struct ipv6_txoptions *opt); |
486 | int ipfragok); | ||
487 | 486 | ||
488 | extern int ip6_nd_hdr(struct sock *sk, | 487 | extern int ip6_nd_hdr(struct sock *sk, |
489 | struct sk_buff *skb, | 488 | struct sk_buff *skb, |
@@ -504,7 +503,8 @@ extern int ip6_append_data(struct sock *sk, | |||
504 | struct ipv6_txoptions *opt, | 503 | struct ipv6_txoptions *opt, |
505 | struct flowi *fl, | 504 | struct flowi *fl, |
506 | struct rt6_info *rt, | 505 | struct rt6_info *rt, |
507 | unsigned int flags); | 506 | unsigned int flags, |
507 | int dontfrag); | ||
508 | 508 | ||
509 | extern int ip6_push_pending_frames(struct sock *sk); | 509 | extern int ip6_push_pending_frames(struct sock *sk); |
510 | 510 | ||
@@ -578,9 +578,11 @@ extern int ip6_datagram_connect(struct sock *sk, | |||
578 | struct sockaddr *addr, int addr_len); | 578 | struct sockaddr *addr, int addr_len); |
579 | 579 | ||
580 | extern int ipv6_recv_error(struct sock *sk, struct msghdr *msg, int len); | 580 | extern int ipv6_recv_error(struct sock *sk, struct msghdr *msg, int len); |
581 | extern int ipv6_recv_rxpmtu(struct sock *sk, struct msghdr *msg, int len); | ||
581 | extern void ipv6_icmp_error(struct sock *sk, struct sk_buff *skb, int err, __be16 port, | 582 | extern void ipv6_icmp_error(struct sock *sk, struct sk_buff *skb, int err, __be16 port, |
582 | u32 info, u8 *payload); | 583 | u32 info, u8 *payload); |
583 | extern void ipv6_local_error(struct sock *sk, int err, struct flowi *fl, u32 info); | 584 | extern void ipv6_local_error(struct sock *sk, int err, struct flowi *fl, u32 info); |
585 | extern void ipv6_local_rxpmtu(struct sock *sk, struct flowi *fl, u32 mtu); | ||
584 | 586 | ||
585 | extern int inet6_release(struct socket *sock); | 587 | extern int inet6_release(struct socket *sock); |
586 | extern int inet6_bind(struct socket *sock, struct sockaddr *uaddr, | 588 | extern int inet6_bind(struct socket *sock, struct sockaddr *uaddr, |
diff --git a/include/net/ipx.h b/include/net/ipx.h index a14121dd1932..ef51a668ba19 100644 --- a/include/net/ipx.h +++ b/include/net/ipx.h | |||
@@ -13,6 +13,7 @@ | |||
13 | #include <net/datalink.h> | 13 | #include <net/datalink.h> |
14 | #include <linux/ipx.h> | 14 | #include <linux/ipx.h> |
15 | #include <linux/list.h> | 15 | #include <linux/list.h> |
16 | #include <linux/slab.h> | ||
16 | 17 | ||
17 | struct ipx_address { | 18 | struct ipx_address { |
18 | __be32 net; | 19 | __be32 net; |
diff --git a/include/net/irda/irttp.h b/include/net/irda/irttp.h index 0788c23d2828..11aee7a2972a 100644 --- a/include/net/irda/irttp.h +++ b/include/net/irda/irttp.h | |||
@@ -97,7 +97,7 @@ | |||
97 | #define TTP_MAX_SDU_SIZE 0x01 | 97 | #define TTP_MAX_SDU_SIZE 0x01 |
98 | 98 | ||
99 | /* | 99 | /* |
100 | * This structure contains all data assosiated with one instance of a TTP | 100 | * This structure contains all data associated with one instance of a TTP |
101 | * connection. | 101 | * connection. |
102 | */ | 102 | */ |
103 | struct tsap_cb { | 103 | struct tsap_cb { |
diff --git a/include/net/iucv/iucv.h b/include/net/iucv/iucv.h index 5e310c8d8e2f..205a3360156e 100644 --- a/include/net/iucv/iucv.h +++ b/include/net/iucv/iucv.h | |||
@@ -28,6 +28,7 @@ | |||
28 | */ | 28 | */ |
29 | 29 | ||
30 | #include <linux/types.h> | 30 | #include <linux/types.h> |
31 | #include <linux/slab.h> | ||
31 | #include <asm/debug.h> | 32 | #include <asm/debug.h> |
32 | 33 | ||
33 | /* | 34 | /* |
diff --git a/include/net/mac80211.h b/include/net/mac80211.h index 9448a5b1bb15..ac45c5b9d7e2 100644 --- a/include/net/mac80211.h +++ b/include/net/mac80211.h | |||
@@ -1646,7 +1646,7 @@ struct ieee80211_ops { | |||
1646 | struct ieee80211_bss_conf *info, | 1646 | struct ieee80211_bss_conf *info, |
1647 | u32 changed); | 1647 | u32 changed); |
1648 | u64 (*prepare_multicast)(struct ieee80211_hw *hw, | 1648 | u64 (*prepare_multicast)(struct ieee80211_hw *hw, |
1649 | int mc_count, struct dev_addr_list *mc_list); | 1649 | struct netdev_hw_addr_list *mc_list); |
1650 | void (*configure_filter)(struct ieee80211_hw *hw, | 1650 | void (*configure_filter)(struct ieee80211_hw *hw, |
1651 | unsigned int changed_flags, | 1651 | unsigned int changed_flags, |
1652 | unsigned int *total_flags, | 1652 | unsigned int *total_flags, |
diff --git a/include/net/mld.h b/include/net/mld.h new file mode 100644 index 000000000000..467143cd4e2f --- /dev/null +++ b/include/net/mld.h | |||
@@ -0,0 +1,75 @@ | |||
1 | #ifndef LINUX_MLD_H | ||
2 | #define LINUX_MLD_H | ||
3 | |||
4 | #include <linux/in6.h> | ||
5 | #include <linux/icmpv6.h> | ||
6 | |||
7 | /* MLDv1 Query/Report/Done */ | ||
8 | struct mld_msg { | ||
9 | struct icmp6hdr mld_hdr; | ||
10 | struct in6_addr mld_mca; | ||
11 | }; | ||
12 | |||
13 | #define mld_type mld_hdr.icmp6_type | ||
14 | #define mld_code mld_hdr.icmp6_code | ||
15 | #define mld_cksum mld_hdr.icmp6_cksum | ||
16 | #define mld_maxdelay mld_hdr.icmp6_maxdelay | ||
17 | #define mld_reserved mld_hdr.icmp6_dataun.un_data16[1] | ||
18 | |||
19 | /* Multicast Listener Discovery version 2 headers */ | ||
20 | /* MLDv2 Report */ | ||
21 | struct mld2_grec { | ||
22 | __u8 grec_type; | ||
23 | __u8 grec_auxwords; | ||
24 | __be16 grec_nsrcs; | ||
25 | struct in6_addr grec_mca; | ||
26 | struct in6_addr grec_src[0]; | ||
27 | }; | ||
28 | |||
29 | struct mld2_report { | ||
30 | struct icmp6hdr mld2r_hdr; | ||
31 | struct mld2_grec mld2r_grec[0]; | ||
32 | }; | ||
33 | |||
34 | #define mld2r_type mld2r_hdr.icmp6_type | ||
35 | #define mld2r_resv1 mld2r_hdr.icmp6_code | ||
36 | #define mld2r_cksum mld2r_hdr.icmp6_cksum | ||
37 | #define mld2r_resv2 mld2r_hdr.icmp6_dataun.un_data16[0] | ||
38 | #define mld2r_ngrec mld2r_hdr.icmp6_dataun.un_data16[1] | ||
39 | |||
40 | /* MLDv2 Query */ | ||
41 | struct mld2_query { | ||
42 | struct icmp6hdr mld2q_hdr; | ||
43 | struct in6_addr mld2q_mca; | ||
44 | #if defined(__LITTLE_ENDIAN_BITFIELD) | ||
45 | __u8 mld2q_qrv:3, | ||
46 | mld2q_suppress:1, | ||
47 | mld2q_resv2:4; | ||
48 | #elif defined(__BIG_ENDIAN_BITFIELD) | ||
49 | __u8 mld2q_resv2:4, | ||
50 | mld2q_suppress:1, | ||
51 | mld2q_qrv:3; | ||
52 | #else | ||
53 | #error "Please fix <asm/byteorder.h>" | ||
54 | #endif | ||
55 | __u8 mld2q_qqic; | ||
56 | __be16 mld2q_nsrcs; | ||
57 | struct in6_addr mld2q_srcs[0]; | ||
58 | }; | ||
59 | |||
60 | #define mld2q_type mld2q_hdr.icmp6_type | ||
61 | #define mld2q_code mld2q_hdr.icmp6_code | ||
62 | #define mld2q_cksum mld2q_hdr.icmp6_cksum | ||
63 | #define mld2q_mrc mld2q_hdr.icmp6_maxdelay | ||
64 | #define mld2q_resv1 mld2q_hdr.icmp6_dataun.un_data16[1] | ||
65 | |||
66 | /* Max Response Code */ | ||
67 | #define MLDV2_MASK(value, nb) ((nb)>=32 ? (value) : ((1<<(nb))-1) & (value)) | ||
68 | #define MLDV2_EXP(thresh, nbmant, nbexp, value) \ | ||
69 | ((value) < (thresh) ? (value) : \ | ||
70 | ((MLDV2_MASK(value, nbmant) | (1<<(nbmant))) << \ | ||
71 | (MLDV2_MASK((value) >> (nbmant), nbexp) + (nbexp)))) | ||
72 | |||
73 | #define MLDV2_MRC(value) MLDV2_EXP(0x8000, 12, 3, value) | ||
74 | |||
75 | #endif | ||
diff --git a/include/net/neighbour.h b/include/net/neighbour.h index da1d58be31b7..eb21340a573b 100644 --- a/include/net/neighbour.h +++ b/include/net/neighbour.h | |||
@@ -299,6 +299,20 @@ static inline int neigh_event_send(struct neighbour *neigh, struct sk_buff *skb) | |||
299 | return 0; | 299 | return 0; |
300 | } | 300 | } |
301 | 301 | ||
302 | #ifdef CONFIG_BRIDGE_NETFILTER | ||
303 | static inline int neigh_hh_bridge(struct hh_cache *hh, struct sk_buff *skb) | ||
304 | { | ||
305 | unsigned seq, hh_alen; | ||
306 | |||
307 | do { | ||
308 | seq = read_seqbegin(&hh->hh_lock); | ||
309 | hh_alen = HH_DATA_ALIGN(ETH_HLEN); | ||
310 | memcpy(skb->data - hh_alen, hh->hh_data, ETH_ALEN + hh_alen - ETH_HLEN); | ||
311 | } while (read_seqretry(&hh->hh_lock, seq)); | ||
312 | return 0; | ||
313 | } | ||
314 | #endif | ||
315 | |||
302 | static inline int neigh_hh_output(struct hh_cache *hh, struct sk_buff *skb) | 316 | static inline int neigh_hh_output(struct hh_cache *hh, struct sk_buff *skb) |
303 | { | 317 | { |
304 | unsigned seq; | 318 | unsigned seq; |
diff --git a/include/net/net_namespace.h b/include/net/net_namespace.h index 82b7be4db89a..bd10a7908993 100644 --- a/include/net/net_namespace.h +++ b/include/net/net_namespace.h | |||
@@ -100,14 +100,9 @@ struct net { | |||
100 | extern struct net init_net; | 100 | extern struct net init_net; |
101 | 101 | ||
102 | #ifdef CONFIG_NET | 102 | #ifdef CONFIG_NET |
103 | #define INIT_NET_NS(net_ns) .net_ns = &init_net, | ||
104 | |||
105 | extern struct net *copy_net_ns(unsigned long flags, struct net *net_ns); | 103 | extern struct net *copy_net_ns(unsigned long flags, struct net *net_ns); |
106 | 104 | ||
107 | #else /* CONFIG_NET */ | 105 | #else /* CONFIG_NET */ |
108 | |||
109 | #define INIT_NET_NS(net_ns) | ||
110 | |||
111 | static inline struct net *copy_net_ns(unsigned long flags, struct net *net_ns) | 106 | static inline struct net *copy_net_ns(unsigned long flags, struct net *net_ns) |
112 | { | 107 | { |
113 | /* There is nothing to copy so this is a noop */ | 108 | /* There is nothing to copy so this is a noop */ |
diff --git a/include/net/netfilter/nf_conntrack_extend.h b/include/net/netfilter/nf_conntrack_extend.h index 2d2a1f9a61d8..32d15bd6efa3 100644 --- a/include/net/netfilter/nf_conntrack_extend.h +++ b/include/net/netfilter/nf_conntrack_extend.h | |||
@@ -1,6 +1,8 @@ | |||
1 | #ifndef _NF_CONNTRACK_EXTEND_H | 1 | #ifndef _NF_CONNTRACK_EXTEND_H |
2 | #define _NF_CONNTRACK_EXTEND_H | 2 | #define _NF_CONNTRACK_EXTEND_H |
3 | 3 | ||
4 | #include <linux/slab.h> | ||
5 | |||
4 | #include <net/netfilter/nf_conntrack.h> | 6 | #include <net/netfilter/nf_conntrack.h> |
5 | 7 | ||
6 | enum nf_ct_ext_id { | 8 | enum nf_ct_ext_id { |
diff --git a/include/net/netlabel.h b/include/net/netlabel.h index 60ebbc1fef46..9db401a8b4d9 100644 --- a/include/net/netlabel.h +++ b/include/net/netlabel.h | |||
@@ -31,6 +31,7 @@ | |||
31 | #define _NETLABEL_H | 31 | #define _NETLABEL_H |
32 | 32 | ||
33 | #include <linux/types.h> | 33 | #include <linux/types.h> |
34 | #include <linux/slab.h> | ||
34 | #include <linux/net.h> | 35 | #include <linux/net.h> |
35 | #include <linux/skbuff.h> | 36 | #include <linux/skbuff.h> |
36 | #include <linux/in.h> | 37 | #include <linux/in.h> |
diff --git a/include/net/netlink.h b/include/net/netlink.h index f82e463c875a..4fc05b58503e 100644 --- a/include/net/netlink.h +++ b/include/net/netlink.h | |||
@@ -945,7 +945,11 @@ static inline u64 nla_get_u64(const struct nlattr *nla) | |||
945 | */ | 945 | */ |
946 | static inline __be64 nla_get_be64(const struct nlattr *nla) | 946 | static inline __be64 nla_get_be64(const struct nlattr *nla) |
947 | { | 947 | { |
948 | return *(__be64 *) nla_data(nla); | 948 | __be64 tmp; |
949 | |||
950 | nla_memcpy(&tmp, nla, sizeof(tmp)); | ||
951 | |||
952 | return tmp; | ||
949 | } | 953 | } |
950 | 954 | ||
951 | /** | 955 | /** |
diff --git a/include/net/netns/generic.h b/include/net/netns/generic.h index ff4982ab84b6..81a31c0db3e7 100644 --- a/include/net/netns/generic.h +++ b/include/net/netns/generic.h | |||
@@ -14,11 +14,8 @@ | |||
14 | * The rules are simple: | 14 | * The rules are simple: |
15 | * 1. set pernet_operations->id. After register_pernet_device you | 15 | * 1. set pernet_operations->id. After register_pernet_device you |
16 | * will have the id of your private pointer. | 16 | * will have the id of your private pointer. |
17 | * 2. Either set pernet_operations->size (to have the code allocate and | 17 | * 2. set pernet_operations->size to have the code allocate and free |
18 | * free a private structure pointed to from struct net ) or | 18 | * a private structure pointed to from struct net. |
19 | * call net_assign_generic() to put the private data on the struct | ||
20 | * net (most preferably this should be done in the ->init callback | ||
21 | * of the ops registered); | ||
22 | * 3. do not change this pointer while the net is alive; | 19 | * 3. do not change this pointer while the net is alive; |
23 | * 4. do not try to have any private reference on the net_generic object. | 20 | * 4. do not try to have any private reference on the net_generic object. |
24 | * | 21 | * |
@@ -46,6 +43,4 @@ static inline void *net_generic(struct net *net, int id) | |||
46 | 43 | ||
47 | return ptr; | 44 | return ptr; |
48 | } | 45 | } |
49 | |||
50 | extern int net_assign_generic(struct net *net, int id, void *data); | ||
51 | #endif | 46 | #endif |
diff --git a/include/net/netns/ipv4.h b/include/net/netns/ipv4.h index 2764994c9136..d68c3f121774 100644 --- a/include/net/netns/ipv4.h +++ b/include/net/netns/ipv4.h | |||
@@ -55,19 +55,14 @@ struct netns_ipv4 { | |||
55 | int sysctl_rt_cache_rebuild_count; | 55 | int sysctl_rt_cache_rebuild_count; |
56 | int current_rt_cache_rebuild_count; | 56 | int current_rt_cache_rebuild_count; |
57 | 57 | ||
58 | struct timer_list rt_secret_timer; | ||
59 | atomic_t rt_genid; | 58 | atomic_t rt_genid; |
60 | 59 | ||
61 | #ifdef CONFIG_IP_MROUTE | 60 | #ifdef CONFIG_IP_MROUTE |
62 | struct sock *mroute_sk; | 61 | #ifndef CONFIG_IP_MROUTE_MULTIPLE_TABLES |
63 | struct mfc_cache **mfc_cache_array; | 62 | struct mr_table *mrt; |
64 | struct vif_device *vif_table; | 63 | #else |
65 | int maxvif; | 64 | struct list_head mr_tables; |
66 | atomic_t cache_resolve_queue_len; | 65 | struct fib_rules_ops *mr_rules_ops; |
67 | int mroute_do_assert; | ||
68 | int mroute_do_pim; | ||
69 | #if defined(CONFIG_IP_PIMSM_V1) || defined(CONFIG_IP_PIMSM_V2) | ||
70 | int mroute_reg_vif_num; | ||
71 | #endif | 66 | #endif |
72 | #endif | 67 | #endif |
73 | }; | 68 | }; |
diff --git a/include/net/netrom.h b/include/net/netrom.h index ab170a60e7d3..f0793c1cb5f8 100644 --- a/include/net/netrom.h +++ b/include/net/netrom.h | |||
@@ -9,6 +9,7 @@ | |||
9 | 9 | ||
10 | #include <linux/netrom.h> | 10 | #include <linux/netrom.h> |
11 | #include <linux/list.h> | 11 | #include <linux/list.h> |
12 | #include <linux/slab.h> | ||
12 | #include <net/sock.h> | 13 | #include <net/sock.h> |
13 | 14 | ||
14 | #define NR_NETWORK_LEN 15 | 15 | #define NR_NETWORK_LEN 15 |
diff --git a/include/net/pkt_sched.h b/include/net/pkt_sched.h index b6cdc33b39c1..9d4d87cc970e 100644 --- a/include/net/pkt_sched.h +++ b/include/net/pkt_sched.h | |||
@@ -12,7 +12,7 @@ struct qdisc_walker { | |||
12 | int (*fn)(struct Qdisc *, unsigned long cl, struct qdisc_walker *); | 12 | int (*fn)(struct Qdisc *, unsigned long cl, struct qdisc_walker *); |
13 | }; | 13 | }; |
14 | 14 | ||
15 | #define QDISC_ALIGNTO 32 | 15 | #define QDISC_ALIGNTO 64 |
16 | #define QDISC_ALIGN(len) (((len) + QDISC_ALIGNTO-1) & ~(QDISC_ALIGNTO-1)) | 16 | #define QDISC_ALIGN(len) (((len) + QDISC_ALIGNTO-1) & ~(QDISC_ALIGNTO-1)) |
17 | 17 | ||
18 | static inline void *qdisc_priv(struct Qdisc *q) | 18 | static inline void *qdisc_priv(struct Qdisc *q) |
diff --git a/include/net/raw.h b/include/net/raw.h index 6c14a656357a..43c57502659b 100644 --- a/include/net/raw.h +++ b/include/net/raw.h | |||
@@ -19,6 +19,7 @@ | |||
19 | 19 | ||
20 | 20 | ||
21 | #include <net/protocol.h> | 21 | #include <net/protocol.h> |
22 | #include <linux/icmp.h> | ||
22 | 23 | ||
23 | extern struct proto raw_prot; | 24 | extern struct proto raw_prot; |
24 | 25 | ||
@@ -56,4 +57,16 @@ int raw_seq_open(struct inode *ino, struct file *file, | |||
56 | void raw_hash_sk(struct sock *sk); | 57 | void raw_hash_sk(struct sock *sk); |
57 | void raw_unhash_sk(struct sock *sk); | 58 | void raw_unhash_sk(struct sock *sk); |
58 | 59 | ||
60 | struct raw_sock { | ||
61 | /* inet_sock has to be the first member */ | ||
62 | struct inet_sock inet; | ||
63 | struct icmp_filter filter; | ||
64 | u32 ipmr_table; | ||
65 | }; | ||
66 | |||
67 | static inline struct raw_sock *raw_sk(const struct sock *sk) | ||
68 | { | ||
69 | return (struct raw_sock *)sk; | ||
70 | } | ||
71 | |||
59 | #endif /* _RAW_H */ | 72 | #endif /* _RAW_H */ |
diff --git a/include/net/sch_generic.h b/include/net/sch_generic.h index 67dc08eaaa45..03ca5d826757 100644 --- a/include/net/sch_generic.h +++ b/include/net/sch_generic.h | |||
@@ -73,6 +73,7 @@ struct Qdisc { | |||
73 | struct sk_buff_head q; | 73 | struct sk_buff_head q; |
74 | struct gnet_stats_basic_packed bstats; | 74 | struct gnet_stats_basic_packed bstats; |
75 | struct gnet_stats_queue qstats; | 75 | struct gnet_stats_queue qstats; |
76 | struct rcu_head rcu_head; | ||
76 | }; | 77 | }; |
77 | 78 | ||
78 | struct Qdisc_class_ops { | 79 | struct Qdisc_class_ops { |
diff --git a/include/net/sctp/command.h b/include/net/sctp/command.h index 8be5135ff7aa..2c55a7ea20af 100644 --- a/include/net/sctp/command.h +++ b/include/net/sctp/command.h | |||
@@ -107,6 +107,7 @@ typedef enum { | |||
107 | SCTP_CMD_T1_RETRAN, /* Mark for retransmission after T1 timeout */ | 107 | SCTP_CMD_T1_RETRAN, /* Mark for retransmission after T1 timeout */ |
108 | SCTP_CMD_UPDATE_INITTAG, /* Update peer inittag */ | 108 | SCTP_CMD_UPDATE_INITTAG, /* Update peer inittag */ |
109 | SCTP_CMD_SEND_MSG, /* Send the whole use message */ | 109 | SCTP_CMD_SEND_MSG, /* Send the whole use message */ |
110 | SCTP_CMD_SEND_NEXT_ASCONF, /* Send the next ASCONF after ACK */ | ||
110 | SCTP_CMD_LAST | 111 | SCTP_CMD_LAST |
111 | } sctp_verb_t; | 112 | } sctp_verb_t; |
112 | 113 | ||
diff --git a/include/net/sctp/sctp.h b/include/net/sctp/sctp.h index 78740ec57d5d..65946bc43d00 100644 --- a/include/net/sctp/sctp.h +++ b/include/net/sctp/sctp.h | |||
@@ -128,6 +128,7 @@ extern int sctp_register_pf(struct sctp_pf *, sa_family_t); | |||
128 | int sctp_backlog_rcv(struct sock *sk, struct sk_buff *skb); | 128 | int sctp_backlog_rcv(struct sock *sk, struct sk_buff *skb); |
129 | int sctp_inet_listen(struct socket *sock, int backlog); | 129 | int sctp_inet_listen(struct socket *sock, int backlog); |
130 | void sctp_write_space(struct sock *sk); | 130 | void sctp_write_space(struct sock *sk); |
131 | void sctp_data_ready(struct sock *sk, int len); | ||
131 | unsigned int sctp_poll(struct file *file, struct socket *sock, | 132 | unsigned int sctp_poll(struct file *file, struct socket *sock, |
132 | poll_table *wait); | 133 | poll_table *wait); |
133 | void sctp_sock_rfree(struct sk_buff *skb); | 134 | void sctp_sock_rfree(struct sk_buff *skb); |
@@ -268,7 +269,7 @@ enum { | |||
268 | #define SCTP_MIB_MAX __SCTP_MIB_MAX | 269 | #define SCTP_MIB_MAX __SCTP_MIB_MAX |
269 | struct sctp_mib { | 270 | struct sctp_mib { |
270 | unsigned long mibs[SCTP_MIB_MAX]; | 271 | unsigned long mibs[SCTP_MIB_MAX]; |
271 | } __SNMP_MIB_ALIGN__; | 272 | }; |
272 | 273 | ||
273 | 274 | ||
274 | /* Print debugging messages. */ | 275 | /* Print debugging messages. */ |
@@ -546,7 +547,7 @@ for (pos = chunk->subh.fwdtsn_hdr->skip;\ | |||
546 | #define WORD_ROUND(s) (((s)+3)&~3) | 547 | #define WORD_ROUND(s) (((s)+3)&~3) |
547 | 548 | ||
548 | /* Make a new instance of type. */ | 549 | /* Make a new instance of type. */ |
549 | #define t_new(type, flags) (type *)kmalloc(sizeof(type), flags) | 550 | #define t_new(type, flags) (type *)kzalloc(sizeof(type), flags) |
550 | 551 | ||
551 | /* Compare two timevals. */ | 552 | /* Compare two timevals. */ |
552 | #define tv_lt(s, t) \ | 553 | #define tv_lt(s, t) \ |
diff --git a/include/net/sctp/sm.h b/include/net/sctp/sm.h index 851c813adb3a..273a8bb683e3 100644 --- a/include/net/sctp/sm.h +++ b/include/net/sctp/sm.h | |||
@@ -437,7 +437,7 @@ sctp_vtag_verify_either(const struct sctp_chunk *chunk, | |||
437 | */ | 437 | */ |
438 | if ((!sctp_test_T_bit(chunk) && | 438 | if ((!sctp_test_T_bit(chunk) && |
439 | (ntohl(chunk->sctp_hdr->vtag) == asoc->c.my_vtag)) || | 439 | (ntohl(chunk->sctp_hdr->vtag) == asoc->c.my_vtag)) || |
440 | (sctp_test_T_bit(chunk) && | 440 | (sctp_test_T_bit(chunk) && asoc->c.peer_vtag && |
441 | (ntohl(chunk->sctp_hdr->vtag) == asoc->c.peer_vtag))) { | 441 | (ntohl(chunk->sctp_hdr->vtag) == asoc->c.peer_vtag))) { |
442 | return 1; | 442 | return 1; |
443 | } | 443 | } |
diff --git a/include/net/sctp/structs.h b/include/net/sctp/structs.h index ff3017744711..43257b903c82 100644 --- a/include/net/sctp/structs.h +++ b/include/net/sctp/structs.h | |||
@@ -643,17 +643,15 @@ struct sctp_pf { | |||
643 | struct sctp_datamsg { | 643 | struct sctp_datamsg { |
644 | /* Chunks waiting to be submitted to lower layer. */ | 644 | /* Chunks waiting to be submitted to lower layer. */ |
645 | struct list_head chunks; | 645 | struct list_head chunks; |
646 | /* Chunks that have been transmitted. */ | ||
647 | size_t msg_size; | ||
648 | /* Reference counting. */ | 646 | /* Reference counting. */ |
649 | atomic_t refcnt; | 647 | atomic_t refcnt; |
650 | /* When is this message no longer interesting to the peer? */ | 648 | /* When is this message no longer interesting to the peer? */ |
651 | unsigned long expires_at; | 649 | unsigned long expires_at; |
652 | /* Did the messenge fail to send? */ | 650 | /* Did the messenge fail to send? */ |
653 | int send_error; | 651 | int send_error; |
654 | char send_failed; | 652 | u8 send_failed:1, |
655 | /* Control whether chunks from this message can be abandoned. */ | 653 | can_abandon:1, /* can chunks from this message can be abandoned. */ |
656 | char can_abandon; | 654 | can_delay; /* should this message be Nagle delayed */ |
657 | }; | 655 | }; |
658 | 656 | ||
659 | struct sctp_datamsg *sctp_datamsg_from_user(struct sctp_association *, | 657 | struct sctp_datamsg *sctp_datamsg_from_user(struct sctp_association *, |
@@ -757,7 +755,6 @@ struct sctp_chunk { | |||
757 | #define SCTP_NEED_FRTX 0x1 | 755 | #define SCTP_NEED_FRTX 0x1 |
758 | #define SCTP_DONT_FRTX 0x2 | 756 | #define SCTP_DONT_FRTX 0x2 |
759 | __u16 rtt_in_progress:1, /* This chunk used for RTT calc? */ | 757 | __u16 rtt_in_progress:1, /* This chunk used for RTT calc? */ |
760 | resent:1, /* Has this chunk ever been resent. */ | ||
761 | has_tsn:1, /* Does this chunk have a TSN yet? */ | 758 | has_tsn:1, /* Does this chunk have a TSN yet? */ |
762 | has_ssn:1, /* Does this chunk have a SSN yet? */ | 759 | has_ssn:1, /* Does this chunk have a SSN yet? */ |
763 | singleton:1, /* Only chunk in the packet? */ | 760 | singleton:1, /* Only chunk in the packet? */ |
@@ -778,6 +775,7 @@ int sctp_user_addto_chunk(struct sctp_chunk *chunk, int off, int len, | |||
778 | struct iovec *data); | 775 | struct iovec *data); |
779 | void sctp_chunk_free(struct sctp_chunk *); | 776 | void sctp_chunk_free(struct sctp_chunk *); |
780 | void *sctp_addto_chunk(struct sctp_chunk *, int len, const void *data); | 777 | void *sctp_addto_chunk(struct sctp_chunk *, int len, const void *data); |
778 | void *sctp_addto_chunk_fixed(struct sctp_chunk *, int len, const void *data); | ||
781 | struct sctp_chunk *sctp_chunkify(struct sk_buff *, | 779 | struct sctp_chunk *sctp_chunkify(struct sk_buff *, |
782 | const struct sctp_association *, | 780 | const struct sctp_association *, |
783 | struct sock *); | 781 | struct sock *); |
@@ -878,7 +876,30 @@ struct sctp_transport { | |||
878 | 876 | ||
879 | /* Reference counting. */ | 877 | /* Reference counting. */ |
880 | atomic_t refcnt; | 878 | atomic_t refcnt; |
881 | int dead; | 879 | int dead:1, |
880 | /* RTO-Pending : A flag used to track if one of the DATA | ||
881 | * chunks sent to this address is currently being | ||
882 | * used to compute a RTT. If this flag is 0, | ||
883 | * the next DATA chunk sent to this destination | ||
884 | * should be used to compute a RTT and this flag | ||
885 | * should be set. Every time the RTT | ||
886 | * calculation completes (i.e. the DATA chunk | ||
887 | * is SACK'd) clear this flag. | ||
888 | */ | ||
889 | rto_pending:1, | ||
890 | |||
891 | /* | ||
892 | * hb_sent : a flag that signals that we have a pending | ||
893 | * heartbeat. | ||
894 | */ | ||
895 | hb_sent:1, | ||
896 | |||
897 | /* Is the Path MTU update pending on this tranport */ | ||
898 | pmtu_pending:1, | ||
899 | |||
900 | /* Is this structure kfree()able? */ | ||
901 | malloced:1; | ||
902 | |||
882 | 903 | ||
883 | /* This is the peer's IP address and port. */ | 904 | /* This is the peer's IP address and port. */ |
884 | union sctp_addr ipaddr; | 905 | union sctp_addr ipaddr; |
@@ -908,22 +929,6 @@ struct sctp_transport { | |||
908 | /* SRTT : The current smoothed round trip time. */ | 929 | /* SRTT : The current smoothed round trip time. */ |
909 | __u32 srtt; | 930 | __u32 srtt; |
910 | 931 | ||
911 | /* RTO-Pending : A flag used to track if one of the DATA | ||
912 | * chunks sent to this address is currently being | ||
913 | * used to compute a RTT. If this flag is 0, | ||
914 | * the next DATA chunk sent to this destination | ||
915 | * should be used to compute a RTT and this flag | ||
916 | * should be set. Every time the RTT | ||
917 | * calculation completes (i.e. the DATA chunk | ||
918 | * is SACK'd) clear this flag. | ||
919 | * hb_sent : a flag that signals that we have a pending heartbeat. | ||
920 | */ | ||
921 | __u8 rto_pending; | ||
922 | __u8 hb_sent; | ||
923 | |||
924 | /* Flag to track the current fast recovery state */ | ||
925 | __u8 fast_recovery; | ||
926 | |||
927 | /* | 932 | /* |
928 | * These are the congestion stats. | 933 | * These are the congestion stats. |
929 | */ | 934 | */ |
@@ -943,9 +948,6 @@ struct sctp_transport { | |||
943 | 948 | ||
944 | __u32 burst_limited; /* Holds old cwnd when max.burst is applied */ | 949 | __u32 burst_limited; /* Holds old cwnd when max.burst is applied */ |
945 | 950 | ||
946 | /* TSN marking the fast recovery exit point */ | ||
947 | __u32 fast_recovery_exit; | ||
948 | |||
949 | /* Destination */ | 951 | /* Destination */ |
950 | struct dst_entry *dst; | 952 | struct dst_entry *dst; |
951 | /* Source address. */ | 953 | /* Source address. */ |
@@ -976,9 +978,6 @@ struct sctp_transport { | |||
976 | */ | 978 | */ |
977 | __u16 pathmaxrxt; | 979 | __u16 pathmaxrxt; |
978 | 980 | ||
979 | /* is the Path MTU update pending on this tranport */ | ||
980 | __u8 pmtu_pending; | ||
981 | |||
982 | /* PMTU : The current known path MTU. */ | 981 | /* PMTU : The current known path MTU. */ |
983 | __u32 pathmtu; | 982 | __u32 pathmtu; |
984 | 983 | ||
@@ -1022,8 +1021,6 @@ struct sctp_transport { | |||
1022 | /* This is the list of transports that have chunks to send. */ | 1021 | /* This is the list of transports that have chunks to send. */ |
1023 | struct list_head send_ready; | 1022 | struct list_head send_ready; |
1024 | 1023 | ||
1025 | int malloced; /* Is this structure kfree()able? */ | ||
1026 | |||
1027 | /* State information saved for SFR_CACC algorithm. The key | 1024 | /* State information saved for SFR_CACC algorithm. The key |
1028 | * idea in SFR_CACC is to maintain state at the sender on a | 1025 | * idea in SFR_CACC is to maintain state at the sender on a |
1029 | * per-destination basis when a changeover happens. | 1026 | * per-destination basis when a changeover happens. |
@@ -1065,7 +1062,7 @@ void sctp_transport_route(struct sctp_transport *, union sctp_addr *, | |||
1065 | struct sctp_sock *); | 1062 | struct sctp_sock *); |
1066 | void sctp_transport_pmtu(struct sctp_transport *); | 1063 | void sctp_transport_pmtu(struct sctp_transport *); |
1067 | void sctp_transport_free(struct sctp_transport *); | 1064 | void sctp_transport_free(struct sctp_transport *); |
1068 | void sctp_transport_reset_timers(struct sctp_transport *, int); | 1065 | void sctp_transport_reset_timers(struct sctp_transport *); |
1069 | void sctp_transport_hold(struct sctp_transport *); | 1066 | void sctp_transport_hold(struct sctp_transport *); |
1070 | void sctp_transport_put(struct sctp_transport *); | 1067 | void sctp_transport_put(struct sctp_transport *); |
1071 | void sctp_transport_update_rto(struct sctp_transport *, __u32); | 1068 | void sctp_transport_update_rto(struct sctp_transport *, __u32); |
@@ -1719,6 +1716,12 @@ struct sctp_association { | |||
1719 | /* Highest TSN that is acknowledged by incoming SACKs. */ | 1716 | /* Highest TSN that is acknowledged by incoming SACKs. */ |
1720 | __u32 highest_sacked; | 1717 | __u32 highest_sacked; |
1721 | 1718 | ||
1719 | /* TSN marking the fast recovery exit point */ | ||
1720 | __u32 fast_recovery_exit; | ||
1721 | |||
1722 | /* Flag to track the current fast recovery state */ | ||
1723 | __u8 fast_recovery; | ||
1724 | |||
1722 | /* The number of unacknowledged data chunks. Reported through | 1725 | /* The number of unacknowledged data chunks. Reported through |
1723 | * the SCTP_STATUS sockopt. | 1726 | * the SCTP_STATUS sockopt. |
1724 | */ | 1727 | */ |
diff --git a/include/net/snmp.h b/include/net/snmp.h index 692ee0061dc4..92456f1035f5 100644 --- a/include/net/snmp.h +++ b/include/net/snmp.h | |||
@@ -52,26 +52,11 @@ struct snmp_mib { | |||
52 | * count on the 20Gb/s + networks people expect in a few years time! | 52 | * count on the 20Gb/s + networks people expect in a few years time! |
53 | */ | 53 | */ |
54 | 54 | ||
55 | /* | ||
56 | * The rule for padding: | ||
57 | * Best is power of two because then the right structure can be found by a | ||
58 | * simple shift. The structure should be always cache line aligned. | ||
59 | * gcc needs n=alignto(cachelinesize, popcnt(sizeof(bla_mib))) shift/add | ||
60 | * instructions to emulate multiply in case it is not power-of-two. | ||
61 | * Currently n is always <=3 for all sizes so simple cache line alignment | ||
62 | * is enough. | ||
63 | * | ||
64 | * The best solution would be a global CPU local area , especially on 64 | ||
65 | * and 128byte cacheline machine it makes a *lot* of sense -AK | ||
66 | */ | ||
67 | |||
68 | #define __SNMP_MIB_ALIGN__ ____cacheline_aligned | ||
69 | |||
70 | /* IPstats */ | 55 | /* IPstats */ |
71 | #define IPSTATS_MIB_MAX __IPSTATS_MIB_MAX | 56 | #define IPSTATS_MIB_MAX __IPSTATS_MIB_MAX |
72 | struct ipstats_mib { | 57 | struct ipstats_mib { |
73 | unsigned long mibs[IPSTATS_MIB_MAX]; | 58 | unsigned long mibs[IPSTATS_MIB_MAX]; |
74 | } __SNMP_MIB_ALIGN__; | 59 | }; |
75 | 60 | ||
76 | /* ICMP */ | 61 | /* ICMP */ |
77 | #define ICMP_MIB_DUMMY __ICMP_MIB_MAX | 62 | #define ICMP_MIB_DUMMY __ICMP_MIB_MAX |
@@ -79,36 +64,36 @@ struct ipstats_mib { | |||
79 | 64 | ||
80 | struct icmp_mib { | 65 | struct icmp_mib { |
81 | unsigned long mibs[ICMP_MIB_MAX]; | 66 | unsigned long mibs[ICMP_MIB_MAX]; |
82 | } __SNMP_MIB_ALIGN__; | 67 | }; |
83 | 68 | ||
84 | #define ICMPMSG_MIB_MAX __ICMPMSG_MIB_MAX | 69 | #define ICMPMSG_MIB_MAX __ICMPMSG_MIB_MAX |
85 | struct icmpmsg_mib { | 70 | struct icmpmsg_mib { |
86 | unsigned long mibs[ICMPMSG_MIB_MAX]; | 71 | unsigned long mibs[ICMPMSG_MIB_MAX]; |
87 | } __SNMP_MIB_ALIGN__; | 72 | }; |
88 | 73 | ||
89 | /* ICMP6 (IPv6-ICMP) */ | 74 | /* ICMP6 (IPv6-ICMP) */ |
90 | #define ICMP6_MIB_MAX __ICMP6_MIB_MAX | 75 | #define ICMP6_MIB_MAX __ICMP6_MIB_MAX |
91 | struct icmpv6_mib { | 76 | struct icmpv6_mib { |
92 | unsigned long mibs[ICMP6_MIB_MAX]; | 77 | unsigned long mibs[ICMP6_MIB_MAX]; |
93 | } __SNMP_MIB_ALIGN__; | 78 | }; |
94 | 79 | ||
95 | #define ICMP6MSG_MIB_MAX __ICMP6MSG_MIB_MAX | 80 | #define ICMP6MSG_MIB_MAX __ICMP6MSG_MIB_MAX |
96 | struct icmpv6msg_mib { | 81 | struct icmpv6msg_mib { |
97 | unsigned long mibs[ICMP6MSG_MIB_MAX]; | 82 | unsigned long mibs[ICMP6MSG_MIB_MAX]; |
98 | } __SNMP_MIB_ALIGN__; | 83 | }; |
99 | 84 | ||
100 | 85 | ||
101 | /* TCP */ | 86 | /* TCP */ |
102 | #define TCP_MIB_MAX __TCP_MIB_MAX | 87 | #define TCP_MIB_MAX __TCP_MIB_MAX |
103 | struct tcp_mib { | 88 | struct tcp_mib { |
104 | unsigned long mibs[TCP_MIB_MAX]; | 89 | unsigned long mibs[TCP_MIB_MAX]; |
105 | } __SNMP_MIB_ALIGN__; | 90 | }; |
106 | 91 | ||
107 | /* UDP */ | 92 | /* UDP */ |
108 | #define UDP_MIB_MAX __UDP_MIB_MAX | 93 | #define UDP_MIB_MAX __UDP_MIB_MAX |
109 | struct udp_mib { | 94 | struct udp_mib { |
110 | unsigned long mibs[UDP_MIB_MAX]; | 95 | unsigned long mibs[UDP_MIB_MAX]; |
111 | } __SNMP_MIB_ALIGN__; | 96 | }; |
112 | 97 | ||
113 | /* Linux */ | 98 | /* Linux */ |
114 | #define LINUX_MIB_MAX __LINUX_MIB_MAX | 99 | #define LINUX_MIB_MAX __LINUX_MIB_MAX |
@@ -148,6 +133,8 @@ struct linux_xfrm_mib { | |||
148 | __this_cpu_add(mib[0]->mibs[field], addend) | 133 | __this_cpu_add(mib[0]->mibs[field], addend) |
149 | #define SNMP_ADD_STATS_USER(mib, field, addend) \ | 134 | #define SNMP_ADD_STATS_USER(mib, field, addend) \ |
150 | this_cpu_add(mib[1]->mibs[field], addend) | 135 | this_cpu_add(mib[1]->mibs[field], addend) |
136 | #define SNMP_ADD_STATS(mib, field, addend) \ | ||
137 | this_cpu_add(mib[0]->mibs[field], addend) | ||
151 | /* | 138 | /* |
152 | * Use "__typeof__(*mib[0]) *ptr" instead of "__typeof__(mib[0]) ptr" | 139 | * Use "__typeof__(*mib[0]) *ptr" instead of "__typeof__(mib[0]) ptr" |
153 | * to make @ptr a non-percpu pointer. | 140 | * to make @ptr a non-percpu pointer. |
diff --git a/include/net/sock.h b/include/net/sock.h index 092b0551e77f..328e03f47dd1 100644 --- a/include/net/sock.h +++ b/include/net/sock.h | |||
@@ -51,6 +51,7 @@ | |||
51 | #include <linux/skbuff.h> /* struct sk_buff */ | 51 | #include <linux/skbuff.h> /* struct sk_buff */ |
52 | #include <linux/mm.h> | 52 | #include <linux/mm.h> |
53 | #include <linux/security.h> | 53 | #include <linux/security.h> |
54 | #include <linux/slab.h> | ||
54 | 55 | ||
55 | #include <linux/filter.h> | 56 | #include <linux/filter.h> |
56 | #include <linux/rculist_nulls.h> | 57 | #include <linux/rculist_nulls.h> |
@@ -73,7 +74,7 @@ | |||
73 | printk(KERN_DEBUG msg); } while (0) | 74 | printk(KERN_DEBUG msg); } while (0) |
74 | #else | 75 | #else |
75 | /* Validate arguments and do nothing */ | 76 | /* Validate arguments and do nothing */ |
76 | static void inline int __attribute__ ((format (printf, 2, 3))) | 77 | static inline void __attribute__ ((format (printf, 2, 3))) |
77 | SOCK_DEBUG(struct sock *sk, const char *msg, ...) | 78 | SOCK_DEBUG(struct sock *sk, const char *msg, ...) |
78 | { | 79 | { |
79 | } | 80 | } |
@@ -158,7 +159,7 @@ struct sock_common { | |||
158 | * @sk_userlocks: %SO_SNDBUF and %SO_RCVBUF settings | 159 | * @sk_userlocks: %SO_SNDBUF and %SO_RCVBUF settings |
159 | * @sk_lock: synchronizer | 160 | * @sk_lock: synchronizer |
160 | * @sk_rcvbuf: size of receive buffer in bytes | 161 | * @sk_rcvbuf: size of receive buffer in bytes |
161 | * @sk_sleep: sock wait queue | 162 | * @sk_wq: sock wait queue and async head |
162 | * @sk_dst_cache: destination cache | 163 | * @sk_dst_cache: destination cache |
163 | * @sk_dst_lock: destination cache lock | 164 | * @sk_dst_lock: destination cache lock |
164 | * @sk_policy: flow policy | 165 | * @sk_policy: flow policy |
@@ -197,6 +198,7 @@ struct sock_common { | |||
197 | * @sk_rcvlowat: %SO_RCVLOWAT setting | 198 | * @sk_rcvlowat: %SO_RCVLOWAT setting |
198 | * @sk_rcvtimeo: %SO_RCVTIMEO setting | 199 | * @sk_rcvtimeo: %SO_RCVTIMEO setting |
199 | * @sk_sndtimeo: %SO_SNDTIMEO setting | 200 | * @sk_sndtimeo: %SO_SNDTIMEO setting |
201 | * @sk_rxhash: flow hash received from netif layer | ||
200 | * @sk_filter: socket filtering instructions | 202 | * @sk_filter: socket filtering instructions |
201 | * @sk_protinfo: private area, net family specific, when not using slab | 203 | * @sk_protinfo: private area, net family specific, when not using slab |
202 | * @sk_timer: sock cleanup timer | 204 | * @sk_timer: sock cleanup timer |
@@ -254,14 +256,13 @@ struct sock { | |||
254 | struct sk_buff *head; | 256 | struct sk_buff *head; |
255 | struct sk_buff *tail; | 257 | struct sk_buff *tail; |
256 | int len; | 258 | int len; |
257 | int limit; | ||
258 | } sk_backlog; | 259 | } sk_backlog; |
259 | wait_queue_head_t *sk_sleep; | 260 | struct socket_wq *sk_wq; |
260 | struct dst_entry *sk_dst_cache; | 261 | struct dst_entry *sk_dst_cache; |
261 | #ifdef CONFIG_XFRM | 262 | #ifdef CONFIG_XFRM |
262 | struct xfrm_policy *sk_policy[2]; | 263 | struct xfrm_policy *sk_policy[2]; |
263 | #endif | 264 | #endif |
264 | rwlock_t sk_dst_lock; | 265 | spinlock_t sk_dst_lock; |
265 | atomic_t sk_rmem_alloc; | 266 | atomic_t sk_rmem_alloc; |
266 | atomic_t sk_wmem_alloc; | 267 | atomic_t sk_wmem_alloc; |
267 | atomic_t sk_omem_alloc; | 268 | atomic_t sk_omem_alloc; |
@@ -278,6 +279,9 @@ struct sock { | |||
278 | int sk_gso_type; | 279 | int sk_gso_type; |
279 | unsigned int sk_gso_max_size; | 280 | unsigned int sk_gso_max_size; |
280 | int sk_rcvlowat; | 281 | int sk_rcvlowat; |
282 | #ifdef CONFIG_RPS | ||
283 | __u32 sk_rxhash; | ||
284 | #endif | ||
281 | unsigned long sk_flags; | 285 | unsigned long sk_flags; |
282 | unsigned long sk_lingertime; | 286 | unsigned long sk_lingertime; |
283 | struct sk_buff_head sk_error_queue; | 287 | struct sk_buff_head sk_error_queue; |
@@ -603,10 +607,20 @@ static inline void __sk_add_backlog(struct sock *sk, struct sk_buff *skb) | |||
603 | skb->next = NULL; | 607 | skb->next = NULL; |
604 | } | 608 | } |
605 | 609 | ||
610 | /* | ||
611 | * Take into account size of receive queue and backlog queue | ||
612 | */ | ||
613 | static inline bool sk_rcvqueues_full(const struct sock *sk, const struct sk_buff *skb) | ||
614 | { | ||
615 | unsigned int qsize = sk->sk_backlog.len + atomic_read(&sk->sk_rmem_alloc); | ||
616 | |||
617 | return qsize + skb->truesize > sk->sk_rcvbuf; | ||
618 | } | ||
619 | |||
606 | /* The per-socket spinlock must be held here. */ | 620 | /* The per-socket spinlock must be held here. */ |
607 | static inline __must_check int sk_add_backlog(struct sock *sk, struct sk_buff *skb) | 621 | static inline __must_check int sk_add_backlog(struct sock *sk, struct sk_buff *skb) |
608 | { | 622 | { |
609 | if (sk->sk_backlog.len >= max(sk->sk_backlog.limit, sk->sk_rcvbuf << 1)) | 623 | if (sk_rcvqueues_full(sk, skb)) |
610 | return -ENOBUFS; | 624 | return -ENOBUFS; |
611 | 625 | ||
612 | __sk_add_backlog(sk, skb); | 626 | __sk_add_backlog(sk, skb); |
@@ -619,6 +633,40 @@ static inline int sk_backlog_rcv(struct sock *sk, struct sk_buff *skb) | |||
619 | return sk->sk_backlog_rcv(sk, skb); | 633 | return sk->sk_backlog_rcv(sk, skb); |
620 | } | 634 | } |
621 | 635 | ||
636 | static inline void sock_rps_record_flow(const struct sock *sk) | ||
637 | { | ||
638 | #ifdef CONFIG_RPS | ||
639 | struct rps_sock_flow_table *sock_flow_table; | ||
640 | |||
641 | rcu_read_lock(); | ||
642 | sock_flow_table = rcu_dereference(rps_sock_flow_table); | ||
643 | rps_record_sock_flow(sock_flow_table, sk->sk_rxhash); | ||
644 | rcu_read_unlock(); | ||
645 | #endif | ||
646 | } | ||
647 | |||
648 | static inline void sock_rps_reset_flow(const struct sock *sk) | ||
649 | { | ||
650 | #ifdef CONFIG_RPS | ||
651 | struct rps_sock_flow_table *sock_flow_table; | ||
652 | |||
653 | rcu_read_lock(); | ||
654 | sock_flow_table = rcu_dereference(rps_sock_flow_table); | ||
655 | rps_reset_sock_flow(sock_flow_table, sk->sk_rxhash); | ||
656 | rcu_read_unlock(); | ||
657 | #endif | ||
658 | } | ||
659 | |||
660 | static inline void sock_rps_save_rxhash(struct sock *sk, u32 rxhash) | ||
661 | { | ||
662 | #ifdef CONFIG_RPS | ||
663 | if (unlikely(sk->sk_rxhash != rxhash)) { | ||
664 | sock_rps_reset_flow(sk); | ||
665 | sk->sk_rxhash = rxhash; | ||
666 | } | ||
667 | #endif | ||
668 | } | ||
669 | |||
622 | #define sk_wait_event(__sk, __timeo, __condition) \ | 670 | #define sk_wait_event(__sk, __timeo, __condition) \ |
623 | ({ int __rc; \ | 671 | ({ int __rc; \ |
624 | release_sock(__sk); \ | 672 | release_sock(__sk); \ |
@@ -973,6 +1021,16 @@ extern void release_sock(struct sock *sk); | |||
973 | SINGLE_DEPTH_NESTING) | 1021 | SINGLE_DEPTH_NESTING) |
974 | #define bh_unlock_sock(__sk) spin_unlock(&((__sk)->sk_lock.slock)) | 1022 | #define bh_unlock_sock(__sk) spin_unlock(&((__sk)->sk_lock.slock)) |
975 | 1023 | ||
1024 | static inline void lock_sock_bh(struct sock *sk) | ||
1025 | { | ||
1026 | spin_lock_bh(&sk->sk_lock.slock); | ||
1027 | } | ||
1028 | |||
1029 | static inline void unlock_sock_bh(struct sock *sk) | ||
1030 | { | ||
1031 | spin_unlock_bh(&sk->sk_lock.slock); | ||
1032 | } | ||
1033 | |||
976 | extern struct sock *sk_alloc(struct net *net, int family, | 1034 | extern struct sock *sk_alloc(struct net *net, int family, |
977 | gfp_t priority, | 1035 | gfp_t priority, |
978 | struct proto *prot); | 1036 | struct proto *prot); |
@@ -1159,6 +1217,10 @@ static inline void sk_set_socket(struct sock *sk, struct socket *sock) | |||
1159 | sk->sk_socket = sock; | 1217 | sk->sk_socket = sock; |
1160 | } | 1218 | } |
1161 | 1219 | ||
1220 | static inline wait_queue_head_t *sk_sleep(struct sock *sk) | ||
1221 | { | ||
1222 | return &sk->sk_wq->wait; | ||
1223 | } | ||
1162 | /* Detach socket from process context. | 1224 | /* Detach socket from process context. |
1163 | * Announce socket dead, detach it from wait queue and inode. | 1225 | * Announce socket dead, detach it from wait queue and inode. |
1164 | * Note that parent inode held reference count on this struct sock, | 1226 | * Note that parent inode held reference count on this struct sock, |
@@ -1171,14 +1233,14 @@ static inline void sock_orphan(struct sock *sk) | |||
1171 | write_lock_bh(&sk->sk_callback_lock); | 1233 | write_lock_bh(&sk->sk_callback_lock); |
1172 | sock_set_flag(sk, SOCK_DEAD); | 1234 | sock_set_flag(sk, SOCK_DEAD); |
1173 | sk_set_socket(sk, NULL); | 1235 | sk_set_socket(sk, NULL); |
1174 | sk->sk_sleep = NULL; | 1236 | sk->sk_wq = NULL; |
1175 | write_unlock_bh(&sk->sk_callback_lock); | 1237 | write_unlock_bh(&sk->sk_callback_lock); |
1176 | } | 1238 | } |
1177 | 1239 | ||
1178 | static inline void sock_graft(struct sock *sk, struct socket *parent) | 1240 | static inline void sock_graft(struct sock *sk, struct socket *parent) |
1179 | { | 1241 | { |
1180 | write_lock_bh(&sk->sk_callback_lock); | 1242 | write_lock_bh(&sk->sk_callback_lock); |
1181 | sk->sk_sleep = &parent->wait; | 1243 | rcu_assign_pointer(sk->sk_wq, parent->wq); |
1182 | parent->sk = sk; | 1244 | parent->sk = sk; |
1183 | sk_set_socket(sk, parent); | 1245 | sk_set_socket(sk, parent); |
1184 | security_sock_graft(sk, parent); | 1246 | security_sock_graft(sk, parent); |
@@ -1191,7 +1253,9 @@ extern unsigned long sock_i_ino(struct sock *sk); | |||
1191 | static inline struct dst_entry * | 1253 | static inline struct dst_entry * |
1192 | __sk_dst_get(struct sock *sk) | 1254 | __sk_dst_get(struct sock *sk) |
1193 | { | 1255 | { |
1194 | return sk->sk_dst_cache; | 1256 | return rcu_dereference_check(sk->sk_dst_cache, rcu_read_lock_held() || |
1257 | sock_owned_by_user(sk) || | ||
1258 | lockdep_is_held(&sk->sk_lock.slock)); | ||
1195 | } | 1259 | } |
1196 | 1260 | ||
1197 | static inline struct dst_entry * | 1261 | static inline struct dst_entry * |
@@ -1199,50 +1263,65 @@ sk_dst_get(struct sock *sk) | |||
1199 | { | 1263 | { |
1200 | struct dst_entry *dst; | 1264 | struct dst_entry *dst; |
1201 | 1265 | ||
1202 | read_lock(&sk->sk_dst_lock); | 1266 | rcu_read_lock(); |
1203 | dst = sk->sk_dst_cache; | 1267 | dst = rcu_dereference(sk->sk_dst_cache); |
1204 | if (dst) | 1268 | if (dst) |
1205 | dst_hold(dst); | 1269 | dst_hold(dst); |
1206 | read_unlock(&sk->sk_dst_lock); | 1270 | rcu_read_unlock(); |
1207 | return dst; | 1271 | return dst; |
1208 | } | 1272 | } |
1209 | 1273 | ||
1274 | extern void sk_reset_txq(struct sock *sk); | ||
1275 | |||
1276 | static inline void dst_negative_advice(struct sock *sk) | ||
1277 | { | ||
1278 | struct dst_entry *ndst, *dst = __sk_dst_get(sk); | ||
1279 | |||
1280 | if (dst && dst->ops->negative_advice) { | ||
1281 | ndst = dst->ops->negative_advice(dst); | ||
1282 | |||
1283 | if (ndst != dst) { | ||
1284 | rcu_assign_pointer(sk->sk_dst_cache, ndst); | ||
1285 | sk_reset_txq(sk); | ||
1286 | } | ||
1287 | } | ||
1288 | } | ||
1289 | |||
1210 | static inline void | 1290 | static inline void |
1211 | __sk_dst_set(struct sock *sk, struct dst_entry *dst) | 1291 | __sk_dst_set(struct sock *sk, struct dst_entry *dst) |
1212 | { | 1292 | { |
1213 | struct dst_entry *old_dst; | 1293 | struct dst_entry *old_dst; |
1214 | 1294 | ||
1215 | sk_tx_queue_clear(sk); | 1295 | sk_tx_queue_clear(sk); |
1216 | old_dst = sk->sk_dst_cache; | 1296 | /* |
1217 | sk->sk_dst_cache = dst; | 1297 | * This can be called while sk is owned by the caller only, |
1298 | * with no state that can be checked in a rcu_dereference_check() cond | ||
1299 | */ | ||
1300 | old_dst = rcu_dereference_raw(sk->sk_dst_cache); | ||
1301 | rcu_assign_pointer(sk->sk_dst_cache, dst); | ||
1218 | dst_release(old_dst); | 1302 | dst_release(old_dst); |
1219 | } | 1303 | } |
1220 | 1304 | ||
1221 | static inline void | 1305 | static inline void |
1222 | sk_dst_set(struct sock *sk, struct dst_entry *dst) | 1306 | sk_dst_set(struct sock *sk, struct dst_entry *dst) |
1223 | { | 1307 | { |
1224 | write_lock(&sk->sk_dst_lock); | 1308 | spin_lock(&sk->sk_dst_lock); |
1225 | __sk_dst_set(sk, dst); | 1309 | __sk_dst_set(sk, dst); |
1226 | write_unlock(&sk->sk_dst_lock); | 1310 | spin_unlock(&sk->sk_dst_lock); |
1227 | } | 1311 | } |
1228 | 1312 | ||
1229 | static inline void | 1313 | static inline void |
1230 | __sk_dst_reset(struct sock *sk) | 1314 | __sk_dst_reset(struct sock *sk) |
1231 | { | 1315 | { |
1232 | struct dst_entry *old_dst; | 1316 | __sk_dst_set(sk, NULL); |
1233 | |||
1234 | sk_tx_queue_clear(sk); | ||
1235 | old_dst = sk->sk_dst_cache; | ||
1236 | sk->sk_dst_cache = NULL; | ||
1237 | dst_release(old_dst); | ||
1238 | } | 1317 | } |
1239 | 1318 | ||
1240 | static inline void | 1319 | static inline void |
1241 | sk_dst_reset(struct sock *sk) | 1320 | sk_dst_reset(struct sock *sk) |
1242 | { | 1321 | { |
1243 | write_lock(&sk->sk_dst_lock); | 1322 | spin_lock(&sk->sk_dst_lock); |
1244 | __sk_dst_reset(sk); | 1323 | __sk_dst_reset(sk); |
1245 | write_unlock(&sk->sk_dst_lock); | 1324 | spin_unlock(&sk->sk_dst_lock); |
1246 | } | 1325 | } |
1247 | 1326 | ||
1248 | extern struct dst_entry *__sk_dst_check(struct sock *sk, u32 cookie); | 1327 | extern struct dst_entry *__sk_dst_check(struct sock *sk, u32 cookie); |
@@ -1313,12 +1392,12 @@ static inline int sk_has_allocations(const struct sock *sk) | |||
1313 | } | 1392 | } |
1314 | 1393 | ||
1315 | /** | 1394 | /** |
1316 | * sk_has_sleeper - check if there are any waiting processes | 1395 | * wq_has_sleeper - check if there are any waiting processes |
1317 | * @sk: socket | 1396 | * @sk: struct socket_wq |
1318 | * | 1397 | * |
1319 | * Returns true if socket has waiting processes | 1398 | * Returns true if socket_wq has waiting processes |
1320 | * | 1399 | * |
1321 | * The purpose of the sk_has_sleeper and sock_poll_wait is to wrap the memory | 1400 | * The purpose of the wq_has_sleeper and sock_poll_wait is to wrap the memory |
1322 | * barrier call. They were added due to the race found within the tcp code. | 1401 | * barrier call. They were added due to the race found within the tcp code. |
1323 | * | 1402 | * |
1324 | * Consider following tcp code paths: | 1403 | * Consider following tcp code paths: |
@@ -1331,9 +1410,10 @@ static inline int sk_has_allocations(const struct sock *sk) | |||
1331 | * ... ... | 1410 | * ... ... |
1332 | * tp->rcv_nxt check sock_def_readable | 1411 | * tp->rcv_nxt check sock_def_readable |
1333 | * ... { | 1412 | * ... { |
1334 | * schedule ... | 1413 | * schedule rcu_read_lock(); |
1335 | * if (sk->sk_sleep && waitqueue_active(sk->sk_sleep)) | 1414 | * wq = rcu_dereference(sk->sk_wq); |
1336 | * wake_up_interruptible(sk->sk_sleep) | 1415 | * if (wq && waitqueue_active(&wq->wait)) |
1416 | * wake_up_interruptible(&wq->wait) | ||
1337 | * ... | 1417 | * ... |
1338 | * } | 1418 | * } |
1339 | * | 1419 | * |
@@ -1342,19 +1422,18 @@ static inline int sk_has_allocations(const struct sock *sk) | |||
1342 | * could then endup calling schedule and sleep forever if there are no more | 1422 | * could then endup calling schedule and sleep forever if there are no more |
1343 | * data on the socket. | 1423 | * data on the socket. |
1344 | * | 1424 | * |
1345 | * The sk_has_sleeper is always called right after a call to read_lock, so we | ||
1346 | * can use smp_mb__after_lock barrier. | ||
1347 | */ | 1425 | */ |
1348 | static inline int sk_has_sleeper(struct sock *sk) | 1426 | static inline bool wq_has_sleeper(struct socket_wq *wq) |
1349 | { | 1427 | { |
1428 | |||
1350 | /* | 1429 | /* |
1351 | * We need to be sure we are in sync with the | 1430 | * We need to be sure we are in sync with the |
1352 | * add_wait_queue modifications to the wait queue. | 1431 | * add_wait_queue modifications to the wait queue. |
1353 | * | 1432 | * |
1354 | * This memory barrier is paired in the sock_poll_wait. | 1433 | * This memory barrier is paired in the sock_poll_wait. |
1355 | */ | 1434 | */ |
1356 | smp_mb__after_lock(); | 1435 | smp_mb(); |
1357 | return sk->sk_sleep && waitqueue_active(sk->sk_sleep); | 1436 | return wq && waitqueue_active(&wq->wait); |
1358 | } | 1437 | } |
1359 | 1438 | ||
1360 | /** | 1439 | /** |
@@ -1363,7 +1442,7 @@ static inline int sk_has_sleeper(struct sock *sk) | |||
1363 | * @wait_address: socket wait queue | 1442 | * @wait_address: socket wait queue |
1364 | * @p: poll_table | 1443 | * @p: poll_table |
1365 | * | 1444 | * |
1366 | * See the comments in the sk_has_sleeper function. | 1445 | * See the comments in the wq_has_sleeper function. |
1367 | */ | 1446 | */ |
1368 | static inline void sock_poll_wait(struct file *filp, | 1447 | static inline void sock_poll_wait(struct file *filp, |
1369 | wait_queue_head_t *wait_address, poll_table *p) | 1448 | wait_queue_head_t *wait_address, poll_table *p) |
@@ -1374,7 +1453,7 @@ static inline void sock_poll_wait(struct file *filp, | |||
1374 | * We need to be sure we are in sync with the | 1453 | * We need to be sure we are in sync with the |
1375 | * socket flags modification. | 1454 | * socket flags modification. |
1376 | * | 1455 | * |
1377 | * This memory barrier is paired in the sk_has_sleeper. | 1456 | * This memory barrier is paired in the wq_has_sleeper. |
1378 | */ | 1457 | */ |
1379 | smp_mb(); | 1458 | smp_mb(); |
1380 | } | 1459 | } |
@@ -1556,7 +1635,24 @@ sock_recv_timestamp(struct msghdr *msg, struct sock *sk, struct sk_buff *skb) | |||
1556 | sk->sk_stamp = kt; | 1635 | sk->sk_stamp = kt; |
1557 | } | 1636 | } |
1558 | 1637 | ||
1559 | extern void sock_recv_ts_and_drops(struct msghdr *msg, struct sock *sk, struct sk_buff *skb); | 1638 | extern void __sock_recv_ts_and_drops(struct msghdr *msg, struct sock *sk, |
1639 | struct sk_buff *skb); | ||
1640 | |||
1641 | static inline void sock_recv_ts_and_drops(struct msghdr *msg, struct sock *sk, | ||
1642 | struct sk_buff *skb) | ||
1643 | { | ||
1644 | #define FLAGS_TS_OR_DROPS ((1UL << SOCK_RXQ_OVFL) | \ | ||
1645 | (1UL << SOCK_RCVTSTAMP) | \ | ||
1646 | (1UL << SOCK_TIMESTAMPING_RX_SOFTWARE) | \ | ||
1647 | (1UL << SOCK_TIMESTAMPING_SOFTWARE) | \ | ||
1648 | (1UL << SOCK_TIMESTAMPING_RAW_HARDWARE) | \ | ||
1649 | (1UL << SOCK_TIMESTAMPING_SYS_HARDWARE)) | ||
1650 | |||
1651 | if (sk->sk_flags & FLAGS_TS_OR_DROPS) | ||
1652 | __sock_recv_ts_and_drops(msg, sk, skb); | ||
1653 | else | ||
1654 | sk->sk_stamp = skb->tstamp; | ||
1655 | } | ||
1560 | 1656 | ||
1561 | /** | 1657 | /** |
1562 | * sock_tx_timestamp - checks whether the outgoing packet is to be time stamped | 1658 | * sock_tx_timestamp - checks whether the outgoing packet is to be time stamped |
diff --git a/include/net/tcp.h b/include/net/tcp.h index 75be5a28815d..fb5c66b2ab81 100644 --- a/include/net/tcp.h +++ b/include/net/tcp.h | |||
@@ -294,6 +294,7 @@ extern struct proto tcp_prot; | |||
294 | #define TCP_INC_STATS_BH(net, field) SNMP_INC_STATS_BH((net)->mib.tcp_statistics, field) | 294 | #define TCP_INC_STATS_BH(net, field) SNMP_INC_STATS_BH((net)->mib.tcp_statistics, field) |
295 | #define TCP_DEC_STATS(net, field) SNMP_DEC_STATS((net)->mib.tcp_statistics, field) | 295 | #define TCP_DEC_STATS(net, field) SNMP_DEC_STATS((net)->mib.tcp_statistics, field) |
296 | #define TCP_ADD_STATS_USER(net, field, val) SNMP_ADD_STATS_USER((net)->mib.tcp_statistics, field, val) | 296 | #define TCP_ADD_STATS_USER(net, field, val) SNMP_ADD_STATS_USER((net)->mib.tcp_statistics, field, val) |
297 | #define TCP_ADD_STATS(net, field, val) SNMP_ADD_STATS((net)->mib.tcp_statistics, field, val) | ||
297 | 298 | ||
298 | extern void tcp_v4_err(struct sk_buff *skb, u32); | 299 | extern void tcp_v4_err(struct sk_buff *skb, u32); |
299 | 300 | ||
@@ -423,7 +424,7 @@ extern u8 *tcp_parse_md5sig_option(struct tcphdr *th); | |||
423 | * TCP v4 functions exported for the inet6 API | 424 | * TCP v4 functions exported for the inet6 API |
424 | */ | 425 | */ |
425 | 426 | ||
426 | extern void tcp_v4_send_check(struct sock *sk, int len, | 427 | extern void tcp_v4_send_check(struct sock *sk, |
427 | struct sk_buff *skb); | 428 | struct sk_buff *skb); |
428 | 429 | ||
429 | extern int tcp_v4_conn_request(struct sock *sk, | 430 | extern int tcp_v4_conn_request(struct sock *sk, |
@@ -939,7 +940,7 @@ static inline int tcp_prequeue(struct sock *sk, struct sk_buff *skb) | |||
939 | 940 | ||
940 | tp->ucopy.memory = 0; | 941 | tp->ucopy.memory = 0; |
941 | } else if (skb_queue_len(&tp->ucopy.prequeue) == 1) { | 942 | } else if (skb_queue_len(&tp->ucopy.prequeue) == 1) { |
942 | wake_up_interruptible_sync_poll(sk->sk_sleep, | 943 | wake_up_interruptible_sync_poll(sk_sleep(sk), |
943 | POLLIN | POLLRDNORM | POLLRDBAND); | 944 | POLLIN | POLLRDNORM | POLLRDBAND); |
944 | if (!inet_csk_ack_scheduled(sk)) | 945 | if (!inet_csk_ack_scheduled(sk)) |
945 | inet_csk_reset_xmit_timer(sk, ICSK_TIME_DACK, | 946 | inet_csk_reset_xmit_timer(sk, ICSK_TIME_DACK, |
@@ -1032,6 +1033,14 @@ static inline int keepalive_probes(const struct tcp_sock *tp) | |||
1032 | return tp->keepalive_probes ? : sysctl_tcp_keepalive_probes; | 1033 | return tp->keepalive_probes ? : sysctl_tcp_keepalive_probes; |
1033 | } | 1034 | } |
1034 | 1035 | ||
1036 | static inline u32 keepalive_time_elapsed(const struct tcp_sock *tp) | ||
1037 | { | ||
1038 | const struct inet_connection_sock *icsk = &tp->inet_conn; | ||
1039 | |||
1040 | return min_t(u32, tcp_time_stamp - icsk->icsk_ack.lrcvtime, | ||
1041 | tcp_time_stamp - tp->rcv_tstamp); | ||
1042 | } | ||
1043 | |||
1035 | static inline int tcp_fin_time(const struct sock *sk) | 1044 | static inline int tcp_fin_time(const struct sock *sk) |
1036 | { | 1045 | { |
1037 | int fin_timeout = tcp_sk(sk)->linger2 ? : sysctl_tcp_fin_timeout; | 1046 | int fin_timeout = tcp_sk(sk)->linger2 ? : sysctl_tcp_fin_timeout; |
diff --git a/include/net/transp_v6.h b/include/net/transp_v6.h index d65381cad0fc..42a0eb68b7b6 100644 --- a/include/net/transp_v6.h +++ b/include/net/transp_v6.h | |||
@@ -44,7 +44,8 @@ extern int datagram_send_ctl(struct net *net, | |||
44 | struct msghdr *msg, | 44 | struct msghdr *msg, |
45 | struct flowi *fl, | 45 | struct flowi *fl, |
46 | struct ipv6_txoptions *opt, | 46 | struct ipv6_txoptions *opt, |
47 | int *hlimit, int *tclass); | 47 | int *hlimit, int *tclass, |
48 | int *dontfrag); | ||
48 | 49 | ||
49 | #define LOOPBACK4_IPV6 cpu_to_be32(0x7f000006) | 50 | #define LOOPBACK4_IPV6 cpu_to_be32(0x7f000006) |
50 | 51 | ||
diff --git a/include/net/x25.h b/include/net/x25.h index 9baa07dc7d17..468551ea4f1d 100644 --- a/include/net/x25.h +++ b/include/net/x25.h | |||
@@ -10,6 +10,7 @@ | |||
10 | #ifndef _X25_H | 10 | #ifndef _X25_H |
11 | #define _X25_H | 11 | #define _X25_H |
12 | #include <linux/x25.h> | 12 | #include <linux/x25.h> |
13 | #include <linux/slab.h> | ||
13 | #include <net/sock.h> | 14 | #include <net/sock.h> |
14 | 15 | ||
15 | #define X25_ADDR_LEN 16 | 16 | #define X25_ADDR_LEN 16 |
@@ -182,6 +183,10 @@ extern int sysctl_x25_clear_request_timeout; | |||
182 | extern int sysctl_x25_ack_holdback_timeout; | 183 | extern int sysctl_x25_ack_holdback_timeout; |
183 | extern int sysctl_x25_forward; | 184 | extern int sysctl_x25_forward; |
184 | 185 | ||
186 | extern int x25_parse_address_block(struct sk_buff *skb, | ||
187 | struct x25_address *called_addr, | ||
188 | struct x25_address *calling_addr); | ||
189 | |||
185 | extern int x25_addr_ntoa(unsigned char *, struct x25_address *, | 190 | extern int x25_addr_ntoa(unsigned char *, struct x25_address *, |
186 | struct x25_address *); | 191 | struct x25_address *); |
187 | extern int x25_addr_aton(unsigned char *, struct x25_address *, | 192 | extern int x25_addr_aton(unsigned char *, struct x25_address *, |
diff --git a/include/net/x25device.h b/include/net/x25device.h index 1415bcf93980..1fa08b49f1c2 100644 --- a/include/net/x25device.h +++ b/include/net/x25device.h | |||
@@ -3,6 +3,7 @@ | |||
3 | 3 | ||
4 | #include <linux/if_ether.h> | 4 | #include <linux/if_ether.h> |
5 | #include <linux/if_packet.h> | 5 | #include <linux/if_packet.h> |
6 | #include <linux/if_x25.h> | ||
6 | #include <linux/skbuff.h> | 7 | #include <linux/skbuff.h> |
7 | 8 | ||
8 | static inline __be16 x25_type_trans(struct sk_buff *skb, struct net_device *dev) | 9 | static inline __be16 x25_type_trans(struct sk_buff *skb, struct net_device *dev) |
diff --git a/include/net/xfrm.h b/include/net/xfrm.h index d74e080ba6c9..1913af67c43d 100644 --- a/include/net/xfrm.h +++ b/include/net/xfrm.h | |||
@@ -12,6 +12,7 @@ | |||
12 | #include <linux/in6.h> | 12 | #include <linux/in6.h> |
13 | #include <linux/mutex.h> | 13 | #include <linux/mutex.h> |
14 | #include <linux/audit.h> | 14 | #include <linux/audit.h> |
15 | #include <linux/slab.h> | ||
15 | 16 | ||
16 | #include <net/sock.h> | 17 | #include <net/sock.h> |
17 | #include <net/dst.h> | 18 | #include <net/dst.h> |
@@ -19,6 +20,7 @@ | |||
19 | #include <net/route.h> | 20 | #include <net/route.h> |
20 | #include <net/ipv6.h> | 21 | #include <net/ipv6.h> |
21 | #include <net/ip6_fib.h> | 22 | #include <net/ip6_fib.h> |
23 | #include <net/flow.h> | ||
22 | 24 | ||
23 | #include <linux/interrupt.h> | 25 | #include <linux/interrupt.h> |
24 | 26 | ||
@@ -266,7 +268,6 @@ struct xfrm_policy_afinfo { | |||
266 | xfrm_address_t *saddr, | 268 | xfrm_address_t *saddr, |
267 | xfrm_address_t *daddr); | 269 | xfrm_address_t *daddr); |
268 | int (*get_saddr)(struct net *net, xfrm_address_t *saddr, xfrm_address_t *daddr); | 270 | int (*get_saddr)(struct net *net, xfrm_address_t *saddr, xfrm_address_t *daddr); |
269 | struct dst_entry *(*find_bundle)(struct flowi *fl, struct xfrm_policy *policy); | ||
270 | void (*decode_session)(struct sk_buff *skb, | 271 | void (*decode_session)(struct sk_buff *skb, |
271 | struct flowi *fl, | 272 | struct flowi *fl, |
272 | int reverse); | 273 | int reverse); |
@@ -481,13 +482,14 @@ struct xfrm_policy { | |||
481 | atomic_t refcnt; | 482 | atomic_t refcnt; |
482 | struct timer_list timer; | 483 | struct timer_list timer; |
483 | 484 | ||
485 | struct flow_cache_object flo; | ||
486 | atomic_t genid; | ||
484 | u32 priority; | 487 | u32 priority; |
485 | u32 index; | 488 | u32 index; |
486 | struct xfrm_mark mark; | 489 | struct xfrm_mark mark; |
487 | struct xfrm_selector selector; | 490 | struct xfrm_selector selector; |
488 | struct xfrm_lifetime_cfg lft; | 491 | struct xfrm_lifetime_cfg lft; |
489 | struct xfrm_lifetime_cur curlft; | 492 | struct xfrm_lifetime_cur curlft; |
490 | struct dst_entry *bundles; | ||
491 | struct xfrm_policy_walk_entry walk; | 493 | struct xfrm_policy_walk_entry walk; |
492 | u8 type; | 494 | u8 type; |
493 | u8 action; | 495 | u8 action; |
@@ -734,19 +736,12 @@ static inline void xfrm_pol_put(struct xfrm_policy *policy) | |||
734 | xfrm_policy_destroy(policy); | 736 | xfrm_policy_destroy(policy); |
735 | } | 737 | } |
736 | 738 | ||
737 | #ifdef CONFIG_XFRM_SUB_POLICY | ||
738 | static inline void xfrm_pols_put(struct xfrm_policy **pols, int npols) | 739 | static inline void xfrm_pols_put(struct xfrm_policy **pols, int npols) |
739 | { | 740 | { |
740 | int i; | 741 | int i; |
741 | for (i = npols - 1; i >= 0; --i) | 742 | for (i = npols - 1; i >= 0; --i) |
742 | xfrm_pol_put(pols[i]); | 743 | xfrm_pol_put(pols[i]); |
743 | } | 744 | } |
744 | #else | ||
745 | static inline void xfrm_pols_put(struct xfrm_policy **pols, int npols) | ||
746 | { | ||
747 | xfrm_pol_put(pols[0]); | ||
748 | } | ||
749 | #endif | ||
750 | 745 | ||
751 | extern void __xfrm_state_destroy(struct xfrm_state *); | 746 | extern void __xfrm_state_destroy(struct xfrm_state *); |
752 | 747 | ||
@@ -877,11 +872,15 @@ struct xfrm_dst { | |||
877 | struct rt6_info rt6; | 872 | struct rt6_info rt6; |
878 | } u; | 873 | } u; |
879 | struct dst_entry *route; | 874 | struct dst_entry *route; |
875 | struct flow_cache_object flo; | ||
876 | struct xfrm_policy *pols[XFRM_POLICY_TYPE_MAX]; | ||
877 | int num_pols, num_xfrms; | ||
880 | #ifdef CONFIG_XFRM_SUB_POLICY | 878 | #ifdef CONFIG_XFRM_SUB_POLICY |
881 | struct flowi *origin; | 879 | struct flowi *origin; |
882 | struct xfrm_selector *partner; | 880 | struct xfrm_selector *partner; |
883 | #endif | 881 | #endif |
884 | u32 genid; | 882 | u32 xfrm_genid; |
883 | u32 policy_genid; | ||
885 | u32 route_mtu_cached; | 884 | u32 route_mtu_cached; |
886 | u32 child_mtu_cached; | 885 | u32 child_mtu_cached; |
887 | u32 route_cookie; | 886 | u32 route_cookie; |
@@ -891,6 +890,7 @@ struct xfrm_dst { | |||
891 | #ifdef CONFIG_XFRM | 890 | #ifdef CONFIG_XFRM |
892 | static inline void xfrm_dst_destroy(struct xfrm_dst *xdst) | 891 | static inline void xfrm_dst_destroy(struct xfrm_dst *xdst) |
893 | { | 892 | { |
893 | xfrm_pols_put(xdst->pols, xdst->num_pols); | ||
894 | dst_release(xdst->route); | 894 | dst_release(xdst->route); |
895 | if (likely(xdst->u.dst.xfrm)) | 895 | if (likely(xdst->u.dst.xfrm)) |
896 | xfrm_state_put(xdst->u.dst.xfrm); | 896 | xfrm_state_put(xdst->u.dst.xfrm); |