sys/netinet/sctp_output.c

2479 	 * first question, is the ifn we will emit on in our list, if so, we
2516 	 * can't get one on the emitting interface so let's find first a
2604 	 * first question, is the ifn we will emit on in our list, if so, we
2616 	 * first question, is the ifn we will emit on in our list?  If so,
2824 			 * don't list it to the peer so we will get an
3330 	 * interface address in route, Is it in the bound list. If so we
3911 		/* no space, so free the entire chain */
4042 	struct socket *so = NULL;
4233 				 * (or valid source addr), so we can't get
4284 				so = SCTP_INP_SO(inp);
4285 				SCTP_SOCKET_UNLOCK(so, 0);
4293 				SCTP_SOCKET_LOCK(so, 0);
4524 				 * (or valid source addr), so we can't get
4629 				so = SCTP_INP_SO(inp);
4630 				SCTP_SOCKET_UNLOCK(so, 0);
4642 				SCTP_SOCKET_LOCK(so, 0);
5389 	/* Ok so far lets munge through the rest of the packet */
5519 	struct socket *so;
5861 	so = inp->sctp_socket;
5862 	if (so == NULL) {
5867 		initack->init.a_rwnd = htonl(max(SCTP_SB_LIMIT_RCV(so), SCTP_MINIMAL_RWND));
6148 					 * priority so if the one we are
6592 			/* can't copy so we are done */
6671 				 * there is nothing queued to send, so I'm
6698 				 * so set SHUTDOWN_PENDING
6775 	 * the send time.. so you would push up a notification if any send
7115 	 * get a full msg in so we have to allow splitting.
7467 			 * all the data if there is no leading space, so we
7793 	 * see if the cwnd/rwnd allows any output, if so we go ahead and
7961 			/* null so to beginning */
8684 							 * so done bundling
9447 		/* send back 0/0 so we enter normal transmission */
9662 					/* different keyid, so done bundling */
9721 							 * so done bundling
9745 					/* can't fit so we are done */
9943 	 * - See if there are retransmits pending, if so we must
9949 	 * - Check to see if the cwnd/rwnd allows any output, if so we
9989 	 * running, if so piggy-back the sack.
10042 			 * The count was off.. retran is not happening so do
10197 	 * it. It must be marked as UNSENT again so next call will continue
10423 	 * If so, we will take and and remove the old one.
10479 			/* No memory so we drop the idea, and set a timer */
10526 		 * No duplicates so we use the last place we received data
10876 		/* NO Auth chunk prepended, so reserve space in front */
11372 	/* nope could not find one to update so we must build one */
12135 	 * processing is up and running so care must be taken to spl...()
12216 sctp_sosend(struct socket *so,
12254 	error = sctp_lower_sosend(so, addr_to_use, uio, top,
12265 sctp_lower_sosend(struct socket *so,
12308 	t_inp = inp = (struct sctp_inpcb *)so->so_pcb;
12513 				 * Set the connected flag so we can queue
12516 				soisconnecting(so);
12588 	if (SCTP_SO_IS_NBIO(so)
12600 		if ((SCTP_SB_LIMIT_SND(so) < (sndlen + inqueue_bytes + stcb->asoc.sb_send_resv)) ||
12603 			if (sndlen > SCTP_SB_LIMIT_SND(so))
12740 		/* now relock the stcb so everything is sane */
12755 	if (SCTP_SB_LIMIT_SND(so) > inqueue_bytes) {
12760 			max_len = SCTP_SB_LIMIT_SND(so) - inqueue_bytes;
12800 		local_add_more = min(SCTP_SB_LIMIT_SND(so), SCTP_BASE_SYSCTL(sctp_add_more_threshold));
12813 	    (SCTP_SB_LIMIT_SND(so) >= local_add_more)) ||
12817 		SOCKBUF_LOCK(&so->so_snd);
12819 		while ((SCTP_SB_LIMIT_SND(so) < (inqueue_bytes + local_add_more)) ||
12822 			    (unsigned int)SCTP_SB_LIMIT_SND(so),
12833 			error = sbwait(&so->so_snd);
12835 			if (error || so->so_error || be.error) {
12837 					if (so->so_error)
12838 						error = so->so_error;
12843 				SOCKBUF_UNLOCK(&so->so_snd);
12855 		if (SCTP_SB_LIMIT_SND(so) > inqueue_bytes) {
12856 			max_len = SCTP_SB_LIMIT_SND(so) - inqueue_bytes;
12860 		SOCKBUF_UNLOCK(&so->so_snd);
12944 			if (SCTP_SB_LIMIT_SND(so) > stcb->asoc.total_output_queue_size)
12945 				max_len = SCTP_SB_LIMIT_SND(so) - stcb->asoc.total_output_queue_size;
12950 			    (max_len && (SCTP_SB_LIMIT_SND(so) < SCTP_BASE_SYSCTL(sctp_add_more_threshold))) ||
13020 				if (SCTP_SB_LIMIT_SND(so) > stcb->asoc.total_output_queue_size)
13021 					max_len = SCTP_SB_LIMIT_SND(so) - inqueue_bytes;
13121 			SOCKBUF_LOCK(&so->so_snd);
13131 			 * LOCK the so->so_snd to do the actual sowwakeup(). So
13136 			if (SCTP_SB_LIMIT_SND(so) <= (stcb->asoc.total_output_queue_size +
13137 			    min(SCTP_BASE_SYSCTL(sctp_add_more_threshold), SCTP_SB_LIMIT_SND(so)))) {
13144 				error = sbwait(&so->so_snd);
13147 				if (error || so->so_error || be.error) {
13149 						if (so->so_error)
13150 							error = so->so_error;
13155 					SOCKBUF_UNLOCK(&so->so_snd);
13163 			SOCKBUF_UNLOCK(&so->so_snd);
13224 			/* there is nothing queued to send, so I'm done... */
13250 			 * we still got (or just got) data to send, so set
13288 					 * now relock the stcb so everything
13430 		SCTP_PRINTF("Warning - inp is NULL so cant validate locks\n");