iscsi_iser.h 21.1 KB
Newer Older
1 2 3 4 5 6 7 8 9 10
/*
 * iSER transport for the Open iSCSI Initiator & iSER transport internals
 *
 * Copyright (C) 2004 Dmitry Yusupov
 * Copyright (C) 2004 Alex Aizman
 * Copyright (C) 2005 Mike Christie
 * based on code maintained by open-iscsi@googlegroups.com
 *
 * Copyright (c) 2004, 2005, 2006 Voltaire, Inc. All rights reserved.
 * Copyright (c) 2005, 2006 Cisco Systems.  All rights reserved.
11
 * Copyright (c) 2013-2014 Mellanox Technologies. All rights reserved.
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
 *
 * 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.
 */
#ifndef __ISCSI_ISER_H__
#define __ISCSI_ISER_H__

#include <linux/types.h>
#include <linux/net.h>
46
#include <linux/printk.h>
47 48
#include <scsi/libiscsi.h>
#include <scsi/scsi_transport_iscsi.h>
49 50
#include <scsi/scsi_cmnd.h>
#include <scsi/scsi_device.h>
51

52
#include <linux/interrupt.h>
53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71
#include <linux/wait.h>
#include <linux/sched.h>
#include <linux/list.h>
#include <linux/slab.h>
#include <linux/dma-mapping.h>
#include <linux/mutex.h>
#include <linux/mempool.h>
#include <linux/uio.h>

#include <linux/socket.h>
#include <linux/in.h>
#include <linux/in6.h>

#include <rdma/ib_verbs.h>
#include <rdma/ib_fmr_pool.h>
#include <rdma/rdma_cm.h>

#define DRV_NAME	"iser"
#define PFX		DRV_NAME ": "
S
Sagi Grimberg 已提交
72
#define DRV_VER		"1.6"
73

74 75
#define iser_dbg(fmt, arg...)				 \
	do {						 \
76
		if (unlikely(iser_debug_level > 2))	 \
77 78
			printk(KERN_DEBUG PFX "%s: " fmt,\
				__func__ , ## arg);	 \
79 80 81
	} while (0)

#define iser_warn(fmt, arg...)				\
82
	do {						\
83
		if (unlikely(iser_debug_level > 0))	\
84
			pr_warn(PFX "%s: " fmt,		\
85 86 87 88
				__func__ , ## arg);	\
	} while (0)

#define iser_info(fmt, arg...)				\
89
	do {						\
90
		if (unlikely(iser_debug_level > 1))	\
91
			pr_info(PFX "%s: " fmt,		\
92 93 94
				__func__ , ## arg);	\
	} while (0)

95 96
#define iser_err(fmt, arg...) \
	pr_err(PFX "%s: " fmt, __func__ , ## arg)
97

98
#define SHIFT_4K	12
99
#define SIZE_4K	(1ULL << SHIFT_4K)
100
#define MASK_4K	(~(SIZE_4K-1))
L
Lucas De Marchi 已提交
101
					/* support up to 512KB in one RDMA */
102
#define ISCSI_ISER_SG_TABLESIZE         (0x80000 >> SHIFT_4K)
103 104 105 106 107 108 109
#define ISER_DEF_XMIT_CMDS_DEFAULT		512
#if ISCSI_DEF_XMIT_CMDS_MAX > ISER_DEF_XMIT_CMDS_DEFAULT
	#define ISER_DEF_XMIT_CMDS_MAX		ISCSI_DEF_XMIT_CMDS_MAX
#else
	#define ISER_DEF_XMIT_CMDS_MAX		ISER_DEF_XMIT_CMDS_DEFAULT
#endif
#define ISER_DEF_CMD_PER_LUN		ISER_DEF_XMIT_CMDS_MAX
110 111 112 113 114 115 116 117

/* QP settings */
/* Maximal bounds on received asynchronous PDUs */
#define ISER_MAX_RX_MISC_PDUS		4 /* NOOP_IN(2) , ASYNC_EVENT(2)   */

#define ISER_MAX_TX_MISC_PDUS		6 /* NOOP_OUT(2), TEXT(1),         *
					   * SCSI_TMFUNC(2), LOGOUT(1) */

118
#define ISER_QP_MAX_RECV_DTOS		(ISER_DEF_XMIT_CMDS_MAX)
119

120
#define ISER_MIN_POSTED_RX		(ISER_DEF_XMIT_CMDS_MAX >> 2)
121 122 123 124 125 126 127 128 129

/* the max TX (send) WR supported by the iSER QP is defined by                 *
 * max_send_wr = T * (1 + D) + C ; D is how many inflight dataouts we expect   *
 * to have at max for SCSI command. The tx posting & completion handling code  *
 * supports -EAGAIN scheme where tx is suspended till the QP has room for more *
 * send WR. D=8 comes from 64K/8K                                              */

#define ISER_INFLIGHT_DATAOUTS		8

130
#define ISER_QP_MAX_REQ_DTOS		(ISER_DEF_XMIT_CMDS_MAX *    \
131 132 133 134
					(1 + ISER_INFLIGHT_DATAOUTS) + \
					ISER_MAX_TX_MISC_PDUS        + \
					ISER_MAX_RX_MISC_PDUS)

135 136 137 138 139 140 141 142 143
/* Max registration work requests per command */
#define ISER_MAX_REG_WR_PER_CMD		5

/* For Signature we don't support DATAOUTs so no need to make room for them */
#define ISER_QP_SIG_MAX_REQ_DTOS	(ISER_DEF_XMIT_CMDS_MAX	*       \
					(1 + ISER_MAX_REG_WR_PER_CMD) + \
					ISER_MAX_TX_MISC_PDUS         + \
					ISER_MAX_RX_MISC_PDUS)

144 145 146 147 148
#define ISER_GET_MAX_XMIT_CMDS(send_wr) ((send_wr			\
					 - ISER_MAX_TX_MISC_PDUS	\
					 - ISER_MAX_RX_MISC_PDUS) /	\
					 (1 + ISER_INFLIGHT_DATAOUTS))

