Lines Matching defs:fe

23 netfe_stream_open_udp(struct netfe_lcore *fe, struct netfe_sprm *sprm,
33 fes = netfe_get_stream(&fe->free);
39 fes->rxev = tle_event_alloc(fe->rxeq, fes);
40 fes->txev = tle_event_alloc(fe->txeq, fes);
43 netfe_stream_close(fe, fes);
68 netfe_stream_close(fe, fes);
103 struct netfe_lcore *fe;
118 sz = sizeof(*fe) + snum * sizeof(struct netfe_stream);
119 fe = rte_zmalloc_socket(NULL, sz, RTE_CACHE_LINE_SIZE,
122 if (fe == NULL) {
128 RTE_PER_LCORE(_fe) = fe;
130 fe->snum = snum;
132 LIST_INIT(&fe->free.head);
133 LIST_INIT(&fe->use.head);
134 fes = (struct netfe_stream *)(fe + 1);
136 netfe_put_stream(fe, &fe->free, fes);
139 fe->rxeq = tle_evq_create(&eprm);
140 fe->txeq = tle_evq_create(&eprm);
143 __func__, lcore, fe->rxeq, fe->txeq);
144 if (fe->rxeq == NULL || fe->txeq == NULL)
147 rc = fwd_tbl_init(fe, AF_INET, lcore);
153 rc = fwd_tbl_init(fe, AF_INET6, lcore);
162 fes = netfe_stream_open_udp(fe, sprm, lcore, prm->stream[i].op,
173 rc = fwd_tbl_add(fe,
179 netfe_stream_close(fe, fes);
197 struct netfe_lcore *fe;
200 fe = RTE_PER_LCORE(_fe);
202 fed = fwd_tbl_lkp(fe, fes->family, sa);
215 fed = netfe_stream_open_udp(fe, &fes->fwdprm, lcore, FWD,
220 rc = fwd_tbl_add(fe, fes->family, sa, fed);
222 netfe_stream_close(fe, fed);
486 struct netfe_lcore *fe;
490 fe = RTE_PER_LCORE(_fe);
491 if (fe == NULL)
497 n = tle_evq_get(fe->rxeq, (const void **)(uintptr_t)fs, RTE_DIM(fs));
501 __func__, lcore, fe->rxeq, n);
507 n = tle_evq_get(fe->txeq, (const void **)(uintptr_t)fs, RTE_DIM(fs));
511 __func__, lcore, fe->txeq, n);
526 struct netfe_lcore *fe;
531 fe = RTE_PER_LCORE(_fe);
532 if (fe == NULL)
535 for (i = 0; i != fe->use.num; i++) {
536 fes = netfe_get_stream(&fe->use);
539 netfe_stream_close(fe, fes);
542 tle_evq_destroy(fe->txeq);
543 tle_evq_destroy(fe->rxeq);
545 rte_free(fe);
564 if (prm->fe.max_streams != 0)
565 rc = netfe_lcore_init_udp(&prm->fe);