drivers/infiniband/hw/erdma/erdma_cm.h

   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