115 	tcp_stream *stream = NULL;  in CreateMonitorStream()  local
118 	stream = CreateDualTCPStream(mtcp, NULL, stream_type, pctx->p.iph->daddr,  in CreateMonitorStream()
121 	if (!stream)  in CreateMonitorStream()
124 	stream->side = MOS_SIDE_CLI;  in CreateMonitorStream()
125 	stream->pair_stream->side = MOS_SIDE_SVR;  in CreateMonitorStream()
127 	stream->rcvvar->irs = pctx->p.seq;  in CreateMonitorStream()
128 	stream->sndvar->peer_wnd = pctx->p.window;  in CreateMonitorStream()
129 	stream->rcv_nxt = stream->rcvvar->irs + 1;  in CreateMonitorStream()
130 	stream->sndvar->cwnd = 1;  in CreateMonitorStream()
137 	if (IS_STREAM_TYPE(stream, MOS_SOCK_MONITOR_STREAM_ACTIVE)) {  in CreateMonitorStream()
138 		assert(IS_STREAM_TYPE(stream->pair_stream,  in CreateMonitorStream()
141 		stream->buffer_mgmt = FALSE;  in CreateMonitorStream()
142 		stream->pair_stream->buffer_mgmt = FALSE;  in CreateMonitorStream()
150 		stream->status_mgmt = 0;  in CreateMonitorStream()
151 		SOCKQ_FOREACH_START(walk, &stream->msocks) {  in CreateMonitorStream()
153 			if (bm > stream->buffer_mgmt) {  in CreateMonitorStream()
154 				stream->buffer_mgmt = bm;  in CreateMonitorStream()
157 				stream->status_mgmt = 1;  in CreateMonitorStream()
161 		stream->pair_stream->status_mgmt = 0;  in CreateMonitorStream()
162 		SOCKQ_FOREACH_START(walk, &stream->pair_stream->msocks) {  in CreateMonitorStream()
164 			if (bm > stream->pair_stream->buffer_mgmt) {  in CreateMonitorStream()
165 				stream->pair_stream->buffer_mgmt = bm;  in CreateMonitorStream()
168 				stream->pair_stream->status_mgmt = 1;  in CreateMonitorStream()
173 	ParseTCPOptions(stream, pctx->p.cur_ts,  in CreateMonitorStream()
177 	return stream;  in CreateMonitorStream()