samplevnf -

Age	Commit message (Expand)	Author	Files	Lines
2017-07-14	Adding PROX(Packet pROcessing eXecution engine) VNF to sampleVNF	Deepak S	1	-0/+28

/* // Copyright (c) 2010-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. */ #include "task_init.h" #include "task_base.h" #include "stats.h" #include "arp.h" #include "etypes.h" #include "quit.h" #include "log.h" #include "prox_port_cfg.h" #include "lconf.h" #include "cmd_parser.h" #include "handle_arp.h" struct task_arp { struct task_base base; struct ether_addr src_mac; uint32_t seed; uint32_t flags; uint32_t ip; uint32_t tmp_ip; uint8_t arp_replies_ring; uint8_t other_pkts_ring; uint8_t send_arp_requests; }; static void task_update_config(struct task_arp *task) { if (unlikely(task->ip != task->tmp_ip)) task->ip = task->tmp_ip; } static void handle_arp(struct task_arp *task, struct ether_hdr_arp *hdr, struct ether_addr *s_addr) { build_arp_reply(hdr, s_addr); } static int handle_arp_bulk(struct task_base *tbase, struct rte_mbuf **mbufs, uint16_t n_pkts) { struct ether_hdr_arp *hdr; struct task_arp *task = (struct task_arp *)tbase; uint8_t out[MAX_PKT_BURST] = {0}; struct rte_mbuf *replies_mbufs[64] = {0}, *arp_pkt_mbufs[64] = {0}; int n_arp_reply_pkts = 0, n_other_pkts = 0,n_arp_pkts = 0; struct ether_addr s_addr; for (uint16_t j = 0; j < n_pkts; ++j) { hdr = rte_pktmbuf_mtod(mbufs[j], struct ether_hdr_arp *); if (hdr->ether_hdr.ether_type == ETYPE_ARP) { if (arp_is_gratuitous(hdr)) { out[n_other_pkts] = OUT_DISCARD; n_other_pkts++; plog_info("Received gratuitous packet \n"); } else if (hdr->arp.oper == 0x100) { if (task->arp_replies_ring != OUT_DISCARD) { arp_pkt_mbufs[n_arp_pkts] = mbufs[j]; out[n_arp_pkts] = task->arp_replies_ring; n_arp_pkts++; } else if (task->ip == 0) { create_mac(hdr, &s_addr); handle_arp(task, hdr, &s_addr); replies_mbufs[n_arp_reply_pkts] = mbufs[j]; out[n_arp_reply_pkts] = 0; n_arp_reply_pkts++; } else if (hdr->arp.data.tpa == task->ip) { handle_arp(task, hdr, &task->src_mac); replies_mbufs[n_arp_reply_pkts] = mbufs[j]; out[n_arp_reply_pkts] = 0; n_arp_reply_pkts++; } else { out[n_other_pkts] = OUT_DISCARD; mbufs[n_other_pkts] = mbufs[j]; n_other_pkts++; plogx_dbg("Received ARP on unexpected IP %x, expecting %x\n", rte_be_to_cpu_32(hdr->arp.data.tpa), rte_be_to_cpu_32(task->ip)); } } else if (hdr->arp.oper == 0x200) { arp_pkt_mbufs[n_arp_pkts] = mbufs[j]; out[n_arp_pkts] = task->arp_replies_ring; n_arp_pkts++; } else { out[n_other_pkts] = task->other_pkts_ring; mbufs[n_other_pkts] = mbufs[j]; n_other_pkts++; } } else { out[n_other_pkts] = task->other_pkts_ring; mbufs[n_other_pkts] = mbufs[j]; n_other_pkts++; } } int ret = 0; if (n_arp_reply_pkts) { ret+=task->base.aux->tx_pkt_hw(&task->base, replies_mbufs, n_arp_reply_pkts, out); } if (n_arp_pkts) ret+= task->base.tx_pkt(&task->base, arp_pkt_mbufs, n_arp_pkts, out); ret+= task->base.tx_pkt(&task->base, mbufs, n_other_pkts, out); task_update_config(task); return ret; } void task_arp_set_local_ip(struct task_base *tbase, uint32_t ip) { struct task_arp *task = (struct task_arp *)tbase; task->tmp_ip = ip; } static void init_task_arp(struct task_base *tbase, struct task_args *targ) { struct task_arp *task = (struct task_arp *)tbase; struct task_args *dtarg; struct core_task ct; int port_found = 0; task->other_pkts_ring = OUT_DISCARD; task->arp_replies_ring = OUT_DISCARD; task->seed = rte_rdtsc(); memcpy(&task->src_mac, &prox_port_cfg[task->base.tx_params_hw_sw.tx_port_queue.port].eth_addr, sizeof(struct ether_addr)); task->ip = rte_cpu_to_be_32(targ->local_ipv4); task->tmp_ip = task->ip; PROX_PANIC(targ->nb_txrings > targ->core_task_set[0].n_elems, "%d txrings but %d elems in task_set\n", targ->nb_txrings, targ->core_task_set[0].n_elems); for (uint32_t i = 0; i < targ->nb_txrings; ++i) { ct = targ->core_task_set[0].core_task[i]; plog_info("ARP mode checking whether core %d task %d (i.e. ring %d) can handle arp\n", ct.core, ct.task, i); dtarg = core_targ_get(ct.core, ct.task); dtarg = find_reachable_task_sending_to_port(dtarg); if ((dtarg != NULL) && (task_is_sub_mode(dtarg->lconf->id, dtarg->id, "l3"))) { plog_info("ARP task sending ARP replies to core %d and task %d to handle them\n", ct.core, ct.task); task->arp_replies_ring = i; } else { plog_info("ARP task sending (potentially other) packets to core %d and task %d\n", ct.core, ct.task); task->other_pkts_ring = i; } } if ((targ->nb_txports == 0) && (task->arp_replies_ring == OUT_DISCARD)) { PROX_PANIC(1, "arp mode must have a tx_port or a ring able to a task in l3 reaching tx port"); } } // Reply to ARP requests with random MAC addresses static struct task_init task_init_cpe_arp = { .mode_str = "arp", .init = init_task_arp, .handle = handle_arp_bulk, .size = sizeof(struct task_arp) }; // Reply to ARP requests with MAC address of the interface static struct task_init task_init_arp = { .mode_str = "arp", .sub_mode_str = "local", .init = init_task_arp, .handle = handle_arp_bulk, .size = sizeof(struct task_arp) }; __attribute__((constructor)) static void reg_task_arp(void) { reg_task(&task_init_cpe_arp); reg_task(&task_init_arp); }