This source file includes following definitions.
- to_ep
- to_listen_ep
- compute_wscale
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32 #ifndef _IWCH_CM_H_
33 #define _IWCH_CM_H_
34
35 #include <linux/inet.h>
36 #include <linux/wait.h>
37 #include <linux/spinlock.h>
38 #include <linux/kref.h>
39
40 #include <rdma/ib_verbs.h>
41 #include <rdma/iw_cm.h>
42
43 #include "cxgb3_offload.h"
44 #include "iwch_provider.h"
45
46 #define MPA_KEY_REQ "MPA ID Req Frame"
47 #define MPA_KEY_REP "MPA ID Rep Frame"
48
49 #define MPA_MAX_PRIVATE_DATA 256
50 #define MPA_REV 0
51 #define MPA_REJECT 0x20
52 #define MPA_CRC 0x40
53 #define MPA_MARKERS 0x80
54 #define MPA_FLAGS_MASK 0xE0
55
56 #define put_ep(ep) { \
57 pr_debug("put_ep (via %s:%u) ep %p refcnt %d\n", \
58 __func__, __LINE__, ep, kref_read(&((ep)->kref))); \
59 WARN_ON(kref_read(&((ep)->kref)) < 1); \
60 kref_put(&((ep)->kref), __free_ep); \
61 }
62
63 #define get_ep(ep) { \
64 pr_debug("get_ep (via %s:%u) ep %p, refcnt %d\n", \
65 __func__, __LINE__, ep, kref_read(&((ep)->kref))); \
66 kref_get(&((ep)->kref)); \
67 }
68
69 struct mpa_message {
70 u8 key[16];
71 u8 flags;
72 u8 revision;
73 __be16 private_data_size;
74 u8 private_data[0];
75 };
76
77 struct terminate_message {
78 u8 layer_etype;
79 u8 ecode;
80 __be16 hdrct_rsvd;
81 u8 len_hdrs[0];
82 };
83
84 #define TERM_MAX_LENGTH (sizeof(struct terminate_message) + 2 + 18 + 28)
85
86 enum iwch_layers_types {
87 LAYER_RDMAP = 0x00,
88 LAYER_DDP = 0x10,
89 LAYER_MPA = 0x20,
90 RDMAP_LOCAL_CATA = 0x00,
91 RDMAP_REMOTE_PROT = 0x01,
92 RDMAP_REMOTE_OP = 0x02,
93 DDP_LOCAL_CATA = 0x00,
94 DDP_TAGGED_ERR = 0x01,
95 DDP_UNTAGGED_ERR = 0x02,
96 DDP_LLP = 0x03
97 };
98
99 enum iwch_rdma_ecodes {
100 RDMAP_INV_STAG = 0x00,
101 RDMAP_BASE_BOUNDS = 0x01,
102 RDMAP_ACC_VIOL = 0x02,
103 RDMAP_STAG_NOT_ASSOC = 0x03,
104 RDMAP_TO_WRAP = 0x04,
105 RDMAP_INV_VERS = 0x05,
106 RDMAP_INV_OPCODE = 0x06,
107 RDMAP_STREAM_CATA = 0x07,
108 RDMAP_GLOBAL_CATA = 0x08,
109 RDMAP_CANT_INV_STAG = 0x09,
110 RDMAP_UNSPECIFIED = 0xff
111 };
112
113 enum iwch_ddp_ecodes {
114 DDPT_INV_STAG = 0x00,
115 DDPT_BASE_BOUNDS = 0x01,
116 DDPT_STAG_NOT_ASSOC = 0x02,
117 DDPT_TO_WRAP = 0x03,
118 DDPT_INV_VERS = 0x04,
119 DDPU_INV_QN = 0x01,
120 DDPU_INV_MSN_NOBUF = 0x02,
121 DDPU_INV_MSN_RANGE = 0x03,
122 DDPU_INV_MO = 0x04,
123 DDPU_MSG_TOOBIG = 0x05,
124 DDPU_INV_VERS = 0x06
125 };
126
127 enum iwch_mpa_ecodes {
128 MPA_CRC_ERR = 0x02,
129 MPA_MARKER_ERR = 0x03
130 };
131
132 enum iwch_ep_state {
133 IDLE = 0,
134 LISTEN,
135 CONNECTING,
136 MPA_REQ_WAIT,
137 MPA_REQ_SENT,
138 MPA_REQ_RCVD,
139 MPA_REP_SENT,
140 FPDU_MODE,
141 ABORTING,
142 CLOSING,
143 MORIBUND,
144 DEAD,
145 };
146
147 enum iwch_ep_flags {
148 PEER_ABORT_IN_PROGRESS = 0,
149 ABORT_REQ_IN_PROGRESS = 1,
150 RELEASE_RESOURCES = 2,
151 CLOSE_SENT = 3,
152 };
153
154 struct iwch_ep_common {
155 struct iw_cm_id *cm_id;
156 struct iwch_qp *qp;
157 struct t3cdev *tdev;
158 enum iwch_ep_state state;
159 struct kref kref;
160 spinlock_t lock;
161 struct sockaddr_in local_addr;
162 struct sockaddr_in remote_addr;
163 wait_queue_head_t waitq;
164 int rpl_done;
165 int rpl_err;
166 unsigned long flags;
167 };
168
169 struct iwch_listen_ep {
170 struct iwch_ep_common com;
171 unsigned int stid;
172 int backlog;
173 };
174
175 struct iwch_ep {
176 struct iwch_ep_common com;
177 struct iwch_ep *parent_ep;
178 struct timer_list timer;
179 unsigned int atid;
180 u32 hwtid;
181 u32 snd_seq;
182 u32 rcv_seq;
183 struct l2t_entry *l2t;
184 struct dst_entry *dst;
185 struct sk_buff *mpa_skb;
186 struct iwch_mpa_attributes mpa_attr;
187 unsigned int mpa_pkt_len;
188 u8 mpa_pkt[sizeof(struct mpa_message) + MPA_MAX_PRIVATE_DATA];
189 u8 tos;
190 u16 emss;
191 u16 plen;
192 u32 ird;
193 u32 ord;
194 };
195
196 static inline struct iwch_ep *to_ep(struct iw_cm_id *cm_id)
197 {
198 return cm_id->provider_data;
199 }
200
201 static inline struct iwch_listen_ep *to_listen_ep(struct iw_cm_id *cm_id)
202 {
203 return cm_id->provider_data;
204 }
205
206 static inline int compute_wscale(int win)
207 {
208 int wscale = 0;
209
210 while (wscale < 14 && (65535<<wscale) < win)
211 wscale++;
212 return wscale;
213 }
214
215
216
217 int iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
218 int iwch_create_listen(struct iw_cm_id *cm_id, int backlog);
219 int iwch_destroy_listen(struct iw_cm_id *cm_id);
220 int iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
221 int iwch_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
222 int iwch_ep_disconnect(struct iwch_ep *ep, int abrupt, gfp_t gfp);
223 int iwch_quiesce_tid(struct iwch_ep *ep);
224 int iwch_resume_tid(struct iwch_ep *ep);
225 void __free_ep(struct kref *kref);
226 void iwch_rearp(struct iwch_ep *ep);
227 int iwch_ep_redirect(void *ctx, struct dst_entry *old, struct dst_entry *new, struct l2t_entry *l2t);
228
229 int __init iwch_cm_init(void);
230 void __exit iwch_cm_term(void);
231 extern int peer2peer;
232
233 #endif