154 struct pkt_node {  struct
215 	STAILQ_ENTRY(pkt_node)	nodes;
268 STAILQ_HEAD(pkthead, pkt_node) pkt_queue = STAILQ_HEAD_INITIALIZER(pkt_queue);
376 siftr_process_pkt(struct pkt_node * pkt_node, char *buf)  in siftr_process_pkt()  argument
382 	if (pkt_node->flowid == 0) {  in siftr_process_pkt()
386 	counter_list = counter_hash + (pkt_node->flowid & siftr_hashmask);  in siftr_process_pkt()
387 	hash_node = siftr_find_flow(counter_list, pkt_node->flowid);  in siftr_process_pkt()
413 	    direction[pkt_node->direction],  in siftr_process_pkt()
414 	    (intmax_t)pkt_node->tval.tv_sec,  in siftr_process_pkt()
415 	    pkt_node->tval.tv_usec,  in siftr_process_pkt()
420 	    pkt_node->snd_ssthresh,  in siftr_process_pkt()
421 	    pkt_node->snd_cwnd,  in siftr_process_pkt()
422 	    pkt_node->t_flags2,  in siftr_process_pkt()
423 	    pkt_node->snd_wnd,  in siftr_process_pkt()
424 	    pkt_node->rcv_wnd,  in siftr_process_pkt()
425 	    pkt_node->snd_scale,  in siftr_process_pkt()
426 	    pkt_node->rcv_scale,  in siftr_process_pkt()
427 	    pkt_node->conn_state,  in siftr_process_pkt()
428 	    pkt_node->mss,  in siftr_process_pkt()
429 	    pkt_node->srtt,  in siftr_process_pkt()
430 	    pkt_node->sack_enabled,  in siftr_process_pkt()
431 	    pkt_node->t_flags,  in siftr_process_pkt()
432 	    pkt_node->rto,  in siftr_process_pkt()
433 	    pkt_node->snd_buf_hiwater,  in siftr_process_pkt()
434 	    pkt_node->snd_buf_cc,  in siftr_process_pkt()
435 	    pkt_node->rcv_buf_hiwater,  in siftr_process_pkt()
436 	    pkt_node->rcv_buf_cc,  in siftr_process_pkt()
437 	    pkt_node->sent_inflight_bytes,  in siftr_process_pkt()
438 	    pkt_node->t_segqlen,  in siftr_process_pkt()
439 	    pkt_node->flowid,  in siftr_process_pkt()
440 	    pkt_node->flowtype);  in siftr_process_pkt()
448 	STAILQ_HEAD(pkthead, pkt_node) tmp_pkt_queue =  in siftr_pkt_manager_thread()
450 	struct pkt_node *pkt_node;  in siftr_pkt_manager_thread()  local
490 		while ((pkt_node = STAILQ_FIRST(&tmp_pkt_queue)) != NULL) {  in siftr_pkt_manager_thread()
493 			    ((STAILQ_NEXT(pkt_node, nodes) != NULL) ?  in siftr_pkt_manager_thread()
509 			STAILQ_FOREACH(pkt_node, &tmp_pkt_queue, nodes) {  in siftr_pkt_manager_thread()
511 					ret_sz = siftr_process_pkt(pkt_node,  in siftr_pkt_manager_thread()
523 				pkt_node = STAILQ_FIRST(&tmp_pkt_queue);  in siftr_pkt_manager_thread()
525 				free(pkt_node, M_SIFTR_PKTNODE);  in siftr_pkt_manager_thread()
670 siftr_siftdata(struct pkt_node *pn, struct inpcb *inp, struct tcpcb *tp,  in siftr_siftdata()
725 	struct pkt_node *pn;  in siftr_chkpkt()
838 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);  in siftr_chkpkt()
872 	struct pkt_node *pn;  in siftr_chkpkt6()
987 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);  in siftr_chkpkt6()