Lines Matching defs:pkt_node

149     "SIFTR pkt_node struct");
154 struct pkt_node {
162 	/* IP version pkt_node relates to; either INP_IPV4 or INP_IPV6. */
214 	/* Link to next pkt_node in the list. */
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)
382 	if (pkt_node->flowid == 0) {
386 	counter_list = counter_hash + (pkt_node->flowid & siftr_hashmask);
387 	hash_node = siftr_find_flow(counter_list, pkt_node->flowid);
413 	    direction[pkt_node->direction],
414 	    (intmax_t)pkt_node->tval.tv_sec,
415 	    pkt_node->tval.tv_usec,
420 	    pkt_node->snd_ssthresh,
421 	    pkt_node->snd_cwnd,
422 	    pkt_node->t_flags2,
423 	    pkt_node->snd_wnd,
424 	    pkt_node->rcv_wnd,
425 	    pkt_node->snd_scale,
426 	    pkt_node->rcv_scale,
427 	    pkt_node->conn_state,
428 	    pkt_node->mss,
429 	    pkt_node->srtt,
430 	    pkt_node->sack_enabled,
431 	    pkt_node->t_flags,
432 	    pkt_node->rto,
433 	    pkt_node->snd_buf_hiwater,
434 	    pkt_node->snd_buf_cc,
435 	    pkt_node->rcv_buf_hiwater,
436 	    pkt_node->rcv_buf_cc,
437 	    pkt_node->sent_inflight_bytes,
438 	    pkt_node->t_segqlen,
439 	    pkt_node->flowid,
440 	    pkt_node->flowtype);
448 	STAILQ_HEAD(pkthead, pkt_node) tmp_pkt_queue =
450 	struct pkt_node *pkt_node;
469 		/* Gain exclusive access to the pkt_node queue. */
490 		while ((pkt_node = STAILQ_FIRST(&tmp_pkt_queue)) != NULL) {
493 			    ((STAILQ_NEXT(pkt_node, nodes) != NULL) ?
509 			STAILQ_FOREACH(pkt_node, &tmp_pkt_queue, nodes) {
511 					ret_sz = siftr_process_pkt(pkt_node,
523 				pkt_node = STAILQ_FIRST(&tmp_pkt_queue);
525 				free(pkt_node, M_SIFTR_PKTNODE);
670 siftr_siftdata(struct pkt_node *pn, struct inpcb *inp, struct tcpcb *tp,
725 	struct pkt_node *pn;
838 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);
872 	struct pkt_node *pn;
987 	pn = malloc(sizeof(struct pkt_node), M_SIFTR_PKTNODE, M_NOWAIT|M_ZERO);