| /mOS-networking-stack/core/src/ |
| H A D | addr_pool.c | 115 in_addr_t saddr; in CreateAddressPoolPerCore() local 160 saddr = htonl(saddr_h); in CreateAddressPoolPerCore() 171 ap->pool[cnt].addr.sin_addr.s_addr = saddr; in CreateAddressPoolPerCore() 217 const struct sockaddr_in *daddr, struct sockaddr_in *saddr) in FetchAddress() argument 223 if (!ap || !daddr || !saddr) in FetchAddress() 232 if (saddr->sin_addr.s_addr != INADDR_ANY && in FetchAddress() 238 if (saddr->sin_port != INPORT_ANY && in FetchAddress() 239 walk->addr.sin_port != saddr->sin_port) { in FetchAddress() 255 *saddr = walk->addr; in FetchAddress() 275 if (!ap || !daddr || !saddr) in FetchAddressPerCore() [all …]
|
| H A D | icmp.c | 18 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr); 61 ICMPOutput(struct mtcp_manager *mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in ICMPOutput() argument 113 iph->saddr = saddr; in ICMPOutput() 136 DumpICMPPacket(icmph, saddr, daddr); in ICMPOutput() 142 RequestICMP(mtcp_manager_t mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in RequestICMP() argument 147 ICMPOutput(mtcp, pctx, saddr, daddr, ICMP_ECHO, 0, ntohs(icmp_id), ntohs(icmp_sequence), in RequestICMP() 160 ICMPOutput(mtcp, pctx, pctx->p.iph->daddr, pctx->p.iph->saddr, ICMP_ECHOREPLY, 0, in ProcessICMPECHORequest() 231 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr) in DumpICMPPacket() argument 241 t = (uint8_t *)&saddr; in DumpICMPPacket()
|
| H A D | tcp.c | 66 addr = &mtcp->listener->socket->saddr; in DetectStreamType() 95 pctx->p.iph->saddr, pctx->p.tcph->source, NULL); in CreateServerStream() 119 pctx->p.tcph->dest, pctx->p.iph->saddr, in CreateMonitorStream() 185 temp_stream.saddr = pctx->p.iph->daddr; in FindStream() 187 temp_stream.daddr = pctx->p.iph->saddr; in FindStream() 231 pctx->p.iph->saddr, pctx->p.tcph->source, in CreateStream() 325 pctx->p.iph->saddr, pctx->p.tcph->source, 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 | api.c | 166 *(struct sockaddr_in *)addr = socket->saddr; in mtcp_getsockname() 167 *addrlen = sizeof(socket->saddr); in mtcp_getsockname() 735 mtcp->smap[sockid].saddr = *addr_in; in mtcp_bind() 884 socket->saddr.sin_family = AF_INET; in mtcp_accept() 885 socket->saddr.sin_port = accepted->dport; in mtcp_accept() 953 in_addr_t saddr, in_port_t sport, in eval_bpf_5tuple() argument 969 iph->saddr = saddr; in eval_bpf_5tuple() 1089 socket->saddr.sin_port, in mtcp_connect() 1103 socket->saddr.sin_addr.s_addr, in mtcp_connect() 1109 socket->saddr.sin_addr.s_addr, in mtcp_connect() [all …]
|
| H A D | fhash.c | 77 char *key = (char *)&flow->saddr; in HashFlow() 90 return SuperFastHash((const char *)&flow->saddr, 12) & (NUM_BINS - 1); in HashFlow() 95 (flow1->saddr == flow2->saddr && flow1->sport == flow2->sport && \
|
| H A D | ip_out.c | 123 uint16_t ip_id, uint32_t saddr, uint32_t daddr, uint16_t tcplen, in IPOutputStandalone() argument 165 iph->saddr = saddr; in IPOutputStandalone() 227 iph->saddr = stream->saddr; in IPOutput()
|
| H A D | tcp_stream.c | 428 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, argument 473 stream->saddr = saddr; 569 sa = (uint8_t *)&stream->saddr; 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 622 cs = CreateTCPStream(mtcp, socket, type, daddr, dport, saddr, sport, hash); 651 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport) argument 720 sa = (uint8_t *)&stream->saddr; 794 addr.sin_addr.s_addr = stream->saddr; [all …]
|
| H A D | tcp_util.c | 158 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr) in TCPCalcChecksum() argument 179 sum += (saddr & 0x0000FFFF) + (saddr >> 16); in TCPCalcChecksum()
|
| H A D | mos_api.c | 583 pkt->iph->saddr, pkt->tcph->source, in mtcp_sendpkt() 783 stream->saddr, stream->sport, stream->daddr, stream->dport, in SendRSTPacketStandalone() 848 mtcp_getpeername(mctx_t mctx, int sockfd, struct sockaddr *saddr, in mtcp_getpeername() argument 878 sin = (struct sockaddr_in *)saddr; in mtcp_getpeername() 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 | debug.c | 103 t = (uint8_t *)&iph->saddr; in DumpPacket() 168 t = (uint8_t *)&iph->saddr; in DumpIPPacket() 226 t = (uint8_t *)&iph->saddr; in DumpIPPacketToFile()
|
| H A D | socket.c | 116 memset(&socket->saddr, 0, sizeof(struct sockaddr_in)); in AllocateSocket()
|
| /mOS-networking-stack/util/ |
| H A D | rss.c | 235 struct in_addr saddr, daddr; in CheckRSSHash() local 253 saddr.s_addr = (in_addr_t) myrand(); in CheckRSSHash() 255 if (inet_aton(src_ip, &saddr) == 0) saddr.s_addr = (in_addr_t) myrand(); in CheckRSSHash() 276 queue_idx = GetRSSCPUCore(saddr.s_addr, daddr.s_addr, sport, dport, num_queue); in CheckRSSHash() 278 strncpy(saddr_str, inet_ntoa(saddr), 15); in CheckRSSHash() 282 queue_idx = GetRSSCPUCore(daddr.s_addr, saddr.s_addr, dport, sport, num_queue); in CheckRSSHash()
|
| H A D | netlib.c | 114 struct sockaddr_in saddr; in CreateConnectionSocket() local 147 saddr.sin_family = AF_INET; in CreateConnectionSocket() 148 saddr.sin_addr.s_addr = netAddr; in CreateConnectionSocket() 149 saddr.sin_port = htons(portNum); in CreateConnectionSocket() 151 if (connect(fd, (struct sockaddr *) &saddr, in CreateConnectionSocket() 156 inet_ntoa(saddr.sin_addr), portNum, errno); in CreateConnectionSocket()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | tcp_stream.h | 239 uint32_t saddr; /* in network order */ member 306 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, 310 CreateDualTCPStream(mtcp_manager_t mtcp, socket_map_t socket, int type, uint32_t saddr, 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 | addr_pool.h | 31 const struct sockaddr_in *daddr, struct sockaddr_in *saddr); 35 const struct sockaddr_in *daddr, struct sockaddr_in *saddr);
|
| H A D | ip_out.h | 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 | socket.h | 113 struct sockaddr_in saddr; member
|
| 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);
|
| /mOS-networking-stack/samples/epserver/ |
| H A D | epserver-mp.c | 309 struct sockaddr_in saddr; in CreateListeningSocket() local 325 saddr.sin_family = AF_INET; in CreateListeningSocket() 326 saddr.sin_addr.s_addr = INADDR_ANY; in CreateListeningSocket() 327 saddr.sin_port = htons(80); in CreateListeningSocket() 329 (struct sockaddr *)&saddr, sizeof(struct sockaddr_in)); in CreateListeningSocket()
|
| H A D | epserver.c | 310 struct sockaddr_in saddr; in CreateListeningSocket() local 326 saddr.sin_family = AF_INET; in CreateListeningSocket() 327 saddr.sin_addr.s_addr = INADDR_ANY; in CreateListeningSocket() 328 saddr.sin_port = htons(80); in CreateListeningSocket() 330 (struct sockaddr *)&saddr, sizeof(struct sockaddr_in)); in CreateListeningSocket()
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 66 static in_addr_t saddr; variable 569 saddr = INADDR_ANY; in GlbInitWget() 624 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget()
|
| H A D | epwget-mp.c | 65 static in_addr_t saddr; variable 567 saddr = INADDR_ANY; in GlbInitWget() 622 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget()
|