diff options
author | Mohammad Abdul Awal <mohammad.abdul.awal@intel.com> | 2017-05-11 13:36:12 +0100 |
---|---|---|
committer | Mohammad Abdul Awal <mohammad.abdul.awal@intel.com> | 2017-05-15 15:11:36 +0100 |
commit | fbba0a3bf2dbfd86e48efe9745af9f94203d5f80 (patch) | |
tree | 69ba709ff7ebc503fc2036324c1ffa09037a9f7d /lib/libtle_l4p/tcp_rxtx.c | |
parent | 8d020909941acca43cf7e772a99682a894347526 (diff) |
Added rte_ring wrapper functions to support dpdk-17.05 and older version
Change-Id: I5cfcff8be275ab2a2fb4ad6a62777a8cb88f425b
Signed-off-by: Mohammad Abdul Awal <mohammad.abdul.awal@intel.com>
Diffstat (limited to 'lib/libtle_l4p/tcp_rxtx.c')
-rw-r--r-- | lib/libtle_l4p/tcp_rxtx.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/lib/libtle_l4p/tcp_rxtx.c b/lib/libtle_l4p/tcp_rxtx.c index ceaa2bc..ff39f32 100644 --- a/lib/libtle_l4p/tcp_rxtx.c +++ b/lib/libtle_l4p/tcp_rxtx.c @@ -154,14 +154,14 @@ static inline void stream_drb_free(struct tle_tcp_stream *s, struct tle_drb *drbs[], uint32_t nb_drb) { - rte_ring_enqueue_burst(s->tx.drb.r, (void **)drbs, nb_drb); + _rte_ring_enqueue_burst(s->tx.drb.r, (void **)drbs, nb_drb); } static inline uint32_t stream_drb_alloc(struct tle_tcp_stream *s, struct tle_drb *drbs[], uint32_t nb_drb) { - return rte_ring_dequeue_burst(s->tx.drb.r, (void **)drbs, nb_drb); + return _rte_ring_dequeue_burst(s->tx.drb.r, (void **)drbs, nb_drb); } static inline void @@ -939,7 +939,7 @@ rx_ack_listen(struct tle_tcp_stream *s, struct stbl *st, if (accept_prep_stream(s, st, cs, &so, tms, pi, si) == 0) { /* put new stream in the accept queue */ - if (rte_ring_enqueue_burst(s->rx.q, + if (_rte_ring_enqueue_burst(s->rx.q, (void * const *)&ts, 1) == 1) { *csp = cs; return 0; @@ -1927,7 +1927,7 @@ tle_tcp_stream_accept(struct tle_stream *ts, struct tle_stream *rs[], struct tle_tcp_stream *s; s = TCP_STREAM(ts); - n = rte_ring_mc_dequeue_burst(s->rx.q, (void **)rs, num); + n = _rte_ring_mc_dequeue_burst(s->rx.q, (void **)rs, num); if (n == 0) return 0; @@ -2138,7 +2138,7 @@ tle_tcp_stream_recv(struct tle_stream *ts, struct rte_mbuf *pkt[], uint16_t num) struct tle_tcp_stream *s; s = TCP_STREAM(ts); - n = rte_ring_mc_dequeue_burst(s->rx.q, (void **)pkt, num); + n = _rte_ring_mc_dequeue_burst(s->rx.q, (void **)pkt, num); if (n == 0) return 0; @@ -2174,7 +2174,7 @@ tx_segments(struct tle_tcp_stream *s, uint64_t ol_flags, if (i == num) { /* queue packets for further transmission. */ - rc = rte_ring_mp_enqueue_bulk(s->tx.q, (void **)segs, num); + rc = _rte_ring_mp_enqueue_bulk(s->tx.q, (void **)segs, num); if (rc != 0) free_segments(segs, num); } @@ -2228,8 +2228,8 @@ tle_tcp_stream_send(struct tle_stream *ts, struct rte_mbuf *pkt[], uint16_t num) if (i != k) { /* queue packets for further transmission. */ - n = rte_ring_mp_enqueue_burst(s->tx.q, (void **)pkt + k, - (i - k)); + n = _rte_ring_mp_enqueue_burst(s->tx.q, + (void **)pkt + k, (i - k)); k += n; /* |