dev/firewire/if_fwe.c

211 	struct fw_xferq *xferq;
219 		xferq = fc->ir[fwe->dma_ch];
221 		if (xferq->flag & FWXFERQ_RUNNING)
223 		xferq->flag &=
226 		xferq->hand =  NULL;
228 		for (i = 0; i < xferq->bnchunk; i++)
229 			m_freem(xferq->bulkxfer[i].mbuf);
230 		free(xferq->bulkxfer, M_FWE);
239 		xferq->bulkxfer =  NULL;
277 	struct fw_xferq *xferq;
292 		xferq = fc->ir[fwe->dma_ch];
293 		xferq->flag |= FWXFERQ_EXTBUF |
297 		xferq->flag &= ~0xff;
298 		xferq->flag |= fwe->stream_ch & 0xff;
300 		xferq->sc = (caddr_t) fwe;
301 		xferq->hand = fwe_as_input;
302 		xferq->bnchunk = rx_queue_len;
303 		xferq->bnpacket = 1;
304 		xferq->psize = MCLBYTES;
305 		xferq->queued = 0;
306 		xferq->buf = NULL;
307 		xferq->bulkxfer = (struct fw_bulkxfer *) malloc(
308 			sizeof(struct fw_bulkxfer) * xferq->bnchunk,
310 		STAILQ_INIT(&xferq->stvalid);
311 		STAILQ_INIT(&xferq->stfree);
312 		STAILQ_INIT(&xferq->stdma);
313 		xferq->stproc = NULL;
314 		for (i = 0; i < xferq->bnchunk; i++) {
316 			xferq->bulkxfer[i].mbuf = m;
318 			STAILQ_INSERT_TAIL(&xferq->stfree,
319 					&xferq->bulkxfer[i], link);
333 		xferq = fc->ir[fwe->dma_ch];
337 	if ((xferq->flag & FWXFERQ_RUNNING) == 0)
493 	struct fw_xferq *xferq;
498 	xferq = fwe->fd.fc->atq;
499 	while ((xferq->queued < xferq->maxq - 1) &&
545 		xferq->start(fwe->fd.fc);
550 fwe_as_input(struct fw_xferq *xferq)
559 	fwe = (struct fwe_softc *)xferq->sc;
563 	while ((sxfer = STAILQ_FIRST(&xferq->stvalid)) != NULL) {
564 		STAILQ_REMOVE_HEAD(&xferq->stvalid, link);
574 			STAILQ_INSERT_TAIL(&xferq->stfree, sxfer, link);
607 	if (STAILQ_FIRST(&xferq->stfree) != NULL)