1 /*- 2 * BSD LICENSE 3 * 4 * Copyright(c) 2010-2014 Intel Corporation. All rights reserved. 5 * All rights reserved. 6 * 7 * Redistribution and use in source and binary forms, with or without 8 * modification, are permitted provided that the following conditions 9 * are met: 10 * 11 * * Redistributions of source code must retain the above copyright 12 * notice, this list of conditions and the following disclaimer. 13 * * Redistributions in binary form must reproduce the above copyright 14 * notice, this list of conditions and the following disclaimer in 15 * the documentation and/or other materials provided with the 16 * distribution. 17 * * Neither the name of Intel Corporation nor the names of its 18 * contributors may be used to endorse or promote products derived 19 * from this software without specific prior written permission. 20 * 21 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 22 * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT 23 * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR 24 * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT 25 * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, 26 * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT 27 * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, 28 * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY 29 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 30 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 31 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 32 */ 33 34 #include <stdio.h> 35 #include <stdlib.h> 36 #include <stdint.h> 37 38 #include <rte_log.h> 39 #include <rte_port_ring.h> 40 #include <rte_table_stub.h> 41 #include <rte_pipeline.h> 42 43 #include "main.h" 44 45 void 46 app_main_loop_worker_pipeline_stub(void) { 47 struct rte_pipeline_params pipeline_params = { 48 .name = "pipeline", 49 .socket_id = rte_socket_id(), 50 }; 51 52 struct rte_pipeline *p; 53 uint32_t port_in_id[APP_MAX_PORTS]; 54 uint32_t port_out_id[APP_MAX_PORTS]; 55 uint32_t table_id[APP_MAX_PORTS]; 56 uint32_t i; 57 58 RTE_LOG(INFO, USER1, "Core %u is doing work (pipeline with stub " 59 "tables)\n", rte_lcore_id()); 60 61 /* Pipeline configuration */ 62 p = rte_pipeline_create(&pipeline_params); 63 if (p == NULL) 64 rte_panic("Unable to configure the pipeline\n"); 65 66 /* Input port configuration */ 67 for (i = 0; i < app.n_ports; i++) { 68 struct rte_port_ring_reader_params port_ring_params = { 69 .ring = app.rings_rx[i], 70 }; 71 72 struct rte_pipeline_port_in_params port_params = { 73 .ops = &rte_port_ring_reader_ops, 74 .arg_create = (void *) &port_ring_params, 75 .f_action = NULL, 76 .arg_ah = NULL, 77 .burst_size = app.burst_size_worker_read, 78 }; 79 80 if (rte_pipeline_port_in_create(p, &port_params, 81 &port_in_id[i])) 82 rte_panic("Unable to configure input port for " 83 "ring %d\n", i); 84 } 85 86 /* Output port configuration */ 87 for (i = 0; i < app.n_ports; i++) { 88 struct rte_port_ring_writer_params port_ring_params = { 89 .ring = app.rings_tx[i], 90 .tx_burst_sz = app.burst_size_worker_write, 91 }; 92 93 struct rte_pipeline_port_out_params port_params = { 94 .ops = &rte_port_ring_writer_ops, 95 .arg_create = (void *) &port_ring_params, 96 .f_action = NULL, 97 .f_action_bulk = NULL, 98 .arg_ah = NULL, 99 }; 100 101 if (rte_pipeline_port_out_create(p, &port_params, 102 &port_out_id[i])) 103 rte_panic("Unable to configure output port for " 104 "ring %d\n", i); 105 } 106 107 /* Table configuration */ 108 for (i = 0; i < app.n_ports; i++) { 109 struct rte_pipeline_table_params table_params = { 110 .ops = &rte_table_stub_ops, 111 .arg_create = NULL, 112 .f_action_hit = NULL, 113 .f_action_miss = NULL, 114 .arg_ah = NULL, 115 .action_data_size = 0, 116 }; 117 118 if (rte_pipeline_table_create(p, &table_params, &table_id[i])) 119 rte_panic("Unable to configure table %u\n", i); 120 } 121 122 /* Interconnecting ports and tables */ 123 for (i = 0; i < app.n_ports; i++) 124 if (rte_pipeline_port_in_connect_to_table(p, port_in_id[i], 125 table_id[i])) 126 rte_panic("Unable to connect input port %u to " 127 "table %u\n", port_in_id[i], table_id[i]); 128 129 /* Add entries to tables */ 130 for (i = 0; i < app.n_ports; i++) { 131 struct rte_pipeline_table_entry entry = { 132 .action = RTE_PIPELINE_ACTION_PORT, 133 {.port_id = port_out_id[i ^ 1]}, 134 }; 135 struct rte_pipeline_table_entry *default_entry_ptr; 136 137 if (rte_pipeline_table_default_entry_add(p, table_id[i], &entry, 138 &default_entry_ptr)) 139 rte_panic("Unable to add default entry to table %u\n", 140 table_id[i]); 141 } 142 143 /* Enable input ports */ 144 for (i = 0; i < app.n_ports; i++) 145 if (rte_pipeline_port_in_enable(p, port_in_id[i])) 146 rte_panic("Unable to enable input port %u\n", 147 port_in_id[i]); 148 149 /* Check pipeline consistency */ 150 if (rte_pipeline_check(p) < 0) 151 rte_panic("Pipeline consistency check failed\n"); 152 153 /* Run-time */ 154 #if APP_FLUSH == 0 155 for ( ; ; ) 156 rte_pipeline_run(p); 157 #else 158 for (i = 0; ; i++) { 159 rte_pipeline_run(p); 160 161 if ((i & APP_FLUSH) == 0) 162 rte_pipeline_flush(p); 163 } 164 #endif 165 } 166