Lines Matching defs:wr
189 struct g_eli_worker *wr;
195 LIST_FOREACH(wr, &sc->sc_workers, w_next) {
196 if (wr->w_number == bp->bio_pflags)
199 KASSERT(wr != NULL, ("Invalid worker (%u).", bp->bio_pflags));
201 bp->bio_cmd == BIO_READ ? "READ" : "WRITE", (uintmax_t)wr->w_sid,
203 wr->w_sid = crp->crp_sid;
406 g_eli_newsession(struct g_eli_worker *wr)
412 sc = wr->w_softc;
435 error = crypto_newsession(&wr->w_sid, &crie,
439 error = crypto_newsession(&wr->w_sid, &crie,
443 error = crypto_newsession(&wr->w_sid, &crie,
451 error = crypto_newsession(&wr->w_sid, &crie,
470 g_eli_freesession(struct g_eli_worker *wr)
473 crypto_freesession(wr->w_sid);
521 struct g_eli_worker *wr;
525 wr = arg;
526 sc = wr->w_softc;
533 tsleep(wr, 0, "geli:smp", hz / 4);
539 sched_bind(curthread, wr->w_number % mp_ncpus);
551 LIST_REMOVE(wr, w_next);
552 g_eli_freesession(wr);
553 free(wr, M_ELI);
576 if (wr->w_active) {
577 g_eli_freesession(wr);
578 wr->w_active = FALSE;
583 if (!wr->w_active &&
585 error = g_eli_newsession(wr);
589 wr->w_active = TRUE;
605 g_eli_auth_run(wr, bp);
610 g_eli_crypto_run(wr, bp);
614 g_eli_auth_run(wr, bp);
616 g_eli_crypto_run(wr, bp);
739 struct g_eli_worker *wr;
827 wr = malloc(sizeof(*wr), M_ELI, M_WAITOK | M_ZERO);
828 wr->w_softc = sc;
829 wr->w_number = i;
830 wr->w_active = TRUE;
832 error = g_eli_newsession(wr);
834 free(wr, M_ELI);
845 error = kproc_create(g_eli_worker, wr, &wr->w_proc, 0, 0,
848 g_eli_freesession(wr);
849 free(wr, M_ELI);
859 LIST_INSERT_HEAD(&sc->sc_workers, wr, w_next);