149
#define ISER_WC_BATCH_COUNT   16
150
#define ISER_SIGNAL_CMD_COUNT 32
151

152 153 154 155
#define ISER_VER			0x10
#define ISER_WSV			0x08
#define ISER_RSV			0x04

156
#define ISER_FASTREG_LI_WRID		0xffffffffffffffffULL
157
#define ISER_BEACON_WRID		0xfffffffffffffffeULL
158

159 160 161 162 163 164 165 166 167 168
/**
 * struct iser_hdr - iSER header
 *
 * @flags:        flags support (zbva, remote_inv)
 * @rsvd:         reserved
 * @write_stag:   write rkey
 * @write_va:     write virtual address
 * @reaf_stag:    read rkey
 * @read_va:      read virtual address
 */
169 170 171
struct iser_hdr {
	u8      flags;
	u8      rsvd[3];
172
	__be32  write_stag;
173
	__be64  write_va;
174
	__be32  read_stag;
175 176 177
	__be64  read_va;
} __attribute__((packed));

178 179 180 181 182 183 184 185 186

#define ISER_ZBVA_NOT_SUPPORTED		0x80
#define ISER_SEND_W_INV_NOT_SUPPORTED	0x40

struct iser_cm_hdr {
	u8      flags;
	u8      rsvd[3];
} __packed;

187 188 189 190 191 192
/* Constant PDU lengths calculations */
#define ISER_HEADERS_LEN  (sizeof(struct iser_hdr) + sizeof(struct iscsi_hdr))

#define ISER_RECV_DATA_SEG_LEN	128
#define ISER_RX_PAYLOAD_SIZE	(ISER_HEADERS_LEN + ISER_RECV_DATA_SEG_LEN)
#define ISER_RX_LOGIN_SIZE	(ISER_HEADERS_LEN + ISCSI_DEF_MAX_RECV_SEG_LEN)
193 194 195 196

/* Length of an object name string */
#define ISER_OBJECT_NAME_SIZE		    64

