| /mOS-networking-stack/core/src/ |
| H A D | eth_in.c | 28 ProcessPacket(mtcp_manager_t mtcp, const int ifidx, const int index, in ProcessPacket() argument
39 DumpPacket(mtcp, (char *)pkt_data, len, "IN", ifidx); in ProcessPacket()
43 mtcp->nstat.rx_packets[ifidx]++; in ProcessPacket()
44 mtcp->nstat.rx_bytes[ifidx] += len + ETHER_OVR; in ProcessPacket()
54 FillInPacketEthContext(&pctx, cur_ts, ifidx, index, ethh, len); in ProcessPacket()
65 ret = ProcessARPPacket(mtcp, cur_ts, ifidx, pkt_data, len); in ProcessPacket()
70 DumpPacket(mtcp, (char *)pkt_data, len, "??", ifidx); in ProcessPacket()
72 mtcp->iom->release_pkt(mtcp->ctx, ifidx, pkt_data, len); in ProcessPacket()
82 mtcp->nstat.rx_errors[ifidx]++; in ProcessPacket()
|
| H A D | pcap_module.c | 35 pcap_recv_pkts(struct mtcp_thread_context *ctxt, int ifidx) in pcap_recv_pkts() argument
37 if (ifidx < 0 || ifidx >= MAX_DEVICES) in pcap_recv_pkts()
41 if ((ppc->rdata = pcap_next(ppc->handle[ifidx], &ppc->phdr)) == NULL) in pcap_recv_pkts()
57 pcap_get_rptr(struct mtcp_thread_context *ctxt, int ifidx, int index, uint16_t *len) in pcap_get_rptr() argument
82 pcap_get_wptr(struct mtcp_thread_context *ctxt, int ifidx, uint16_t pktsize) in pcap_get_wptr() argument
87 ppc->count[ifidx] = 1; in pcap_get_wptr()
|
| H A D | dpdk_module.c | 366 dpdk_recv_pkts(struct mtcp_thread_context *ctxt, int ifidx) in dpdk_recv_pkts() argument
373 qid = cpu_qid_map[ifidx][ctxt->cpu]; in dpdk_recv_pkts()
379 if (dpc->rmbufs[ifidx].len != 0) { in dpdk_recv_pkts()
380 free_pkts(dpc->rmbufs[ifidx].m_table, dpc->rmbufs[ifidx].len); in dpdk_recv_pkts()
381 dpc->rmbufs[ifidx].len = 0; in dpdk_recv_pkts()
384 ret = rte_eth_rx_burst((uint8_t)ifidx, qid, in dpdk_recv_pkts()
389 dpc->rmbufs[ifidx].len = ret; in dpdk_recv_pkts()
395 dpdk_get_rptr(struct mtcp_thread_context *ctxt, int ifidx, int index, uint16_t *len) in dpdk_get_rptr() argument
413 dpc->rmbufs[ifidx].m_table[index] = m; in dpdk_get_rptr()
|
| H A D | netmap_module.c | 99 netmap_release_pkt(struct mtcp_thread_context *ctxt, int ifidx, unsigned char *pkt_data, int len) in netmap_release_pkt() argument
160 netmap_recv_pkts(struct mtcp_thread_context *ctxt, int ifidx) in netmap_recv_pkts() argument
165 d = npc->local_nmd[ifidx]; in netmap_recv_pkts()
174 for (c = 0; c < n && cnt != got && npc->dev_poll_flag[ifidx]; c++) { in netmap_recv_pkts()
193 npc->dev_poll_flag[ifidx] = 0; in netmap_recv_pkts()
199 netmap_get_rptr(struct mtcp_thread_context *ctxt, int ifidx, int index, uint16_t *len) in netmap_get_rptr() argument
|
| H A D | arp.c | 263 const int ifidx, unsigned char *pkt_data, int len) in ProcessARPPacket() argument
285 ProcessARPRequest(mtcp, arph, ifidx, cur_ts); in ProcessARPPacket()
|
| H A D | core.c | 1050 CreateMTCPSender(int ifidx) in CreateMTCPSender() argument
1059 sender->ifidx = ifidx; in CreateMTCPSender()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | io_module.h | 68 …void (*release_pkt)(struct mtcp_thread_context *ctx, int ifidx, unsigned char *pkt_data, int …
69 uint8_t * (*get_wptr)(struct mtcp_thread_context *ctx, int ifidx, uint16_t len);
72 uint8_t * (*get_rptr)(struct mtcp_thread_context *ctx, int ifidx, int index, uint16_t *len);
74 int32_t (*recv_pkts)(struct mtcp_thread_context *ctx, int ifidx);
|
| H A D | eth_in.h | 7 ProcessPacket(mtcp_manager_t mtcp, const int ifidx, const int index,
|
| H A D | arp.h | 24 const int ifidx, unsigned char* pkt_data, int len);
|
| H A D | mtcp.h | 183 int ifidx; member
|