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 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 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