1 /* QLogic qed NIC Driver
2  * Copyright (c) 2015-2017  QLogic Corporation
3  *
4  * This software is available to you under a choice of one of two
5  * licenses.  You may choose to be licensed under the terms of the GNU
6  * General Public License (GPL) Version 2, available from the file
7  * COPYING in the main directory of this source tree, or the
8  * OpenIB.org BSD license below:
9  *
10  *     Redistribution and use in source and binary forms, with or
11  *     without modification, are permitted provided that the following
12  *     conditions are met:
13  *
14  *      - Redistributions of source code must retain the above
15  *        copyright notice, this list of conditions and the following
16  *        disclaimer.
17  *
18  *      - Redistributions in binary form must reproduce the above
19  *        copyright notice, this list of conditions and the following
20  *        disclaimer in the documentation and /or other materials
21  *        provided with the distribution.
22  *
23  * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
24  * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
25  * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
26  * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
27  * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
28  * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
29  * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
30  * SOFTWARE.
31  */
32 
33 #include <linux/types.h>
34 #include <asm/byteorder.h>
35 #include <asm/param.h>
36 #include <linux/delay.h>
37 #include <linux/dma-mapping.h>
38 #include <linux/etherdevice.h>
39 #include <linux/interrupt.h>
40 #include <linux/kernel.h>
41 #include <linux/log2.h>
42 #include <linux/module.h>
43 #include <linux/pci.h>
44 #include <linux/slab.h>
45 #include <linux/stddef.h>
46 #include <linux/string.h>
47 #include <linux/workqueue.h>
48 #include <linux/errno.h>
49 #include <linux/list.h>
50 #include <linux/spinlock.h>
51 #include <linux/qed/qed_iscsi_if.h>
52 #include "qed.h"
53 #include "qed_cxt.h"
54 #include "qed_dev_api.h"
55 #include "qed_hsi.h"
56 #include "qed_hw.h"
57 #include "qed_int.h"
58 #include "qed_iscsi.h"
59 #include "qed_ll2.h"
60 #include "qed_mcp.h"
61 #include "qed_sp.h"
62 #include "qed_sriov.h"
63 #include "qed_reg_addr.h"
64 
65 struct qed_iscsi_conn {
66 	struct list_head list_entry;
67 	bool free_on_delete;
68 
69 	u16 conn_id;
70 	u32 icid;
71 	u32 fw_cid;
72 
73 	u8 layer_code;
74 	u8 offl_flags;
75 	u8 connect_mode;
76 	u32 initial_ack;
77 	dma_addr_t sq_pbl_addr;
78 	struct qed_chain r2tq;
79 	struct qed_chain xhq;
80 	struct qed_chain uhq;
81 
82 	struct tcp_upload_params *tcp_upload_params_virt_addr;
83 	dma_addr_t tcp_upload_params_phys_addr;
84 	struct scsi_terminate_extra_params *queue_cnts_virt_addr;
85 	dma_addr_t queue_cnts_phys_addr;
86 	dma_addr_t syn_phy_addr;
87 
88 	u16 syn_ip_payload_length;
89 	u8 local_mac[6];
90 	u8 remote_mac[6];
91 	u16 vlan_id;
92 	u8 tcp_flags;
93 	u8 ip_version;
94 	u32 remote_ip[4];
95 	u32 local_ip[4];
96 	u8 ka_max_probe_cnt;
97 	u8 dup_ack_theshold;
98 	u32 rcv_next;
99 	u32 snd_una;
100 	u32 snd_next;
101 	u32 snd_max;
102 	u32 snd_wnd;
103 	u32 rcv_wnd;
104 	u32 snd_wl1;
105 	u32 cwnd;
106 	u32 ss_thresh;
107 	u16 srtt;
108 	u16 rtt_var;
109 	u32 ts_time;
110 	u32 ts_recent;
111 	u32 ts_recent_age;
112 	u32 total_rt;
113 	u32 ka_timeout_delta;
114 	u32 rt_timeout_delta;
115 	u8 dup_ack_cnt;
116 	u8 snd_wnd_probe_cnt;
117 	u8 ka_probe_cnt;
118 	u8 rt_cnt;
119 	u32 flow_label;
120 	u32 ka_timeout;
121 	u32 ka_interval;
122 	u32 max_rt_time;
123 	u32 initial_rcv_wnd;
124 	u8 ttl;
125 	u8 tos_or_tc;
126 	u16 remote_port;
127 	u16 local_port;
128 	u16 mss;
129 	u8 snd_wnd_scale;
130 	u8 rcv_wnd_scale;
131 	u32 ts_ticks_per_second;
132 	u16 da_timeout_value;
133 	u8 ack_frequency;
134 
135 	u8 update_flag;
136 	u8 default_cq;
137 	u32 max_seq_size;
138 	u32 max_recv_pdu_length;
139 	u32 max_send_pdu_length;
140 	u32 first_seq_length;
141 	u32 exp_stat_sn;
142 	u32 stat_sn;
143 	u16 physical_q0;
144 	u16 physical_q1;
145 	u8 abortive_dsconnect;
146 };
147 
148 static int
149 qed_sp_iscsi_func_start(struct qed_hwfn *p_hwfn,
150 			enum spq_mode comp_mode,
151 			struct qed_spq_comp_cb *p_comp_addr,
152 			void *event_context, iscsi_event_cb_t async_event_cb)
153 {
154 	struct iscsi_init_ramrod_params *p_ramrod = NULL;
155 	struct scsi_init_func_queues *p_queue = NULL;
156 	struct qed_iscsi_pf_params *p_params = NULL;
157 	struct iscsi_spe_func_init *p_init = NULL;
158 	struct qed_spq_entry *p_ent = NULL;
159 	struct qed_sp_init_data init_data;
160 	int rc = 0;
161 	u32 dval;
162 	u16 val;
163 	u8 i;
164 
165 	/* Get SPQ entry */
166 	memset(&init_data, 0, sizeof(init_data));
167 	init_data.cid = qed_spq_get_cid(p_hwfn);
168 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
169 	init_data.comp_mode = comp_mode;
170 	init_data.p_comp_data = p_comp_addr;
171 
172 	rc = qed_sp_init_request(p_hwfn, &p_ent,
173 				 ISCSI_RAMROD_CMD_ID_INIT_FUNC,
174 				 PROTOCOLID_ISCSI, &init_data);
175 	if (rc)
176 		return rc;
177 
178 	p_ramrod = &p_ent->ramrod.iscsi_init;
179 	p_init = &p_ramrod->iscsi_init_spe;
180 	p_params = &p_hwfn->pf_params.iscsi_pf_params;
181 	p_queue = &p_init->q_params;
182 
183 	/* Sanity */
184 	if (p_params->num_queues > p_hwfn->hw_info.feat_num[QED_ISCSI_CQ]) {
185 		DP_ERR(p_hwfn,
186 		       "Cannot satisfy CQ amount. Queues requested %d, CQs available %d. Aborting function start\n",
187 		       p_params->num_queues,
188 		       p_hwfn->hw_info.resc_num[QED_ISCSI_CQ]);
189 		return -EINVAL;
190 	}
191 
192 	SET_FIELD(p_init->hdr.flags,
193 		  ISCSI_SLOW_PATH_HDR_LAYER_CODE, ISCSI_SLOW_PATH_LAYER_CODE);
194 	p_init->hdr.op_code = ISCSI_RAMROD_CMD_ID_INIT_FUNC;
195 
196 	val = p_params->half_way_close_timeout;
197 	p_init->half_way_close_timeout = cpu_to_le16(val);
198 	p_init->num_sq_pages_in_ring = p_params->num_sq_pages_in_ring;
199 	p_init->num_r2tq_pages_in_ring = p_params->num_r2tq_pages_in_ring;
200 	p_init->num_uhq_pages_in_ring = p_params->num_uhq_pages_in_ring;
201 	p_init->ooo_enable = p_params->ooo_enable;
202 	p_init->ll2_rx_queue_id = p_hwfn->hw_info.resc_start[QED_LL2_QUEUE] +
203 				  p_params->ll2_ooo_queue_id;
204 	p_init->func_params.log_page_size = p_params->log_page_size;
205 	val = p_params->num_tasks;
206 	p_init->func_params.num_tasks = cpu_to_le16(val);
207 	p_init->debug_mode.flags = p_params->debug_mode;
208 
209 	DMA_REGPAIR_LE(p_queue->glbl_q_params_addr,
210 		       p_params->glbl_q_params_addr);
211 
212 	val = p_params->cq_num_entries;
213 	p_queue->cq_num_entries = cpu_to_le16(val);
214 	val = p_params->cmdq_num_entries;
215 	p_queue->cmdq_num_entries = cpu_to_le16(val);
216 	p_queue->num_queues = p_params->num_queues;
217 	dval = (u8)p_hwfn->hw_info.resc_start[QED_CMDQS_CQS];
218 	p_queue->queue_relative_offset = (u8)dval;
219 	p_queue->cq_sb_pi = p_params->gl_rq_pi;
220 	p_queue->cmdq_sb_pi = p_params->gl_cmd_pi;
221 
222 	for (i = 0; i < p_params->num_queues; i++) {
223 		val = p_hwfn->sbs_info[i]->igu_sb_id;
224 		p_queue->cq_cmdq_sb_num_arr[i] = cpu_to_le16(val);
225 	}
226 
227 	p_queue->bdq_resource_id = (u8)RESC_START(p_hwfn, QED_BDQ);
228 
229 	DMA_REGPAIR_LE(p_queue->bdq_pbl_base_address[BDQ_ID_RQ],
230 		       p_params->bdq_pbl_base_addr[BDQ_ID_RQ]);
231 	p_queue->bdq_pbl_num_entries[BDQ_ID_RQ] =
232 	    p_params->bdq_pbl_num_entries[BDQ_ID_RQ];
233 	val = p_params->bdq_xoff_threshold[BDQ_ID_RQ];
234 	p_queue->bdq_xoff_threshold[BDQ_ID_RQ] = cpu_to_le16(val);
235 	val = p_params->bdq_xon_threshold[BDQ_ID_RQ];
236 	p_queue->bdq_xon_threshold[BDQ_ID_RQ] = cpu_to_le16(val);
237 
238 	DMA_REGPAIR_LE(p_queue->bdq_pbl_base_address[BDQ_ID_IMM_DATA],
239 		       p_params->bdq_pbl_base_addr[BDQ_ID_IMM_DATA]);
240 	p_queue->bdq_pbl_num_entries[BDQ_ID_IMM_DATA] =
241 	    p_params->bdq_pbl_num_entries[BDQ_ID_IMM_DATA];
242 	val = p_params->bdq_xoff_threshold[BDQ_ID_IMM_DATA];
243 	p_queue->bdq_xoff_threshold[BDQ_ID_IMM_DATA] = cpu_to_le16(val);
244 	val = p_params->bdq_xon_threshold[BDQ_ID_IMM_DATA];
245 	p_queue->bdq_xon_threshold[BDQ_ID_IMM_DATA] = cpu_to_le16(val);
246 	val = p_params->rq_buffer_size;
247 	p_queue->rq_buffer_size = cpu_to_le16(val);
248 	if (p_params->is_target) {
249 		SET_FIELD(p_queue->q_validity,
250 			  SCSI_INIT_FUNC_QUEUES_RQ_VALID, 1);
251 		if (p_queue->bdq_pbl_num_entries[BDQ_ID_IMM_DATA])
252 			SET_FIELD(p_queue->q_validity,
253 				  SCSI_INIT_FUNC_QUEUES_IMM_DATA_VALID, 1);
254 		SET_FIELD(p_queue->q_validity,
255 			  SCSI_INIT_FUNC_QUEUES_CMD_VALID, 1);
256 	} else {
257 		SET_FIELD(p_queue->q_validity,
258 			  SCSI_INIT_FUNC_QUEUES_RQ_VALID, 1);
259 	}
260 	p_ramrod->tcp_init.two_msl_timer = cpu_to_le32(p_params->two_msl_timer);
261 	val = p_params->tx_sws_timer;
262 	p_ramrod->tcp_init.tx_sws_timer = cpu_to_le16(val);
263 	p_ramrod->tcp_init.maxfinrt = p_params->max_fin_rt;
264 
265 	p_hwfn->p_iscsi_info->event_context = event_context;
266 	p_hwfn->p_iscsi_info->event_cb = async_event_cb;
267 
268 	return qed_spq_post(p_hwfn, p_ent, NULL);
269 }
270 
271 static int qed_sp_iscsi_conn_offload(struct qed_hwfn *p_hwfn,
272 				     struct qed_iscsi_conn *p_conn,
273 				     enum spq_mode comp_mode,
274 				     struct qed_spq_comp_cb *p_comp_addr)
275 {
276 	struct iscsi_spe_conn_offload *p_ramrod = NULL;
277 	struct tcp_offload_params_opt2 *p_tcp2 = NULL;
278 	struct tcp_offload_params *p_tcp = NULL;
279 	struct qed_spq_entry *p_ent = NULL;
280 	struct qed_sp_init_data init_data;
281 	dma_addr_t r2tq_pbl_addr;
282 	dma_addr_t xhq_pbl_addr;
283 	dma_addr_t uhq_pbl_addr;
284 	u16 physical_q;
285 	int rc = 0;
286 	u32 dval;
287 	u16 wval;
288 	u8 i;
289 	u16 *p;
290 
291 	/* Get SPQ entry */
292 	memset(&init_data, 0, sizeof(init_data));
293 	init_data.cid = p_conn->icid;
294 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
295 	init_data.comp_mode = comp_mode;
296 	init_data.p_comp_data = p_comp_addr;
297 
298 	rc = qed_sp_init_request(p_hwfn, &p_ent,
299 				 ISCSI_RAMROD_CMD_ID_OFFLOAD_CONN,
300 				 PROTOCOLID_ISCSI, &init_data);
301 	if (rc)
302 		return rc;
303 
304 	p_ramrod = &p_ent->ramrod.iscsi_conn_offload;
305 
306 	/* Transmission PQ is the first of the PF */
307 	physical_q = qed_get_cm_pq_idx(p_hwfn, PQ_FLAGS_OFLD);
308 	p_conn->physical_q0 = cpu_to_le16(physical_q);
309 	p_ramrod->iscsi.physical_q0 = cpu_to_le16(physical_q);
310 
311 	/* iSCSI Pure-ACK PQ */
312 	physical_q = qed_get_cm_pq_idx(p_hwfn, PQ_FLAGS_ACK);
313 	p_conn->physical_q1 = cpu_to_le16(physical_q);
314 	p_ramrod->iscsi.physical_q1 = cpu_to_le16(physical_q);
315 
316 	p_ramrod->hdr.op_code = ISCSI_RAMROD_CMD_ID_OFFLOAD_CONN;
317 	SET_FIELD(p_ramrod->hdr.flags, ISCSI_SLOW_PATH_HDR_LAYER_CODE,
318 		  p_conn->layer_code);
319 
320 	p_ramrod->conn_id = cpu_to_le16(p_conn->conn_id);
321 	p_ramrod->fw_cid = cpu_to_le32(p_conn->icid);
322 
323 	DMA_REGPAIR_LE(p_ramrod->iscsi.sq_pbl_addr, p_conn->sq_pbl_addr);
324 
325 	r2tq_pbl_addr = qed_chain_get_pbl_phys(&p_conn->r2tq);
326 	DMA_REGPAIR_LE(p_ramrod->iscsi.r2tq_pbl_addr, r2tq_pbl_addr);
327 
328 	xhq_pbl_addr = qed_chain_get_pbl_phys(&p_conn->xhq);
329 	DMA_REGPAIR_LE(p_ramrod->iscsi.xhq_pbl_addr, xhq_pbl_addr);
330 
331 	uhq_pbl_addr = qed_chain_get_pbl_phys(&p_conn->uhq);
332 	DMA_REGPAIR_LE(p_ramrod->iscsi.uhq_pbl_addr, uhq_pbl_addr);
333 
334 	p_ramrod->iscsi.initial_ack = cpu_to_le32(p_conn->initial_ack);
335 	p_ramrod->iscsi.flags = p_conn->offl_flags;
336 	p_ramrod->iscsi.default_cq = p_conn->default_cq;
337 	p_ramrod->iscsi.stat_sn = cpu_to_le32(p_conn->stat_sn);
338 
339 	if (!GET_FIELD(p_ramrod->iscsi.flags,
340 		       ISCSI_CONN_OFFLOAD_PARAMS_TCP_ON_CHIP_1B)) {
341 		p_tcp = &p_ramrod->tcp;
342 
343 		p = (u16 *)p_conn->local_mac;
344 		p_tcp->local_mac_addr_hi = swab16(get_unaligned(p));
345 		p_tcp->local_mac_addr_mid = swab16(get_unaligned(p + 1));
346 		p_tcp->local_mac_addr_lo = swab16(get_unaligned(p + 2));
347 
348 		p = (u16 *)p_conn->remote_mac;
349 		p_tcp->remote_mac_addr_hi = swab16(get_unaligned(p));
350 		p_tcp->remote_mac_addr_mid = swab16(get_unaligned(p + 1));
351 		p_tcp->remote_mac_addr_lo = swab16(get_unaligned(p + 2));
352 
353 		p_tcp->vlan_id = cpu_to_le16(p_conn->vlan_id);
354 
355 		p_tcp->flags = p_conn->tcp_flags;
356 		p_tcp->ip_version = p_conn->ip_version;
357 		for (i = 0; i < 4; i++) {
358 			dval = p_conn->remote_ip[i];
359 			p_tcp->remote_ip[i] = cpu_to_le32(dval);
360 			dval = p_conn->local_ip[i];
361 			p_tcp->local_ip[i] = cpu_to_le32(dval);
362 		}
363 		p_tcp->ka_max_probe_cnt = p_conn->ka_max_probe_cnt;
364 		p_tcp->dup_ack_theshold = p_conn->dup_ack_theshold;
365 
366 		p_tcp->rcv_next = cpu_to_le32(p_conn->rcv_next);
367 		p_tcp->snd_una = cpu_to_le32(p_conn->snd_una);
368 		p_tcp->snd_next = cpu_to_le32(p_conn->snd_next);
369 		p_tcp->snd_max = cpu_to_le32(p_conn->snd_max);
370 		p_tcp->snd_wnd = cpu_to_le32(p_conn->snd_wnd);
371 		p_tcp->rcv_wnd = cpu_to_le32(p_conn->rcv_wnd);
372 		p_tcp->snd_wl1 = cpu_to_le32(p_conn->snd_wl1);
373 		p_tcp->cwnd = cpu_to_le32(p_conn->cwnd);
374 		p_tcp->ss_thresh = cpu_to_le32(p_conn->ss_thresh);
375 		p_tcp->srtt = cpu_to_le16(p_conn->srtt);
376 		p_tcp->rtt_var = cpu_to_le16(p_conn->rtt_var);
377 		p_tcp->ts_recent = cpu_to_le32(p_conn->ts_recent);
378 		p_tcp->ts_recent_age = cpu_to_le32(p_conn->ts_recent_age);
379 		p_tcp->total_rt = cpu_to_le32(p_conn->total_rt);
380 		dval = p_conn->ka_timeout_delta;
381 		p_tcp->ka_timeout_delta = cpu_to_le32(dval);
382 		dval = p_conn->rt_timeout_delta;
383 		p_tcp->rt_timeout_delta = cpu_to_le32(dval);
384 		p_tcp->dup_ack_cnt = p_conn->dup_ack_cnt;
385 		p_tcp->snd_wnd_probe_cnt = p_conn->snd_wnd_probe_cnt;
386 		p_tcp->ka_probe_cnt = p_conn->ka_probe_cnt;
387 		p_tcp->rt_cnt = p_conn->rt_cnt;
388 		p_tcp->flow_label = cpu_to_le32(p_conn->flow_label);
389 		p_tcp->ka_timeout = cpu_to_le32(p_conn->ka_timeout);
390 		p_tcp->ka_interval = cpu_to_le32(p_conn->ka_interval);
391 		p_tcp->max_rt_time = cpu_to_le32(p_conn->max_rt_time);
392 		dval = p_conn->initial_rcv_wnd;
393 		p_tcp->initial_rcv_wnd = cpu_to_le32(dval);
394 		p_tcp->ttl = p_conn->ttl;
395 		p_tcp->tos_or_tc = p_conn->tos_or_tc;
396 		p_tcp->remote_port = cpu_to_le16(p_conn->remote_port);
397 		p_tcp->local_port = cpu_to_le16(p_conn->local_port);
398 		p_tcp->mss = cpu_to_le16(p_conn->mss);
399 		p_tcp->snd_wnd_scale = p_conn->snd_wnd_scale;
400 		p_tcp->rcv_wnd_scale = p_conn->rcv_wnd_scale;
401 		wval = p_conn->da_timeout_value;
402 		p_tcp->da_timeout_value = cpu_to_le16(wval);
403 		p_tcp->ack_frequency = p_conn->ack_frequency;
404 		p_tcp->connect_mode = p_conn->connect_mode;
405 	} else {
406 		p_tcp2 =
407 		    &((struct iscsi_spe_conn_offload_option2 *)p_ramrod)->tcp;
408 
409 		p = (u16 *)p_conn->local_mac;
410 		p_tcp2->local_mac_addr_hi = swab16(get_unaligned(p));
411 		p_tcp2->local_mac_addr_mid = swab16(get_unaligned(p + 1));
412 		p_tcp2->local_mac_addr_lo = swab16(get_unaligned(p + 2));
413 
414 		p = (u16 *)p_conn->remote_mac;
415 		p_tcp2->remote_mac_addr_hi = swab16(get_unaligned(p));
416 		p_tcp2->remote_mac_addr_mid = swab16(get_unaligned(p + 1));
417 		p_tcp2->remote_mac_addr_lo = swab16(get_unaligned(p + 2));
418 
419 		p_tcp2->vlan_id = cpu_to_le16(p_conn->vlan_id);
420 		p_tcp2->flags = p_conn->tcp_flags;
421 
422 		p_tcp2->ip_version = p_conn->ip_version;
423 		for (i = 0; i < 4; i++) {
424 			dval = p_conn->remote_ip[i];
425 			p_tcp2->remote_ip[i] = cpu_to_le32(dval);
426 			dval = p_conn->local_ip[i];
427 			p_tcp2->local_ip[i] = cpu_to_le32(dval);
428 		}
429 
430 		p_tcp2->flow_label = cpu_to_le32(p_conn->flow_label);
431 		p_tcp2->ttl = p_conn->ttl;
432 		p_tcp2->tos_or_tc = p_conn->tos_or_tc;
433 		p_tcp2->remote_port = cpu_to_le16(p_conn->remote_port);
434 		p_tcp2->local_port = cpu_to_le16(p_conn->local_port);
435 		p_tcp2->mss = cpu_to_le16(p_conn->mss);
436 		p_tcp2->rcv_wnd_scale = p_conn->rcv_wnd_scale;
437 		p_tcp2->connect_mode = p_conn->connect_mode;
438 		wval = p_conn->syn_ip_payload_length;
439 		p_tcp2->syn_ip_payload_length = cpu_to_le16(wval);
440 		p_tcp2->syn_phy_addr_lo = DMA_LO_LE(p_conn->syn_phy_addr);
441 		p_tcp2->syn_phy_addr_hi = DMA_HI_LE(p_conn->syn_phy_addr);
442 	}
443 
444 	return qed_spq_post(p_hwfn, p_ent, NULL);
445 }
446 
447 static int qed_sp_iscsi_conn_update(struct qed_hwfn *p_hwfn,
448 				    struct qed_iscsi_conn *p_conn,
449 				    enum spq_mode comp_mode,
450 				    struct qed_spq_comp_cb *p_comp_addr)
451 {
452 	struct iscsi_conn_update_ramrod_params *p_ramrod = NULL;
453 	struct qed_spq_entry *p_ent = NULL;
454 	struct qed_sp_init_data init_data;
455 	int rc = -EINVAL;
456 	u32 dval;
457 
458 	/* Get SPQ entry */
459 	memset(&init_data, 0, sizeof(init_data));
460 	init_data.cid = p_conn->icid;
461 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
462 	init_data.comp_mode = comp_mode;
463 	init_data.p_comp_data = p_comp_addr;
464 
465 	rc = qed_sp_init_request(p_hwfn, &p_ent,
466 				 ISCSI_RAMROD_CMD_ID_UPDATE_CONN,
467 				 PROTOCOLID_ISCSI, &init_data);
468 	if (rc)
469 		return rc;
470 
471 	p_ramrod = &p_ent->ramrod.iscsi_conn_update;
472 	p_ramrod->hdr.op_code = ISCSI_RAMROD_CMD_ID_UPDATE_CONN;
473 	SET_FIELD(p_ramrod->hdr.flags,
474 		  ISCSI_SLOW_PATH_HDR_LAYER_CODE, p_conn->layer_code);
475 
476 	p_ramrod->conn_id = cpu_to_le16(p_conn->conn_id);
477 	p_ramrod->fw_cid = cpu_to_le32(p_conn->icid);
478 	p_ramrod->flags = p_conn->update_flag;
479 	p_ramrod->max_seq_size = cpu_to_le32(p_conn->max_seq_size);
480 	dval = p_conn->max_recv_pdu_length;
481 	p_ramrod->max_recv_pdu_length = cpu_to_le32(dval);
482 	dval = p_conn->max_send_pdu_length;
483 	p_ramrod->max_send_pdu_length = cpu_to_le32(dval);
484 	dval = p_conn->first_seq_length;
485 	p_ramrod->first_seq_length = cpu_to_le32(dval);
486 	p_ramrod->exp_stat_sn = cpu_to_le32(p_conn->exp_stat_sn);
487 
488 	return qed_spq_post(p_hwfn, p_ent, NULL);
489 }
490 
491 static int qed_sp_iscsi_conn_terminate(struct qed_hwfn *p_hwfn,
492 				       struct qed_iscsi_conn *p_conn,
493 				       enum spq_mode comp_mode,
494 				       struct qed_spq_comp_cb *p_comp_addr)
495 {
496 	struct iscsi_spe_conn_termination *p_ramrod = NULL;
497 	struct qed_spq_entry *p_ent = NULL;
498 	struct qed_sp_init_data init_data;
499 	int rc = -EINVAL;
500 
501 	/* Get SPQ entry */
502 	memset(&init_data, 0, sizeof(init_data));
503 	init_data.cid = p_conn->icid;
504 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
505 	init_data.comp_mode = comp_mode;
506 	init_data.p_comp_data = p_comp_addr;
507 
508 	rc = qed_sp_init_request(p_hwfn, &p_ent,
509 				 ISCSI_RAMROD_CMD_ID_TERMINATION_CONN,
510 				 PROTOCOLID_ISCSI, &init_data);
511 	if (rc)
512 		return rc;
513 
514 	p_ramrod = &p_ent->ramrod.iscsi_conn_terminate;
515 	p_ramrod->hdr.op_code = ISCSI_RAMROD_CMD_ID_TERMINATION_CONN;
516 	SET_FIELD(p_ramrod->hdr.flags,
517 		  ISCSI_SLOW_PATH_HDR_LAYER_CODE, p_conn->layer_code);
518 
519 	p_ramrod->conn_id = cpu_to_le16(p_conn->conn_id);
520 	p_ramrod->fw_cid = cpu_to_le32(p_conn->icid);
521 	p_ramrod->abortive = p_conn->abortive_dsconnect;
522 
523 	DMA_REGPAIR_LE(p_ramrod->query_params_addr,
524 		       p_conn->tcp_upload_params_phys_addr);
525 	DMA_REGPAIR_LE(p_ramrod->queue_cnts_addr, p_conn->queue_cnts_phys_addr);
526 
527 	return qed_spq_post(p_hwfn, p_ent, NULL);
528 }
529 
530 static int qed_sp_iscsi_conn_clear_sq(struct qed_hwfn *p_hwfn,
531 				      struct qed_iscsi_conn *p_conn,
532 				      enum spq_mode comp_mode,
533 				      struct qed_spq_comp_cb *p_comp_addr)
534 {
535 	struct iscsi_slow_path_hdr *p_ramrod = NULL;
536 	struct qed_spq_entry *p_ent = NULL;
537 	struct qed_sp_init_data init_data;
538 	int rc = -EINVAL;
539 
540 	/* Get SPQ entry */
541 	memset(&init_data, 0, sizeof(init_data));
542 	init_data.cid = p_conn->icid;
543 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
544 	init_data.comp_mode = comp_mode;
545 	init_data.p_comp_data = p_comp_addr;
546 
547 	rc = qed_sp_init_request(p_hwfn, &p_ent,
548 				 ISCSI_RAMROD_CMD_ID_CLEAR_SQ,
549 				 PROTOCOLID_ISCSI, &init_data);
550 	if (rc)
551 		return rc;
552 
553 	p_ramrod = &p_ent->ramrod.iscsi_empty;
554 	p_ramrod->op_code = ISCSI_RAMROD_CMD_ID_CLEAR_SQ;
555 	SET_FIELD(p_ramrod->flags,
556 		  ISCSI_SLOW_PATH_HDR_LAYER_CODE, p_conn->layer_code);
557 
558 	return qed_spq_post(p_hwfn, p_ent, NULL);
559 }
560 
561 static int qed_sp_iscsi_func_stop(struct qed_hwfn *p_hwfn,
562 				  enum spq_mode comp_mode,
563 				  struct qed_spq_comp_cb *p_comp_addr)
564 {
565 	struct iscsi_spe_func_dstry *p_ramrod = NULL;
566 	struct qed_spq_entry *p_ent = NULL;
567 	struct qed_sp_init_data init_data;
568 	int rc = 0;
569 
570 	/* Get SPQ entry */
571 	memset(&init_data, 0, sizeof(init_data));
572 	init_data.cid = qed_spq_get_cid(p_hwfn);
573 	init_data.opaque_fid = p_hwfn->hw_info.opaque_fid;
574 	init_data.comp_mode = comp_mode;
575 	init_data.p_comp_data = p_comp_addr;
576 
577 	rc = qed_sp_init_request(p_hwfn, &p_ent,
578 				 ISCSI_RAMROD_CMD_ID_DESTROY_FUNC,
579 				 PROTOCOLID_ISCSI, &init_data);
580 	if (rc)
581 		return rc;
582 
583 	p_ramrod = &p_ent->ramrod.iscsi_destroy;
584 	p_ramrod->hdr.op_code = ISCSI_RAMROD_CMD_ID_DESTROY_FUNC;
585 
586 	return qed_spq_post(p_hwfn, p_ent, NULL);
587 }
588 
589 static void __iomem *qed_iscsi_get_db_addr(struct qed_hwfn *p_hwfn, u32 cid)
590 {
591 	return (u8 __iomem *)p_hwfn->doorbells +
592 			     qed_db_addr(cid, DQ_DEMS_LEGACY);
593 }
594 
595 static void __iomem *qed_iscsi_get_primary_bdq_prod(struct qed_hwfn *p_hwfn,
596 						    u8 bdq_id)
597 {
598 	if (RESC_NUM(p_hwfn, QED_BDQ)) {
599 		return (u8 __iomem *)p_hwfn->regview +
600 		       GTT_BAR0_MAP_REG_MSDM_RAM +
601 		       MSTORM_SCSI_BDQ_EXT_PROD_OFFSET(RESC_START(p_hwfn,
602 								  QED_BDQ),
603 						       bdq_id);
604 	} else {
605 		DP_NOTICE(p_hwfn, "BDQ is not allocated!\n");
606 		return NULL;
607 	}
608 }
609 
610 static void __iomem *qed_iscsi_get_secondary_bdq_prod(struct qed_hwfn *p_hwfn,
611 						      u8 bdq_id)
612 {
613 	if (RESC_NUM(p_hwfn, QED_BDQ)) {
614 		return (u8 __iomem *)p_hwfn->regview +
615 		       GTT_BAR0_MAP_REG_TSDM_RAM +
616 		       TSTORM_SCSI_BDQ_EXT_PROD_OFFSET(RESC_START(p_hwfn,
617 								  QED_BDQ),
618 						       bdq_id);
619 	} else {
620 		DP_NOTICE(p_hwfn, "BDQ is not allocated!\n");
621 		return NULL;
622 	}
623 }
624 
625 static int qed_iscsi_setup_connection(struct qed_hwfn *p_hwfn,
626 				      struct qed_iscsi_conn *p_conn)
627 {
628 	if (!p_conn->queue_cnts_virt_addr)
629 		goto nomem;
630 	memset(p_conn->queue_cnts_virt_addr, 0,
631 	       sizeof(*p_conn->queue_cnts_virt_addr));
632 
633 	if (!p_conn->tcp_upload_params_virt_addr)
634 		goto nomem;
635 	memset(p_conn->tcp_upload_params_virt_addr, 0,
636 	       sizeof(*p_conn->tcp_upload_params_virt_addr));
637 
638 	if (!p_conn->r2tq.p_virt_addr)
639 		goto nomem;
640 	qed_chain_pbl_zero_mem(&p_conn->r2tq);
641 
642 	if (!p_conn->uhq.p_virt_addr)
643 		goto nomem;
644 	qed_chain_pbl_zero_mem(&p_conn->uhq);
645 
646 	if (!p_conn->xhq.p_virt_addr)
647 		goto nomem;
648 	qed_chain_pbl_zero_mem(&p_conn->xhq);
649 
650 	return 0;
651 nomem:
652 	return -ENOMEM;
653 }
654 
655 static int qed_iscsi_allocate_connection(struct qed_hwfn *p_hwfn,
656 					 struct qed_iscsi_conn **p_out_conn)
657 {
658 	u16 uhq_num_elements = 0, xhq_num_elements = 0, r2tq_num_elements = 0;
659 	struct scsi_terminate_extra_params *p_q_cnts = NULL;
660 	struct qed_iscsi_pf_params *p_params = NULL;
661 	struct tcp_upload_params *p_tcp = NULL;
662 	struct qed_iscsi_conn *p_conn = NULL;
663 	int rc = 0;
664 
665 	/* Try finding a free connection that can be used */
666 	spin_lock_bh(&p_hwfn->p_iscsi_info->lock);
667 	if (!list_empty(&p_hwfn->p_iscsi_info->free_list))
668 		p_conn = list_first_entry(&p_hwfn->p_iscsi_info->free_list,
669 					  struct qed_iscsi_conn, list_entry);
670 	if (p_conn) {
671 		list_del(&p_conn->list_entry);
672 		spin_unlock_bh(&p_hwfn->p_iscsi_info->lock);
673 		*p_out_conn = p_conn;
674 		return 0;
675 	}
676 	spin_unlock_bh(&p_hwfn->p_iscsi_info->lock);
677 
678 	/* Need to allocate a new connection */
679 	p_params = &p_hwfn->pf_params.iscsi_pf_params;
680 
681 	p_conn = kzalloc(sizeof(*p_conn), GFP_KERNEL);
682 	if (!p_conn)
683 		return -ENOMEM;
684 
685 	p_q_cnts = dma_alloc_coherent(&p_hwfn->cdev->pdev->dev,
686 				      sizeof(*p_q_cnts),
687 				      &p_conn->queue_cnts_phys_addr,
688 				      GFP_KERNEL);
689 	if (!p_q_cnts)
690 		goto nomem_queue_cnts_param;
691 	p_conn->queue_cnts_virt_addr = p_q_cnts;
692 
693 	p_tcp = dma_alloc_coherent(&p_hwfn->cdev->pdev->dev,
694 				   sizeof(*p_tcp),
695 				   &p_conn->tcp_upload_params_phys_addr,
696 				   GFP_KERNEL);
697 	if (!p_tcp)
698 		goto nomem_upload_param;
699 	p_conn->tcp_upload_params_virt_addr = p_tcp;
700 
701 	r2tq_num_elements = p_params->num_r2tq_pages_in_ring *
702 			    QED_CHAIN_PAGE_SIZE / 0x80;
703 	rc = qed_chain_alloc(p_hwfn->cdev,
704 			     QED_CHAIN_USE_TO_CONSUME_PRODUCE,
705 			     QED_CHAIN_MODE_PBL,
706 			     QED_CHAIN_CNT_TYPE_U16,
707 			     r2tq_num_elements, 0x80, &p_conn->r2tq);
708 	if (rc)
709 		goto nomem_r2tq;
710 
711 	uhq_num_elements = p_params->num_uhq_pages_in_ring *
712 			   QED_CHAIN_PAGE_SIZE / sizeof(struct iscsi_uhqe);
713 	rc = qed_chain_alloc(p_hwfn->cdev,
714 			     QED_CHAIN_USE_TO_CONSUME_PRODUCE,
715 			     QED_CHAIN_MODE_PBL,
716 			     QED_CHAIN_CNT_TYPE_U16,
717 			     uhq_num_elements,
718 			     sizeof(struct iscsi_uhqe), &p_conn->uhq);
719 	if (rc)
720 		goto nomem_uhq;
721 
722 	xhq_num_elements = uhq_num_elements;
723 	rc = qed_chain_alloc(p_hwfn->cdev,
724 			     QED_CHAIN_USE_TO_CONSUME_PRODUCE,
725 			     QED_CHAIN_MODE_PBL,
726 			     QED_CHAIN_CNT_TYPE_U16,
727 			     xhq_num_elements,
728 			     sizeof(struct iscsi_xhqe), &p_conn->xhq);
729 	if (rc)
730 		goto nomem;
731 
732 	p_conn->free_on_delete = true;
733 	*p_out_conn = p_conn;
734 	return 0;
735 
736 nomem:
737 	qed_chain_free(p_hwfn->cdev, &p_conn->uhq);
738 nomem_uhq:
739 	qed_chain_free(p_hwfn->cdev, &p_conn->r2tq);
740 nomem_r2tq:
741 	dma_free_coherent(&p_hwfn->cdev->pdev->dev,
742 			  sizeof(struct tcp_upload_params),
743 			  p_conn->tcp_upload_params_virt_addr,
744 			  p_conn->tcp_upload_params_phys_addr);
745 nomem_upload_param:
746 	dma_free_coherent(&p_hwfn->cdev->pdev->dev,
747 			  sizeof(struct scsi_terminate_extra_params),
748 			  p_conn->queue_cnts_virt_addr,
749 			  p_conn->queue_cnts_phys_addr);
750 nomem_queue_cnts_param:
751 	kfree(p_conn);
752 
753 	return -ENOMEM;
754 }
755 
756 static int qed_iscsi_acquire_connection(struct qed_hwfn *p_hwfn,
757 					struct qed_iscsi_conn *p_in_conn,
758 					struct qed_iscsi_conn **p_out_conn)
759 {
760 	struct qed_iscsi_conn *p_conn = NULL;
761 	int rc = 0;
762 	u32 icid;
763 
764 	spin_lock_bh(&p_hwfn->p_iscsi_info->lock);
765 	rc = qed_cxt_acquire_cid(p_hwfn, PROTOCOLID_ISCSI, &icid);
766 	spin_unlock_bh(&p_hwfn->p_iscsi_info->lock);
767 	if (rc)
768 		return rc;
769 
770 	/* Use input connection or allocate a new one */
771 	if (p_in_conn)
772 		p_conn = p_in_conn;
773 	else
774 		rc = qed_iscsi_allocate_connection(p_hwfn, &p_conn);
775 
776 	if (!rc)
777 		rc = qed_iscsi_setup_connection(p_hwfn, p_conn);
778 
779 	if (rc) {
780 		spin_lock_bh(&p_hwfn->p_iscsi_info->lock);
781 		qed_cxt_release_cid(p_hwfn, icid);
782 		spin_unlock_bh(&p_hwfn->p_iscsi_info->lock);
783 		return rc;
784 	}
785 
786 	p_conn->icid = icid;
787 	p_conn->conn_id = (u16)icid;
788 	p_conn->fw_cid = (p_hwfn->hw_info.opaque_fid << 16) | icid;
789 
790 	*p_out_conn = p_conn;
791 
792 	return rc;
793 }
794 
795 static void qed_iscsi_release_connection(struct qed_hwfn *p_hwfn,
796 					 struct qed_iscsi_conn *p_conn)
797 {
798 	spin_lock_bh(&p_hwfn->p_iscsi_info->lock);
799 	list_add_tail(&p_conn->list_entry, &p_hwfn->p_iscsi_info->free_list);
800 	qed_cxt_release_cid(p_hwfn, p_conn->icid);
801 	spin_unlock_bh(&p_hwfn->p_iscsi_info->lock);
802 }
803 
804 void qed_iscsi_free_connection(struct qed_hwfn *p_hwfn,
805 			       struct qed_iscsi_conn *p_conn)
806 {
807 	qed_chain_free(p_hwfn->cdev, &p_conn->xhq);
808 	qed_chain_free(p_hwfn->cdev, &p_conn->uhq);
809 	qed_chain_free(p_hwfn->cdev, &p_conn->r2tq);
810 	dma_free_coherent(&p_hwfn->cdev->pdev->dev,
811 			  sizeof(struct tcp_upload_params),
812 			  p_conn->tcp_upload_params_virt_addr,
813 			  p_conn->tcp_upload_params_phys_addr);
814 	dma_free_coherent(&p_hwfn->cdev->pdev->dev,
815 			  sizeof(struct scsi_terminate_extra_params),
816 			  p_conn->queue_cnts_virt_addr,
817 			  p_conn->queue_cnts_phys_addr);
818 	kfree(p_conn);
819 }
820 
821 struct qed_iscsi_info *qed_iscsi_alloc(struct qed_hwfn *p_hwfn)
822 {
823 	struct qed_iscsi_info *p_iscsi_info;
824 
825 	p_iscsi_info = kzalloc(sizeof(*p_iscsi_info), GFP_KERNEL);
826 	if (!p_iscsi_info)
827 		return NULL;
828 
829 	INIT_LIST_HEAD(&p_iscsi_info->free_list);
830 	return p_iscsi_info;
831 }
832 
833 void qed_iscsi_setup(struct qed_hwfn *p_hwfn,
834 		     struct qed_iscsi_info *p_iscsi_info)
835 {
836 	spin_lock_init(&p_iscsi_info->lock);
837 }
838 
839 void qed_iscsi_free(struct qed_hwfn *p_hwfn,
840 		    struct qed_iscsi_info *p_iscsi_info)
841 {
842 	struct qed_iscsi_conn *p_conn = NULL;
843 
844 	while (!list_empty(&p_hwfn->p_iscsi_info->free_list)) {
845 		p_conn = list_first_entry(&p_hwfn->p_iscsi_info->free_list,
846 					  struct qed_iscsi_conn, list_entry);
847 		if (p_conn) {
848 			list_del(&p_conn->list_entry);
849 			qed_iscsi_free_connection(p_hwfn, p_conn);
850 		}
851 	}
852 
853 	kfree(p_iscsi_info);
854 }
855 
856 static void _qed_iscsi_get_tstats(struct qed_hwfn *p_hwfn,
857 				  struct qed_ptt *p_ptt,
858 				  struct qed_iscsi_stats *p_stats)
859 {
860 	struct tstorm_iscsi_stats_drv tstats;
861 	u32 tstats_addr;
862 
863 	memset(&tstats, 0, sizeof(tstats));
864 	tstats_addr = BAR0_MAP_REG_TSDM_RAM +
865 		      TSTORM_ISCSI_RX_STATS_OFFSET(p_hwfn->rel_pf_id);
866 	qed_memcpy_from(p_hwfn, p_ptt, &tstats, tstats_addr, sizeof(tstats));
867 
868 	p_stats->iscsi_rx_bytes_cnt =
869 	    HILO_64_REGPAIR(tstats.iscsi_rx_bytes_cnt);
870 	p_stats->iscsi_rx_packet_cnt =
871 	    HILO_64_REGPAIR(tstats.iscsi_rx_packet_cnt);
872 	p_stats->iscsi_rx_new_ooo_isle_events_cnt =
873 	    HILO_64_REGPAIR(tstats.iscsi_rx_new_ooo_isle_events_cnt);
874 	p_stats->iscsi_cmdq_threshold_cnt =
875 	    le32_to_cpu(tstats.iscsi_cmdq_threshold_cnt);
876 	p_stats->iscsi_rq_threshold_cnt =
877 	    le32_to_cpu(tstats.iscsi_rq_threshold_cnt);
878 	p_stats->iscsi_immq_threshold_cnt =
879 	    le32_to_cpu(tstats.iscsi_immq_threshold_cnt);
880 }
881 
882 static void _qed_iscsi_get_mstats(struct qed_hwfn *p_hwfn,
883 				  struct qed_ptt *p_ptt,
884 				  struct qed_iscsi_stats *p_stats)
885 {
886 	struct mstorm_iscsi_stats_drv mstats;
887 	u32 mstats_addr;
888 
889 	memset(&mstats, 0, sizeof(mstats));
890 	mstats_addr = BAR0_MAP_REG_MSDM_RAM +
891 		      MSTORM_ISCSI_RX_STATS_OFFSET(p_hwfn->rel_pf_id);
892 	qed_memcpy_from(p_hwfn, p_ptt, &mstats, mstats_addr, sizeof(mstats));
893 
894 	p_stats->iscsi_rx_dropped_pdus_task_not_valid =
895 	    HILO_64_REGPAIR(mstats.iscsi_rx_dropped_pdus_task_not_valid);
896 }
897 
898 static void _qed_iscsi_get_ustats(struct qed_hwfn *p_hwfn,
899 				  struct qed_ptt *p_ptt,
900 				  struct qed_iscsi_stats *p_stats)
901 {
902 	struct ustorm_iscsi_stats_drv ustats;
903 	u32 ustats_addr;
904 
905 	memset(&ustats, 0, sizeof(ustats));
906 	ustats_addr = BAR0_MAP_REG_USDM_RAM +
907 		      USTORM_ISCSI_RX_STATS_OFFSET(p_hwfn->rel_pf_id);
908 	qed_memcpy_from(p_hwfn, p_ptt, &ustats, ustats_addr, sizeof(ustats));
909 
910 	p_stats->iscsi_rx_data_pdu_cnt =
911 	    HILO_64_REGPAIR(ustats.iscsi_rx_data_pdu_cnt);
912 	p_stats->iscsi_rx_r2t_pdu_cnt =
913 	    HILO_64_REGPAIR(ustats.iscsi_rx_r2t_pdu_cnt);
914 	p_stats->iscsi_rx_total_pdu_cnt =
915 	    HILO_64_REGPAIR(ustats.iscsi_rx_total_pdu_cnt);
916 }
917 
918 static void _qed_iscsi_get_xstats(struct qed_hwfn *p_hwfn,
919 				  struct qed_ptt *p_ptt,
920 				  struct qed_iscsi_stats *p_stats)
921 {
922 	struct xstorm_iscsi_stats_drv xstats;
923 	u32 xstats_addr;
924 
925 	memset(&xstats, 0, sizeof(xstats));
926 	xstats_addr = BAR0_MAP_REG_XSDM_RAM +
927 		      XSTORM_ISCSI_TX_STATS_OFFSET(p_hwfn->rel_pf_id);
928 	qed_memcpy_from(p_hwfn, p_ptt, &xstats, xstats_addr, sizeof(xstats));
929 
930 	p_stats->iscsi_tx_go_to_slow_start_event_cnt =
931 	    HILO_64_REGPAIR(xstats.iscsi_tx_go_to_slow_start_event_cnt);
932 	p_stats->iscsi_tx_fast_retransmit_event_cnt =
933 	    HILO_64_REGPAIR(xstats.iscsi_tx_fast_retransmit_event_cnt);
934 }
935 
936 static void _qed_iscsi_get_ystats(struct qed_hwfn *p_hwfn,
937 				  struct qed_ptt *p_ptt,
938 				  struct qed_iscsi_stats *p_stats)
939 {
940 	struct ystorm_iscsi_stats_drv ystats;
941 	u32 ystats_addr;
942 
943 	memset(&ystats, 0, sizeof(ystats));
944 	ystats_addr = BAR0_MAP_REG_YSDM_RAM +
945 		      YSTORM_ISCSI_TX_STATS_OFFSET(p_hwfn->rel_pf_id);
946 	qed_memcpy_from(p_hwfn, p_ptt, &ystats, ystats_addr, sizeof(ystats));
947 
948 	p_stats->iscsi_tx_data_pdu_cnt =
949 	    HILO_64_REGPAIR(ystats.iscsi_tx_data_pdu_cnt);
950 	p_stats->iscsi_tx_r2t_pdu_cnt =
951 	    HILO_64_REGPAIR(ystats.iscsi_tx_r2t_pdu_cnt);
952 	p_stats->iscsi_tx_total_pdu_cnt =
953 	    HILO_64_REGPAIR(ystats.iscsi_tx_total_pdu_cnt);
954 }
955 
956 static void _qed_iscsi_get_pstats(struct qed_hwfn *p_hwfn,
957 				  struct qed_ptt *p_ptt,
958 				  struct qed_iscsi_stats *p_stats)
959 {
960 	struct pstorm_iscsi_stats_drv pstats;
961 	u32 pstats_addr;
962 
963 	memset(&pstats, 0, sizeof(pstats));
964 	pstats_addr = BAR0_MAP_REG_PSDM_RAM +
965 		      PSTORM_ISCSI_TX_STATS_OFFSET(p_hwfn->rel_pf_id);
966 	qed_memcpy_from(p_hwfn, p_ptt, &pstats, pstats_addr, sizeof(pstats));
967 
968 	p_stats->iscsi_tx_bytes_cnt =
969 	    HILO_64_REGPAIR(pstats.iscsi_tx_bytes_cnt);
970 	p_stats->iscsi_tx_packet_cnt =
971 	    HILO_64_REGPAIR(pstats.iscsi_tx_packet_cnt);
972 }
973 
974 static int qed_iscsi_get_stats(struct qed_hwfn *p_hwfn,
975 			       struct qed_iscsi_stats *stats)
976 {
977 	struct qed_ptt *p_ptt;
978 
979 	memset(stats, 0, sizeof(*stats));
980 
981 	p_ptt = qed_ptt_acquire(p_hwfn);
982 	if (!p_ptt) {
983 		DP_ERR(p_hwfn, "Failed to acquire ptt\n");
984 		return -EAGAIN;
985 	}
986 
987 	_qed_iscsi_get_tstats(p_hwfn, p_ptt, stats);
988 	_qed_iscsi_get_mstats(p_hwfn, p_ptt, stats);
989 	_qed_iscsi_get_ustats(p_hwfn, p_ptt, stats);
990 
991 	_qed_iscsi_get_xstats(p_hwfn, p_ptt, stats);
992 	_qed_iscsi_get_ystats(p_hwfn, p_ptt, stats);
993 	_qed_iscsi_get_pstats(p_hwfn, p_ptt, stats);
994 
995 	qed_ptt_release(p_hwfn, p_ptt);
996 
997 	return 0;
998 }
999 
1000 struct qed_hash_iscsi_con {
1001 	struct hlist_node node;
1002 	struct qed_iscsi_conn *con;
1003 };
1004 
1005 static int qed_fill_iscsi_dev_info(struct qed_dev *cdev,
1006 				   struct qed_dev_iscsi_info *info)
1007 {
1008 	struct qed_hwfn *hwfn = QED_LEADING_HWFN(cdev);
1009 
1010 	int rc;
1011 
1012 	memset(info, 0, sizeof(*info));
1013 	rc = qed_fill_dev_info(cdev, &info->common);
1014 
1015 	info->primary_dbq_rq_addr =
1016 	    qed_iscsi_get_primary_bdq_prod(hwfn, BDQ_ID_RQ);
1017 	info->secondary_bdq_rq_addr =
1018 	    qed_iscsi_get_secondary_bdq_prod(hwfn, BDQ_ID_RQ);
1019 
1020 	info->num_cqs = FEAT_NUM(hwfn, QED_ISCSI_CQ);
1021 
1022 	return rc;
1023 }
1024 
1025 static void qed_register_iscsi_ops(struct qed_dev *cdev,
1026 				   struct qed_iscsi_cb_ops *ops, void *cookie)
1027 {
1028 	cdev->protocol_ops.iscsi = ops;
1029 	cdev->ops_cookie = cookie;
1030 }
1031 
1032 static struct qed_hash_iscsi_con *qed_iscsi_get_hash(struct qed_dev *cdev,
1033 						     u32 handle)
1034 {
1035 	struct qed_hash_iscsi_con *hash_con = NULL;
1036 
1037 	if (!(cdev->flags & QED_FLAG_STORAGE_STARTED))
1038 		return NULL;
1039 
1040 	hash_for_each_possible(cdev->connections, hash_con, node, handle) {
1041 		if (hash_con->con->icid == handle)
1042 			break;
1043 	}
1044 
1045 	if (!hash_con || (hash_con->con->icid != handle))
1046 		return NULL;
1047 
1048 	return hash_con;
1049 }
1050 
1051 static int qed_iscsi_stop(struct qed_dev *cdev)
1052 {
1053 	int rc;
1054 
1055 	if (!(cdev->flags & QED_FLAG_STORAGE_STARTED)) {
1056 		DP_NOTICE(cdev, "iscsi already stopped\n");
1057 		return 0;
1058 	}
1059 
1060 	if (!hash_empty(cdev->connections)) {
1061 		DP_NOTICE(cdev,
1062 			  "Can't stop iscsi - not all connections were returned\n");
1063 		return -EINVAL;
1064 	}
1065 
1066 	/* Stop the iscsi */
1067 	rc = qed_sp_iscsi_func_stop(QED_LEADING_HWFN(cdev),
1068 				    QED_SPQ_MODE_EBLOCK, NULL);
1069 	cdev->flags &= ~QED_FLAG_STORAGE_STARTED;
1070 
1071 	return rc;
1072 }
1073 
1074 static int qed_iscsi_start(struct qed_dev *cdev,
1075 			   struct qed_iscsi_tid *tasks,
1076 			   void *event_context,
1077 			   iscsi_event_cb_t async_event_cb)
1078 {
1079 	int rc;
1080 	struct qed_tid_mem *tid_info;
1081 
1082 	if (cdev->flags & QED_FLAG_STORAGE_STARTED) {
1083 		DP_NOTICE(cdev, "iscsi already started;\n");
1084 		return 0;
1085 	}
1086 
1087 	rc = qed_sp_iscsi_func_start(QED_LEADING_HWFN(cdev),
1088 				     QED_SPQ_MODE_EBLOCK, NULL, event_context,
1089 				     async_event_cb);
1090 	if (rc) {
1091 		DP_NOTICE(cdev, "Failed to start iscsi\n");
1092 		return rc;
1093 	}
1094 
1095 	cdev->flags |= QED_FLAG_STORAGE_STARTED;
1096 	hash_init(cdev->connections);
1097 
1098 	if (!tasks)
1099 		return 0;
1100 
1101 	tid_info = kzalloc(sizeof(*tid_info), GFP_KERNEL);
1102 
1103 	if (!tid_info) {
1104 		qed_iscsi_stop(cdev);
1105 		return -ENOMEM;
1106 	}
1107 
1108 	rc = qed_cxt_get_tid_mem_info(QED_LEADING_HWFN(cdev),
1109 				      tid_info);
1110 	if (rc) {
1111 		DP_NOTICE(cdev, "Failed to gather task information\n");
1112 		qed_iscsi_stop(cdev);
1113 		kfree(tid_info);
1114 		return rc;
1115 	}
1116 
1117 	/* Fill task information */
1118 	tasks->size = tid_info->tid_size;
1119 	tasks->num_tids_per_block = tid_info->num_tids_per_block;
1120 	memcpy(tasks->blocks, tid_info->blocks,
1121 	       MAX_TID_BLOCKS_ISCSI * sizeof(u8 *));
1122 
1123 	kfree(tid_info);
1124 
1125 	return 0;
1126 }
1127 
1128 static int qed_iscsi_acquire_conn(struct qed_dev *cdev,
1129 				  u32 *handle,
1130 				  u32 *fw_cid, void __iomem **p_doorbell)
1131 {
1132 	struct qed_hash_iscsi_con *hash_con;
1133 	int rc;
1134 
1135 	/* Allocate a hashed connection */
1136 	hash_con = kzalloc(sizeof(*hash_con), GFP_ATOMIC);
1137 	if (!hash_con)
1138 		return -ENOMEM;
1139 
1140 	/* Acquire the connection */
1141 	rc = qed_iscsi_acquire_connection(QED_LEADING_HWFN(cdev), NULL,
1142 					  &hash_con->con);
1143 	if (rc) {
1144 		DP_NOTICE(cdev, "Failed to acquire Connection\n");
1145 		kfree(hash_con);
1146 		return rc;
1147 	}
1148 
1149 	/* Added the connection to hash table */
1150 	*handle = hash_con->con->icid;
1151 	*fw_cid = hash_con->con->fw_cid;
1152 	hash_add(cdev->connections, &hash_con->node, *handle);
1153 
1154 	if (p_doorbell)
1155 		*p_doorbell = qed_iscsi_get_db_addr(QED_LEADING_HWFN(cdev),
1156 						    *handle);
1157 
1158 	return 0;
1159 }
1160 
1161 static int qed_iscsi_release_conn(struct qed_dev *cdev, u32 handle)
1162 {
1163 	struct qed_hash_iscsi_con *hash_con;
1164 
1165 	hash_con = qed_iscsi_get_hash(cdev, handle);
1166 	if (!hash_con) {
1167 		DP_NOTICE(cdev, "Failed to find connection for handle %d\n",
1168 			  handle);
1169 		return -EINVAL;
1170 	}
1171 
1172 	hlist_del(&hash_con->node);
1173 	qed_iscsi_release_connection(QED_LEADING_HWFN(cdev), hash_con->con);
1174 	kfree(hash_con);
1175 
1176 	return 0;
1177 }
1178 
1179 static int qed_iscsi_offload_conn(struct qed_dev *cdev,
1180 				  u32 handle,
1181 				  struct qed_iscsi_params_offload *conn_info)
1182 {
1183 	struct qed_hash_iscsi_con *hash_con;
1184 	struct qed_iscsi_conn *con;
1185 
1186 	hash_con = qed_iscsi_get_hash(cdev, handle);
1187 	if (!hash_con) {
1188 		DP_NOTICE(cdev, "Failed to find connection for handle %d\n",
1189 			  handle);
1190 		return -EINVAL;
1191 	}
1192 
1193 	/* Update the connection with information from the params */
1194 	con = hash_con->con;
1195 
1196 	ether_addr_copy(con->local_mac, conn_info->src.mac);
1197 	ether_addr_copy(con->remote_mac, conn_info->dst.mac);
1198 	memcpy(con->local_ip, conn_info->src.ip, sizeof(con->local_ip));
1199 	memcpy(con->remote_ip, conn_info->dst.ip, sizeof(con->remote_ip));
1200 	con->local_port = conn_info->src.port;
1201 	con->remote_port = conn_info->dst.port;
1202 
1203 	con->layer_code = conn_info->layer_code;
1204 	con->sq_pbl_addr = conn_info->sq_pbl_addr;
1205 	con->initial_ack = conn_info->initial_ack;
1206 	con->vlan_id = conn_info->vlan_id;
1207 	con->tcp_flags = conn_info->tcp_flags;
1208 	con->ip_version = conn_info->ip_version;
1209 	con->default_cq = conn_info->default_cq;
1210 	con->ka_max_probe_cnt = conn_info->ka_max_probe_cnt;
1211 	con->dup_ack_theshold = conn_info->dup_ack_theshold;
1212 	con->rcv_next = conn_info->rcv_next;
1213 	con->snd_una = conn_info->snd_una;
1214 	con->snd_next = conn_info->snd_next;
1215 	con->snd_max = conn_info->snd_max;
1216 	con->snd_wnd = conn_info->snd_wnd;
1217 	con->rcv_wnd = conn_info->rcv_wnd;
1218 	con->snd_wl1 = conn_info->snd_wl1;
1219 	con->cwnd = conn_info->cwnd;
1220 	con->ss_thresh = conn_info->ss_thresh;
1221 	con->srtt = conn_info->srtt;
1222 	con->rtt_var = conn_info->rtt_var;
1223 	con->ts_time = conn_info->ts_time;
1224 	con->ts_recent = conn_info->ts_recent;
1225 	con->ts_recent_age = conn_info->ts_recent_age;
1226 	con->total_rt = conn_info->total_rt;
1227 	con->ka_timeout_delta = conn_info->ka_timeout_delta;
1228 	con->rt_timeout_delta = conn_info->rt_timeout_delta;
1229 	con->dup_ack_cnt = conn_info->dup_ack_cnt;
1230 	con->snd_wnd_probe_cnt = conn_info->snd_wnd_probe_cnt;
1231 	con->ka_probe_cnt = conn_info->ka_probe_cnt;
1232 	con->rt_cnt = conn_info->rt_cnt;
1233 	con->flow_label = conn_info->flow_label;
1234 	con->ka_timeout = conn_info->ka_timeout;
1235 	con->ka_interval = conn_info->ka_interval;
1236 	con->max_rt_time = conn_info->max_rt_time;
1237 	con->initial_rcv_wnd = conn_info->initial_rcv_wnd;
1238 	con->ttl = conn_info->ttl;
1239 	con->tos_or_tc = conn_info->tos_or_tc;
1240 	con->remote_port = conn_info->remote_port;
1241 	con->local_port = conn_info->local_port;
1242 	con->mss = conn_info->mss;
1243 	con->snd_wnd_scale = conn_info->snd_wnd_scale;
1244 	con->rcv_wnd_scale = conn_info->rcv_wnd_scale;
1245 	con->ts_ticks_per_second = conn_info->ts_ticks_per_second;
1246 	con->da_timeout_value = conn_info->da_timeout_value;
1247 	con->ack_frequency = conn_info->ack_frequency;
1248 
1249 	/* Set default values on other connection fields */
1250 	con->offl_flags = 0x1;
1251 
1252 	return qed_sp_iscsi_conn_offload(QED_LEADING_HWFN(cdev), con,
1253 					 QED_SPQ_MODE_EBLOCK, NULL);
1254 }
1255 
1256 static int qed_iscsi_update_conn(struct qed_dev *cdev,
1257 				 u32 handle,
1258 				 struct qed_iscsi_params_update *conn_info)
1259 {
1260 	struct qed_hash_iscsi_con *hash_con;
1261 	struct qed_iscsi_conn *con;
1262 
1263 	hash_con = qed_iscsi_get_hash(cdev, handle);
1264 	if (!hash_con) {
1265 		DP_NOTICE(cdev, "Failed to find connection for handle %d\n",
1266 			  handle);
1267 		return -EINVAL;
1268 	}
1269 
1270 	/* Update the connection with information from the params */
1271 	con = hash_con->con;
1272 	con->update_flag = conn_info->update_flag;
1273 	con->max_seq_size = conn_info->max_seq_size;
1274 	con->max_recv_pdu_length = conn_info->max_recv_pdu_length;
1275 	con->max_send_pdu_length = conn_info->max_send_pdu_length;
1276 	con->first_seq_length = conn_info->first_seq_length;
1277 	con->exp_stat_sn = conn_info->exp_stat_sn;
1278 
1279 	return qed_sp_iscsi_conn_update(QED_LEADING_HWFN(cdev), con,
1280 					QED_SPQ_MODE_EBLOCK, NULL);
1281 }
1282 
1283 static int qed_iscsi_clear_conn_sq(struct qed_dev *cdev, u32 handle)
1284 {
1285 	struct qed_hash_iscsi_con *hash_con;
1286 
1287 	hash_con = qed_iscsi_get_hash(cdev, handle);
1288 	if (!hash_con) {
1289 		DP_NOTICE(cdev, "Failed to find connection for handle %d\n",
1290 			  handle);
1291 		return -EINVAL;
1292 	}
1293 
1294 	return qed_sp_iscsi_conn_clear_sq(QED_LEADING_HWFN(cdev),
1295 					  hash_con->con,
1296 					  QED_SPQ_MODE_EBLOCK, NULL);
1297 }
1298 
1299 static int qed_iscsi_destroy_conn(struct qed_dev *cdev,
1300 				  u32 handle, u8 abrt_conn)
1301 {
1302 	struct qed_hash_iscsi_con *hash_con;
1303 
1304 	hash_con = qed_iscsi_get_hash(cdev, handle);
1305 	if (!hash_con) {
1306 		DP_NOTICE(cdev, "Failed to find connection for handle %d\n",
1307 			  handle);
1308 		return -EINVAL;
1309 	}
1310 
1311 	hash_con->con->abortive_dsconnect = abrt_conn;
1312 
1313 	return qed_sp_iscsi_conn_terminate(QED_LEADING_HWFN(cdev),
1314 					   hash_con->con,
1315 					   QED_SPQ_MODE_EBLOCK, NULL);
1316 }
1317 
1318 static int qed_iscsi_stats(struct qed_dev *cdev, struct qed_iscsi_stats *stats)
1319 {
1320 	return qed_iscsi_get_stats(QED_LEADING_HWFN(cdev), stats);
1321 }
1322 
1323 void qed_get_protocol_stats_iscsi(struct qed_dev *cdev,
1324 				  struct qed_mcp_iscsi_stats *stats)
1325 {
1326 	struct qed_iscsi_stats proto_stats;
1327 
1328 	/* Retrieve FW statistics */
1329 	memset(&proto_stats, 0, sizeof(proto_stats));
1330 	if (qed_iscsi_stats(cdev, &proto_stats)) {
1331 		DP_VERBOSE(cdev, QED_MSG_STORAGE,
1332 			   "Failed to collect ISCSI statistics\n");
1333 		return;
1334 	}
1335 
1336 	/* Translate FW statistics into struct */
1337 	stats->rx_pdus = proto_stats.iscsi_rx_total_pdu_cnt;
1338 	stats->tx_pdus = proto_stats.iscsi_tx_total_pdu_cnt;
1339 	stats->rx_bytes = proto_stats.iscsi_rx_bytes_cnt;
1340 	stats->tx_bytes = proto_stats.iscsi_tx_bytes_cnt;
1341 }
1342 
1343 static const struct qed_iscsi_ops qed_iscsi_ops_pass = {
1344 	.common = &qed_common_ops_pass,
1345 	.ll2 = &qed_ll2_ops_pass,
1346 	.fill_dev_info = &qed_fill_iscsi_dev_info,
1347 	.register_ops = &qed_register_iscsi_ops,
1348 	.start = &qed_iscsi_start,
1349 	.stop = &qed_iscsi_stop,
1350 	.acquire_conn = &qed_iscsi_acquire_conn,
1351 	.release_conn = &qed_iscsi_release_conn,
1352 	.offload_conn = &qed_iscsi_offload_conn,
1353 	.update_conn = &qed_iscsi_update_conn,
1354 	.destroy_conn = &qed_iscsi_destroy_conn,
1355 	.clear_sq = &qed_iscsi_clear_conn_sq,
1356 	.get_stats = &qed_iscsi_stats,
1357 };
1358 
1359 const struct qed_iscsi_ops *qed_get_iscsi_ops(void)
1360 {
1361 	return &qed_iscsi_ops_pass;
1362 }
1363 EXPORT_SYMBOL(qed_get_iscsi_ops);
1364 
1365 void qed_put_iscsi_ops(void)
1366 {
1367 }
1368 EXPORT_SYMBOL(qed_put_iscsi_ops);
1369