bsd/netat/adsp_stream.c

84 void adsp_input(mp)
85 	gbuf_t *mp;
92 	switch (gbuf_type(mp)) {
94 		p = (at_ddp_t *)gbuf_rptr(mp);
98 			gbuf_freem(mp);
110 				gbuf_freem(mp);
115 			gbuf_next(mp) = 0;
118 				gbuf_next(mb) = mp;
120 				sp->deferred_mb = mp;
124 		while (mp) {
125 			adsp_rput(sp->gref, mp);
126 			if ((mp = sp->deferred_mb) != 0) {
127 				sp->deferred_mb = gbuf_next(mp);
128 				gbuf_next(mp) = 0;
136 		gref = (gref_t *)((ioc_t *)gbuf_rptr(mp))->ioc_private;
146 		gbuf_freem(mp);
150 	adsp_rput(gref, mp);
273 void adsp_rput(gref, mp)
275     gbuf_t *mp;
277   switch (gbuf_type(mp)) {
281 	switch (adspReadHandler(gref, mp)) {
283 	    atalk_putnext(gref, mp);
298     	switch (gbuf_type(mp)) {
302 	    if (adspReadHandler(gref, mp) == STR_PUTNEXT)
303 		atalk_putnext(gref, mp);
306 	    atalk_putnext(gref, mp);
321 int adsp_wput(gref, mp)
323     gbuf_t *mp;
335 	if (gbuf_type(mp) == MSG_IOCTL) {
336 		iocbp = (ioc_t *)gbuf_rptr(mp);
342 			if (gbuf_cont(mp) == NULL) {
344 				adsp_iocnak(gref, mp, EINVAL);
346 			v = *(unsigned char *)gbuf_rptr(gbuf_cont(mp));
351 				adsp_iocnak(gref, mp, EINVAL);
357 						adsp_iocnak(gref, mp, EINVAL);
366 				*(unsigned char *)gbuf_rptr(gbuf_cont(mp)) = v;
369 				adsp_iocack(gref, mp);
379 			if (((xm = gbuf_cont(mp)) == NULL)
382 				adsp_iocnak(gref, mp, ENOBUFS);
385 			gbuf_cont(mp) = xm;
403 			adsp_iocack(gref, mp);
408 			if (((xm = gbuf_cont(mp)) == NULL) &&
411 			    adsp_iocnak(gref, mp, ENOBUFS);
414 			gbuf_cont(mp) = xm;
420 			    (ddp_addr_t *)gbuf_rptr(gbuf_cont(mp));
427 			adsp_iocack(gref, mp);
433 	    gbuf_freem(mp);
435 	    rc = adspWriteHandler(gref, mp);
439 		if (gbuf_type(mp) == MSG_IOCTL) {
440 		    iocbp = (ioc_t *)gbuf_rptr(mp);
443 		DDP_OUTPUT(mp);
449 		gbuf_freem(mp);
614 void SndMsgUp(gref, mp)
616 	gbuf_t *mp;
620 	  ("SndMsgUp: gref=0x%x, mbuf=0x%x\n",	(unsigned)gref, (unsigned)mp));
621     trace_mbufs(D_M_ADSP, "        m", mp);
623     atalk_putnext(gref, mp);