1 // SPDX-License-Identifier: GPL-2.0-or-later
2 /*
3  * Copyright (c) 2015 Linaro Ltd.
4  * Copyright (c) 2015 Hisilicon Limited.
5  */
6 
7 #include "hisi_sas.h"
8 #define DRV_NAME "hisi_sas"
9 
10 #define DEV_IS_GONE(dev) \
11 	((!dev) || (dev->dev_type == SAS_PHY_UNUSED))
12 
13 static int hisi_sas_debug_issue_ssp_tmf(struct domain_device *device,
14 				u8 *lun, struct hisi_sas_tmf_task *tmf);
15 static int
16 hisi_sas_internal_task_abort(struct hisi_hba *hisi_hba,
17 			     struct domain_device *device,
18 			     int abort_flag, int tag);
19 static int hisi_sas_softreset_ata_disk(struct domain_device *device);
20 static int hisi_sas_control_phy(struct asd_sas_phy *sas_phy, enum phy_func func,
21 				void *funcdata);
22 static void hisi_sas_release_task(struct hisi_hba *hisi_hba,
23 				  struct domain_device *device);
24 static void hisi_sas_dev_gone(struct domain_device *device);
25 
26 u8 hisi_sas_get_ata_protocol(struct host_to_dev_fis *fis, int direction)
27 {
28 	switch (fis->command) {
29 	case ATA_CMD_FPDMA_WRITE:
30 	case ATA_CMD_FPDMA_READ:
31 	case ATA_CMD_FPDMA_RECV:
32 	case ATA_CMD_FPDMA_SEND:
33 	case ATA_CMD_NCQ_NON_DATA:
34 		return HISI_SAS_SATA_PROTOCOL_FPDMA;
35 
36 	case ATA_CMD_DOWNLOAD_MICRO:
37 	case ATA_CMD_ID_ATA:
38 	case ATA_CMD_PMP_READ:
39 	case ATA_CMD_READ_LOG_EXT:
40 	case ATA_CMD_PIO_READ:
41 	case ATA_CMD_PIO_READ_EXT:
42 	case ATA_CMD_PMP_WRITE:
43 	case ATA_CMD_WRITE_LOG_EXT:
44 	case ATA_CMD_PIO_WRITE:
45 	case ATA_CMD_PIO_WRITE_EXT:
46 		return HISI_SAS_SATA_PROTOCOL_PIO;
47 
48 	case ATA_CMD_DSM:
49 	case ATA_CMD_DOWNLOAD_MICRO_DMA:
50 	case ATA_CMD_PMP_READ_DMA:
51 	case ATA_CMD_PMP_WRITE_DMA:
52 	case ATA_CMD_READ:
53 	case ATA_CMD_READ_EXT:
54 	case ATA_CMD_READ_LOG_DMA_EXT:
55 	case ATA_CMD_READ_STREAM_DMA_EXT:
56 	case ATA_CMD_TRUSTED_RCV_DMA:
57 	case ATA_CMD_TRUSTED_SND_DMA:
58 	case ATA_CMD_WRITE:
59 	case ATA_CMD_WRITE_EXT:
60 	case ATA_CMD_WRITE_FUA_EXT:
61 	case ATA_CMD_WRITE_QUEUED:
62 	case ATA_CMD_WRITE_LOG_DMA_EXT:
63 	case ATA_CMD_WRITE_STREAM_DMA_EXT:
64 	case ATA_CMD_ZAC_MGMT_IN:
65 		return HISI_SAS_SATA_PROTOCOL_DMA;
66 
67 	case ATA_CMD_CHK_POWER:
68 	case ATA_CMD_DEV_RESET:
69 	case ATA_CMD_EDD:
70 	case ATA_CMD_FLUSH:
71 	case ATA_CMD_FLUSH_EXT:
72 	case ATA_CMD_VERIFY:
73 	case ATA_CMD_VERIFY_EXT:
74 	case ATA_CMD_SET_FEATURES:
75 	case ATA_CMD_STANDBY:
76 	case ATA_CMD_STANDBYNOW1:
77 	case ATA_CMD_ZAC_MGMT_OUT:
78 		return HISI_SAS_SATA_PROTOCOL_NONDATA;
79 
80 	case ATA_CMD_SET_MAX:
81 		switch (fis->features) {
82 		case ATA_SET_MAX_PASSWD:
83 		case ATA_SET_MAX_LOCK:
84 			return HISI_SAS_SATA_PROTOCOL_PIO;
85 
86 		case ATA_SET_MAX_PASSWD_DMA:
87 		case ATA_SET_MAX_UNLOCK_DMA:
88 			return HISI_SAS_SATA_PROTOCOL_DMA;
89 
90 		default:
91 			return HISI_SAS_SATA_PROTOCOL_NONDATA;
92 		}
93 
94 	default:
95 	{
96 		if (direction == DMA_NONE)
97 			return HISI_SAS_SATA_PROTOCOL_NONDATA;
98 		return HISI_SAS_SATA_PROTOCOL_PIO;
99 	}
100 	}
101 }
102 EXPORT_SYMBOL_GPL(hisi_sas_get_ata_protocol);
103 
104 void hisi_sas_sata_done(struct sas_task *task,
105 			    struct hisi_sas_slot *slot)
106 {
107 	struct task_status_struct *ts = &task->task_status;
108 	struct ata_task_resp *resp = (struct ata_task_resp *)ts->buf;
109 	struct hisi_sas_status_buffer *status_buf =
110 			hisi_sas_status_buf_addr_mem(slot);
111 	u8 *iu = &status_buf->iu[0];
112 	struct dev_to_host_fis *d2h =  (struct dev_to_host_fis *)iu;
113 
114 	resp->frame_len = sizeof(struct dev_to_host_fis);
115 	memcpy(&resp->ending_fis[0], d2h, sizeof(struct dev_to_host_fis));
116 
117 	ts->buf_valid_size = sizeof(*resp);
118 }
119 EXPORT_SYMBOL_GPL(hisi_sas_sata_done);
120 
121 /*
122  * This function assumes linkrate mask fits in 8 bits, which it
123  * does for all HW versions supported.
124  */
125 u8 hisi_sas_get_prog_phy_linkrate_mask(enum sas_linkrate max)
126 {
127 	u8 rate = 0;
128 	int i;
129 
130 	max -= SAS_LINK_RATE_1_5_GBPS;
131 	for (i = 0; i <= max; i++)
132 		rate |= 1 << (i * 2);
133 	return rate;
134 }
135 EXPORT_SYMBOL_GPL(hisi_sas_get_prog_phy_linkrate_mask);
136 
137 static struct hisi_hba *dev_to_hisi_hba(struct domain_device *device)
138 {
139 	return device->port->ha->lldd_ha;
140 }
141 
142 struct hisi_sas_port *to_hisi_sas_port(struct asd_sas_port *sas_port)
143 {
144 	return container_of(sas_port, struct hisi_sas_port, sas_port);
145 }
146 EXPORT_SYMBOL_GPL(to_hisi_sas_port);
147 
148 void hisi_sas_stop_phys(struct hisi_hba *hisi_hba)
149 {
150 	int phy_no;
151 
152 	for (phy_no = 0; phy_no < hisi_hba->n_phy; phy_no++)
153 		hisi_sas_phy_enable(hisi_hba, phy_no, 0);
154 }
155 EXPORT_SYMBOL_GPL(hisi_sas_stop_phys);
156 
157 static void hisi_sas_slot_index_clear(struct hisi_hba *hisi_hba, int slot_idx)
158 {
159 	void *bitmap = hisi_hba->slot_index_tags;
160 
161 	clear_bit(slot_idx, bitmap);
162 }
163 
164 static void hisi_sas_slot_index_free(struct hisi_hba *hisi_hba, int slot_idx)
165 {
166 	if (hisi_hba->hw->slot_index_alloc ||
167 	    slot_idx >= HISI_SAS_UNRESERVED_IPTT) {
168 		spin_lock(&hisi_hba->lock);
169 		hisi_sas_slot_index_clear(hisi_hba, slot_idx);
170 		spin_unlock(&hisi_hba->lock);
171 	}
172 }
173 
174 static void hisi_sas_slot_index_set(struct hisi_hba *hisi_hba, int slot_idx)
175 {
176 	void *bitmap = hisi_hba->slot_index_tags;
177 
178 	set_bit(slot_idx, bitmap);
179 }
180 
181 static int hisi_sas_slot_index_alloc(struct hisi_hba *hisi_hba,
182 				     struct scsi_cmnd *scsi_cmnd)
183 {
184 	int index;
185 	void *bitmap = hisi_hba->slot_index_tags;
186 
187 	if (scsi_cmnd)
188 		return scsi_cmnd->request->tag;
189 
190 	spin_lock(&hisi_hba->lock);
191 	index = find_next_zero_bit(bitmap, hisi_hba->slot_index_count,
192 				   hisi_hba->last_slot_index + 1);
193 	if (index >= hisi_hba->slot_index_count) {
194 		index = find_next_zero_bit(bitmap,
195 				hisi_hba->slot_index_count,
196 				HISI_SAS_UNRESERVED_IPTT);
197 		if (index >= hisi_hba->slot_index_count) {
198 			spin_unlock(&hisi_hba->lock);
199 			return -SAS_QUEUE_FULL;
200 		}
201 	}
202 	hisi_sas_slot_index_set(hisi_hba, index);
203 	hisi_hba->last_slot_index = index;
204 	spin_unlock(&hisi_hba->lock);
205 
206 	return index;
207 }
208 
209 static void hisi_sas_slot_index_init(struct hisi_hba *hisi_hba)
210 {
211 	int i;
212 
213 	for (i = 0; i < hisi_hba->slot_index_count; ++i)
214 		hisi_sas_slot_index_clear(hisi_hba, i);
215 }
216 
217 void hisi_sas_slot_task_free(struct hisi_hba *hisi_hba, struct sas_task *task,
218 			     struct hisi_sas_slot *slot)
219 {
220 	int device_id = slot->device_id;
221 	struct hisi_sas_device *sas_dev = &hisi_hba->devices[device_id];
222 
223 	if (task) {
224 		struct device *dev = hisi_hba->dev;
225 
226 		if (!task->lldd_task)
227 			return;
228 
229 		task->lldd_task = NULL;
230 
231 		if (!sas_protocol_ata(task->task_proto)) {
232 			if (slot->n_elem)
233 				dma_unmap_sg(dev, task->scatter,
234 					     task->num_scatter,
235 					     task->data_dir);
236 			if (slot->n_elem_dif) {
237 				struct sas_ssp_task *ssp_task = &task->ssp_task;
238 				struct scsi_cmnd *scsi_cmnd = ssp_task->cmd;
239 
240 				dma_unmap_sg(dev, scsi_prot_sglist(scsi_cmnd),
241 					     scsi_prot_sg_count(scsi_cmnd),
242 					     task->data_dir);
243 			}
244 		}
245 	}
246 
247 	spin_lock(&sas_dev->lock);
248 	list_del_init(&slot->entry);
249 	spin_unlock(&sas_dev->lock);
250 
251 	memset(slot, 0, offsetof(struct hisi_sas_slot, buf));
252 
253 	hisi_sas_slot_index_free(hisi_hba, slot->idx);
254 }
255 EXPORT_SYMBOL_GPL(hisi_sas_slot_task_free);
256 
257 static void hisi_sas_task_prep_smp(struct hisi_hba *hisi_hba,
258 				  struct hisi_sas_slot *slot)
259 {
260 	hisi_hba->hw->prep_smp(hisi_hba, slot);
261 }
262 
263 static void hisi_sas_task_prep_ssp(struct hisi_hba *hisi_hba,
264 				  struct hisi_sas_slot *slot)
265 {
266 	hisi_hba->hw->prep_ssp(hisi_hba, slot);
267 }
268 
269 static void hisi_sas_task_prep_ata(struct hisi_hba *hisi_hba,
270 				  struct hisi_sas_slot *slot)
271 {
272 	hisi_hba->hw->prep_stp(hisi_hba, slot);
273 }
274 
275 static void hisi_sas_task_prep_abort(struct hisi_hba *hisi_hba,
276 		struct hisi_sas_slot *slot,
277 		int device_id, int abort_flag, int tag_to_abort)
278 {
279 	hisi_hba->hw->prep_abort(hisi_hba, slot,
280 			device_id, abort_flag, tag_to_abort);
281 }
282 
283 static void hisi_sas_dma_unmap(struct hisi_hba *hisi_hba,
284 			       struct sas_task *task, int n_elem,
285 			       int n_elem_req)
286 {
287 	struct device *dev = hisi_hba->dev;
288 
289 	if (!sas_protocol_ata(task->task_proto)) {
290 		if (task->num_scatter) {
291 			if (n_elem)
292 				dma_unmap_sg(dev, task->scatter,
293 					     task->num_scatter,
294 					     task->data_dir);
295 		} else if (task->task_proto & SAS_PROTOCOL_SMP) {
296 			if (n_elem_req)
297 				dma_unmap_sg(dev, &task->smp_task.smp_req,
298 					     1, DMA_TO_DEVICE);
299 		}
300 	}
301 }
302 
303 static int hisi_sas_dma_map(struct hisi_hba *hisi_hba,
304 			    struct sas_task *task, int *n_elem,
305 			    int *n_elem_req)
306 {
307 	struct device *dev = hisi_hba->dev;
308 	int rc;
309 
310 	if (sas_protocol_ata(task->task_proto)) {
311 		*n_elem = task->num_scatter;
312 	} else {
313 		unsigned int req_len;
314 
315 		if (task->num_scatter) {
316 			*n_elem = dma_map_sg(dev, task->scatter,
317 					     task->num_scatter, task->data_dir);
318 			if (!*n_elem) {
319 				rc = -ENOMEM;
320 				goto prep_out;
321 			}
322 		} else if (task->task_proto & SAS_PROTOCOL_SMP) {
323 			*n_elem_req = dma_map_sg(dev, &task->smp_task.smp_req,
324 						 1, DMA_TO_DEVICE);
325 			if (!*n_elem_req) {
326 				rc = -ENOMEM;
327 				goto prep_out;
328 			}
329 			req_len = sg_dma_len(&task->smp_task.smp_req);
330 			if (req_len & 0x3) {
331 				rc = -EINVAL;
332 				goto err_out_dma_unmap;
333 			}
334 		}
335 	}
336 
337 	if (*n_elem > HISI_SAS_SGE_PAGE_CNT) {
338 		dev_err(dev, "task prep: n_elem(%d) > HISI_SAS_SGE_PAGE_CNT\n",
339 			*n_elem);
340 		rc = -EINVAL;
341 		goto err_out_dma_unmap;
342 	}
343 	return 0;
344 
345 err_out_dma_unmap:
346 	/* It would be better to call dma_unmap_sg() here, but it's messy */
347 	hisi_sas_dma_unmap(hisi_hba, task, *n_elem,
348 			   *n_elem_req);
349 prep_out:
350 	return rc;
351 }
352 
353 static void hisi_sas_dif_dma_unmap(struct hisi_hba *hisi_hba,
354 				   struct sas_task *task, int n_elem_dif)
355 {
356 	struct device *dev = hisi_hba->dev;
357 
358 	if (n_elem_dif) {
359 		struct sas_ssp_task *ssp_task = &task->ssp_task;
360 		struct scsi_cmnd *scsi_cmnd = ssp_task->cmd;
361 
362 		dma_unmap_sg(dev, scsi_prot_sglist(scsi_cmnd),
363 			     scsi_prot_sg_count(scsi_cmnd),
364 			     task->data_dir);
365 	}
366 }
367 
368 static int hisi_sas_dif_dma_map(struct hisi_hba *hisi_hba,
369 				int *n_elem_dif, struct sas_task *task)
370 {
371 	struct device *dev = hisi_hba->dev;
372 	struct sas_ssp_task *ssp_task;
373 	struct scsi_cmnd *scsi_cmnd;
374 	int rc;
375 
376 	if (task->num_scatter) {
377 		ssp_task = &task->ssp_task;
378 		scsi_cmnd = ssp_task->cmd;
379 
380 		if (scsi_prot_sg_count(scsi_cmnd)) {
381 			*n_elem_dif = dma_map_sg(dev,
382 						 scsi_prot_sglist(scsi_cmnd),
383 						 scsi_prot_sg_count(scsi_cmnd),
384 						 task->data_dir);
385 
386 			if (!*n_elem_dif)
387 				return -ENOMEM;
388 
389 			if (*n_elem_dif > HISI_SAS_SGE_DIF_PAGE_CNT) {
390 				dev_err(dev, "task prep: n_elem_dif(%d) too large\n",
391 					*n_elem_dif);
392 				rc = -EINVAL;
393 				goto err_out_dif_dma_unmap;
394 			}
395 		}
396 	}
397 
398 	return 0;
399 
400 err_out_dif_dma_unmap:
401 	dma_unmap_sg(dev, scsi_prot_sglist(scsi_cmnd),
402 		     scsi_prot_sg_count(scsi_cmnd), task->data_dir);
403 	return rc;
404 }
405 
406 static int hisi_sas_task_prep(struct sas_task *task,
407 			      struct hisi_sas_dq **dq_pointer,
408 			      bool is_tmf, struct hisi_sas_tmf_task *tmf,
409 			      int *pass)
410 {
411 	struct domain_device *device = task->dev;
412 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
413 	struct hisi_sas_device *sas_dev = device->lldd_dev;
414 	struct hisi_sas_port *port;
415 	struct hisi_sas_slot *slot;
416 	struct hisi_sas_cmd_hdr	*cmd_hdr_base;
417 	struct asd_sas_port *sas_port = device->port;
418 	struct device *dev = hisi_hba->dev;
419 	int dlvry_queue_slot, dlvry_queue, rc, slot_idx;
420 	int n_elem = 0, n_elem_dif = 0, n_elem_req = 0;
421 	struct scsi_cmnd *scmd = NULL;
422 	struct hisi_sas_dq *dq;
423 	unsigned long flags;
424 	int wr_q_index;
425 
426 	if (DEV_IS_GONE(sas_dev)) {
427 		if (sas_dev)
428 			dev_info(dev, "task prep: device %d not ready\n",
429 				 sas_dev->device_id);
430 		else
431 			dev_info(dev, "task prep: device %016llx not ready\n",
432 				 SAS_ADDR(device->sas_addr));
433 
434 		return -ECOMM;
435 	}
436 
437 	if (task->uldd_task) {
438 		struct ata_queued_cmd *qc;
439 
440 		if (dev_is_sata(device)) {
441 			qc = task->uldd_task;
442 			scmd = qc->scsicmd;
443 		} else {
444 			scmd = task->uldd_task;
445 		}
446 	}
447 
448 	if (scmd) {
449 		unsigned int dq_index;
450 		u32 blk_tag;
451 
452 		blk_tag = blk_mq_unique_tag(scmd->request);
453 		dq_index = blk_mq_unique_tag_to_hwq(blk_tag);
454 		*dq_pointer = dq = &hisi_hba->dq[dq_index];
455 	} else {
456 		struct Scsi_Host *shost = hisi_hba->shost;
457 		struct blk_mq_queue_map *qmap = &shost->tag_set.map[HCTX_TYPE_DEFAULT];
458 		int queue = qmap->mq_map[raw_smp_processor_id()];
459 
460 		*dq_pointer = dq = &hisi_hba->dq[queue];
461 	}
462 
463 	port = to_hisi_sas_port(sas_port);
464 	if (port && !port->port_attached) {
465 		dev_info(dev, "task prep: %s port%d not attach device\n",
466 			 (dev_is_sata(device)) ?
467 			 "SATA/STP" : "SAS",
468 			 device->port->id);
469 
470 		return -ECOMM;
471 	}
472 
473 	rc = hisi_sas_dma_map(hisi_hba, task, &n_elem,
474 			      &n_elem_req);
475 	if (rc < 0)
476 		goto prep_out;
477 
478 	if (!sas_protocol_ata(task->task_proto)) {
479 		rc = hisi_sas_dif_dma_map(hisi_hba, &n_elem_dif, task);
480 		if (rc < 0)
481 			goto err_out_dma_unmap;
482 	}
483 
484 	if (hisi_hba->hw->slot_index_alloc)
485 		rc = hisi_hba->hw->slot_index_alloc(hisi_hba, device);
486 	else
487 		rc = hisi_sas_slot_index_alloc(hisi_hba, scmd);
488 
489 	if (rc < 0)
490 		goto err_out_dif_dma_unmap;
491 
492 	slot_idx = rc;
493 	slot = &hisi_hba->slot_info[slot_idx];
494 
495 	spin_lock(&dq->lock);
496 	wr_q_index = dq->wr_point;
497 	dq->wr_point = (dq->wr_point + 1) % HISI_SAS_QUEUE_SLOTS;
498 	list_add_tail(&slot->delivery, &dq->list);
499 	spin_unlock(&dq->lock);
500 	spin_lock(&sas_dev->lock);
501 	list_add_tail(&slot->entry, &sas_dev->list);
502 	spin_unlock(&sas_dev->lock);
503 
504 	dlvry_queue = dq->id;
505 	dlvry_queue_slot = wr_q_index;
506 
507 	slot->device_id = sas_dev->device_id;
508 	slot->n_elem = n_elem;
509 	slot->n_elem_dif = n_elem_dif;
510 	slot->dlvry_queue = dlvry_queue;
511 	slot->dlvry_queue_slot = dlvry_queue_slot;
512 	cmd_hdr_base = hisi_hba->cmd_hdr[dlvry_queue];
513 	slot->cmd_hdr = &cmd_hdr_base[dlvry_queue_slot];
514 	slot->task = task;
515 	slot->port = port;
516 	slot->tmf = tmf;
517 	slot->is_internal = is_tmf;
518 	task->lldd_task = slot;
519 
520 	memset(slot->cmd_hdr, 0, sizeof(struct hisi_sas_cmd_hdr));
521 	memset(hisi_sas_cmd_hdr_addr_mem(slot), 0, HISI_SAS_COMMAND_TABLE_SZ);
522 	memset(hisi_sas_status_buf_addr_mem(slot), 0,
523 	       sizeof(struct hisi_sas_err_record));
524 
525 	switch (task->task_proto) {
526 	case SAS_PROTOCOL_SMP:
527 		hisi_sas_task_prep_smp(hisi_hba, slot);
528 		break;
529 	case SAS_PROTOCOL_SSP:
530 		hisi_sas_task_prep_ssp(hisi_hba, slot);
531 		break;
532 	case SAS_PROTOCOL_SATA:
533 	case SAS_PROTOCOL_STP:
534 	case SAS_PROTOCOL_SATA | SAS_PROTOCOL_STP:
535 		hisi_sas_task_prep_ata(hisi_hba, slot);
536 		break;
537 	default:
538 		dev_err(dev, "task prep: unknown/unsupported proto (0x%x)\n",
539 			task->task_proto);
540 		break;
541 	}
542 
543 	spin_lock_irqsave(&task->task_state_lock, flags);
544 	task->task_state_flags |= SAS_TASK_AT_INITIATOR;
545 	spin_unlock_irqrestore(&task->task_state_lock, flags);
546 
547 	++(*pass);
548 	WRITE_ONCE(slot->ready, 1);
549 
550 	return 0;
551 
552 err_out_dif_dma_unmap:
553 	if (!sas_protocol_ata(task->task_proto))
554 		hisi_sas_dif_dma_unmap(hisi_hba, task, n_elem_dif);
555 err_out_dma_unmap:
556 	hisi_sas_dma_unmap(hisi_hba, task, n_elem,
557 			   n_elem_req);
558 prep_out:
559 	dev_err(dev, "task prep: failed[%d]!\n", rc);
560 	return rc;
561 }
562 
563 static int hisi_sas_task_exec(struct sas_task *task, gfp_t gfp_flags,
564 			      bool is_tmf, struct hisi_sas_tmf_task *tmf)
565 {
566 	u32 rc;
567 	u32 pass = 0;
568 	struct hisi_hba *hisi_hba;
569 	struct device *dev;
570 	struct domain_device *device = task->dev;
571 	struct asd_sas_port *sas_port = device->port;
572 	struct hisi_sas_dq *dq = NULL;
573 
574 	if (!sas_port) {
575 		struct task_status_struct *ts = &task->task_status;
576 
577 		ts->resp = SAS_TASK_UNDELIVERED;
578 		ts->stat = SAS_PHY_DOWN;
579 		/*
580 		 * libsas will use dev->port, should
581 		 * not call task_done for sata
582 		 */
583 		if (device->dev_type != SAS_SATA_DEV)
584 			task->task_done(task);
585 		return -ECOMM;
586 	}
587 
588 	hisi_hba = dev_to_hisi_hba(device);
589 	dev = hisi_hba->dev;
590 
591 	if (unlikely(test_bit(HISI_SAS_REJECT_CMD_BIT, &hisi_hba->flags))) {
592 		if (!gfpflags_allow_blocking(gfp_flags))
593 			return -EINVAL;
594 
595 		down(&hisi_hba->sem);
596 		up(&hisi_hba->sem);
597 	}
598 
599 	/* protect task_prep and start_delivery sequence */
600 	rc = hisi_sas_task_prep(task, &dq, is_tmf, tmf, &pass);
601 	if (rc)
602 		dev_err(dev, "task exec: failed[%d]!\n", rc);
603 
604 	if (likely(pass)) {
605 		spin_lock(&dq->lock);
606 		hisi_hba->hw->start_delivery(dq);
607 		spin_unlock(&dq->lock);
608 	}
609 
610 	return rc;
611 }
612 
613 static void hisi_sas_bytes_dmaed(struct hisi_hba *hisi_hba, int phy_no,
614 				 gfp_t gfp_flags)
615 {
616 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
617 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
618 
619 	if (!phy->phy_attached)
620 		return;
621 
622 	if (test_bit(HISI_SAS_PM_BIT, &hisi_hba->flags) &&
623 	    !sas_phy->suspended) {
624 		dev_warn(hisi_hba->dev, "phy%d during suspend filtered out\n", phy_no);
625 		return;
626 	}
627 
628 	sas_notify_phy_event(sas_phy, PHYE_OOB_DONE, gfp_flags);
629 
630 	if (sas_phy->phy) {
631 		struct sas_phy *sphy = sas_phy->phy;
632 
633 		sphy->negotiated_linkrate = sas_phy->linkrate;
634 		sphy->minimum_linkrate_hw = SAS_LINK_RATE_1_5_GBPS;
635 		sphy->maximum_linkrate_hw =
636 			hisi_hba->hw->phy_get_max_linkrate();
637 		if (sphy->minimum_linkrate == SAS_LINK_RATE_UNKNOWN)
638 			sphy->minimum_linkrate = phy->minimum_linkrate;
639 
640 		if (sphy->maximum_linkrate == SAS_LINK_RATE_UNKNOWN)
641 			sphy->maximum_linkrate = phy->maximum_linkrate;
642 	}
643 
644 	if (phy->phy_type & PORT_TYPE_SAS) {
645 		struct sas_identify_frame *id;
646 
647 		id = (struct sas_identify_frame *)phy->frame_rcvd;
648 		id->dev_type = phy->identify.device_type;
649 		id->initiator_bits = SAS_PROTOCOL_ALL;
650 		id->target_bits = phy->identify.target_port_protocols;
651 	} else if (phy->phy_type & PORT_TYPE_SATA) {
652 		/* Nothing */
653 	}
654 
655 	sas_phy->frame_rcvd_size = phy->frame_rcvd_size;
656 	sas_notify_port_event(sas_phy, PORTE_BYTES_DMAED, gfp_flags);
657 }
658 
659 static struct hisi_sas_device *hisi_sas_alloc_dev(struct domain_device *device)
660 {
661 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
662 	struct hisi_sas_device *sas_dev = NULL;
663 	int last = hisi_hba->last_dev_id;
664 	int first = (hisi_hba->last_dev_id + 1) % HISI_SAS_MAX_DEVICES;
665 	int i;
666 
667 	spin_lock(&hisi_hba->lock);
668 	for (i = first; i != last; i %= HISI_SAS_MAX_DEVICES) {
669 		if (hisi_hba->devices[i].dev_type == SAS_PHY_UNUSED) {
670 			int queue = i % hisi_hba->queue_count;
671 			struct hisi_sas_dq *dq = &hisi_hba->dq[queue];
672 
673 			hisi_hba->devices[i].device_id = i;
674 			sas_dev = &hisi_hba->devices[i];
675 			sas_dev->dev_status = HISI_SAS_DEV_INIT;
676 			sas_dev->dev_type = device->dev_type;
677 			sas_dev->hisi_hba = hisi_hba;
678 			sas_dev->sas_device = device;
679 			sas_dev->dq = dq;
680 			spin_lock_init(&sas_dev->lock);
681 			INIT_LIST_HEAD(&hisi_hba->devices[i].list);
682 			break;
683 		}
684 		i++;
685 	}
686 	hisi_hba->last_dev_id = i;
687 	spin_unlock(&hisi_hba->lock);
688 
689 	return sas_dev;
690 }
691 
692 #define HISI_SAS_DISK_RECOVER_CNT 3
693 static int hisi_sas_init_device(struct domain_device *device)
694 {
695 	int rc = TMF_RESP_FUNC_COMPLETE;
696 	struct scsi_lun lun;
697 	struct hisi_sas_tmf_task tmf_task;
698 	int retry = HISI_SAS_DISK_RECOVER_CNT;
699 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
700 	struct device *dev = hisi_hba->dev;
701 	struct sas_phy *local_phy;
702 
703 	switch (device->dev_type) {
704 	case SAS_END_DEVICE:
705 		int_to_scsilun(0, &lun);
706 
707 		tmf_task.tmf = TMF_CLEAR_TASK_SET;
708 		while (retry-- > 0) {
709 			rc = hisi_sas_debug_issue_ssp_tmf(device, lun.scsi_lun,
710 							  &tmf_task);
711 			if (rc == TMF_RESP_FUNC_COMPLETE) {
712 				hisi_sas_release_task(hisi_hba, device);
713 				break;
714 			}
715 		}
716 		break;
717 	case SAS_SATA_DEV:
718 	case SAS_SATA_PM:
719 	case SAS_SATA_PM_PORT:
720 	case SAS_SATA_PENDING:
721 		/*
722 		 * send HARD RESET to clear previous affiliation of
723 		 * STP target port
724 		 */
725 		local_phy = sas_get_local_phy(device);
726 		if (!scsi_is_sas_phy_local(local_phy) &&
727 		    !test_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags)) {
728 			unsigned long deadline = ata_deadline(jiffies, 20000);
729 			struct sata_device *sata_dev = &device->sata_dev;
730 			struct ata_host *ata_host = sata_dev->ata_host;
731 			struct ata_port_operations *ops = ata_host->ops;
732 			struct ata_port *ap = sata_dev->ap;
733 			struct ata_link *link;
734 			unsigned int classes;
735 
736 			ata_for_each_link(link, ap, EDGE)
737 				rc = ops->hardreset(link, &classes,
738 						    deadline);
739 		}
740 		sas_put_local_phy(local_phy);
741 		if (rc) {
742 			dev_warn(dev, "SATA disk hardreset fail: %d\n", rc);
743 			return rc;
744 		}
745 
746 		while (retry-- > 0) {
747 			rc = hisi_sas_softreset_ata_disk(device);
748 			if (!rc)
749 				break;
750 		}
751 		break;
752 	default:
753 		break;
754 	}
755 
756 	return rc;
757 }
758 
759 static int hisi_sas_dev_found(struct domain_device *device)
760 {
761 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
762 	struct domain_device *parent_dev = device->parent;
763 	struct hisi_sas_device *sas_dev;
764 	struct device *dev = hisi_hba->dev;
765 	int rc;
766 
767 	if (hisi_hba->hw->alloc_dev)
768 		sas_dev = hisi_hba->hw->alloc_dev(device);
769 	else
770 		sas_dev = hisi_sas_alloc_dev(device);
771 	if (!sas_dev) {
772 		dev_err(dev, "fail alloc dev: max support %d devices\n",
773 			HISI_SAS_MAX_DEVICES);
774 		return -EINVAL;
775 	}
776 
777 	device->lldd_dev = sas_dev;
778 	hisi_hba->hw->setup_itct(hisi_hba, sas_dev);
779 
780 	if (parent_dev && dev_is_expander(parent_dev->dev_type)) {
781 		int phy_no;
782 		u8 phy_num = parent_dev->ex_dev.num_phys;
783 		struct ex_phy *phy;
784 
785 		for (phy_no = 0; phy_no < phy_num; phy_no++) {
786 			phy = &parent_dev->ex_dev.ex_phy[phy_no];
787 			if (SAS_ADDR(phy->attached_sas_addr) ==
788 				SAS_ADDR(device->sas_addr))
789 				break;
790 		}
791 
792 		if (phy_no == phy_num) {
793 			dev_info(dev, "dev found: no attached "
794 				 "dev:%016llx at ex:%016llx\n",
795 				 SAS_ADDR(device->sas_addr),
796 				 SAS_ADDR(parent_dev->sas_addr));
797 			rc = -EINVAL;
798 			goto err_out;
799 		}
800 	}
801 
802 	dev_info(dev, "dev[%d:%x] found\n",
803 		sas_dev->device_id, sas_dev->dev_type);
804 
805 	rc = hisi_sas_init_device(device);
806 	if (rc)
807 		goto err_out;
808 	sas_dev->dev_status = HISI_SAS_DEV_NORMAL;
809 	return 0;
810 
811 err_out:
812 	hisi_sas_dev_gone(device);
813 	return rc;
814 }
815 
816 int hisi_sas_slave_configure(struct scsi_device *sdev)
817 {
818 	struct domain_device *dev = sdev_to_domain_dev(sdev);
819 	int ret = sas_slave_configure(sdev);
820 
821 	if (ret)
822 		return ret;
823 	if (!dev_is_sata(dev))
824 		sas_change_queue_depth(sdev, 64);
825 
826 	return 0;
827 }
828 EXPORT_SYMBOL_GPL(hisi_sas_slave_configure);
829 
830 void hisi_sas_scan_start(struct Scsi_Host *shost)
831 {
832 	struct hisi_hba *hisi_hba = shost_priv(shost);
833 
834 	hisi_hba->hw->phys_init(hisi_hba);
835 }
836 EXPORT_SYMBOL_GPL(hisi_sas_scan_start);
837 
838 int hisi_sas_scan_finished(struct Scsi_Host *shost, unsigned long time)
839 {
840 	struct hisi_hba *hisi_hba = shost_priv(shost);
841 	struct sas_ha_struct *sha = &hisi_hba->sha;
842 
843 	/* Wait for PHY up interrupt to occur */
844 	if (time < HZ)
845 		return 0;
846 
847 	sas_drain_work(sha);
848 	return 1;
849 }
850 EXPORT_SYMBOL_GPL(hisi_sas_scan_finished);
851 
852 static void hisi_sas_phyup_work(struct work_struct *work)
853 {
854 	struct hisi_sas_phy *phy =
855 		container_of(work, typeof(*phy), works[HISI_PHYE_PHY_UP]);
856 	struct hisi_hba *hisi_hba = phy->hisi_hba;
857 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
858 	int phy_no = sas_phy->id;
859 
860 	if (phy->identify.target_port_protocols == SAS_PROTOCOL_SSP)
861 		hisi_hba->hw->sl_notify_ssp(hisi_hba, phy_no);
862 	hisi_sas_bytes_dmaed(hisi_hba, phy_no, GFP_KERNEL);
863 }
864 
865 static void hisi_sas_linkreset_work(struct work_struct *work)
866 {
867 	struct hisi_sas_phy *phy =
868 		container_of(work, typeof(*phy), works[HISI_PHYE_LINK_RESET]);
869 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
870 
871 	hisi_sas_control_phy(sas_phy, PHY_FUNC_LINK_RESET, NULL);
872 }
873 
874 static const work_func_t hisi_sas_phye_fns[HISI_PHYES_NUM] = {
875 	[HISI_PHYE_PHY_UP] = hisi_sas_phyup_work,
876 	[HISI_PHYE_LINK_RESET] = hisi_sas_linkreset_work,
877 };
878 
879 bool hisi_sas_notify_phy_event(struct hisi_sas_phy *phy,
880 				enum hisi_sas_phy_event event)
881 {
882 	struct hisi_hba *hisi_hba = phy->hisi_hba;
883 
884 	if (WARN_ON(event >= HISI_PHYES_NUM))
885 		return false;
886 
887 	return queue_work(hisi_hba->wq, &phy->works[event]);
888 }
889 EXPORT_SYMBOL_GPL(hisi_sas_notify_phy_event);
890 
891 static void hisi_sas_wait_phyup_timedout(struct timer_list *t)
892 {
893 	struct hisi_sas_phy *phy = from_timer(phy, t, timer);
894 	struct hisi_hba *hisi_hba = phy->hisi_hba;
895 	struct device *dev = hisi_hba->dev;
896 	int phy_no = phy->sas_phy.id;
897 
898 	dev_warn(dev, "phy%d wait phyup timeout, issuing link reset\n", phy_no);
899 	hisi_sas_notify_phy_event(phy, HISI_PHYE_LINK_RESET);
900 }
901 
902 void hisi_sas_phy_oob_ready(struct hisi_hba *hisi_hba, int phy_no)
903 {
904 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
905 	struct device *dev = hisi_hba->dev;
906 
907 	dev_dbg(dev, "phy%d OOB ready\n", phy_no);
908 	if (phy->phy_attached)
909 		return;
910 
911 	if (!timer_pending(&phy->timer)) {
912 		phy->timer.expires = jiffies + HISI_SAS_WAIT_PHYUP_TIMEOUT * HZ;
913 		add_timer(&phy->timer);
914 	}
915 }
916 EXPORT_SYMBOL_GPL(hisi_sas_phy_oob_ready);
917 
918 static void hisi_sas_phy_init(struct hisi_hba *hisi_hba, int phy_no)
919 {
920 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
921 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
922 	int i;
923 
924 	phy->hisi_hba = hisi_hba;
925 	phy->port = NULL;
926 	phy->minimum_linkrate = SAS_LINK_RATE_1_5_GBPS;
927 	phy->maximum_linkrate = hisi_hba->hw->phy_get_max_linkrate();
928 	sas_phy->enabled = (phy_no < hisi_hba->n_phy) ? 1 : 0;
929 	sas_phy->class = SAS;
930 	sas_phy->iproto = SAS_PROTOCOL_ALL;
931 	sas_phy->tproto = 0;
932 	sas_phy->type = PHY_TYPE_PHYSICAL;
933 	sas_phy->role = PHY_ROLE_INITIATOR;
934 	sas_phy->oob_mode = OOB_NOT_CONNECTED;
935 	sas_phy->linkrate = SAS_LINK_RATE_UNKNOWN;
936 	sas_phy->id = phy_no;
937 	sas_phy->sas_addr = &hisi_hba->sas_addr[0];
938 	sas_phy->frame_rcvd = &phy->frame_rcvd[0];
939 	sas_phy->ha = (struct sas_ha_struct *)hisi_hba->shost->hostdata;
940 	sas_phy->lldd_phy = phy;
941 
942 	for (i = 0; i < HISI_PHYES_NUM; i++)
943 		INIT_WORK(&phy->works[i], hisi_sas_phye_fns[i]);
944 
945 	spin_lock_init(&phy->lock);
946 
947 	timer_setup(&phy->timer, hisi_sas_wait_phyup_timedout, 0);
948 }
949 
950 /* Wrapper to ensure we track hisi_sas_phy.enable properly */
951 void hisi_sas_phy_enable(struct hisi_hba *hisi_hba, int phy_no, int enable)
952 {
953 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
954 	struct asd_sas_phy *aphy = &phy->sas_phy;
955 	struct sas_phy *sphy = aphy->phy;
956 	unsigned long flags;
957 
958 	spin_lock_irqsave(&phy->lock, flags);
959 
960 	if (enable) {
961 		/* We may have been enabled already; if so, don't touch */
962 		if (!phy->enable)
963 			sphy->negotiated_linkrate = SAS_LINK_RATE_UNKNOWN;
964 		hisi_hba->hw->phy_start(hisi_hba, phy_no);
965 	} else {
966 		sphy->negotiated_linkrate = SAS_PHY_DISABLED;
967 		hisi_hba->hw->phy_disable(hisi_hba, phy_no);
968 	}
969 	phy->enable = enable;
970 	spin_unlock_irqrestore(&phy->lock, flags);
971 }
972 EXPORT_SYMBOL_GPL(hisi_sas_phy_enable);
973 
974 static void hisi_sas_port_notify_formed(struct asd_sas_phy *sas_phy)
975 {
976 	struct sas_ha_struct *sas_ha = sas_phy->ha;
977 	struct hisi_hba *hisi_hba = sas_ha->lldd_ha;
978 	struct hisi_sas_phy *phy = sas_phy->lldd_phy;
979 	struct asd_sas_port *sas_port = sas_phy->port;
980 	struct hisi_sas_port *port;
981 	unsigned long flags;
982 
983 	if (!sas_port)
984 		return;
985 
986 	port = to_hisi_sas_port(sas_port);
987 	spin_lock_irqsave(&hisi_hba->lock, flags);
988 	port->port_attached = 1;
989 	port->id = phy->port_id;
990 	phy->port = port;
991 	sas_port->lldd_port = port;
992 	spin_unlock_irqrestore(&hisi_hba->lock, flags);
993 }
994 
995 static void hisi_sas_do_release_task(struct hisi_hba *hisi_hba, struct sas_task *task,
996 				     struct hisi_sas_slot *slot)
997 {
998 	if (task) {
999 		unsigned long flags;
1000 		struct task_status_struct *ts;
1001 
1002 		ts = &task->task_status;
1003 
1004 		ts->resp = SAS_TASK_COMPLETE;
1005 		ts->stat = SAS_ABORTED_TASK;
1006 		spin_lock_irqsave(&task->task_state_lock, flags);
1007 		task->task_state_flags &=
1008 			~(SAS_TASK_STATE_PENDING | SAS_TASK_AT_INITIATOR);
1009 		if (!slot->is_internal && task->task_proto != SAS_PROTOCOL_SMP)
1010 			task->task_state_flags |= SAS_TASK_STATE_DONE;
1011 		spin_unlock_irqrestore(&task->task_state_lock, flags);
1012 	}
1013 
1014 	hisi_sas_slot_task_free(hisi_hba, task, slot);
1015 }
1016 
1017 static void hisi_sas_release_task(struct hisi_hba *hisi_hba,
1018 			struct domain_device *device)
1019 {
1020 	struct hisi_sas_slot *slot, *slot2;
1021 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1022 
1023 	list_for_each_entry_safe(slot, slot2, &sas_dev->list, entry)
1024 		hisi_sas_do_release_task(hisi_hba, slot->task, slot);
1025 }
1026 
1027 void hisi_sas_release_tasks(struct hisi_hba *hisi_hba)
1028 {
1029 	struct hisi_sas_device *sas_dev;
1030 	struct domain_device *device;
1031 	int i;
1032 
1033 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
1034 		sas_dev = &hisi_hba->devices[i];
1035 		device = sas_dev->sas_device;
1036 
1037 		if ((sas_dev->dev_type == SAS_PHY_UNUSED) ||
1038 		    !device)
1039 			continue;
1040 
1041 		hisi_sas_release_task(hisi_hba, device);
1042 	}
1043 }
1044 EXPORT_SYMBOL_GPL(hisi_sas_release_tasks);
1045 
1046 static void hisi_sas_dereg_device(struct hisi_hba *hisi_hba,
1047 				struct domain_device *device)
1048 {
1049 	if (hisi_hba->hw->dereg_device)
1050 		hisi_hba->hw->dereg_device(hisi_hba, device);
1051 }
1052 
1053 static void hisi_sas_dev_gone(struct domain_device *device)
1054 {
1055 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1056 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1057 	struct device *dev = hisi_hba->dev;
1058 	int ret = 0;
1059 
1060 	dev_info(dev, "dev[%d:%x] is gone\n",
1061 		 sas_dev->device_id, sas_dev->dev_type);
1062 
1063 	down(&hisi_hba->sem);
1064 	if (!test_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags)) {
1065 		hisi_sas_internal_task_abort(hisi_hba, device,
1066 					     HISI_SAS_INT_ABT_DEV, 0);
1067 
1068 		hisi_sas_dereg_device(hisi_hba, device);
1069 
1070 		ret = hisi_hba->hw->clear_itct(hisi_hba, sas_dev);
1071 		device->lldd_dev = NULL;
1072 	}
1073 
1074 	if (hisi_hba->hw->free_device)
1075 		hisi_hba->hw->free_device(sas_dev);
1076 
1077 	/* Don't mark it as SAS_PHY_UNUSED if failed to clear ITCT */
1078 	if (!ret)
1079 		sas_dev->dev_type = SAS_PHY_UNUSED;
1080 	sas_dev->sas_device = NULL;
1081 	up(&hisi_hba->sem);
1082 }
1083 
1084 static int hisi_sas_queue_command(struct sas_task *task, gfp_t gfp_flags)
1085 {
1086 	return hisi_sas_task_exec(task, gfp_flags, 0, NULL);
1087 }
1088 
1089 static int hisi_sas_phy_set_linkrate(struct hisi_hba *hisi_hba, int phy_no,
1090 			struct sas_phy_linkrates *r)
1091 {
1092 	struct sas_phy_linkrates _r;
1093 
1094 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
1095 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
1096 	enum sas_linkrate min, max;
1097 
1098 	if (r->minimum_linkrate > SAS_LINK_RATE_1_5_GBPS)
1099 		return -EINVAL;
1100 
1101 	if (r->maximum_linkrate == SAS_LINK_RATE_UNKNOWN) {
1102 		max = sas_phy->phy->maximum_linkrate;
1103 		min = r->minimum_linkrate;
1104 	} else if (r->minimum_linkrate == SAS_LINK_RATE_UNKNOWN) {
1105 		max = r->maximum_linkrate;
1106 		min = sas_phy->phy->minimum_linkrate;
1107 	} else
1108 		return -EINVAL;
1109 
1110 	_r.maximum_linkrate = max;
1111 	_r.minimum_linkrate = min;
1112 
1113 	sas_phy->phy->maximum_linkrate = max;
1114 	sas_phy->phy->minimum_linkrate = min;
1115 
1116 	hisi_sas_phy_enable(hisi_hba, phy_no, 0);
1117 	msleep(100);
1118 	hisi_hba->hw->phy_set_linkrate(hisi_hba, phy_no, &_r);
1119 	hisi_sas_phy_enable(hisi_hba, phy_no, 1);
1120 
1121 	return 0;
1122 }
1123 
1124 static int hisi_sas_control_phy(struct asd_sas_phy *sas_phy, enum phy_func func,
1125 				void *funcdata)
1126 {
1127 	struct sas_ha_struct *sas_ha = sas_phy->ha;
1128 	struct hisi_hba *hisi_hba = sas_ha->lldd_ha;
1129 	int phy_no = sas_phy->id;
1130 
1131 	switch (func) {
1132 	case PHY_FUNC_HARD_RESET:
1133 		hisi_hba->hw->phy_hard_reset(hisi_hba, phy_no);
1134 		break;
1135 
1136 	case PHY_FUNC_LINK_RESET:
1137 		hisi_sas_phy_enable(hisi_hba, phy_no, 0);
1138 		msleep(100);
1139 		hisi_sas_phy_enable(hisi_hba, phy_no, 1);
1140 		break;
1141 
1142 	case PHY_FUNC_DISABLE:
1143 		hisi_sas_phy_enable(hisi_hba, phy_no, 0);
1144 		break;
1145 
1146 	case PHY_FUNC_SET_LINK_RATE:
1147 		return hisi_sas_phy_set_linkrate(hisi_hba, phy_no, funcdata);
1148 	case PHY_FUNC_GET_EVENTS:
1149 		if (hisi_hba->hw->get_events) {
1150 			hisi_hba->hw->get_events(hisi_hba, phy_no);
1151 			break;
1152 		}
1153 		fallthrough;
1154 	case PHY_FUNC_RELEASE_SPINUP_HOLD:
1155 	default:
1156 		return -EOPNOTSUPP;
1157 	}
1158 	return 0;
1159 }
1160 
1161 static void hisi_sas_task_done(struct sas_task *task)
1162 {
1163 	del_timer(&task->slow_task->timer);
1164 	complete(&task->slow_task->completion);
1165 }
1166 
1167 static void hisi_sas_tmf_timedout(struct timer_list *t)
1168 {
1169 	struct sas_task_slow *slow = from_timer(slow, t, timer);
1170 	struct sas_task *task = slow->task;
1171 	unsigned long flags;
1172 	bool is_completed = true;
1173 
1174 	spin_lock_irqsave(&task->task_state_lock, flags);
1175 	if (!(task->task_state_flags & SAS_TASK_STATE_DONE)) {
1176 		task->task_state_flags |= SAS_TASK_STATE_ABORTED;
1177 		is_completed = false;
1178 	}
1179 	spin_unlock_irqrestore(&task->task_state_lock, flags);
1180 
1181 	if (!is_completed)
1182 		complete(&task->slow_task->completion);
1183 }
1184 
1185 #define TASK_TIMEOUT 20
1186 #define TASK_RETRY 3
1187 #define INTERNAL_ABORT_TIMEOUT 6
1188 static int hisi_sas_exec_internal_tmf_task(struct domain_device *device,
1189 					   void *parameter, u32 para_len,
1190 					   struct hisi_sas_tmf_task *tmf)
1191 {
1192 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1193 	struct hisi_hba *hisi_hba = sas_dev->hisi_hba;
1194 	struct device *dev = hisi_hba->dev;
1195 	struct sas_task *task;
1196 	int res, retry;
1197 
1198 	for (retry = 0; retry < TASK_RETRY; retry++) {
1199 		task = sas_alloc_slow_task(GFP_KERNEL);
1200 		if (!task)
1201 			return -ENOMEM;
1202 
1203 		task->dev = device;
1204 		task->task_proto = device->tproto;
1205 
1206 		if (dev_is_sata(device)) {
1207 			task->ata_task.device_control_reg_update = 1;
1208 			memcpy(&task->ata_task.fis, parameter, para_len);
1209 		} else {
1210 			memcpy(&task->ssp_task, parameter, para_len);
1211 		}
1212 		task->task_done = hisi_sas_task_done;
1213 
1214 		task->slow_task->timer.function = hisi_sas_tmf_timedout;
1215 		task->slow_task->timer.expires = jiffies + TASK_TIMEOUT * HZ;
1216 		add_timer(&task->slow_task->timer);
1217 
1218 		res = hisi_sas_task_exec(task, GFP_KERNEL, 1, tmf);
1219 
1220 		if (res) {
1221 			del_timer(&task->slow_task->timer);
1222 			dev_err(dev, "abort tmf: executing internal task failed: %d\n",
1223 				res);
1224 			goto ex_err;
1225 		}
1226 
1227 		wait_for_completion(&task->slow_task->completion);
1228 		res = TMF_RESP_FUNC_FAILED;
1229 		/* Even TMF timed out, return direct. */
1230 		if ((task->task_state_flags & SAS_TASK_STATE_ABORTED)) {
1231 			if (!(task->task_state_flags & SAS_TASK_STATE_DONE)) {
1232 				struct hisi_sas_slot *slot = task->lldd_task;
1233 
1234 				dev_err(dev, "abort tmf: TMF task timeout and not done\n");
1235 				if (slot) {
1236 					struct hisi_sas_cq *cq =
1237 					       &hisi_hba->cq[slot->dlvry_queue];
1238 					/*
1239 					 * sync irq to avoid free'ing task
1240 					 * before using task in IO completion
1241 					 */
1242 					synchronize_irq(cq->irq_no);
1243 					slot->task = NULL;
1244 				}
1245 
1246 				goto ex_err;
1247 			} else
1248 				dev_err(dev, "abort tmf: TMF task timeout\n");
1249 		}
1250 
1251 		if (task->task_status.resp == SAS_TASK_COMPLETE &&
1252 		     task->task_status.stat == TMF_RESP_FUNC_COMPLETE) {
1253 			res = TMF_RESP_FUNC_COMPLETE;
1254 			break;
1255 		}
1256 
1257 		if (task->task_status.resp == SAS_TASK_COMPLETE &&
1258 			task->task_status.stat == TMF_RESP_FUNC_SUCC) {
1259 			res = TMF_RESP_FUNC_SUCC;
1260 			break;
1261 		}
1262 
1263 		if (task->task_status.resp == SAS_TASK_COMPLETE &&
1264 		      task->task_status.stat == SAS_DATA_UNDERRUN) {
1265 			/* no error, but return the number of bytes of
1266 			 * underrun
1267 			 */
1268 			dev_warn(dev, "abort tmf: task to dev %016llx resp: 0x%x sts 0x%x underrun\n",
1269 				 SAS_ADDR(device->sas_addr),
1270 				 task->task_status.resp,
1271 				 task->task_status.stat);
1272 			res = task->task_status.residual;
1273 			break;
1274 		}
1275 
1276 		if (task->task_status.resp == SAS_TASK_COMPLETE &&
1277 			task->task_status.stat == SAS_DATA_OVERRUN) {
1278 			dev_warn(dev, "abort tmf: blocked task error\n");
1279 			res = -EMSGSIZE;
1280 			break;
1281 		}
1282 
1283 		if (task->task_status.resp == SAS_TASK_COMPLETE &&
1284 		    task->task_status.stat == SAS_OPEN_REJECT) {
1285 			dev_warn(dev, "abort tmf: open reject failed\n");
1286 			res = -EIO;
1287 		} else {
1288 			dev_warn(dev, "abort tmf: task to dev %016llx resp: 0x%x status 0x%x\n",
1289 				 SAS_ADDR(device->sas_addr),
1290 				 task->task_status.resp,
1291 				 task->task_status.stat);
1292 		}
1293 		sas_free_task(task);
1294 		task = NULL;
1295 	}
1296 ex_err:
1297 	if (retry == TASK_RETRY)
1298 		dev_warn(dev, "abort tmf: executing internal task failed!\n");
1299 	sas_free_task(task);
1300 	return res;
1301 }
1302 
1303 static void hisi_sas_fill_ata_reset_cmd(struct ata_device *dev,
1304 		bool reset, int pmp, u8 *fis)
1305 {
1306 	struct ata_taskfile tf;
1307 
1308 	ata_tf_init(dev, &tf);
1309 	if (reset)
1310 		tf.ctl |= ATA_SRST;
1311 	else
1312 		tf.ctl &= ~ATA_SRST;
1313 	tf.command = ATA_CMD_DEV_RESET;
1314 	ata_tf_to_fis(&tf, pmp, 0, fis);
1315 }
1316 
1317 static int hisi_sas_softreset_ata_disk(struct domain_device *device)
1318 {
1319 	u8 fis[20] = {0};
1320 	struct ata_port *ap = device->sata_dev.ap;
1321 	struct ata_link *link;
1322 	int rc = TMF_RESP_FUNC_FAILED;
1323 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1324 	struct device *dev = hisi_hba->dev;
1325 	int s = sizeof(struct host_to_dev_fis);
1326 
1327 	ata_for_each_link(link, ap, EDGE) {
1328 		int pmp = sata_srst_pmp(link);
1329 
1330 		hisi_sas_fill_ata_reset_cmd(link->device, 1, pmp, fis);
1331 		rc = hisi_sas_exec_internal_tmf_task(device, fis, s, NULL);
1332 		if (rc != TMF_RESP_FUNC_COMPLETE)
1333 			break;
1334 	}
1335 
1336 	if (rc == TMF_RESP_FUNC_COMPLETE) {
1337 		ata_for_each_link(link, ap, EDGE) {
1338 			int pmp = sata_srst_pmp(link);
1339 
1340 			hisi_sas_fill_ata_reset_cmd(link->device, 0, pmp, fis);
1341 			rc = hisi_sas_exec_internal_tmf_task(device, fis,
1342 							     s, NULL);
1343 			if (rc != TMF_RESP_FUNC_COMPLETE)
1344 				dev_err(dev, "ata disk de-reset failed\n");
1345 		}
1346 	} else {
1347 		dev_err(dev, "ata disk reset failed\n");
1348 	}
1349 
1350 	if (rc == TMF_RESP_FUNC_COMPLETE)
1351 		hisi_sas_release_task(hisi_hba, device);
1352 
1353 	return rc;
1354 }
1355 
1356 static int hisi_sas_debug_issue_ssp_tmf(struct domain_device *device,
1357 				u8 *lun, struct hisi_sas_tmf_task *tmf)
1358 {
1359 	struct sas_ssp_task ssp_task;
1360 
1361 	if (!(device->tproto & SAS_PROTOCOL_SSP))
1362 		return TMF_RESP_FUNC_ESUPP;
1363 
1364 	memcpy(ssp_task.LUN, lun, 8);
1365 
1366 	return hisi_sas_exec_internal_tmf_task(device, &ssp_task,
1367 				sizeof(ssp_task), tmf);
1368 }
1369 
1370 static void hisi_sas_refresh_port_id(struct hisi_hba *hisi_hba)
1371 {
1372 	u32 state = hisi_hba->hw->get_phys_state(hisi_hba);
1373 	int i;
1374 
1375 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
1376 		struct hisi_sas_device *sas_dev = &hisi_hba->devices[i];
1377 		struct domain_device *device = sas_dev->sas_device;
1378 		struct asd_sas_port *sas_port;
1379 		struct hisi_sas_port *port;
1380 		struct hisi_sas_phy *phy = NULL;
1381 		struct asd_sas_phy *sas_phy;
1382 
1383 		if ((sas_dev->dev_type == SAS_PHY_UNUSED)
1384 				|| !device || !device->port)
1385 			continue;
1386 
1387 		sas_port = device->port;
1388 		port = to_hisi_sas_port(sas_port);
1389 
1390 		list_for_each_entry(sas_phy, &sas_port->phy_list, port_phy_el)
1391 			if (state & BIT(sas_phy->id)) {
1392 				phy = sas_phy->lldd_phy;
1393 				break;
1394 			}
1395 
1396 		if (phy) {
1397 			port->id = phy->port_id;
1398 
1399 			/* Update linkrate of directly attached device. */
1400 			if (!device->parent)
1401 				device->linkrate = phy->sas_phy.linkrate;
1402 
1403 			hisi_hba->hw->setup_itct(hisi_hba, sas_dev);
1404 		} else
1405 			port->id = 0xff;
1406 	}
1407 }
1408 
1409 static void hisi_sas_rescan_topology(struct hisi_hba *hisi_hba, u32 state)
1410 {
1411 	struct asd_sas_port *_sas_port = NULL;
1412 	int phy_no;
1413 
1414 	for (phy_no = 0; phy_no < hisi_hba->n_phy; phy_no++) {
1415 		struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
1416 		struct asd_sas_phy *sas_phy = &phy->sas_phy;
1417 		struct asd_sas_port *sas_port = sas_phy->port;
1418 		bool do_port_check = _sas_port != sas_port;
1419 
1420 		if (!sas_phy->phy->enabled)
1421 			continue;
1422 
1423 		/* Report PHY state change to libsas */
1424 		if (state & BIT(phy_no)) {
1425 			if (do_port_check && sas_port && sas_port->port_dev) {
1426 				struct domain_device *dev = sas_port->port_dev;
1427 
1428 				_sas_port = sas_port;
1429 
1430 				if (dev_is_expander(dev->dev_type))
1431 					sas_notify_port_event(sas_phy,
1432 							PORTE_BROADCAST_RCVD,
1433 							GFP_KERNEL);
1434 			}
1435 		} else {
1436 			hisi_sas_phy_down(hisi_hba, phy_no, 0, GFP_KERNEL);
1437 		}
1438 	}
1439 }
1440 
1441 static void hisi_sas_reset_init_all_devices(struct hisi_hba *hisi_hba)
1442 {
1443 	struct hisi_sas_device *sas_dev;
1444 	struct domain_device *device;
1445 	int i;
1446 
1447 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
1448 		sas_dev = &hisi_hba->devices[i];
1449 		device = sas_dev->sas_device;
1450 
1451 		if ((sas_dev->dev_type == SAS_PHY_UNUSED) || !device)
1452 			continue;
1453 
1454 		hisi_sas_init_device(device);
1455 	}
1456 }
1457 
1458 static void hisi_sas_send_ata_reset_each_phy(struct hisi_hba *hisi_hba,
1459 					     struct asd_sas_port *sas_port,
1460 					     struct domain_device *device)
1461 {
1462 	struct hisi_sas_tmf_task tmf_task = { .force_phy = 1 };
1463 	struct ata_port *ap = device->sata_dev.ap;
1464 	struct device *dev = hisi_hba->dev;
1465 	int s = sizeof(struct host_to_dev_fis);
1466 	int rc = TMF_RESP_FUNC_FAILED;
1467 	struct asd_sas_phy *sas_phy;
1468 	struct ata_link *link;
1469 	u8 fis[20] = {0};
1470 	u32 state;
1471 
1472 	state = hisi_hba->hw->get_phys_state(hisi_hba);
1473 	list_for_each_entry(sas_phy, &sas_port->phy_list, port_phy_el) {
1474 		if (!(state & BIT(sas_phy->id)))
1475 			continue;
1476 
1477 		ata_for_each_link(link, ap, EDGE) {
1478 			int pmp = sata_srst_pmp(link);
1479 
1480 			tmf_task.phy_id = sas_phy->id;
1481 			hisi_sas_fill_ata_reset_cmd(link->device, 1, pmp, fis);
1482 			rc = hisi_sas_exec_internal_tmf_task(device, fis, s,
1483 							     &tmf_task);
1484 			if (rc != TMF_RESP_FUNC_COMPLETE) {
1485 				dev_err(dev, "phy%d ata reset failed rc=%d\n",
1486 					sas_phy->id, rc);
1487 				break;
1488 			}
1489 		}
1490 	}
1491 }
1492 
1493 static void hisi_sas_terminate_stp_reject(struct hisi_hba *hisi_hba)
1494 {
1495 	struct device *dev = hisi_hba->dev;
1496 	int port_no, rc, i;
1497 
1498 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
1499 		struct hisi_sas_device *sas_dev = &hisi_hba->devices[i];
1500 		struct domain_device *device = sas_dev->sas_device;
1501 
1502 		if ((sas_dev->dev_type == SAS_PHY_UNUSED) || !device)
1503 			continue;
1504 
1505 		rc = hisi_sas_internal_task_abort(hisi_hba, device,
1506 						  HISI_SAS_INT_ABT_DEV, 0);
1507 		if (rc < 0)
1508 			dev_err(dev, "STP reject: abort dev failed %d\n", rc);
1509 	}
1510 
1511 	for (port_no = 0; port_no < hisi_hba->n_phy; port_no++) {
1512 		struct hisi_sas_port *port = &hisi_hba->port[port_no];
1513 		struct asd_sas_port *sas_port = &port->sas_port;
1514 		struct domain_device *port_dev = sas_port->port_dev;
1515 		struct domain_device *device;
1516 
1517 		if (!port_dev || !dev_is_expander(port_dev->dev_type))
1518 			continue;
1519 
1520 		/* Try to find a SATA device */
1521 		list_for_each_entry(device, &sas_port->dev_list,
1522 				    dev_list_node) {
1523 			if (dev_is_sata(device)) {
1524 				hisi_sas_send_ata_reset_each_phy(hisi_hba,
1525 								 sas_port,
1526 								 device);
1527 				break;
1528 			}
1529 		}
1530 	}
1531 }
1532 
1533 void hisi_sas_controller_reset_prepare(struct hisi_hba *hisi_hba)
1534 {
1535 	struct Scsi_Host *shost = hisi_hba->shost;
1536 
1537 	down(&hisi_hba->sem);
1538 	hisi_hba->phy_state = hisi_hba->hw->get_phys_state(hisi_hba);
1539 
1540 	scsi_block_requests(shost);
1541 	hisi_hba->hw->wait_cmds_complete_timeout(hisi_hba, 100, 5000);
1542 
1543 	if (timer_pending(&hisi_hba->timer))
1544 		del_timer_sync(&hisi_hba->timer);
1545 
1546 	set_bit(HISI_SAS_REJECT_CMD_BIT, &hisi_hba->flags);
1547 }
1548 EXPORT_SYMBOL_GPL(hisi_sas_controller_reset_prepare);
1549 
1550 void hisi_sas_controller_reset_done(struct hisi_hba *hisi_hba)
1551 {
1552 	struct Scsi_Host *shost = hisi_hba->shost;
1553 
1554 	/* Init and wait for PHYs to come up and all libsas event finished. */
1555 	hisi_hba->hw->phys_init(hisi_hba);
1556 	msleep(1000);
1557 	hisi_sas_refresh_port_id(hisi_hba);
1558 	clear_bit(HISI_SAS_REJECT_CMD_BIT, &hisi_hba->flags);
1559 
1560 	if (hisi_hba->reject_stp_links_msk)
1561 		hisi_sas_terminate_stp_reject(hisi_hba);
1562 	hisi_sas_reset_init_all_devices(hisi_hba);
1563 	up(&hisi_hba->sem);
1564 	scsi_unblock_requests(shost);
1565 	clear_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags);
1566 
1567 	hisi_sas_rescan_topology(hisi_hba, hisi_hba->phy_state);
1568 }
1569 EXPORT_SYMBOL_GPL(hisi_sas_controller_reset_done);
1570 
1571 static int hisi_sas_controller_reset(struct hisi_hba *hisi_hba)
1572 {
1573 	struct device *dev = hisi_hba->dev;
1574 	struct Scsi_Host *shost = hisi_hba->shost;
1575 	int rc;
1576 
1577 	if (hisi_sas_debugfs_enable && hisi_hba->debugfs_itct[0].itct)
1578 		queue_work(hisi_hba->wq, &hisi_hba->debugfs_work);
1579 
1580 	if (!hisi_hba->hw->soft_reset)
1581 		return -1;
1582 
1583 	if (test_and_set_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags))
1584 		return -1;
1585 
1586 	dev_info(dev, "controller resetting...\n");
1587 	hisi_sas_controller_reset_prepare(hisi_hba);
1588 
1589 	rc = hisi_hba->hw->soft_reset(hisi_hba);
1590 	if (rc) {
1591 		dev_warn(dev, "controller reset failed (%d)\n", rc);
1592 		clear_bit(HISI_SAS_REJECT_CMD_BIT, &hisi_hba->flags);
1593 		up(&hisi_hba->sem);
1594 		scsi_unblock_requests(shost);
1595 		clear_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags);
1596 		return rc;
1597 	}
1598 
1599 	hisi_sas_controller_reset_done(hisi_hba);
1600 	dev_info(dev, "controller reset complete\n");
1601 
1602 	return 0;
1603 }
1604 
1605 static int hisi_sas_abort_task(struct sas_task *task)
1606 {
1607 	struct scsi_lun lun;
1608 	struct hisi_sas_tmf_task tmf_task;
1609 	struct domain_device *device = task->dev;
1610 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1611 	struct hisi_hba *hisi_hba;
1612 	struct device *dev;
1613 	int rc = TMF_RESP_FUNC_FAILED;
1614 	unsigned long flags;
1615 
1616 	if (!sas_dev)
1617 		return TMF_RESP_FUNC_FAILED;
1618 
1619 	hisi_hba = dev_to_hisi_hba(task->dev);
1620 	dev = hisi_hba->dev;
1621 
1622 	spin_lock_irqsave(&task->task_state_lock, flags);
1623 	if (task->task_state_flags & SAS_TASK_STATE_DONE) {
1624 		struct hisi_sas_slot *slot = task->lldd_task;
1625 		struct hisi_sas_cq *cq;
1626 
1627 		if (slot) {
1628 			/*
1629 			 * sync irq to avoid free'ing task
1630 			 * before using task in IO completion
1631 			 */
1632 			cq = &hisi_hba->cq[slot->dlvry_queue];
1633 			synchronize_irq(cq->irq_no);
1634 		}
1635 		spin_unlock_irqrestore(&task->task_state_lock, flags);
1636 		rc = TMF_RESP_FUNC_COMPLETE;
1637 		goto out;
1638 	}
1639 	task->task_state_flags |= SAS_TASK_STATE_ABORTED;
1640 	spin_unlock_irqrestore(&task->task_state_lock, flags);
1641 
1642 	if (task->lldd_task && task->task_proto & SAS_PROTOCOL_SSP) {
1643 		struct scsi_cmnd *cmnd = task->uldd_task;
1644 		struct hisi_sas_slot *slot = task->lldd_task;
1645 		u16 tag = slot->idx;
1646 		int rc2;
1647 
1648 		int_to_scsilun(cmnd->device->lun, &lun);
1649 		tmf_task.tmf = TMF_ABORT_TASK;
1650 		tmf_task.tag_of_task_to_be_managed = tag;
1651 
1652 		rc = hisi_sas_debug_issue_ssp_tmf(task->dev, lun.scsi_lun,
1653 						  &tmf_task);
1654 
1655 		rc2 = hisi_sas_internal_task_abort(hisi_hba, device,
1656 						   HISI_SAS_INT_ABT_CMD, tag);
1657 		if (rc2 < 0) {
1658 			dev_err(dev, "abort task: internal abort (%d)\n", rc2);
1659 			return TMF_RESP_FUNC_FAILED;
1660 		}
1661 
1662 		/*
1663 		 * If the TMF finds that the IO is not in the device and also
1664 		 * the internal abort does not succeed, then it is safe to
1665 		 * free the slot.
1666 		 * Note: if the internal abort succeeds then the slot
1667 		 * will have already been completed
1668 		 */
1669 		if (rc == TMF_RESP_FUNC_COMPLETE && rc2 != TMF_RESP_FUNC_SUCC) {
1670 			if (task->lldd_task)
1671 				hisi_sas_do_release_task(hisi_hba, task, slot);
1672 		}
1673 	} else if (task->task_proto & SAS_PROTOCOL_SATA ||
1674 		task->task_proto & SAS_PROTOCOL_STP) {
1675 		if (task->dev->dev_type == SAS_SATA_DEV) {
1676 			rc = hisi_sas_internal_task_abort(hisi_hba, device,
1677 							  HISI_SAS_INT_ABT_DEV,
1678 							  0);
1679 			if (rc < 0) {
1680 				dev_err(dev, "abort task: internal abort failed\n");
1681 				goto out;
1682 			}
1683 			hisi_sas_dereg_device(hisi_hba, device);
1684 			rc = hisi_sas_softreset_ata_disk(device);
1685 		}
1686 	} else if (task->lldd_task && task->task_proto & SAS_PROTOCOL_SMP) {
1687 		/* SMP */
1688 		struct hisi_sas_slot *slot = task->lldd_task;
1689 		u32 tag = slot->idx;
1690 		struct hisi_sas_cq *cq = &hisi_hba->cq[slot->dlvry_queue];
1691 
1692 		rc = hisi_sas_internal_task_abort(hisi_hba, device,
1693 						  HISI_SAS_INT_ABT_CMD, tag);
1694 		if (((rc < 0) || (rc == TMF_RESP_FUNC_FAILED)) &&
1695 					task->lldd_task) {
1696 			/*
1697 			 * sync irq to avoid free'ing task
1698 			 * before using task in IO completion
1699 			 */
1700 			synchronize_irq(cq->irq_no);
1701 			slot->task = NULL;
1702 		}
1703 	}
1704 
1705 out:
1706 	if (rc != TMF_RESP_FUNC_COMPLETE)
1707 		dev_notice(dev, "abort task: rc=%d\n", rc);
1708 	return rc;
1709 }
1710 
1711 static int hisi_sas_abort_task_set(struct domain_device *device, u8 *lun)
1712 {
1713 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1714 	struct device *dev = hisi_hba->dev;
1715 	struct hisi_sas_tmf_task tmf_task;
1716 	int rc;
1717 
1718 	rc = hisi_sas_internal_task_abort(hisi_hba, device,
1719 					  HISI_SAS_INT_ABT_DEV, 0);
1720 	if (rc < 0) {
1721 		dev_err(dev, "abort task set: internal abort rc=%d\n", rc);
1722 		return TMF_RESP_FUNC_FAILED;
1723 	}
1724 	hisi_sas_dereg_device(hisi_hba, device);
1725 
1726 	tmf_task.tmf = TMF_ABORT_TASK_SET;
1727 	rc = hisi_sas_debug_issue_ssp_tmf(device, lun, &tmf_task);
1728 
1729 	if (rc == TMF_RESP_FUNC_COMPLETE)
1730 		hisi_sas_release_task(hisi_hba, device);
1731 
1732 	return rc;
1733 }
1734 
1735 static int hisi_sas_clear_aca(struct domain_device *device, u8 *lun)
1736 {
1737 	struct hisi_sas_tmf_task tmf_task;
1738 	int rc;
1739 
1740 	tmf_task.tmf = TMF_CLEAR_ACA;
1741 	rc = hisi_sas_debug_issue_ssp_tmf(device, lun, &tmf_task);
1742 
1743 	return rc;
1744 }
1745 
1746 static int hisi_sas_debug_I_T_nexus_reset(struct domain_device *device)
1747 {
1748 	struct sas_phy *local_phy = sas_get_local_phy(device);
1749 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1750 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1751 	struct sas_ha_struct *sas_ha = &hisi_hba->sha;
1752 	DECLARE_COMPLETION_ONSTACK(phyreset);
1753 	int rc, reset_type;
1754 
1755 	if (!local_phy->enabled) {
1756 		sas_put_local_phy(local_phy);
1757 		return -ENODEV;
1758 	}
1759 
1760 	if (scsi_is_sas_phy_local(local_phy)) {
1761 		struct asd_sas_phy *sas_phy =
1762 			sas_ha->sas_phy[local_phy->number];
1763 		struct hisi_sas_phy *phy =
1764 			container_of(sas_phy, struct hisi_sas_phy, sas_phy);
1765 		phy->in_reset = 1;
1766 		phy->reset_completion = &phyreset;
1767 	}
1768 
1769 	reset_type = (sas_dev->dev_status == HISI_SAS_DEV_INIT ||
1770 		      !dev_is_sata(device)) ? true : false;
1771 
1772 	rc = sas_phy_reset(local_phy, reset_type);
1773 	sas_put_local_phy(local_phy);
1774 
1775 	if (scsi_is_sas_phy_local(local_phy)) {
1776 		struct asd_sas_phy *sas_phy =
1777 			sas_ha->sas_phy[local_phy->number];
1778 		struct hisi_sas_phy *phy =
1779 			container_of(sas_phy, struct hisi_sas_phy, sas_phy);
1780 		int ret = wait_for_completion_timeout(&phyreset, 2 * HZ);
1781 		unsigned long flags;
1782 
1783 		spin_lock_irqsave(&phy->lock, flags);
1784 		phy->reset_completion = NULL;
1785 		phy->in_reset = 0;
1786 		spin_unlock_irqrestore(&phy->lock, flags);
1787 
1788 		/* report PHY down if timed out */
1789 		if (!ret)
1790 			hisi_sas_phy_down(hisi_hba, sas_phy->id, 0, GFP_KERNEL);
1791 	} else if (sas_dev->dev_status != HISI_SAS_DEV_INIT) {
1792 		/*
1793 		 * If in init state, we rely on caller to wait for link to be
1794 		 * ready; otherwise, except phy reset is fail, delay.
1795 		 */
1796 		if (!rc)
1797 			msleep(2000);
1798 	}
1799 
1800 	return rc;
1801 }
1802 
1803 static int hisi_sas_I_T_nexus_reset(struct domain_device *device)
1804 {
1805 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1806 	struct device *dev = hisi_hba->dev;
1807 	int rc;
1808 
1809 	rc = hisi_sas_internal_task_abort(hisi_hba, device,
1810 					  HISI_SAS_INT_ABT_DEV, 0);
1811 	if (rc < 0) {
1812 		dev_err(dev, "I_T nexus reset: internal abort (%d)\n", rc);
1813 		return TMF_RESP_FUNC_FAILED;
1814 	}
1815 	hisi_sas_dereg_device(hisi_hba, device);
1816 
1817 	if (dev_is_sata(device)) {
1818 		rc = hisi_sas_softreset_ata_disk(device);
1819 		if (rc == TMF_RESP_FUNC_FAILED)
1820 			return TMF_RESP_FUNC_FAILED;
1821 	}
1822 
1823 	rc = hisi_sas_debug_I_T_nexus_reset(device);
1824 
1825 	if ((rc == TMF_RESP_FUNC_COMPLETE) || (rc == -ENODEV))
1826 		hisi_sas_release_task(hisi_hba, device);
1827 
1828 	return rc;
1829 }
1830 
1831 static int hisi_sas_lu_reset(struct domain_device *device, u8 *lun)
1832 {
1833 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1834 	struct hisi_hba *hisi_hba = dev_to_hisi_hba(device);
1835 	struct device *dev = hisi_hba->dev;
1836 	int rc = TMF_RESP_FUNC_FAILED;
1837 
1838 	/* Clear internal IO and then lu reset */
1839 	rc = hisi_sas_internal_task_abort(hisi_hba, device,
1840 					  HISI_SAS_INT_ABT_DEV, 0);
1841 	if (rc < 0) {
1842 		dev_err(dev, "lu_reset: internal abort failed\n");
1843 		goto out;
1844 	}
1845 	hisi_sas_dereg_device(hisi_hba, device);
1846 
1847 	if (dev_is_sata(device)) {
1848 		struct sas_phy *phy;
1849 
1850 		phy = sas_get_local_phy(device);
1851 
1852 		rc = sas_phy_reset(phy, true);
1853 
1854 		if (rc == 0)
1855 			hisi_sas_release_task(hisi_hba, device);
1856 		sas_put_local_phy(phy);
1857 	} else {
1858 		struct hisi_sas_tmf_task tmf_task = { .tmf =  TMF_LU_RESET };
1859 
1860 		rc = hisi_sas_debug_issue_ssp_tmf(device, lun, &tmf_task);
1861 		if (rc == TMF_RESP_FUNC_COMPLETE)
1862 			hisi_sas_release_task(hisi_hba, device);
1863 	}
1864 out:
1865 	if (rc != TMF_RESP_FUNC_COMPLETE)
1866 		dev_err(dev, "lu_reset: for device[%d]:rc= %d\n",
1867 			     sas_dev->device_id, rc);
1868 	return rc;
1869 }
1870 
1871 static int hisi_sas_clear_nexus_ha(struct sas_ha_struct *sas_ha)
1872 {
1873 	struct hisi_hba *hisi_hba = sas_ha->lldd_ha;
1874 	struct device *dev = hisi_hba->dev;
1875 	HISI_SAS_DECLARE_RST_WORK_ON_STACK(r);
1876 	int rc, i;
1877 
1878 	queue_work(hisi_hba->wq, &r.work);
1879 	wait_for_completion(r.completion);
1880 	if (!r.done)
1881 		return TMF_RESP_FUNC_FAILED;
1882 
1883 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
1884 		struct hisi_sas_device *sas_dev = &hisi_hba->devices[i];
1885 		struct domain_device *device = sas_dev->sas_device;
1886 
1887 		if ((sas_dev->dev_type == SAS_PHY_UNUSED) || !device ||
1888 		    dev_is_expander(device->dev_type))
1889 			continue;
1890 
1891 		rc = hisi_sas_debug_I_T_nexus_reset(device);
1892 		if (rc != TMF_RESP_FUNC_COMPLETE)
1893 			dev_info(dev, "clear nexus ha: for device[%d] rc=%d\n",
1894 				 sas_dev->device_id, rc);
1895 	}
1896 
1897 	hisi_sas_release_tasks(hisi_hba);
1898 
1899 	return TMF_RESP_FUNC_COMPLETE;
1900 }
1901 
1902 static int hisi_sas_query_task(struct sas_task *task)
1903 {
1904 	struct scsi_lun lun;
1905 	struct hisi_sas_tmf_task tmf_task;
1906 	int rc = TMF_RESP_FUNC_FAILED;
1907 
1908 	if (task->lldd_task && task->task_proto & SAS_PROTOCOL_SSP) {
1909 		struct scsi_cmnd *cmnd = task->uldd_task;
1910 		struct domain_device *device = task->dev;
1911 		struct hisi_sas_slot *slot = task->lldd_task;
1912 		u32 tag = slot->idx;
1913 
1914 		int_to_scsilun(cmnd->device->lun, &lun);
1915 		tmf_task.tmf = TMF_QUERY_TASK;
1916 		tmf_task.tag_of_task_to_be_managed = tag;
1917 
1918 		rc = hisi_sas_debug_issue_ssp_tmf(device,
1919 						  lun.scsi_lun,
1920 						  &tmf_task);
1921 		switch (rc) {
1922 		/* The task is still in Lun, release it then */
1923 		case TMF_RESP_FUNC_SUCC:
1924 		/* The task is not in Lun or failed, reset the phy */
1925 		case TMF_RESP_FUNC_FAILED:
1926 		case TMF_RESP_FUNC_COMPLETE:
1927 			break;
1928 		default:
1929 			rc = TMF_RESP_FUNC_FAILED;
1930 			break;
1931 		}
1932 	}
1933 	return rc;
1934 }
1935 
1936 static int
1937 hisi_sas_internal_abort_task_exec(struct hisi_hba *hisi_hba, int device_id,
1938 				  struct sas_task *task, int abort_flag,
1939 				  int task_tag, struct hisi_sas_dq *dq)
1940 {
1941 	struct domain_device *device = task->dev;
1942 	struct hisi_sas_device *sas_dev = device->lldd_dev;
1943 	struct device *dev = hisi_hba->dev;
1944 	struct hisi_sas_port *port;
1945 	struct hisi_sas_slot *slot;
1946 	struct asd_sas_port *sas_port = device->port;
1947 	struct hisi_sas_cmd_hdr *cmd_hdr_base;
1948 	int dlvry_queue_slot, dlvry_queue, n_elem = 0, rc, slot_idx;
1949 	unsigned long flags;
1950 	int wr_q_index;
1951 
1952 	if (unlikely(test_bit(HISI_SAS_REJECT_CMD_BIT, &hisi_hba->flags)))
1953 		return -EINVAL;
1954 
1955 	if (!device->port)
1956 		return -1;
1957 
1958 	port = to_hisi_sas_port(sas_port);
1959 
1960 	/* simply get a slot and send abort command */
1961 	rc = hisi_sas_slot_index_alloc(hisi_hba, NULL);
1962 	if (rc < 0)
1963 		goto err_out;
1964 
1965 	slot_idx = rc;
1966 	slot = &hisi_hba->slot_info[slot_idx];
1967 
1968 	spin_lock(&dq->lock);
1969 	wr_q_index = dq->wr_point;
1970 	dq->wr_point = (dq->wr_point + 1) % HISI_SAS_QUEUE_SLOTS;
1971 	list_add_tail(&slot->delivery, &dq->list);
1972 	spin_unlock(&dq->lock);
1973 	spin_lock(&sas_dev->lock);
1974 	list_add_tail(&slot->entry, &sas_dev->list);
1975 	spin_unlock(&sas_dev->lock);
1976 
1977 	dlvry_queue = dq->id;
1978 	dlvry_queue_slot = wr_q_index;
1979 
1980 	slot->device_id = sas_dev->device_id;
1981 	slot->n_elem = n_elem;
1982 	slot->dlvry_queue = dlvry_queue;
1983 	slot->dlvry_queue_slot = dlvry_queue_slot;
1984 	cmd_hdr_base = hisi_hba->cmd_hdr[dlvry_queue];
1985 	slot->cmd_hdr = &cmd_hdr_base[dlvry_queue_slot];
1986 	slot->task = task;
1987 	slot->port = port;
1988 	slot->is_internal = true;
1989 	task->lldd_task = slot;
1990 
1991 	memset(slot->cmd_hdr, 0, sizeof(struct hisi_sas_cmd_hdr));
1992 	memset(hisi_sas_cmd_hdr_addr_mem(slot), 0, HISI_SAS_COMMAND_TABLE_SZ);
1993 	memset(hisi_sas_status_buf_addr_mem(slot), 0,
1994 	       sizeof(struct hisi_sas_err_record));
1995 
1996 	hisi_sas_task_prep_abort(hisi_hba, slot, device_id,
1997 				      abort_flag, task_tag);
1998 
1999 	spin_lock_irqsave(&task->task_state_lock, flags);
2000 	task->task_state_flags |= SAS_TASK_AT_INITIATOR;
2001 	spin_unlock_irqrestore(&task->task_state_lock, flags);
2002 	WRITE_ONCE(slot->ready, 1);
2003 	/* send abort command to the chip */
2004 	spin_lock(&dq->lock);
2005 	hisi_hba->hw->start_delivery(dq);
2006 	spin_unlock(&dq->lock);
2007 
2008 	return 0;
2009 
2010 err_out:
2011 	dev_err(dev, "internal abort task prep: failed[%d]!\n", rc);
2012 
2013 	return rc;
2014 }
2015 
2016 /**
2017  * _hisi_sas_internal_task_abort -- execute an internal
2018  * abort command for single IO command or a device
2019  * @hisi_hba: host controller struct
2020  * @device: domain device
2021  * @abort_flag: mode of operation, device or single IO
2022  * @tag: tag of IO to be aborted (only relevant to single
2023  *       IO mode)
2024  * @dq: delivery queue for this internal abort command
2025  */
2026 static int
2027 _hisi_sas_internal_task_abort(struct hisi_hba *hisi_hba,
2028 			      struct domain_device *device, int abort_flag,
2029 			      int tag, struct hisi_sas_dq *dq)
2030 {
2031 	struct sas_task *task;
2032 	struct hisi_sas_device *sas_dev = device->lldd_dev;
2033 	struct device *dev = hisi_hba->dev;
2034 	int res;
2035 
2036 	/*
2037 	 * The interface is not realized means this HW don't support internal
2038 	 * abort, or don't need to do internal abort. Then here, we return
2039 	 * TMF_RESP_FUNC_FAILED and let other steps go on, which depends that
2040 	 * the internal abort has been executed and returned CQ.
2041 	 */
2042 	if (!hisi_hba->hw->prep_abort)
2043 		return TMF_RESP_FUNC_FAILED;
2044 
2045 	task = sas_alloc_slow_task(GFP_KERNEL);
2046 	if (!task)
2047 		return -ENOMEM;
2048 
2049 	task->dev = device;
2050 	task->task_proto = device->tproto;
2051 	task->task_done = hisi_sas_task_done;
2052 	task->slow_task->timer.function = hisi_sas_tmf_timedout;
2053 	task->slow_task->timer.expires = jiffies + INTERNAL_ABORT_TIMEOUT * HZ;
2054 	add_timer(&task->slow_task->timer);
2055 
2056 	res = hisi_sas_internal_abort_task_exec(hisi_hba, sas_dev->device_id,
2057 						task, abort_flag, tag, dq);
2058 	if (res) {
2059 		del_timer(&task->slow_task->timer);
2060 		dev_err(dev, "internal task abort: executing internal task failed: %d\n",
2061 			res);
2062 		goto exit;
2063 	}
2064 	wait_for_completion(&task->slow_task->completion);
2065 	res = TMF_RESP_FUNC_FAILED;
2066 
2067 	/* Internal abort timed out */
2068 	if ((task->task_state_flags & SAS_TASK_STATE_ABORTED)) {
2069 		if (hisi_sas_debugfs_enable && hisi_hba->debugfs_itct[0].itct)
2070 			queue_work(hisi_hba->wq, &hisi_hba->debugfs_work);
2071 
2072 		if (!(task->task_state_flags & SAS_TASK_STATE_DONE)) {
2073 			struct hisi_sas_slot *slot = task->lldd_task;
2074 
2075 			if (slot) {
2076 				struct hisi_sas_cq *cq =
2077 					&hisi_hba->cq[slot->dlvry_queue];
2078 				/*
2079 				 * sync irq to avoid free'ing task
2080 				 * before using task in IO completion
2081 				 */
2082 				synchronize_irq(cq->irq_no);
2083 				slot->task = NULL;
2084 			}
2085 			dev_err(dev, "internal task abort: timeout and not done.\n");
2086 
2087 			res = -EIO;
2088 			goto exit;
2089 		} else
2090 			dev_err(dev, "internal task abort: timeout.\n");
2091 	}
2092 
2093 	if (task->task_status.resp == SAS_TASK_COMPLETE &&
2094 		task->task_status.stat == TMF_RESP_FUNC_COMPLETE) {
2095 		res = TMF_RESP_FUNC_COMPLETE;
2096 		goto exit;
2097 	}
2098 
2099 	if (task->task_status.resp == SAS_TASK_COMPLETE &&
2100 		task->task_status.stat == TMF_RESP_FUNC_SUCC) {
2101 		res = TMF_RESP_FUNC_SUCC;
2102 		goto exit;
2103 	}
2104 
2105 exit:
2106 	dev_dbg(dev, "internal task abort: task to dev %016llx task=%pK resp: 0x%x sts 0x%x\n",
2107 		SAS_ADDR(device->sas_addr), task,
2108 		task->task_status.resp, /* 0 is complete, -1 is undelivered */
2109 		task->task_status.stat);
2110 	sas_free_task(task);
2111 
2112 	return res;
2113 }
2114 
2115 static int
2116 hisi_sas_internal_task_abort(struct hisi_hba *hisi_hba,
2117 			     struct domain_device *device,
2118 			     int abort_flag, int tag)
2119 {
2120 	struct hisi_sas_slot *slot;
2121 	struct device *dev = hisi_hba->dev;
2122 	struct hisi_sas_dq *dq;
2123 	int i, rc;
2124 
2125 	switch (abort_flag) {
2126 	case HISI_SAS_INT_ABT_CMD:
2127 		slot = &hisi_hba->slot_info[tag];
2128 		dq = &hisi_hba->dq[slot->dlvry_queue];
2129 		return _hisi_sas_internal_task_abort(hisi_hba, device,
2130 						     abort_flag, tag, dq);
2131 	case HISI_SAS_INT_ABT_DEV:
2132 		for (i = 0; i < hisi_hba->cq_nvecs; i++) {
2133 			struct hisi_sas_cq *cq = &hisi_hba->cq[i];
2134 			const struct cpumask *mask = cq->irq_mask;
2135 
2136 			if (mask && !cpumask_intersects(cpu_online_mask, mask))
2137 				continue;
2138 			dq = &hisi_hba->dq[i];
2139 			rc = _hisi_sas_internal_task_abort(hisi_hba, device,
2140 							   abort_flag, tag,
2141 							   dq);
2142 			if (rc)
2143 				return rc;
2144 		}
2145 		break;
2146 	default:
2147 		dev_err(dev, "Unrecognised internal abort flag (%d)\n",
2148 			abort_flag);
2149 		return -EINVAL;
2150 	}
2151 
2152 	return 0;
2153 }
2154 
2155 static void hisi_sas_port_formed(struct asd_sas_phy *sas_phy)
2156 {
2157 	hisi_sas_port_notify_formed(sas_phy);
2158 }
2159 
2160 static int hisi_sas_write_gpio(struct sas_ha_struct *sha, u8 reg_type,
2161 			u8 reg_index, u8 reg_count, u8 *write_data)
2162 {
2163 	struct hisi_hba *hisi_hba = sha->lldd_ha;
2164 
2165 	if (!hisi_hba->hw->write_gpio)
2166 		return -EOPNOTSUPP;
2167 
2168 	return hisi_hba->hw->write_gpio(hisi_hba, reg_type,
2169 				reg_index, reg_count, write_data);
2170 }
2171 
2172 static void hisi_sas_phy_disconnected(struct hisi_sas_phy *phy)
2173 {
2174 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
2175 	struct sas_phy *sphy = sas_phy->phy;
2176 	unsigned long flags;
2177 
2178 	phy->phy_attached = 0;
2179 	phy->phy_type = 0;
2180 	phy->port = NULL;
2181 
2182 	spin_lock_irqsave(&phy->lock, flags);
2183 	if (phy->enable)
2184 		sphy->negotiated_linkrate = SAS_LINK_RATE_UNKNOWN;
2185 	else
2186 		sphy->negotiated_linkrate = SAS_PHY_DISABLED;
2187 	spin_unlock_irqrestore(&phy->lock, flags);
2188 }
2189 
2190 void hisi_sas_phy_down(struct hisi_hba *hisi_hba, int phy_no, int rdy,
2191 		       gfp_t gfp_flags)
2192 {
2193 	struct hisi_sas_phy *phy = &hisi_hba->phy[phy_no];
2194 	struct asd_sas_phy *sas_phy = &phy->sas_phy;
2195 	struct device *dev = hisi_hba->dev;
2196 
2197 	if (rdy) {
2198 		/* Phy down but ready */
2199 		hisi_sas_bytes_dmaed(hisi_hba, phy_no, gfp_flags);
2200 		hisi_sas_port_notify_formed(sas_phy);
2201 	} else {
2202 		struct hisi_sas_port *port  = phy->port;
2203 
2204 		if (test_bit(HISI_SAS_RESET_BIT, &hisi_hba->flags) ||
2205 		    phy->in_reset) {
2206 			dev_info(dev, "ignore flutter phy%d down\n", phy_no);
2207 			return;
2208 		}
2209 		/* Phy down and not ready */
2210 		sas_notify_phy_event(sas_phy, PHYE_LOSS_OF_SIGNAL, gfp_flags);
2211 		sas_phy_disconnected(sas_phy);
2212 
2213 		if (port) {
2214 			if (phy->phy_type & PORT_TYPE_SAS) {
2215 				int port_id = port->id;
2216 
2217 				if (!hisi_hba->hw->get_wideport_bitmap(hisi_hba,
2218 								       port_id))
2219 					port->port_attached = 0;
2220 			} else if (phy->phy_type & PORT_TYPE_SATA)
2221 				port->port_attached = 0;
2222 		}
2223 		hisi_sas_phy_disconnected(phy);
2224 	}
2225 }
2226 EXPORT_SYMBOL_GPL(hisi_sas_phy_down);
2227 
2228 void hisi_sas_sync_irqs(struct hisi_hba *hisi_hba)
2229 {
2230 	int i;
2231 
2232 	for (i = 0; i < hisi_hba->cq_nvecs; i++) {
2233 		struct hisi_sas_cq *cq = &hisi_hba->cq[i];
2234 
2235 		synchronize_irq(cq->irq_no);
2236 	}
2237 }
2238 EXPORT_SYMBOL_GPL(hisi_sas_sync_irqs);
2239 
2240 int hisi_sas_host_reset(struct Scsi_Host *shost, int reset_type)
2241 {
2242 	struct hisi_hba *hisi_hba = shost_priv(shost);
2243 
2244 	if (reset_type != SCSI_ADAPTER_RESET)
2245 		return -EOPNOTSUPP;
2246 
2247 	queue_work(hisi_hba->wq, &hisi_hba->rst_work);
2248 
2249 	return 0;
2250 }
2251 EXPORT_SYMBOL_GPL(hisi_sas_host_reset);
2252 
2253 struct scsi_transport_template *hisi_sas_stt;
2254 EXPORT_SYMBOL_GPL(hisi_sas_stt);
2255 
2256 static struct sas_domain_function_template hisi_sas_transport_ops = {
2257 	.lldd_dev_found		= hisi_sas_dev_found,
2258 	.lldd_dev_gone		= hisi_sas_dev_gone,
2259 	.lldd_execute_task	= hisi_sas_queue_command,
2260 	.lldd_control_phy	= hisi_sas_control_phy,
2261 	.lldd_abort_task	= hisi_sas_abort_task,
2262 	.lldd_abort_task_set	= hisi_sas_abort_task_set,
2263 	.lldd_clear_aca		= hisi_sas_clear_aca,
2264 	.lldd_I_T_nexus_reset	= hisi_sas_I_T_nexus_reset,
2265 	.lldd_lu_reset		= hisi_sas_lu_reset,
2266 	.lldd_query_task	= hisi_sas_query_task,
2267 	.lldd_clear_nexus_ha	= hisi_sas_clear_nexus_ha,
2268 	.lldd_port_formed	= hisi_sas_port_formed,
2269 	.lldd_write_gpio	= hisi_sas_write_gpio,
2270 };
2271 
2272 void hisi_sas_init_mem(struct hisi_hba *hisi_hba)
2273 {
2274 	int i, s, j, max_command_entries = HISI_SAS_MAX_COMMANDS;
2275 	struct hisi_sas_breakpoint *sata_breakpoint = hisi_hba->sata_breakpoint;
2276 
2277 	for (i = 0; i < hisi_hba->queue_count; i++) {
2278 		struct hisi_sas_cq *cq = &hisi_hba->cq[i];
2279 		struct hisi_sas_dq *dq = &hisi_hba->dq[i];
2280 		struct hisi_sas_cmd_hdr *cmd_hdr = hisi_hba->cmd_hdr[i];
2281 
2282 		s = sizeof(struct hisi_sas_cmd_hdr);
2283 		for (j = 0; j < HISI_SAS_QUEUE_SLOTS; j++)
2284 			memset(&cmd_hdr[j], 0, s);
2285 
2286 		dq->wr_point = 0;
2287 
2288 		s = hisi_hba->hw->complete_hdr_size * HISI_SAS_QUEUE_SLOTS;
2289 		memset(hisi_hba->complete_hdr[i], 0, s);
2290 		cq->rd_point = 0;
2291 	}
2292 
2293 	s = sizeof(struct hisi_sas_initial_fis) * hisi_hba->n_phy;
2294 	memset(hisi_hba->initial_fis, 0, s);
2295 
2296 	s = max_command_entries * sizeof(struct hisi_sas_iost);
2297 	memset(hisi_hba->iost, 0, s);
2298 
2299 	s = max_command_entries * sizeof(struct hisi_sas_breakpoint);
2300 	memset(hisi_hba->breakpoint, 0, s);
2301 
2302 	s = sizeof(struct hisi_sas_sata_breakpoint);
2303 	for (j = 0; j < HISI_SAS_MAX_ITCT_ENTRIES; j++)
2304 		memset(&sata_breakpoint[j], 0, s);
2305 }
2306 EXPORT_SYMBOL_GPL(hisi_sas_init_mem);
2307 
2308 int hisi_sas_alloc(struct hisi_hba *hisi_hba)
2309 {
2310 	struct device *dev = hisi_hba->dev;
2311 	int i, j, s, max_command_entries = HISI_SAS_MAX_COMMANDS;
2312 	int max_command_entries_ru, sz_slot_buf_ru;
2313 	int blk_cnt, slots_per_blk;
2314 
2315 	sema_init(&hisi_hba->sem, 1);
2316 	spin_lock_init(&hisi_hba->lock);
2317 	for (i = 0; i < hisi_hba->n_phy; i++) {
2318 		hisi_sas_phy_init(hisi_hba, i);
2319 		hisi_hba->port[i].port_attached = 0;
2320 		hisi_hba->port[i].id = -1;
2321 	}
2322 
2323 	for (i = 0; i < HISI_SAS_MAX_DEVICES; i++) {
2324 		hisi_hba->devices[i].dev_type = SAS_PHY_UNUSED;
2325 		hisi_hba->devices[i].device_id = i;
2326 		hisi_hba->devices[i].dev_status = HISI_SAS_DEV_INIT;
2327 	}
2328 
2329 	for (i = 0; i < hisi_hba->queue_count; i++) {
2330 		struct hisi_sas_cq *cq = &hisi_hba->cq[i];
2331 		struct hisi_sas_dq *dq = &hisi_hba->dq[i];
2332 
2333 		/* Completion queue structure */
2334 		cq->id = i;
2335 		cq->hisi_hba = hisi_hba;
2336 
2337 		/* Delivery queue structure */
2338 		spin_lock_init(&dq->lock);
2339 		INIT_LIST_HEAD(&dq->list);
2340 		dq->id = i;
2341 		dq->hisi_hba = hisi_hba;
2342 
2343 		/* Delivery queue */
2344 		s = sizeof(struct hisi_sas_cmd_hdr) * HISI_SAS_QUEUE_SLOTS;
2345 		hisi_hba->cmd_hdr[i] = dmam_alloc_coherent(dev, s,
2346 						&hisi_hba->cmd_hdr_dma[i],
2347 						GFP_KERNEL);
2348 		if (!hisi_hba->cmd_hdr[i])
2349 			goto err_out;
2350 
2351 		/* Completion queue */
2352 		s = hisi_hba->hw->complete_hdr_size * HISI_SAS_QUEUE_SLOTS;
2353 		hisi_hba->complete_hdr[i] = dmam_alloc_coherent(dev, s,
2354 						&hisi_hba->complete_hdr_dma[i],
2355 						GFP_KERNEL);
2356 		if (!hisi_hba->complete_hdr[i])
2357 			goto err_out;
2358 	}
2359 
2360 	s = HISI_SAS_MAX_ITCT_ENTRIES * sizeof(struct hisi_sas_itct);
2361 	hisi_hba->itct = dmam_alloc_coherent(dev, s, &hisi_hba->itct_dma,
2362 					     GFP_KERNEL);
2363 	if (!hisi_hba->itct)
2364 		goto err_out;
2365 
2366 	hisi_hba->slot_info = devm_kcalloc(dev, max_command_entries,
2367 					   sizeof(struct hisi_sas_slot),
2368 					   GFP_KERNEL);
2369 	if (!hisi_hba->slot_info)
2370 		goto err_out;
2371 
2372 	/* roundup to avoid overly large block size */
2373 	max_command_entries_ru = roundup(max_command_entries, 64);
2374 	if (hisi_hba->prot_mask & HISI_SAS_DIX_PROT_MASK)
2375 		sz_slot_buf_ru = sizeof(struct hisi_sas_slot_dif_buf_table);
2376 	else
2377 		sz_slot_buf_ru = sizeof(struct hisi_sas_slot_buf_table);
2378 	sz_slot_buf_ru = roundup(sz_slot_buf_ru, 64);
2379 	s = max(lcm(max_command_entries_ru, sz_slot_buf_ru), PAGE_SIZE);
2380 	blk_cnt = (max_command_entries_ru * sz_slot_buf_ru) / s;
2381 	slots_per_blk = s / sz_slot_buf_ru;
2382 
2383 	for (i = 0; i < blk_cnt; i++) {
2384 		int slot_index = i * slots_per_blk;
2385 		dma_addr_t buf_dma;
2386 		void *buf;
2387 
2388 		buf = dmam_alloc_coherent(dev, s, &buf_dma,
2389 					  GFP_KERNEL);
2390 		if (!buf)
2391 			goto err_out;
2392 
2393 		for (j = 0; j < slots_per_blk; j++, slot_index++) {
2394 			struct hisi_sas_slot *slot;
2395 
2396 			slot = &hisi_hba->slot_info[slot_index];
2397 			slot->buf = buf;
2398 			slot->buf_dma = buf_dma;
2399 			slot->idx = slot_index;
2400 
2401 			buf += sz_slot_buf_ru;
2402 			buf_dma += sz_slot_buf_ru;
2403 		}
2404 	}
2405 
2406 	s = max_command_entries * sizeof(struct hisi_sas_iost);
2407 	hisi_hba->iost = dmam_alloc_coherent(dev, s, &hisi_hba->iost_dma,
2408 					     GFP_KERNEL);
2409 	if (!hisi_hba->iost)
2410 		goto err_out;
2411 
2412 	s = max_command_entries * sizeof(struct hisi_sas_breakpoint);
2413 	hisi_hba->breakpoint = dmam_alloc_coherent(dev, s,
2414 						   &hisi_hba->breakpoint_dma,
2415 						   GFP_KERNEL);
2416 	if (!hisi_hba->breakpoint)
2417 		goto err_out;
2418 
2419 	hisi_hba->slot_index_count = max_command_entries;
2420 	s = hisi_hba->slot_index_count / BITS_PER_BYTE;
2421 	hisi_hba->slot_index_tags = devm_kzalloc(dev, s, GFP_KERNEL);
2422 	if (!hisi_hba->slot_index_tags)
2423 		goto err_out;
2424 
2425 	s = sizeof(struct hisi_sas_initial_fis) * HISI_SAS_MAX_PHYS;
2426 	hisi_hba->initial_fis = dmam_alloc_coherent(dev, s,
2427 						    &hisi_hba->initial_fis_dma,
2428 						    GFP_KERNEL);
2429 	if (!hisi_hba->initial_fis)
2430 		goto err_out;
2431 
2432 	s = HISI_SAS_MAX_ITCT_ENTRIES * sizeof(struct hisi_sas_sata_breakpoint);
2433 	hisi_hba->sata_breakpoint = dmam_alloc_coherent(dev, s,
2434 					&hisi_hba->sata_breakpoint_dma,
2435 					GFP_KERNEL);
2436 	if (!hisi_hba->sata_breakpoint)
2437 		goto err_out;
2438 
2439 	hisi_sas_slot_index_init(hisi_hba);
2440 	hisi_hba->last_slot_index = HISI_SAS_UNRESERVED_IPTT;
2441 
2442 	hisi_hba->wq = create_singlethread_workqueue(dev_name(dev));
2443 	if (!hisi_hba->wq) {
2444 		dev_err(dev, "sas_alloc: failed to create workqueue\n");
2445 		goto err_out;
2446 	}
2447 
2448 	return 0;
2449 err_out:
2450 	return -ENOMEM;
2451 }
2452 EXPORT_SYMBOL_GPL(hisi_sas_alloc);
2453 
2454 void hisi_sas_free(struct hisi_hba *hisi_hba)
2455 {
2456 	int i;
2457 
2458 	for (i = 0; i < hisi_hba->n_phy; i++) {
2459 		struct hisi_sas_phy *phy = &hisi_hba->phy[i];
2460 
2461 		del_timer_sync(&phy->timer);
2462 	}
2463 
2464 	if (hisi_hba->wq)
2465 		destroy_workqueue(hisi_hba->wq);
2466 }
2467 EXPORT_SYMBOL_GPL(hisi_sas_free);
2468 
2469 void hisi_sas_rst_work_handler(struct work_struct *work)
2470 {
2471 	struct hisi_hba *hisi_hba =
2472 		container_of(work, struct hisi_hba, rst_work);
2473 
2474 	hisi_sas_controller_reset(hisi_hba);
2475 }
2476 EXPORT_SYMBOL_GPL(hisi_sas_rst_work_handler);
2477 
2478 void hisi_sas_sync_rst_work_handler(struct work_struct *work)
2479 {
2480 	struct hisi_sas_rst *rst =
2481 		container_of(work, struct hisi_sas_rst, work);
2482 
2483 	if (!hisi_sas_controller_reset(rst->hisi_hba))
2484 		rst->done = true;
2485 	complete(rst->completion);
2486 }
2487 EXPORT_SYMBOL_GPL(hisi_sas_sync_rst_work_handler);
2488 
2489 int hisi_sas_get_fw_info(struct hisi_hba *hisi_hba)
2490 {
2491 	struct device *dev = hisi_hba->dev;
2492 	struct platform_device *pdev = hisi_hba->platform_dev;
2493 	struct device_node *np = pdev ? pdev->dev.of_node : NULL;
2494 	struct clk *refclk;
2495 
2496 	if (device_property_read_u8_array(dev, "sas-addr", hisi_hba->sas_addr,
2497 					  SAS_ADDR_SIZE)) {
2498 		dev_err(dev, "could not get property sas-addr\n");
2499 		return -ENOENT;
2500 	}
2501 
2502 	if (np) {
2503 		/*
2504 		 * These properties are only required for platform device-based
2505 		 * controller with DT firmware.
2506 		 */
2507 		hisi_hba->ctrl = syscon_regmap_lookup_by_phandle(np,
2508 					"hisilicon,sas-syscon");
2509 		if (IS_ERR(hisi_hba->ctrl)) {
2510 			dev_err(dev, "could not get syscon\n");
2511 			return -ENOENT;
2512 		}
2513 
2514 		if (device_property_read_u32(dev, "ctrl-reset-reg",
2515 					     &hisi_hba->ctrl_reset_reg)) {
2516 			dev_err(dev, "could not get property ctrl-reset-reg\n");
2517 			return -ENOENT;
2518 		}
2519 
2520 		if (device_property_read_u32(dev, "ctrl-reset-sts-reg",
2521 					     &hisi_hba->ctrl_reset_sts_reg)) {
2522 			dev_err(dev, "could not get property ctrl-reset-sts-reg\n");
2523 			return -ENOENT;
2524 		}
2525 
2526 		if (device_property_read_u32(dev, "ctrl-clock-ena-reg",
2527 					     &hisi_hba->ctrl_clock_ena_reg)) {
2528 			dev_err(dev, "could not get property ctrl-clock-ena-reg\n");
2529 			return -ENOENT;
2530 		}
2531 	}
2532 
2533 	refclk = devm_clk_get(dev, NULL);
2534 	if (IS_ERR(refclk))
2535 		dev_dbg(dev, "no ref clk property\n");
2536 	else
2537 		hisi_hba->refclk_frequency_mhz = clk_get_rate(refclk) / 1000000;
2538 
2539 	if (device_property_read_u32(dev, "phy-count", &hisi_hba->n_phy)) {
2540 		dev_err(dev, "could not get property phy-count\n");
2541 		return -ENOENT;
2542 	}
2543 
2544 	if (device_property_read_u32(dev, "queue-count",
2545 				     &hisi_hba->queue_count)) {
2546 		dev_err(dev, "could not get property queue-count\n");
2547 		return -ENOENT;
2548 	}
2549 
2550 	return 0;
2551 }
2552 EXPORT_SYMBOL_GPL(hisi_sas_get_fw_info);
2553 
2554 static struct Scsi_Host *hisi_sas_shost_alloc(struct platform_device *pdev,
2555 					      const struct hisi_sas_hw *hw)
2556 {
2557 	struct resource *res;
2558 	struct Scsi_Host *shost;
2559 	struct hisi_hba *hisi_hba;
2560 	struct device *dev = &pdev->dev;
2561 	int error;
2562 
2563 	shost = scsi_host_alloc(hw->sht, sizeof(*hisi_hba));
2564 	if (!shost) {
2565 		dev_err(dev, "scsi host alloc failed\n");
2566 		return NULL;
2567 	}
2568 	hisi_hba = shost_priv(shost);
2569 
2570 	INIT_WORK(&hisi_hba->rst_work, hisi_sas_rst_work_handler);
2571 	hisi_hba->hw = hw;
2572 	hisi_hba->dev = dev;
2573 	hisi_hba->platform_dev = pdev;
2574 	hisi_hba->shost = shost;
2575 	SHOST_TO_SAS_HA(shost) = &hisi_hba->sha;
2576 
2577 	timer_setup(&hisi_hba->timer, NULL, 0);
2578 
2579 	if (hisi_sas_get_fw_info(hisi_hba) < 0)
2580 		goto err_out;
2581 
2582 	error = dma_set_mask_and_coherent(dev, DMA_BIT_MASK(64));
2583 	if (error)
2584 		error = dma_set_mask_and_coherent(dev, DMA_BIT_MASK(32));
2585 
2586 	if (error) {
2587 		dev_err(dev, "No usable DMA addressing method\n");
2588 		goto err_out;
2589 	}
2590 
2591 	hisi_hba->regs = devm_platform_ioremap_resource(pdev, 0);
2592 	if (IS_ERR(hisi_hba->regs))
2593 		goto err_out;
2594 
2595 	res = platform_get_resource(pdev, IORESOURCE_MEM, 1);
2596 	if (res) {
2597 		hisi_hba->sgpio_regs = devm_ioremap_resource(dev, res);
2598 		if (IS_ERR(hisi_hba->sgpio_regs))
2599 			goto err_out;
2600 	}
2601 
2602 	if (hisi_sas_alloc(hisi_hba)) {
2603 		hisi_sas_free(hisi_hba);
2604 		goto err_out;
2605 	}
2606 
2607 	return shost;
2608 err_out:
2609 	scsi_host_put(shost);
2610 	dev_err(dev, "shost alloc failed\n");
2611 	return NULL;
2612 }
2613 
2614 static int hisi_sas_interrupt_preinit(struct hisi_hba *hisi_hba)
2615 {
2616 	if (hisi_hba->hw->interrupt_preinit)
2617 		return hisi_hba->hw->interrupt_preinit(hisi_hba);
2618 	return 0;
2619 }
2620 
2621 int hisi_sas_probe(struct platform_device *pdev,
2622 		   const struct hisi_sas_hw *hw)
2623 {
2624 	struct Scsi_Host *shost;
2625 	struct hisi_hba *hisi_hba;
2626 	struct device *dev = &pdev->dev;
2627 	struct asd_sas_phy **arr_phy;
2628 	struct asd_sas_port **arr_port;
2629 	struct sas_ha_struct *sha;
2630 	int rc, phy_nr, port_nr, i;
2631 
2632 	shost = hisi_sas_shost_alloc(pdev, hw);
2633 	if (!shost)
2634 		return -ENOMEM;
2635 
2636 	sha = SHOST_TO_SAS_HA(shost);
2637 	hisi_hba = shost_priv(shost);
2638 	platform_set_drvdata(pdev, sha);
2639 
2640 	phy_nr = port_nr = hisi_hba->n_phy;
2641 
2642 	arr_phy = devm_kcalloc(dev, phy_nr, sizeof(void *), GFP_KERNEL);
2643 	arr_port = devm_kcalloc(dev, port_nr, sizeof(void *), GFP_KERNEL);
2644 	if (!arr_phy || !arr_port) {
2645 		rc = -ENOMEM;
2646 		goto err_out_ha;
2647 	}
2648 
2649 	sha->sas_phy = arr_phy;
2650 	sha->sas_port = arr_port;
2651 	sha->lldd_ha = hisi_hba;
2652 
2653 	shost->transportt = hisi_sas_stt;
2654 	shost->max_id = HISI_SAS_MAX_DEVICES;
2655 	shost->max_lun = ~0;
2656 	shost->max_channel = 1;
2657 	shost->max_cmd_len = 16;
2658 	if (hisi_hba->hw->slot_index_alloc) {
2659 		shost->can_queue = HISI_SAS_MAX_COMMANDS;
2660 		shost->cmd_per_lun = HISI_SAS_MAX_COMMANDS;
2661 	} else {
2662 		shost->can_queue = HISI_SAS_UNRESERVED_IPTT;
2663 		shost->cmd_per_lun = HISI_SAS_UNRESERVED_IPTT;
2664 	}
2665 
2666 	sha->sas_ha_name = DRV_NAME;
2667 	sha->dev = hisi_hba->dev;
2668 	sha->lldd_module = THIS_MODULE;
2669 	sha->sas_addr = &hisi_hba->sas_addr[0];
2670 	sha->num_phys = hisi_hba->n_phy;
2671 	sha->core.shost = hisi_hba->shost;
2672 
2673 	for (i = 0; i < hisi_hba->n_phy; i++) {
2674 		sha->sas_phy[i] = &hisi_hba->phy[i].sas_phy;
2675 		sha->sas_port[i] = &hisi_hba->port[i].sas_port;
2676 	}
2677 
2678 	rc = hisi_sas_interrupt_preinit(hisi_hba);
2679 	if (rc)
2680 		goto err_out_ha;
2681 
2682 	rc = scsi_add_host(shost, &pdev->dev);
2683 	if (rc)
2684 		goto err_out_ha;
2685 
2686 	rc = sas_register_ha(sha);
2687 	if (rc)
2688 		goto err_out_register_ha;
2689 
2690 	rc = hisi_hba->hw->hw_init(hisi_hba);
2691 	if (rc)
2692 		goto err_out_register_ha;
2693 
2694 	scsi_scan_host(shost);
2695 
2696 	return 0;
2697 
2698 err_out_register_ha:
2699 	scsi_remove_host(shost);
2700 err_out_ha:
2701 	hisi_sas_free(hisi_hba);
2702 	scsi_host_put(shost);
2703 	return rc;
2704 }
2705 EXPORT_SYMBOL_GPL(hisi_sas_probe);
2706 
2707 int hisi_sas_remove(struct platform_device *pdev)
2708 {
2709 	struct sas_ha_struct *sha = platform_get_drvdata(pdev);
2710 	struct hisi_hba *hisi_hba = sha->lldd_ha;
2711 	struct Scsi_Host *shost = sha->core.shost;
2712 
2713 	if (timer_pending(&hisi_hba->timer))
2714 		del_timer(&hisi_hba->timer);
2715 
2716 	sas_unregister_ha(sha);
2717 	sas_remove_host(sha->core.shost);
2718 
2719 	hisi_sas_free(hisi_hba);
2720 	scsi_host_put(shost);
2721 	return 0;
2722 }
2723 EXPORT_SYMBOL_GPL(hisi_sas_remove);
2724 
2725 #if IS_ENABLED(CONFIG_SCSI_HISI_SAS_DEBUGFS_DEFAULT_ENABLE)
2726 #define DEBUGFS_ENABLE_DEFAULT  "enabled"
2727 bool hisi_sas_debugfs_enable = true;
2728 u32 hisi_sas_debugfs_dump_count = 50;
2729 #else
2730 #define DEBUGFS_ENABLE_DEFAULT "disabled"
2731 bool hisi_sas_debugfs_enable;
2732 u32 hisi_sas_debugfs_dump_count = 1;
2733 #endif
2734 
2735 EXPORT_SYMBOL_GPL(hisi_sas_debugfs_enable);
2736 module_param_named(debugfs_enable, hisi_sas_debugfs_enable, bool, 0444);
2737 MODULE_PARM_DESC(hisi_sas_debugfs_enable,
2738 		 "Enable driver debugfs (default "DEBUGFS_ENABLE_DEFAULT")");
2739 
2740 EXPORT_SYMBOL_GPL(hisi_sas_debugfs_dump_count);
2741 module_param_named(debugfs_dump_count, hisi_sas_debugfs_dump_count, uint, 0444);
2742 MODULE_PARM_DESC(hisi_sas_debugfs_dump_count, "Number of debugfs dumps to allow");
2743 
2744 struct dentry *hisi_sas_debugfs_dir;
2745 EXPORT_SYMBOL_GPL(hisi_sas_debugfs_dir);
2746 
2747 static __init int hisi_sas_init(void)
2748 {
2749 	hisi_sas_stt = sas_domain_attach_transport(&hisi_sas_transport_ops);
2750 	if (!hisi_sas_stt)
2751 		return -ENOMEM;
2752 
2753 	if (hisi_sas_debugfs_enable) {
2754 		hisi_sas_debugfs_dir = debugfs_create_dir("hisi_sas", NULL);
2755 		if (hisi_sas_debugfs_dump_count > HISI_SAS_MAX_DEBUGFS_DUMP) {
2756 			pr_info("hisi_sas: Limiting debugfs dump count\n");
2757 			hisi_sas_debugfs_dump_count = HISI_SAS_MAX_DEBUGFS_DUMP;
2758 		}
2759 	}
2760 
2761 	return 0;
2762 }
2763 
2764 static __exit void hisi_sas_exit(void)
2765 {
2766 	sas_release_transport(hisi_sas_stt);
2767 
2768 	debugfs_remove(hisi_sas_debugfs_dir);
2769 }
2770 
2771 module_init(hisi_sas_init);
2772 module_exit(hisi_sas_exit);
2773 
2774 MODULE_LICENSE("GPL");
2775 MODULE_AUTHOR("John Garry <john.garry@huawei.com>");
2776 MODULE_DESCRIPTION("HISILICON SAS controller driver");
2777 MODULE_ALIAS("platform:" DRV_NAME);
2778