197
enum iser_conn_state {
198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217
	ISER_CONN_INIT,		   /* descriptor allocd, no conn          */
	ISER_CONN_PENDING,	   /* in the process of being established */
	ISER_CONN_UP,		   /* up and running                      */
	ISER_CONN_TERMINATING,	   /* in the process of being terminated  */
	ISER_CONN_DOWN,		   /* shut down                           */
	ISER_CONN_STATES_NUM
};

enum iser_task_status {
	ISER_TASK_STATUS_INIT = 0,
	ISER_TASK_STATUS_STARTED,
	ISER_TASK_STATUS_COMPLETED
};

enum iser_data_dir {
	ISER_DIR_IN = 0,	   /* to initiator */
	ISER_DIR_OUT,		   /* from initiator */
	ISER_DIRS_NUM
};

218 219 220
/**
 * struct iser_data_buf - iSER data buffer
 *
221
 * @sg:           pointer to the sg list
222 223 224
 * @size:         num entries of this sg
 * @data_len:     total beffer byte len
 * @dma_nents:    returned by dma_map_sg
225 226
 * @orig_sg:      pointer to the original sg list (in case
 *                we used a copy)
227
 * @orig_size:    num entris of orig sg list
228
 */
229
struct iser_data_buf {
230
	struct scatterlist *sg;
231 232 233
	unsigned int       size;
	unsigned long      data_len;
	unsigned int       dma_nents;
234
	struct scatterlist *orig_sg;
235
	unsigned int       orig_size;
236 237 238 239
  };

/* fwd declarations */
struct iser_device;
240
struct iscsi_iser_task;
241
struct iscsi_endpoint;
242
struct iser_reg_resources;
243

244 245 246
/**
 * struct iser_mem_reg - iSER memory registration info
 *
247 248
 * @sge:          memory region sg element
 * @rkey:         memory region remote key
249 250
 * @mem_h:        pointer to registration context (FMR/Fastreg)
 */
251
struct iser_mem_reg {
252 253 254
	struct ib_sge	 sge;
	u32		 rkey;
	void		*mem_h;
255 256 257 258 259 260 261 262
};

enum iser_desc_type {
	ISCSI_TX_CONTROL ,
	ISCSI_TX_SCSI_COMMAND,
	ISCSI_TX_DATAOUT
};

263 264 265 266 267 268 269 270 271 272 273
/**
 * struct iser_tx_desc - iSER TX descriptor (for send wr_id)
 *
 * @iser_header:   iser header
 * @iscsi_header:  iscsi header
 * @type:          command/control/dataout
 * @dam_addr:      header buffer dma_address
 * @tx_sg:         sg[0] points to iser/iscsi headers
 *                 sg[1] optionally points to either of immediate data
 *                 unsolicited data-out or control
 * @num_sge:       number sges used on this TX task
274
 * @mapped:        Is the task header mapped
275
 */
276
struct iser_tx_desc {
277 278 279
	struct iser_hdr              iser_header;
	struct iscsi_hdr             iscsi_header;
	enum   iser_desc_type        type;
280 281 282
	u64		             dma_addr;
	struct ib_sge		     tx_sg[2];
	int                          num_sge;
283
	bool			     mapped;
284 285
};

286 287
#define ISER_RX_PAD_SIZE	(256 - (ISER_RX_PAYLOAD_SIZE + \
					sizeof(u64) + sizeof(struct ib_sge)))
288 289 290 291 292 293 294 295 296 297
/**
 * struct iser_rx_desc - iSER RX descriptor (for recv wr_id)
 *
 * @iser_header:   iser header
 * @iscsi_header:  iscsi header
 * @data:          received data segment
 * @dma_addr:      receive buffer dma address
 * @rx_sg:         ib_sge of receive buffer
 * @pad:           for sense data TODO: Modify to maximum sense length supported
 */
298 299 300 301 302 303 304 305 306
struct iser_rx_desc {
	struct iser_hdr              iser_header;
	struct iscsi_hdr             iscsi_header;
	char		             data[ISER_RECV_DATA_SEG_LEN];
	u64		             dma_addr;
	struct ib_sge		     rx_sg;
	char		             pad[ISER_RX_PAD_SIZE];
} __attribute__((packed));

