| /dpdk/examples/ip_pipeline/ |
| H A D | conn.c | 22 struct conn { struct 41 struct conn *conn; in conn_init() local 62 conn = calloc(1, sizeof(struct conn)); in conn_init() 132 conn_free(struct conn *conn) in conn_free() argument 151 conn_poll_for_conn(struct conn *conn) in conn_poll_for_conn() argument 209 data_event_handle(struct conn *conn, in data_event_handle() argument 233 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle() 236 conn->msg_handle(conn->msg_in, in data_event_handle() 251 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle() 275 control_event_handle(struct conn *conn, in control_event_handle() argument [all …]
|
| H A D | main.c | 37 struct conn_params conn; member 40 .conn = { 95 app.conn.addr = strdup(optarg); in parse_args() 96 if (app.conn.addr == NULL) { in parse_args() 149 struct conn *conn; in main() local 165 conn = conn_init(&app.conn); in main() 166 if (conn == NULL) { in main() 258 app.conn.msg_in_len_max, in main() 259 app.conn.msg_out_len_max); in main() 263 conn_poll_for_conn(conn); in main() [all …]
|
| H A D | conn.h | 10 struct conn; 35 struct conn * 39 conn_free(struct conn *conn); 42 conn_poll_for_conn(struct conn *conn); 45 conn_poll_for_msg(struct conn *conn);
|
| H A D | meson.build | 19 'conn.c',
|
| H A D | Makefile | 10 SRCS-y += conn.c
|
| /dpdk/examples/pipeline/ |
| H A D | conn.c | 22 struct conn { struct 42 struct conn *conn; in conn_init() local 63 conn = calloc(1, sizeof(struct conn)); in conn_init() 134 conn_free(struct conn *conn) in conn_free() argument 153 conn_poll_for_conn(struct conn *conn) in conn_poll_for_conn() argument 211 data_event_handle(struct conn *conn, in data_event_handle() argument 235 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle() 238 conn->msg_handle(conn->msg_in, in data_event_handle() 254 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle() 278 control_event_handle(struct conn *conn, in control_event_handle() argument [all …]
|
| H A D | main.c | 23 struct conn_params conn; member 26 .conn = { 83 if (app.conn.addr == NULL) { in parse_args() 136 struct conn *conn; in main() local 174 app.conn.msg_in_len_max, in main() 175 app.conn.msg_out_len_max, in main() 179 app.conn.msg_handle_arg = obj; in main() 180 conn = conn_init(&app.conn); in main() 181 if (!conn) { in main() 189 conn_poll_for_conn(conn); in main() [all …]
|
| H A D | conn.h | 10 struct conn; 38 struct conn * 42 conn_free(struct conn *conn); 45 conn_poll_for_conn(struct conn *conn); 48 conn_poll_for_msg(struct conn *conn);
|
| H A D | meson.build | 18 'conn.c',
|
| H A D | Makefile | 9 SRCS-y += conn.c
|
| /dpdk/drivers/net/softnic/ |
| H A D | conn.c | 64 if (conn == NULL) in softnic_conn_init() 130 return conn; in softnic_conn_init() 150 free(conn); in softnic_conn_free() 193 conn->welcome, in softnic_conn_poll_for_conn() 201 conn->prompt, in softnic_conn_poll_for_conn() 220 conn->buf, in data_event_handle() 236 conn->msg_in[conn->msg_in_len] = 0; in data_event_handle() 239 conn->msg_handle(conn->msg_in, in data_event_handle() 254 } else if (conn->msg_in_len < conn->msg_in_len_max) { in data_event_handle() 255 conn->msg_in[conn->msg_in_len] = conn->buf[i]; in data_event_handle() [all …]
|
| H A D | conn.h | 41 softnic_conn_free(struct softnic_conn *conn); 44 softnic_conn_poll_for_conn(struct softnic_conn *conn); 47 softnic_conn_poll_for_msg(struct softnic_conn *conn);
|
| H A D | rte_eth_softnic.c | 214 softnic_conn_free(p->conn); in pmd_free() 354 p->conn = softnic_conn_init(&conn_params); in pmd_init() 355 if (p->conn == NULL) { in pmd_init() 727 softnic_conn_poll_for_conn(softnic->conn); in rte_pmd_softnic_manage() 729 softnic_conn_poll_for_msg(softnic->conn); in rte_pmd_softnic_manage()
|
| H A D | meson.build | 10 'conn.c',
|
| H A D | rte_eth_softnic_internals.h | 629 struct softnic_conn *conn; member
|
| /dpdk/lib/vhost/ |
| H A D | socket.c | 215 conn = malloc(sizeof(*conn)); in vhost_user_add_connection() 216 if (conn == NULL) { in vhost_user_add_connection() 259 conn->connfd = fd; in vhost_user_add_connection() 260 conn->vsocket = vsocket; in vhost_user_add_connection() 261 conn->vid = vid; in vhost_user_add_connection() 263 NULL, conn); in vhost_user_add_connection() 284 free(conn); in vhost_user_add_connection() 334 free(conn); in vhost_user_read_cb() 1026 conn != NULL; in rte_vhost_driver_unregister() 1027 conn = next) { in rte_vhost_driver_unregister() [all …]
|
| /dpdk/examples/ipsec-secgw/ |
| H A D | event_helper.c | 389 conn = &(adapter->conn[conn_id]); in eh_set_default_conf_rx_adapter() 392 conn->ethdev_id = i; in eh_set_default_conf_rx_adapter() 396 conn->ethdev_rx_qid = -1; in eh_set_default_conf_rx_adapter() 490 conn = &(tx_adapter->conn[conn_id]); in eh_set_default_conf_tx_adapter() 493 conn->ethdev_id = i; in eh_set_default_conf_tx_adapter() 852 conn = &(adapter->conn[j]); in eh_rx_adapter_configure() 875 conn->ethdev_id, conn->ethdev_rx_qid, in eh_rx_adapter_configure() 1230 conn = &(adapter->conn[j]); in eh_tx_adapter_configure() 1234 conn->ethdev_id, conn->ethdev_tx_qid); in eh_tx_adapter_configure() 1394 conn = &(adapter->conn[j]); in eh_display_rx_adapter_conf() [all …]
|
| H A D | event_helper.h | 121 conn[EVENT_MODE_MAX_CONNECTIONS_PER_ADAPTER]; member 137 conn[EVENT_MODE_MAX_CONNECTIONS_PER_TX_ADAPTER]; member
|
| /dpdk/doc/guides/prog_guide/ |
| H A D | event_timer_adapter.rst | 214 rte_mempool_get(event_timer_pool, (void **)&conn->evtim); 215 if (conn->evtim == NULL) { ... } 218 conn->evtim->ev.op = RTE_EVENT_OP_NEW; 219 conn->evtim->ev.queue_id = event_queue_id; 220 conn->evtim->ev.sched_type = RTE_SCHED_TYPE_ATOMIC; 222 conn->evtim->ev.event_type = RTE_EVENT_TYPE_TIMER; 223 conn->evtim->ev.event_ptr = conn; 224 conn->evtim->state = RTE_EVENT_TIMER_NOT_ARMED; 267 rte_event_timer_cancel_burst(adapter, &conn->timer, 1); 301 conn = ev.event_ptr; [all …]
|
| /dpdk/drivers/net/netvsc/ |
| H A D | hn_nvs.c | 185 struct hn_nvs_rxbuf_conn conn; in hn_nvs_conn_rxbuf() local 195 conn.type = NVS_TYPE_RXBUF_CONN; in hn_nvs_conn_rxbuf() 196 conn.gpadl = hv->rxbuf_res->phys_addr; in hn_nvs_conn_rxbuf() 197 conn.sig = NVS_RXBUF_SIG; in hn_nvs_conn_rxbuf() 202 error = hn_nvs_execute(hv, &conn, sizeof(conn), in hn_nvs_conn_rxbuf()
|