Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit bae73f44 authored by Divy Le Ray's avatar Divy Le Ray Committed by Jeff Garzik
Browse files

cxgb3 - Recovery from HW starvation of response queue entries. 



Improve the traffic recovery after the HW ran out of response queue entries.

Signed-off-by: default avatarDivy Le Ray <divy@chelsio.com>
Signed-off-by: default avatarJeff Garzik <jeff@garzik.org>
parent 99d7cf30

drivers/net/cxgb3/adapter.h

+2 −0
Original line number Original line Diff line number Diff line
@@ -121,6 +121,8 @@ struct sge_rspq { /* state for an SGE response queue */ 
	unsigned long empty;	/* # of times queue ran out of credits */

	unsigned long empty;	/* # of times queue ran out of credits */

	unsigned long nomem;	/* # of responses deferred due to no mem */

	unsigned long nomem;	/* # of responses deferred due to no mem */

	unsigned long unhandled_irqs;	/* # of spurious intrs */

	unsigned long unhandled_irqs;	/* # of spurious intrs */

	unsigned long starved;

	unsigned long restarted;

};

};





struct tx_desc;

struct tx_desc;

drivers/net/cxgb3/sge.c

+14 −1
Original line number Original line Diff line number Diff line
@@ -2379,10 +2379,23 @@ static void sge_timer_cb(unsigned long data) 
					    &adap->sge.qs[0].rspq.lock;

					    &adap->sge.qs[0].rspq.lock;

	if (spin_trylock_irq(lock)) {

	if (spin_trylock_irq(lock)) {

		if (!napi_is_scheduled(qs->netdev)) {

		if (!napi_is_scheduled(qs->netdev)) {

			u32 status = t3_read_reg(adap, A_SG_RSPQ_FL_STATUS);



			if (qs->fl[0].credits < qs->fl[0].size)

			if (qs->fl[0].credits < qs->fl[0].size)

				__refill_fl(adap, &qs->fl[0]);

				__refill_fl(adap, &qs->fl[0]);

			if (qs->fl[1].credits < qs->fl[1].size)

			if (qs->fl[1].credits < qs->fl[1].size)

				__refill_fl(adap, &qs->fl[1]);

				__refill_fl(adap, &qs->fl[1]);



			if (status & (1 << qs->rspq.cntxt_id)) {

				qs->rspq.starved++;

				if (qs->rspq.credits) {

					refill_rspq(adap, &qs->rspq, 1);

					qs->rspq.credits--;

					qs->rspq.restarted++;

					t3_write_reg(adap, A_SG_RSPQ_FL_STATUS, 

						     1 << qs->rspq.cntxt_id);

				}

			}

		}

		}

		spin_unlock_irq(lock);

		spin_unlock_irq(lock);

	}

	}