1 /* SPDX-License-Identifier: GPL-2.0 OR BSD-3-Clause */
2 
3 /* Authors: Cheng Xu <chengyou@linux.alibaba.com> */
4 /*          Kai Shen <kaishen@linux.alibaba.com> */
5 /* Copyright (c) 2020-2022, Alibaba Group. */
6 
7 /* Authors: Bernard Metzler <bmt@zurich.ibm.com> */
8 /*          Greg Joyce <greg@opengridcomputing.com> */
9 /* Copyright (c) 2008-2019, IBM Corporation */
10 /* Copyright (c) 2017, Open Grid Computing, Inc. */
11 
12 #ifndef __ERDMA_CM_H__
13 #define __ERDMA_CM_H__
14 
15 #include <linux/tcp.h>
16 #include <net/sock.h>
17 #include <rdma/iw_cm.h>
18 
19 /* iWarp MPA protocol defs */
20 #define MPA_REVISION_EXT_1 129
21 #define MPA_MAX_PRIVDATA RDMA_MAX_PRIVATE_DATA
22 #define MPA_KEY_REQ "MPA ID Req Frame"
23 #define MPA_KEY_REP "MPA ID Rep Frame"
24 #define MPA_KEY_SIZE 16
25 #define MPA_DEFAULT_HDR_LEN 28
26 
27 struct mpa_rr_params {
28 	__be16 bits;
29 	__be16 pd_len;
30 };
31 
32 /*
33  * MPA request/response Hdr bits & fields
34  */
35 enum {
36 	MPA_RR_FLAG_MARKERS = cpu_to_be16(0x8000),
37 	MPA_RR_FLAG_CRC = cpu_to_be16(0x4000),
38 	MPA_RR_FLAG_REJECT = cpu_to_be16(0x2000),
39 	MPA_RR_RESERVED = cpu_to_be16(0x1f00),
40 	MPA_RR_MASK_REVISION = cpu_to_be16(0x00ff)
41 };
42 
43 /*
44  * MPA request/reply header
45  */
46 struct mpa_rr {
47 	u8 key[16];
48 	struct mpa_rr_params params;
49 };
50 
51 struct erdma_mpa_ext {
52 	__be32 cookie;
53 	__be32 bits;
54 };
55 
56 enum {
57 	MPA_EXT_FLAG_CC = cpu_to_be32(0x0000000f),
58 };
59 
60 struct erdma_mpa_info {
61 	struct mpa_rr hdr; /* peer mpa hdr in host byte order */
62 	struct erdma_mpa_ext ext_data;
63 	char *pdata;
64 	int bytes_rcvd;
65 };
66 
67 struct erdma_sk_upcalls {
68 	void (*sk_state_change)(struct sock *sk);
69 	void (*sk_data_ready)(struct sock *sk, int bytes);
70 	void (*sk_error_report)(struct sock *sk);
71 };
72 
73 struct erdma_dev;
74 
75 enum erdma_cep_state {
76 	ERDMA_EPSTATE_IDLE = 1,
77 	ERDMA_EPSTATE_LISTENING,
78 	ERDMA_EPSTATE_CONNECTING,
79 	ERDMA_EPSTATE_AWAIT_MPAREQ,
80 	ERDMA_EPSTATE_RECVD_MPAREQ,
81 	ERDMA_EPSTATE_AWAIT_MPAREP,
82 	ERDMA_EPSTATE_RDMA_MODE,
83 	ERDMA_EPSTATE_CLOSED
84 };
85 
86 struct erdma_cep {
87 	struct iw_cm_id *cm_id;
88 	struct erdma_dev *dev;
89 	struct list_head devq;
90 	spinlock_t lock;
91 	struct kref ref;
92 	int in_use;
93 	wait_queue_head_t waitq;
94 	enum erdma_cep_state state;
95 
96 	struct list_head listenq;
97 	struct erdma_cep *listen_cep;
98 
99 	struct erdma_qp *qp;
100 	struct socket *sock;
101 
102 	struct erdma_cm_work *mpa_timer;
103 	struct list_head work_freelist;
104 
105 	struct erdma_mpa_info mpa;
106 	int ord;
107 	int ird;
108 
109 	int pd_len;
110 	/* hold user's private data. */
111 	void *private_data;
112 
113 	/* Saved upcalls of socket llp.sock */
114 	void (*sk_state_change)(struct sock *sk);
115 	void (*sk_data_ready)(struct sock *sk);
116 	void (*sk_error_report)(struct sock *sk);
117 };
118 
119 #define MPAREQ_TIMEOUT (HZ * 20)
120 #define MPAREP_TIMEOUT (HZ * 10)
121 #define CONNECT_TIMEOUT (HZ * 10)
122 
123 enum erdma_work_type {
124 	ERDMA_CM_WORK_ACCEPT = 1,
125 	ERDMA_CM_WORK_READ_MPAHDR,
126 	ERDMA_CM_WORK_CLOSE_LLP, /* close socket */
127 	ERDMA_CM_WORK_PEER_CLOSE, /* socket indicated peer close */
128 	ERDMA_CM_WORK_MPATIMEOUT,
129 	ERDMA_CM_WORK_CONNECTED,
130 	ERDMA_CM_WORK_CONNECTTIMEOUT
131 };
132 
133 struct erdma_cm_work {
134 	struct delayed_work work;
135 	struct list_head list;
136 	enum erdma_work_type type;
137 	struct erdma_cep *cep;
138 };
139 
140 #define to_sockaddr_in(a) (*(struct sockaddr_in *)(&(a)))
141 
getname_peer(struct socket * s,struct sockaddr_storage * a)142 static inline int getname_peer(struct socket *s, struct sockaddr_storage *a)
143 {
144 	return s->ops->getname(s, (struct sockaddr *)a, 1);
145 }
146 
getname_local(struct socket * s,struct sockaddr_storage * a)147 static inline int getname_local(struct socket *s, struct sockaddr_storage *a)
148 {
149 	return s->ops->getname(s, (struct sockaddr *)a, 0);
150 }
151 
152 int erdma_connect(struct iw_cm_id *id, struct iw_cm_conn_param *param);
153 int erdma_accept(struct iw_cm_id *id, struct iw_cm_conn_param *param);
154 int erdma_reject(struct iw_cm_id *id, const void *pdata, u8 plen);
155 int erdma_create_listen(struct iw_cm_id *id, int backlog);
156 int erdma_destroy_listen(struct iw_cm_id *id);
157 
158 void erdma_cep_get(struct erdma_cep *ceq);
159 void erdma_cep_put(struct erdma_cep *ceq);
160 int erdma_cm_queue_work(struct erdma_cep *ceq, enum erdma_work_type type);
161 
162 int erdma_cm_init(void);
163 void erdma_cm_exit(void);
164 
165 #define sk_to_cep(sk) ((struct erdma_cep *)((sk)->sk_user_data))
166 
167 #endif
168