Searched refs:drb (Results 1 - 9 of 9) sorted by relevance

/tldk/lib/libtle_l4p/
H A Dudp_stream.h55 uint32_t nb_elem; /* number of obects per drb. */
58 } drb; member in struct:tle_udp_stream::__anon545
70 ((s)->tx.drb.nb_max != rte_ring_count((s)->tx.drb.r))
73 ((s)->tx.drb.nb_max == rte_ring_count((s)->tx.drb.r))
H A Dudp_stream.c39 rte_free(s->tx.drb.r);
65 struct tle_drb *drb; local
96 /* size of the drb. */
102 s->tx.drb.r = rte_zmalloc_socket(NULL, sz, RTE_CACHE_LINE_SIZE,
104 if (s->tx.drb.r == NULL) {
112 rte_ring_init(s->tx.drb.r, name, n, 0);
115 drb = (struct tle_drb *)((uintptr_t)s->tx.drb.r +
117 drb->udata = s;
118 drb
135 udp_free_drbs(struct tle_stream *s, struct tle_drb *drb[], uint32_t nb_drb) argument
[all...]
H A Dtcp_stream.h125 uint32_t nb_elem; /* number of objects per drb. */
128 } drb; member in struct:tle_tcp_stream::__anon17
141 ((s)->tx.drb.nb_max != rte_ring_count((s)->tx.drb.r))
144 ((s)->tx.drb.nb_max == rte_ring_count((s)->tx.drb.r))
173 } drb; member in struct:stream_szofs
H A Dtcp_stream.c116 szofs->drb.nb_obj = drb_nb_elem(ctx);
117 szofs->drb.nb_max = calc_stream_drb_num(ctx, szofs->drb.nb_obj);
118 szofs->drb.nb_rng = rte_align32pow2(szofs->drb.nb_max);
119 szofs->drb.rng_sz = rte_ring_get_memsize(szofs->drb.nb_rng);
120 szofs->drb.blk_sz = tle_drb_calc_size(szofs->drb.nb_obj);
121 szofs->drb
134 struct tle_drb *drb; local
173 tcp_free_drbs(struct tle_stream *s, struct tle_drb *drb[], uint32_t nb_drb) argument
[all...]
H A Dudp_rxtx.c217 stream_drb_release(struct tle_udp_stream *s, struct tle_drb *drb[], argument
222 n = rte_ring_count(s->tx.drb.r);
223 _rte_ring_enqueue_burst(s->tx.drb.r, (void **)drb, nb_drb);
244 struct tle_drb *drb[num]; local
251 num, drb, &k);
259 s = drb[i]->udata;
260 for (j = i + 1; j != k && s == drb[j]->udata; j++)
262 stream_drb_release(s, drb + i, j - i);
446 _rte_ring_enqueue_burst(s->tx.drb
515 struct tle_drb *drb[num]; local
[all...]
H A Dctx.c271 struct tle_drb *drb[MAX_PKT_BURST]; local
274 k = RTE_DIM(drb);
276 RTE_DIM(pkt), drb, &k);
283 s = drb[i]->udata;
284 tle_stream_ops[proto].free_drbs(s, drb + i, 1);
H A Dtcp_rxtx.c157 _rte_ring_enqueue_burst(s->tx.drb.r, (void **)drbs, nb_drb);
164 return _rte_ring_dequeue_burst(s->tx.drb.r, (void **)drbs, nb_drb);
335 struct tle_drb *drb[num]; local
338 bsz = s->tx.drb.nb_elem;
342 nb = stream_drb_alloc(s, drb, nbm);
344 /* drb ring is empty. */
356 num, drb, &nb);
360 stream_drb_free(s, drb + nbm - nb, nb);
550 struct tle_drb *drb; local
552 if (stream_drb_alloc(s, &drb,
1985 struct tle_drb *drb[num]; local
[all...]
/tldk/test/dring/
H A Dtest_dring.c61 struct tle_drb *drb; local
64 while (rte_ring_dequeue(r, (void **)&drb) == 0)
65 free(drb);
80 struct tle_drb *drb; local
103 drb = calloc(1, sz);
104 if (drb == NULL) {
111 drb->size = k;
112 rte_ring_enqueue(r, drb);
172 struct tle_drb *drb[num]; local
180 n = tle_dring_sc_dequeue(dr, (const void **)obj, num, drb,
221 struct tle_drb *drb[num]; local
[all...]
/tldk/test/gtest/
H A Dtest_tle_dring.h127 struct tle_drb *drb; local
130 while (rte_ring_dequeue(r, (void **)&drb) == 0)
131 free(drb);
143 struct tle_drb *drb; local
166 drb = (struct tle_drb *)calloc(1, sz);
167 if (drb == NULL) {
174 drb->size = k;
175 rte_ring_enqueue(r, drb);
189 struct tle_drb *drb[num]; local
197 if (rte_ring_dequeue(r, (void **)&drb[
257 struct tle_drb *drb[num]; local
[all...]

Completed in 7 milliseconds