90 	tcp_stream *cur_stream = NULL;  in CreateServerStream()  local
93 	cur_stream = CreateTCPStream(mtcp, NULL, type,  in CreateServerStream()
96 	if (!cur_stream) {  in CreateServerStream()
101 	cur_stream->rcvvar->irs = pctx->p.seq;  in CreateServerStream()
102 	cur_stream->sndvar->peer_wnd = pctx->p.window;  in CreateServerStream()
103 	cur_stream->rcv_nxt = cur_stream->rcvvar->irs;  in CreateServerStream()
104 	cur_stream->sndvar->cwnd = 1;  in CreateServerStream()
105 	ParseTCPOptions(cur_stream, pctx->p.cur_ts, (uint8_t *)pctx->p.tcph +   in CreateServerStream()
108 	return cur_stream;  in CreateServerStream()
198 	tcp_stream *cur_stream = NULL;  in CreateStream()  local
217 			cur_stream = CreateServerStream(mtcp, stream_type, pctx);  in CreateStream()
218 			if (!cur_stream) {  in CreateStream()
230 			cur_stream = CreateClientTCPStream(mtcp, NULL, stream_type,  in CreateStream()
235 			cur_stream = CreateMonitorStream(mtcp, pctx, stream_type, hash);  in CreateStream()
237 			if (!cur_stream) {  in CreateStream()
247 		return cur_stream;  in CreateStream()
276 HandleSockStream(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,   in HandleSockStream()  argument
279 	UpdateRecvTCPContext(mtcp, cur_stream, pctx);  in HandleSockStream()
280 	DoActionEndTCPPacket(mtcp, cur_stream, pctx);	  in HandleSockStream()
412 	struct tcp_stream *cur_stream;  in ProcessInTCPPacket()  local
448 	cur_stream = FindStream(mtcp, pctx, &hash);  in ProcessInTCPPacket()
449 	if (!cur_stream) {  in ProcessInTCPPacket()
460 		cur_stream = CreateStream(mtcp, pctx, &hash);  in ProcessInTCPPacket()
461 		if (!cur_stream)  in ProcessInTCPPacket()
465 	if (cur_stream) {  in ProcessInTCPPacket()
466 		cur_stream->cb_events = events;  in ProcessInTCPPacket()
468 		if (cur_stream->rcvvar && cur_stream->rcvvar->rcvbuf)  in ProcessInTCPPacket()
469 			pctx->p.offset = (uint64_t)seq2loff(cur_stream->rcvvar->rcvbuf,  in ProcessInTCPPacket()
470 					pctx->p.seq, cur_stream->rcvvar->irs + 1);  in ProcessInTCPPacket()
472 		if (IS_STREAM_TYPE(cur_stream, MOS_SOCK_STREAM))  in ProcessInTCPPacket()
473 			HandleSockStream(mtcp, cur_stream, pctx);  in ProcessInTCPPacket()
475 		else if (HAS_STREAM_TYPE(cur_stream, MOS_SOCK_MONITOR_STREAM_ACTIVE))  in ProcessInTCPPacket()
476 			HandleMonitorStream(mtcp, cur_stream, cur_stream->pair_stream, pctx);  in ProcessInTCPPacket()