| /mOS-networking-stack/core/src/ |
| H A D | ip_out.c | 12 GetOutputInterface(uint32_t daddr) in GetOutputInterface() argument 30 uint8_t *da = (uint8_t *)&daddr; in GetOutputInterface() 44 uint32_t daddr = 0; in ForwardIPPacket() local 56 daddr = pctx->p.iph->daddr; in ForwardIPPacket() 65 haddr = GetDestinationHWaddr(daddr); in ForwardIPPacket() 70 RequestARP(mtcp, daddr, in ForwardIPPacket() 131 nif = GetOutputInterface(daddr); in IPOutputStandalone() 135 haddr = GetDestinationHWaddr(daddr); in IPOutputStandalone() 143 uint8_t *da = (uint8_t *)&daddr; in IPOutputStandalone() 166 iph->daddr = daddr; in IPOutputStandalone() [all …]
|
| H A D | icmp.c | 18 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr); 74 nif = GetOutputInterface(daddr); in ICMPOutput() 79 haddr = GetDestinationHWaddr(daddr); in ICMPOutput() 81 uint8_t *da = (uint8_t *)&daddr; in ICMPOutput() 87 RequestARP(mtcp, daddr, nif, mtcp->cur_ts); in ICMPOutput() 88 haddr = GetDestinationHWaddr(daddr); in ICMPOutput() 114 iph->daddr = daddr; in ICMPOutput() 136 DumpICMPPacket(icmph, saddr, daddr); in ICMPOutput() 195 if (pctx->p.iph->daddr == g_config.mos->netdev_table->ent[i]->ip_addr) { in ProcessICMPPacket() 231 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr) in DumpICMPPacket() argument [all …]
|
| H A D | addr_pool.c | 110 in_addr_t saddr_base, int num_addr, in_addr_t daddr, in_port_t dport) in CreateAddressPoolPerCore() argument 153 daddr_h = ntohl(daddr); in CreateAddressPoolPerCore() 217 const struct sockaddr_in *daddr, struct sockaddr_in *saddr) in FetchAddress() argument 223 if (!ap || !daddr || !saddr) in FetchAddress() 245 ntohl(daddr->sin_addr.s_addr), ntohs(walk->addr.sin_port), in FetchAddress() 246 ntohs(daddr->sin_port), num_queues); in FetchAddress() 270 const struct sockaddr_in *daddr, struct sockaddr_in *saddr) in FetchAddressPerCore() argument 275 if (!ap || !daddr || !saddr) in FetchAddressPerCore()
|
| H A D | tcp.c | 94 pctx->p.iph->daddr, pctx->p.tcph->dest, in CreateServerStream() 118 stream = CreateDualTCPStream(mtcp, NULL, stream_type, pctx->p.iph->daddr, in CreateMonitorStream() 185 temp_stream.saddr = pctx->p.iph->daddr; in FindStream() 187 temp_stream.daddr = pctx->p.iph->saddr; in FindStream() 206 stream_type = DetectStreamType(mtcp, pctx, iph->daddr, tcph->dest); in CreateStream() 232 pctx->p.iph->daddr, pctx->p.tcph->dest, in CreateStream() 326 pctx->p.iph->daddr, pctx->p.tcph->dest)) == NULL) { in UpdateMonitor() 435 iph->saddr, pctx->p.iph->daddr)) { in ProcessInTCPPacket() 439 iph->saddr, iph->daddr)); in ProcessInTCPPacket() 504 iph->daddr, tcph->dest, iph->saddr, tcph->source, in ProcessInTCPPacket()
|
| H A D | tcp_stream.c | 428 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, argument 475 stream->daddr = daddr; 524 stream->sndvar->nif_out = GetOutputInterface(stream->daddr); 570 da = (uint8_t *)&stream->daddr; 583 uint16_t sport, uint32_t daddr, uint16_t dport, unsigned int *hash) argument 589 saddr, sport, daddr, dport, hash); 596 daddr, dport, saddr, sport, hash); 616 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, argument 651 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport) argument 721 da = (uint8_t *)&stream->daddr; [all …]
|
| H A D | tcp_util.c | 158 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr) in TCPCalcChecksum() argument 180 sum += (daddr & 0x0000FFFF) + (daddr >> 16); in TCPCalcChecksum()
|
| H A D | debug.c | 110 t = (uint8_t *)&iph->daddr; in DumpPacket() 175 t = (uint8_t *)&iph->daddr; in DumpIPPacket() 233 t = (uint8_t *)&iph->daddr; in DumpIPPacketToFile()
|
| H A D | fhash.c | 96 flow1->daddr == flow2->daddr && flow1->dport == flow2->dport)
|
| H A D | mos_api.c | 584 pkt->iph->daddr, pkt->tcph->dest, in mtcp_sendpkt() 783 stream->saddr, stream->sport, stream->daddr, stream->dport, in SendRSTPacketStandalone() 895 stream->daddr : stream->saddr; in mtcp_getpeername() 909 stream->daddr : stream->saddr; in mtcp_getpeername() 916 stream->daddr : stream->saddr; in mtcp_getpeername() 1193 iph->saddr, iph->daddr); in mtcp_setlastpkt()
|
| H A D | api.c | 886 socket->saddr.sin_addr.s_addr = accepted->daddr; in mtcp_accept() 905 addr_in->sin_addr.s_addr = accepted->daddr; in mtcp_accept() 914 in_addr_t daddr, in_addr_t dport) in mtcp_init_rss() argument 930 nif_out = GetOutputInterface(daddr); in mtcp_init_rss() 940 saddr_base, num_addr, daddr, dport); in mtcp_init_rss() 954 in_addr_t daddr, in_port_t dport) { in eval_bpf_5tuple() argument 970 iph->daddr = daddr; in eval_bpf_5tuple()
|
| H A D | tcp_out.c | 143 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, in SendTCPPacketStandalone() argument 165 saddr, daddr, TCP_HEADER_LEN + optlen + payloadlen, &pctx, cur_ts); in SendTCPPacketStandalone() 219 saddr, daddr); in SendTCPPacketStandalone() 354 cur_stream->daddr); in SendTCPPacket()
|
| /mOS-networking-stack/util/ |
| H A D | rss.c | 235 struct in_addr saddr, daddr; in CheckRSSHash() local 258 daddr.s_addr = (in_addr_t) myrand(); in CheckRSSHash() 260 if (inet_aton(dest_ip, &daddr) == 0) daddr.s_addr = (in_addr_t) myrand(); in CheckRSSHash() 276 queue_idx = GetRSSCPUCore(saddr.s_addr, daddr.s_addr, sport, dport, num_queue); in CheckRSSHash() 279 strncpy(daddr_str, inet_ntoa(daddr), 15); in CheckRSSHash() 282 queue_idx = GetRSSCPUCore(daddr.s_addr, saddr.s_addr, dport, sport, num_queue); in CheckRSSHash()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | addr_pool.h | 24 in_addr_t saddr_base, int num_addr, in_addr_t daddr, in_port_t dport); 31 const struct sockaddr_in *daddr, struct sockaddr_in *saddr); 35 const struct sockaddr_in *daddr, struct sockaddr_in *saddr);
|
| H A D | tcp_stream.h | 240 uint32_t daddr; /* in network order */ member 306 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, 311 uint16_t sport, uint32_t daddr, uint16_t dport, unsigned int *hash); 315 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, unsigned int *hash); 319 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport);
|
| H A D | ip_out.h | 9 GetOutputInterface(uint32_t daddr); 19 uint16_t ip_id, uint32_t saddr, uint32_t daddr, uint16_t tcplen,
|
| H A D | tcp_util.h | 27 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr);
|
| H A D | icmp.h | 31 RequestICMP(mtcp_manager_t mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr,
|
| H A D | tcp_out.h | 16 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport,
|
| H A D | tcp_in.h | 138 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr);
|
| H A D | mtcp_api.h | 345 in_addr_t daddr, in_addr_t dport);
|
| H A D | mtcp.h | 159 uint32_t daddr; member
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 64 static in_addr_t daddr; variable 188 addr.sin_addr.s_addr = daddr; in CreateConnection() 567 daddr = inet_addr(host); in GlbInitWget() 624 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget() 675 daddr_in.s_addr = daddr; in RunWget()
|
| H A D | epwget-mp.c | 63 static in_addr_t daddr; variable 187 addr.sin_addr.s_addr = daddr; in CreateConnection() 565 daddr = inet_addr(host); in GlbInitWget() 622 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget() 673 daddr_in.s_addr = daddr; in RunWget()
|
| /mOS-networking-stack/core/include/ |
| H A D | mtcp_api.h | 345 in_addr_t daddr, in_addr_t dport);
|
| /mOS-networking-stack/samples/simple_firewall/ |
| H A D | simple_firewall.c | 346 action = FWRLookup(p.iph->saddr, p.iph->daddr, in ApplyActionPerFlow()
|