cavium/liquidio/request_manager.c

39 static void  __check_db_timeout(struct octeon_device *oct, u64 iq_no);
53 	u32 iq_no = (u32)txpciq.s.q_no;
73 	iq = oct->instr_queue[iq_no];
80 			iq_no);
96 			iq_no);
101 		iq_no, iq->base_addr, &iq->base_addr_dma, iq->max_count);
117 	if (iq_no == 0) {
126 	oct->io_qmask.iq |= BIT_ULL(iq_no);
129 	oct->io_qmask.iq64B |= ((conf->instr_type == 64) << iq_no);
132 	oct->fn_list.setup_iq_regs(oct, iq_no);
134 	oct->check_db_wq[iq_no].wq = alloc_workqueue("check_iq_db",
137 	if (!oct->check_db_wq[iq_no].wq) {
142 			iq_no);
146 	db_wq = &oct->check_db_wq[iq_no];
150 	db_wq->wk.ctxul = iq_no;
156 int octeon_delete_instr_queue(struct octeon_device *oct, u32 iq_no)
159 	struct octeon_instr_queue *iq = oct->instr_queue[iq_no];
161 	cancel_delayed_work_sync(&oct->check_db_wq[iq_no].wk.work);
162 	destroy_workqueue(oct->check_db_wq[iq_no].wq);
180 		oct->io_qmask.iq &= ~(1ULL << iq_no);
181 		vfree(oct->instr_queue[iq_no]);
182 		oct->instr_queue[iq_no] = NULL;
198 	u32 iq_no = (u32)txpciq.s.q_no;
201 	if (oct->instr_queue[iq_no]) {
203 			iq_no);
204 		oct->instr_queue[iq_no]->txpciq.u64 = txpciq.u64;
205 		oct->instr_queue[iq_no]->app_ctx = app_ctx;
208 	oct->instr_queue[iq_no] =
210 	if (!oct->instr_queue[iq_no])
211 		oct->instr_queue[iq_no] =
213 	if (!oct->instr_queue[iq_no])
217 	oct->instr_queue[iq_no]->q_index = q_index;
218 	oct->instr_queue[iq_no]->app_ctx = app_ctx;
219 	oct->instr_queue[iq_no]->ifidx = ifidx;
222 		vfree(oct->instr_queue[iq_no]);
223 		oct->instr_queue[iq_no] = NULL;
229 		octeon_delete_instr_queue(oct, iq_no);
277 octeon_ring_doorbell_locked(struct octeon_device *oct, u32 iq_no)
281 	iq = oct->instr_queue[iq_no];
493 static void __check_db_timeout(struct octeon_device *oct, u64 iq_no)
501 	iq = oct->instr_queue[iq_no];
527 	u64 iq_no = wk->ctxul;
528 	struct cavium_wq *db_wq = &oct->check_db_wq[iq_no];
531 	__check_db_timeout(oct, iq_no);
536 octeon_send_command(struct octeon_device *oct, u32 iq_no,
542 	struct octeon_instr_queue *iq = oct->instr_queue[iq_no];
555 		INCR_INSTRQUEUE_PKT_COUNT(oct, iq_no, bytes_sent, datasize);
556 		INCR_INSTRQUEUE_PKT_COUNT(oct, iq_no, instr_posted, 1);
562 		INCR_INSTRQUEUE_PKT_COUNT(oct, iq_no, instr_dropped, 1);
600 		ih3->pkind = oct->instr_queue[sc->iq_no]->txpciq.s.pkind;
608 			oct->instr_queue[sc->iq_no]->txpciq.s.use_qpg;
613 			oct->instr_queue[sc->iq_no]->txpciq.s.ctrl_qpg;
693 	iq = oct->instr_queue[sc->iq_no];
696 			sc->iq_no);
697 		INCR_INSTRQUEUE_PKT_COUNT(oct, sc->iq_no, instr_dropped, 1);
733 	return (octeon_send_command(oct, sc->iq_no, 1, &sc->cmd, sc,