307
struct iser_conn;
S
Sagi Grimberg 已提交
308
struct ib_conn;
309 310
struct iscsi_iser_task;

311 312 313 314
/**
 * struct iser_comp - iSER completion context
 *
 * @device:     pointer to device handle
315
 * @cq:         completion queue
316
 * @wcs:        work completion array
317 318 319 320 321 322
 * @tasklet:    Tasklet handle
 * @active_qps: Number of active QPs attached
 *              to completion context
 */
struct iser_comp {
	struct iser_device      *device;
323
	struct ib_cq		*cq;
324
	struct ib_wc		 wcs[ISER_WC_BATCH_COUNT];
325 326 327 328
	struct tasklet_struct	 tasklet;
	int                      active_qps;
};

S
Sagi Grimberg 已提交
329 330 331 332 333 334
/**
 * struct iser_device - Memory registration operations
 *     per-device registration schemes
 *
 * @alloc_reg_res:     Allocate registration resources
 * @free_reg_res:      Free registration resources
335 336
 * @fast_reg_mem:      Register memory buffers
 * @unreg_mem:         Un-register memory buffers
337 338
 * @reg_desc_get:      Get a registration descriptor for pool
 * @reg_desc_put:      Get a registration descriptor to pool
S
Sagi Grimberg 已提交
339 340 341 342 343
 */
struct iser_reg_ops {
	int            (*alloc_reg_res)(struct ib_conn *ib_conn,
					unsigned cmds_max);
	void           (*free_reg_res)(struct ib_conn *ib_conn);
344 345 346 347 348 349
	int            (*reg_mem)(struct iscsi_iser_task *iser_task,
				  struct iser_data_buf *mem,
				  struct iser_reg_resources *rsc,
				  struct iser_mem_reg *reg);
	void           (*unreg_mem)(struct iscsi_iser_task *iser_task,
				    enum iser_data_dir cmd_dir);
350 351 352
	struct iser_fr_desc * (*reg_desc_get)(struct ib_conn *ib_conn);
	void           (*reg_desc_put)(struct ib_conn *ib_conn,
				       struct iser_fr_desc *desc);
S
Sagi Grimberg 已提交
353 354
};

355 356 357 358 359 360 361 362 363 364 365 366 367
/**
 * struct iser_device - iSER device handle
 *
 * @ib_device:     RDMA device
 * @pd:            Protection Domain for this device
 * @dev_attr:      Device attributes container
 * @mr:            Global DMA memory region
 * @event_handler: IB events handle routine
 * @ig_list:	   entry in devices list
 * @refcount:      Reference counter, dominated by open iser connections
 * @comps_used:    Number of completion contexts used, Min between online
 *                 cpus and device max completion vectors
 * @comps:         Dinamically allocated array of completion handlers
S
Sagi Grimberg 已提交
368
 * @reg_ops:       Registration ops
369
 */
370 371 372
struct iser_device {
	struct ib_device             *ib_device;
	struct ib_pd	             *pd;
373
	struct ib_device_attr	     dev_attr;
374
	struct ib_mr	             *mr;
375
	struct ib_event_handler      event_handler;
376
	struct list_head             ig_list;
377
	int                          refcount;
378
	int			     comps_used;
379
	struct iser_comp	     *comps;
S
Sagi Grimberg 已提交
380
	struct iser_reg_ops          *reg_ops;
381 382
};

383 384 385 386
#define ISER_CHECK_GUARD	0xc0
#define ISER_CHECK_REFTAG	0x0f
#define ISER_CHECK_APPTAG	0x30

387 388 389 390
/**
 * struct iser_reg_resources - Fast registration recources
 *
 * @mr:         memory region
391 392 393
 * @fmr_pool:   pool of fmrs
 * @frpl:       fast reg page list used by frwrs
 * @page_vec:   fast reg page list used by fmr pool
394 395 396
 * @mr_valid:   is mr valid indicator
 */
struct iser_reg_resources {
397 398 399 400 401 402 403 404
	union {
		struct ib_mr             *mr;
		struct ib_fmr_pool       *fmr_pool;
	};
	union {
		struct ib_fast_reg_page_list     *frpl;
		struct iser_page_vec             *page_vec;
	};
405
	u8				  mr_valid:1;
406 407
};

