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
 27struct mpa_rr_params {
 28	__be16 bits;
 29	__be16 pd_len;
 30};
 31
 32/*
 33 * MPA request/response Hdr bits & fields
 34 */
 35enum {
 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 */
 46struct mpa_rr {
 47	u8 key[16];
 48	struct mpa_rr_params params;
 49};
 50
 51struct erdma_mpa_ext {
 52	__be32 cookie;
 53	__be32 bits;
 54};
 55
 56enum {
 57	MPA_EXT_FLAG_CC = cpu_to_be32(0x0000000f),
 58};
 59
 60struct 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
 67struct 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
 73struct erdma_dev;
 74
 75enum 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
 86struct 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
123enum 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
133struct 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
142static inline int getname_peer(struct socket *s, struct sockaddr_storage *a)
143{
144	return s->ops->getname(s, (struct sockaddr *)a, 1);
145}
146
147static inline int getname_local(struct socket *s, struct sockaddr_storage *a)
148{
149	return s->ops->getname(s, (struct sockaddr *)a, 0);
150}
151
152int erdma_connect(struct iw_cm_id *id, struct iw_cm_conn_param *param);
153int erdma_accept(struct iw_cm_id *id, struct iw_cm_conn_param *param);
154int erdma_reject(struct iw_cm_id *id, const void *pdata, u8 plen);
155int erdma_create_listen(struct iw_cm_id *id, int backlog);
156int erdma_destroy_listen(struct iw_cm_id *id);
157
158void erdma_cep_get(struct erdma_cep *ceq);
159void erdma_cep_put(struct erdma_cep *ceq);
160int erdma_cm_queue_work(struct erdma_cep *ceq, enum erdma_work_type type);
161
162int erdma_cm_init(void);
163void erdma_cm_exit(void);
164
165#define sk_to_cep(sk) ((struct erdma_cep *)((sk)->sk_user_data))
166
167#endif