hw/erdma/erdma_cm.h

0001 /* SPDX-License-Identifier: GPL-2.0 OR BSD-3-Clause */
0002
0003 /* Authors: Cheng Xu <chengyou@linux.alibaba.com> */
0004 /*          Kai Shen <kaishen@linux.alibaba.com> */
0005 /* Copyright (c) 2020-2022, Alibaba Group. */
0006
0007 /* Authors: Bernard Metzler <bmt@zurich.ibm.com> */
0008 /*          Greg Joyce <greg@opengridcomputing.com> */
0009 /* Copyright (c) 2008-2019, IBM Corporation */
0010 /* Copyright (c) 2017, Open Grid Computing, Inc. */
0011
0012 #ifndef __ERDMA_CM_H__
0013 #define __ERDMA_CM_H__
0014
0015 #include <linux/tcp.h>
0016 #include <net/sock.h>
0017 #include <rdma/iw_cm.h>
0018
0019 /* iWarp MPA protocol defs */
0020 #define MPA_REVISION_EXT_1 129
0021 #define MPA_MAX_PRIVDATA RDMA_MAX_PRIVATE_DATA
0022 #define MPA_KEY_REQ "MPA ID Req Frame"
0023 #define MPA_KEY_REP "MPA ID Rep Frame"
0024 #define MPA_KEY_SIZE 16
0025 #define MPA_DEFAULT_HDR_LEN 28
0026
0027 struct mpa_rr_params {
0028     __be16 bits;
0029     __be16 pd_len;
0030 };
0031
0032 /*
0033  * MPA request/response Hdr bits & fields
0034  */
0035 enum {
0036     MPA_RR_FLAG_MARKERS = __cpu_to_be16(0x8000),
0037     MPA_RR_FLAG_CRC = __cpu_to_be16(0x4000),
0038     MPA_RR_FLAG_REJECT = __cpu_to_be16(0x2000),
0039     MPA_RR_RESERVED = __cpu_to_be16(0x1f00),
0040     MPA_RR_MASK_REVISION = __cpu_to_be16(0x00ff)
0041 };
0042
0043 /*
0044  * MPA request/reply header
0045  */
0046 struct mpa_rr {
0047     u8 key[16];
0048     struct mpa_rr_params params;
0049 };
0050
0051 struct erdma_mpa_ext {
0052     __be32 cookie;
0053     __be32 bits;
0054 };
0055
0056 enum {
0057     MPA_EXT_FLAG_CC = cpu_to_be32(0x0000000f),
0058 };
0059
0060 struct erdma_mpa_info {
0061     struct mpa_rr hdr; /* peer mpa hdr in host byte order */
0062     struct erdma_mpa_ext ext_data;
0063     char *pdata;
0064     int bytes_rcvd;
0065 };
0066
0067 struct erdma_sk_upcalls {
0068     void (*sk_state_change)(struct sock *sk);
0069     void (*sk_data_ready)(struct sock *sk, int bytes);
0070     void (*sk_error_report)(struct sock *sk);
0071 };
0072
0073 struct erdma_dev;
0074
0075 enum erdma_cep_state {
0076     ERDMA_EPSTATE_IDLE = 1,
0077     ERDMA_EPSTATE_LISTENING,
0078     ERDMA_EPSTATE_CONNECTING,
0079     ERDMA_EPSTATE_AWAIT_MPAREQ,
0080     ERDMA_EPSTATE_RECVD_MPAREQ,
0081     ERDMA_EPSTATE_AWAIT_MPAREP,
0082     ERDMA_EPSTATE_RDMA_MODE,
0083     ERDMA_EPSTATE_CLOSED
0084 };
0085
0086 struct erdma_cep {
0087     struct iw_cm_id *cm_id;
0088     struct erdma_dev *dev;
0089     struct list_head devq;
0090     spinlock_t lock;
0091     struct kref ref;
0092     int in_use;
0093     wait_queue_head_t waitq;
0094     enum erdma_cep_state state;
0095
0096     struct list_head listenq;
0097     struct erdma_cep *listen_cep;
0098
0099     struct erdma_qp *qp;
0100     struct socket *sock;
0101
0102     struct erdma_cm_work *mpa_timer;
0103     struct list_head work_freelist;
0104
0105     struct erdma_mpa_info mpa;
0106     int ord;
0107     int ird;
0108
0109     int pd_len;
0110     /* hold user's private data. */
0111     void *private_data;
0112
0113     /* Saved upcalls of socket llp.sock */
0114     void (*sk_state_change)(struct sock *sk);
0115     void (*sk_data_ready)(struct sock *sk);
0116     void (*sk_error_report)(struct sock *sk);
0117 };
0118
0119 #define MPAREQ_TIMEOUT (HZ * 20)
0120 #define MPAREP_TIMEOUT (HZ * 10)
0121 #define CONNECT_TIMEOUT (HZ * 10)
0122
0123 enum erdma_work_type {
0124     ERDMA_CM_WORK_ACCEPT = 1,
0125     ERDMA_CM_WORK_READ_MPAHDR,
0126     ERDMA_CM_WORK_CLOSE_LLP, /* close socket */
0127     ERDMA_CM_WORK_PEER_CLOSE, /* socket indicated peer close */
0128     ERDMA_CM_WORK_MPATIMEOUT,
0129     ERDMA_CM_WORK_CONNECTED,
0130     ERDMA_CM_WORK_CONNECTTIMEOUT
0131 };
0132
0133 struct erdma_cm_work {
0134     struct delayed_work work;
0135     struct list_head list;
0136     enum erdma_work_type type;
0137     struct erdma_cep *cep;
0138 };
0139
0140 #define to_sockaddr_in(a) (*(struct sockaddr_in *)(&(a)))
0141
0142 static inline int getname_peer(struct socket *s, struct sockaddr_storage *a)
0143 {
0144     return s->ops->getname(s, (struct sockaddr *)a, 1);
0145 }
0146
0147 static inline int getname_local(struct socket *s, struct sockaddr_storage *a)
0148 {
0149     return s->ops->getname(s, (struct sockaddr *)a, 0);
0150 }
0151
0152 int erdma_connect(struct iw_cm_id *id, struct iw_cm_conn_param *param);
0153 int erdma_accept(struct iw_cm_id *id, struct iw_cm_conn_param *param);
0154 int erdma_reject(struct iw_cm_id *id, const void *pdata, u8 plen);
0155 int erdma_create_listen(struct iw_cm_id *id, int backlog);
0156 int erdma_destroy_listen(struct iw_cm_id *id);
0157
0158 void erdma_cep_get(struct erdma_cep *ceq);
0159 void erdma_cep_put(struct erdma_cep *ceq);
0160 int erdma_cm_queue_work(struct erdma_cep *ceq, enum erdma_work_type type);
0161
0162 int erdma_cm_init(void);
0163 void erdma_cm_exit(void);
0164
0165 #define sk_to_cep(sk) ((struct erdma_cep *)((sk)->sk_user_data))
0166
0167 #endif