408 409 410
/**
 * struct iser_pi_context - Protection information context
 *
411 412 413 414
 * @rsc:             protection buffer registration resources
 * @sig_mr:          signature enable memory region
 * @sig_mr_valid:    is sig_mr valid indicator
 * @sig_protected:   is region protected indicator
415
 */
416
struct iser_pi_context {
417
	struct iser_reg_resources	rsc;
418
	struct ib_mr                   *sig_mr;
419 420
	u8                              sig_mr_valid:1;
	u8                              sig_protected:1;
421 422
};

423
/**
424
 * struct iser_fr_desc - Fast registration descriptor
425 426
 *
 * @list:           entry in connection fastreg pool
427
 * @rsc:            data buffer registration resources
428 429
 * @pi_ctx:         protection information context
 */
430
struct iser_fr_desc {
431
	struct list_head		  list;
432
	struct iser_reg_resources	  rsc;
433
	struct iser_pi_context		 *pi_ctx;
434 435
};

436 437 438
/**
 * struct iser_fr_pool: connection fast registration pool
 *
439
 * @list:                list of fastreg descriptors
440
 * @lock:                protects fmr/fastreg pool
441
 * @size:                size of the pool
442 443
 */
struct iser_fr_pool {
444 445 446
	struct list_head        list;
	spinlock_t              lock;
	int                     size;
447 448
};

S
Sagi Grimberg 已提交
449 450 451 452 453 454
/**
 * struct ib_conn - Infiniband related objects
 *
 * @cma_id:              rdma_cm connection maneger handle
 * @qp:                  Connection Queue-pair
 * @post_recv_buf_count: post receive counter
M
Max Gurtovoy 已提交
455
 * @sig_count:           send work request signal count
S
Sagi Grimberg 已提交
456 457
 * @rx_wr:               receive work request for batch posts
 * @device:              reference to iser device
458
 * @comp:                iser completion context
S
Sagi Grimberg 已提交
459
 * @pi_support:          Indicate device T10-PI support
460
 * @beacon:              beacon send wr to signal all flush errors were drained
461
 * @flush_comp:          completes when all connection completions consumed
462
 * @fr_pool:             connection fast registration poool
S
Sagi Grimberg 已提交
463 464 465 466 467
 */
struct ib_conn {
	struct rdma_cm_id           *cma_id;
	struct ib_qp	            *qp;
	int                          post_recv_buf_count;
M
Max Gurtovoy 已提交
468
	u8                           sig_count;
S
Sagi Grimberg 已提交
469 470
	struct ib_recv_wr	     rx_wr[ISER_MIN_POSTED_RX];
	struct iser_device          *device;
471
	struct iser_comp	    *comp;
S
Sagi Grimberg 已提交
472
	bool			     pi_support;
473
	struct ib_send_wr	     beacon;
474
	struct completion	     flush_comp;
475
	struct iser_fr_pool          fr_pool;
S
Sagi Grimberg 已提交
476 477
};

478 479 480 481 482 483 484 485 486 487 488
/**
 * struct iser_conn - iSER connection context
 *
 * @ib_conn:          connection RDMA resources
 * @iscsi_conn:       link to matching iscsi connection
 * @ep:               transport handle
 * @state:            connection logical state
 * @qp_max_recv_dtos: maximum number of data outs, corresponds
 *                    to max number of post recvs
 * @qp_max_recv_dtos_mask: (qp_max_recv_dtos - 1)
 * @min_posted_rx:    (qp_max_recv_dtos >> 2)
489
 * @max_cmds:         maximum cmds allowed for this connection
490 491 492 493 494 495 496 497 498 499 500 501 502 503 504 505 506
 * @name:             connection peer portal
 * @release_work:     deffered work for release job
 * @state_mutex:      protects iser onnection state
 * @stop_completion:  conn_stop completion
 * @ib_completion:    RDMA cleanup completion
 * @up_completion:    connection establishment completed
 *                    (state is ISER_CONN_UP)
 * @conn_list:        entry in ig conn list
 * @login_buf:        login data buffer (stores login parameters)
 * @login_req_buf:    login request buffer
 * @login_req_dma:    login request buffer dma address
 * @login_resp_buf:   login response buffer
 * @login_resp_dma:   login response buffer dma address
 * @rx_desc_head:     head of rx_descs cyclic buffer
 * @rx_descs:         rx buffers array (cyclic buffer)
 * @num_rx_descs:     number of rx descriptors
 */
