| /mOS-networking-stack/util/ |
| H A D | rss.c | 237 in_port_t sport, dport; in CheckRSSHash() local 270 dport = htons(dest_port); in CheckRSSHash() 272 dport = ports >> 16; in CheckRSSHash() 276 queue_idx = GetRSSCPUCore(saddr.s_addr, daddr.s_addr, sport, dport, num_queue); in CheckRSSHash() 280 printf("%15s:%5d\t%15s:%5d\t%d\n", saddr_str, ntohs(sport), daddr_str, ntohs(dport), queue_idx); in CheckRSSHash() 282 queue_idx = GetRSSCPUCore(daddr.s_addr, saddr.s_addr, dport, sport, num_queue); in CheckRSSHash() 283 printf("%15s:%5d\t%15s:%5d\t%d\n", daddr_str, ntohs(dport), saddr_str, ntohs(sport), queue_idx); in CheckRSSHash() 317 int32_t sport = -1, dport = -1; in main() local 337 dport = atoi(optarg); in main() 350 CheckRSSHash(cnt, srcIP, destIP, sport, dport); in main()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | tcp_stream.h | 242 uint16_t dport; /* 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 | addr_pool.h | 24 in_addr_t saddr_base, int num_addr, in_addr_t daddr, in_port_t dport);
|
| H A D | tcp_out.h | 16 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport,
|
| H A D | mtcp_api.h | 345 in_addr_t daddr, in_addr_t dport);
|
| /mOS-networking-stack/core/src/ |
| H A D | tcp_stream.c | 428 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, argument 476 stream->dport = dport; 574 da[0], da[1], da[2], da[3], ntohs(stream->dport), 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 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 725 da[0], da[1], da[2], da[3], ntohs(stream->dport), [all …]
|
| H A D | api.c | 885 socket->saddr.sin_port = accepted->dport; in mtcp_accept() 904 addr_in->sin_port = accepted->dport; in mtcp_accept() 914 in_addr_t daddr, in_addr_t dport) in mtcp_init_rss() argument 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 974 tcph->dest = dport; in eval_bpf_5tuple() 989 in_port_t dport; in mtcp_connect() local 1047 dport = addr_in->sin_port; in mtcp_connect() 1056 socket->saddr.sin_port, dport, num_queues); in mtcp_connect() 1090 dip, dport) == 0)) { in mtcp_connect() [all …]
|
| H A D | fhash.c | 96 flow1->daddr == flow2->daddr && flow1->dport == flow2->dport)
|
| 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 154 dport_h = ntohs(dport); in CreateAddressPoolPerCore()
|
| H A D | mos_api.c | 783 stream->saddr, stream->sport, stream->daddr, stream->dport, in SendRSTPacketStandalone() 897 stream->dport : stream->sport; in mtcp_getpeername() 911 stream->dport : stream->sport; in mtcp_getpeername() 918 stream->dport : stream->sport; in mtcp_getpeername()
|
| H A D | tcp_out.c | 143 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, in SendTCPPacketStandalone() argument 172 tcph->dest = dport; in SendTCPPacketStandalone() 272 tcph->dest = cur_stream->dport; in SendTCPPacket()
|
| H A D | tcp.c | 188 temp_stream.dport = pctx->p.tcph->source; in FindStream()
|
| /mOS-networking-stack/samples/simple_firewall/config/ |
| H A D | simple_firewall.conf | 3 DROP 10.0.0.0/24 10.0.0.0/24 dport:80
|
| /mOS-networking-stack/samples/epwget/ |
| H A D | epwget.c | 65 static in_port_t dport; variable 189 addr.sin_port = dport; in CreateConnection() 568 dport = (dest_port == 0) ? htons(PORT_NUM) : htons(dest_port); in GlbInitWget() 624 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget() 677 core, flows[core], inet_ntoa(daddr_in), ntohs(dport)); in RunWget()
|
| H A D | epwget-mp.c | 64 static in_port_t dport; variable 188 addr.sin_port = dport; in CreateConnection() 566 dport = (dest_port == 0) ? htons(PORT_NUM) : htons(dest_port); in GlbInitWget() 622 mtcp_init_rss(mctx, saddr, IP_RANGE, daddr, dport); in InitWget() 675 core, flows[core], inet_ntoa(daddr_in), ntohs(dport)); in RunWget()
|
| /mOS-networking-stack/samples/simple_firewall/ |
| H A D | simple_firewall.c | 129 ExtractPort(char* buf, in_port_t* sport, in_port_t* dport) in ExtractPort() argument 146 p = dport; in ExtractPort()
|
| /mOS-networking-stack/core/include/ |
| H A D | mtcp_api.h | 345 in_addr_t daddr, in_addr_t dport);
|