Searched refs:lc (Results 1 - 19 of 19) sorted by relevance

/tldk/examples/l4fwd/
H A Dlcore.h32 struct netbe_lcore *lc; local
35 lc = data;
37 rc = rte_lpm_lookup(lc->lpm4, rte_be_to_cpu_32(addr->s_addr), &idx);
39 dst = &lc->dst4[idx];
55 struct netbe_lcore *lc; local
59 lc = data;
62 rc = rte_lpm6_lookup(lc->lpm6, (uint8_t *)p, &idx);
64 dst = &lc->dst6[idx];
72 lcore_lpm_init(struct netbe_lcore *lc) argument
85 sid = rte_lcore_to_socket_id(lc
241 create_context(struct netbe_lcore *lc, const struct tle_ctx_param *ctx_prm) argument
293 lcore_init(struct netbe_lcore *lc, const struct tle_ctx_param *ctx_prm, const uint32_t prtqid, const uint16_t *bl_ports, uint32_t nb_bl_ports) argument
363 struct netbe_lcore *lc; local
450 uint32_t i, j, lc, ln; local
[all...]
H A Dcommon.h222 netbe_lcore_setup(struct netbe_lcore *lc) argument
228 __func__, lc->id, proto_name[lc->proto], lc->ctx);
241 for (i = 0; i != lc->prtq_num && rc == 0; i++) {
244 __func__, i, lc->prtq[i].port.id, lc->prtq[i].rxqid,
245 proto_name[lc->proto], lc->prtq[i].dev);
247 rc = setup_rx_cb(&lc
262 struct netbe_lcore *lc; local
303 netbe_add_ipv4_route(struct netbe_lcore *lc, const struct netbe_dest *dst, uint8_t idx) argument
329 netbe_add_ipv6_route(struct netbe_lcore *lc, const struct netbe_dest *dst, uint8_t idx) argument
392 netbe_add_dest(struct netbe_lcore *lc, uint32_t dev_idx, uint16_t family, const struct netbe_dest *dst, uint32_t dnum) argument
523 netbe_rx(struct netbe_lcore *lc, uint32_t pidx) argument
565 netbe_tx(struct netbe_lcore *lc, uint32_t pidx) argument
610 struct netbe_lcore *lc; local
[all...]
H A Dport.h254 check_lcore(uint32_t lc) argument
256 if (rte_lcore_is_enabled(lc) == 0) {
257 RTE_LOG(ERR, USER1, "lcore %u is not enabled\n", lc);
260 if (rte_eal_get_lcore_state(lc) == RUNNING) {
262 lc, lcore_config[lc].f);
381 struct netbe_lcore *lc; local
431 lc = find_initilized_lcore(cfg, prt->lcore_id[j]);
432 if (lc == NULL) {
433 lc
[all...]
H A Dpkt.c97 tcp_stat_update(struct netbe_lcore *lc, const struct rte_mbuf *m, argument
103 lc->tcp_stat.flags[th->tcp_flags]++;
234 handle_arp(struct rte_mbuf *m, struct netbe_lcore *lc, dpdk_port_t port, argument
251 abuf = &lc->prtq[port].arp_buf;
261 fill_eth_tcp_arp_hdr_len(struct rte_mbuf *m, struct netbe_lcore *lc, argument
285 return handle_arp(m, lc, port, l2_len);
434 reassemble(struct rte_mbuf *m, struct netbe_lcore *lc, uint64_t tms, argument
441 tbl = lc->ftbl;
442 dr = &lc->death_row;
443 l3cs = lc
536 struct netbe_lcore *lc; local
605 struct netbe_lcore *lc; local
691 struct netbe_lcore *lc; local
746 struct netbe_lcore *lc; local
815 struct netbe_lcore *lc; local
842 struct netbe_lcore *lc; local
864 struct netbe_lcore *lc; local
944 setup_rx_cb(const struct netbe_port *uprt, struct netbe_lcore *lc, uint16_t qid, uint32_t arp) argument
[all...]
H A Dmain.c124 struct netbe_lcore *lc; local
139 lc = cfg->cpu + k;
140 for (l = 0; l != lc->prtq_num; l++)
141 if (lc->prtq[l].port.id == p) {
142 rc = netbe_add_dest(lc, l, f,
146 "%s(lc=%u, family=%u) "
149 __func__, lc->id, f, i);
267 prm[becfg.cpu[i].id].be.lc = becfg.cpu + i;
275 if (prm[i].be.lc != NULL || prm[i].fe.max_streams != 0)
281 if (prm[i].be.lc !
[all...]
H A Dtcp.h107 "code=%u, bidx=%u, lc=%u\n",
241 NETFE_TRACE("%s(lc=%u, fes=%p): tle_tcp_stream_connect() "
252 RTE_LOG(ERR, USER1, "%s(lc=%u fes=%p) failed to open "
341 "%s(lc=%u): not enough FE resources to handle %u new "
676 struct netbe_lcore *lc; local
678 lc = RTE_PER_LCORE(_be);
679 if (lc == NULL)
682 for (i = 0; i != lc->prtq_num; i++) {
683 netbe_rx(lc, i);
684 tle_tcp_process(lc
[all...]
H A Dnetbe.h250 struct netbe_lcore *lc; member in struct:lcore_prm::__anon9
321 int setup_rx_cb(const struct netbe_port *uprt, struct netbe_lcore *lc,
H A Dudp.h80 "code=%u, bidx=%u, lc=%u\n",
568 if (rc == 0 && prm->be.lc != NULL)
569 rc = netbe_lcore_setup(prm->be.lc);
/tldk/test/dring/
H A Dtest_dring.c171 uint32_t i, k, lc, n, t; local
175 lc = rte_lcore_id();
194 __func__, __LINE__, dr, num, lc, n, t,
205 __func__, __LINE__, dr, num, lc, drb[i],
220 uint32_t i, j, k, lc, nb; local
224 lc = rte_lcore_id();
236 __func__, __LINE__, dr, num, lc, drb[j],
242 drb[j]->udata = (void *)(uintptr_t)(lc + 1);
270 if ((uintptr_t)drb[i]->udata != lc + 1) {
273 __func__, __LINE__, dr, num, lc, dr
288 uint32_t i, lc, n; local
394 uint32_t lc; local
[all...]
/tldk/test/gtest/
H A Dtest_tle_dring.h188 uint32_t i, j, k, lc, nb; local
192 lc = rte_lcore_id();
204 __func__, __LINE__, dr, num, lc, drb[j],
210 drb[j]->udata = (void *)(uintptr_t)(lc + 1);
238 if ((uintptr_t)drb[i]->udata != lc + 1) {
241 __func__, __LINE__, dr, num, lc, drb[i],
256 uint32_t i, k, lc, n, t; local
260 lc = rte_lcore_id();
279 __func__, __LINE__, dr, num, lc, n, t,
290 __func__, __LINE__, dr, num, lc, dr
305 uint32_t i, lc, n; local
373 uint32_t lc; local
[all...]
/tldk/test/memtank/
H A Dtest_memtank.c313 memtank_stat_dump(FILE *f, uint32_t lc, const struct memtank_stat *ms) argument
320 if (lc == UINT32_MAX)
323 fprintf(f, "%s(lc=%u)={\n", __func__, lc);
441 create_worker_ring(struct worker_args *wa, uint32_t lc) argument
451 __func__, lc, sz, wa->max_obj);
458 __func__, lc, ring, wa->max_obj,
473 uint32_t lc, n, num; local
479 lc = rte_lcore_id();
493 lc,
509 uint32_t ft, lc, n, num; local
674 fill_worker_args(struct worker_args *wa, uint32_t alloc_flags, uint32_t free_flags, uint32_t lc) argument
702 uint32_t lc; local
737 uint32_t lc; local
[all...]
/tldk/app/nginx/src/tldk/
H A Dbe.h45 int be_check_lcore(uint32_t lc);
H A Dmodule.c85 uint32_t lc, rc, sid; local
88 lc = cf->lcore;
89 sid = rte_lcore_to_socket_id(lc);
115 __func__, lc, cf->worker, tcx->ctx);
224 uint32_t i, j, wrk, num, lc, ctx_lim; local
305 lc = cf->ctx[i].lcore;
306 num = lc_ctxs[lc].nb_ctxs;
307 ctx_lim = RTE_DIM(lc_ctxs[lc].ctxs);
310 lc_ctxs[lc].ctxs[num] = tcx;
311 lc_ctxs[lc]
[all...]
H A Dtldk_sock.c195 uint32_t i, lc, sid, sn; local
200 lc = tc->cf->lcore;
202 sid = rte_lcore_to_socket_id(lc);
225 __func__, lc, ngx_worker,
237 rte_lcore_to_socket_id(lc));
242 __func__, lc, ngx_worker, sz);
H A Dbe.c698 tcp_stat_update(struct tldk_ctx *lc, const struct rte_mbuf *m, argument
704 lc->tcp_stat.flags[th->tcp_flags]++;
/tldk/app/nginx/src/http/modules/
H A Dngx_http_limit_conn_module.c151 ngx_http_limit_conn_node_t *lc; local
206 lc = (ngx_http_limit_conn_node_t *) &node->color;
209 lc->len = (u_char) key.len;
210 lc->conn = 1;
211 ngx_memcpy(lc->data, key.data, key.len);
217 lc = (ngx_http_limit_conn_node_t *) &node->color;
219 if ((ngx_uint_t) lc->conn >= limits[i].conn) {
231 lc->conn++;
235 "limit conn: %08Xi %d", node->key, lc->conn);
344 ngx_http_limit_conn_node_t *lc; local
[all...]
/tldk/app/nginx/src/stream/
H A Dngx_stream_limit_conn_module.c135 ngx_stream_limit_conn_node_t *lc; local
184 lc = (ngx_stream_limit_conn_node_t *) &node->color;
187 lc->len = (u_char) key.len;
188 lc->conn = 1;
189 ngx_memcpy(lc->data, key.data, key.len);
195 lc = (ngx_stream_limit_conn_node_t *) &node->color;
197 if ((ngx_uint_t) lc->conn >= limits[i].conn) {
209 lc->conn++;
213 "limit conn: %08Xi %d", node->key, lc->conn);
323 ngx_stream_limit_conn_node_t *lc; local
[all...]
/tldk/app/nginx/src/event/
H A Dngx_event_accept.c33 ngx_connection_t *c, *lc; local
53 lc = ev->data;
54 ls = lc->listening;
65 s = accept4(lc->fd, &sa.sockaddr, &socklen, SOCK_NONBLOCK);
67 s = accept(lc->fd, &sa.sockaddr, &socklen);
70 s = accept(lc->fd, &sa.sockaddr, &socklen);
333 ngx_connection_t *c, *lc; local
364 lc = ev->data;
365 ls = lc->listening;
403 n = recvmsg(lc
[all...]
/tldk/app/nginx/contrib/vim/syntax/
H A Dnginx.vim16 syn region ngxString start=+[^:a-zA-Z>!\\@]\z(["']\)+lc=1 end=+\z1+ skip=+\\\\\|\\\z1+ contains=ngxVariableString

Completed in 17 milliseconds