1125 	cur_stream->sndvar->cwnd = 1;  in mtcp_connect()
1126 	cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 10;  in mtcp_connect()
1256 	cur_stream->sndvar->on_closeq = TRUE;  in CloseStreamSocket()
1433 	if (cur_stream->sndvar->on_resetq) {  in mtcp_abort()
1440 	cur_stream->sndvar->on_resetq = TRUE;  in mtcp_abort()
1486 		if (rcvvar->rcv_wnd > cur_stream->sndvar->eff_mss) {  in CopyToUser()
1487 			if (!cur_stream->sndvar->on_ackq) {  in CopyToUser()
1489 				cur_stream->sndvar->on_ackq = TRUE;  in CopyToUser()
1730 	struct tcp_send_vars *sndvar = cur_stream->sndvar;  in CopyFromUser()  local
1734 	sndlen = MIN((int)sndvar->snd_wnd, len);  in CopyFromUser()
1741 	if (!sndvar->sndbuf) {  in CopyFromUser()
1742 		sndvar->sndbuf = SBInit(mtcp->rbm_snd, sndvar->iss + 1);  in CopyFromUser()
1743 		if (!sndvar->sndbuf) {  in CopyFromUser()
1751 	ret = SBPut(mtcp->rbm_snd, sndvar->sndbuf, buf, sndlen);  in CopyFromUser()
1753 	sndvar->snd_wnd = sndvar->sndbuf->size - sndvar->sndbuf->len;  in CopyFromUser()
1756 				ret, sndlen, sndvar->sndbuf->len);  in CopyFromUser()
1761 	if (sndvar->snd_wnd <= 0) {  in CopyFromUser()
1763 				cur_stream->id, sndvar->snd_wnd);  in CopyFromUser()
1775 	struct tcp_send_vars *sndvar;  in mtcp_write()  local
1824 	sndvar = cur_stream->sndvar;  in mtcp_write()
1826 	SBUF_LOCK(&sndvar->write_lock);  in mtcp_write()
1829 	SBUF_UNLOCK(&sndvar->write_lock);  in mtcp_write()
1831 	if (ret > 0 && !(sndvar->on_sendq || sndvar->on_send_list)) {  in mtcp_write()
1833 		sndvar->on_sendq = TRUE;  in mtcp_write()
1845 	if (sndvar->snd_wnd > 0) {  in mtcp_write()
1862 	struct tcp_send_vars *sndvar;  in mtcp_writev()  local
1898 	sndvar = cur_stream->sndvar;  in mtcp_writev()
1899 	SBUF_LOCK(&sndvar->write_lock);  in mtcp_writev()
1916 	SBUF_UNLOCK(&sndvar->write_lock);  in mtcp_writev()
1918 	if (to_write > 0 && !(sndvar->on_sendq || sndvar->on_send_list)) {  in mtcp_writev()
1920 		sndvar->on_sendq = TRUE;  in mtcp_writev()
1932 	if (sndvar->snd_wnd > 0) {  in mtcp_writev()