285 			struct tcp_stream *recvside_stream, struct pkt_ctx *pctx,  in UpdateMonitor()  argument
322 	if (recvside_stream == NULL) {  in UpdateMonitor()
324 		if ((recvside_stream = AttachServerTCPStream(mtcp, sendside_stream, 0,  in UpdateMonitor()
331 		recvside_stream->rcvvar->irs = pctx->p.seq;  in UpdateMonitor()
332 		recvside_stream->sndvar->peer_wnd = pctx->p.window;  in UpdateMonitor()
333 		recvside_stream->rcv_nxt = recvside_stream->rcvvar->irs + 1;  in UpdateMonitor()
334 		recvside_stream->sndvar->cwnd = 1;  in UpdateMonitor()
336 		ParseTCPOptions(recvside_stream, pctx->p.cur_ts,  in UpdateMonitor()
342 	PostSendTCPAction(mtcp, pctx, recvside_stream, sendside_stream);  in UpdateMonitor()
344 	if (/*1*/recvside_stream->status_mgmt) {  in UpdateMonitor()
345 		recvside_stream->cb_events = MOS_ON_PKT_IN;  in UpdateMonitor()
348 		PreRecvTCPEventPrediction(mtcp, pctx, recvside_stream);  in UpdateMonitor()
354 			UpdateRecvTCPContext(mtcp, recvside_stream, pctx);  in UpdateMonitor()
356 			UpdatePassiveRecvTCPContext(mtcp, recvside_stream, pctx);  in UpdateMonitor()
359 		if (recvside_stream->side == MOS_SIDE_CLI) {  in UpdateMonitor()
360 			SOCKQ_FOREACH_REVERSE(walk, &recvside_stream->msocks) {  in UpdateMonitor()
361 				HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side,  in UpdateMonitor()
362 					       pctx, recvside_stream->cb_events);  in UpdateMonitor()
365 			SOCKQ_FOREACH_START(walk, &recvside_stream->msocks) {  in UpdateMonitor()
366 				HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side,  in UpdateMonitor()
367 					       pctx, recvside_stream->cb_events);  in UpdateMonitor()
373 	recvside_stream->cb_events = 0;  in UpdateMonitor()
379 			struct tcp_stream *recvside_stream, struct pkt_ctx *pctx)   in HandleMonitorStream()  argument
381 	UpdateMonitor(mtcp, sendside_stream, recvside_stream, pctx, true);  in HandleMonitorStream()
383 	recvside_stream = sendside_stream->pair_stream;  in HandleMonitorStream()
385 	if (HAS_STREAM_TYPE(recvside_stream, MOS_SOCK_STREAM)) {  in HandleMonitorStream()
386 		DoActionEndTCPPacket(mtcp, recvside_stream, pctx);  in HandleMonitorStream()
392 		if (recvside_stream->stream_type == sendside_stream->stream_type &&  in HandleMonitorStream()
393 		    IS_STREAM_TYPE(recvside_stream, MOS_SOCK_MONITOR_STREAM_ACTIVE)) {  in HandleMonitorStream()
394 			if (((recvside_stream->state == TCP_ST_TIME_WAIT &&  in HandleMonitorStream()
396 			     recvside_stream->state == TCP_ST_CLOSED_RSVD ||  in HandleMonitorStream()
397 			     !recvside_stream->status_mgmt) &&  in HandleMonitorStream()
403 				DestroyTCPStream(mtcp, recvside_stream);  in HandleMonitorStream()