netgraph/netflow/netflow.c

204 get_export_dgram(priv_p priv, fib_export_p fe)
208 	mtx_lock(&fe->export_mtx);
209 	if (fe->exp.item != NULL) {
210 		item = fe->exp.item;
211 		fe->exp.item = NULL;
213 	mtx_unlock(&fe->export_mtx);
238 return_export_dgram(priv_p priv, fib_export_p fe, item_p item, int flags)
246 	mtx_lock(&fe->export_mtx);
247 	if (fe->exp.item == NULL) {
248 		fe->exp.item = item;
249 		mtx_unlock(&fe->export_mtx);
251 		mtx_unlock(&fe->export_mtx);
252 		export_send(priv, fe, item, flags);
261 expire_flow(priv_p priv, fib_export_p fe, struct flow_entry *fle, int flags)
267 		exp.item = get_export_dgram(priv, fe);
278 			export_send(priv, fe, exp.item, flags);
280 			return_export_dgram(priv, fe, exp.item, NG_QUEUE);
284 		exp.item9 = get_export9_dgram(priv, fe, &exp.item9_opt);
300 			export9_send(priv, fe, exp.item9, exp.item9_opt, flags);
302 			return_export9_dgram(priv, fe, exp.item9,
568 	fib_export_p	fe = priv_to_fib(priv, fib);
572 	if (fe != NULL)
575 	if ((fe = malloc(sizeof(struct fib_export), M_NETGRAPH,
579 	mtx_init(&fe->export_mtx, "export dgram lock", NULL, MTX_DEF);
580 	mtx_init(&fe->export9_mtx, "export9 dgram lock", NULL, MTX_DEF);
581 	fe->fib = fib;
582 	fe->domain_id = fib;
585 	    (uintptr_t)NULL, (uintptr_t)fe) == 0) {
588 		    fib, fe, priv_to_fib(priv, fib));
589 		mtx_destroy(&fe->export_mtx);
590 		mtx_destroy(&fe->export9_mtx);
591 		free(fe, M_NETGRAPH);
595 		    fib, fe, priv_to_fib(priv, fib));
609 	fib_export_p fe;
622 			fe = priv_to_fib(priv, fle->f.r.fib);
623 			expire_flow(priv, fe, fle, NG_QUEUE);
629 			fe = priv_to_fib(priv, fle->f.r.fib);
630 			expire_flow(priv, fe, fle, NG_QUEUE);
654 		if ((fe = priv_to_fib(priv, i)) == NULL)
657 		if (fe->exp.item != NULL)
658 			export_send(priv, fe, fe->exp.item, NG_QUEUE);
660 		if (fe->exp.item9 != NULL)
661 			export9_send(priv, fe, fe->exp.item9,
662 			    fe->exp.item9_opt, NG_QUEUE);
664 		mtx_destroy(&fe->export_mtx);
665 		mtx_destroy(&fe->export9_mtx);
666 		free(fe, M_NETGRAPH);
674 ng_netflow_flow_add(priv_p priv, fib_export_p fe, struct ip *ip,
701 	r.fib = fe->fib;
803 ng_netflow_flow6_add(priv_p priv, fib_export_p fe, struct ip6_hdr *ip6,
823 	r.fib = fe->fib;
1036 export_send(priv_p priv, fib_export_p fe, item_p item, int flags)
1055 	header->engine_id = fe->domain_id;
1057 	header->flow_seq = htonl(atomic_fetchadd_32(&fe->flow_seq,