Home
last modified time | relevance | path

Searched refs:mtcp_manager_t (Results 1 – 25 of 42) sorted by relevance

12

/mOS-networking-stack/core/src/include/
H A Dtimer.h39 AddtoRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
42 RemoveFromRTOList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
48 RemoveFromTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
51 AddtoTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
54 RemoveFromTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
57 UpdateTimeoutList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
60 UpdateRetransmissionTimer(mtcp_manager_t mtcp,
64 CheckRtmTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
67 CheckTimewaitExpire(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
70 CheckConnectionTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
[all …]
H A Dtcp_out.h26 WriteTCPControlList(mtcp_manager_t mtcp,
30 WriteTCPDataList(mtcp_manager_t mtcp,
34 WriteTCPACKList(mtcp_manager_t mtcp,
38 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts);
41 AddtoSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
44 RemoveFromControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
47 RemoveFromSendList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
50 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream);
53 EnqueueACK(mtcp_manager_t mtcp,
57 DumpControlList(mtcp_manager_t mtcp, struct mtcp_sender *sender);
[all …]
H A Darp.h20 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts);
23 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts,
27 PublishARP(mtcp_manager_t mtcp);
33 ForwardARPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx);
36 ARPTimer(mtcp_manager_t mtcp, uint32_t cur_ts);
H A Dtcp_stream.h293 RaiseReadEvent(mtcp_manager_t mtcp, tcp_stream *stream);
296 RaiseWriteEvent(mtcp_manager_t mtcp, tcp_stream *stream);
299 RaiseCloseEvent(mtcp_manager_t mtcp, tcp_stream *stream);
302 RaiseErrorEvent(mtcp_manager_t mtcp, tcp_stream *stream);
305 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,
310 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr,
314 CreateClientTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,
318 AttachServerTCPStream(mtcp_manager_t mtcp, tcp_stream *cs, int type,
322 DestroyTCPStream(mtcp_manager_t mtcp, tcp_stream *stream);
325 DumpStream(mtcp_manager_t mtcp, tcp_stream *stream);
H A Devent_callback.h62 InitEvent(mtcp_manager_t mtcp, int num_evt);
71 InitEvB(mtcp_manager_t mtcp, struct ev_base *evb);
74 CleanupEvB(mtcp_manager_t mtcp, struct ev_base *evb);
77 HandleCallback(mtcp_manager_t mtcp, uint32_t hook,
H A Dtcp_in.h125 ProcessTCPUplink(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream,
130 UpdateRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
134 DoActionEndTCPPacket(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
141 UpdatePassiveRecvTCPContext(mtcp_manager_t mtcp, struct tcp_stream *cur_stream,
145 PreRecvTCPEventPrediction(mtcp_manager_t mtcp, struct pkt_ctx *pctx,
H A Dtcp.h16 HandleSingleCallback(mtcp_manager_t mtcp, uint32_t hooking_point,
20 ProcessInTCPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx);
23 UpdateMonitor(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream,
H A Ddebug.h57 mtcp_manager_t mtcp = GetMTCPManager(&mctx);
234 DumpPacket(mtcp_manager_t mtcp, char *buf, int len, char *step, int ifindex);
237 DumpIPPacket(mtcp_manager_t mtcp, const struct iphdr *iph, int len);
243 flush_log_data(mtcp_manager_t mtcp);
246 thread_printf(mtcp_manager_t mtcp, FILE* f_idx, const char* _Format, ...);
H A Dip_out.h12 ForwardIPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx);
15 ForwardIPv4Packet(mtcp_manager_t mtcp, int nif_in, char *buf, int len);
H A Dicmp.h31 RequestICMP(mtcp_manager_t mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr,
36 ProcessICMPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx);
H A Dscalable_event.h71 InitEvent(mtcp_manager_t mtcp);
74 HandleCallback(mtcp_manager_t mtcp, uint32_t hook,
H A Dmtcp.h298 typedef struct mtcp_manager* mtcp_manager_t; typedef
301 mtcp_manager_t
345 RunPassiveLoop(mtcp_manager_t mtcp);
/mOS-networking-stack/core/src/
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()
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()
156 UpdateRetransmissionTimer(mtcp_manager_t mtcp, in UpdateRetransmissionTimer()
355 RearrangeRTOStore(mtcp_manager_t mtcp) { in RearrangeRTOStore()
534 RegTimer(mtcp_manager_t mtcp, struct timer *timer) in RegTimer()
573 DelTimer(mtcp_manager_t mtcp, struct timer *timer) in DelTimer()
[all …]
H A Dmos_api.c96 mtcp_manager_t mtcp; in mtcp_bind_monitor_filter()
185 mtcp_manager_t mtcp; in mtcp_set_uctx()
213 mtcp_manager_t mtcp; in mtcp_get_uctx()
248 mtcp_manager_t mtcp; in mtcp_peek()
364 mtcp_manager_t mtcp; in mtcp_ppeek()
455 mtcp_manager_t mtcp; in mtcp_getlastpkt()
528 mtcp_manager_t mtcp; in mtcp_getlastpkt()
557 mtcp_manager_t mtcp; in mtcp_sendpkt()
707 mtcp_manager_t mtcp; in mtcp_cb_stop()
794 mtcp_manager_t mtcp; in mtcp_reset_conn()
[all …]
H A Dapi.c51 inline mtcp_manager_t
132 mtcp_manager_t mtcp; in mtcp_getsockname()
176 mtcp_manager_t mtcp; in mtcp_getsockopt()
263 mtcp_manager_t mtcp; in mtcp_setsockopt()
466 mtcp_manager_t mtcp; in mtcp_setsock_nonblock()
494 mtcp_manager_t mtcp; in mtcp_ioctl()
557 mtcp_manager_t mtcp; in mtcp_monitor()
625 mtcp_manager_t mtcp; in mtcp_socket()
682 mtcp_manager_t mtcp; in mtcp_bind()
744 mtcp_manager_t mtcp; in mtcp_listen()
[all …]
H A Dtcp_in.c23 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()
62 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()
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()
[all …]
H A Dsocket.c12 FreeMonListener(mtcp_manager_t mtcp, socket_map_t socket) in FreeMonListener()
42 FreeMonStream(mtcp_manager_t mtcp, socket_map_t socket) in FreeMonStream()
73 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in AllocateSocket()
135 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in FreeSocket()
H A Dtcp.c26 DetectStreamType(mtcp_manager_t mtcp, struct pkt_ctx *pctx, in DetectStreamType()
88 CreateServerStream(mtcp_manager_t mtcp, int type, struct pkt_ctx *pctx) in CreateServerStream()
112 CreateMonitorStream(mtcp_manager_t mtcp, struct pkt_ctx* pctx, in CreateMonitorStream()
181 FindStream(mtcp_manager_t mtcp, struct pkt_ctx *pctx, unsigned int *hash) in FindStream()
196 CreateStream(mtcp_manager_t mtcp, struct pkt_ctx *pctx, unsigned int *hash) in CreateStream()
276 HandleSockStream(mtcp_manager_t mtcp, struct tcp_stream *cur_stream, in HandleSockStream()
284 UpdateMonitor(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream, in UpdateMonitor()
378 HandleMonitorStream(mtcp_manager_t mtcp, struct tcp_stream *sendside_stream, in HandleMonitorStream()
409 ProcessInTCPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx) in ProcessInTCPPacket()
H A Dtcp_out.c572 WriteTCPControlList(mtcp_manager_t mtcp, in WriteTCPControlList()
622 WriteTCPDataList(mtcp_manager_t mtcp, in WriteTCPDataList()
712 WriteTCPACKList(mtcp_manager_t mtcp, in WriteTCPACKList()
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()
946 EnqueueACK(mtcp_manager_t mtcp, in EnqueueACK()
972 DumpControlList(mtcp_manager_t mtcp, struct mtcp_sender *sender) in DumpControlList()
[all …]
H A Dtcp_stream.c237 RaiseReadEvent(mtcp_manager_t mtcp, tcp_stream *stream) in RaiseReadEvent()
285 RaiseWriteEvent(mtcp_manager_t mtcp, tcp_stream *stream) in RaiseWriteEvent()
298 RaiseCloseEvent(mtcp_manager_t mtcp, tcp_stream *stream) in RaiseCloseEvent()
314 RaiseErrorEvent(mtcp_manager_t mtcp, tcp_stream *stream) in RaiseErrorEvent()
329 AddMonitorStreamSockets(mtcp_manager_t mtcp, struct tcp_stream *stream) in AddMonitorStreamSockets()
393 DestroyMonitorStreamSocket(mtcp_manager_t mtcp, socket_map_t msock) in DestroyMonitorStreamSocket()
427 CreateTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type,
650 AttachServerTCPStream(mtcp_manager_t mtcp, tcp_stream *cs, int type,
687 DestroySingleTCPStream(mtcp_manager_t mtcp, tcp_stream *stream)
885 DestroyTCPStream(mtcp_manager_t mtcp, tcp_stream *stream)
[all …]
H A Darp.c185 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts) in RequestARP()
218 ProcessARPRequest(mtcp_manager_t mtcp, in ProcessARPRequest()
236 ProcessARPReply(mtcp_manager_t mtcp, struct arphdr *arph, uint32_t cur_ts) in ProcessARPReply()
262 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts, in ProcessARPPacket()
301 PublishARP(mtcp_manager_t mtcp) in PublishARP()
313 ARPTimer(mtcp_manager_t mtcp, uint32_t cur_ts) in ARPTimer()
H A Dicmp.c142 RequestICMP(mtcp_manager_t mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in RequestICMP()
152 ProcessICMPECHORequest(mtcp_manager_t mtcp, struct pkt_ctx *pctx, struct icmphdr *icmph) in ProcessICMPECHORequest()
168 ProcessICMPECHOReply(mtcp_manager_t mtcp, struct pkt_ctx *pctx, struct icmphdr *icmph) in ProcessICMPECHOReply()
187 ProcessICMPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx) in ProcessICMPPacket()
H A Dcore.c138 mtcp_manager_t mtcp = ctx->mtcp_manager; in AttachDevice()
247 PrintThreadRoundTime(mtcp_manager_t mtcp) in PrintThreadRoundTime()
287 PrintNetworkStats(mtcp_manager_t mtcp, uint32_t cur_ts) in PrintNetworkStats()
423 FlushMonitorReadEvents(mtcp_manager_t mtcp) in FlushMonitorReadEvents()
470 FlushBufferedReadEvents(mtcp_manager_t mtcp) in FlushBufferedReadEvents()
793 DestroyRemainingFlows(mtcp_manager_t mtcp) in DestroyRemainingFlows()
821 InterruptApplication(mtcp_manager_t mtcp) in InterruptApplication()
844 RunPassiveLoop(mtcp_manager_t mtcp) in RunPassiveLoop()
854 mtcp_manager_t mtcp = ctx->mtcp_manager; in RunMainLoop()
1078 static mtcp_manager_t
[all …]
H A Dpipe.c111 RaiseEventToPair(mtcp_manager_t mtcp, socket_map_t socket, uint32_t event) in RaiseEventToPair()
133 mtcp_manager_t mtcp; in PipeRead()
236 mtcp_manager_t mtcp; in PipeWrite()
368 mtcp_manager_t mtcp; in PipeClose()
H A Ddebug.c12 void flush_log_data(mtcp_manager_t mtcp) in flush_log_data()
26 thread_printf(mtcp_manager_t mtcp, FILE* f_idx, const char* _Format, ...) in thread_printf()
64 DumpPacket(mtcp_manager_t mtcp, char *buf, int len, char *step, int ifindex) in DumpPacket()
159 DumpIPPacket(mtcp_manager_t mtcp, const struct iphdr *iph, int len) in DumpIPPacket()

12