168 lines · c
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 12921#define MPA_MAX_PRIVDATA RDMA_MAX_PRIVATE_DATA22#define MPA_KEY_REQ "MPA ID Req Frame"23#define MPA_KEY_REP "MPA ID Rep Frame"24#define MPA_KEY_SIZE 1625#define MPA_DEFAULT_HDR_LEN 2826 27struct mpa_rr_params {28 __be16 bits;29 __be16 pd_len;30};31 32/*33 * MPA request/response Hdr bits & fields34 */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 header45 */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_CLOSED84};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_CONNECTTIMEOUT131};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#endif168