507
struct iser_conn {
S
Sagi Grimberg 已提交
508
	struct ib_conn		     ib_conn;
509
	struct iscsi_conn	     *iscsi_conn;
510
	struct iscsi_endpoint	     *ep;
511 512 513 514
	enum iser_conn_state	     state;
	unsigned		     qp_max_recv_dtos;
	unsigned		     qp_max_recv_dtos_mask;
	unsigned		     min_posted_rx;
515
	u16                          max_cmds;
516
	char 			     name[ISER_OBJECT_NAME_SIZE];
517
	struct work_struct	     release_work;
518
	struct mutex		     state_mutex;
519 520
	struct completion	     stop_completion;
	struct completion	     ib_completion;
521
	struct completion	     up_completion;
522
	struct list_head	     conn_list;
523 524

	char  			     *login_buf;
525 526
	char			     *login_req_buf, *login_resp_buf;
	u64			     login_req_dma, login_resp_dma;
527 528
	unsigned int 		     rx_desc_head;
	struct iser_rx_desc	     *rx_descs;
529
	u32                          num_rx_descs;
530 531
};

532 533 534 535 536 537 538 539 540
/**
 * struct iscsi_iser_task - iser task context
 *
 * @desc:     TX descriptor
 * @iser_conn:        link to iser connection
 * @status:           current task status
 * @sc:               link to scsi command
 * @command_sent:     indicate if command was sent
 * @dir:              iser data direction
541
 * @rdma_reg:         task rdma registration desc
542 543 544
 * @data:             iser data buffer desc
 * @prot:             iser protection buffer desc
 */
545
struct iscsi_iser_task {
546
	struct iser_tx_desc          desc;
547
	struct iser_conn	     *iser_conn;
548
	enum iser_task_status 	     status;
549
	struct scsi_cmnd	     *sc;
550 551
	int                          command_sent;
	int                          dir[ISER_DIRS_NUM];
552
	struct iser_mem_reg          rdma_reg[ISER_DIRS_NUM];
553 554
	struct iser_data_buf         data[ISER_DIRS_NUM];
	struct iser_data_buf         prot[ISER_DIRS_NUM];
555 556 557 558 559 560 561 562 563
};

struct iser_page_vec {
	u64 *pages;
	int length;
	int offset;
	int data_size;
};

564 565 566 567 568 569 570 571 572
/**
 * struct iser_global: iSER global context
 *
 * @device_list_mutex:    protects device_list
 * @device_list:          iser devices global list
 * @connlist_mutex:       protects connlist
 * @connlist:             iser connections global list
 * @desc_cache:           kmem cache for tx dataout
 */
573
struct iser_global {
574 575
	struct mutex      device_list_mutex;
	struct list_head  device_list;
576
	struct mutex      connlist_mutex;
577
	struct list_head  connlist;
578
	struct kmem_cache *desc_cache;
579 580 581 582
};

extern struct iser_global ig;
extern int iser_debug_level;
583 584
extern bool iser_pi_enable;
extern int iser_pi_guard;
585

S
Sagi Grimberg 已提交
586 587
int iser_assign_reg_ops(struct iser_device *device);

588
int iser_send_control(struct iscsi_conn *conn,
589
		      struct iscsi_task *task);
590

591
int iser_send_command(struct iscsi_conn *conn,
592
		      struct iscsi_task *task);
593

594
int iser_send_data_out(struct iscsi_conn *conn,
595
		       struct iscsi_task *task,
596
		       struct iscsi_data *hdr);
597 598

