23 Handle_TCP_ST_ESTABLISHED (mtcp_manager_t mtcp, tcp_stream* cur_stream, 
27 FilterSYNPacket(mtcp_manager_t mtcp, uint32_t ip, uint16_t port)  in FilterSYNPacket()  argument
34 	if (!mtcp->listener) {  in FilterSYNPacket()
39 	addr = &mtcp->listener->socket->saddr;  in FilterSYNPacket()
62 HandleActiveOpen(mtcp_manager_t mtcp, tcp_stream *cur_stream,   in HandleActiveOpen()  argument
79 		UpdateRetransmissionTimer(mtcp, cur_stream, pctx->p.cur_ts);  in HandleActiveOpen()
88 ValidateSequence(mtcp_manager_t mtcp, tcp_stream *cur_stream,   in ValidateSequence()  argument
157 				AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);  in ValidateSequence()
168 NotifyConnectionReset(mtcp_manager_t mtcp, tcp_stream *cur_stream)  in NotifyConnectionReset()  argument
176 ProcessRST(mtcp_manager_t mtcp, tcp_stream *cur_stream,   in ProcessRST()  argument
186 	DumpStream(mtcp, cur_stream);  in ProcessRST()
207 			RAISE_DEBUG_EVENT(mtcp, cur_stream,  in ProcessRST()
244 			RaiseCloseEvent(mtcp, cur_stream);  in ProcessRST()
251 EstimateRTT(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t mrtt)  in EstimateRTT()  argument
305 ProcessACK(mtcp_manager_t mtcp, tcp_stream *cur_stream,   in ProcessACK()  argument
369 				RaiseWriteEvent(mtcp, cur_stream);  in ProcessACK()
461 				RemoveFromSendList(mtcp, cur_stream);  in ProcessACK()
485 			EstimateRTT(mtcp, cur_stream,   in ProcessACK()
520 			SBRemove(mtcp->rbm_snd, sndvar->sndbuf, rmlen);  in ProcessACK()
531 				RaiseWriteEvent(mtcp, cur_stream);  in ProcessACK()
538 			UpdateRetransmissionTimer(mtcp, cur_stream, pctx->p.cur_ts);  in ProcessACK()
547 ProcessTCPPayload(mtcp_manager_t mtcp, tcp_stream *cur_stream,   in ProcessTCPPayload()  argument
574 				HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in ProcessTCPPayload()
579 				HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in ProcessTCPPayload()
588 		rcvvar->rcvbuf = tcprb_new(mtcp->bufseg_pool, g_config.mos->rmem_size, cur_stream->buffer_mgmt);  in ProcessTCPPayload()
596 				RaiseErrorEvent(mtcp, cur_stream);  in ProcessTCPPayload()
634 						HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in ProcessTCPPayload()
641 						HandleCallback(mtcp, MOS_NULL, walk, cur_stream->side,  in ProcessTCPPayload()
657 	if (ret < 0 && cur_stream->buffer_mgmt && mtcp->num_msp == 0)  in ProcessTCPPayload()
669 		RAISE_DEBUG_EVENT(mtcp, cur_stream,  in ProcessTCPPayload()
694 		RaiseReadEvent(mtcp, cur_stream);  in ProcessTCPPayload()
700 Handle_TCP_ST_LISTEN (mtcp_manager_t mtcp, tcp_stream* cur_stream,   in Handle_TCP_ST_LISTEN()  argument
730 Handle_TCP_ST_SYN_SENT (mtcp_manager_t mtcp, tcp_stream* cur_stream,  in Handle_TCP_ST_SYN_SENT()  argument
759 					RaiseErrorEvent(mtcp, cur_stream);  in Handle_TCP_ST_SYN_SENT()
773 		int ret = HandleActiveOpen(mtcp, cur_stream, pctx);  in Handle_TCP_ST_SYN_SENT()
780 			RAISE_DEBUG_EVENT(mtcp, cur_stream,  in Handle_TCP_ST_SYN_SENT()
789 			RemoveFromRTOList(mtcp, cur_stream);  in Handle_TCP_ST_SYN_SENT()
796 				RaiseWriteEvent(mtcp, cur_stream);  in Handle_TCP_ST_SYN_SENT()
806 				AddtoTimeoutList(mtcp, cur_stream);  in Handle_TCP_ST_SYN_SENT()
811 			Handle_TCP_ST_ESTABLISHED(mtcp, cur_stream, pctx);  in Handle_TCP_ST_SYN_SENT()
824 Handle_TCP_ST_SYN_RCVD (mtcp_manager_t mtcp, tcp_stream* cur_stream,   in Handle_TCP_ST_SYN_RCVD()  argument
846 			RemoveFromRTOList(mtcp, cur_stream);  in Handle_TCP_ST_SYN_RCVD()
854 			Handle_TCP_ST_ESTABLISHED(mtcp, cur_stream, pctx);  in Handle_TCP_ST_SYN_RCVD()
860 			struct tcp_listener *listener = mtcp->listener;  in Handle_TCP_ST_SYN_RCVD()
875 				AddEpollEvent(mtcp->ep,   in Handle_TCP_ST_SYN_RCVD()
883 				AddtoTimeoutList(mtcp, cur_stream);  in Handle_TCP_ST_SYN_RCVD()
905 Handle_TCP_ST_ESTABLISHED (mtcp_manager_t mtcp, tcp_stream* cur_stream,   in Handle_TCP_ST_ESTABLISHED()  argument
931 		if (ProcessTCPPayload(mtcp, cur_stream, pctx)) {  in Handle_TCP_ST_ESTABLISHED()
941 			ProcessACK(mtcp, cur_stream, pctx);  in Handle_TCP_ST_ESTABLISHED()
965 			RaiseReadEvent(mtcp, cur_stream);  in Handle_TCP_ST_ESTABLISHED()
967 			RAISE_DEBUG_EVENT(mtcp, cur_stream,  in Handle_TCP_ST_ESTABLISHED()
979 Handle_TCP_ST_CLOSE_WAIT (mtcp_manager_t mtcp, tcp_stream* cur_stream,   in Handle_TCP_ST_CLOSE_WAIT()  argument
991 		ProcessACK(mtcp, cur_stream, pctx);   in Handle_TCP_ST_CLOSE_WAIT()
996 Handle_TCP_ST_LAST_ACK (mtcp_manager_t mtcp, tcp_stream* cur_stream,   in Handle_TCP_ST_LAST_ACK()  argument
1010 			ProcessACK(mtcp, cur_stream, pctx);  in Handle_TCP_ST_LAST_ACK()
1019 			DumpIPPacket(mtcp, pctx->p.iph, pctx->p.ip_len);  in Handle_TCP_ST_LAST_ACK()
1022 			DumpStream(mtcp, cur_stream);  in Handle_TCP_ST_LAST_ACK()
1023 			DumpControlList(mtcp, mtcp->n_sender[0]);  in Handle_TCP_ST_LAST_ACK()
1032 				UpdateRetransmissionTimer(mtcp, cur_stream, pctx->p.cur_ts);  in Handle_TCP_ST_LAST_ACK()
1055 Handle_TCP_ST_FIN_WAIT_1 (mtcp_manager_t mtcp, tcp_stream* cur_stream,  argument
1061 		RAISE_DEBUG_EVENT(mtcp, cur_stream,
1071 			ProcessACK(mtcp, cur_stream, pctx); 
1093 				RemoveFromRTOList(mtcp, cur_stream);
1099 			RAISE_DEBUG_EVENT(mtcp, cur_stream,
1107 		RAISE_DEBUG_EVENT(mtcp, cur_stream,
1123 		if (ProcessTCPPayload(mtcp, cur_stream, pctx)) {
1152 				AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1156 			RAISE_DEBUG_EVENT(mtcp, cur_stream,
1168 Handle_TCP_ST_FIN_WAIT_2 (mtcp_manager_t mtcp, tcp_stream* cur_stream,  argument
1175 			ProcessACK(mtcp, cur_stream, pctx); 
1184 		if (ProcessTCPPayload(mtcp, cur_stream, pctx)) {
1207 			AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1216 		DumpIPPacket(mtcp, pctx->p.iph, pctx->p.ip_len);
1223 Handle_TCP_ST_CLOSING (mtcp_manager_t mtcp, tcp_stream* cur_stream,  argument
1230 			ProcessACK(mtcp, cur_stream, pctx);
1247 			DumpStream(mtcp, cur_stream);
1256 			UpdateRetransmissionTimer(mtcp, cur_stream, pctx->p.cur_ts);
1261 		AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1271 UpdateRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,   argument
1282 		ret = ValidateSequence(mtcp, cur_stream, pctx);
1287 			DumpIPPacket(mtcp, pctx->p.iph, pctx->p.ip_len);
1290 			DumpStream(mtcp, cur_stream);
1305 		UpdateTimeoutList(mtcp, cur_stream);
1311 			if (ProcessRST(mtcp, cur_stream, pctx)) {
1334 		Handle_TCP_ST_LISTEN(mtcp, cur_stream, pctx);
1338 		Handle_TCP_ST_SYN_SENT(mtcp, cur_stream, pctx);
1344 			Handle_TCP_ST_LISTEN(mtcp, cur_stream, pctx);
1346 			Handle_TCP_ST_SYN_RCVD(mtcp, cur_stream, pctx);
1348 				Handle_TCP_ST_ESTABLISHED(mtcp, cur_stream, pctx);
1353 		Handle_TCP_ST_ESTABLISHED(mtcp, cur_stream, pctx);
1357 		Handle_TCP_ST_CLOSE_WAIT(mtcp, cur_stream, pctx);
1361 		Handle_TCP_ST_LAST_ACK(mtcp, cur_stream, pctx);
1365 		Handle_TCP_ST_FIN_WAIT_1(mtcp, cur_stream, pctx);
1369 		Handle_TCP_ST_FIN_WAIT_2(mtcp, cur_stream, pctx);
1373 		Handle_TCP_ST_CLOSING(mtcp, cur_stream, pctx);
1380 			RemoveFromTimewaitList(mtcp, cur_stream);
1381 			AddtoTimewaitList(mtcp, cur_stream, pctx->p.cur_ts);
1400 DoActionEndTCPPacket(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,   argument
1410 				AddtoSendList(mtcp, cur_stream);
1413 				EnqueueACK(mtcp, cur_stream, pctx->p.cur_ts, ACK_OPT_NOW);
1416 				EnqueueACK(mtcp, cur_stream, pctx->p.cur_ts, ACK_OPT_AGGREGATE);
1419 				AddtoControlList(mtcp, cur_stream, pctx->p.cur_ts);
1423 					SendTCPPacketStandalone(mtcp, 
1429 					SendTCPPacketStandalone(mtcp, 
1436 				DestroyTCPStream(mtcp, cur_stream);
1453 UpdatePassiveRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,   argument
1456 	UpdateRecvTCPContext(mtcp, cur_stream, pctx);
1463 PreRecvTCPEventPrediction(mtcp_manager_t mtcp, struct pkt_ctx *pctx,  argument
1466 	tcp_rb_overlapchk(mtcp, pctx, recvside_stream);