sys/netinet/sctputil.c

3057     struct sctp_stream_queue_pending *sp, int so_locked
3091 		ssfe->ssfe_length = (uint32_t) (notifhdr_len + sp->length);
3094 		ssfe->ssfe_info.snd_sid = sp->stream;
3095 		if (sp->some_taken) {
3100 		ssfe->ssfe_info.snd_ppid = sp->ppid;
3101 		ssfe->ssfe_info.snd_context = sp->context;
3109 		ssf->ssf_length = (uint32_t) (notifhdr_len + sp->length);
3112 		ssf->ssf_info.sinfo_stream = sp->stream;
3114 		if (sp->some_taken) {
3119 		ssf->ssf_info.sinfo_ppid = sp->ppid;
3120 		ssf->ssf_info.sinfo_context = sp->context;
3124 	SCTP_BUF_NEXT(m_notify) = sp->data;
3127 	sp->data = NULL;
3837 	struct sctp_stream_queue_pending *sp, *nsp;
3909 		TAILQ_FOREACH_SAFE(sp, &outs->outqueue, next, nsp) {
3911 			TAILQ_REMOVE(&outs->outqueue, sp, next);
3912 			stcb->asoc.ss_functions.sctp_ss_remove_from_stream(stcb, asoc, outs, sp, holds_lock);
3913 			sctp_free_spbufspace(stcb, asoc, sp);
3914 			if (sp->data) {
3916 				    error, (void *)sp, so_locked);
3917 				if (sp->data) {
3918 					sctp_m_freem(sp->data);
3919 					sp->data = NULL;
3920 					sp->tail_mbuf = NULL;
3921 					sp->length = 0;
3924 			if (sp->net) {
3925 				sctp_free_remote_addr(sp->net);
3926 				sp->net = NULL;
3929 			sctp_free_a_strmoq(stcb, sp, so_locked);
4712 	struct sctp_stream_queue_pending *sp;
4831 		sp = TAILQ_FIRST(&strq->outqueue);
4832 		if (sp != NULL) {
4833 			sp->discard_rest = 1;
4856 					if (sp->sinfo_flags & SCTP_UNORDERED) {
4862 					if (sp->sinfo_flags & SCTP_UNORDERED) {
4868 				chk->rec.data.stream_number = sp->stream;
4869 				chk->rec.data.payloadtype = sp->ppid;
4870 				chk->rec.data.context = sp->context;
4871 				chk->flags = sp->act_flags;
4880 			if (sp->sinfo_flags & SCTP_UNORDERED) {
4884 				if ((sp->sinfo_flags & SCTP_UNORDERED) == 0) {
4888 				if (sp->sinfo_flags & SCTP_UNORDERED) {
4895 			if (sp->data) {
4901 				sctp_free_spbufspace(stcb, &stcb->asoc, sp);
4902 				ret_sz += sp->length;
4904 				sp->some_taken = 1;
4905 				sctp_m_freem(sp->data);
4906 				sp->data = NULL;
4907 				sp->tail_mbuf = NULL;
4908 				sp->length = 0;
6837 	struct mbuf *sp, *last;
6851 	 * rest in the sp.
6853 	sp = m_split(m, off, M_NOWAIT);
6854 	if (sp == NULL) {
6858 	if (sp->m_pkthdr.len < sizeof(struct udphdr) + sizeof(struct sctphdr)) {
6860 		m_freem(sp);
6864 	sp = m_pullup(sp, sizeof(struct udphdr) + sizeof(struct sctphdr));
6865 	if (sp == NULL) {
6870 	m_adj(sp, sizeof(struct udphdr));
6874 	last->m_next = sp;
6875 	m->m_pkthdr.len += sp->m_pkthdr.len;