26 DetectStreamType(mtcp_manager_t mtcp, struct pkt_ctx *pctx,  in DetectStreamType()  argument
38 	if (mtcp->num_msp > 0) {  in DetectStreamType()
42 		TAILQ_FOREACH(walk, &mtcp->monitors, link) {  in DetectStreamType()
64 	if (mtcp->listener) {  in DetectStreamType()
66 		addr = &mtcp->listener->socket->saddr;  in DetectStreamType()
88 CreateServerStream(mtcp_manager_t mtcp, int type, struct pkt_ctx *pctx)  in CreateServerStream()  argument
93 	cur_stream = CreateTCPStream(mtcp, NULL, type,  in CreateServerStream()
112 CreateMonitorStream(mtcp_manager_t mtcp, struct pkt_ctx* pctx,   in CreateMonitorStream()  argument
118 	stream = CreateDualTCPStream(mtcp, NULL, stream_type, pctx->p.iph->daddr,  in CreateMonitorStream()
181 FindStream(mtcp_manager_t mtcp, struct pkt_ctx *pctx, unsigned int *hash)  in FindStream()  argument
190 	return HTSearch(mtcp->tcp_flow_table, &temp_stream, hash);  in FindStream()
196 CreateStream(mtcp_manager_t mtcp, struct pkt_ctx *pctx, unsigned int *hash)   in CreateStream()  argument
206 		stream_type = DetectStreamType(mtcp, pctx, iph->daddr, tcph->dest);  in CreateStream()
210 			DumpIPPacket(mtcp, iph, pctx->p.ip_len);  in CreateStream()
217 			cur_stream = CreateServerStream(mtcp, stream_type, pctx);  in CreateStream()
221 				DumpIPPacket(mtcp, iph, pctx->p.ip_len);  in CreateStream()
230 			cur_stream = CreateClientTCPStream(mtcp, NULL, stream_type,  in CreateStream()
235 			cur_stream = CreateMonitorStream(mtcp, pctx, stream_type, hash);  in CreateStream()
240 				DumpIPPacket(mtcp, iph, pctx->p.ip_len);  in CreateStream()
252 		DumpIPPacket(mtcp, iph, pctx->p.ip_len);  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()
284 UpdateMonitor(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream,   in UpdateMonitor()  argument
303 			UpdatePassiveSendTCPContext(mtcp, sendside_stream, pctx);  in UpdateMonitor()
309 				HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side,  in UpdateMonitor()
314 				HandleCallback(mtcp, MOS_HK_SND, walk, sendside_stream->side,  in UpdateMonitor()
324 		if ((recvside_stream = AttachServerTCPStream(mtcp, sendside_stream, 0,  in UpdateMonitor()
327 			DestroyTCPStream(mtcp, sendside_stream);  in UpdateMonitor()
342 	PostSendTCPAction(mtcp, pctx, recvside_stream, sendside_stream);  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()
361 				HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side,  in UpdateMonitor()
366 				HandleCallback(mtcp, MOS_HK_RCV, walk, recvside_stream->side,  in UpdateMonitor()
378 HandleMonitorStream(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream,   in HandleMonitorStream()  argument
381 	UpdateMonitor(mtcp, sendside_stream, recvside_stream, pctx, true);  in HandleMonitorStream()
386 		DoActionEndTCPPacket(mtcp, recvside_stream, pctx);  in HandleMonitorStream()
390 			ForwardIPPacket(mtcp, pctx);  in HandleMonitorStream()
403 				DestroyTCPStream(mtcp, recvside_stream);  in HandleMonitorStream()
409 ProcessInTCPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx)  in ProcessInTCPPacket()  argument
424 	TAILQ_FOREACH(walk, &mtcp->monitors, link)  in ProcessInTCPPacket()
426 			HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH,  in ProcessInTCPPacket()
440 		if (pctx->forward && mtcp->num_msp)  in ProcessInTCPPacket()
441 			ForwardIPPacket(mtcp, pctx);  in ProcessInTCPPacket()
448 	cur_stream = FindStream(mtcp, pctx, &hash);  in ProcessInTCPPacket()
454 		if (mtcp->listener == NULL && mtcp->num_msp == 0) {  in ProcessInTCPPacket()
460 		cur_stream = CreateStream(mtcp, pctx, &hash);  in ProcessInTCPPacket()
473 			HandleSockStream(mtcp, cur_stream, pctx);  in ProcessInTCPPacket()
476 			HandleMonitorStream(mtcp, cur_stream, cur_stream->pair_stream, pctx);  in ProcessInTCPPacket()
486 		TAILQ_FOREACH(walk, &mtcp->monitors, link) {  in ProcessInTCPPacket()
493 				HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH,  in ProcessInTCPPacket()
497 		if (mtcp->listener) {  in ProcessInTCPPacket()
503 				SendTCPPacketStandalone(mtcp,  in ProcessInTCPPacket()
510 			ForwardIPPacket(mtcp, pctx);  in ProcessInTCPPacket()