172 struct pkt_node {  struct
242 	STAILQ_ENTRY(pkt_node)	nodes;
285 STAILQ_HEAD(pkthead, pkt_node) pkt_queue = STAILQ_HEAD_INITIALIZER(pkt_queue);
336 siftr_process_pkt(struct pkt_node * pkt_node)  in siftr_process_pkt()  argument
355 	key[0] = pkt_node->ipver;  in siftr_process_pkt()
356 	memcpy(key + key_offset, &pkt_node->ip_laddr,  in siftr_process_pkt()
357 	    sizeof(pkt_node->ip_laddr));  in siftr_process_pkt()
358 	key_offset += sizeof(pkt_node->ip_laddr);  in siftr_process_pkt()
359 	memcpy(key + key_offset, &pkt_node->tcp_localport,  in siftr_process_pkt()
360 	    sizeof(pkt_node->tcp_localport));  in siftr_process_pkt()
361 	key_offset += sizeof(pkt_node->tcp_localport);  in siftr_process_pkt()
362 	memcpy(key + key_offset, &pkt_node->ip_faddr,  in siftr_process_pkt()
363 	    sizeof(pkt_node->ip_faddr));  in siftr_process_pkt()
364 	key_offset += sizeof(pkt_node->ip_faddr);  in siftr_process_pkt()
365 	memcpy(key + key_offset, &pkt_node->tcp_foreignport,  in siftr_process_pkt()
366 	    sizeof(pkt_node->tcp_foreignport));  in siftr_process_pkt()
411 			if (pkt_node->direction == DIR_IN)  in siftr_process_pkt()
443 	pkt_node->ip_laddr[3] = ntohl(pkt_node->ip_laddr[3]);  in siftr_process_pkt()
444 	pkt_node->ip_faddr[3] = ntohl(pkt_node->ip_faddr[3]);  in siftr_process_pkt()
446 	if (pkt_node->ipver == INP_IPV6) { /* IPv6 packet */  in siftr_process_pkt()
447 		pkt_node->ip_laddr[0] = ntohl(pkt_node->ip_laddr[0]);  in siftr_process_pkt()
448 		pkt_node->ip_laddr[1] = ntohl(pkt_node->ip_laddr[1]);  in siftr_process_pkt()
449 		pkt_node->ip_laddr[2] = ntohl(pkt_node->ip_laddr[2]);  in siftr_process_pkt()
450 		pkt_node->ip_faddr[0] = ntohl(pkt_node->ip_faddr[0]);  in siftr_process_pkt()
451 		pkt_node->ip_faddr[1] = ntohl(pkt_node->ip_faddr[1]);  in siftr_process_pkt()
452 		pkt_node->ip_faddr[2] = ntohl(pkt_node->ip_faddr[2]);  in siftr_process_pkt()
460 		    direction[pkt_node->direction],  in siftr_process_pkt()
461 		    pkt_node->hash,  in siftr_process_pkt()
462 		    pkt_node->tval.tv_sec,  in siftr_process_pkt()
463 		    pkt_node->tval.tv_usec,  in siftr_process_pkt()
464 		    UPPER_SHORT(pkt_node->ip_laddr[0]),  in siftr_process_pkt()
465 		    LOWER_SHORT(pkt_node->ip_laddr[0]),  in siftr_process_pkt()
466 		    UPPER_SHORT(pkt_node->ip_laddr[1]),  in siftr_process_pkt()
467 		    LOWER_SHORT(pkt_node->ip_laddr[1]),  in siftr_process_pkt()
468 		    UPPER_SHORT(pkt_node->ip_laddr[2]),  in siftr_process_pkt()
469 		    LOWER_SHORT(pkt_node->ip_laddr[2]),  in siftr_process_pkt()
470 		    UPPER_SHORT(pkt_node->ip_laddr[3]),  in siftr_process_pkt()
471 		    LOWER_SHORT(pkt_node->ip_laddr[3]),  in siftr_process_pkt()
472 		    ntohs(pkt_node->tcp_localport),  in siftr_process_pkt()
473 		    UPPER_SHORT(pkt_node->ip_faddr[0]),  in siftr_process_pkt()
474 		    LOWER_SHORT(pkt_node->ip_faddr[0]),  in siftr_process_pkt()
475 		    UPPER_SHORT(pkt_node->ip_faddr[1]),  in siftr_process_pkt()
476 		    LOWER_SHORT(pkt_node->ip_faddr[1]),  in siftr_process_pkt()
477 		    UPPER_SHORT(pkt_node->ip_faddr[2]),  in siftr_process_pkt()
478 		    LOWER_SHORT(pkt_node->ip_faddr[2]),  in siftr_process_pkt()
479 		    UPPER_SHORT(pkt_node->ip_faddr[3]),  in siftr_process_pkt()
480 		    LOWER_SHORT(pkt_node->ip_faddr[3]),  in siftr_process_pkt()
481 		    ntohs(pkt_node->tcp_foreignport),  in siftr_process_pkt()
482 		    pkt_node->snd_ssthresh,  in siftr_process_pkt()
483 		    pkt_node->snd_cwnd,  in siftr_process_pkt()
484 		    pkt_node->snd_bwnd,  in siftr_process_pkt()
485 		    pkt_node->snd_wnd,  in siftr_process_pkt()
486 		    pkt_node->rcv_wnd,  in siftr_process_pkt()
487 		    pkt_node->snd_scale,  in siftr_process_pkt()
488 		    pkt_node->rcv_scale,  in siftr_process_pkt()
489 		    pkt_node->conn_state,  in siftr_process_pkt()
490 		    pkt_node->max_seg_size,  in siftr_process_pkt()
491 		    pkt_node->smoothed_rtt,  in siftr_process_pkt()
492 		    pkt_node->sack_enabled,  in siftr_process_pkt()
493 		    pkt_node->flags,  in siftr_process_pkt()
494 		    pkt_node->rxt_length,  in siftr_process_pkt()
495 		    pkt_node->snd_buf_hiwater,  in siftr_process_pkt()
496 		    pkt_node->snd_buf_cc,  in siftr_process_pkt()
497 		    pkt_node->rcv_buf_hiwater,  in siftr_process_pkt()
498 		    pkt_node->rcv_buf_cc,  in siftr_process_pkt()
499 		    pkt_node->sent_inflight_bytes,  in siftr_process_pkt()
500 		    pkt_node->t_segqlen,  in siftr_process_pkt()
501 		    pkt_node->flowid,  in siftr_process_pkt()
502 		    pkt_node->flowtype);  in siftr_process_pkt()
504 		pkt_node->ip_laddr[0] = FIRST_OCTET(pkt_node->ip_laddr[3]);  in siftr_process_pkt()
505 		pkt_node->ip_laddr[1] = SECOND_OCTET(pkt_node->ip_laddr[3]);  in siftr_process_pkt()
506 		pkt_node->ip_laddr[2] = THIRD_OCTET(pkt_node->ip_laddr[3]);  in siftr_process_pkt()
507 		pkt_node->ip_laddr[3] = FOURTH_OCTET(pkt_node->ip_laddr[3]);  in siftr_process_pkt()
508 		pkt_node->ip_faddr[0] = FIRST_OCTET(pkt_node->ip_faddr[3]);  in siftr_process_pkt()
509 		pkt_node->ip_faddr[1] = SECOND_OCTET(pkt_node->ip_faddr[3]);  in siftr_process_pkt()
510 		pkt_node->ip_faddr[2] = THIRD_OCTET(pkt_node->ip_faddr[3]);  in siftr_process_pkt()
511 		pkt_node->ip_faddr[3] = FOURTH_OCTET(pkt_node->ip_faddr[3]);  in siftr_process_pkt()
519 		    direction[pkt_node->direction],  in siftr_process_pkt()
520 		    pkt_node->hash,  in siftr_process_pkt()
521 		    (intmax_t)pkt_node->tval.tv_sec,  in siftr_process_pkt()
522 		    pkt_node->tval.tv_usec,  in siftr_process_pkt()
523 		    pkt_node->ip_laddr[0],  in siftr_process_pkt()
524 		    pkt_node->ip_laddr[1],  in siftr_process_pkt()
525 		    pkt_node->ip_laddr[2],  in siftr_process_pkt()
526 		    pkt_node->ip_laddr[3],  in siftr_process_pkt()
527 		    ntohs(pkt_node->tcp_localport),  in siftr_process_pkt()
528 		    pkt_node->ip_faddr[0],  in siftr_process_pkt()
529 		    pkt_node->ip_faddr[1],  in siftr_process_pkt()
530 		    pkt_node->ip_faddr[2],  in siftr_process_pkt()
531 		    pkt_node->ip_faddr[3],  in siftr_process_pkt()
532 		    ntohs(pkt_node->tcp_foreignport),  in siftr_process_pkt()
533 		    pkt_node->snd_ssthresh,  in siftr_process_pkt()
534 		    pkt_node->snd_cwnd,  in siftr_process_pkt()
535 		    pkt_node->snd_bwnd,  in siftr_process_pkt()
536 		    pkt_node->snd_wnd,  in siftr_process_pkt()
537 		    pkt_node->rcv_wnd,  in siftr_process_pkt()
538 		    pkt_node->snd_scale,  in siftr_process_pkt()
539 		    pkt_node->rcv_scale,  in siftr_process_pkt()
540 		    pkt_node->conn_state,  in siftr_process_pkt()
541 		    pkt_node->max_seg_size,  in siftr_process_pkt()
542 		    pkt_node->smoothed_rtt,  in siftr_process_pkt()
543 		    pkt_node->sack_enabled,  in siftr_process_pkt()
544 		    pkt_node->flags,  in siftr_process_pkt()
545 		    pkt_node->rxt_length,  in siftr_process_pkt()
546 		    pkt_node->snd_buf_hiwater,  in siftr_process_pkt()
547 		    pkt_node->snd_buf_cc,  in siftr_process_pkt()
548 		    pkt_node->rcv_buf_hiwater,  in siftr_process_pkt()
549 		    pkt_node->rcv_buf_cc,  in siftr_process_pkt()
550 		    pkt_node->sent_inflight_bytes,  in siftr_process_pkt()
551 		    pkt_node->t_segqlen,  in siftr_process_pkt()
552 		    pkt_node->flowid,  in siftr_process_pkt()
553 		    pkt_node->flowtype);  in siftr_process_pkt()
564 	STAILQ_HEAD(pkthead, pkt_node) tmp_pkt_queue =  in siftr_pkt_manager_thread()
566 	struct pkt_node *pkt_node, *pkt_node_temp;  in siftr_pkt_manager_thread()  local
604 		STAILQ_FOREACH_SAFE(pkt_node, &tmp_pkt_queue, nodes,  in siftr_pkt_manager_thread()
606 			siftr_process_pkt(pkt_node);  in siftr_pkt_manager_thread()
608 			free(pkt_node, M_SIFTR_PKTNODE);  in siftr_pkt_manager_thread()
757 siftr_siftdata(struct pkt_node *pn, struct inpcb *inp, struct tcpcb *tp,  in siftr_siftdata()
833 	struct pkt_node *pn;  in siftr_chkpkt()
921 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);  in siftr_chkpkt()
1013 	struct pkt_node *pn;  in siftr_chkpkt6()
1105 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);  in siftr_chkpkt6()