Lines Matching refs:mtcp
142 SendTCPPacketStandalone(struct mtcp_manager *mtcp, in SendTCPPacketStandalone() argument
164 tcph = (struct tcphdr *)IPOutputStandalone(mtcp, htons(ip_id), in SendTCPPacketStandalone()
209 if (likely(mtcp->iom->dev_ioctl != NULL)) in SendTCPPacketStandalone()
210 rc = mtcp->iom->dev_ioctl(mtcp->ctx, in SendTCPPacketStandalone()
227 DumpPacket(mtcp, in SendTCPPacketStandalone()
235 TAILQ_FOREACH(walk, &mtcp->monitors, link) in SendTCPPacketStandalone()
240 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in SendTCPPacketStandalone()
247 SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream, in SendTCPPacket() argument
264 tcph = (struct tcphdr *)IPOutput(mtcp, cur_stream, in SendTCPPacket()
318 UpdateTimeoutList(mtcp, cur_stream); in SendTCPPacket()
344 if (likely(mtcp->iom->dev_ioctl != NULL)) in SendTCPPacket()
345 rc = mtcp->iom->dev_ioctl(mtcp->ctx, in SendTCPPacket()
374 AddtoRTOList(mtcp, cur_stream); in SendTCPPacket()
379 TAILQ_FOREACH(walk, &mtcp->monitors, link) in SendTCPPacket()
384 HandleCallback(mtcp, MOS_NULL, walk->socket, MOS_SIDE_BOTH, in SendTCPPacket()
387 if (mtcp->num_msp /* this means that stream monitor is on */) { in SendTCPPacket()
399 UpdateMonitor(mtcp, sendside_stream, recvside_stream, &pctx, false); in SendTCPPacket()
404 DumpPacket(mtcp, in SendTCPPacket()
415 FlushTCPSendingBuffer(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts) in FlushTCPSendingBuffer() argument
490 EnqueueACK(mtcp, cur_stream, cur_ts, ACK_OPT_WACK); in FlushTCPSendingBuffer()
498 sndlen = SendTCPPacket(mtcp, cur_stream, cur_ts, in FlushTCPSendingBuffer()
515 SendControlPacket(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts) in SendControlPacket() argument
557 ret = SendTCPPacket(mtcp, cur_stream, cur_ts, TCP_FLAG_RST, NULL, 0); in SendControlPacket()
559 DestroyTCPStream(mtcp, cur_stream); in SendControlPacket()
568 return SendTCPPacket(mtcp, cur_stream, cur_ts, flag, NULL, 0); in SendControlPacket()
572 WriteTCPControlList(mtcp_manager_t mtcp, in WriteTCPControlList() argument
600 ret = SendControlPacket(mtcp, cur_stream, cur_ts); in WriteTCPControlList()
622 WriteTCPDataList(mtcp_manager_t mtcp, in WriteTCPDataList() argument
654 ret = FlushTCPSendingBuffer(mtcp, cur_stream, cur_ts); in WriteTCPDataList()
659 ret = FlushTCPSendingBuffer(mtcp, cur_stream, cur_ts); in WriteTCPDataList()
664 DumpStream(mtcp, cur_stream); in WriteTCPDataList()
691 AddtoControlList(mtcp, cur_stream, cur_ts); in WriteTCPDataList()
699 DumpStream(mtcp, cur_stream); in WriteTCPDataList()
712 WriteTCPACKList(mtcp_manager_t mtcp, in WriteTCPACKList() argument
758 DumpStream(mtcp, cur_stream); in WriteTCPACKList()
765 ret = SendTCPPacket(mtcp, cur_stream, in WriteTCPACKList()
777 ret = SendTCPPacket(mtcp, cur_stream, in WriteTCPACKList()
801 AddtoControlList(mtcp, cur_stream, cur_ts); in WriteTCPACKList()
809 thread_printf(mtcp, mtcp->log_fp, in WriteTCPACKList()
811 DumpStream(mtcp, cur_stream); in WriteTCPACKList()
824 GetSender(mtcp_manager_t mtcp, tcp_stream *cur_stream) in GetSender() argument
827 return mtcp->g_sender; in GetSender()
834 return mtcp->n_sender[cur_stream->sndvar->nif_out]; in GetSender()
839 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts) in AddtoControlList() argument
843 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoControlList()
846 ret = SendControlPacket(mtcp, cur_stream, cur_ts); in AddtoControlList()
850 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoControlList()
871 AddtoSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoSendList() argument
873 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoSendList()
878 mtcp->ctx->cpu, in AddtoSendList()
892 AddtoACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoACKList() argument
894 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in AddtoACKList()
905 RemoveFromControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromControlList() argument
907 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromControlList()
920 RemoveFromSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromSendList() argument
922 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromSendList()
933 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromACKList() argument
935 struct mtcp_sender *sender = GetSender(mtcp, cur_stream); in RemoveFromACKList()
946 EnqueueACK(mtcp_manager_t mtcp, in EnqueueACK() argument
968 AddtoACKList(mtcp, cur_stream); in EnqueueACK()
972 DumpControlList(mtcp_manager_t mtcp, struct mtcp_sender *sender) in DumpControlList() argument
1013 UpdatePassiveSendTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream, in UpdatePassiveSendTCPContext() argument
1026 AddtoTimeoutList(mtcp, cur_stream); in UpdatePassiveSendTCPContext()
1099 RAISE_DEBUG_EVENT(mtcp, cur_stream, in UpdatePassiveSendTCPContext()
1124 RAISE_DEBUG_EVENT(mtcp, cur_stream, in UpdatePassiveSendTCPContext()
1190 UNUSED(mtcp); in UpdatePassiveSendTCPContext()
1195 PostSendTCPAction(mtcp_manager_t mtcp, struct pkt_ctx *pctx, in PostSendTCPAction() argument