sys/netinet/siftr.c

672 siftr_siftdata(struct pkt_node *pn, struct inpcb *inp, struct tcpcb *tp,
675 	pn->ipver = ipver;
676 	pn->lport = inp->inp_lport;
677 	pn->fport = inp->inp_fport;
678 	pn->laddr = inp->inp_inc.inc_ie.ie_dependladdr;
679 	pn->faddr = inp->inp_inc.inc_ie.ie_dependfaddr;
680 	pn->snd_cwnd = tp->snd_cwnd;
681 	pn->snd_wnd = tp->snd_wnd;
682 	pn->rcv_wnd = tp->rcv_wnd;
683 	pn->t_flags2 = tp->t_flags2;
684 	pn->snd_ssthresh = tp->snd_ssthresh;
685 	pn->snd_scale = tp->snd_scale;
686 	pn->rcv_scale = tp->rcv_scale;
687 	pn->conn_state = tp->t_state;
688 	pn->mss = tp->t_maxseg;
689 	pn->srtt = ((uint64_t)tp->t_srtt * tick) >> TCP_RTT_SHIFT;
690 	pn->sack_enabled = (tp->t_flags & TF_SACK_PERMIT) != 0;
691 	pn->t_flags = tp->t_flags;
692 	pn->rto = tp->t_rxtcur * tick;
693 	pn->snd_buf_hiwater = inp->inp_socket->so_snd.sb_hiwat;
694 	pn->snd_buf_cc = sbused(&inp->inp_socket->so_snd);
695 	pn->rcv_buf_hiwater = inp->inp_socket->so_rcv.sb_hiwat;
696 	pn->rcv_buf_cc = sbused(&inp->inp_socket->so_rcv);
697 	pn->sent_inflight_bytes = tp->snd_max - tp->snd_una;
698 	pn->t_segqlen = tp->t_segqlen;
704 	pn->direction = (dir == PFIL_IN ? DIR_IN : DIR_OUT);
711 	microtime(&pn->tval);
712 	TCP_PROBE1(siftr, pn);
727 	struct pkt_node *pn;
840 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);
842 	if (pn == NULL) {
851 	pn->flowid = hash_id;
852 	pn->flowtype = hash_type;
854 	siftr_siftdata(pn, inp, tp, INP_IPV4, dir, inp_locally_locked);
857 	STAILQ_INSERT_TAIL(&pkt_queue, pn, nodes);
874 	struct pkt_node *pn;
989 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);
991 	if (pn == NULL) {
1000 	pn->flowid = hash_id;
1001 	pn->flowtype = hash_type;
1003 	siftr_siftdata(pn, inp, tp, INP_IPV6, dir, inp_locally_locked);
1006 	STAILQ_INSERT_TAIL(&pkt_queue, pn, nodes);