Home
last modified time | relevance | path

Searched defs:mtcp (Results 1 – 25 of 25) sorted by relevance

/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 Dtcp_in.c27 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()
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()
[all …]
H A Dapi.c132 mtcp_manager_t mtcp; in mtcp_getsockname() local
176 mtcp_manager_t mtcp; in mtcp_getsockopt() local
263 mtcp_manager_t mtcp; in mtcp_setsockopt() local
466 mtcp_manager_t mtcp; in mtcp_setsock_nonblock() local
494 mtcp_manager_t mtcp; in mtcp_ioctl() local
557 mtcp_manager_t mtcp; in mtcp_monitor() local
625 mtcp_manager_t mtcp; in mtcp_socket() local
682 mtcp_manager_t mtcp; in mtcp_bind() local
744 mtcp_manager_t mtcp; in mtcp_listen() local
820 mtcp_manager_t mtcp; in mtcp_accept() local
[all …]
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.c142 SendTCPPacketStandalone(struct mtcp_manager *mtcp, in SendTCPPacketStandalone()
247 SendTCPPacket(struct mtcp_manager *mtcp, tcp_stream *cur_stream, in SendTCPPacket()
572 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()
933 RemoveFromACKList(mtcp_manager_t mtcp, tcp_stream *cur_stream) in RemoveFromACKList()
946 EnqueueACK(mtcp_manager_t mtcp, in EnqueueACK()
[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() local
135 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in FreeSocket() local
H A Dmos_api.c96 mtcp_manager_t mtcp; in mtcp_bind_monitor_filter() local
185 mtcp_manager_t mtcp; in mtcp_set_uctx() local
213 mtcp_manager_t mtcp; in mtcp_get_uctx() local
248 mtcp_manager_t mtcp; in mtcp_peek() local
364 mtcp_manager_t mtcp; in mtcp_ppeek() local
455 mtcp_manager_t mtcp; in mtcp_getlastpkt() local
528 mtcp_manager_t mtcp; in mtcp_getlastpkt() local
557 mtcp_manager_t mtcp; in mtcp_sendpkt() local
707 mtcp_manager_t mtcp; in mtcp_cb_stop() local
794 mtcp_manager_t mtcp; in mtcp_reset_conn() local
[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 Dcore.c138 mtcp_manager_t mtcp = ctx->mtcp_manager; in AttachDevice() local
247 PrintThreadRoundTime(mtcp_manager_t mtcp) in PrintThreadRoundTime()
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() local
1081 mtcp_manager_t mtcp; in InitializeMTCPManager() local
1287 struct mtcp_manager *mtcp; in MTCPRunThread() local
[all …]
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()
H A Dicmp.c61 ICMPOutput(struct mtcp_manager *mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in ICMPOutput()
142 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 Darp.c123 ARPOutput(struct mtcp_manager *mtcp, int nif, int opcode, in ARPOutput()
185 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()
383 ForwardARPPacket(struct mtcp_manager *mtcp, struct pkt_ctx *pctx) in ForwardARPPacket()
H A Deventpoll.c94 mtcp_manager_t mtcp = g_mtcp[mctx->cpu]; in mtcp_epoll_create() local
168 mtcp_manager_t mtcp; in CloseEpollSocket() local
200 RaisePendingStreamEvents(mtcp_manager_t mtcp, in RaisePendingStreamEvents()
244 mtcp_manager_t mtcp; in mtcp_epoll_ctl() local
341 mtcp_manager_t mtcp; in mtcp_epoll_wait() local
H A Deth_out.c46 FlushSendChunkBuf(mtcp_manager_t mtcp, int nif) in FlushSendChunkBuf()
63 EthernetOutput(struct mtcp_manager *mtcp, struct pkt_ctx *pctx, in EthernetOutput()
105 ForwardEthernetFrame(struct mtcp_manager *mtcp, struct pkt_ctx *pctx) in ForwardEthernetFrame()
H A Dip_out.c40 ForwardIPPacket(mtcp_manager_t mtcp, struct pkt_ctx *pctx) in ForwardIPPacket()
122 IPOutputStandalone(struct mtcp_manager *mtcp, in IPOutputStandalone()
182 IPOutput(struct mtcp_manager *mtcp, tcp_stream *stream, uint16_t tcplen, in IPOutput()
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() local
236 mtcp_manager_t mtcp; in PipeWrite() local
368 mtcp_manager_t mtcp; in PipeClose() local
H A Devent_callback.c69 InitEvent(mtcp_manager_t mtcp, int num_evt) in InitEvent()
112 InitEvB(mtcp_manager_t mtcp, struct ev_base *evb) in InitEvB()
125 CleanupEvB(mtcp_manager_t mtcp, struct ev_base *evb) in CleanupEvB()
378 ModCb(mtcp_manager_t mtcp, int op, struct ev_pointer *evp, struct ev_base *evb, in ModCb()
443 mtcp_manager_t mtcp = GetMTCPManager(mctx); in ModifyCallback() local
597 HandleCallback(mtcp_manager_t mtcp, uint32_t hook, in HandleCallback()
H A Dip_in.c31 ProcessInIPv4Packet(mtcp_manager_t mtcp, struct pkt_ctx *pctx) in ProcessInIPv4Packet()
H A Deth_in.c28 ProcessPacket(mtcp_manager_t mtcp, const int ifidx, const int index, in ProcessPacket()
H A Ddpdk_module.c222 mtcp_manager_t mtcp; in dpdk_send_pkts() local
290 mtcp_manager_t mtcp; in dpdk_get_wptr() local
325 mtcp_manager_t mtcp; in dpdk_set_wptr() local
H A Dscalable_event.c725 InitEvent(mtcp_manager_t mtcp) in InitEvent()
863 mtcp_manager_t mtcp = GetMTCPManager(mctx); in mtcp_raise_event() local
982 mtcp_manager_t mtcp = GetMTCPManager(mctx); in mtcp_register_callback() local
1024 HandleCallback(mtcp_manager_t mtcp, uint32_t hook, in HandleCallback()
H A Dnetmap_module.c112 mtcp_manager_t mtcp; in netmap_send_pkts() local
H A Dtcp_rb.c893 tcp_rb_overlapchk(mtcp_manager_t mtcp, struct pkt_ctx *pctx, in tcp_rb_overlapchk()
/mOS-networking-stack/core/src/include/
H A Dscalable_event.h22 #define RAISE_DEBUG_EVENT(mtcp, stream, format, args...) \ argument
/mOS-networking-stack/core/test/scalable_event/
H A Dtest.c21 struct mtcp_manager mtcp; variable