xref: /openbmc/linux/drivers/scsi/esas2r/esas2r_io.c (revision f052febd)
1 /*
2  *  linux/drivers/scsi/esas2r/esas2r_io.c
3  *      For use with ATTO ExpressSAS R6xx SAS/SATA RAID controllers
4  *
5  *  Copyright (c) 2001-2013 ATTO Technology, Inc.
6  *  (mailto:linuxdrivers@attotech.com)mpt3sas/mpt3sas_trigger_diag.
7  *
8  * This program is free software; you can redistribute it and/or
9  * modify it under the terms of the GNU General Public License
10  * as published by the Free Software Foundation; either version 2
11  * of the License, or (at your option) any later version.
12  *
13  * This program is distributed in the hope that it will be useful,
14  * but WITHOUT ANY WARRANTY; without even the implied warranty of
15  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
16  * GNU General Public License for more details.
17  *
18  * NO WARRANTY
19  * THE PROGRAM IS PROVIDED ON AN "AS IS" BASIS, WITHOUT WARRANTIES OR
20  * CONDITIONS OF ANY KIND, EITHER EXPRESS OR IMPLIED INCLUDING, WITHOUT
21  * LIMITATION, ANY WARRANTIES OR CONDITIONS OF TITLE, NON-INFRINGEMENT,
22  * MERCHANTABILITY OR FITNESS FOR A PARTICULAR PURPOSE. Each Recipient is
23  * solely responsible for determining the appropriateness of using and
24  * distributing the Program and assumes all risks associated with its
25  * exercise of rights under this Agreement, including but not limited to
26  * the risks and costs of program errors, damage to or loss of data,
27  * programs or equipment, and unavailability or interruption of operations.
28  *
29  * DISCLAIMER OF LIABILITY
30  * NEITHER RECIPIENT NOR ANY CONTRIBUTORS SHALL HAVE ANY LIABILITY FOR ANY
31  * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
32  * DAMAGES (INCLUDING WITHOUT LIMITATION LOST PROFITS), HOWEVER CAUSED AND
33  * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR
34  * TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE
35  * USE OR DISTRIBUTION OF THE PROGRAM OR THE EXERCISE OF ANY RIGHTS GRANTED
36  * HEREUNDER, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGES
37  *
38  * You should have received a copy of the GNU General Public License
39  * along with this program; if not, write to the Free Software
40  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301,
41  * USA.
42  */
43 
44 #include "esas2r.h"
45 
46 void esas2r_start_request(struct esas2r_adapter *a, struct esas2r_request *rq)
47 {
48 	struct esas2r_target *t = NULL;
49 	struct esas2r_request *startrq = rq;
50 	unsigned long flags;
51 
52 	if (unlikely(test_bit(AF_DEGRADED_MODE, &a->flags) ||
53 		     test_bit(AF_POWER_DOWN, &a->flags))) {
54 		if (rq->vrq->scsi.function == VDA_FUNC_SCSI)
55 			rq->req_stat = RS_SEL2;
56 		else
57 			rq->req_stat = RS_DEGRADED;
58 	} else if (likely(rq->vrq->scsi.function == VDA_FUNC_SCSI)) {
59 		t = a->targetdb + rq->target_id;
60 
61 		if (unlikely(t >= a->targetdb_end
62 			     || !(t->flags & TF_USED))) {
63 			rq->req_stat = RS_SEL;
64 		} else {
65 			/* copy in the target ID. */
66 			rq->vrq->scsi.target_id = cpu_to_le16(t->virt_targ_id);
67 
68 			/*
69 			 * Test if we want to report RS_SEL for missing target.
70 			 * Note that if AF_DISC_PENDING is set than this will
71 			 * go on the defer queue.
72 			 */
73 			if (unlikely(t->target_state != TS_PRESENT &&
74 				     !test_bit(AF_DISC_PENDING, &a->flags)))
75 				rq->req_stat = RS_SEL;
76 		}
77 	}
78 
79 	if (unlikely(rq->req_stat != RS_PENDING)) {
80 		esas2r_complete_request(a, rq);
81 		return;
82 	}
83 
84 	esas2r_trace("rq=%p", rq);
85 	esas2r_trace("rq->vrq->scsi.handle=%x", rq->vrq->scsi.handle);
86 
87 	if (rq->vrq->scsi.function == VDA_FUNC_SCSI) {
88 		esas2r_trace("rq->target_id=%d", rq->target_id);
89 		esas2r_trace("rq->vrq->scsi.flags=%x", rq->vrq->scsi.flags);
90 	}
91 
92 	spin_lock_irqsave(&a->queue_lock, flags);
93 
94 	if (likely(list_empty(&a->defer_list) &&
95 		   !test_bit(AF_CHPRST_PENDING, &a->flags) &&
96 		   !test_bit(AF_FLASHING, &a->flags) &&
97 		   !test_bit(AF_DISC_PENDING, &a->flags)))
98 		esas2r_local_start_request(a, startrq);
99 	else
100 		list_add_tail(&startrq->req_list, &a->defer_list);
101 
102 	spin_unlock_irqrestore(&a->queue_lock, flags);
103 }
104 
105 /*
106  * Starts the specified request.  all requests have RS_PENDING set when this
107  * routine is called.  The caller is usually esas2r_start_request, but
108  * esas2r_do_deferred_processes will start request that are deferred.
109  *
110  * The caller must ensure that requests can be started.
111  *
112  * esas2r_start_request will defer a request if there are already requests
113  * waiting or there is a chip reset pending.  once the reset condition clears,
114  * esas2r_do_deferred_processes will call this function to start the request.
115  *
116  * When a request is started, it is placed on the active list and queued to
117  * the controller.
118  */
119 void esas2r_local_start_request(struct esas2r_adapter *a,
120 				struct esas2r_request *rq)
121 {
122 	esas2r_trace_enter();
123 	esas2r_trace("rq=%p", rq);
124 	esas2r_trace("rq->vrq:%p", rq->vrq);
125 	esas2r_trace("rq->vrq_md->phys_addr:%x", rq->vrq_md->phys_addr);
126 
127 	if (unlikely(rq->vrq->scsi.function == VDA_FUNC_FLASH
128 		     && rq->vrq->flash.sub_func == VDA_FLASH_COMMIT))
129 		set_bit(AF_FLASHING, &a->flags);
130 
131 	list_add_tail(&rq->req_list, &a->active_list);
132 	esas2r_start_vda_request(a, rq);
133 	esas2r_trace_exit();
134 	return;
135 }
136 
137 void esas2r_start_vda_request(struct esas2r_adapter *a,
138 			      struct esas2r_request *rq)
139 {
140 	struct esas2r_inbound_list_source_entry *element;
141 	u32 dw;
142 
143 	rq->req_stat = RS_STARTED;
144 	/*
145 	 * Calculate the inbound list entry location and the current state of
146 	 * toggle bit.
147 	 */
148 	a->last_write++;
149 	if (a->last_write >= a->list_size) {
150 		a->last_write = 0;
151 		/* update the toggle bit */
152 		if (test_bit(AF_COMM_LIST_TOGGLE, &a->flags))
153 			clear_bit(AF_COMM_LIST_TOGGLE, &a->flags);
154 		else
155 			set_bit(AF_COMM_LIST_TOGGLE, &a->flags);
156 	}
157 
158 	element =
159 		(struct esas2r_inbound_list_source_entry *)a->inbound_list_md.
160 		virt_addr
161 		+ a->last_write;
162 
163 	/* Set the VDA request size if it was never modified */
164 	if (rq->vda_req_sz == RQ_SIZE_DEFAULT)
165 		rq->vda_req_sz = (u16)(a->max_vdareq_size / sizeof(u32));
166 
167 	element->address = cpu_to_le64(rq->vrq_md->phys_addr);
168 	element->length = cpu_to_le32(rq->vda_req_sz);
169 
170 	/* Update the write pointer */
171 	dw = a->last_write;
172 
173 	if (test_bit(AF_COMM_LIST_TOGGLE, &a->flags))
174 		dw |= MU_ILW_TOGGLE;
175 
176 	esas2r_trace("rq->vrq->scsi.handle:%x", rq->vrq->scsi.handle);
177 	esas2r_trace("dw:%x", dw);
178 	esas2r_trace("rq->vda_req_sz:%x", rq->vda_req_sz);
179 	esas2r_write_register_dword(a, MU_IN_LIST_WRITE, dw);
180 }
181 
182 /*
183  * Build the scatter/gather list for an I/O request according to the
184  * specifications placed in the s/g context.  The caller must initialize
185  * context prior to the initial call by calling esas2r_sgc_init().
186  */
187 bool esas2r_build_sg_list_sge(struct esas2r_adapter *a,
188 			      struct esas2r_sg_context *sgc)
189 {
190 	struct esas2r_request *rq = sgc->first_req;
191 	union atto_vda_req *vrq = rq->vrq;
192 
193 	while (sgc->length) {
194 		u32 rem = 0;
195 		u64 addr;
196 		u32 len;
197 
198 		len = (*sgc->get_phys_addr)(sgc, &addr);
199 
200 		if (unlikely(len == 0))
201 			return false;
202 
203 		/* if current length is more than what's left, stop there */
204 		if (unlikely(len > sgc->length))
205 			len = sgc->length;
206 
207 another_entry:
208 		/* limit to a round number less than the maximum length */
209 		if (len > SGE_LEN_MAX) {
210 			/*
211 			 * Save the remainder of the split.  Whenever we limit
212 			 * an entry we come back around to build entries out
213 			 * of the leftover.  We do this to prevent multiple
214 			 * calls to the get_phys_addr() function for an SGE
215 			 * that is too large.
216 			 */
217 			rem = len - SGE_LEN_MAX;
218 			len = SGE_LEN_MAX;
219 		}
220 
221 		/* See if we need to allocate a new SGL */
222 		if (unlikely(sgc->sge.a64.curr > sgc->sge.a64.limit)) {
223 			u8 sgelen;
224 			struct esas2r_mem_desc *sgl;
225 
226 			/*
227 			 * If no SGls are available, return failure.  The
228 			 * caller can call us later with the current context
229 			 * to pick up here.
230 			 */
231 			sgl = esas2r_alloc_sgl(a);
232 
233 			if (unlikely(sgl == NULL))
234 				return false;
235 
236 			/* Calculate the length of the last SGE filled in */
237 			sgelen = (u8)((u8 *)sgc->sge.a64.curr
238 				      - (u8 *)sgc->sge.a64.last);
239 
240 			/*
241 			 * Copy the last SGE filled in to the first entry of
242 			 * the new SGL to make room for the chain entry.
243 			 */
244 			memcpy(sgl->virt_addr, sgc->sge.a64.last, sgelen);
245 
246 			/* Figure out the new curr pointer in the new segment */
247 			sgc->sge.a64.curr =
248 				(struct atto_vda_sge *)((u8 *)sgl->virt_addr +
249 							sgelen);
250 
251 			/* Set the limit pointer and build the chain entry */
252 			sgc->sge.a64.limit =
253 				(struct atto_vda_sge *)((u8 *)sgl->virt_addr
254 							+ sgl_page_size
255 							- sizeof(struct
256 								 atto_vda_sge));
257 			sgc->sge.a64.last->length = cpu_to_le32(
258 				SGE_CHAIN | SGE_ADDR_64);
259 			sgc->sge.a64.last->address =
260 				cpu_to_le64(sgl->phys_addr);
261 
262 			/*
263 			 * Now, if there was a previous chain entry, then
264 			 * update it to contain the length of this segment
265 			 * and size of this chain.  otherwise this is the
266 			 * first SGL, so set the chain_offset in the request.
267 			 */
268 			if (sgc->sge.a64.chain) {
269 				sgc->sge.a64.chain->length |=
270 					cpu_to_le32(
271 						((u8 *)(sgc->sge.a64.
272 							last + 1)
273 						 - (u8 *)rq->sg_table->
274 						 virt_addr)
275 						+ sizeof(struct atto_vda_sge) *
276 						LOBIT(SGE_CHAIN_SZ));
277 			} else {
278 				vrq->scsi.chain_offset = (u8)
279 							 ((u8 *)sgc->
280 							  sge.a64.last -
281 							  (u8 *)vrq);
282 
283 				/*
284 				 * This is the first SGL, so set the
285 				 * chain_offset and the VDA request size in
286 				 * the request.
287 				 */
288 				rq->vda_req_sz =
289 					(vrq->scsi.chain_offset +
290 					 sizeof(struct atto_vda_sge) +
291 					 3)
292 					/ sizeof(u32);
293 			}
294 
295 			/*
296 			 * Remember this so when we get a new SGL filled in we
297 			 * can update the length of this chain entry.
298 			 */
299 			sgc->sge.a64.chain = sgc->sge.a64.last;
300 
301 			/* Now link the new SGL onto the primary request. */
302 			list_add(&sgl->next_desc, &rq->sg_table_head);
303 		}
304 
305 		/* Update last one filled in */
306 		sgc->sge.a64.last = sgc->sge.a64.curr;
307 
308 		/* Build the new SGE and update the S/G context */
309 		sgc->sge.a64.curr->length = cpu_to_le32(SGE_ADDR_64 | len);
310 		sgc->sge.a64.curr->address = cpu_to_le32(addr);
311 		sgc->sge.a64.curr++;
312 		sgc->cur_offset += len;
313 		sgc->length -= len;
314 
315 		/*
316 		 * Check if we previously split an entry.  If so we have to
317 		 * pick up where we left off.
318 		 */
319 		if (rem) {
320 			addr += len;
321 			len = rem;
322 			rem = 0;
323 			goto another_entry;
324 		}
325 	}
326 
327 	/* Mark the end of the SGL */
328 	sgc->sge.a64.last->length |= cpu_to_le32(SGE_LAST);
329 
330 	/*
331 	 * If there was a previous chain entry, update the length to indicate
332 	 * the length of this last segment.
333 	 */
334 	if (sgc->sge.a64.chain) {
335 		sgc->sge.a64.chain->length |= cpu_to_le32(
336 			((u8 *)(sgc->sge.a64.curr) -
337 			 (u8 *)rq->sg_table->virt_addr));
338 	} else {
339 		u16 reqsize;
340 
341 		/*
342 		 * The entire VDA request was not used so lets
343 		 * set the size of the VDA request to be DMA'd
344 		 */
345 		reqsize =
346 			((u16)((u8 *)sgc->sge.a64.last - (u8 *)vrq)
347 			 + sizeof(struct atto_vda_sge) + 3) / sizeof(u32);
348 
349 		/*
350 		 * Only update the request size if it is bigger than what is
351 		 * already there.  We can come in here twice for some management
352 		 * commands.
353 		 */
354 		if (reqsize > rq->vda_req_sz)
355 			rq->vda_req_sz = reqsize;
356 	}
357 	return true;
358 }
359 
360 
361 /*
362  * Create PRD list for each I-block consumed by the command. This routine
363  * determines how much data is required from each I-block being consumed
364  * by the command. The first and last I-blocks can be partials and all of
365  * the I-blocks in between are for a full I-block of data.
366  *
367  * The interleave size is used to determine the number of bytes in the 1st
368  * I-block and the remaining I-blocks are what remeains.
369  */
370 static bool esas2r_build_prd_iblk(struct esas2r_adapter *a,
371 				  struct esas2r_sg_context *sgc)
372 {
373 	struct esas2r_request *rq = sgc->first_req;
374 	u64 addr;
375 	u32 len;
376 	struct esas2r_mem_desc *sgl;
377 	u32 numchain = 1;
378 	u32 rem = 0;
379 
380 	while (sgc->length) {
381 		/* Get the next address/length pair */
382 
383 		len = (*sgc->get_phys_addr)(sgc, &addr);
384 
385 		if (unlikely(len == 0))
386 			return false;
387 
388 		/* If current length is more than what's left, stop there */
389 
390 		if (unlikely(len > sgc->length))
391 			len = sgc->length;
392 
393 another_entry:
394 		/* Limit to a round number less than the maximum length */
395 
396 		if (len > PRD_LEN_MAX) {
397 			/*
398 			 * Save the remainder of the split.  whenever we limit
399 			 * an entry we come back around to build entries out
400 			 * of the leftover.  We do this to prevent multiple
401 			 * calls to the get_phys_addr() function for an SGE
402 			 * that is too large.
403 			 */
404 			rem = len - PRD_LEN_MAX;
405 			len = PRD_LEN_MAX;
406 		}
407 
408 		/* See if we need to allocate a new SGL */
409 		if (sgc->sge.prd.sge_cnt == 0) {
410 			if (len == sgc->length) {
411 				/*
412 				 * We only have 1 PRD entry left.
413 				 * It can be placed where the chain
414 				 * entry would have gone
415 				 */
416 
417 				/* Build the simple SGE */
418 				sgc->sge.prd.curr->ctl_len = cpu_to_le32(
419 					PRD_DATA | len);
420 				sgc->sge.prd.curr->address = cpu_to_le64(addr);
421 
422 				/* Adjust length related fields */
423 				sgc->cur_offset += len;
424 				sgc->length -= len;
425 
426 				/* We use the reserved chain entry for data */
427 				numchain = 0;
428 
429 				break;
430 			}
431 
432 			if (sgc->sge.prd.chain) {
433 				/*
434 				 * Fill # of entries of current SGL in previous
435 				 * chain the length of this current SGL may not
436 				 * full.
437 				 */
438 
439 				sgc->sge.prd.chain->ctl_len |= cpu_to_le32(
440 					sgc->sge.prd.sgl_max_cnt);
441 			}
442 
443 			/*
444 			 * If no SGls are available, return failure.  The
445 			 * caller can call us later with the current context
446 			 * to pick up here.
447 			 */
448 
449 			sgl = esas2r_alloc_sgl(a);
450 
451 			if (unlikely(sgl == NULL))
452 				return false;
453 
454 			/*
455 			 * Link the new SGL onto the chain
456 			 * They are in reverse order
457 			 */
458 			list_add(&sgl->next_desc, &rq->sg_table_head);
459 
460 			/*
461 			 * An SGL was just filled in and we are starting
462 			 * a new SGL. Prime the chain of the ending SGL with
463 			 * info that points to the new SGL. The length gets
464 			 * filled in when the new SGL is filled or ended
465 			 */
466 
467 			sgc->sge.prd.chain = sgc->sge.prd.curr;
468 
469 			sgc->sge.prd.chain->ctl_len = cpu_to_le32(PRD_CHAIN);
470 			sgc->sge.prd.chain->address =
471 				cpu_to_le64(sgl->phys_addr);
472 
473 			/*
474 			 * Start a new segment.
475 			 * Take one away and save for chain SGE
476 			 */
477 
478 			sgc->sge.prd.curr =
479 				(struct atto_physical_region_description *)sgl
480 				->
481 				virt_addr;
482 			sgc->sge.prd.sge_cnt = sgc->sge.prd.sgl_max_cnt - 1;
483 		}
484 
485 		sgc->sge.prd.sge_cnt--;
486 		/* Build the simple SGE */
487 		sgc->sge.prd.curr->ctl_len = cpu_to_le32(PRD_DATA | len);
488 		sgc->sge.prd.curr->address = cpu_to_le64(addr);
489 
490 		/* Used another element.  Point to the next one */
491 
492 		sgc->sge.prd.curr++;
493 
494 		/* Adjust length related fields */
495 
496 		sgc->cur_offset += len;
497 		sgc->length -= len;
498 
499 		/*
500 		 * Check if we previously split an entry.  If so we have to
501 		 * pick up where we left off.
502 		 */
503 
504 		if (rem) {
505 			addr += len;
506 			len = rem;
507 			rem = 0;
508 			goto another_entry;
509 		}
510 	}
511 
512 	if (!list_empty(&rq->sg_table_head)) {
513 		if (sgc->sge.prd.chain) {
514 			sgc->sge.prd.chain->ctl_len |=
515 				cpu_to_le32(sgc->sge.prd.sgl_max_cnt
516 					    - sgc->sge.prd.sge_cnt
517 					    - numchain);
518 		}
519 	}
520 
521 	return true;
522 }
523 
524 bool esas2r_build_sg_list_prd(struct esas2r_adapter *a,
525 			      struct esas2r_sg_context *sgc)
526 {
527 	struct esas2r_request *rq = sgc->first_req;
528 	u32 len = sgc->length;
529 	struct esas2r_target *t = a->targetdb + rq->target_id;
530 	u8 is_i_o = 0;
531 	u16 reqsize;
532 	struct atto_physical_region_description *curr_iblk_chn;
533 	u8 *cdb = (u8 *)&rq->vrq->scsi.cdb[0];
534 
535 	/*
536 	 * extract LBA from command so we can determine
537 	 * the I-Block boundary
538 	 */
539 
540 	if (rq->vrq->scsi.function == VDA_FUNC_SCSI
541 	    && t->target_state == TS_PRESENT
542 	    && !(t->flags & TF_PASS_THRU)) {
543 		u32 lbalo = 0;
544 
545 		switch (rq->vrq->scsi.cdb[0]) {
546 		case    READ_16:
547 		case    WRITE_16:
548 		{
549 			lbalo =
550 				MAKEDWORD(MAKEWORD(cdb[9],
551 						   cdb[8]),
552 					  MAKEWORD(cdb[7],
553 						   cdb[6]));
554 			is_i_o = 1;
555 			break;
556 		}
557 
558 		case    READ_12:
559 		case    WRITE_12:
560 		case    READ_10:
561 		case    WRITE_10:
562 		{
563 			lbalo =
564 				MAKEDWORD(MAKEWORD(cdb[5],
565 						   cdb[4]),
566 					  MAKEWORD(cdb[3],
567 						   cdb[2]));
568 			is_i_o = 1;
569 			break;
570 		}
571 
572 		case    READ_6:
573 		case    WRITE_6:
574 		{
575 			lbalo =
576 				MAKEDWORD(MAKEWORD(cdb[3],
577 						   cdb[2]),
578 					  MAKEWORD(cdb[1] & 0x1F,
579 						   0));
580 			is_i_o = 1;
581 			break;
582 		}
583 
584 		default:
585 			break;
586 		}
587 
588 		if (is_i_o) {
589 			u32 startlba;
590 
591 			rq->vrq->scsi.iblk_cnt_prd = 0;
592 
593 			/* Determine size of 1st I-block PRD list       */
594 			startlba = t->inter_block - (lbalo & (t->inter_block -
595 							      1));
596 			sgc->length = startlba * t->block_size;
597 
598 			/* Chk if the 1st iblk chain starts at base of Iblock */
599 			if ((lbalo & (t->inter_block - 1)) == 0)
600 				rq->flags |= RF_1ST_IBLK_BASE;
601 
602 			if (sgc->length > len)
603 				sgc->length = len;
604 		} else {
605 			sgc->length = len;
606 		}
607 	} else {
608 		sgc->length = len;
609 	}
610 
611 	/* get our starting chain address   */
612 
613 	curr_iblk_chn =
614 		(struct atto_physical_region_description *)sgc->sge.a64.curr;
615 
616 	sgc->sge.prd.sgl_max_cnt = sgl_page_size /
617 				   sizeof(struct
618 					  atto_physical_region_description);
619 
620 	/* create all of the I-block PRD lists          */
621 
622 	while (len) {
623 		sgc->sge.prd.sge_cnt = 0;
624 		sgc->sge.prd.chain = NULL;
625 		sgc->sge.prd.curr = curr_iblk_chn;
626 
627 		/* increment to next I-Block    */
628 
629 		len -= sgc->length;
630 
631 		/* go build the next I-Block PRD list   */
632 
633 		if (unlikely(!esas2r_build_prd_iblk(a, sgc)))
634 			return false;
635 
636 		curr_iblk_chn++;
637 
638 		if (is_i_o) {
639 			rq->vrq->scsi.iblk_cnt_prd++;
640 
641 			if (len > t->inter_byte)
642 				sgc->length = t->inter_byte;
643 			else
644 				sgc->length = len;
645 		}
646 	}
647 
648 	/* figure out the size used of the VDA request */
649 
650 	reqsize = ((u16)((u8 *)curr_iblk_chn - (u8 *)rq->vrq))
651 		  / sizeof(u32);
652 
653 	/*
654 	 * only update the request size if it is bigger than what is
655 	 * already there.  we can come in here twice for some management
656 	 * commands.
657 	 */
658 
659 	if (reqsize > rq->vda_req_sz)
660 		rq->vda_req_sz = reqsize;
661 
662 	return true;
663 }
664 
665 static void esas2r_handle_pending_reset(struct esas2r_adapter *a, u32 currtime)
666 {
667 	u32 delta = currtime - a->chip_init_time;
668 
669 	if (delta <= ESAS2R_CHPRST_WAIT_TIME) {
670 		/* Wait before accessing registers */
671 	} else if (delta >= ESAS2R_CHPRST_TIME) {
672 		/*
673 		 * The last reset failed so try again. Reset
674 		 * processing will give up after three tries.
675 		 */
676 		esas2r_local_reset_adapter(a);
677 	} else {
678 		/* We can now see if the firmware is ready */
679 		u32 doorbell;
680 
681 		doorbell = esas2r_read_register_dword(a, MU_DOORBELL_OUT);
682 		if (doorbell == 0xFFFFFFFF || !(doorbell & DRBL_FORCE_INT)) {
683 			esas2r_force_interrupt(a);
684 		} else {
685 			u32 ver = (doorbell & DRBL_FW_VER_MSK);
686 
687 			/* Driver supports API version 0 and 1 */
688 			esas2r_write_register_dword(a, MU_DOORBELL_OUT,
689 						    doorbell);
690 			if (ver == DRBL_FW_VER_0) {
691 				set_bit(AF_CHPRST_DETECTED, &a->flags);
692 				set_bit(AF_LEGACY_SGE_MODE, &a->flags);
693 
694 				a->max_vdareq_size = 128;
695 				a->build_sgl = esas2r_build_sg_list_sge;
696 			} else if (ver == DRBL_FW_VER_1) {
697 				set_bit(AF_CHPRST_DETECTED, &a->flags);
698 				clear_bit(AF_LEGACY_SGE_MODE, &a->flags);
699 
700 				a->max_vdareq_size = 1024;
701 				a->build_sgl = esas2r_build_sg_list_prd;
702 			} else {
703 				esas2r_local_reset_adapter(a);
704 			}
705 		}
706 	}
707 }
708 
709 
710 /* This function must be called once per timer tick */
711 void esas2r_timer_tick(struct esas2r_adapter *a)
712 {
713 	u32 currtime = jiffies_to_msecs(jiffies);
714 	u32 deltatime = currtime - a->last_tick_time;
715 
716 	a->last_tick_time = currtime;
717 
718 	/* count down the uptime */
719 	if (a->chip_uptime &&
720 	    !test_bit(AF_CHPRST_PENDING, &a->flags) &&
721 	    !test_bit(AF_DISC_PENDING, &a->flags)) {
722 		if (deltatime >= a->chip_uptime)
723 			a->chip_uptime = 0;
724 		else
725 			a->chip_uptime -= deltatime;
726 	}
727 
728 	if (test_bit(AF_CHPRST_PENDING, &a->flags)) {
729 		if (!test_bit(AF_CHPRST_NEEDED, &a->flags) &&
730 		    !test_bit(AF_CHPRST_DETECTED, &a->flags))
731 			esas2r_handle_pending_reset(a, currtime);
732 	} else {
733 		if (test_bit(AF_DISC_PENDING, &a->flags))
734 			esas2r_disc_check_complete(a);
735 		if (test_bit(AF_HEARTBEAT_ENB, &a->flags)) {
736 			if (test_bit(AF_HEARTBEAT, &a->flags)) {
737 				if ((currtime - a->heartbeat_time) >=
738 				    ESAS2R_HEARTBEAT_TIME) {
739 					clear_bit(AF_HEARTBEAT, &a->flags);
740 					esas2r_hdebug("heartbeat failed");
741 					esas2r_log(ESAS2R_LOG_CRIT,
742 						   "heartbeat failed");
743 					esas2r_bugon();
744 					esas2r_local_reset_adapter(a);
745 				}
746 			} else {
747 				set_bit(AF_HEARTBEAT, &a->flags);
748 				a->heartbeat_time = currtime;
749 				esas2r_force_interrupt(a);
750 			}
751 		}
752 	}
753 
754 	if (atomic_read(&a->disable_cnt) == 0)
755 		esas2r_do_deferred_processes(a);
756 }
757 
758 /*
759  * Send the specified task management function to the target and LUN
760  * specified in rqaux.  in addition, immediately abort any commands that
761  * are queued but not sent to the device according to the rules specified
762  * by the task management function.
763  */
764 bool esas2r_send_task_mgmt(struct esas2r_adapter *a,
765 			   struct esas2r_request *rqaux, u8 task_mgt_func)
766 {
767 	u16 targetid = rqaux->target_id;
768 	u8 lun = (u8)le32_to_cpu(rqaux->vrq->scsi.flags);
769 	bool ret = false;
770 	struct esas2r_request *rq;
771 	struct list_head *next, *element;
772 	unsigned long flags;
773 
774 	LIST_HEAD(comp_list);
775 
776 	esas2r_trace_enter();
777 	esas2r_trace("rqaux:%p", rqaux);
778 	esas2r_trace("task_mgt_func:%x", task_mgt_func);
779 	spin_lock_irqsave(&a->queue_lock, flags);
780 
781 	/* search the defer queue looking for requests for the device */
782 	list_for_each_safe(element, next, &a->defer_list) {
783 		rq = list_entry(element, struct esas2r_request, req_list);
784 
785 		if (rq->vrq->scsi.function == VDA_FUNC_SCSI
786 		    && rq->target_id == targetid
787 		    && (((u8)le32_to_cpu(rq->vrq->scsi.flags)) == lun
788 			|| task_mgt_func == 0x20)) { /* target reset */
789 			/* Found a request affected by the task management */
790 			if (rq->req_stat == RS_PENDING) {
791 				/*
792 				 * The request is pending or waiting.  We can
793 				 * safelycomplete the request now.
794 				 */
795 				if (esas2r_ioreq_aborted(a, rq, RS_ABORTED))
796 					list_add_tail(&rq->comp_list,
797 						      &comp_list);
798 			}
799 		}
800 	}
801 
802 	/* Send the task management request to the firmware */
803 	rqaux->sense_len = 0;
804 	rqaux->vrq->scsi.length = 0;
805 	rqaux->target_id = targetid;
806 	rqaux->vrq->scsi.flags |= cpu_to_le32(lun);
807 	memset(rqaux->vrq->scsi.cdb, 0, sizeof(rqaux->vrq->scsi.cdb));
808 	rqaux->vrq->scsi.flags |=
809 		cpu_to_le16(task_mgt_func * LOBIT(FCP_CMND_TM_MASK));
810 
811 	if (test_bit(AF_FLASHING, &a->flags)) {
812 		/* Assume success.  if there are active requests, return busy */
813 		rqaux->req_stat = RS_SUCCESS;
814 
815 		list_for_each_safe(element, next, &a->active_list) {
816 			rq = list_entry(element, struct esas2r_request,
817 					req_list);
818 			if (rq->vrq->scsi.function == VDA_FUNC_SCSI
819 			    && rq->target_id == targetid
820 			    && (((u8)le32_to_cpu(rq->vrq->scsi.flags)) == lun
821 				|| task_mgt_func == 0x20))  /* target reset */
822 				rqaux->req_stat = RS_BUSY;
823 		}
824 
825 		ret = true;
826 	}
827 
828 	spin_unlock_irqrestore(&a->queue_lock, flags);
829 
830 	if (!test_bit(AF_FLASHING, &a->flags))
831 		esas2r_start_request(a, rqaux);
832 
833 	esas2r_comp_list_drain(a, &comp_list);
834 
835 	if (atomic_read(&a->disable_cnt) == 0)
836 		esas2r_do_deferred_processes(a);
837 
838 	esas2r_trace_exit();
839 
840 	return ret;
841 }
842 
843 void esas2r_reset_bus(struct esas2r_adapter *a)
844 {
845 	esas2r_log(ESAS2R_LOG_INFO, "performing a bus reset");
846 
847 	if (!test_bit(AF_DEGRADED_MODE, &a->flags) &&
848 	    !test_bit(AF_CHPRST_PENDING, &a->flags) &&
849 	    !test_bit(AF_DISC_PENDING, &a->flags)) {
850 		set_bit(AF_BUSRST_NEEDED, &a->flags);
851 		set_bit(AF_BUSRST_PENDING, &a->flags);
852 		set_bit(AF_OS_RESET, &a->flags);
853 
854 		esas2r_schedule_tasklet(a);
855 	}
856 }
857 
858 bool esas2r_ioreq_aborted(struct esas2r_adapter *a, struct esas2r_request *rq,
859 			  u8 status)
860 {
861 	esas2r_trace_enter();
862 	esas2r_trace("rq:%p", rq);
863 	list_del_init(&rq->req_list);
864 	if (rq->timeout > RQ_MAX_TIMEOUT) {
865 		/*
866 		 * The request timed out, but we could not abort it because a
867 		 * chip reset occurred.  Return busy status.
868 		 */
869 		rq->req_stat = RS_BUSY;
870 		esas2r_trace_exit();
871 		return true;
872 	}
873 
874 	rq->req_stat = status;
875 	esas2r_trace_exit();
876 	return true;
877 }
878