bsd/kern/uipc_socket2.c

77 #include <sys/mbuf.h>
106 static inline void sbcompress(struct sockbuf *, struct mbuf *, struct mbuf *);
109     struct mbuf *, struct mbuf *);
110 static int sbappendcontrol_internal(struct sockbuf *, struct mbuf *,
111     struct mbuf *);
121  * Based on the number of mbuf clusters configured, high_sb_max and sb_max can
598  *    any associated data (mbuf's must be of type MT_SONAME).
602  *    should be present (mbuf's must be of type MT_RIGHTS).
664  * Free mbufs held by a socket, and reserved mbuf space.
677  * data from an mbuf queue.
701  * Append mbuf chain m to the last record in the
703  * the mbuf chain is recorded in sb.  Empty mbufs are
707 sbappend(struct sockbuf *sb, struct mbuf *m)
745 sbappendstream(struct sockbuf *sb, struct mbuf *m)
783 	struct mbuf *m;
784 	struct mbuf *n = 0;
818 	struct mbuf *m = sb->sb_mb;
836 	struct mbuf *m = sb->sb_mb;
837 	struct mbuf *n;
860  * Similar to sbappend, except the mbuf chain begins a new record.
863 sbappendrecord(struct sockbuf *sb, struct mbuf *m0)
865 	struct mbuf *m;
923 sbinsertoob(struct sockbuf *sb, struct mbuf *m0)
925 	struct mbuf *m;
926 	struct mbuf **mp;
962 	 * Put the first mbuf on the queue.
994     struct mbuf *m0, struct mbuf *control)
996 	struct mbuf *m, *n, *nlast;
1055 sbappendaddr(struct sockbuf *sb, struct sockaddr *asa, struct mbuf *m0,
1056     struct mbuf *control, int *error_out)
1109 sbappendcontrol_internal(struct sockbuf *sb, struct mbuf *m0,
1110     struct mbuf *control)
1112 	struct mbuf *m, *mlast, *n;
1152 sbappendcontrol(struct sockbuf *sb, struct mbuf	*m0, struct mbuf *control,
1207 sbappendmsgstream_rcv(struct sockbuf *sb, struct mbuf *m, uint32_t seqnum,
1210 	struct mbuf *m_eor = NULL;
1219 	/* Keep the TCP sequence number in the mbuf pkthdr */
1222 	/* find last mbuf and set M_EOR */
1265 sbappendstream_rcvdemux(struct socket *so, struct mbuf *m, uint32_t seqnum,
1291 sbappendmptcpstream_rcv(struct sockbuf *sb, struct mbuf *m)
1332 sbappendmsg_snd(struct sockbuf *sb, struct mbuf *m)
1354 	/* note if we need to propogate M_EOR to the last mbuf */
1358 		/* Reset M_EOR from the first mbuf */
1425 		struct mbuf *m = NULL, *mqhead = NULL, *mend = NULL;
1462 				 * If we have only one more mbuf left,
1463 				 * move the last mbuf of this message to
1489 			 * the mbuf that is being dequeued, update
1533  * Compress mbuf chain m into the socket
1534  * buffer sb following mbuf n.  If n
1538 sbcompress(struct sockbuf *sb, struct mbuf *m, struct mbuf *n)
1541 	struct mbuf *o;
1617 	struct mbuf *m;
1676 		 * Don't call sbdrop(sb, 0) if the leading mbuf is non-empty:
1701  * use m_freem_list to free the mbuf structures
1713 	struct mbuf *m, *free_list, *ml;
1714 	struct mbuf *next, *last;
1729 	ml = (struct mbuf *)0;
1783 		ml->m_next = (struct mbuf *)0;
1784 		last->m_nextpkt = (struct mbuf *)0;
1819 	struct mbuf *m, *mn;
1835  * Create a "control" mbuf containing the specified data
1838 struct mbuf *
1842 	struct mbuf *m;
1845 		return ((struct mbuf *)NULL);
1847 		return ((struct mbuf *)NULL);
1859 struct mbuf **
1860 sbcreatecontrol_mbuf(caddr_t p, int size, int type, int level, struct mbuf **mp)
1862 	struct mbuf *m;
2007 pru_rcvoob_notsupp(struct socket *so, struct mbuf *m, int flags)
2014 pru_send_notsupp(struct socket *so, int flags, struct mbuf *m,
2015     struct sockaddr *addr, struct mbuf *control, struct proc *p)
2046     struct mbuf *top, struct mbuf *control, int flags)
2054     struct uio *uio, struct mbuf **mp0, struct mbuf **controlp, int *flagsp)
2159 msgq_sbspace(struct socket *so, struct mbuf *control)
2207 sballoc(struct sockbuf *sb, struct mbuf *m)
2226 sbfree(struct sockbuf *sb, struct mbuf *m)