Searched refs:pi (Results 1 - 5 of 5) sorted by relevance

/tldk/lib/libtle_l4p/
H A Dsyncookie.h69 sync_hash4(const union pkt_info *pi, uint32_t seq, rte_xmm_t *secret_key, argument
77 in4.port = pi->port;
78 in4.addr = pi->addr4;
97 sync_hash6(const union pkt_info *pi, uint32_t seq, rte_xmm_t *secret_key, argument
107 rte_jhash_32b_2hashes(pi->addr6->raw.u32,
108 sizeof(*pi->addr6) / sizeof(uint32_t),
110 return rte_jhash_3words(v0, seq, pi->port.raw, v1);
113 siphash_compression(pi->addr6->raw.u32,
114 sizeof(*pi->addr6) / sizeof(uint32_t), &state);
115 port_seq[0] = pi
134 sync_gen_seq(const union pkt_info *pi, uint32_t seq, uint32_t ts, uint16_t mss, uint32_t hash_alg, rte_xmm_t *secret_key) argument
160 sync_check_ack(const union pkt_info *pi, uint32_t seq, uint32_t ack, uint32_t ts, uint32_t hash_alg, rte_xmm_t *secret_key) argument
[all...]
H A Dstream_table.h64 stbl_pkt_fill_key(struct stbl_key *k, const union pkt_info *pi, uint32_t type) argument
70 k->port = pi->port;
72 k->addr4 = pi->addr4;
74 k->addr6 = *pi->addr6;
92 stbl_add_entry(struct stbl *st, const union pkt_info *pi) argument
99 type = pi->tf.type;
100 stbl_pkt_fill_key(&k, pi, type);
110 stbl_add_stream(struct stbl *st, const union pkt_info *pi, const void *s) argument
114 se = stbl_add_entry(st, pi);
121 stbl_find_entry(struct stbl *st, const union pkt_info *pi) argument
139 stbl_find_data(struct stbl *st, const union pkt_info *pi) argument
[all...]
H A Dtcp_misc.h421 get_pkt_info(const struct rte_mbuf *m, union pkt_info *pi, union seg_info *si) argument
435 pi->addr4.raw = 0;
440 pi->addr4.raw = pa4->raw;
442 pi->addr6 = rte_pktmbuf_mtod_offset(m, const union ipv6_addrs *,
450 pi->tf.flags = tcph->tcp_flags;
451 pi->tf.type = type;
452 pi->csf = m->ol_flags & (PKT_RX_IP_CKSUM_MASK | PKT_RX_L4_CKSUM_MASK);
453 pi->port.raw = prt->raw;
H A Dtcp_rxtx.c39 rx_check_stream(const struct tle_tcp_stream *s, const union pkt_info *pi) argument
43 if (pi->tf.type == TLE_V4)
44 rc = (pi->port.raw & s->s.pmsk.raw) != s->s.port.raw ||
45 (pi->addr4.raw & s->s.ipv4.mask.raw) !=
48 rc = (pi->port.raw & s->s.pmsk.raw) != s->s.port.raw ||
49 ymm_mask_cmp(&pi->addr6->raw, &s->s.ipv6.addr.raw,
56 rx_obtain_listen_stream(const struct tle_dev *dev, const union pkt_info *pi, argument
61 s = (struct tle_tcp_stream *)dev->dp[type]->streams[pi->port.dst];
76 const union pkt_info *pi, uint32_t type)
80 s = stbl_find_data(st, pi);
75 rx_obtain_stream(const struct tle_dev *dev, struct stbl *st, const union pkt_info *pi, uint32_t type) argument
108 pkt_info_bulk_eq(const union pkt_info pi[], uint32_t num) argument
130 pkt_info_bulk_syneq(const union pkt_info pi[], uint32_t num) argument
629 sync_ack(struct tle_tcp_stream *s, const union pkt_info *pi, const union seg_info *si, uint32_t ts, struct rte_mbuf *m) argument
783 restore_syn_opt(union seg_info *si, union tsopt *to, const union pkt_info *pi, uint32_t ts, const struct rte_mbuf *mb, uint32_t hash_alg, rte_xmm_t *secret_key) argument
851 accept_prep_stream(struct tle_tcp_stream *ps, struct stbl *st, struct tle_tcp_stream *cs, const union tsopt *to, uint32_t tms, const union pkt_info *pi, const union seg_info *si) argument
932 rx_ack_listen(struct tle_tcp_stream *s, struct stbl *st, const union pkt_info *pi, union seg_info *si, uint32_t tms, struct rte_mbuf *mb, struct tle_tcp_stream **csp) argument
1617 rx_stream(struct tle_tcp_stream *s, uint32_t ts, const union pkt_info *pi, const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1742 rx_new_stream(struct tle_tcp_stream *s, uint32_t ts, const union pkt_info *pi, const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1763 rx_postsyn(struct tle_dev *dev, struct stbl *st, uint32_t type, uint32_t ts, const union pkt_info pi[], union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1844 rx_syn(struct tle_dev *dev, uint32_t type, uint32_t ts, const union pkt_info pi[], const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1890 union pkt_info pi[num]; local
2010 stream_fill_pkt_info(const struct tle_tcp_stream *s, union pkt_info *pi) argument
2082 union pkt_info pi; local
[all...]
/tldk/app/nginx/src/os/win32/
H A Dngx_process.c210 PROCESS_INFORMATION pi; local
215 ngx_memzero(&pi, sizeof(PROCESS_INFORMATION));
218 NULL, NULL, 0, CREATE_NO_WINDOW, NULL, NULL, &si, &pi)
227 ctx->child = pi.hProcess;
229 if (CloseHandle(pi.hThread) == 0) {
231 "CloseHandle(pi.hThread) failed");
235 "start %s process %P", ctx->name, pi.dwProcessId);
237 return pi.dwProcessId;

Completed in 6 milliseconds