2 * Copyright (c) 2006 - 2009 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
54 IETF_MPA_FLAGS_MARKERS
= 0x80, /* receive Markers */
55 IETF_MPA_FLAGS_CRC
= 0x40, /* receive Markers */
56 IETF_MPA_FLAGS_REJECT
= 0x20, /* Reject */
59 struct ietf_mpa_frame
{
60 u8 key
[IETF_MPA_KEY_SIZE
];
67 #define ietf_mpa_req_resp_frame ietf_mpa_frame
71 __le32 DstIpAdrIndex
; /* Only most significant 5 bits are valid */
73 __be16 TcpPorts
[2]; /* src is low, dest is high */
80 NES_TIMER_NODE_CLEANUP
,
84 #define NES_PASSIVE_STATE_INDICATED 0
85 #define NES_DO_NOT_SEND_RESET_EVENT 1
86 #define NES_SEND_RESET_EVENT 2
95 #define TCP_OPTIONS_PADDING 3
102 enum option_numbers
{
106 OPTION_NUMBER_WINDOW_SCALE
,
107 OPTION_NUMBER_SACK_PERM
,
109 OPTION_NUMBER_WRITE0
= 0xbc
118 struct option_windowscale
{
124 union all_known_options
{
126 struct option_base as_base
;
127 struct option_mss as_mss
;
128 struct option_windowscale as_windowscale
;
131 struct nes_timer_entry
{
132 struct list_head list
;
133 unsigned long timetosend
; /* jiffies */
141 int close_when_complete
;
142 struct net_device
*netdev
;
145 #define NES_DEFAULT_RETRYS 64
146 #define NES_DEFAULT_RETRANS 8
147 #ifdef CONFIG_INFINIBAND_NES_DEBUG
148 #define NES_RETRY_TIMEOUT (1000*HZ/1000)
150 #define NES_RETRY_TIMEOUT (3000*HZ/1000)
152 #define NES_SHORT_TIME (10)
153 #define NES_LONG_TIME (2000*HZ/1000)
154 #define NES_MAX_TIMEOUT ((unsigned long) (12*HZ))
156 #define NES_CM_HASHTABLE_SIZE 1024
157 #define NES_CM_TCP_TIMER_INTERVAL 3000
158 #define NES_CM_DEFAULT_MTU 1540
159 #define NES_CM_DEFAULT_FRAME_CNT 10
160 #define NES_CM_THREAD_STACK_SIZE 256
161 #define NES_CM_DEFAULT_RCV_WND 64240 // before we know that window scaling is allowed
162 #define NES_CM_DEFAULT_RCV_WND_SCALED 256960 // after we know that window scaling is allowed
163 #define NES_CM_DEFAULT_RCV_WND_SCALE 2
164 #define NES_CM_DEFAULT_FREE_PKTS 0x000A
165 #define NES_CM_FREE_PKT_LO_WATERMARK 2
167 #define NES_CM_DEFAULT_MSS 536
169 #define NES_CM_DEF_SEQ 0x159bf75f
170 #define NES_CM_DEF_LOCAL_ID 0x3b47
172 #define NES_CM_DEF_SEQ2 0x18ed5740
173 #define NES_CM_DEF_LOCAL_ID2 0xb807
174 #define MAX_CM_BUFFER (IETF_MPA_FRAME_SIZE + IETF_MAX_PRIV_DATA_LEN)
177 typedef u32 nes_addr_t
;
179 #define nes_cm_tsa_context nes_qp_context
183 /* cm node transition states */
184 enum nes_cm_node_state
{
185 NES_CM_STATE_UNKNOWN
,
187 NES_CM_STATE_LISTENING
,
188 NES_CM_STATE_SYN_RCVD
,
189 NES_CM_STATE_SYN_SENT
,
190 NES_CM_STATE_ONE_SIDE_ESTABLISHED
,
191 NES_CM_STATE_ESTABLISHED
,
192 NES_CM_STATE_ACCEPTING
,
193 NES_CM_STATE_MPAREQ_SENT
,
194 NES_CM_STATE_MPAREQ_RCVD
,
195 NES_CM_STATE_MPAREJ_RCVD
,
197 NES_CM_STATE_FIN_WAIT1
,
198 NES_CM_STATE_FIN_WAIT2
,
199 NES_CM_STATE_CLOSE_WAIT
,
200 NES_CM_STATE_TIME_WAIT
,
201 NES_CM_STATE_LAST_ACK
,
202 NES_CM_STATE_CLOSING
,
203 NES_CM_STATE_LISTENER_DESTROYED
,
207 enum nes_tcpip_pkt_type
{
208 NES_PKT_TYPE_UNKNOWN
,
217 /* type of nes connection */
218 enum nes_cm_conn_type
{
219 NES_CM_IWARP_CONN_TYPE
,
222 /* CM context params */
223 struct nes_cm_tcp_context
{
242 struct nes_cm_tsa_context tsa_cntxt
;
243 struct timeval sent_ts
;
247 enum nes_cm_listener_state
{
248 NES_CM_LISTENER_PASSIVE_STATE
=1,
249 NES_CM_LISTENER_ACTIVE_STATE
=2,
250 NES_CM_LISTENER_EITHER_STATE
=3
253 struct nes_cm_listener
{
254 struct list_head list
;
255 struct nes_cm_core
*cm_core
;
256 u8 loc_mac
[ETH_ALEN
];
259 struct iw_cm_id
*cm_id
;
260 enum nes_cm_conn_type conn_type
;
262 struct nes_vnic
*nesvnic
;
263 atomic_t pend_accepts_cnt
;
265 enum nes_cm_listener_state listener_state
;
269 /* per connection node and node state information */
271 nes_addr_t loc_addr
, rem_addr
;
272 u16 loc_port
, rem_port
;
274 u8 loc_mac
[ETH_ALEN
];
275 u8 rem_mac
[ETH_ALEN
];
277 enum nes_cm_node_state state
;
278 struct nes_cm_tcp_context tcp_cntxt
;
279 struct nes_cm_core
*cm_core
;
280 struct sk_buff_head resend_list
;
282 struct net_device
*netdev
;
284 struct nes_cm_node
*loopbackpartner
;
286 struct nes_timer_entry
*send_entry
;
288 spinlock_t retrans_list_lock
;
289 struct nes_timer_entry
*recv_entry
;
293 struct ietf_mpa_frame mpa_frame
;
294 u8 mpa_frame_buf
[MAX_CM_BUFFER
];
297 struct iw_cm_id
*cm_id
;
298 struct list_head list
;
300 struct nes_cm_listener
*listener
;
301 enum nes_cm_conn_type conn_type
;
302 struct nes_vnic
*nesvnic
;
305 struct list_head timer_entry
;
306 struct list_head reset_entry
;
307 struct nes_qp
*nesqp
;
308 atomic_t passive_state
;
311 /* structure for client or CM to fill when making CM api calls. */
312 /* - only need to set relevant data, based on op. */
315 struct iw_cm_id
*cm_id
;
316 struct net_device
*netdev
;
324 enum nes_cm_conn_type conn_type
;
329 enum nes_cm_event_type
{
330 NES_CM_EVENT_UNKNOWN
,
331 NES_CM_EVENT_ESTABLISHED
,
332 NES_CM_EVENT_MPA_REQ
,
333 NES_CM_EVENT_MPA_CONNECT
,
334 NES_CM_EVENT_MPA_ACCEPT
,
335 NES_CM_EVENT_MPA_REJECT
,
336 NES_CM_EVENT_MPA_ESTABLISHED
,
337 NES_CM_EVENT_CONNECTED
,
340 NES_CM_EVENT_DROPPED_PKT
,
341 NES_CM_EVENT_CLOSE_IMMED
,
342 NES_CM_EVENT_CLOSE_HARD
,
343 NES_CM_EVENT_CLOSE_CLEAN
,
344 NES_CM_EVENT_ABORTED
,
345 NES_CM_EVENT_SEND_FIRST
348 /* event to post to CM event handler */
349 struct nes_cm_event
{
350 enum nes_cm_event_type type
;
352 struct nes_cm_info cm_info
;
353 struct work_struct event_work
;
354 struct nes_cm_node
*cm_node
;
358 enum nes_cm_node_state state
;
360 atomic_t listen_node_cnt
;
361 struct nes_cm_node listen_list
;
362 spinlock_t listen_list_lock
;
367 atomic_t ht_node_cnt
;
368 struct list_head connected_nodes
;
369 /* struct list_head hashtable[NES_CM_HASHTABLE_SIZE]; */
372 struct timer_list tcp_timer
;
374 struct nes_cm_ops
*api
;
376 int (*post_event
)(struct nes_cm_event
*event
);
377 atomic_t events_posted
;
378 struct workqueue_struct
*event_wq
;
379 struct workqueue_struct
*disconn_wq
;
382 u64 aborted_connects
;
385 struct nes_cm_node
*current_listen_node
;
389 #define NES_CM_SET_PKT_SIZE (1 << 1)
390 #define NES_CM_SET_FREE_PKT_Q_SIZE (1 << 2)
392 /* CM ops/API for client interface */
394 int (*accelerated
)(struct nes_cm_core
*, struct nes_cm_node
*);
395 struct nes_cm_listener
* (*listen
)(struct nes_cm_core
*, struct nes_vnic
*,
396 struct nes_cm_info
*);
397 int (*stop_listener
)(struct nes_cm_core
*, struct nes_cm_listener
*);
398 struct nes_cm_node
* (*connect
)(struct nes_cm_core
*,
399 struct nes_vnic
*, u16
, void *,
400 struct nes_cm_info
*);
401 int (*close
)(struct nes_cm_core
*, struct nes_cm_node
*);
402 int (*accept
)(struct nes_cm_core
*, struct ietf_mpa_frame
*,
403 struct nes_cm_node
*);
404 int (*reject
)(struct nes_cm_core
*, struct ietf_mpa_frame
*,
405 struct nes_cm_node
*);
406 int (*recv_pkt
)(struct nes_cm_core
*, struct nes_vnic
*,
408 int (*destroy_cm_core
)(struct nes_cm_core
*);
409 int (*get
)(struct nes_cm_core
*);
410 int (*set
)(struct nes_cm_core
*, u32
, u32
);
413 int schedule_nes_timer(struct nes_cm_node
*, struct sk_buff
*,
414 enum nes_timer_type
, int, int);
416 int nes_accept(struct iw_cm_id
*, struct iw_cm_conn_param
*);
417 int nes_reject(struct iw_cm_id
*, const void *, u8
);
418 int nes_connect(struct iw_cm_id
*, struct iw_cm_conn_param
*);
419 int nes_create_listen(struct iw_cm_id
*, int);
420 int nes_destroy_listen(struct iw_cm_id
*);
422 int nes_cm_recv(struct sk_buff
*, struct net_device
*);
423 int nes_cm_start(void);
424 int nes_cm_stop(void);
426 #endif /* NES_CM_H */