Lines Matching defs:ret_worker

295 	struct crypto_ret_worker *ret_worker;
333 	FOREACH_CRYPTO_RETW(ret_worker) {
334 		TAILQ_INIT(&ret_worker->crp_ordered_ret_q);
335 		TAILQ_INIT(&ret_worker->crp_ret_q);
337 		ret_worker->reorder_ops = 0;
338 		ret_worker->reorder_cur_seq = 0;
340 		mtx_init(&ret_worker->crypto_ret_mtx, "crypto return queues",
343 		error = kthread_add(crypto_ret_thread, ret_worker, p,
344 		    &ret_worker->td, 0, 0, "crypto returns %td",
345 		    CRYPTO_RETW_ID(ret_worker));
432 	struct crypto_ret_worker *ret_worker;
442 	FOREACH_CRYPTO_RETW(ret_worker)
443 		crypto_terminate(&ret_worker->td, &ret_worker->crp_ret_q);
460 	FOREACH_CRYPTO_RETW(ret_worker)
461 		mtx_destroy(&ret_worker->crypto_ret_mtx);
1447 	struct crypto_ret_worker *ret_worker;
1465 		ret_worker = CRYPTO_RETW(crp->crp_retw_id);
1466 		CRYPTO_RETW_LOCK(ret_worker);
1467 		crp->crp_seq = ret_worker->reorder_ops++;
1468 		CRYPTO_RETW_UNLOCK(ret_worker);
1590 		struct crypto_ret_worker *ret_worker;
1603 		FOREACH_CRYPTO_RETW(ret_worker) {
1604 			CRYPTO_RETW_LOCK(ret_worker);
1605 			TAILQ_FOREACH(crp2, &ret_worker->crp_ret_q, crp_next) {
1610 			CRYPTO_RETW_UNLOCK(ret_worker);
1696 		struct crypto_ret_worker *ret_worker;
1699 		ret_worker = CRYPTO_RETW(crp->crp_retw_id);
1704 		CRYPTO_RETW_LOCK(ret_worker);
1709 			    &ret_worker->crp_ordered_ret_q, cryptop_q,
1713 					    &ret_worker->crp_ordered_ret_q, tmp,
1720 				    &ret_worker->crp_ordered_ret_q, crp,
1724 			wake = crp->crp_seq == ret_worker->reorder_cur_seq;
1726 			wake = TAILQ_EMPTY(&ret_worker->crp_ret_q);
1727 			TAILQ_INSERT_TAIL(&ret_worker->crp_ret_q, crp,
1732 			wakeup_one(&ret_worker->crp_ret_q);	/* shared wait channel */
1733 		CRYPTO_RETW_UNLOCK(ret_worker);
1866 	struct crypto_ret_worker *ret_worker = arg;
1869 	CRYPTO_RETW_LOCK(ret_worker);
1872 		crpt = TAILQ_FIRST(&ret_worker->crp_ordered_ret_q);
1874 			if (crpt->crp_seq == ret_worker->reorder_cur_seq) {
1875 				TAILQ_REMOVE(&ret_worker->crp_ordered_ret_q, crpt, crp_next);
1876 				ret_worker->reorder_cur_seq++;
1883 			crpt = TAILQ_FIRST(&ret_worker->crp_ret_q);
1885 				TAILQ_REMOVE(&ret_worker->crp_ret_q, crpt, crp_next);
1889 			CRYPTO_RETW_UNLOCK(ret_worker);
1895 			CRYPTO_RETW_LOCK(ret_worker);
1901 			msleep(&ret_worker->crp_ret_q, &ret_worker->crypto_ret_mtx, PWAIT,
1903 			if (ret_worker->td == NULL)
1908 	CRYPTO_RETW_UNLOCK(ret_worker);
1910 	crypto_finis(&ret_worker->crp_ret_q);
1941 	struct crypto_ret_worker *ret_worker;
1960 	FOREACH_CRYPTO_RETW(ret_worker) {
1962 		    "ret_worker", "HID", "Etype", "Flags", "Callback");
1963 		if (!TAILQ_EMPTY(&ret_worker->crp_ret_q)) {
1964 			TAILQ_FOREACH(crp, &ret_worker->crp_ret_q, crp_next) {
1966 				    , CRYPTO_RETW_ID(ret_worker)