common/io/stream.c

168 static void dblk_lastfree(mblk_t *mp, dblk_t *dbp);
169 static mblk_t *allocb_oversize(size_t size, int flags);
173 static void bcache_dblk_lastfree(mblk_t *mp, dblk_t *dbp);
362 	mblk_cache = kmem_cache_create("streams_mblk", sizeof (mblk_t), 32,
415 mblk_t *
419 	mblk_t *mp;
454 mblk_t *
455 allocb_tmpl(size_t size, const mblk_t *tmpl)
457 	mblk_t *mp = allocb(size, 0);
474 mblk_t *
477 	mblk_t *mp = allocb(size, 0);
489 mblk_t *
492 	mblk_t *mp = allocb_wait(size, 0, flags, error);
512 msg_getcred(const mblk_t *mp, pid_t *cpidp)
516 	mblk_t *mp2;
574 msg_extractcred(mblk_t *mp, pid_t *cpidp)
578 	mblk_t *mp2;
628 msg_getlabel(const mblk_t *mp)
639 freeb(mblk_t *mp)
653 freemsg(mblk_t *mp)
658 		mblk_t *mp_cont = mp->b_cont;
677 mblk_t	*
678 reallocb(mblk_t *mp, size_t size, uint_t copy)
680 	mblk_t		*mp1;
721 dblk_lastfree(mblk_t *mp, dblk_t *dbp)
745 dblk_decref(mblk_t *mp, dblk_t *dbp)
769 mblk_t *
770 dupb(mblk_t *mp)
773 	mblk_t *new_mp;
809 dblk_lastfree_desb(mblk_t *mp, dblk_t *dbp)
839 static mblk_t *
841 	void (*lastfree)(mblk_t *, dblk_t *), int kmflags)
844 	mblk_t *mp;
870 mblk_t *
873 	mblk_t *mp;
897 mblk_t *
900 	mblk_t *mp;
920 mblk_t *
923 	mblk_t *mp;
944 mblk_t *
947 	mblk_t *mp;
968 mblk_t *
971 	mblk_t *mp;
992 bcache_dblk_lastfree(mblk_t *mp, dblk_t *dbp)
1072 mblk_t *
1076 	mblk_t *mp = NULL;
1109 dblk_lastfree_oversize(mblk_t *mp, dblk_t *dbp)
1128 static mblk_t *
1131 	mblk_t *mp;
1147 mblk_t *
1151 	mblk_t *bp;
1168 mblk_t *
1172 	mblk_t *mp;
1224 mblk_t *
1228 	mblk_t		*mp;
1239 	 * Set the mblk_t information and ptrs correctly.
1355 mblk_t *
1356 dupmsg(mblk_t *bp)
1358 	mblk_t *head, *nbp;
1378 mblk_t *
1379 dupmsg_noloan(mblk_t *bp)
1381 	mblk_t *head, *nbp;
1404 mblk_t *
1405 copyb(mblk_t *bp)
1407 	mblk_t	*nbp;
1475 mblk_t *
1476 copymsg(mblk_t *bp)
1478 	mblk_t *head, *nbp;
1498 linkb(mblk_t *mp, mblk_t *bp)
1512 mblk_t *
1513 unlinkb(mblk_t *bp)
1515 	mblk_t *bp1;
1528 mblk_t *
1529 rmvb(mblk_t *mp, mblk_t *bp)
1531 	mblk_t *tmp;
1532 	mblk_t *lastp = NULL;
1546 	return ((mblk_t *)-1);
1556 pullupmsg(mblk_t *mp, ssize_t len)
1558 	mblk_t *bp, *b_cont;
1608 		ASSERT(n >= 0);		/* allow zero-length mblk_t's */
1632 mblk_t *
1633 msgpullup(mblk_t *mp, ssize_t len)
1635 	mblk_t	*newmp;
1668 		ASSERT(n >= 0);		/* allow zero-length mblk_t's */
1694 adjmsg(mblk_t *mp, ssize_t len)
1696 	mblk_t *bp;
1697 	mblk_t *save_bp = NULL;
1698 	mblk_t *prev_bp;
1699 	mblk_t *bcont;
1789 msgdsize(mblk_t *bp)
1855 mblk_t *
1858 	mblk_t *bp;
1897 mp_cont_len(mblk_t *bp, int *mblkcnt)
1899 	mblk_t	*mp;
1924 mblk_t *
1927 	mblk_t *bp, *mp1;
1928 	mblk_t *mp2 = NULL;
2192 rmvq(queue_t *q, mblk_t *mp)
2215 rmvq_noenab(queue_t *q, mblk_t *mp)
2308 	mblk_t *mp, *nmp;
2412 	mblk_t *mp;
2413 	mblk_t *nmp;
2414 	mblk_t *last;
2603 putq(queue_t *q, mblk_t *bp)
2605 	mblk_t *tmp;
2792 putbq(queue_t *q, mblk_t *bp)
2794 	mblk_t *tmp;
2983 insq(queue_t *q, mblk_t *emp, mblk_t *mp)
2985 	mblk_t *tmp;
3115 	mblk_t *bp;
3133 	mblk_t *bp;
3149 	mblk_t *bp;
3166 	mblk_t *bp;
3197 qreply(queue_t *q, mblk_t *bp)
3239 	mblk_t *mp;
3511 			*(mblk_t **)valp = qbp->qb_first;
3513 			*(mblk_t **)valp = q->q_first;
3518 			*(mblk_t **)valp = qbp->qb_last;
3520 			*(mblk_t **)valp = q->q_last;
3613 struioget(queue_t *q, mblk_t *mp, struiod_t *dp, int noblock)