2 * Copyright (c) 2006 - 2014 Intel Corporation. All rights reserved.
4 * This software is available to you under a choice of one of two
5 * licenses. You may choose to be licensed under the terms of the GNU
6 * General Public License (GPL) Version 2, available from the file
7 * COPYING in the main directory of this source tree, or the
8 * OpenIB.org BSD license below:
10 * Redistribution and use in source and binary forms, with or
11 * without modification, are permitted provided that the following
14 * - Redistributions of source code must retain the above
15 * copyright notice, this list of conditions and the following
18 * - Redistributions in binary form must reproduce the above
19 * copyright notice, this list of conditions and the following
20 * disclaimer in the documentation and/or other materials
21 * provided with the distribution.
23 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
24 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
25 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
26 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
27 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
28 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
29 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
39 #define NES_MANAGE_APBVT_DEL 0
40 #define NES_MANAGE_APBVT_ADD 1
42 #define NES_MPA_REQUEST_ACCEPT 1
43 #define NES_MPA_REQUEST_REJECT 2
45 /* IETF MPA -- defines, enums, structs */
46 #define IEFT_MPA_KEY_REQ "MPA ID Req Frame"
47 #define IEFT_MPA_KEY_REP "MPA ID Rep Frame"
48 #define IETF_MPA_KEY_SIZE 16
49 #define IETF_MPA_VERSION 1
50 #define IETF_MAX_PRIV_DATA_LEN 512
51 #define IETF_MPA_FRAME_SIZE 20
52 #define IETF_RTR_MSG_SIZE 4
53 #define IETF_MPA_V2_FLAG 0x10
55 /* IETF RTR MSG Fields */
56 #define IETF_PEER_TO_PEER 0x8000
57 #define IETF_FLPDU_ZERO_LEN 0x4000
58 #define IETF_RDMA0_WRITE 0x8000
59 #define IETF_RDMA0_READ 0x4000
60 #define IETF_NO_IRD_ORD 0x3FFF
61 #define NES_MAX_IRD 0x40
62 #define NES_MAX_ORD 0x7F
65 IETF_MPA_FLAGS_MARKERS = 0x80, /* receive Markers */
66 IETF_MPA_FLAGS_CRC = 0x40, /* receive Markers */
67 IETF_MPA_FLAGS_REJECT = 0x20, /* Reject */
71 u8 key[IETF_MPA_KEY_SIZE];
78 #define ietf_mpa_req_resp_frame ietf_mpa_frame
86 u8 key[IETF_MPA_KEY_SIZE];
90 struct ietf_rtr_msg rtr_msg;
96 __le32 DstIpAdrIndex; /* Only most significant 5 bits are valid */
98 __be16 TcpPorts[2]; /* src is low, dest is high */
102 enum nes_timer_type {
105 NES_TIMER_NODE_CLEANUP,
106 NES_TIMER_TYPE_CLOSE,
109 #define NES_PASSIVE_STATE_INDICATED 0
110 #define NES_DO_NOT_SEND_RESET_EVENT 1
111 #define NES_SEND_RESET_EVENT 2
113 #define MAX_NES_IFS 4
120 #define TCP_OPTIONS_PADDING 3
127 enum option_numbers {
131 OPTION_NUMBER_WINDOW_SCALE,
132 OPTION_NUMBER_SACK_PERM,
134 OPTION_NUMBER_WRITE0 = 0xbc
143 struct option_windowscale {
149 union all_known_options {
151 struct option_base as_base;
152 struct option_mss as_mss;
153 struct option_windowscale as_windowscale;
156 struct nes_timer_entry {
157 struct list_head list;
158 unsigned long timetosend; /* jiffies */
166 int close_when_complete;
167 struct net_device *netdev;
170 #define NES_DEFAULT_RETRYS 64
171 #define NES_DEFAULT_RETRANS 8
172 #ifdef CONFIG_INFINIBAND_NES_DEBUG
173 #define NES_RETRY_TIMEOUT (1000*HZ/1000)
175 #define NES_RETRY_TIMEOUT (3000*HZ/1000)
177 #define NES_SHORT_TIME (10)
178 #define NES_LONG_TIME (2000*HZ/1000)
179 #define NES_MAX_TIMEOUT ((unsigned long) (12*HZ))
181 #define NES_CM_HASHTABLE_SIZE 1024
182 #define NES_CM_TCP_TIMER_INTERVAL 3000
183 #define NES_CM_DEFAULT_MTU 1540
184 #define NES_CM_DEFAULT_FRAME_CNT 10
185 #define NES_CM_THREAD_STACK_SIZE 256
186 #define NES_CM_DEFAULT_RCV_WND 64240 // before we know that window scaling is allowed
187 #define NES_CM_DEFAULT_RCV_WND_SCALED 256960 // after we know that window scaling is allowed
188 #define NES_CM_DEFAULT_RCV_WND_SCALE 2
189 #define NES_CM_DEFAULT_FREE_PKTS 0x000A
190 #define NES_CM_FREE_PKT_LO_WATERMARK 2
192 #define NES_CM_DEFAULT_MSS 536
194 #define NES_CM_DEF_SEQ 0x159bf75f
195 #define NES_CM_DEF_LOCAL_ID 0x3b47
197 #define NES_CM_DEF_SEQ2 0x18ed5740
198 #define NES_CM_DEF_LOCAL_ID2 0xb807
199 #define MAX_CM_BUFFER (IETF_MPA_FRAME_SIZE + IETF_RTR_MSG_SIZE + IETF_MAX_PRIV_DATA_LEN)
201 typedef u32 nes_addr_t;
203 #define nes_cm_tsa_context nes_qp_context
207 /* cm node transition states */
208 enum nes_cm_node_state {
209 NES_CM_STATE_UNKNOWN,
211 NES_CM_STATE_LISTENING,
212 NES_CM_STATE_SYN_RCVD,
213 NES_CM_STATE_SYN_SENT,
214 NES_CM_STATE_ONE_SIDE_ESTABLISHED,
215 NES_CM_STATE_ESTABLISHED,
216 NES_CM_STATE_ACCEPTING,
217 NES_CM_STATE_MPAREQ_SENT,
218 NES_CM_STATE_MPAREQ_RCVD,
219 NES_CM_STATE_MPAREJ_RCVD,
221 NES_CM_STATE_FIN_WAIT1,
222 NES_CM_STATE_FIN_WAIT2,
223 NES_CM_STATE_CLOSE_WAIT,
224 NES_CM_STATE_TIME_WAIT,
225 NES_CM_STATE_LAST_ACK,
226 NES_CM_STATE_CLOSING,
227 NES_CM_STATE_LISTENER_DESTROYED,
231 enum mpa_frame_version {
242 SEND_RDMA_READ_ZERO = 1,
243 SEND_RDMA_WRITE_ZERO = 2
246 enum nes_tcpip_pkt_type {
247 NES_PKT_TYPE_UNKNOWN,
256 /* type of nes connection */
257 enum nes_cm_conn_type {
258 NES_CM_IWARP_CONN_TYPE,
261 /* CM context params */
262 struct nes_cm_tcp_context {
281 struct nes_cm_tsa_context tsa_cntxt;
282 struct timeval sent_ts;
286 enum nes_cm_listener_state {
287 NES_CM_LISTENER_PASSIVE_STATE = 1,
288 NES_CM_LISTENER_ACTIVE_STATE = 2,
289 NES_CM_LISTENER_EITHER_STATE = 3
292 struct nes_cm_listener {
293 struct list_head list;
294 struct nes_cm_core *cm_core;
295 u8 loc_mac[ETH_ALEN];
296 nes_addr_t loc_addr, mapped_loc_addr;
297 u16 loc_port, mapped_loc_port;
298 struct iw_cm_id *cm_id;
299 enum nes_cm_conn_type conn_type;
301 struct nes_vnic *nesvnic;
302 atomic_t pend_accepts_cnt;
304 enum nes_cm_listener_state listener_state;
308 /* per connection node and node state information */
310 nes_addr_t loc_addr, rem_addr;
311 nes_addr_t mapped_loc_addr, mapped_rem_addr;
312 u16 loc_port, rem_port;
313 u16 mapped_loc_port, mapped_rem_port;
315 u8 loc_mac[ETH_ALEN];
316 u8 rem_mac[ETH_ALEN];
318 enum nes_cm_node_state state;
319 struct nes_cm_tcp_context tcp_cntxt;
320 struct nes_cm_core *cm_core;
321 struct sk_buff_head resend_list;
323 struct net_device *netdev;
325 struct nes_cm_node *loopbackpartner;
327 struct nes_timer_entry *send_entry;
328 struct nes_timer_entry *recv_entry;
329 spinlock_t retrans_list_lock;
330 enum send_rdma0 send_rdma0_op;
333 struct ietf_mpa_v1 mpa_frame;
334 struct ietf_mpa_v2 mpa_v2_frame;
335 u8 mpa_frame_buf[MAX_CM_BUFFER];
337 enum mpa_frame_version mpa_frame_rev;
343 struct iw_cm_id *cm_id;
344 struct list_head list;
346 struct nes_cm_listener *listener;
347 enum nes_cm_conn_type conn_type;
348 struct nes_vnic *nesvnic;
351 struct list_head timer_entry;
352 struct list_head reset_entry;
353 struct nes_qp *nesqp;
354 atomic_t passive_state;
357 /* structure for client or CM to fill when making CM api calls. */
358 /* - only need to set relevant data, based on op. */
361 struct iw_cm_id *cm_id;
362 struct net_device *netdev;
371 nes_addr_t mapped_loc_addr;
372 nes_addr_t mapped_rem_addr;
374 enum nes_cm_conn_type conn_type;
379 enum nes_cm_event_type {
380 NES_CM_EVENT_UNKNOWN,
381 NES_CM_EVENT_ESTABLISHED,
382 NES_CM_EVENT_MPA_REQ,
383 NES_CM_EVENT_MPA_CONNECT,
384 NES_CM_EVENT_MPA_ACCEPT,
385 NES_CM_EVENT_MPA_REJECT,
386 NES_CM_EVENT_MPA_ESTABLISHED,
387 NES_CM_EVENT_CONNECTED,
390 NES_CM_EVENT_DROPPED_PKT,
391 NES_CM_EVENT_CLOSE_IMMED,
392 NES_CM_EVENT_CLOSE_HARD,
393 NES_CM_EVENT_CLOSE_CLEAN,
394 NES_CM_EVENT_ABORTED,
395 NES_CM_EVENT_SEND_FIRST
398 /* event to post to CM event handler */
399 struct nes_cm_event {
400 enum nes_cm_event_type type;
402 struct nes_cm_info cm_info;
403 struct work_struct event_work;
404 struct nes_cm_node *cm_node;
408 enum nes_cm_node_state state;
410 atomic_t listen_node_cnt;
411 struct nes_cm_node listen_list;
412 spinlock_t listen_list_lock;
417 atomic_t ht_node_cnt;
418 struct list_head connected_nodes;
419 /* struct list_head hashtable[NES_CM_HASHTABLE_SIZE]; */
422 struct timer_list tcp_timer;
424 struct nes_cm_ops *api;
426 int (*post_event)(struct nes_cm_event *event);
427 atomic_t events_posted;
428 struct workqueue_struct *event_wq;
429 struct workqueue_struct *disconn_wq;
432 u64 aborted_connects;
435 struct nes_cm_node *current_listen_node;
439 #define NES_CM_SET_PKT_SIZE (1 << 1)
440 #define NES_CM_SET_FREE_PKT_Q_SIZE (1 << 2)
442 /* CM ops/API for client interface */
444 int (*accelerated)(struct nes_cm_core *, struct nes_cm_node *);
445 struct nes_cm_listener * (*listen)(struct nes_cm_core *, struct nes_vnic *,
446 struct nes_cm_info *);
447 int (*stop_listener)(struct nes_cm_core *, struct nes_cm_listener *);
448 struct nes_cm_node * (*connect)(struct nes_cm_core *,
449 struct nes_vnic *, u16, void *,
450 struct nes_cm_info *);
451 int (*close)(struct nes_cm_core *, struct nes_cm_node *);
452 int (*accept)(struct nes_cm_core *, struct nes_cm_node *);
453 int (*reject)(struct nes_cm_core *, struct nes_cm_node *);
454 int (*recv_pkt)(struct nes_cm_core *, struct nes_vnic *,
456 int (*destroy_cm_core)(struct nes_cm_core *);
457 int (*get)(struct nes_cm_core *);
458 int (*set)(struct nes_cm_core *, u32, u32);
461 int schedule_nes_timer(struct nes_cm_node *, struct sk_buff *,
462 enum nes_timer_type, int, int);
464 int nes_accept(struct iw_cm_id *, struct iw_cm_conn_param *);
465 int nes_reject(struct iw_cm_id *, const void *, u8);
466 int nes_connect(struct iw_cm_id *, struct iw_cm_conn_param *);
467 int nes_create_listen(struct iw_cm_id *, int);
468 int nes_destroy_listen(struct iw_cm_id *);
470 int nes_cm_recv(struct sk_buff *, struct net_device *);
471 int nes_cm_start(void);
472 int nes_cm_stop(void);
473 int nes_add_ref_cm_node(struct nes_cm_node *cm_node);
474 int nes_rem_ref_cm_node(struct nes_cm_node *cm_node);
476 #endif /* NES_CM_H */