summaryrefslogtreecommitdiff
path: root/usr/src/uts/common/sys/rds.h
blob: bab305c6dfadb6ef885c72bee493da4bd395020c (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
/*
 * Copyright (c) 2010, Oracle and/or its affiliates. All rights reserved.
 */

/*
 * This file contains definitions used in OFED defined user/kernel
 * interfaces. These are imported from the OFED header <linux/rds.h>. Oracle
 * elects to have and use the contents of <linux/rds.h> under and governed
 * by the OpenIB.org BSD license (see below for full license text). However,
 * the following notice accompanied the original version of this file:
 */

/*
 * Copyright (c) 2008 Oracle.  All rights reserved.
 *
 * This software is available to you under a choice of one of two
 * licenses.  You may choose to be licensed under the terms of the GNU
 * General Public License (GPL) Version 2, available from the file
 * COPYING in the main directory of this source tree, or the
 * OpenIB.org BSD license below:
 *
 *     Redistribution and use in source and binary forms, with or
 *     without modification, are permitted provided that the following
 *     conditions are met:
 *
 *      - Redistributions of source code must retain the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer.
 *
 *      - Redistributions in binary form must reproduce the above
 *        copyright notice, this list of conditions and the following
 *        disclaimer in the documentation and/or other materials
 *        provided with the distribution.
 *
 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
 * SOFTWARE.
 *
 */

/*
 * Include this file if the application uses rdsv3 sockets.
 */

/*
 * This file contains definitions from the ofed rds.h and rds_rdma.h
 * header file.
 */
#ifndef _RDSV3_RDS_H
#define	_RDSV3_RDS_H

#include <sys/types.h>
#include <sys/socket.h>

#ifdef __cplusplus
extern "C" {
#endif

#define	RDS_IB_ABI_VERSION		0x301

#define	AF_RDS				AF_INET_OFFLOAD
#define	PF_RDS				AF_INET_OFFLOAD

#define	SOL_RDS				272

/*
 * setsockopt/getsockopt for SOL_RDS
 */
#define	RDSV3_CANCEL_SENT_TO		1
#define	RDSV3_GET_MR			2
#define	RDSV3_FREE_MR			3
/* deprecated: RDS_BARRIER 4 */
#define	RDSV3_RECVERR			5
#define	RDSV3_CONG_MONITOR		6
#define	RDSV3_GET_MR_FOR_DEST		7

/*
 * Control message types for SOL_RDS.
 *
 * RDS_CMSG_RDMA_ARGS (sendmsg)
 *	Request a RDMA transfer to/from the specified
 *	memory ranges.
 *	The cmsg_data is a struct rdsv3_rdma_args.
 * RDS_CMSG_RDMA_DEST (recvmsg, sendmsg)
 *	Kernel informs application about intended
 *	source/destination of a RDMA transfer
 * RDS_CMSG_RDMA_MAP (sendmsg)
 *	Application asks kernel to map the given
 *	memory range into a IB MR, and send the
 *	R_Key along in an RDS extension header.
 *	The cmsg_data is a struct rdsv3_get_mr_args,
 *	the same as for the GET_MR setsockopt.
 * RDS_CMSG_RDMA_STATUS (recvmsg)
 *	Returns the status of a completed RDMA operation.
 */
#define	RDSV3_CMSG_RDMA_ARGS		1
#define	RDSV3_CMSG_RDMA_DEST		2
#define	RDSV3_CMSG_RDMA_MAP		3
#define	RDSV3_CMSG_RDMA_STATUS		4
#define	RDSV3_CMSG_CONG_UPDATE		5

/* rds-info related */

#define	RDSV3_INFO_FIRST		10000
#define	RDSV3_INFO_COUNTERS		10000
#define	RDSV3_INFO_CONNECTIONS		10001
/* 10002 aka RDS_INFO_FLOWS is deprecated */
#define	RDSV3_INFO_SEND_MESSAGES	10003
#define	RDSV3_INFO_RETRANS_MESSAGES	10004
#define	RDSV3_INFO_RECV_MESSAGES	10005
#define	RDSV3_INFO_SOCKETS		10006
#define	RDSV3_INFO_TCP_SOCKETS		10007
#define	RDSV3_INFO_IB_CONNECTIONS	10008
#define	RDSV3_INFO_CONNECTION_STATS	10009
#define	RDSV3_INFO_IWARP_CONNECTIONS	10010
#define	RDSV3_INFO_LAST			10010

struct rds_info_arg {
	uint64_t	lenp;
	uint64_t	datap;
};

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_counter {
	uint8_t	name[32];
	uint64_t	value;
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_counter {
	uint8_t	name[32];
	uint64_t	value;
};
#endif

#define	RDSV3_INFO_CONNECTION_FLAG_SENDING	0x01
#define	RDSV3_INFO_CONNECTION_FLAG_CONNECTING	0x02
#define	RDSV3_INFO_CONNECTION_FLAG_CONNECTED	0x04

#define	TRANSNAMSIZ	16

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_connection {
	uint64_t	next_tx_seq;
	uint64_t	next_rx_seq;
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint8_t		transport[15];		/* null term ascii */
	uint8_t		flags;
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_connection {
	uint64_t	next_tx_seq;
	uint64_t	next_rx_seq;
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint8_t		transport[15];		/* null term ascii */
	uint8_t		flags;
};
#endif

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_flow {
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint32_t	bytes;
	uint16_t	lport;			/* network order */
	uint16_t	fport;			/* network order */
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_flow {
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint32_t	bytes;
	uint16_t	lport;			/* network order */
	uint16_t	fport;			/* network order */
};
#endif

#define	RDSV3_INFO_MESSAGE_FLAG_ACK		0x01
#define	RDSV3_INFO_MESSAGE_FLAG_FAST_ACK	0x02

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_message {
	uint64_t	seq;
	uint32_t	len;
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint16_t	lport;			/* network order */
	uint16_t	fport;			/* network order */
	uint8_t		flags;
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_message {
	uint64_t	seq;
	uint32_t	len;
	uint32_t	laddr;			/* network order */
	uint32_t	faddr;			/* network order */
	uint16_t	lport;			/* network order */
	uint16_t	fport;			/* network order */
	uint8_t		flags;
};
#endif

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_socket {
	uint32_t	sndbuf;
	uint32_t	bound_addr;		/* network order */
	uint32_t	connected_addr;		/* network order */
	uint16_t	bound_port;		/* network order */
	uint16_t	connected_port;		/* network order */
	uint32_t	rcvbuf;
	uint64_t	inum;
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_socket {
	uint32_t	sndbuf;
	uint32_t	bound_addr;		/* network order */
	uint32_t	connected_addr;		/* network order */
	uint16_t	bound_port;		/* network order */
	uint16_t	connected_port;		/* network order */
	uint32_t	rcvbuf;
	uint64_t	inum;
};
#endif

#ifndef __lock_lint
#pragma pack(1)
struct rdsv3_info_socket_v1 {
	uint32_t	sndbuf;
	uint32_t	bound_addr;		/* network order */
	uint32_t	connected_addr;		/* network order */
	uint16_t	bound_port;		/* network order */
	uint16_t	connected_port;		/* network order */
	uint32_t	rcvbuf;
} __attribute__((packed));
#pragma pack()
#else
struct rdsv3_info_socket_v1 {
	uint32_t	sndbuf;
	uint32_t	bound_addr;		/* network order */
	uint32_t	connected_addr;		/* network order */
	uint16_t	bound_port;		/* network order */
	uint16_t	connected_port;		/* network order */
	uint32_t	rcvbuf;
};
#endif

#define	RDS_IB_GID_LEN	16
struct rdsv3_info_rdma_connection {
	uint32_t	src_addr;		/* network order */
	uint32_t	dst_addr;		/* network order */
	uint8_t		src_gid[RDS_IB_GID_LEN];
	uint8_t		dst_gid[RDS_IB_GID_LEN];

	uint32_t	max_send_wr;
	uint32_t	max_recv_wr;
	uint32_t	max_send_sge;
	uint32_t	rdma_mr_max;
	uint32_t	rdma_mr_size;
};

#define	rdsv3_info_ib_connection rdsv3_info_rdma_connection
#define	rdma_fmr_max rdma_mr_max
#define	rdma_fmr_size rdma_mr_size

/*
 * Congestion monitoring.
 * Congestion control in RDS happens at the host connection
 * level by exchanging a bitmap marking congested ports.
 * By default, a process sleeping in poll() is always woken
 * up when the congestion map is updated.
 * With explicit monitoring, an application can have more
 * fine-grained control.
 * The application installs a 64bit mask value in the socket,
 * where each bit corresponds to a group of ports.
 * When a congestion update arrives, RDS checks the set of
 * ports that are now uncongested against the list bit mask
 * installed in the socket, and if they overlap, we queue a
 * cong_notification on the socket.
 *
 * To install the congestion monitor bitmask, use RDS_CONG_MONITOR
 * with the 64bit mask.
 * Congestion updates are received via RDS_CMSG_CONG_UPDATE
 * control messages.
 *
 * The correspondence between bits and ports is
 *	1 << (portnum % 64)
 */
#define	RDSV3_CONG_MONITOR_SIZE	64
#define	RDSV3_CONG_MONITOR_BIT(port)	\
	(((unsigned int) port) % RDSV3_CONG_MONITOR_SIZE)
#define	RDSV3_CONG_MONITOR_MASK(port) (1ULL << RDSV3_CONG_MONITOR_BIT(port))

/*
 * RDMA related types
 */

/*
 * This encapsulates a remote memory location.
 * In the current implementation, it contains the R_Key
 * of the remote memory region, and the offset into it
 * (so that the application does not have to worry about
 * alignment).
 */
typedef uint64_t	rdsv3_rdma_cookie_t;

struct rdsv3_iovec {
	uint64_t	addr;
	uint64_t	bytes;
};

struct rdsv3_get_mr_args {
	struct rdsv3_iovec vec;
	uint64_t	cookie_addr;
	uint64_t	flags;
};

struct rdsv3_get_mr_for_dest_args {
	struct sockaddr_storage	dest_addr;
	struct rdsv3_iovec 	vec;
	uint64_t		cookie_addr;
	uint64_t		flags;
};

struct rdsv3_free_mr_args {
	rdsv3_rdma_cookie_t cookie;
	uint64_t	flags;
};

struct rdsv3_rdma_args {
	rdsv3_rdma_cookie_t cookie;
	struct rdsv3_iovec remote_vec;
	uint64_t	local_vec_addr;
	uint64_t	nr_local;
	uint64_t	flags;
	uint64_t	user_token;
};

struct rdsv3_rdma_notify {
	uint64_t	user_token;
	int32_t		status;
};

#define	RDSV3_RDMA_SUCCESS	0
#define	RDSV3_RDMA_REMOTE_ERROR	1
#define	RDSV3_RDMA_CANCELED	2
#define	RDSV3_RDMA_DROPPED	3
#define	RDSV3_RDMA_OTHER_ERROR	4

/*
 * Common set of flags for all RDMA related structs
 */
#define	RDSV3_RDMA_READWRITE	0x0001
#define	RDSV3_RDMA_FENCE	0x0002	/* use FENCE for immediate send */
#define	RDSV3_RDMA_INVALIDATE	0x0004	/* invalidate R_Key after freeing MR */
#define	RDSV3_RDMA_USE_ONCE	0x0008	/* free MR after use */
#define	RDSV3_RDMA_DONTWAIT	0x0010	/* Don't wait in SET_BARRIER */
#define	RDSV3_RDMA_NOTIFY_ME	0x0020	/* Notify when operation completes */

#ifdef	__cplusplus
}
#endif

#endif /* _RDSV3_RDS_H */