Lines Matching refs:pctx

152 	struct pkt_ctx pctx;  in SendTCPPacketStandalone()  local
155 memset(&pctx, 0, sizeof(pctx)); in SendTCPPacketStandalone()
156 pctx.p.in_ifidx = in_ifidx; in SendTCPPacketStandalone()
165 saddr, daddr, TCP_HEADER_LEN + optlen + payloadlen, &pctx, cur_ts); in SendTCPPacketStandalone()
211 pctx.out_ifidx, in SendTCPPacketStandalone()
213 pctx.p.iph); in SendTCPPacketStandalone()
238 EVAL_BPFFILTER(walk->raw_pkt_fcode, (uint8_t *)pctx.p.ethh, in SendTCPPacketStandalone()
239 pctx.p.eth_len)) in SendTCPPacketStandalone()
241 &pctx, MOS_ON_PKT_IN); in SendTCPPacketStandalone()
254 struct pkt_ctx pctx; in SendTCPPacket() local
257 memset(&pctx, 0, sizeof(pctx)); in SendTCPPacket()
265 TCP_HEADER_LEN + optlen + payloadlen, &pctx, cur_ts); in SendTCPPacket()
346 pctx.out_ifidx, in SendTCPPacket()
348 pctx.p.iph); in SendTCPPacket()
382 EVAL_BPFFILTER(walk->raw_pkt_fcode, (uint8_t *)pctx.p.ethh, in SendTCPPacket()
383 pctx.p.eth_len)) in SendTCPPacket()
385 &pctx, MOS_ON_PKT_IN); in SendTCPPacket()
388 FillPacketContextTCPInfo(&pctx, tcph); in SendTCPPacket()
396 pctx.p.offset = (uint64_t)seq2loff(recvside_stream->rcvvar->rcvbuf, in SendTCPPacket()
397 pctx.p.seq, in SendTCPPacket()
399 UpdateMonitor(mtcp, sendside_stream, recvside_stream, &pctx, false); in SendTCPPacket()
984 struct pkt_ctx *pctx) in UpdatePassiveSendTCPContext_SynSent() argument
987 assert(pctx); in UpdatePassiveSendTCPContext_SynSent()
997 cur_stream->sndvar->ip_id = htons(pctx->p.iph->id); in UpdatePassiveSendTCPContext_SynSent()
998 cur_stream->sndvar->iss = pctx->p.seq; in UpdatePassiveSendTCPContext_SynSent()
999 cur_stream->snd_nxt = pctx->p.seq + 1; in UpdatePassiveSendTCPContext_SynSent()
1001 cur_stream->last_active_ts = pctx->p.cur_ts; in UpdatePassiveSendTCPContext_SynSent()
1014 struct pkt_ctx *pctx) in UpdatePassiveSendTCPContext() argument
1019 tcph = pctx->p.tcph; in UpdatePassiveSendTCPContext()
1025 UpdatePassiveSendTCPContext_SynSent(cur_stream, pctx); in UpdatePassiveSendTCPContext()
1031 cur_stream->sndvar->ts_lastack_sent = pctx->p.cur_ts; in UpdatePassiveSendTCPContext()
1032 cur_stream->last_active_ts = pctx->p.cur_ts; in UpdatePassiveSendTCPContext()
1035 cur_stream->snd_nxt = pctx->p.seq + pctx->p.payloadlen; in UpdatePassiveSendTCPContext()
1058 if (tcph->ack && TCP_SEQ_GT(pctx->p.seq, cur_stream->sndvar->iss)) { in UpdatePassiveSendTCPContext()
1061 cur_stream->snd_nxt = pctx->p.seq; in UpdatePassiveSendTCPContext()
1062 cur_stream->rcv_nxt = pctx->p.ack_seq; in UpdatePassiveSendTCPContext()
1072 cur_stream->sndvar->iss = pctx->p.seq; in UpdatePassiveSendTCPContext()
1076 cur_stream->id, pctx->p.seq); in UpdatePassiveSendTCPContext()
1082 cur_stream->snd_nxt = pctx->p.seq; in UpdatePassiveSendTCPContext()
1083 cur_stream->rcv_nxt = pctx->p.ack_seq; in UpdatePassiveSendTCPContext()
1108 cur_stream->sndvar->fss = pctx->p.seq + pctx->p.payloadlen; in UpdatePassiveSendTCPContext()
1131 cur_stream->sndvar->fss = pctx->p.seq + pctx->p.payloadlen; in UpdatePassiveSendTCPContext()
1183 TCPStateToString(cur_stream), pctx->p.tcph->syn, in UpdatePassiveSendTCPContext()
1184 pctx->p.tcph->ack); in UpdatePassiveSendTCPContext()
1195 PostSendTCPAction(mtcp_manager_t mtcp, struct pkt_ctx *pctx, in PostSendTCPAction() argument