Searched refs:dev (Results 1 - 24 of 24) sorted by relevance

/tldk/test/gtest/
H A Dtest_tle_udp_dev.cpp20 dev = tle_add_dev(NULL, &dev_prm);
21 EXPECT_EQ(dev, (void *) NULL);
27 dev = tle_add_dev(ctx, NULL);
28 EXPECT_EQ(dev, (void *) NULL);
36 dev = tle_add_dev(ctx, &dev_prm);
37 EXPECT_EQ(dev, (void *) NULL);
45 dev = tle_add_dev(ctx, &dev_prm);
46 EXPECT_EQ(dev, (void *) NULL);
53 dev = tle_add_dev(ctx, &dev_prm);
54 ASSERT_NE(dev, (voi
[all...]
H A Dtest_tle_udp_stream.h72 dev = nullptr;
85 dev = setup_dev(ctx, &dev_prm);
86 ASSERT_NE(dev, nullptr);
111 tle_del_dev(dev);
118 struct tle_dev *dev; member in class:test_tle_udp_stream
160 struct tle_dev *dev; local
162 dev = tle_add_dev(ctx, dev_prm);
164 return dev;
208 dev = setup_dev(ctx, &dev_prm);
209 ASSERT_NE(dev, (voi
[all...]
H A Dtest_tle_tcp_stream.h105 struct tle_dev *dev; local
107 dev = tle_add_dev(ctx, dev_prm);
109 return dev;
207 dev = setup_dev(ctx, &dev_prm);
208 ASSERT_NE(dev, (void *) NULL);
214 tle_del_dev(dev);
220 struct tle_dev *dev; member in class:test_tle_tcp_stream
H A Dtest_tle_udp_stream_gen.h79 res->dev = it->second;
116 res->dev = it->second;
225 /* Usual tldk stuff below -> ctx, dev, events etc. */
233 dev = setup_dev(ctx, d.rx_offload, d.tx_offload,
235 ASSERT_NE(dev, nullptr);
243 d.ptr = dev;
259 /* Find which dev has the same address as streams
304 struct tle_dev *dev; member in class:test_tle_udp_gen_base
398 struct tle_dev *dev; local
409 dev
[all...]
H A Dtest_tle_udp_dev.h35 struct tle_dev *dev; member in class:udp_dev
/tldk/lib/libtle_l4p/
H A Dctx.c138 for (i = 0; i != RTE_DIM(ctx->dev); i++)
139 tle_del_dev(ctx->dev + i);
161 init_dev_proto(struct tle_dev *dev, uint32_t idx, int32_t socket_id, argument
166 sz = sizeof(*dev->dp[idx]);
167 dev->dp[idx] = rte_zmalloc_socket(NULL, sz, RTE_CACHE_LINE_SIZE,
170 if (dev->dp[idx] == NULL) {
177 tle_pbm_init(&dev->dp[idx]->use, LPORT_START_BLK);
178 fill_pbm(&dev->dp[idx]->use, blp);
187 if (ctx->nb_dev < RTE_DIM(ctx->dev)) {
188 for (i = 0; i != RTE_DIM(ctx->dev);
203 struct tle_dev *dev; local
290 tle_del_dev(struct tle_dev *dev) argument
349 struct tle_dev *dev; local
424 struct tle_dev *dev; local
[all...]
H A Dstream.h111 num = RTE_MAX(num, RTE_DIM(ctx->dev) + 1);
130 struct tle_dev *dev; local
147 if (rc < 0 || dst->dev == NULL || dst->dev->ctx != ctx)
150 dev = dst->dev;
151 dst->ol_flags = dev->tx.ol_flags[s->type];
156 l3h->src_addr = dev->prm.local_addr4.s_addr;
161 rte_memcpy(l3h->src_addr, &dev->prm.local_addr6,
166 return dev
[all...]
H A Dtle_udp.h91 * @param dev
108 uint16_t tle_udp_rx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[],
119 * @param dev
129 uint16_t tle_udp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[],
159 * The main purpose of that function is to determine over which UDP dev
H A Dtle_tcp.h296 * It is responsibility of that function is to determine over which TCP dev
365 * @param dev
382 uint16_t tle_tcp_rx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[],
393 * @param dev
403 uint16_t tle_tcp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[],
H A Dtle_ctx.h31 * It owns set of <stream>s and <dev>s entities and provides
33 * <dev> is an abstraction for the underlying device, that is able
35 * It is a user responsibility to add to the <ctx> all <dev>s,
38 * Right now adding/deleting <dev>s to the context with open
83 struct tle_dev *dev; /**< device to send packets through. */ member in struct:tle_dest
200 * @param dev
206 int tle_del_dev(struct tle_dev *dev);
H A Dctx.h64 struct tle_dev dev[RTE_MAX_ETHPORTS]; member in struct:tle_ctx
H A Dudp_rxtx.c27 rx_stream_obtain(struct tle_dev *dev, uint32_t type, uint32_t port) argument
31 if (type >= TLE_VNUM || dev->dp[type] == NULL)
34 s = (struct tle_udp_stream *)dev->dp[type]->streams[port];
168 tle_udp_rx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], argument
188 s = rx_stream_obtain(dev, t, p);
241 tle_udp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num) argument
250 n = tle_dring_sc_dequeue(&dev->tx.dr, (const void **)(uintptr_t)pkt,
458 queue_pkt_out(struct tle_udp_stream *s, struct tle_dev *dev, argument
490 n = tle_dring_mp_enqueue(&dev->tx.dr, pkt, nb_pkt, drbs, &nb);
553 pid = rte_atomic32_add_return(&dst.dev
[all...]
H A Dtcp_rxtx.c56 rx_obtain_listen_stream(const struct tle_dev *dev, const union pkt_info *pi, argument
61 s = (struct tle_tcp_stream *)dev->dp[type]->streams[pi->port.dst];
75 rx_obtain_stream(const struct tle_dev *dev, struct stbl *st, argument
83 return rx_obtain_listen_stream(dev, pi, type);
168 get_ip_pid(struct tle_dev *dev, uint32_t num, uint32_t type, uint32_t st) argument
173 pa = &dev->tx.packet_id[type];
334 struct tle_dev *dev; local
351 dev = s->tx.dst.dev;
355 i = tle_dring_mp_enqueue(&dev
370 struct tle_dev *dev; local
547 send_pkt(struct tle_tcp_stream *s, struct tle_dev *dev, struct rte_mbuf *m) argument
635 struct tle_dev *dev; local
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
1982 tle_tcp_tx_bulk(struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num) argument
[all...]
/tldk/examples/l4fwd/test/
H A Dconfig.sh83 LINUX_MAC=$(ssh ${REMOTE_HOST} ip addr show dev ${IFACE})
165 netem="tc qdisc add dev ${IFACE} root netem limit 100000"
322 ip link show dev ${L4FWD_WAIT_VDEV} > /dev/null 2>&1
345 use_ssh tc qdisc del dev ${IFACE} root
384 if_verbose use_ssh tc qdisc show dev ${IFACE}
397 ssh ${REMOTE_HOST} ip addr flush dev ${IFACE}
399 dev ${IFACE}
401 ssh ${REMOTE_HOST} ip neigh flush dev ${IFACE}
403 ip addr add ${LINUX_IPV4}/${MASK_IPV4} dev
[all...]
H A Dnctxrx.sh367 use_ssh dd if=/dev/urandom of=${x} bs=1M \
/tldk/app/nginx/src/tldk/
H A Dbe.c306 port_id = ctx->dev[i].port;
307 queue_id = ctx->dev[i].queue;
380 RTE_LOG(NOTICE, USER1, "%s(lcore=%u,dev_id=%u,dev=%p,"
384 __func__, tcx->cf->lcore, dcf->dev, tcx->dst4[idx].dev,
408 RTE_LOG(NOTICE, USER1, "%s(lcore=%u,dev_id=%u,dev=%p,"
412 __func__, tcx->cf->lcore, dcf->dev, tcx->dst6[idx].dev,
431 dst->dev = td->dev;
1068 be_rx(struct tldk_dev *dev) argument
1101 be_tx(struct tldk_dev *dev) argument
[all...]
H A Dngx_tldk.h71 uint32_t dev; member in struct:tldk_dest_conf
99 struct tldk_dev_conf dev[RTE_MAX_ETHPORTS]; member in struct:tldk_ctx_conf
124 struct tle_dev *dev; member in struct:tldk_dev
149 struct tldk_dev dev[RTE_MAX_ETHPORTS]; member in struct:tldk_ctx
H A Dparse.c202 tldk_dev_parse(ngx_conf_t *cf, struct tldk_dev_conf *dev, argument
210 .name = "dev",
248 memset(dev, 0, sizeof(*dev));
250 dev->id = pvl[0].u64;
251 dev->port = pvl[1].u64;
252 dev->queue = pvl[2].u64;
265 .name = "dev",
314 dst->dev = pvl[0].u64;
450 } else if (ngx_strcmp(v[0].data, "dev")
[all...]
H A Dmodule.c198 port_id = ctx->dev[j].port;
199 queue_id = ctx->dev[j].queue;
/tldk/app/nginx/conf/
H A Dnginx-tldk.conf68 dev 0 port 0 queue 0;
69 dest dev 0 addr 192.168.1.0 masklen 24 mac 3C:FD:FE:9F:D1:E1;
81 dev 0 port 0 queue 1;
82 dest dev 0 addr 192.168.1.0 masklen 24 mac 3C:FD:FE:9F:D1:E1;
/tldk/app/nginx/auto/
H A Dconfigure30 NGX_SYSTEM=`uname -s 2>/dev/null`
31 NGX_RELEASE=`uname -r 2>/dev/null`
32 NGX_MACHINE=`uname -m 2>/dev/null`
/tldk/examples/l4fwd/
H A Dcommon.h243 "%s:%u(port=%u, q=%u, proto=%s, dev=%p)\n",
245 proto_name[lc->proto], lc->prtq[i].dev);
271 RTE_LOG(NOTICE, USER1, "%s:%u(port=%u, q=%u, lcore=%u, dev=%p) "
278 lc->prtq[i].dev,
315 RTE_LOG(NOTICE, USER1, "%s(lcore=%u,port=%u,dev=%p,"
319 __func__, lc->id, dst->port, lc->dst4[idx].dev,
342 RTE_LOG(NOTICE, USER1, "%s(lcore=%u,port=%u,dev=%p,"
346 __func__, lc->id, dst->port, lc->dst6[idx].dev,
364 dst->dev = bed->dev;
442 fill_arp_reply(struct netbe_dev *dev, struct rte_mbuf *m) argument
500 send_arp_reply(struct netbe_dev *dev, struct pkt_buf *pb) argument
[all...]
H A Dnetbe.h110 struct tle_dev *dev; member in struct:netbe_dev
335 (struct tle_dev *dev, struct rte_mbuf *pkt[],
339 (struct tle_dev *dev, struct rte_mbuf *pkt[], uint16_t num);
H A Dlcore.h313 lc->prtq[prtqid].dev = tle_add_dev(lc->ctx, &dprm);
316 "%s(lcore=%u, port=%u, qid=%u), dev: %p\n",
318 lc->prtq[prtqid].rxqid, lc->prtq[prtqid].dev);
320 if (lc->prtq[prtqid].dev == NULL)

Completed in 26 milliseconds