Home
last modified time | relevance | path

Searched defs:cur_stream (Results 1 – 9 of 9) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_in.c62 HandleActiveOpen(mtcp_manager_t mtcp, tcp_stream *cur_stream, in HandleActiveOpen()
88 ValidateSequence(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ValidateSequence()
168 NotifyConnectionReset(mtcp_manager_t mtcp, tcp_stream *cur_stream) in NotifyConnectionReset()
176 ProcessRST(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessRST()
251 EstimateRTT(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t mrtt) in EstimateRTT()
305 ProcessACK(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessACK()
547 ProcessTCPPayload(mtcp_manager_t mtcp, tcp_stream *cur_stream, in ProcessTCPPayload()
700 Handle_TCP_ST_LISTEN (mtcp_manager_t mtcp, tcp_stream* cur_stream, in Handle_TCP_ST_LISTEN()
730 Handle_TCP_ST_SYN_SENT (mtcp_manager_t mtcp, tcp_stream* cur_stream, 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()
[all …]
H A Dtcp_out.c80 GenerateTCPOptions(tcp_stream *cur_stream, uint32_t cur_ts, in GenerateTCPOptions()
247 SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream, in SendTCPPacket()
575 tcp_stream *cur_stream; in WriteTCPControlList() local
625 tcp_stream *cur_stream; in WriteTCPDataList() local
715 tcp_stream *cur_stream; in WriteTCPACKList() local
824 GetSender(mtcp_manager_t mtcp, tcp_stream *cur_stream) in GetSender()
871 AddtoSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoSendList()
892 AddtoACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoACKList()
920 RemoveFromSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromSendList()
933 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromACKList()
[all …]
H A Dtimer.c32 AddtoRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoRTOList()
70 RemoveFromRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromRTOList()
85 AddtoTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts) in AddtoTimewaitList()
111 RemoveFromTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromTimewaitList()
124 AddtoTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in AddtoTimeoutList()
137 RemoveFromTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromTimeoutList()
147 UpdateTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in UpdateTimeoutList()
157 tcp_stream *cur_stream, uint32_t cur_ts) in UpdateRetransmissionTimer()
183 HandleRTO(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream) in HandleRTO()
H A Dapi.c75 tcp_stream *cur_stream; in GetSocketError() local
525 tcp_stream *cur_stream; in mtcp_ioctl() local
986 tcp_stream *cur_stream; in mtcp_connect() local
1201 tcp_stream *cur_stream; in CloseStreamSocket() local
1364 tcp_stream *cur_stream; in mtcp_abort() local
1455 PeekForUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, char *buf, int len) in PeekForUser()
1470 CopyToUser(mtcp_manager_t mtcp, tcp_stream *cur_stream, char *buf, int len) in CopyToUser()
1506 tcp_stream *cur_stream; in mtcp_recv() local
1622 tcp_stream *cur_stream; in mtcp_readv() local
1774 tcp_stream *cur_stream; in mtcp_write() local
[all …]
H A Dtcp.c90 tcp_stream *cur_stream = NULL; in CreateServerStream() local
198 tcp_stream *cur_stream = NULL; in CreateStream() local
276 HandleSockStream(mtcp_manager_t mtcp, struct tcp_stream *cur_stream, in HandleSockStream()
412 struct tcp_stream *cur_stream; in ProcessInTCPPacket() local
H A Dtcp_util.c15 ParseTCPOptions(tcp_stream *cur_stream, in ParseTCPOptions()
62 ParseTCPTimestamp(tcp_stream *cur_stream, in ParseTCPTimestamp()
96 ParseSACKOption(tcp_stream *cur_stream, in ParseSACKOption()
H A Dmos_api.c247 struct tcp_stream *cur_stream; in mtcp_peek() local
365 struct tcp_stream *cur_stream; in mtcp_ppeek() local
490 struct tcp_stream *cur_stream; in mtcp_getlastpkt() local
H A Dcore.c426 struct tcp_stream *cur_stream; in FlushMonitorReadEvents() local
475 struct tcp_stream *cur_stream; in FlushBufferedReadEvents() local
H A Dtcp_stream.c585 tcp_stream *cur_stream, *paired_stream; local