Searched refs:num (Results 1 - 25 of 55) sorted by relevance

123

/tldk/lib/libtle_memtank/
H A Dtle_memtank_pub.h42 _copy_objs(void *dst[], void * const src[], uint32_t num) argument
46 n = RTE_ALIGN_FLOOR(num, 4);
55 switch (num % 4) {
69 _get_free(struct tle_memtank *t, void *obj[], uint32_t num) argument
76 n = RTE_MIN(num, len);
86 _put_free(struct tle_memtank *t, void * const obj[], uint32_t num) argument
94 n = RTE_MIN(num, n);
103 _fill_free(struct tle_memtank *t, uint32_t num, uint32_t flags) argument
106 void *free[num];
115 tle_memtank_alloc(struct tle_memtank *t, void *obj[], uint32_t num, argument
135 tle_memtank_free(struct tle_memtank *t, void * const obj[], uint32_t num, uint32_t flags) argument
[all...]
H A Dtle_memtank.h119 * @param num
127 tle_memtank_alloc(struct tle_memtank *t, void *obj[], uint32_t num,
166 * @param num
172 tle_memtank_free(struct tle_memtank *t, void * const obj[], uint32_t num,
H A Dmemtank.c105 uint32_t num)
116 RTE_ASSERT(n + num <= ch->nb_total);
118 _copy_objs(ch->free + n, obj, num);
119 ch->nb_free = n + num;
143 shrink_chunk(struct memtank *mt, uint32_t num) argument
147 struct memchunk *ch[num];
152 for (k = 0; k != num; k++) {
185 grow_num(struct memtank *mt, uint32_t num) argument
190 n = rte_atomic32_add_return(&mt->nb_chunks, num);
193 return num;
104 put_chunk(struct memtank *mt, struct memchunk *ch, void * const obj[], uint32_t num) argument
200 grow_chunk(struct memtank *mt, uint32_t num) argument
393 uint32_t k, n, num; local
[all...]
/tldk/lib/libtle_l4p/
H A Dtcp_rxq.h27 uint32_t num; member in struct:rxq_objs
32 struct rte_mbuf *mb[], uint32_t num)
38 i = _ofo_step(s->rx.ofo, sl, mb + n, num - n);
40 } while (i != 0 && n != num);
82 struct rte_mbuf *mb[], uint32_t num)
86 n = _rte_ring_enqueue_burst(s->rx.q, (void * const *)mb, num);
89 for (i = n; i != num; i++)
98 struct rte_mbuf *mb[], uint32_t num)
111 t = rx_ino_enqueue(s, &sl, mb, num);
114 if (t != num)
31 rx_ofo_enqueue(struct tle_tcp_stream *s, union seqlen *sl, struct rte_mbuf *mb[], uint32_t num) argument
81 rx_ino_enqueue(struct tle_tcp_stream *s, union seqlen *sl, struct rte_mbuf *mb[], uint32_t num) argument
97 rx_data_enqueue(struct tle_tcp_stream *s, uint32_t seq, uint32_t len, struct rte_mbuf *mb[], uint32_t num) argument
178 tcp_rxq_consume(struct tle_tcp_stream *s, uint32_t num) argument
[all...]
H A Dtle_udp.h97 * Should contain at least *num* elements.
102 * Should contain at least *num* elements.
103 * @param num
109 struct rte_mbuf *rp[], int32_t rc[], uint16_t num);
123 * must be large enough to store up to *num* pointers in it.
124 * @param num
130 uint16_t num);
133 * return up to *num* mbufs that was received for given UDP stream.
145 * must be large enough to store up to *num* pointers in it.
146 * @param num
[all...]
H A Dtle_tcp.h98 * @param num
108 tle_tcp_stream_close_bulk(struct tle_stream *ts[], uint32_t num);
190 * return up to *num* streams from the queue of pending connections
199 * @param num
205 uint32_t num);
214 * @param num
223 struct tle_tcp_stream_cfg prm[], uint32_t num);
233 * contains at least *num* elements in it.
236 * must be large enough to store up to *num* pointers in it.
237 * @param num
[all...]
H A Dtcp_txq.h24 tcp_txq_get_nxt_objs(const struct tle_tcp_stream *s, uint32_t *num) argument
37 *num = cnt;
42 tcp_txq_get_una_objs(const struct tle_tcp_stream *s, uint32_t *num) argument
55 *num = cnt;
60 tcp_txq_set_nxt_head(struct tle_tcp_stream *s, uint32_t num) argument
65 r->cons.head += num;
78 tcp_txq_set_una_tail(struct tle_tcp_stream *s, uint32_t num) argument
84 r->cons.tail += num;
110 txs_dequeue_bulk(struct tle_ctx *ctx, struct tle_tcp_stream *s[], uint32_t num) argument
115 return _rte_ring_dequeue_burst(r, (void **)s, num);
[all...]
H A Dstream_table.c35 stbl_init(struct stbl *st, uint32_t num, int32_t socket) argument
42 num = RTE_MAX(5 * num / 4, 0x10U);
46 hprm.entries = num;
67 sz = sizeof(*st->ht[i].ent) * num;
73 st->ht[i].nb_ent = num;
H A Dstream.h53 get_streams(struct tle_ctx *ctx, struct tle_stream *s[], uint32_t num) argument
60 n = RTE_MIN(ctx->streams.nb_free, num);
107 uint32_t num; local
109 num = (ctx->prm.max_stream_sbufs + obj_num - 1) / obj_num;
110 num = num + num / 2;
111 num = RTE_MAX(num, RTE_DIM(ctx->dev) + 1);
112 return num;
[all...]
H A Dtcp_ofo.h59 _ofo_remove(struct ofo *ofo, uint32_t pos, uint32_t num) argument
63 n = ofo->nb_elem - num - pos;
65 _ofodb_move(&ofo->db[pos + i], &ofo->db[pos + num + i]);
66 ofo->nb_elem -= num;
82 struct rte_mbuf* mb[], uint32_t num, bool is_compact) {
100 n = RTE_MIN(db->nb_max - k, num);
117 struct rte_mbuf *mb[], uint32_t num)
138 i = _ofo_insert_mbuf(ofo, pos, sl, mb, num, false);
144 struct rte_mbuf *mb[], uint32_t num, bool is_compact)
156 for (i = 0, n = skip; i != num
81 _ofo_insert_mbuf(struct ofo* ofo, uint32_t pos, union seqlen* sl, struct rte_mbuf* mb[], uint32_t num, bool is_compact) argument
116 _ofo_insert_new(struct ofo *ofo, uint32_t pos, union seqlen *sl, struct rte_mbuf *mb[], uint32_t num) argument
143 _ofo_insert_right(struct ofo *ofo, uint32_t pos, union seqlen *sl, struct rte_mbuf *mb[], uint32_t num, bool is_compact) argument
176 _ofo_step(struct ofo *ofo, union seqlen *sl, struct rte_mbuf *mb[], uint32_t num) argument
260 uint32_t i, n, num, begin, end; local
[all...]
H A Dudp_rxtx.c93 int32_t rc[], uint32_t num)
97 r = _rte_ring_enqueue_burst(s->rx.q, mb, num);
103 for (i = r, k = 0; i != num; i++, k++) {
114 struct rte_mbuf *rp[], int32_t rc[], uint16_t num)
117 void *mb[num];
122 for (i = 0; i != num; i++) {
142 struct rte_mbuf *rp[], int32_t rc[], uint16_t num)
145 void *mb[num];
150 for (i = 0; i != num; i++) {
169 struct rte_mbuf *rp[], int32_t rc[], uint16_t num)
92 rx_stream(struct tle_udp_stream *s, void *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
112 rx_stream6(struct tle_udp_stream *s, struct rte_mbuf *pkt[], union ipv6_addrs *addr[], union l4_ports port[], struct rte_mbuf *rp[], int32_t rc[], uint16_t num) argument
140 rx_stream4(struct tle_udp_stream *s, struct rte_mbuf *pkt[], union ipv4_addrs addr[], union l4_ports port[], struct rte_mbuf *rp[], int32_t rc[], uint16_t num) argument
168 tle_udp_rx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], struct rte_mbuf *rp[], int32_t rc[], uint16_t num) argument
241 tle_udp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num) argument
273 recv_pkt_process(struct rte_mbuf *m[], uint32_t num, uint32_t type) argument
299 tle_udp_stream_recv(struct tle_stream *us, struct rte_mbuf *pkt[], uint16_t num) argument
407 fragment(struct rte_mbuf *pkt, struct rte_mbuf *frag[], uint32_t num, uint32_t type, const struct tle_dest *dst) argument
502 tle_udp_stream_send(struct tle_stream *us, struct rte_mbuf *pkt[], uint16_t num, const struct sockaddr *dst_addr) argument
[all...]
H A Dtle_event.h220 tle_evq_idle(struct tle_evq *evq, struct tle_event *ev[], uint32_t num) argument
227 for (i = 0; i != num; i++) {
241 * return up to *num* user data pointers associated with
248 * It must be large enough to store up to *num* pointers in it.
249 * @param num
255 tle_evq_get(struct tle_evq *evq, const void *evd[], uint32_t num) argument
266 n = RTE_MIN(num, evq->nb_armed);
H A Dtcp_tx_seg.h24 tcp_segmentation(struct rte_mbuf *mbin, struct rte_mbuf *mbout[], uint16_t num, argument
37 if (mss * num < (uint16_t)mbin->pkt_len)
H A Dtcp_rxtx.c108 pkt_info_bulk_eq(const union pkt_info pi[], uint32_t num) argument
115 while (i != num && xmm_cmp(&pi[0].raw, &pi[i].raw) == 0)
119 while (i != num &&
130 pkt_info_bulk_syneq(const union pkt_info pi[], uint32_t num) argument
137 while (i != num && pi[0].tf.raw == pi[i].tf.raw &&
143 while (i != num && pi[0].tf.raw == pi[i].tf.raw &&
168 get_ip_pid(struct tle_dev *dev, uint32_t num, uint32_t type, uint32_t st) argument
176 pid = rte_atomic32_add_return(pa, num);
177 return pid - num;
180 rte_atomic32_set(pa, pid + num);
331 tx_data_pkts(struct tle_tcp_stream *s, struct rte_mbuf *const m[], uint32_t num) argument
366 tx_data_bulk(struct tle_tcp_stream *s, union seqlen *sl, struct rte_mbuf *mi[], uint32_t num) argument
438 uint32_t n, num, tn, wnd; local
476 uint32_t i, num, plen; local
1286 rx_data_ack(struct tle_tcp_stream *s, struct dack_info *tack, const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1617 rx_stream(struct tle_tcp_stream *s, uint32_t ts, const union pkt_info *pi, const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1742 rx_new_stream(struct tle_tcp_stream *s, uint32_t ts, const union pkt_info *pi, const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1763 rx_postsyn(struct tle_dev *dev, struct stbl *st, uint32_t type, uint32_t ts, const union pkt_info pi[], union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1844 rx_syn(struct tle_dev *dev, uint32_t type, uint32_t ts, const union pkt_info pi[], const union seg_info si[], struct rte_mbuf *mb[], struct rte_mbuf *rp[], int32_t rc[], uint32_t num) argument
1884 tle_tcp_rx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], struct rte_mbuf *rp[], int32_t rc[], uint16_t num) argument
1953 tle_tcp_stream_accept(struct tle_stream *ts, struct tle_stream *rs[], uint32_t num) argument
1982 tle_tcp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num) argument
2169 tle_tcp_stream_recv(struct tle_stream *ts, struct rte_mbuf *pkt[], uint16_t num) argument
2255 tx_segments(struct tle_tcp_stream *s, uint64_t ol_flags, struct rte_mbuf *segs[], uint32_t num) argument
2282 tle_tcp_stream_send(struct tle_stream *ts, struct rte_mbuf *pkt[], uint16_t num) argument
2387 uint32_t j, k, n, num, slen, state; local
2602 tle_tcp_process(struct tle_ctx *ctx, uint32_t num) argument
[all...]
/tldk/test/dring/
H A Dtest_dring.c75 init_drb_ring(uint32_t num) argument
84 n = rte_align32pow2(num);
90 __func__, __LINE__, num, sz);
99 for (i = 0; i != num; i += k) {
101 k = RTE_MIN(k, num - i);
107 __func__, __LINE__, num, i, sz);
117 __func__, num, tsz, rte_ring_count(r));
127 test_fill_obj(uintptr_t obj[], uint32_t num) argument
131 for (i = 0; i != num - 1; i++)
138 test_check_obj(uintptr_t obj[], uint32_t num) argument
168 test_dring_dequeue(struct tle_dring *dr, struct rte_ring *r, uint32_t num, int32_t type) argument
217 test_dring_enqueue(struct tle_dring *dr, struct rte_ring *r, uint32_t num, int32_t type) argument
[all...]
/tldk/test/gtest/
H A Dtest_tle_dring.h81 test_fill_obj(uintptr_t obj[], uint32_t num) argument
85 for (i = 0; i != num - 1; i++)
92 test_check_obj(uintptr_t obj[], uint32_t num) argument
105 for (i = 1; i != num; i++) {
118 return num;
138 init_drb_ring(uint32_t num) argument
147 n = rte_align32pow2(num);
153 __func__, __LINE__, num, sz);
162 for (i = 0; i != num; i += k) {
164 k = RTE_MIN(k, num
185 test_dring_enqueue(struct tle_dring *dr, struct rte_ring *r, uint32_t num, int32_t type) argument
253 test_dring_dequeue(struct tle_dring *dr, struct rte_ring *r, uint32_t num, int32_t type) argument
[all...]
/tldk/lib/libtle_dring/
H A Dtle_dring.h97 __tle_dring_copy_objs(const void *dst[], const void * const src[], uint32_t num) argument
101 for (i = 0; i != RTE_ALIGN_FLOOR(num, 4); i += 4) {
107 switch (num % 4) {
373 uint32_t head, next, num, tail; local
380 num = RTE_MIN(tail - head, nb_obj);
383 if (num == 0) {
388 next = head + num;
402 *nb_drb = __tle_dring_dequeue(dr, head, objs, num, drbs, *nb_drb);
408 return num;
438 uint32_t head, next, num, tai local
526 tle_drb_calc_size(uint32_t num) argument
[all...]
/tldk/lib/libtle_timer/
H A Dtimer.c61 uint32_t num; member in struct:tle_timer_list
87 uint32_t num)
92 n = RTE_MIN(list->num, num);
100 list->num -= n;
112 list->num--;
118 uint32_t num)
122 for (i = 0; i != num; i++) {
126 list->num += num;
86 get_timers(struct tle_timer_list *list, struct tle_timer_elmt *re[], uint32_t num) argument
117 put_timers(struct tle_timer_list *list, struct tle_timer_elmt *te[], uint32_t num) argument
351 tle_timer_get_expired_bulk(struct tle_timer_wheel *tw, void *rt[], uint32_t num) argument
[all...]
H A Dtle_timer.h88 uint32_t num);
/tldk/lib/libtle_misc/
H A Dtle_dpdk_wrapper.h96 _rte_ring_dequeue_ptrs(struct rte_ring *r, void **obj_table, uint32_t num) argument
103 DEQUEUE_PTRS(r, data, tail, obj_table, num, void *);
166 _rte_ring_dequeue_ptrs(struct rte_ring *r, void **obj_table, uint32_t num) argument
171 n = num;
187 _rte_ring_mcs_dequeue_start(struct rte_ring *r, uint32_t num) argument
204 n = RTE_MIN(num, n);
215 _rte_ring_mcs_dequeue_finish(struct rte_ring *r, uint32_t num) argument
223 RTE_ASSERT(n >= num);
225 head = tail + num;
237 _rte_ring_mcs_dequeue_burst(struct rte_ring *r, void **obj_table, uint32_t num) argument
[all...]
/tldk/examples/l4fwd/
H A Dcommon.h87 uint32_t num)
92 n = RTE_MIN(list->num, num);
105 list->num -= n;
116 if (list->num == 0)
126 struct netfe_stream *fs[], uint32_t num)
130 n = RTE_MIN(fe->snum - list->num, num);
131 if (n != num)
133 num
86 netfe_get_streams(struct netfe_stream_list *list, struct netfe_stream *rs[], uint32_t num) argument
125 netfe_put_streams(struct netfe_lcore *fe, struct netfe_stream_list *list, struct netfe_stream *fs[], uint32_t num) argument
502 uint32_t i, n, num; local
[all...]
H A Dnetbe.h102 uint32_t num; member in struct:pkt_buf
227 uint32_t num; member in struct:netfe_stream_list
336 struct rte_mbuf *rp[], int32_t rc[], uint16_t num);
339 (struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num);
342 (struct tle_stream *ts, struct rte_mbuf *pkt[], uint16_t num);
/tldk/app/nginx/src/tldk/
H A Dtldk_sock.h64 uint32_t num; member in struct:tldk_sock::__anon490
70 uint32_t num; member in struct:tldk_sock_list
/tldk/test/memtank/
H A Dtest_memtank.c414 check_fill_objs(void *obj[], uint32_t sz, uint32_t num, argument
424 for (i = 0; i != num; i++) {
429 __func__, sz, num, check, fill, i, obj[i]);
473 uint32_t lc, n, num; local
482 for (n = rte_ring_count(ring); rc == 0 && n != 0; n -= num) {
484 num = rte_rand() % RTE_DIM(obj);
485 num = RTE_MIN(num, n);
487 if (num != 0) {
489 rte_ring_dequeue_bulk(ring, obj, num, NUL
509 uint32_t ft, lc, n, num; local
[all...]
/tldk/app/nginx/src/core/
H A Dngx_conf_file.h252 if (conf.num == 0) { \
253 if (prev.num) { \
254 conf.num = prev.num; \
257 conf.num = default_num; \

Completed in 19 milliseconds

123