Cross Reference: /illumos-gate/usr/src/uts/common/io/tirdwr.c

Lines Matching refs:mp
79 static void tirdwrrput(queue_t *q, mblk_t *mp);
80 static void tirdwrwput(queue_t *q, mblk_t *mp);
150 static void send_fatal(queue_t *q, mblk_t *mp);
213 	mblk_t *mp;
225 		if (mp = allocb(sizeof (struct T_discon_req), BPRI_LO)) {
226 			pptr = (union T_primitives *)mp->b_rptr;
227 			mp->b_wptr = mp->b_rptr + sizeof (struct T_ordrel_req);
229 			mp->b_datap->db_type = M_PROTO;
230 			putnext(WR(q), mp);
245 tirdwrrput(queue_t *q, mblk_t *mp)
256 		freemsg(mp);
260 	switch (mp->b_datap->db_type) {
263 		putnext(q, mp);
267 		putnext(q, mp);
273 		if ((mp->b_wptr - mp->b_rptr) < sizeof (t_scalar_t)) {
275 			freemsg(mp);
278 		pptr = (union T_primitives *)mp->b_rptr;
283 			send_fatal(q, mp);
286 			if (msgdsize(mp) == 0) {
287 				freemsg(mp);
291 			tmp = (mblk_t *)unlinkb(mp);
292 			freemsg(mp);
298 			mp->b_datap->db_type = M_DATA;
299 			mp->b_wptr = mp->b_rptr;
300 			putnext(q, mp);
306 			if (msgdsize(mp) != 0) {
307 				tmp = (mblk_t *)unlinkb(mp);
310 			mp->b_datap->db_type = M_HANGUP;
311 			mp->b_wptr = mp->b_rptr;
312 			putnext(q, mp);
316 			send_fatal(q, mp);
329 tirdwrwput(queue_t *q, mblk_t *mp)
338 		freemsg(mp);
342 	switch (mp->b_datap->db_type) {
344 		putnext(q, mp);
348 		putnext(q, mp);
353 		send_fatal(q, mp);
360 send_fatal(queue_t *q, mblk_t *mp)
367 	mp->b_datap->db_type = M_ERROR;
368 	*mp->b_datap->db_base = EPROTO;
369 	mp->b_rptr = mp->b_datap->db_base;
370 	mp->b_wptr = mp->b_datap->db_base + sizeof (char);
371 	freemsg(unlinkb(mp));
373 		putnext(q, mp);
375 		qreply(q, mp);
381 	mblk_t *mp;
384 	for (mp = q->q_next->q_first; mp != NULL; mp = mp->b_next) {
386 		switch (mp->b_datap->db_type) {
388 			pptr = (union T_primitives *)mp->b_rptr;
389 			if ((mp->b_wptr - mp->b_rptr) < sizeof (t_scalar_t))
396 				if (mp->b_cont &&
397 				    (mp->b_cont->b_datap->db_type != M_DATA))
421 	mblk_t *mp;
428 	for (mp = q->q_first; mp != NULL; ) {
430 		switch (mp->b_datap->db_type) {
432 			pptr = (union T_primitives *)mp->b_rptr;
436 				if (msgdsize(mp) == 0) {
438 					tmp = mp->b_next;
439 					rmvq(q, mp);
440 					freemsg(mp);
441 					mp = tmp;
444 				emp = mp->b_next;
445 				rmvq(q, mp);
446 				tmp = (mblk_t *)unlinkb(mp);
447 				freeb(mp);
449 				mp = emp;
455 			if (msgdsize(mp) == 0)
457 			mp = mp->b_next;
461 			mp = mp->b_next;