void iscsi_iser_recv(struct iscsi_conn *conn,
599 600 601
		     struct iscsi_hdr *hdr,
		     char *rx_data,
		     int rx_data_len);
602

603
void iser_conn_init(struct iser_conn *iser_conn);
604

605
void iser_conn_release(struct iser_conn *iser_conn);
606

607
int iser_conn_terminate(struct iser_conn *iser_conn);
608

609 610
void iser_release_work(struct work_struct *work);

611
void iser_rcv_completion(struct iser_rx_desc *desc,
612
			 unsigned long dto_xfer_len,
S
Sagi Grimberg 已提交
613
			 struct ib_conn *ib_conn);
614

615
void iser_snd_completion(struct iser_tx_desc *desc,
S
Sagi Grimberg 已提交
616
			 struct ib_conn *ib_conn);
617

618
void iser_task_rdma_init(struct iscsi_iser_task *task);
619

620
void iser_task_rdma_finalize(struct iscsi_iser_task *task);
621

622
void iser_free_rx_descriptors(struct iser_conn *iser_conn);
623

624 625 626
void iser_finalize_rdma_unaligned_sg(struct iscsi_iser_task *iser_task,
				     struct iser_data_buf *mem,
				     enum iser_data_dir cmd_dir);
627

628 629 630 631
int iser_reg_rdma_mem(struct iscsi_iser_task *task,
		      enum iser_data_dir dir);
void iser_unreg_rdma_mem(struct iscsi_iser_task *task,
			 enum iser_data_dir dir);
632

633 634 635 636
int  iser_connect(struct iser_conn *iser_conn,
		  struct sockaddr *src_addr,
		  struct sockaddr *dst_addr,
		  int non_blocking);
637

638 639
void iser_unreg_mem_fmr(struct iscsi_iser_task *iser_task,
			enum iser_data_dir cmd_dir);
640 641
void iser_unreg_mem_fastreg(struct iscsi_iser_task *iser_task,
			    enum iser_data_dir cmd_dir);
642

643 644
int  iser_post_recvl(struct iser_conn *iser_conn);
int  iser_post_recvm(struct iser_conn *iser_conn, int count);
645 646
int  iser_post_send(struct ib_conn *ib_conn, struct iser_tx_desc *tx_desc,
		    bool signal);
647

648
int iser_dma_map_task_data(struct iscsi_iser_task *iser_task,
649 650 651
			   struct iser_data_buf *data,
			   enum iser_data_dir iser_dir,
			   enum dma_data_direction dma_dir);
652

653
void iser_dma_unmap_task_data(struct iscsi_iser_task *iser_task,
654 655 656
			      struct iser_data_buf *data,
			      enum dma_data_direction dir);

657 658
int  iser_initialize_task_headers(struct iscsi_task *task,
			struct iser_tx_desc *tx_desc);
659 660
int iser_alloc_rx_descriptors(struct iser_conn *iser_conn,
			      struct iscsi_session *session);
S
Sagi Grimberg 已提交
661
int iser_alloc_fmr_pool(struct ib_conn *ib_conn, unsigned cmds_max);
S
Sagi Grimberg 已提交
662
void iser_free_fmr_pool(struct ib_conn *ib_conn);
S
Sagi Grimberg 已提交
663
int iser_alloc_fastreg_pool(struct ib_conn *ib_conn, unsigned cmds_max);
S
Sagi Grimberg 已提交
664
void iser_free_fastreg_pool(struct ib_conn *ib_conn);
665 666
u8 iser_check_task_pi_status(struct iscsi_iser_task *iser_task,
			     enum iser_data_dir cmd_dir, sector_t *sector);
667
struct iser_fr_desc *
668
iser_reg_desc_get_fr(struct ib_conn *ib_conn);
669
void
670 671 672 673 674 675 676
iser_reg_desc_put_fr(struct ib_conn *ib_conn,
		     struct iser_fr_desc *desc);
struct iser_fr_desc *
iser_reg_desc_get_fmr(struct ib_conn *ib_conn);
void
iser_reg_desc_put_fmr(struct ib_conn *ib_conn,
		      struct iser_fr_desc *desc);
677
#endif