calipso -

Age	Commit message (Expand)	Author	Files	Lines
2017-10-10	release 1.1 for euphrates	Koren Lev	1	-0/+3
2017-08-31	US2876 handle SSH errors	yayogev	1	-1/+5
2017-07-27	Calipso initial release for OPNFV	Yaron Yogev	1	-0/+324

/* // Copyright (c) 2017 Intel Corporation // // Licensed under the Apache License, Version 2.0 (the "License"); // you may not use this file except in compliance with the License. // You may obtain a copy of the License at // // http://www.apache.org/licenses/LICENSE-2.0 // // Unless required by applicable law or agreed to in writing, software // distributed under the License is distributed on an "AS IS" BASIS, // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. */ #ifndef __INCLUDE_APP_H__ #define __INCLUDE_APP_H__ #include <stdint.h> #include <string.h> #include <rte_common.h> #include <rte_mempool.h> #include <rte_ring.h> #include <rte_sched.h> #include <rte_timer.h> #include <cmdline_parse.h> #include <rte_ethdev.h> #include "cpu_core_map.h" #include "pipeline.h" #define APP_PARAM_NAME_SIZE PIPELINE_NAME_SIZE #define APP_LINK_PCI_BDF_SIZE 32 struct app_link_params *fdir_p_link; struct app_mempool_params { char *name; uint32_t parsed; uint32_t buffer_size; uint32_t pool_size; uint32_t cache_size; uint32_t cpu_socket_id; }; struct app_link_params { char *name; uint32_t parsed; uint32_t pmd_id; /* Generated based on port mask */ uint32_t arp_q; /* 0 = Disabled (packets go to default queue 0) */ uint32_t tcp_syn_q; /* 0 = Disabled (pkts go to default queue) */ uint32_t ip_local_q; /* 0 = Disabled (pkts go to default queue 0) */ uint32_t tcp_local_q; /* 0 = Disabled (pkts go to default queue 0) */ uint32_t udp_local_q; /* 0 = Disabled (pkts go to default queue 0) */ uint32_t sctp_local_q; /* 0 = Disabled (pkts go to default queue 0) */ uint32_t state; /* DOWN = 0, UP = 1 */ uint32_t ip; /* 0 = Invalid */ uint8_t ipv6[16]; uint32_t depth; /* Valid only when IP is valid */ uint32_t depth_ipv6; uint64_t mac_addr; /* Read from HW */ char pci_bdf[APP_LINK_PCI_BDF_SIZE]; struct rte_eth_conf conf; uint8_t promisc; }; struct app_pktq_hwq_in_params { char *name; uint32_t parsed; uint32_t mempool_id; /* Position in the app->mempool_params */ uint32_t size; uint32_t burst; struct rte_eth_rxconf conf; }; struct app_pktq_hwq_out_params { char *name; uint32_t parsed; uint32_t size; uint32_t burst; uint32_t dropless; uint64_t n_retries; struct rte_eth_txconf conf; }; struct app_pktq_swq_params { char *name; uint32_t parsed; uint32_t size; uint32_t burst_read; uint32_t burst_write; uint32_t dropless; uint64_t n_retries; uint32_t cpu_socket_id; uint32_t ipv4_frag; uint32_t ipv6_frag; uint32_t ipv4_ras; uint32_t ipv6_ras; uint32_t mtu; uint32_t metadata_size; uint32_t mempool_direct_id; uint32_t mempool_indirect_id; }; #ifndef APP_FILE_NAME_SIZE #define APP_FILE_NAME_SIZE 256 #endif #ifndef APP_MAX_SCHED_SUBPORTS #define APP_MAX_SCHED_SUBPORTS 8 #endif #ifndef APP_MAX_SCHED_PIPES #define APP_MAX_SCHED_PIPES 4096 #endif struct app_pktq_tm_params { char *name; uint32_t parsed; const char *file_name; struct rte_sched_port_params sched_port_params; struct rte_sched_subport_params sched_subport_params[APP_MAX_SCHED_SUBPORTS]; struct rte_sched_pipe_params sched_pipe_profiles[RTE_SCHED_PIPE_PROFILES_PER_PORT]; int sched_pipe_to_profile[APP_MAX_SCHED_SUBPORTS * APP_MAX_SCHED_PIPES]; uint32_t burst_read; uint32_t burst_write; }; struct app_pktq_source_params { char *name; uint32_t parsed; uint32_t mempool_id; /* Position in the app->mempool_params array */ uint32_t burst; char *file_name; /* Full path of PCAP file to be copied to mbufs */ uint32_t n_bytes_per_pkt; }; struct app_pktq_sink_params { char *name; uint8_t parsed; char *file_name; /* Full path of PCAP file to be copied to mbufs */ uint32_t n_pkts_to_dump; }; struct app_msgq_params { char *name; uint32_t parsed; uint32_t size; uint32_t cpu_socket_id; }; enum app_pktq_in_type { APP_PKTQ_IN_HWQ, APP_PKTQ_IN_SWQ, APP_PKTQ_IN_TM, APP_PKTQ_IN_SOURCE, }; struct app_pktq_in_params { enum app_pktq_in_type type; uint32_t id; /* Position in the appropriate app array */ }; enum app_pktq_out_type { APP_PKTQ_OUT_HWQ, APP_PKTQ_OUT_SWQ, APP_PKTQ_OUT_TM, APP_PKTQ_OUT_SINK, }; struct app_pktq_out_params { enum app_pktq_out_type type; uint32_t id; /* Position in the appropriate app array */ }; #ifndef APP_PIPELINE_TYPE_SIZE #define APP_PIPELINE_TYPE_SIZE 64 #endif #define APP_MAX_PIPELINE_PKTQ_IN PIPELINE_MAX_PORT_IN #define APP_MAX_PIPELINE_PKTQ_OUT PIPELINE_MAX_PORT_OUT #define APP_MAX_PIPELINE_MSGQ_IN PIPELINE_MAX_MSGQ_IN #define APP_MAX_PIPELINE_MSGQ_OUT PIPELINE_MAX_MSGQ_OUT #define APP_MAX_PIPELINE_ARGS PIPELINE_MAX_ARGS struct app_pipeline_params { char *name; uint8_t parsed; char type[APP_PIPELINE_TYPE_SIZE]; uint32_t socket_id; uint32_t core_id; uint32_t hyper_th_id; struct app_pktq_in_params pktq_in[APP_MAX_PIPELINE_PKTQ_IN]; struct app_pktq_out_params pktq_out[APP_MAX_PIPELINE_PKTQ_OUT]; uint32_t msgq_in[APP_MAX_PIPELINE_MSGQ_IN]; uint32_t msgq_out[APP_MAX_PIPELINE_MSGQ_OUT]; uint32_t n_pktq_in; uint32_t n_pktq_out; uint32_t n_msgq_in; uint32_t n_msgq_out; uint32_t timer_period; char *args_name[APP_MAX_PIPELINE_ARGS]; char *args_value[APP_MAX_PIPELINE_ARGS]; uint32_t n_args; }; struct app_pipeline_data { void *be; void *fe; struct pipeline_type *ptype; uint64_t timer_period; uint32_t enabled; }; struct app_thread_pipeline_data { uint32_t pipeline_id; void *be; pipeline_be_op_run f_run; pipeline_be_op_timer f_timer; uint64_t timer_period; uint64_t deadline; }; #ifndef APP_MAX_THREAD_PIPELINES #define APP_MAX_THREAD_PIPELINES 32 #endif #ifndef APP_THREAD_TIMER_PERIOD #define APP_THREAD_TIMER_PERIOD 1 #endif struct app_thread_data { struct app_thread_pipeline_data regular[APP_MAX_THREAD_PIPELINES]; struct app_thread_pipeline_data custom[APP_MAX_THREAD_PIPELINES]; uint32_t n_regular; uint32_t n_custom; uint64_t timer_period; uint64_t thread_req_deadline; uint64_t deadline; struct rte_ring *msgq_in; struct rte_ring *msgq_out; uint64_t headroom_time; uint64_t headroom_cycles; double headroom_ratio; }; #ifndef APP_MAX_LINKS #define APP_MAX_LINKS 32 #endif struct app_eal_params { /* Map lcore set to physical cpu set */ char *coremap; /* Core ID that is used as master */ uint32_t master_lcore_present; uint32_t master_lcore; /* Number of memory channels */ uint32_t channels_present; uint32_t channels; /* Memory to allocate (see also --socket-mem) */ uint32_t memory_present; uint32_t memory; /* Force number of memory ranks (don't detect) */ uint32_t ranks_present; uint32_t ranks; /* Add a PCI device in black list. */ char *pci_blacklist[APP_MAX_LINKS]; /* Add a PCI device in white list. */ char *pci_whitelist[APP_MAX_LINKS]; /* Add a virtual device. */ char *vdev[APP_MAX_LINKS]; /* Use VMware TSC map instead of native RDTSC */ uint32_t vmware_tsc_map_present; int vmware_tsc_map; /* Type of this process (primary|secondary|auto) */ char *proc_type; /* Set syslog facility */ char *syslog; /* Set default log level */ uint32_t log_level_present; uint32_t log_level; /* Display version information on startup */ uint32_t version_present; int version; /* This help */ uint32_t help_present; int help; /* Use malloc instead of hugetlbfs */ uint32_t no_huge_present; int no_huge; /* Disable PCI */ uint32_t no_pci_present; int no_pci; /* Disable HPET */ uint32_t no_hpet_present; int no_hpet; /* No shared config (mmap'd files) */ uint32_t no_shconf_present; int no_shconf; /* Add driver */ char *add_driver; /* Memory to allocate on sockets (comma separated values)*/ char *socket_mem; /* Directory where hugetlbfs is mounted */ char *huge_dir; /* Prefix for hugepage filenames */ char *file_prefix; /* Base virtual address */ char *base_virtaddr; /* Create /dev/uioX (usually done by hotplug) */ uint32_t create_uio_dev_present; int create_uio_dev; /* Interrupt mode for VFIO (legacy|msi|msix) */ char *vfio_intr; /* Support running on Xen dom0 without hugetlbfs */ uint32_t xen_dom0_present; int xen_dom0; }; #ifndef APP_APPNAME_SIZE #define APP_APPNAME_SIZE 256 #endif #ifndef APP_MAX_MEMPOOLS #define APP_MAX_MEMPOOLS 8 #endif #ifndef APP_LINK_MAX_HWQ_IN #define APP_LINK_MAX_HWQ_IN 64 #endif #ifndef APP_LINK_MAX_HWQ_OUT #define APP_LINK_MAX_HWQ_OUT 64 #endif #define APP_MAX_HWQ_IN (APP_MAX_LINKS * APP_LINK_MAX_HWQ_IN) #define APP_MAX_HWQ_OUT (APP_MAX_LINKS * APP_LINK_MAX_HWQ_OUT) #ifndef APP_MAX_PKTQ_SWQ #define APP_MAX_PKTQ_SWQ 256 #endif #define APP_MAX_PKTQ_TM APP_MAX_LINKS #ifndef APP_MAX_PKTQ_SOURCE #define APP_MAX_PKTQ_SOURCE 32 #endif #ifndef APP_MAX_PKTQ_SINK #define APP_MAX_PKTQ_SINK 32 #endif #ifndef APP_MAX_MSGQ #define APP_MAX_MSGQ 128 #endif #ifndef APP_MAX_PIPELINES #define APP_MAX_PIPELINES 64 #endif #ifndef APP_EAL_ARGC #define APP_EAL_ARGC 32 #endif #ifndef APP_MAX_PIPELINE_TYPES #define APP_MAX_PIPELINE_TYPES 64 #endif #ifndef APP_MAX_THREADS #define APP_MAX_THREADS RTE_MAX_LCORE #endif #ifndef APP_MAX_CMDS #define APP_MAX_CMDS 128 #endif #ifndef APP_THREAD_HEADROOM_STATS_COLLECT #define APP_THREAD_HEADROOM_STATS_COLLECT 1 #endif uint8_t enable_hwlb; uint8_t enable_flow_dir; #define APP_CORE_MASK_SIZE \ (RTE_MAX_LCORE / 64 + ((RTE_MAX_LCORE % 64) ? 1 : 0)) struct app_params { /* Config */ char app_name[APP_APPNAME_SIZE]; const char *config_file; const char *script_file; const char *parser_file; const char *output_file; const char *preproc; const char *preproc_args; uint64_t port_mask; uint32_t log_level; struct app_eal_params eal_params; struct app_mempool_params mempool_params[APP_MAX_MEMPOOLS]; struct app_link_params link_params[APP_MAX_LINKS]; struct app_pktq_hwq_in_params hwq_in_params[APP_MAX_HWQ_IN]; struct app_pktq_hwq_out_params hwq_out_params[APP_MAX_HWQ_OUT]; struct app_pktq_swq_params swq_params[APP_MAX_PKTQ_SWQ]; struct app_pktq_tm_params tm_params[APP_MAX_PKTQ_TM]; struct app_pktq_source_params source_params[APP_MAX_PKTQ_SOURCE]; struct app_pktq_sink_params sink_params[APP_MAX_PKTQ_SINK]; struct app_msgq_params msgq_params[APP_MAX_MSGQ]; struct app_pipeline_params pipeline_params[APP_MAX_PIPELINES]; uint32_t n_mempools; uint32_t n_links; uint32_t n_pktq_hwq_in; uint32_t n_pktq_hwq_out; uint32_t n_pktq_swq; uint32_t n_pktq_tm; uint32_t n_pktq_source; uint32_t n_pktq_sink; uint32_t n_msgq; uint32_t n_pipelines; uint32_t header_csum_req; uint32_t n_hwlb_q; /* Init */ char *eal_argv[1 + APP_EAL_ARGC]; struct cpu_core_map *core_map; uint64_t core_mask[APP_CORE_MASK_SIZE]; struct rte_mempool *mempool[APP_MAX_MEMPOOLS]; struct rte_ring *swq[APP_MAX_PKTQ_SWQ]; struct rte_sched_port *tm[APP_MAX_PKTQ_TM]; struct rte_ring *msgq[APP_MAX_MSGQ]; struct pipeline_type pipeline_type[APP_MAX_PIPELINE_TYPES]; struct app_pipeline_data pipeline_data[APP_MAX_PIPELINES]; struct app_thread_data thread_data[APP_MAX_THREADS]; cmdline_parse_ctx_t cmds[APP_MAX_CMDS + 1]; int eal_argc; uint32_t n_pipeline_types; uint32_t n_cmds; }; #define APP_PARAM_VALID(obj) ((obj)->name != NULL) #define APP_PARAM_COUNT(obj_array, n_objs) \ { \ size_t i; \ \ n_objs = 0; \ for (i = 0; i < RTE_DIM(obj_array); i++) \ if (APP_PARAM_VALID(&((obj_array)[i]))) \ n_objs++; \ } #define APP_PARAM_FIND(obj_array, key) \ ({ \ ssize_t obj_idx; \ const ssize_t obj_count = RTE_DIM(obj_array); \ \ for (obj_idx = 0; obj_idx < obj_count; obj_idx++) { \ if (!APP_PARAM_VALID(&((obj_array)[obj_idx]))) \ continue; \ \ if (strcmp(key, (obj_array)[obj_idx].name) == 0) \ break; \ } \ obj_idx < obj_count ? obj_idx : -ENOENT; \ }) #define APP_PARAM_FIND_BY_ID(obj_array, prefix, id, obj) \ do { \ char name[APP_PARAM_NAME_SIZE]; \ ssize_t pos; \ \ sprintf(name, prefix "%" PRIu32, id); \ pos = APP_PARAM_FIND(obj_array, name); \ obj = (pos < 0) ? NULL : &((obj_array)[pos]); \ } while (0) #define APP_PARAM_GET_ID(obj, prefix, id) \ do \ sscanf(obj->name, prefix "%" SCNu32, &id); \ while (0) \ #define APP_PARAM_ADD(obj_array, obj_name) \ ({ \ ssize_t obj_idx; \ const ssize_t obj_count = RTE_DIM(obj_array); \ \ obj_idx = APP_PARAM_FIND(obj_array, obj_name); \ if (obj_idx < 0) { \ for (obj_idx = 0; obj_idx < obj_count; obj_idx++) { \ if (!APP_PARAM_VALID(&((obj_array)[obj_idx]))) \ break; \ } \ \ if (obj_idx < obj_count) { \ (obj_array)[obj_idx].name = strdup(obj_name); \ if ((obj_array)[obj_idx].name == NULL) \ obj_idx = -EINVAL; \ } else \ obj_idx = -ENOMEM; \ } \ obj_idx; \ }) #define APP_CHECK(exp, fmt, ...) \ do { \ if (!(exp)) { \ fprintf(stderr, fmt "\n", ## __VA_ARGS__); \ abort(); \ } \ } while (0) enum app_log_level { APP_LOG_LEVEL_HIGH = 1, APP_LOG_LEVEL_LOW, APP_LOG_LEVELS }; #define APP_LOG(app, level, fmt, ...) \ do { \ if (app->log_level >= APP_LOG_LEVEL_ ## level) \ fprintf(stdout, "[APP] " fmt "\n", ## __VA_ARGS__); \ } while (0) static inline uint32_t app_link_get_n_rxq(struct app_params *app, struct app_link_params *link) { uint32_t n_rxq = 0, link_id, i; uint32_t n_pktq_hwq_in = RTE_MIN(app->n_pktq_hwq_in, RTE_DIM(app->hwq_in_params)); APP_PARAM_GET_ID(link, "LINK", link_id); for (i = 0; i < n_pktq_hwq_in; i++) { struct app_pktq_hwq_in_params *p = &app->hwq_in_params[i]; uint32_t rxq_link_id, rxq_queue_id; sscanf(p->name, "RXQ%" SCNu32 ".%" SCNu32, &rxq_link_id, &rxq_queue_id); if (rxq_link_id == link_id) n_rxq++; } return n_rxq; } static inline uint32_t app_link_get_n_txq(struct app_params *app, struct app_link_params *link) { uint32_t n_txq = 0, link_id, i; uint32_t n_pktq_hwq_out = RTE_MIN(app->n_pktq_hwq_out, RTE_DIM(app->hwq_out_params)); APP_PARAM_GET_ID(link, "LINK", link_id); for (i = 0; i < n_pktq_hwq_out; i++) { struct app_pktq_hwq_out_params *p = &app->hwq_out_params[i]; uint32_t txq_link_id, txq_queue_id; sscanf(p->name, "TXQ%" SCNu32 ".%" SCNu32, &txq_link_id, &txq_queue_id); if (txq_link_id == link_id) n_txq++; } return n_txq; } static inline uint32_t app_rxq_get_readers(struct app_params *app, struct app_pktq_hwq_in_params *rxq) { uint32_t pos = rxq - app->hwq_in_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_readers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_in = RTE_MIN(p->n_pktq_in, RTE_DIM(p->pktq_in)); uint32_t j; for (j = 0; j < n_pktq_in; j++) { struct app_pktq_in_params *pktq = &p->pktq_in[j]; if ((pktq->type == APP_PKTQ_IN_HWQ) && (pktq->id == pos)) n_readers++; } } return n_readers; } static inline uint32_t app_swq_get_readers(struct app_params *app, struct app_pktq_swq_params *swq) { uint32_t pos = swq - app->swq_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_readers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_in = RTE_MIN(p->n_pktq_in, RTE_DIM(p->pktq_in)); uint32_t j; for (j = 0; j < n_pktq_in; j++) { struct app_pktq_in_params *pktq = &p->pktq_in[j]; if ((pktq->type == APP_PKTQ_IN_SWQ) && (pktq->id == pos)) n_readers++; } } return n_readers; } static inline uint32_t app_tm_get_readers(struct app_params *app, struct app_pktq_tm_params *tm) { uint32_t pos = tm - app->tm_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_readers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_in = RTE_MIN(p->n_pktq_in, RTE_DIM(p->pktq_in)); uint32_t j; for (j = 0; j < n_pktq_in; j++) { struct app_pktq_in_params *pktq = &p->pktq_in[j]; if ((pktq->type == APP_PKTQ_IN_TM) && (pktq->id == pos)) n_readers++; } } return n_readers; } static inline uint32_t app_source_get_readers(struct app_params *app, struct app_pktq_source_params *source) { uint32_t pos = source - app->source_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_readers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_in = RTE_MIN(p->n_pktq_in, RTE_DIM(p->pktq_in)); uint32_t j; for (j = 0; j < n_pktq_in; j++) { struct app_pktq_in_params *pktq = &p->pktq_in[j]; if ((pktq->type == APP_PKTQ_IN_SOURCE) && (pktq->id == pos)) n_readers++; } } return n_readers; } static inline uint32_t app_msgq_get_readers(struct app_params *app, struct app_msgq_params *msgq) { uint32_t pos = msgq - app->msgq_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_readers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_msgq_in = RTE_MIN(p->n_msgq_in, RTE_DIM(p->msgq_in)); uint32_t j; for (j = 0; j < n_msgq_in; j++) if (p->msgq_in[j] == pos) n_readers++; } return n_readers; } static inline uint32_t app_txq_get_writers(struct app_params *app, struct app_pktq_hwq_out_params *txq) { uint32_t pos = txq - app->hwq_out_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_writers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_out = RTE_MIN(p->n_pktq_out, RTE_DIM(p->pktq_out)); uint32_t j; for (j = 0; j < n_pktq_out; j++) { struct app_pktq_out_params *pktq = &p->pktq_out[j]; if ((pktq->type == APP_PKTQ_OUT_HWQ) && (pktq->id == pos)) n_writers++; } } return n_writers; } static inline uint32_t app_swq_get_writers(struct app_params *app, struct app_pktq_swq_params *swq) { uint32_t pos = swq - app->swq_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_writers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_out = RTE_MIN(p->n_pktq_out, RTE_DIM(p->pktq_out)); uint32_t j; for (j = 0; j < n_pktq_out; j++) { struct app_pktq_out_params *pktq = &p->pktq_out[j]; if ((pktq->type == APP_PKTQ_OUT_SWQ) && (pktq->id == pos)) n_writers++; } } return n_writers; } static inline uint32_t app_tm_get_writers(struct app_params *app, struct app_pktq_tm_params *tm) { uint32_t pos = tm - app->tm_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_writers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_out = RTE_MIN(p->n_pktq_out, RTE_DIM(p->pktq_out)); uint32_t j; for (j = 0; j < n_pktq_out; j++) { struct app_pktq_out_params *pktq = &p->pktq_out[j]; if ((pktq->type == APP_PKTQ_OUT_TM) && (pktq->id == pos)) n_writers++; } } return n_writers; } static inline uint32_t app_sink_get_writers(struct app_params *app, struct app_pktq_sink_params *sink) { uint32_t pos = sink - app->sink_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_writers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_pktq_out = RTE_MIN(p->n_pktq_out, RTE_DIM(p->pktq_out)); uint32_t j; for (j = 0; j < n_pktq_out; j++) { struct app_pktq_out_params *pktq = &p->pktq_out[j]; if ((pktq->type == APP_PKTQ_OUT_SINK) && (pktq->id == pos)) n_writers++; } } return n_writers; } static inline uint32_t app_core_is_enabled(struct app_params *app, uint32_t lcore_id) { return(app->core_mask[lcore_id / 64] & (1LLU << (lcore_id % 64))); } static inline void app_core_enable_in_core_mask(struct app_params *app, int lcore_id) { app->core_mask[lcore_id / 64] |= 1LLU << (lcore_id % 64); } static inline void app_core_build_core_mask_string(struct app_params *app, char *mask_buffer) { int i; mask_buffer[0] = '\0'; for (i = (int)RTE_DIM(app->core_mask); i > 0; i--) { /* For Hex representation of bits in uint64_t */ char buffer[(64 / 8) * 2 + 1]; memset(buffer, 0, sizeof(buffer)); snprintf(buffer, sizeof(buffer), "%016" PRIx64, app->core_mask[i-1]); strcat(mask_buffer, buffer); } } static inline uint32_t app_msgq_get_writers(struct app_params *app, struct app_msgq_params *msgq) { uint32_t pos = msgq - app->msgq_params; uint32_t n_pipelines = RTE_MIN(app->n_pipelines, RTE_DIM(app->pipeline_params)); uint32_t n_writers = 0, i; for (i = 0; i < n_pipelines; i++) { struct app_pipeline_params *p = &app->pipeline_params[i]; uint32_t n_msgq_out = RTE_MIN(p->n_msgq_out, RTE_DIM(p->msgq_out)); uint32_t j; for (j = 0; j < n_msgq_out; j++) if (p->msgq_out[j] == pos) n_writers++; } return n_writers; } static inline struct app_link_params * app_get_link_for_rxq(struct app_params *app, struct app_pktq_hwq_in_params *p) { char link_name[APP_PARAM_NAME_SIZE]; ssize_t link_param_idx; uint32_t rxq_link_id, rxq_queue_id; sscanf(p->name, "RXQ%" SCNu32 ".%" SCNu32, &rxq_link_id, &rxq_queue_id); sprintf(link_name, "LINK%" PRIu32, rxq_link_id); link_param_idx = APP_PARAM_FIND(app->link_params, link_name); APP_CHECK((link_param_idx >= 0), "Cannot find %s for %s", link_name, p->name); return &app->link_params[link_param_idx]; } static inline struct app_link_params * app_get_link_for_txq(struct app_params *app, struct app_pktq_hwq_out_params *p) { char link_name[APP_PARAM_NAME_SIZE]; ssize_t link_param_idx; uint32_t txq_link_id, txq_queue_id; sscanf(p->name, "TXQ%" SCNu32 ".%" SCNu32, &txq_link_id, &txq_queue_id); sprintf(link_name, "LINK%" PRIu32, txq_link_id); link_param_idx = APP_PARAM_FIND(app->link_params, link_name); APP_CHECK((link_param_idx >= 0), "Cannot find %s for %s", link_name, p->name); return &app->link_params[link_param_idx]; } static inline struct app_link_params * app_get_link_for_tm(struct app_params *app, struct app_pktq_tm_params *p_tm) { char link_name[APP_PARAM_NAME_SIZE]; uint32_t link_id; ssize_t link_param_idx; sscanf(p_tm->name, "TM%" PRIu32, &link_id); sprintf(link_name, "LINK%" PRIu32, link_id); link_param_idx = APP_PARAM_FIND(app->link_params, link_name); APP_CHECK((link_param_idx >= 0), "Cannot find %s for %s", link_name, p_tm->name); return &app->link_params[link_param_idx]; } int app_config_init(struct app_params *app); int app_config_args(struct app_params *app, int argc, char **argv); int app_config_preproc(struct app_params *app); int app_config_parse(struct app_params *app, const char *file_name); int app_config_parse_tm(struct app_params *app); void app_config_save(struct app_params *app, const char *file_name); int app_config_check(struct app_params *app); int app_init(struct app_params *app); int app_thread(void *arg); int app_pipeline_type_register(struct app_params *app, struct pipeline_type *ptype); struct pipeline_type *app_pipeline_type_find(struct app_params *app, char *name); void app_link_up_internal(struct app_params *app, struct app_link_params *cp); void app_link_down_internal(struct app_params *app, struct app_link_params *cp); #endif