| /mOS-networking-stack/core/src/include/ |
| H A D | tcp_stream.h | 78 uint32_t sack_cnt; 79 uint32_t sack_bytes; 83 uint32_t rto_cnt; 84 uint32_t rto_bytes; 88 uint32_t seq_base; 89 uint32_t seq_off; 97 uint32_t left_edge; 99 uint32_t expire; 236 uint32_t id; 244 uint32_t actions; [all …]
|
| H A D | netmap.h | 146 uint32_t buf_idx; /* buffer index */ 267 const uint32_t nr_buf_size; 272 uint32_t cur; /* (u) wakeup point */ 273 uint32_t tail; /* (k) first kernel slot */ 275 uint32_t flags; 321 const uint32_t ni_flags; /* properties */ 335 uint32_t ni_spare1[5]; 476 uint32_t nr_version; /* API version */ 479 uint32_t nr_tx_slots; /* slots in tx rings */ 513 uint32_t nr_flags; [all …]
|
| H A D | tcp_ring_buffer.h | 33 uint32_t seq; 34 uint32_t len : 31, 44 uint32_t head_offset; /* offset for the head (head - data) */ 45 uint32_t tail_offset; /* offset fot the last byte (null byte) */ 49 uint32_t monitor_read_tail_offset; 57 uint32_t head_seq; 58 uint32_t init_seq; 63 uint32_t RBGetCurnum(rb_manager_t rbm); 72 uint32_t RBIsDanger(rb_manager_t rbm); 76 uint32_t len, uint32_t seq); [all …]
|
| H A D | tcp_out.h | 16 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, 17 uint32_t seq, uint32_t ack_seq, uint16_t window, uint8_t flags, 19 uint32_t cur_ts, uint32_t echo_ts, uint16_t ip_id, int8_t in_ifidx); 23 uint32_t cur_ts, uint8_t flags, uint8_t *payload, uint16_t payloadlen); 27 struct mtcp_sender *sender, uint32_t cur_ts, int thresh); 31 struct mtcp_sender *sender, uint32_t cur_ts, int thresh); 35 struct mtcp_sender *sender, uint32_t cur_ts, int thresh); 38 AddtoControlList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts); 54 tcp_stream *cur_stream, uint32_t cur_ts, uint8_t opt);
|
| H A D | tcp_send_buffer.h | 15 uint32_t head_off; 16 uint32_t tail_off; 17 uint32_t len; 19 uint32_t size; 21 uint32_t head_seq; 22 uint32_t init_seq; 25 uint32_t 29 SBManagerCreate(size_t chunk_size, uint8_t disable_rings, uint32_t concurrency); 32 SBInit(sb_manager_t sbm, uint32_t init_seq);
|
| H A D | mtcp.h | 152 uint32_t netmask; 153 uint32_t ip_addr; 159 uint32_t daddr; 160 uint32_t mask; 161 uint32_t masked; 168 uint32_t ip; 170 uint32_t ip_mask; 171 uint32_t ip_masked; 239 uint32_t ts_last_event; 271 uint32_t cur_ts; [all …]
|
| H A D | mos_api.h | 96 uint32_t u32; 123 uint32_t cur_ts; /**< packet receiving time (read-only:ro) */ 135 uint32_t seq; 136 uint32_t ack_seq; 176 uint32_t base_seq; /* seq # of the flow where the actual sequence # translation starts */ 227 uint32_t tcpbi_init_seq; 232 uint32_t tcpbi_last_byte_read; 240 uint32_t tcpbi_next_byte_expected; 246 uint32_t tcpbi_last_byte_received; 252 uint32_t len; [all …]
|
| H A D | config.h | 59 uint32_t netmask; 60 uint32_t ip_addr; 65 uint32_t gateway; 77 uint32_t ip; 79 uint32_t mask; 80 uint32_t masked_ip; 93 uint32_t ip; 95 uint32_t mask; 96 uint32_t masked_ip; 206 ParseIPAddress(uint32_t *ip_addr, char *ip_str);
|
| H A D | arp.h | 14 GetHWaddr(uint32_t ip); 17 GetDestinationHWaddr(uint32_t dip); 20 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts); 23 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts, 36 ARPTimer(mtcp_manager_t mtcp, uint32_t cur_ts);
|
| H A D | tcp_util.h | 9 uint32_t ts_val; 10 uint32_t ts_ref; 14 uint32_t cur_ts, uint8_t *tcpopt, int len); 23 uint32_t ack_seq, uint8_t *tcpopt, int len); 27 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr);
|
| H A D | timer.h | 29 uint32_t rto_now_idx; // pointing the hs_table_s index 30 uint32_t rto_now_ts; // 45 AddtoTimewaitList(mtcp_manager_t mtcp, tcp_stream *cur_stream, uint32_t cur_ts); 61 tcp_stream *cur_stream, uint32_t cur_ts); 64 CheckRtmTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh); 67 CheckTimewaitExpire(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh); 70 CheckConnectionTimeout(mtcp_manager_t mtcp, uint32_t cur_ts, int thresh);
|
| H A D | tcp_in.h | 53 #define TIMEVAL_TO_TS(t) (uint32_t)((t)->tv_sec * HZ + \ 122 uint32_t cur_ts, uint8_t *tcpopt, int len); 125 ProcessTCPUplink(mtcp_manager_t mtcp, uint32_t cur_ts, tcp_stream *cur_stream, 126 const struct tcphdr *tcph, uint32_t seq, uint32_t ack_seq, 127 uint8_t *payload, int payloadlen, uint32_t window); 138 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr);
|
| 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, 20 struct pkt_ctx *pctx, uint32_t cur_ts); 24 struct pkt_ctx *pctx, uint32_t cur_ts);
|
| H A D | netmap_user.h | 122 static inline uint32_t 140 static inline uint32_t 200 uint32_t caplen; 201 uint32_t len; 219 uint32_t memsize; 245 uint32_t if_flags; 246 uint32_t if_reqcap; 247 uint32_t if_curcap; 614 uint32_t nr_ringid = 0, nr_flags, nr_reg; in nm_open() 927 uint32_t i, idx; in nm_inject() [all …]
|
| /mOS-networking-stack/core/src/ |
| H A D | tcp_util.c | 16 uint32_t cur_ts, uint8_t *tcpopt, int len) in ParseTCPOptions() 82 ts->ts_val = ntohl(*(uint32_t *)(tcpopt + i)); in ParseTCPTimestamp() 83 ts->ts_ref = ntohl(*(uint32_t *)(tcpopt + i + 4)); in ParseTCPTimestamp() 97 uint32_t ack_seq, uint8_t *tcpopt, int len) in ParseSACKOption() 101 uint32_t left_edge, right_edge; in ParseSACKOption() 119 left_edge = ntohl(*(uint32_t *)(tcpopt + i + j)); in ParseSACKOption() 158 TCPCalcChecksum(uint16_t *buf, uint16_t len, uint32_t saddr, uint32_t daddr) in TCPCalcChecksum() 160 uint32_t sum; in TCPCalcChecksum() 225 uint32_t ts_val, ts_ref; in PrintTCPOptions() 226 ts_val = *(uint32_t *)(tcpopt + i); in PrintTCPOptions() [all …]
|
| H A D | icmp.c | 18 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr); 40 uint32_t sum = 0; in ICMPChecksum() 61 ICMPOutput(struct mtcp_manager *mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in ICMPOutput() 69 uint32_t pktlen = sizeof(struct iphdr) + sizeof(struct icmphdr) + len; in ICMPOutput() 71 uint32_t ts; in ICMPOutput() 142 RequestICMP(mtcp_manager_t mtcp, struct pkt_ctx *pctx, uint32_t saddr, uint32_t daddr, in RequestICMP() 231 DumpICMPPacket(struct icmphdr *icmph, uint32_t saddr, uint32_t daddr) in DumpICMPPacket()
|
| H A D | arp.c | 37 uint32_t ar_sip; /* sender ip address */ 39 uint32_t ar_tip; /* target ip address */ 46 uint32_t ip; 48 uint32_t ts_out; 74 GetHWaddr(uint32_t ip) in GetHWaddr() 89 GetDestinationHWaddr(uint32_t dip) in GetDestinationHWaddr() 124 uint32_t dst_ip, unsigned char *dst_haddr, in ARPOutput() 185 RequestARP(mtcp_manager_t mtcp, uint32_t ip, int nif, uint32_t cur_ts) in RequestARP() 219 struct arphdr *arph, int nif, uint32_t cur_ts) in ProcessARPRequest() 262 ProcessARPPacket(mtcp_manager_t mtcp, uint32_t cur_ts, in ProcessARPPacket() [all …]
|
| H A D | util.c | 28 BuildKeyCache(uint32_t *cache, int cache_len) in BuildKeyCache() 44 uint32_t result = (((uint32_t)key[0]) << 24) | in BuildKeyCache() 46 (((uint32_t)key[2]) << 8) | ((uint32_t)key[3]); in BuildKeyCache() 47 uint32_t idx = 32; in BuildKeyCache() 52 uint32_t bit; in BuildKeyCache() 61 uint32_t 68 uint32_t res = 0; in GetRSSHash() 71 static uint32_t key_cache[KEY_CACHE_LEN] = {0}; in GetRSSHash() 118 uint32_t masked; in GetRSSCPUCore() 123 static const uint32_t off[4] = {3, 1, -1, -3}; in GetRSSCPUCore() [all …]
|
| H A D | tcp_out.c | 71 uint32_t *ts = (uint32_t *)(tcpopt + 2); in GenerateTCPTimestamp() 80 GenerateTCPOptions(tcp_stream *cur_stream, uint32_t cur_ts, in GenerateTCPOptions() 143 uint32_t saddr, uint16_t sport, uint32_t daddr, uint16_t dport, in SendTCPPacketStandalone() 144 uint32_t seq, uint32_t ack_seq, uint16_t window, uint8_t flags, in SendTCPPacketStandalone() 146 uint32_t cur_ts, uint32_t echo_ts, uint16_t ip_id, int8_t in_ifidx) in SendTCPPacketStandalone() 150 uint32_t *ts; in SendTCPPacketStandalone() 192 ts = (uint32_t *)(tcpopt + 4); in SendTCPPacketStandalone() 253 uint32_t window32 = 0; in SendTCPPacket() 420 uint32_t buffered_len; in FlushTCPSendingBuffer() 421 uint32_t seq; in FlushTCPSendingBuffer() [all …]
|
| H A D | memory_mgt.c | 179 uint32_t 184 uint32_t danger_num = mp->mp_total_chunks * DANGER_THREASHOLD; in MPIsDanger() 185 uint32_t safe_num = mp->mp_total_chunks * SAFE_THREASHOLD; in MPIsDanger() 192 uint32_t 196 uint32_t safe_num = mp->mp_total_chunks * SAFELINE; in MPIsOverSafeline()
|
| H A D | tcp_send_buffer.c | 15 uint32_t cur_num; 16 uint32_t cnum; 22 uint32_t 29 SBManagerCreate(size_t chunk_size, uint8_t disable_rings, uint32_t concurrency) in SBManagerCreate() 60 SBInit(sb_manager_t sbm, uint32_t init_seq) in SBInit()
|
| H A D | ip_out.c | 12 GetOutputInterface(uint32_t daddr) in GetOutputInterface() 44 uint32_t daddr = 0; in ForwardIPPacket() 123 uint16_t ip_id, uint32_t saddr, uint32_t daddr, uint16_t tcplen, in IPOutputStandalone() 124 struct pkt_ctx *pctx, uint32_t cur_ts) in IPOutputStandalone() 183 struct pkt_ctx *pctx, uint32_t cur_ts) in IPOutput()
|
| H A D | debug.c | 100 udph = (struct udphdr *)((uint32_t *)iph + iph->ihl); in DumpPacket() 101 tcph = (struct tcphdr *)((uint32_t *)iph + iph->ihl); in DumpPacket() 165 udph = (struct udphdr *)((uint32_t *)iph + iph->ihl); in DumpIPPacket() 166 tcph = (struct tcphdr *)((uint32_t *)iph + iph->ihl); in DumpIPPacket() 223 udph = (struct udphdr *)((uint32_t *)iph + iph->ihl); in DumpIPPacketToFile() 224 tcph = (struct tcphdr *)((uint32_t *)iph + iph->ihl); in DumpIPPacketToFile()
|
| /mOS-networking-stack/util/ |
| H A D | rss.c | 14 BuildKeyCache(uint32_t *cache, int cache_len) in BuildKeyCache() 92 …uint32_t result = (((uint32_t)key[0]) << 24) | (((uint32_t)key[1]) << 16) | (((uin… in BuildKeyCache() 93 uint32_t idx = 32; in BuildKeyCache() 98 uint32_t bit; in BuildKeyCache() 107 static uint32_t 114 uint32_t res = 0; in GetRSSHash() 117 static uint32_t key_cache[KEY_CACHE_LEN] = {0}; in GetRSSHash() 160 uint32_t masked = GetRSSHash(sip, dip, sp, dp) & RSS_BIT_MASK; 163 static const uint32_t off[4] = {3, 1, -1, -3}; 189 uint32_t correct_hash[] = {0x51ccc178, in VerifyRSSHash()
|
| /mOS-networking-stack/core/include/ |
| H A D | mos_api.h | 96 uint32_t u32; 123 uint32_t cur_ts; /**< packet receiving time (read-only:ro) */ 135 uint32_t seq; 136 uint32_t ack_seq; 176 uint32_t base_seq; /* seq # of the flow where the actual sequence # translation starts */ 227 uint32_t tcpbi_init_seq; 232 uint32_t tcpbi_last_byte_read; 240 uint32_t tcpbi_next_byte_expected; 246 uint32_t tcpbi_last_byte_received; 252 uint32_t len; [all …]
|