aboutsummaryrefslogtreecommitdiffstats
path: root/plugins/vcgn-plugin/vcgn/cnat_util.c
diff options
context:
space:
mode:
Diffstat (limited to 'plugins/vcgn-plugin/vcgn/cnat_util.c')
-rw-r--r--plugins/vcgn-plugin/vcgn/cnat_util.c2256
1 files changed, 0 insertions, 2256 deletions
diff --git a/plugins/vcgn-plugin/vcgn/cnat_util.c b/plugins/vcgn-plugin/vcgn/cnat_util.c
deleted file mode 100644
index c3697b6be2f..00000000000
--- a/plugins/vcgn-plugin/vcgn/cnat_util.c
+++ /dev/null
@@ -1,2256 +0,0 @@
-/*
- *------------------------------------------------------------------
- * cnat_util.c - cnat helpers
- *
- * Copyright (c) 2009-2014 Cisco and/or its affiliates.
- * 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 <vlib/vlib.h>
-#include <vnet/vnet.h>
-#include <vppinfra/vec.h>
-#include <vppinfra/bitmap.h>
-#include <vppinfra/hash.h>
-#include <vppinfra/pool.h>
-#include <vppinfra/clib.h>
-#include <vppinfra/error.h>
-
-#include "tcp_header_definitions.h"
-
-#if 0
-void spp_api_cnat_v4_config_dummy_t_handler
-(spp_api_cnat_v4_config_dummy_t *mp);
-
-void spp_api_cnat_v4_config_dummy_max_t_handler
-(spp_api_cnat_v4_config_dummy_max_t *mp);
-
-void spp_api_cnat_v4_config_icmp_timeout_t_handler
-(spp_api_cnat_v4_config_icmp_timeout_t *mp);
-
-void spp_api_cnat_clear_db_request_t_handler
-(spp_api_cnat_clear_db_request_t *mp);
-
-void spp_api_cnat_v4_debug_global_t_handler
-(spp_api_cnat_v4_debug_global_t *mp);
-
-void spp_api_cnat_v4_show_outside_entry_req_t_handler
-(spp_api_cnat_v4_show_outside_entry_req_t *mp);
-
-void spp_api_cnat_v4_show_inside_entry_req_t_handler
-(spp_api_cnat_v4_show_inside_entry_req_t *mp);
-
-void spp_api_cnat_show_statistics_summary_req_t_handler
-(spp_api_cnat_show_statistics_summary_req_t *mp);
-
-void cnat_db_create_db_entries_cmd (int argc, unsigned long *argv)
-{
- int i, j ;
- int nusers = 3000;
-
- cnat_db_key_bucket_t key_info;
- cnat_main_db_entry_t *db;
- cnat_gen_icmp_info info;
- cnat_key_t dest_info_dummy;
-
- memset(&dest_info_dummy, 0, sizeof(cnat_key_t));
- printf ("Create %d users, 100 translations each...\n", nusers);
-
- for (i = 0; i < nusers; i++) {
- for (j = 0; j < 100; j++) {
-
- key_info.k.k.vrf = CNAT_TCP | (1 & CNAT_VRF_MASK);
- key_info.k.k.ipv4 = 0x0c000001+i;
- key_info.k.k.port = 1024+j;
-
- db = cnat_get_main_db_entry_v2(&key_info, PORT_SINGLE,
- PORT_TYPE_DYNAMIC, &info, &dest_info_dummy);
-
- if (db == 0) {
- printf ("OOPS: cnat_main_db_create failed users %d trans %d\n", i, j);
- return; /*jli*/
- }
-
- db->entry_expires = cnat_current_time;
-
- }
- }
-}
-
-void db_test_clear (int argc, unsigned long *argv)
-{
- spp_api_cnat_clear_db_request_t mp;
-
- mp.wildcard = argv[0];
- mp.protocol = argv[1];
- mp.port_num = argv[2];
- mp.inside_vrf = argv[3];
- mp.ip_addr = argv[4];
- spp_api_cnat_clear_db_request_t_handler(&mp);
-}
-
-/* test code*/
-void cnat_db_test_show (int argc, unsigned long *argv)
-{
-
- spp_api_cnat_v4_show_inside_entry_req_t mp1[2000];
- spp_api_cnat_v4_show_outside_entry_req_t mp2[30000];
-
- if (argc > 1) {
- if (argc != 7) {
- printf("Usage: db test show dec((which)) dec((vrf)) dec((proto)) dec((ip)) dec((start_port)) dec((end_port)) dec((flags))\n");
- return;
- }
-
- mp1[0].vrf_id = argv[1];
- mp1[0].protocol = argv[2];;
- mp1[0].ipv4_addr = argv[3];
- mp1[0].start_port = argv[4];
- mp1[0].end_port = argv[5];
- mp1[0].flags = argv[6];
- mp1[0].all_entries = 0;
-
- if (argv[0] == 1) {
- spp_api_cnat_v4_show_inside_entry_req_t_handler (&(mp1[0]));
- } else {
- spp_api_cnat_v4_show_outside_entry_req_t_handler (&(mp2[0]));
- }
-
- return;
- } else {
- printf("inside entries \n");
- mp1[0].ipv4_addr = 0x016994CA;
- mp1[0].vrf_id = 1;
- mp1[0].all_entries = 0;
- mp1[0].start_port = 32765;
- mp1[0].end_port = 65535;
- mp1[0].protocol = 2;
- mp1[0].flags = 3;
-
- spp_api_cnat_v4_show_inside_entry_req_t_handler (&(mp1[0]));
-
- mp2[0].ipv4_addr = 0x640200c1;
- mp2[0].vrf_id = 0;
- mp2[0].start_port = 1025;
- mp2[0].end_port = 62235;
- mp2[0].protocol = 2;
- mp2[0].flags = 3;
-
- spp_api_cnat_v4_show_outside_entry_req_t_handler (&(mp2[0]));
- }
-
-#if 1
- {
- spp_api_cnat_stats_node_mapping_t mp3[20000];
- spp_api_cnat_stats_counter_mapping_t mp4[20000];
- spp_api_cnat_stats_counter_values_t mp5[23000];
-
- mp3[0].rc = 0;
- spp_api_cnat_stats_node_mapping_t_handler (&mp3);
- mp4[0].rc = 0;
- spp_api_cnat_stats_counter_mapping_t_handler (&mp4);
-
- mp5[0].flag = 1;
- spp_api_cnat_stats_counter_values_t_handler(&mp5);
- }
-#endif
-
-#if 0
- mp1.ipv4_addr = 0x0A010102;
- mp1.vrf_id = 1;
- mp1.all_entries = 1;
- mp1.protocol = 1;
-
- spp_api_cnat_v4_show_inside_entry_req_t_handler (&mp1);
-
-
- mp1.ipv4_addr = 0x0A010103;
- mp1.vrf_id = 1;
- mp1.all_entries = 1;
- mp1.protocol = 2;
-
- spp_api_cnat_v4_show_inside_entry_req_t_handler (&mp1);
-
- mp6[0].inside_vrf_id = 1;
- mp6[0].start_ipv4_address = 0x64020001;
- mp6[0].end_ipv4_address = 0x64020101;
- mp6[0].free_addr = 0;
- mp6[0].flags = CNAT_TRANSLATION_ENTRY_STATIC;
-
- spp_api_cnat_v4_show_freeUsed_entry_req_t_handler(&mp6);
-
-#endif
- printf("returned here");
-
- return;
-}
-
-
-
-void cnat_db_clear_all_entries (int argc, unsigned long *argv)
-{
- cnat_main_db_entry_t * db;
- u32 index;
-
- pool_header_t * p = vec_header(cnat_main_db, sizeof(pool_header_t) );
-
- for(index = 0; index < vec_len(cnat_main_db); index++) {
-
- if ( !clib_bitmap_get(p->free_bitmap, index)) {
-
- db = cnat_main_db + index;
- cnat_delete_main_db_entry_v2(db);
-
- }
- }
-
-}
-
-
-void spp_log_cmd (int argc, unsigned long *argv)
-{
- u16 num_traces;
- u16 error_code;
- u16 num_args;
- u32 arg[7];
- u8 i;
-
- num_traces = argv[0];
-
- for (i = 0; i < num_traces; i++) {
- error_code = argv[1 + 4*i];
- num_args = argv[2 + 4*i];
- arg[0] = argv[3 + 4*i];
- arg[1] = argv[4 + 4*i];
-
- spp_printf(error_code, num_args, arg);
- }
-}
-
-
-void cnat_db_create_random_entries (int argc, unsigned long *argv)
-{
-
- platform_cnat_db_create_random_entries();
-}
-
-#define MAX_DEPTH 10
-
-void show_user_db_hash_chain_len() {
-
- u32 max_len, len, n, i, max_idx, index, used;
- cnat_user_db_entry_t * udb;
- u32 hash_depth[MAX_DEPTH];
-
- memset(hash_depth, 0, sizeof(u32)*MAX_DEPTH);
-
- n = vec_len(cnat_user_hash);
-
- used = 0;
- max_len = 0;
- for(i=0;i<n;i++) {
-
- index = cnat_user_hash[i].next;
-
- len = 0;
- if (index != EMPTY) used++;
-
- while (index != EMPTY) {
- len++ ;
- udb = cnat_user_db + index;
- index = udb->user_hash.next;
- }
-
- if(len < (MAX_DEPTH-1) ) {
- hash_depth[len]++;
- } else {
- hash_depth[MAX_DEPTH-1]++;
- }
-
- if (max_len < len) {
- max_len = len;
- max_idx = cnat_user_hash[i].next;
- }
- }
-
- printf("Max user db hash length %u, total buckets %u used %u\n",
- max_len, n, used);
-
- for( i=1; i<(MAX_DEPTH - 1); i++) {
- printf("Hash chain len %02d, entries count %d\n", i, hash_depth[i]);
- }
-
- printf("Hash chain len >%02d, entries count %d\n",
- MAX_DEPTH-1, hash_depth[MAX_DEPTH-1]);
-
-}
-
-void show_main_db_hash_chain_len() {
-
- u32 max_len, len, n, i, max_idx, index, used;
- cnat_main_db_entry_t * db;
- u32 hash_depth[MAX_DEPTH];
-
- memset(hash_depth, 0, sizeof(u32)*MAX_DEPTH);
-
- n = vec_len(cnat_in2out_hash);
-
- used = 0;
- max_len = 0;
- for(i=0;i<n;i++) {
-
- index = cnat_in2out_hash[i].next;
-
- len = 0;
- if (index != EMPTY) used++;
-
- while (index != EMPTY) {
- len++ ;
- db = cnat_main_db + index;
- index = db->in2out_hash.next;
- }
-
- if(len < (MAX_DEPTH-1) ) {
- hash_depth[len]++;
- } else {
- hash_depth[MAX_DEPTH-1]++;
- }
-
- if (max_len < len) {
- max_len = len;
- max_idx = cnat_in2out_hash[i].next;
- }
- }
-
- printf("Max main db I2O hash length %u, total buckets %u used %u\n",
- max_len, n, used);
-
- for( i=1; i<(MAX_DEPTH - 1); i++) {
- printf("Hash chain len %02d, entries count %d\n", i, hash_depth[i]);
- }
-
- printf("Hash chain len >%02d, entries count %d\n",
- MAX_DEPTH-1, hash_depth[MAX_DEPTH-1]);
-
-
- memset(hash_depth, 0, sizeof(u32)*MAX_DEPTH);
-
- n = vec_len(cnat_out2in_hash);
- used = 0;
- max_len = 0;
-
- for(i=0;i<n;i++) {
-
- index = cnat_out2in_hash[i].next;
- len = 0;
-
- if (index != EMPTY) used++;
-
- while (index != EMPTY) {
- len++ ;
- db = cnat_main_db + index;
- index = db->out2in_hash.next;
- }
-
- if(len < (MAX_DEPTH-1) ) {
- hash_depth[len]++;
- } else {
- hash_depth[MAX_DEPTH-1]++;
- }
-
- if (max_len < len) {
- max_len = len;
- max_idx = cnat_in2out_hash[i].next;
- }
- }
-
- printf("Max main db O2I hash length %u, total buckets %u used %u\n",
- max_len, n, used);
-
- for( i=1; i<(MAX_DEPTH - 1); i++) {
- printf("Hash chain len %02d, entries count %d\n", i, hash_depth[i]);
- }
-
- printf("Hash chain len >%02d, entries count %d\n",
- MAX_DEPTH-1, hash_depth[MAX_DEPTH-1]);
-
-
-}
-
-u32 db_free_entry (void * p) {
-
- pool_header_t * h;
- u32 free;
-
- h = pool_header(p);
-
- free = p == 0 ? 0: vec_len(h->free_indices);
-
- return free;
-}
-
-void cnat_db_summary (int argc, unsigned long *argv) {
-
- PLATFORM_DEBUG_PRINT("\n-----------------------------------------");
- PLATFORM_DEBUG_PRINT("\nSummary DB");
- PLATFORM_DEBUG_PRINT("\n-----------------------------------------\n");
- u32 count1, count2, i;
-#ifndef NO_NAT64_DEF
- extern void nat64_session_db_summary();
-#endif
- /* main db active entry count*/
- count1 = vec_len(cnat_main_db);
- count2 = db_free_entry(cnat_main_db);
-
- PLATFORM_DEBUG_PRINT("main db entries: total %u, active %u, free %u\n", count1, count1 - count2, count2);
-
- /* user db active entry count */
- count1 = vec_len(cnat_user_db);
- count2 = db_free_entry(cnat_user_db);
-
- PLATFORM_DEBUG_PRINT("user db entries: total %u, active %u, free %u\n", count1, count1 - count2, count2);
-
-
- /* user db active entry count */
-#ifndef NO_NAT64_DEF
- nat64_session_db_summary();
-#endif
-
- /* main db hash i2o o2i usage count */
- count1 = 0;
- count2 = 0;
-
- for (i=0; i< CNAT_MAIN_HASH_SIZE; i++) {
-
- if(cnat_in2out_hash[i].next != ~0) count1++;
- if(cnat_out2in_hash[i].next != ~0) count2++;
-
- }
-
- PLATFORM_DEBUG_PRINT("main hash in2out: total %6u, used %u (%.2f%%)\n",
- CNAT_MAIN_HASH_SIZE, count1,
- (100.0*count1)/CNAT_MAIN_HASH_SIZE);
-
- PLATFORM_DEBUG_PRINT("main hash out2in: total %6u, used %u (%.2f%%)\n",
- CNAT_MAIN_HASH_SIZE, count2,
- (100.0 * count1)/CNAT_MAIN_HASH_SIZE);
-
- /* use db hashing usage count */
-
- count1 = 0;
-
- for (i=0; i< CNAT_USER_HASH_SIZE; i++) {
- if(cnat_user_hash[i].next != ~0) count1++;
- }
-
- PLATFORM_DEBUG_PRINT("user db hash: total %6u, used %u (%.2f%%)\n",
- CNAT_USER_HASH_SIZE, count1,
- (100.0*count1)/CNAT_USER_HASH_SIZE);
-
- PLATFORM_DEBUG_PRINT("\nNull pointer exceptions:\n");
- PLATFORM_DEBUG_PRINT("packet_pool: null enq : %10u, null deq : %10u\n",null_enq_pkt, null_deq_pkt);
- PLATFORM_DEBUG_PRINT("ctx_pool : null enq : %10u, null deq : %10u\n",null_enq_ctx, null_deq_ctx);
- PLATFORM_DEBUG_PRINT("wqe_pool : null enq : %10u, null deq : %10u\n",null_enq_wqe, null_deq_wqe);
-
- PLATFORM_DEBUG_PRINT("\nReceived Packet Errors on SPI:\n");
- PLATFORM_DEBUG_PRINT("rcv_pkt_errs: %10u\n",rcv_pkt_errs);
-
- PLATFORM_DEBUG_PRINT("\nctx/sf allocation failure errors: \n");
-#ifndef CGN_PERF_SCALE_DEBUG
- PLATFORM_DEBUG_PRINT("Warning: collection of error counts <with timestamp> is disabled.\n");
- PLATFORM_DEBUG_PRINT("sf alloc errors: %10u, ctx alloc errors: %10u\n",sf_alloc_errs,ctx_alloc_errs);
-#else
- for(i=0;i<COUNTER_BUFFER_SIZE;i++)
- PLATFORM_DEBUG_PRINT("<%2d>Timestamp <sec>: %10u, sf errors: %10u, ctx errors: %10u\n",\
- i,err_cnt_arr[i].timestamp,\
- err_cnt_arr[i].sf_error_counter, \
- err_cnt_arr[i].ctx_error_counter);
-#endif
-}
-
-void cnat_db_hash_summary (int argc, unsigned long *argv) {
-
- show_main_db_hash_chain_len();
-
- show_user_db_hash_chain_len();
-}
-
-/*
- * cnat_port_alloc
- * This function is now deprecated...
- *
- */
-#ifdef LB_PORT
-int cnat_port_alloc (cnat_portmap_t *cnat_portmap, u16 *portmap_inuse,
- int cnat_instance,
- port_alloc_t atype, port_pair_t ptype,
- int *index, u32 *ipv4_address, u16 *base_port)
-#else
-int cnat_port_alloc (cnat_portmap_t *cnat_portmap, u16 *portmap_inuse,
- port_alloc_t atype, port_pair_t ptype,
- int *index, u32 *ipv4_address, u16 *base_port)
-#endif
-{
-
- return (0);
-}
-
-/*
- * cnat_port_free
- * This function is now deprecated...
- *
- */
-#ifdef LB_PORT
-void cnat_port_free (cnat_portmap_t *cnat_portmap, u16 *portmap_inuse,
- int instance, int index, port_pair_t ptype, u16 base_port)
-#else
-void cnat_port_free (cnat_portmap_t *cnat_portmap, u16 *portmap_inuse,
- int index, port_pair_t ptype, u16 base_port)
-#endif
-{
-}
-
-void spp_api_cnat_port_allocate_t_handler(spp_api_cnat_port_allocate_t *mp)
-{
- int i, j, k1, k2;
- int pm_index;
- u32 ipv4_address;
- u16 aport;
- int rv;
- char *out1, *out2, *out_f;
- port_alloc_t pt1, pt2;
- cnat_portmap_t *pm = 0;
- u16 *pm_inuse = 0;
- u32 *firstp =0;
- u32 nr_ports =0;
- u32 nodd_ports = 0;
- u32 neven_ports = 0;
-#ifdef LB_PORT
- u32 my_instance = 1;
-#endif
- char out_r[12] = "allocated-r";
- char out_o[12] = "allocated-o";
- char out_e[12] = "allocated-e";
-
-
- /*
- * this command is run after db create portmap
- * vrf is hardcode to 1
- */
-
- /* Already have a portmap vector for this VRF? */
- for (i = 0; i < vec_len(cnat_portmap_indices_by_vrf); i++) {
- if (cnat_portmap_indices_by_vrf[i] == mp->vrf) {
- pm = cnat_portmaps[i];
- pm_inuse = cnat_portmaps_inuse[i];
- goto found_portmaps;
- }
- }
-
- printf("need to run db create portmaps first 0x%d\n",
- vec_len(cnat_portmap_indices_by_vrf));
- return;
-
-found_portmaps:
- nr_ports = mp->nr_ports;
- nodd_ports = mp->nodd_ports;
- neven_ports = mp->neven_ports;
-
- if ((nr_ports + nodd_ports + neven_ports ) > (PORTS_PER_ADDR)) {
- printf("invalid port# nr_ports %d + odd %d + even %d "
- "should be less than 200 \n", nr_ports, nodd_ports, neven_ports);
- return;
- }
-
- /*
- * first port
- */
- firstp = nr_ports ? (&nr_ports) : (nodd_ports ? (&nodd_ports) : (&neven_ports));
- if (!(*firstp)) {
- printf("invalid port# nr_ports %d odd %d even %d ",
- nr_ports, nodd_ports, neven_ports);
- }
- out_f = nr_ports ? out_r : (nodd_ports ? out_o : out_e);
-
-#ifdef LB_PORT
- rv = cnat_port_alloc (pm, pm_inuse, my_instance,
- PORT_ALLOC_ANY, PORT_S_ODD,
- &pm_index, &ipv4_address, &aport);
-#else
- rv = cnat_port_alloc (pm, pm_inuse,
- PORT_ALLOC_ANY, PORT_S_ODD,
- &pm_index, &ipv4_address, &aport);
-#endif
-
- if (!rv) {
- printf("failed-o\n");
- return;
- }
- printf("%s %8d %10x %8d\n", out_f,
- pm_index, ipv4_address, aport);
-
- (*firstp)--;
-
- for (i=0; i < nr_ports; i++) {
-#ifdef LB_PORT
- rv = cnat_port_alloc (pm, pm_inuse, my_instance,
- PORT_ALLOC_DIRECTED, PORT_SINGLE,
- &pm_index, &ipv4_address, &aport);
-#else
- rv = cnat_port_alloc (pm, pm_inuse,
- PORT_ALLOC_DIRECTED, PORT_SINGLE,
- &pm_index, &ipv4_address, &aport);
-#endif
- if (rv) {
- printf("%s %8d %10x %8d\n", out_r,
- pm_index, ipv4_address, aport);
- } else {
- printf("%s failed\n", out_r);
- return;
- }
- }
-
- if (nodd_ports > neven_ports) {
- k1 = nodd_ports;
- k2 = neven_ports;
- pt1 = PORT_S_ODD;
- pt2 = PORT_S_EVEN;
- out1 = out_o;
- out2 = out_e;
- } else {
- k1= neven_ports;
- pt1 = PORT_S_EVEN;
- k2 = nodd_ports;
- pt2 = PORT_S_ODD;
- out1 = out_e;
- out2 = out_o;
- }
-
- j = 0;
- for (i=0; i < k1; i++) {
-#ifdef LB_PORT
- rv = cnat_port_alloc (pm, pm_inuse, my_instance,
- PORT_ALLOC_DIRECTED, pt1,
- &pm_index, &ipv4_address, &aport);
-#else
- rv = cnat_port_alloc (pm, pm_inuse,
- PORT_ALLOC_DIRECTED, pt1,
- &pm_index, &ipv4_address, &aport);
-#endif
- if (rv) {
- printf("%s %8d %10x %8d\n", out1,
- pm_index, ipv4_address, aport);
- } else {
- printf("%s failed\n", out1);
- return;
- }
-
- if (j < k2) {
-#ifdef LB_PORT
- rv = cnat_port_alloc (pm, pm_inuse, my_instance,
- PORT_ALLOC_DIRECTED, pt2,
- &pm_index, &ipv4_address, &aport);
-#else
- rv = cnat_port_alloc (pm, pm_inuse,
- PORT_ALLOC_DIRECTED, pt2,
- &pm_index, &ipv4_address, &aport);
-#endif
-
- if (rv) {
- printf("%s %8d %10x %8d\n", out2,
- pm_index, ipv4_address, aport);
- j++;
- } else {
- printf("%s failed\n", __FUNCTION__);
- return;
- }
- }
- }
-}
-
-void cnat_db_summary_stats (int argc, unsigned long *argv)
-{
- spp_api_cnat_show_statistics_summary_req_t mp[50000];
-
- spp_api_cnat_show_statistics_summary_req_t_handler(&(mp[0]));
-}
-
-void cnat_debug_global_test (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_debug_global_t *mp;
- spp_api_cnat_v4_config_dummy_t mp1;
- spp_api_cnat_v4_config_icmp_timeout_t mp2[10];
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEBUG_GLOBAL;
- mp->debug_flag = argv[0];
-
- platform_send_msg(mp);
-
- mp2[0].default_value = 3;
-
- spp_api_cnat_v4_config_dummy_t_handler(&mp1);
- spp_api_cnat_v4_config_icmp_timeout_t_handler(&(mp2[0]));
-}
-
-void cnat_debug_inside_test (int argc, unsigned long *argv)
-{
-
- spp_api_cnat_v4_debug_in2out_private_addr_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEBUG_IN2OUT_PRIVATE_ADDR;
-
- mp->start_addr = spp_host_to_net_byte_order_32(argv[0]);
- mp->end_addr = spp_host_to_net_byte_order_32(argv[1]);
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[2]);
- mp->debug_flag = spp_host_to_net_byte_order_32(argv[3]);
-
- platform_send_msg(mp);
-}
-
-void cnat_config_ports_user (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_config_port_limit_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_CONFIG_PORT_LIMIT;
-
- mp->port_limit = spp_host_to_net_byte_order_16(argv[0]);
-
- platform_send_msg(mp);
-
-}
-
-void cnat_debug_outside_test (int argc, unsigned long *argv)
-{
-
- spp_api_cnat_v4_debug_out2in_public_addr_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEBUG_OUT2IN_PUBLIC_ADDR;
-
- mp->start_addr = spp_host_to_net_byte_order_32(argv[0]);
- mp->end_addr = spp_host_to_net_byte_order_32(argv[1]);
- mp->o_vrf = spp_host_to_net_byte_order_16(argv[2]);
- mp->debug_flag = spp_host_to_net_byte_order_32(argv[3]);
-
- platform_send_msg(mp);
-}
-
-void cnat_debug_udp_dump (int argc, unsigned long *argv)
-{
-
- spp_api_cnat_p2mp_debug_request_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_P2MP_DEBUG_REQUEST;
- mp->dump_type =
- spp_host_to_net_byte_order_16(CNAT_DEBUG_GENERIC_COMMAND_DEBUG_FLAGS);
-
- if (spp_host_to_net_byte_order_32(argv[0]) == 1) {
- mp->param[0] = spp_host_to_net_byte_order_32(
- CNAT_DEBUG_FLAG_UDP_INSIDE_PACKET_DUMP);
- } else {
- mp->param[0] = spp_host_to_net_byte_order_32(
- CNAT_DEBUG_FLAG_UDP_OUTSIDE_PACKET_DUMP);
- }
- mp->param[1] = spp_host_to_net_byte_order_32(argv[1]);
-
- platform_send_msg(mp);
-
-
-
-}
-
-void cnat_debug_udp_crc (int argc, unsigned long *argv)
-{
- spp_api_cnat_p2mp_debug_request_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_P2MP_DEBUG_REQUEST;
- mp->dump_type =
- spp_host_to_net_byte_order_16(CNAT_DEBUG_GENERIC_COMMAND_DEBUG_FLAGS);
-
- if (spp_host_to_net_byte_order_32(argv[0]) == 1) {
- mp->param[0] = spp_host_to_net_byte_order_32(
- CNAT_DEBUG_FLAG_UDP_INSIDE_CHECKSUM_MODIFY);
- } else {
- mp->param[0] = spp_host_to_net_byte_order_32(
- CNAT_DEBUG_FLAG_UDP_OUTSIDE_CHECKSUM_MODIFY);
- }
- mp->param[1] = spp_host_to_net_byte_order_32(argv[1]);
-
- platform_send_msg(mp);
-
-}
-
-void cnat_db_allocate_port_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_port_allocate_t *mp;
-
-
- if (!argc) {
- printf("no port# defined\n");
- return;
- }
-
- if ( argc < 3) {
- printf("no port# defined\n");
- return;
- }
-
- if ((argc == 3) && (argv[0] == 0) && (argv[1] == 0) && (argv[2] == 0)) {
- printf("no port# defined\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_PORT_ALLOCATE;
- mp->nr_ports = argv[0];
- mp->nodd_ports = argv[1];
- mp->neven_ports = argv[2];
- mp->vrf = 1;
-
- platform_send_msg(mp);
-}
-
-
-void spp_api_cnat_port_clear_t_handler(spp_api_cnat_port_clear_t *mp)
-{
- u32 i;
- cnat_portmap_t *pm = 0;
- u16 *pm_inuse = 0;
-#ifdef LB_PORT
- u32 my_instance = 1;
-#endif
-
-
- /*
- * this command is run after db create port
- * vrf is hardcode to 1
- */
-
- /* Already have a portmap vector for this VRF? */
- for (i = 0; i < vec_len(cnat_portmap_indices_by_vrf); i++) {
- if (cnat_portmap_indices_by_vrf[i] == mp->vrf) {
- pm = cnat_portmaps[i];
- pm_inuse = cnat_portmaps_inuse[i];
- goto found_portmaps;
- }
- }
-
- printf("portmap is not created 0x%d\n",
- vec_len(cnat_portmap_indices_by_vrf));
- return;
-
-found_portmaps:
- if (mp->pm_index >= vec_len(pm)) {
- printf("invalid port_index 0x%d >= 0x%d\n",
- mp->pm_index, vec_len(pm));
- return;
- }
-
-#ifdef LB_PORT
- cnat_port_free(pm, pm_inuse, my_instance,
- mp->pm_index, PORT_SINGLE, mp->port);
-#else
- cnat_port_free(pm, pm_inuse,
- mp->pm_index, PORT_SINGLE, mp->port);
-#endif
- printf("\n pm_index %d port %d is deleted\n", mp->pm_index, mp->port);
-}
-
-
-
-void cnat_db_clear_port_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_port_clear_t *mp;
-
- if (!argc) {
- printf("no port# defined\n");
- return;
- }
-
- if ( argc < 2 ) {
- printf("no port# defined\n");
- return;
- }
-
- if (argc > 2) {
- printf("too many port# defined\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_PORT_CLEAR;
- mp->pm_index = argv[0];
- mp->port = argv[1];
- mp->vrf = 1;
-
- platform_send_msg(mp);
-}
-
-
-void spp_api_cnat_v4_add_vrf_map_t_handler
-(spp_api_cnat_v4_add_vrf_map_t *mp);
-
-void spp_api_cnat_v4_del_vrf_map_t_handler
-(spp_api_cnat_v4_del_vrf_map_t *mp);
-
-void spp_api_cnat_v4_add_static_port_t_handler
-(spp_api_cnat_v4_add_static_port_t *mp);
-
-void spp_api_cnat_v4_del_static_port_t_handler
-(spp_api_cnat_v4_del_static_port_t *mp);
-
-
-void cnat_db_create_vrfmap_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_add_vrf_map_t *mp;
-
- if ((argc != 4)) {
- printf("need right input\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_ADD_VRF_MAP;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- mp->o_vrf = spp_host_to_net_byte_order_16(argv[1]);
- mp->start_addr[0] = spp_host_to_net_byte_order_32(argv[2]);
- mp->end_addr[0] = spp_host_to_net_byte_order_32(argv[3]);
-
- /*
- * Some hardcoded values for the vrf ids
- */
- mp->i_vrf_id = spp_host_to_net_byte_order_32(0x00000100 | mp->i_vrf);
- mp->o_vrf_id = spp_host_to_net_byte_order_32(0x00000200 | mp->o_vrf);
-
- platform_send_msg(mp);
-}
-
-
-void cnat_db_delete_vrfmap_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_del_vrf_map_t *mp;
-
- if (argc != 4) {
- printf("need right input\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEL_VRF_MAP;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- mp->start_addr[0] = spp_host_to_net_byte_order_32(argv[2]);
- mp->end_addr[0] = spp_host_to_net_byte_order_32(argv[3]);
-
- platform_send_msg(mp);
-}
-
-void cnat_db_add_svi_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_config_svi_params_t *mp;
-
- if (argc != 3) {
- printf("need right input\n");
- return;
- }
-
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_CONFIG_SVI_PARAMS;
- mp->uidb_index = spp_host_to_net_byte_order_16(argv[1]);
- mp->svi_ipv4_addr = spp_host_to_net_byte_order_32(argv[2]);
- platform_send_msg(mp);
- return;
-}
-
-
-
-void spp_api_cnat_port_create_t_handler(spp_api_cnat_port_create_t *mp)
-{
- int i, j, k1, k2;
- int my_index;
- u32 ipv4_address;
- u16 aport;
- u32 pm_len =0;
- cnat_errno_t rv;
- u16 i_vrf;
- char *out1, *out2, *out_f;
- port_alloc_t pt1, pt2;
- cnat_vrfmap_t *my_vrfmap;
- cnat_portmap_v2_t *pm = 0;
- u32 *firstp =0;
- u32 nr_ports =0;
- u32 nodd_ports = 0;
- u32 neven_ports = 0;
-#ifdef LB_PORT
- u32 my_instance = 1;
-#endif
- char out_r[12] = "allocated-r";
- char out_o[12] = "allocated-o";
- char out_e[12] = "allocated-e";
-#ifndef NO_BULK_LOGGING
- int nfv9_log_req;
-#endif
-
- nr_ports = mp->nr_ports;
- nodd_ports = mp->nodd_ports;
- neven_ports = mp->neven_ports;
- i_vrf = mp->vrf;
-
- /*
- * this command is run after db create vrfmap
- * or using vrf id in init function
- */
- /* Already have a portmap vector for this VRF? */
- pool_foreach (my_vrfmap, cnat_map_by_vrf, ({
- if ((my_vrfmap->status == S_RUN) &&
- (my_vrfmap->i_vrf == i_vrf)) {
- pm = my_vrfmap->portmap_list;
- pm_len = vec_len(pm);
- if (pm_len) {
- goto found_portmaps;
- }
- }
- }));
-
- printf("need to run db create vrfmaps first for this vrf0x%d\n", pm_len);
- return;
-
-found_portmaps:
-
- if ((nr_ports + nodd_ports + neven_ports ) > (PORTS_PER_ADDR)) {
- printf("invalid port# nr_ports %d + odd %d + even %d "
- "should be less than 200 \n", nr_ports, nodd_ports, neven_ports);
- return;
- }
-
- /*
- * first port
- */
- firstp = nr_ports ? (&nr_ports) : (nodd_ports ? (&nodd_ports) : (&neven_ports));
- if (!(*firstp)) {
- printf("invalid port# nr_ports %d odd %d even %d ",
- nr_ports, nodd_ports, neven_ports);
- }
- out_f = nr_ports ? out_r : (nodd_ports ? out_o : out_e);
-
- rv = cnat_dynamic_port_alloc_v2 (pm, PORT_ALLOC_ANY, PORT_S_ODD,
- &my_index, &ipv4_address, &aport,
- cnat_static_port_range
-#ifndef NO_BULK_LOGGING
- , BULKSIZE_FROM_VRFMAP(my_vrfmap),
- &nfv9_log_req
-#endif
- , 0,
- &(my_vrfmap->rseed_ip)
- );
-
- if (rv != CNAT_SUCCESS) {
- printf("failed-o\n");
- return;
- }
- printf("%s %8d %10x %8d\n", out_f,
- my_index, ipv4_address, aport);
-
- (*firstp)--;
-
- for (i=0; i < nr_ports; i++) {
- rv = cnat_dynamic_port_alloc_v2 (pm, PORT_ALLOC_DIRECTED, PORT_SINGLE,
- &my_index, &ipv4_address, &aport,
- cnat_static_port_range
-#ifndef NO_BULK_LOGGING
- , BULKSIZE_FROM_VRFMAP(my_vrfmap),
- &nfv9_log_req
-#endif
- , 0,
- &(my_vrfmap->rseed_ip)
- );
-
- if (rv == CNAT_SUCCESS) {
- printf("%s %8d %10x %8d\n", out_r,
- my_index, ipv4_address, aport);
- } else {
- printf("%s failed\n", __FUNCTION__);
- return;
- }
- }
-
- if (nodd_ports > neven_ports) {
- k1 = nodd_ports;
- k2 = neven_ports;
- pt1 = PORT_S_ODD;
- pt2 = PORT_S_EVEN;
- out1 = out_o;
- out2 = out_e;
- } else {
- k1= neven_ports;
- pt1 = PORT_S_EVEN;
- k2 = nodd_ports;
- pt2 = PORT_S_ODD;
- out1 = out_e;
- out2 = out_o;
- }
-
- j = 0;
- for (i=0; i < k1; i++) {
- rv = cnat_dynamic_port_alloc_v2 (pm, PORT_ALLOC_DIRECTED, pt1,
- &my_index, &ipv4_address, &aport,
- cnat_static_port_range
-#ifndef NO_BULK_LOGGING
- , BULKSIZE_FROM_VRFMAP(my_vrfmap),
- &nfv9_log_req
-#endif
- , 0,
- &(my_vrfmap->rseed_ip)
- );
-
- if (rv == CNAT_SUCCESS) {
- printf("%s %8d %10x %8d\n", out1,
- my_index, ipv4_address, aport);
- } else {
- printf("%s failed\n", __FUNCTION__);
- return;
- }
-
- if (j < k2) {
- rv = cnat_dynamic_port_alloc_v2 (pm, PORT_ALLOC_DIRECTED, pt2,
- &my_index, &ipv4_address, &aport,
- cnat_static_port_range
-#ifndef NO_BULK_LOGGING
- , BULKSIZE_FROM_VRFMAP(my_vrfmap),
- &nfv9_log_req
-#endif
- , 0,
- &(my_vrfmap->rseed_ip)
- );
-
- if (rv == CNAT_SUCCESS) {
- printf("%s %8d %10x %8d\n", out2,
- my_index, ipv4_address, aport);
- j++;
- } else {
- printf("%s failed\n", __FUNCTION__);
- return;
- return;
- }
- }
- }
-}
-
-
-void cnat_db_create_port_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_port_create_t *mp;
-
- if (argc != 4) {
- printf("no proper input defined\n");
- return;
- }
-
- if ((argv[0] == 0) && (argv[1] == 0) && (argv[2] == 0)) {
- printf("no port# defined\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_PORT_CREATE;
- mp->nr_ports = argv[0];
- mp->nodd_ports = argv[1];
- mp->neven_ports = argv[2];
- mp->vrf = argv[3];
-
- platform_send_msg(mp);
-}
-
-void spp_api_cnat_port_delete_t_handler(spp_api_cnat_port_delete_t *mp)
-{
- u32 pm_len;
- cnat_vrfmap_t *my_vrfmap;
- cnat_portmap_v2_t *pm = 0;
-
- u32 my_index, my_port;
- u16 i_vrf;
-#ifdef LB_PORT
- u32 my_instance = 1;
-#endif
-
- my_index = mp->pm_index;
- my_port = mp->port;
- i_vrf = mp->vrf;
-
- /*
- * this command is run after db create port
- */
- pool_foreach (my_vrfmap, cnat_map_by_vrf, ({
- if (my_vrfmap->i_vrf == i_vrf) {
- pm = my_vrfmap->portmap_list;
- pm_len = vec_len(pm);
- if (pm_len) {
- goto found_portmaps;
- }
- }
- }));
-
- printf("portmap is not created 0x%d\n",
- vec_len(cnat_portmap_indices_by_vrf));
- return;
-
-found_portmaps:
- if (my_index >= pm_len) {
- printf("invalid port_index 0x%d >= 0x%d\n",
- my_index, pm_len);
- return;
- }
-
-#ifdef LB_PORT
- cnat_port_free_v2(pm, my_instance,
- my_index, PORT_SINGLE, mp->port,cnat_static_port_range);
-#else
- cnat_port_free_v2(pm, my_index, PORT_SINGLE, mp->port,cnat_static_port_range);
-#endif
- printf("\n pm_index %d port %d is deleted\n", mp->pm_index, mp->port);
-}
-
-void cnat_db_delete_port_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_port_clear_t *mp;
-
- if (argc != 3) {
- printf("no proper input defined\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
-
- mp->_spp_msg_id = SPP_API_CNAT_PORT_DELETE;
- mp->pm_index = argv[0];
- mp->port = argv[1];
- mp->vrf = argv[2];
- platform_send_msg(mp);
-}
-
-void cnat_db_create_static_fwd_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_add_static_port_t *mp;
-
- if (argc != 4) {
- printf("need right input\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_ADD_STATIC_PORT;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- mp->i_ip = spp_host_to_net_byte_order_32(argv[1]);
- mp->i_port = spp_host_to_net_byte_order_16(argv[2]);
- mp->proto = argv[3];
-
- platform_send_msg(mp);
- return;
-}
-
-void cnat_db_create_static_fwd_stby_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_add_static_port_t *mp;
-
- if (argc != 7) {
- printf("need right input\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_ADD_STATIC_PORT;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- mp->i_ip = spp_host_to_net_byte_order_32(argv[1]);
- mp->i_port = spp_host_to_net_byte_order_16(argv[2]);
- mp->proto = argv[3];
- mp->o_vrf_id = spp_host_to_net_byte_order_32(argv[4]);
- mp->o_ip = spp_host_to_net_byte_order_32(argv[5]);
- mp->o_port = spp_host_to_net_byte_order_16(argv[6]);
-
-printf("\ni_vrf %d, ip 0x%x, port %d, o_ip, port %d", mp->i_vrf, mp->i_ip, mp->i_port, mp->o_ip, mp->o_port);
-
- platform_send_msg(mp);
- return;
-}
-
-void cnat_db_delete_static_fwd_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_del_static_port_t *mp;
-
- if (argc != 3) {
- printf("need right input\n");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEL_STATIC_PORT;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- mp->i_ip = spp_host_to_net_byte_order_32(argv[1]);
- mp->i_port = spp_host_to_net_byte_order_16(argv[2]);
-
- platform_send_msg(mp);
- return;
-}
-
-void cnat_nfv9_create_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_config_nfv9_logging_t *mp;
-
- if (argc < 3) {
- printf("nfv9 create i_vrf ip_addr port [refresh_rate] [timeout] [mtu]");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_CONFIG_NFV9_LOGGING;
- mp->enable = 1;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
-
- mp->ipv4_address = spp_host_to_net_byte_order_32(argv[1]);
- mp->port = spp_host_to_net_byte_order_16(argv[2]);
-
- if (argc > 3) {
- mp->refresh_rate = spp_host_to_net_byte_order_16(argv[3]);
- mp->timeout_rate = spp_host_to_net_byte_order_16(argv[4]);
- mp->path_mtu = spp_host_to_net_byte_order_16(argv[5]);
- } else {
- mp->refresh_rate = spp_host_to_net_byte_order_16(1000);
- mp->timeout_rate = spp_host_to_net_byte_order_16(30);
- mp->path_mtu = spp_host_to_net_byte_order_16(1500);
- }
- platform_send_msg(mp);
-}
-
-void cnat_delete_cgn (int argc, unsigned long *argv)
-{
- void *mp_send;
- spp_api_cnat_del_cgn_t *mp;
- u32 mp_size;
-
- mp_size = sizeof(spp_api_cnat_del_cgn_t);
-
- mp = spp_msg_api_alloc(mp_size);
- memset(mp, 0, mp_size);
-
- mp->_spp_msg_id = SPP_API_CNAT_DEL_CGN;
-
- mp_send = mp;
-
- platform_send_msg(mp);
-}
-
-void cnat_debug_global_all (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_debug_global_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEBUG_GLOBAL;
- mp->debug_flag = CNAT_DEBUG_GLOBAL_ALL;
-
- platform_send_msg(mp);
-}
-
-void cnat_debug_global_none (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_debug_global_t *mp;
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_DEBUG_GLOBAL;
- mp->debug_flag = CNAT_DEBUG_NONE;
-
- platform_send_msg(mp);
-}
-
-
-void cnat_bulk_cmd (int argc, unsigned long *argv)
-{
- void *mp_send;
-
- if (argc < 1) {
- printf("\nargc = %d", argc);
- printf("\n1. bulk cmd [0=static-port, 1=bulk_vrf, 2=policy_knob]");
- return;
- }
-
-
- switch (argv[0]) {
- case 0:
- {
- spp_api_cnat_v4_bulk_add_delete_static_port_t *mp;
- spp_api_cnat_v4_add_static_port_t *mp_sp;
- u32 mp_size =
- sizeof(spp_api_cnat_v4_bulk_add_delete_static_port_t) +
- (sizeof(spp_api_cnat_v4_add_static_port_t))*2;
-
- mp = spp_msg_api_alloc(mp_size);
- memset(mp, 0, mp_size);
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_BULK_ADD_DELETE_STATIC_PORT;
-
- mp->num_static_port_entries = spp_host_to_net_byte_order_32(3);
-
- mp_sp = (spp_api_cnat_v4_add_static_port_t *) &(mp->pad2);
-
- mp_sp->_spp_msg_id = spp_host_to_net_byte_order_16(
- SPP_API_CNAT_V4_ADD_STATIC_PORT);
- mp_sp->proto = 2;
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x1);
- mp_sp->i_ip = spp_host_to_net_byte_order_32(0x11111111);
- mp_sp->i_port = spp_host_to_net_byte_order_16(0x7777);
-
- mp_sp++;
-
-
- mp_sp->_spp_msg_id = spp_host_to_net_byte_order_16(
- SPP_API_CNAT_V4_ADD_STATIC_PORT);
- mp_sp->proto = 1;
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x1);
- mp_sp->i_ip = spp_host_to_net_byte_order_32(0x22222222);
- mp_sp->i_port = spp_host_to_net_byte_order_16(0x6666);
-
- mp_sp++;
-
-
- mp_sp->_spp_msg_id = spp_host_to_net_byte_order_16(
- SPP_API_CNAT_V4_ADD_STATIC_PORT);
- mp_sp->proto = 1;
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x1);
- mp_sp->i_ip = spp_host_to_net_byte_order_32(0x33333333);
- mp_sp->i_port = spp_host_to_net_byte_order_16(0x5555);
-
- mp_send = mp;
-
- }
- break;
-
- case 1:
- {
- spp_api_cnat_v4_bulk_vrf_map_t *mp;
- spp_api_cnat_v4_single_vrf_map_req *mp_sp;
-
- u32 mp_size = sizeof(spp_api_cnat_v4_bulk_vrf_map_t) +
- (sizeof(spp_api_cnat_v4_single_vrf_map_req))*2;
-
- mp = spp_msg_api_alloc(mp_size);
- memset(mp, 0, mp_size);
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_BULK_VRF_MAP;
-
- mp->num_vrfmap_entries = spp_host_to_net_byte_order_32(3);
-
- mp_sp = (spp_api_cnat_v4_single_vrf_map_req *)
- &(mp->vrf_policy_enable);
-
- mp_sp->i_vrf_id = spp_host_to_net_byte_order_32(0xe0000001);
- mp_sp->o_vrf_id = spp_host_to_net_byte_order_32(0xe0000000);
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x1);
- mp_sp->o_vrf = spp_host_to_net_byte_order_16(0x0);
- mp_sp->start_addr = spp_host_to_net_byte_order_32(0x11111100);
- mp_sp->end_addr = spp_host_to_net_byte_order_32(0x111111ff);
- mp_sp->vrf_policy_enable = spp_host_to_net_byte_order_16(0x3);
- mp_sp->tcp_mss_value = spp_host_to_net_byte_order_16(0x111);
- mp_sp->vrf_nfv9_logging_ipv4_address = spp_host_to_net_byte_order_32(0x11000001);
- mp_sp->vrf_nfv9_logging_udp_port = spp_host_to_net_byte_order_16(0x1001);
- mp_sp->vrf_nfv9_refresh_rate = spp_host_to_net_byte_order_16(0x100);
- mp_sp->vrf_nfv9_timeout_rate = spp_host_to_net_byte_order_16(0x10);
- mp_sp->vrf_nfv9_path_mtu = spp_host_to_net_byte_order_16(0x100);
-
- mp_sp++;
-
- mp_sp->i_vrf_id = spp_host_to_net_byte_order_32(0xe0000002);
- mp_sp->o_vrf_id = spp_host_to_net_byte_order_32(0xe0000000);
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x2);
- mp_sp->o_vrf = spp_host_to_net_byte_order_16(0x0);
- mp_sp->start_addr = spp_host_to_net_byte_order_32(0x22220000);
- mp_sp->end_addr = spp_host_to_net_byte_order_32(0x2222ffff);
- mp_sp->vrf_policy_enable = spp_host_to_net_byte_order_16(0x1);
- mp_sp->tcp_mss_value = spp_host_to_net_byte_order_16(0x222);
- mp_sp->vrf_nfv9_logging_ipv4_address = spp_host_to_net_byte_order_32(0x22000002);
- mp_sp->vrf_nfv9_logging_udp_port = spp_host_to_net_byte_order_16(0x2002);
- mp_sp->vrf_nfv9_refresh_rate = spp_host_to_net_byte_order_16(0x200);
- mp_sp->vrf_nfv9_timeout_rate = spp_host_to_net_byte_order_16(0x20);
- mp_sp->vrf_nfv9_path_mtu = spp_host_to_net_byte_order_16(0x200);
-
- mp_sp++;
-
- mp_sp->i_vrf_id = spp_host_to_net_byte_order_32(0xe0000003);
- mp_sp->o_vrf_id = spp_host_to_net_byte_order_32(0xe0000007);
- mp_sp->i_vrf = spp_host_to_net_byte_order_16(0x3);
- mp_sp->o_vrf = spp_host_to_net_byte_order_16(0x7);
- mp_sp->start_addr = spp_host_to_net_byte_order_32(0x33333000);
- mp_sp->end_addr = spp_host_to_net_byte_order_32(0x33333fff);
- mp_sp->vrf_policy_enable = spp_host_to_net_byte_order_16(0x1);
- mp_sp->tcp_mss_value = spp_host_to_net_byte_order_16(0x333);
- mp_sp->vrf_nfv9_logging_ipv4_address = spp_host_to_net_byte_order_32(0x33000003);
- mp_sp->vrf_nfv9_logging_udp_port = spp_host_to_net_byte_order_16(0x3003);
- mp_sp->vrf_nfv9_refresh_rate = spp_host_to_net_byte_order_16(0x300);
- mp_sp->vrf_nfv9_timeout_rate = spp_host_to_net_byte_order_16(0x30);
- mp_sp->vrf_nfv9_path_mtu = spp_host_to_net_byte_order_16(0x300);
-
- mp_send = mp;
- }
- break;
-
- case 2:
- {
- spp_api_cnat_v4_bulk_policy_knob_t *mp;
-
- u32 mp_size =
- sizeof(spp_api_cnat_v4_bulk_policy_knob_t) +
- (sizeof(spp_api_cnat_v4_single_vrf_map_req))*2;
-
- mp = spp_msg_api_alloc(mp_size);
- memset(mp, 0, mp_size);
-
- mp->_spp_msg_id = SPP_API_CNAT_V4_BULK_POLICY_KNOB;
-
- mp->port_limit = spp_host_to_net_byte_order_16(345);
- mp->icmp_timeout = spp_host_to_net_byte_order_16(300);
- mp->udp_init_timeout = spp_host_to_net_byte_order_16(175);
- mp->udp_act_timeout = spp_host_to_net_byte_order_16(133);
- mp->tcp_init_timeout = spp_host_to_net_byte_order_16(222);
- mp->tcp_act_timeout = spp_host_to_net_byte_order_16(2345);
-
- mp->nat_policy_enable = spp_host_to_net_byte_order_32(0x7);
-
- mp->global_nfv9_logging_ipv4_address = spp_host_to_net_byte_order_32(0x77777777);
- mp->global_nfv9_logging_udp_port = spp_host_to_net_byte_order_16(0x7007);
- mp->global_nfv9_refresh_rate = spp_host_to_net_byte_order_16(0x700);
- mp->global_nfv9_timeout_rate = spp_host_to_net_byte_order_16(0x70);
- mp->global_nfv9_path_mtu = spp_host_to_net_byte_order_16(0x700);
-
- mp_send = mp;
- }
- break;
-
-
- default:
- printf("\nargv[2] = %d", argv[2]);
- printf("\n2. bulk cmd [0=static-port, 1=bulk_vrf, 2=policy_knob+bulk_vrf]");
- return;
-
- }
- platform_send_msg(mp_send);
-}
-
-void cnat_nfv9_delete_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_v4_config_nfv9_logging_t *mp;
-
- if (argc != 1) {
- printf("nfv9 delete i_vrf ");
- return;
- }
-
- mp = spp_msg_api_alloc (sizeof (*mp));
- memset(mp, 0, sizeof (*mp));
- mp->_spp_msg_id = SPP_API_CNAT_V4_CONFIG_NFV9_LOGGING;
- mp->enable = 0;
- mp->i_vrf = spp_host_to_net_byte_order_16(argv[0]);
- platform_send_msg(mp);
-}
-
-void cnat_generic_cmd (int argc, unsigned long *argv)
-{
- spp_api_cnat_generic_command_request_t *mp;
-
- if (argc != 9) {
- printf("generic command core type p1 p2 p3 p4 p5 p6 p7 ");
- return;
- }
-
- /*
- * Allocate a large buffer for message req and resp structure
- */
- mp = spp_msg_api_alloc (MAX_DEBUG_BUFFER_SIZE);
- memset(mp, 0, MAX_DEBUG_BUFFER_SIZE);
- mp->_spp_msg_id = SPP_API_CNAT_GENERIC_COMMAND_REQUEST;
- mp->core_num = argv[0];
- mp->params[0] = spp_host_to_net_byte_order_32(argv[1]);
- mp->params[1] = spp_host_to_net_byte_order_32(argv[2]);
- mp->params[2] = spp_host_to_net_byte_order_32(argv[3]);
- mp->params[3] = spp_host_to_net_byte_order_32(argv[4]);
- mp->params[4] = spp_host_to_net_byte_order_32(argv[5]);
- mp->params[5] = spp_host_to_net_byte_order_32(argv[6]);
- mp->params[6] = spp_host_to_net_byte_order_32(argv[7]);
- mp->params[7] = spp_host_to_net_byte_order_32(argv[8]);
- platform_send_msg(mp);
-}
-
-u32 icmp_sent_timestamps; /* 32 KB array per core */
-u8 v4_pkt_count = 0;
-
-cnat_icmp_msg_t icmp_msg_gen_allowed ()
-{
-#ifdef DISABLE_ICMP_THROTTLE_FOR_DEBUG_PURPOSE
- return CNAT_ICMP_MSG;
-#else
- u32 current_timestamp;
- spp_node_main_vector_t *nmv;
- u32 updated_timestamp;
-
- v4_pkt_count ++;
-
- nmv = spp_get_node_main_vectorized_inline();
-
- current_timestamp = nmv->ticks / nmv->ticks_per_second;
-
- PLATFORM_UPDATE_TIMESTAMP
- if (PREDICT_FALSE(icmp_sent_timestamps != updated_timestamp)) {
- v4_pkt_count = 1;
- /* update timestamp */
- icmp_sent_timestamps = updated_timestamp;
- }
- if (PREDICT_TRUE(v4_pkt_count <= cnat_main_db_icmp_rate_limit_core)) {
- return CNAT_ICMP_MSG;
- } else {
- return CNAT_NO_ICMP_MSG;
- }
-#endif
-}
-
-u32 v6_icmp_sent_timestamps; /* 32 KB array per core */
-u8 v6_pkt_count = 0;
-
-cnat_icmp_msg_t v6_icmp_msg_gen_allowed ()
-{
-#ifdef DISABLE_ICMP_THROTTLE_FOR_DEBUG_PURPOSE
- return CNAT_ICMP_MSG;
-#else
- u32 current_timestamp;
- spp_node_main_vector_t *nmv;
- u32 updated_timestamp;
-
- nmv = spp_get_node_main_vectorized_inline();
-
- current_timestamp = nmv->ticks / nmv->ticks_per_second;
- PLATFORM_UPDATE_TIMESTAMP
- v6_pkt_count ++;
-
- if (PREDICT_FALSE(v6_icmp_sent_timestamps != updated_timestamp)) {
- v6_pkt_count = 1;
- /* update timestamp */
- v6_icmp_sent_timestamps = updated_timestamp;
- }
- if (PREDICT_TRUE(v6_pkt_count <= cnat_main_db_icmp_rate_limit_core)) {
- return CNAT_ICMP_MSG;
- } else {
- return CNAT_NO_ICMP_MSG;
- }
-#endif
-}
-
-u32 v4_udp_crc_zero_timestamps;
-u32 v4_udp_crc_zero_pkt_count = 0;
-int v4_crc_zero_udp_allowed ()
-{
- PLATFORM_V4_CRC_ZERO_UDP_ALLOWED
- /* Currently not supported for Brahmos. we need to take care of this */
- spp_node_main_vector_t *nmv;
- u32 hash_value, current_timestamp;
-
- nmv = spp_get_node_main_vectorized_inline();
-
- current_timestamp = nmv->ticks / nmv->ticks_per_second;
- v4_udp_crc_zero_pkt_count++;
- if (PREDICT_FALSE(v4_udp_crc_zero_timestamps != current_timestamp)) {
- v4_udp_crc_zero_pkt_count = 1;
- v4_udp_crc_zero_timestamps = current_timestamp;
- }
- if (PREDICT_TRUE(v4_udp_crc_zero_pkt_count <=
- crc_zero_udp_rate_limit_core)) {
- return 1;
- } else {
- return 0;
- }
-}
-
-/*
- * ipv4_decr_ttl_n_calc_csum()
- * - It decrements the TTL and calculates the incremental IPv4 checksum
- */
-
-ALWAYS_INLINE(
-void ipv4_decr_ttl_n_calc_csum(ipv4_header *ipv4))
-{
- u32 checksum;
- u16 old;
-
- old = ntohs(*(u16 *)&ipv4->ttl);
-
- /* Decrement TTL */
- ipv4->ttl--;
-
- /* Calculate incremental checksum */
- checksum = old + (~ntohs(*(u16 *)&ipv4->ttl) & 0xFFFF);
- checksum += ntohs(ipv4->checksum);
- checksum = (checksum & 0xFFFF) + (checksum >> 16);
- ipv4->checksum = htons(checksum + (checksum >> 16));
-}
-
-ALWAYS_INLINE(
-void calc_ipv4_checksum (ipv4_header *ipv4))
-{
- u16 *data = (u16 *) ipv4;
- u32 checksum = 0;
-
- checksum = crc_calc(ipv4);
-
- /* Now produce the 1's complement */
- ipv4->checksum = spp_host_to_net_byte_order_16(((u16) (~(u16)checksum)));
-}
-
-ALWAYS_INLINE(
-void calc_v4_icmp_checksum (icmp_v4_t *icmp, int ipv4_payload_size))
-{
- u16 *data = (u16 *) icmp;
- int num_hwords = (ipv4_payload_size)/2;
- u32 checksum = 0;
-
- icmp->checksum = 0;
- if (PREDICT_FALSE((ipv4_payload_size%2) != 0)) {
- num_hwords += 1;
- /* Append 0's in the last octet */
- *((u8 *)data + ipv4_payload_size) = 0;
- }
- while (num_hwords) {
- checksum += (u32)spp_net_to_host_byte_order_16(data++);
- num_hwords--;
- }
-
- /* Add in the carry of the original sum */
- checksum = (checksum & 0xFFFF) + (checksum >> 16);
- /* Add in the carry of the final sum */
- checksum = (checksum & 0xFFFF) + (checksum >> 16);
- /* Now produce the 1's complement */
- icmp->checksum = spp_host_to_net_byte_order_16(((u16) (~(u16)checksum)));
-}
-
-ALWAYS_INLINE(
-void calc_v6_icmp_checksum (ipv6_header_t *ipv6, u16 ip_payload_size))
-{
- u16 *data;
- u16 *data1;
- int i;
- icmp_v6_t *icmp;
- int num_hwords = (ip_payload_size)/2;
- u32 checksum = 0;
- pseudo_v6_header_t pseudo_header;
-
- icmp = (icmp_v6_t *) ((u8 *)ipv6 + IPV6_HDR_LEN);
- data = (u16 *) icmp;
- icmp->checksum = 0;
-
-#if 1
- if (PREDICT_FALSE((ip_payload_size%2) != 0)) {
- num_hwords += 1;
- /* Append 0's in the last octet */
- *((u8 *)data + ip_payload_size) = 0;
- }
-#endif
-
- /* construct the pseudo header */
-
- pseudo_header.src_addr[0] = ipv6->src_addr[0];
- pseudo_header.src_addr[1] = ipv6->src_addr[1];
- pseudo_header.src_addr[2] = ipv6->src_addr[2];
- pseudo_header.src_addr[3] = ipv6->src_addr[3];
- pseudo_header.dst_addr[0] = ipv6->dst_addr[0];
- pseudo_header.dst_addr[1] = ipv6->dst_addr[1];
- pseudo_header.dst_addr[2] = ipv6->dst_addr[2];
- pseudo_header.dst_addr[3] = ipv6->dst_addr[3];
- pseudo_header.payload_length = spp_host_to_net_byte_order_16(ip_payload_size);
- pseudo_header.next_header = spp_host_to_net_byte_order_16(ipv6->next_header);
-
- data1 = (u16 *) &pseudo_header;
-
- /* sizeof(pseudo_v6_header_t) = 36 */
- for (i = 0; i < 18; i++) {
- checksum += (u32)spp_net_to_host_byte_order_16(data1++);
- }
-
-checksum_calc:
-
- if (PREDICT_TRUE(num_hwords)) {
- checksum += (u32)spp_net_to_host_byte_order_16(data);
- num_hwords--;
- data++;
- goto checksum_calc;
- }
-
- /* Add in the carry of the original sum */
- checksum = (checksum & 0xFFFF) + (checksum >> 16);
- /* Add in the carry of the final sum */
- checksum = (checksum & 0xFFFF) + (checksum >> 16);
- /* Now produce the 1's complement */
- icmp->checksum = spp_host_to_net_byte_order_16(((u16) (~(u16)checksum)));
-}
-
-void icmp_error_generate_v6 (spp_ctx_t *ctx, u8 icmp_type,
- u8 icmp_code, u16 uidb_index) {
-
- u16 ip_hdr_len, ip_payload_size;
- u32 *src_p, * dst_p;
- icmp_v6_t *icmp;
- int i;
- ipv6_header_t *ip_old, *ip_new;
- u16 icmp_payload_len;
-
- /*
- * As per RFC 2463, we limit the maximum size of generated ICMPv6 message to * 1280. And hence if the packet is bigger than 1280, then it needs to be
- * truncated. Also, if the packet had multiple chained buffers, we need to
- * free all chained buffers, except the first one.
- */
- free_all_but_first_chained_buffers(ctx);
-
- ip_hdr_len = IPV6_HDR_LEN;
- /* offset to ip payload */
-
- ip_old = (ipv6_header_t *)PLATFORM_CTX_CURRENT_HDR;
- ip_new = (ipv6_header_t *) ((u8 *) PLATFORM_CTX_CURRENT_HDR - ICMPV6_ERR_SIZE);
- icmp = (icmp_v6_t*) ( (u8*)ip_new + ip_hdr_len);
-
- icmp_payload_len = ip_hdr_len +
- spp_net_to_host_byte_order_16(&(ip_old->payload_length)) ;
-
- ip_payload_size = ICMPV6_HDR_SIZE + icmp_payload_len;
- /*
- * There is no easy way to predict this case as the probablity that the IPv6
- * pkt is big depends on the type of traffic. Let us optimize the big
- * pkt case as it involves more processing
- *
- * If the pkt size exceeds IPV6_MIN_PATH_MTU truncate it to IPV6_MIN_PATH_MTU
- */
- if (PREDICT_TRUE((ip_payload_size + ip_hdr_len) > IPV6_MIN_PATH_MTU)) {
- ip_payload_size = IPV6_MIN_PATH_MTU - ip_hdr_len;
- }
-
- /* Following ICMP op has to be after ip header being copied */
- icmp->type = icmp_type;
- icmp->code = icmp_code;
-
- ip_new->version_trafficclass_flowlabel = spp_host_to_net_byte_order_32(
- VERSION_TRAFFICCLASS_FLOWLABEL);
- ip_new->payload_length = spp_host_to_net_byte_order_16(ip_payload_size);
- ip_new->next_header = IPV6_PROTO_ICMPV6;
- ip_new->hop_limit = 64;
- ip_new->dst_addr[0] = ip_old->src_addr[0];
- ip_new->dst_addr[1] = ip_old->src_addr[1];
- ip_new->dst_addr[2] = ip_old->src_addr[2];
- ip_new->dst_addr[3] = ip_old->src_addr[3];
-
- ip_new->src_addr[0] =
- spp_host_to_net_byte_order_32(svi_params_array[uidb_index].ipv6_addr[0]);
- ip_new->src_addr[1] =
- spp_host_to_net_byte_order_32(svi_params_array[uidb_index].ipv6_addr[1]);
- ip_new->src_addr[2] =
- spp_host_to_net_byte_order_32(svi_params_array[uidb_index].ipv6_addr[2]);
- ip_new->src_addr[3] =
- spp_host_to_net_byte_order_32(svi_params_array[uidb_index].ipv6_addr[3]);
- /* calc checksum for icmp */
-
- calc_v6_icmp_checksum(ip_new, ip_payload_size);
-#if 0
- printf("Flow = 0x%x\n", ip_new->version_trafficclass_flowlabel);
- printf("Hoplimit = 0x%x\n", ip_new->hop_limit);
- printf("Length= 0x%x\n", ip_new->payload_length);
- printf("Next header = 0x%x\n", ip_new->next_header);
- printf("Src add0 = 0x%x\n", ip_new->src_addr[0]);
- printf("Src add1 = 0x%x\n", ip_new->src_addr[1]);
- printf("Src add2 = 0x%x\n", ip_new->src_addr[2]);
- printf("Src add3 = 0x%x\n", ip_new->src_addr[3]);
- printf("Dst add0 = 0x%x\n", ip_new->dst_addr[0]);
- printf("Dst add1 = 0x%x\n", ip_new->dst_addr[1]);
- printf("Dst add2 = 0x%x\n", ip_new->dst_addr[2]);
- printf("Dst add3 = 0x%x\n", ip_new->dst_addr[3]);
- printf("Icmp type = 0x%x\n", icmp->type);
- printf("Icmp code = 0x%x\n", icmp->code);
-
- printf("\n\nICMP packet:\n");
- for (i = 0; i < 10; i ++) {
- printf("0x%x " , *((u8 *)icmp + i));
- if ((i%16) == 15) {
- printf("\n");
- }
- }
-#endif
-
- ctx->current_header -= ICMPV6_ERR_SIZE;
- ctx->current_length = ip_payload_size + ip_hdr_len;
- PLATFORM_CNAT_SET_TX_VRF(ctx,uidb_index);
-}
-
-void icmp_error_generate_v2 (ipv4_header *ip, u8 icmp_type,
- u8 icmp_code, u16 mtu, u32 src_ip)
-{
-
- u16 ip_hdr_len, ip_payload_size;
- u32 *src_p, * dst_p;
- icmp_v4_t *icmp;
-
- ip_hdr_len = (ip->version_hdr_len_words & 0xf) << 2; /* offset to ip payload */
- icmp = (icmp_v4_t*) ( (u8*)ip + ip_hdr_len);
- ip_payload_size = sizeof(icmp_v4_t) + ip_hdr_len +
- ICMP_UNREACHABLE_IP_PAYLOAD_SIZE;
-
- src_p = (u32*)
- ((u8*)ip + ip_hdr_len + ICMP_UNREACHABLE_IP_PAYLOAD_SIZE - 4);
- dst_p = (u32*) ((u8*)src_p + sizeof(ipv4_header) +
- sizeof(icmp_v4_t));
-
- while(src_p >= (u32*)ip) *dst_p-- = *src_p--;
-
- /* Following ICMP op has to be after ip header being copied */
- icmp->type = icmp_type;
- icmp->code = icmp_code;
- icmp->identifier = 0;
- icmp->sequence = 0;
- if(PREDICT_FALSE(mtu != 0)) {
- icmp->sequence = spp_host_to_net_byte_order_16(mtu);
- }
-
-
- /* build icmp header, keep original tos, identification values */
- ip->version_hdr_len_words = 0x45;
- ip->total_len_bytes = sizeof(ipv4_header) + ip_payload_size;
- ip->total_len_bytes = spp_host_to_net_byte_order_16(ip->total_len_bytes);
- ip->frag_flags_offset = 0;
- ip->ttl = 64;
- ip->protocol = ICMP_PROT;
- ip->checksum = 0;
- ip->dest_addr = ip->src_addr;
- ip->src_addr = spp_host_to_net_byte_order_32(src_ip);
-
- /* calc checksum for ip and icmp */
-
- calc_ipv4_checksum(ip);
- calc_v4_icmp_checksum( (icmp_v4_t *) ((u8*) ip + sizeof(ipv4_header)),
- ip_payload_size);
-}
-
-void icmp_error_generate (ipv4_header *ip, u8 icmp_type,
- u8 icmp_code, u16 uidb_index) {
-
- u16 ip_hdr_len, ip_payload_size;
- u32 *src_p, * dst_p;
- icmp_v4_t *icmp;
-
- ip_hdr_len = (ip->version_hdr_len_words & 0xf) << 2; /* offset to ip payload */
- icmp = (icmp_v4_t*) ( (u8*)ip + ip_hdr_len);
- ip_payload_size = sizeof(icmp_v4_t) + ip_hdr_len +
- ICMP_UNREACHABLE_IP_PAYLOAD_SIZE;
-
- src_p = (u32*)
- ((u8*)ip + ip_hdr_len + ICMP_UNREACHABLE_IP_PAYLOAD_SIZE - 4);
- dst_p = (u32*) ((u8*)src_p + sizeof(ipv4_header) +
- sizeof(icmp_v4_t));
-
- while(src_p >= (u32*)ip) *dst_p-- = *src_p--;
-
- /* Following ICMP op has to be after ip header being copied */
- icmp->type = icmp_type;
- icmp->code = icmp_code;
- icmp->identifier = 0;
- icmp->sequence = 0;
-
-
- /* build icmp header, keep original tos, identification values */
- ip->version_hdr_len_words = 0x45;
- ip->total_len_bytes = sizeof(ipv4_header) + ip_payload_size;
- ip->total_len_bytes = spp_host_to_net_byte_order_16(ip->total_len_bytes);
- ip->frag_flags_offset = 0;
- ip->ttl = 64;
- ip->protocol = ICMP_PROT;
- ip->checksum = 0;
- ip->dest_addr = ip->src_addr;
-
- ip->src_addr = spp_host_to_net_byte_order_32(svi_params_array[uidb_index].ipv4_addr);
-
- /* calc checksum for ip and icmp */
-
- calc_ipv4_checksum(ip);
- calc_v4_icmp_checksum( (icmp_v4_t *) ((u8*) ip + sizeof(ipv4_header)),
- ip_payload_size);
-#if 0
- printf("version_hdr_len_words = 0x%x\n", ip->version_hdr_len_words);
- printf("total_len_bytes = 0x%x\n", ip->total_len_bytes);
- printf("Frag = 0x%x\n", ip->frag_flags_offset);
- printf("ttl = 0x%x\n", ip->ttl);
- printf("Protocol = 0x%x\n", ip->protocol);
- printf("checksum = 0x%x\n", ip->checksum);
- printf("Dest addr = 0x%x\n", ip->dest_addr);
- printf("Src addr = 0x%x\n", ip->src_addr);
- printf("Icmp type = 0x%x\n", icmp->type);
- printf("Icmp code = 0x%x\n", icmp->code);
-#endif
-
-}
-
-int icmpv4_generate_with_throttling_v2 (spp_ctx_t *ctx, ipv4_header *ipv4,
- int icmp_type, int icmp_code,
- u16 mtu, u32 src_ip)
-{
- u16 ip_hdr_len;
- icmp_v4_t *icmp;
- u16 rx_uidb_index = ctx->ru.rx.uidb_index;
- if (icmp_msg_gen_allowed()) {
- free_all_but_first_chained_buffers(ctx);
- icmp_error_generate_v2(ipv4, icmp_type, icmp_code, mtu, src_ip);
- ctx->current_length = (u16)
- ((u8*)ctx->current_header - ctx->packet_data) +
- spp_net_to_host_byte_order_16(&ipv4->total_len_bytes);
- PLATFORM_CNAT_SET_TX_VRF(ctx,rx_uidb_index);
- return 1;
- } else {
- return 0;
- }
-}
-
-int icmpv4_generate_with_throttling (spp_ctx_t *ctx, ipv4_header *ipv4,
- u16 rx_uidb_index)
-{
- int icmp_type;
- int icmp_code;
-
- if (icmp_msg_gen_allowed()) {
- /* ICMP error would be small, so one buffer is enough. Clear the other */
- free_all_but_first_chained_buffers(ctx);
-
- icmp_type = ICMPV4_TIMEEXCEEDED;
- icmp_code = ICMPV4_TIMTTL;
- icmp_error_generate(ipv4, icmp_type, icmp_code, rx_uidb_index);
- ctx->current_length = (u16)
- ((u8*)ctx->current_header - ctx->packet_data) +
- spp_net_to_host_byte_order_16(&ipv4->total_len_bytes);
- PLATFORM_CNAT_SET_TX_VRF(ctx,rx_uidb_index);
- return 1;
- } else {
- return 0;
- }
-}
-
-int icmpv4_generate_with_throttling_v1 (spp_ctx_t *ctx, ipv4_header *ipv4,
- u16 rx_uidb_index, u32 type, u32 code)
-{
- if (icmp_msg_gen_allowed()) {
- /* ICMP error would be small, so one buffer is enough. Clear the other */
- free_all_but_first_chained_buffers(ctx);
-
- icmp_error_generate(ipv4, type, code, rx_uidb_index);
- ctx->current_length = (u16)
- ((u8*)ctx->current_header - ctx->packet_data) +
- spp_net_to_host_byte_order_16(&ipv4->total_len_bytes);
- PLATFORM_CNAT_SET_TX_VRF(ctx,rx_uidb_index);
- return 1;
- } else {
- return 0;
- }
-}
-
-
-int icmpv6_generate_with_throttling (spp_ctx_t *ctx, ipv6_header_t *ipv6,
- u16 rx_uidb_index)
-{
- int icmp_type;
- int icmp_code;
-
- if (v6_icmp_msg_gen_allowed()) {
- icmp_type = ICMPV6_TIMEEXCEEDED;
- icmp_code = ICMPV6_TIMTTL;
- icmp_error_generate_v6(ctx, icmp_type, icmp_code, rx_uidb_index);
- return 1;
- } else {
- return 0;
- }
-}
-
-int icmpv6_generate_with_throttling_v1 (spp_ctx_t *ctx, ipv6_header_t *ipv6,
- u16 rx_uidb_index, u32 type, u32 code)
-{
-
- if (v6_icmp_msg_gen_allowed()) {
- icmp_error_generate_v6(ctx, type, code, rx_uidb_index);
- return 1;
- } else {
- return 0;
- }
-}
-#endif
-
-void calculate_window_scale(tcp_hdr_type *tcp_header, u8 *scale) {
-
- u8 check_options = 0;
-
- *scale = 0;
- check_options = ((tcp_header->flags & TCP_FLAG_SYN) &&
- (((tcp_header->hdr_len>>4) << 2) > sizeof(tcp_hdr_type)));
-
- if (PREDICT_FALSE(check_options)) {
- u8 *options_ptr = tcp_findoption(tcp_header, TCP_OPTION_WINDOW_SCALE);
-
- /*
- * TCP option field: | kind 1B | len 1B | value 2B|
- * where kind != [0, 1]
- */
- if (PREDICT_TRUE(options_ptr &&
- (options_ptr[1] == TCP_OPTION_WINDOW_SCALE))) {
- u8 *ptr = (u8*)(options_ptr + 2);
- *scale = *ptr;
-
- if(PREDICT_FALSE(*scale >= 14)) {
- *scale = 14;
- }
-
- return;
- }
- }
-}
-
-#if 0
-ALWAYS_INLINE(
-void cnat_log_nat44_tcp_seq_mismatch(
- cnat_main_db_entry_t *db,
- cnat_vrfmap_t *vrfmap))
-{
- /* As of now, Netflow does not require this to be logged
- * So only syslog
- */
- if(PREDICT_TRUE(db->flags & CNAT_TAC_SEQ_MISMATCH)) {
- /* Already logged ..*/
- return;
- }
- /* else, set the flag and call the log API */
-
- db->flags = db->flags | CNAT_TAC_SEQ_MISMATCH;
-
- cnat_syslog_nat44_tcp_seq_mismatch(db, vrfmap);
-}
-
-
-static int cnat_util_init (void *notused)
-{
- /* run SPP_API_CNAT_PORTMAP_CREATE first*/
- spp_msg_api_set_handler(SPP_API_CNAT_PORT_ALLOCATE,
- spp_api_cnat_port_allocate_t_handler);
-
-
- spp_msg_api_set_handler(SPP_API_CNAT_PORT_CLEAR,
- spp_api_cnat_port_clear_t_handler);
-
- /* run vrfmap config first */
- spp_msg_api_set_handler(SPP_API_CNAT_PORT_CREATE,
- spp_api_cnat_port_create_t_handler);
-
- spp_msg_api_set_handler(SPP_API_CNAT_PORT_DELETE,
- spp_api_cnat_port_delete_t_handler);
- return 0;
-}
-
-void
-print_ipv6_pkt (ipv6_header_t *ip)
-{
- u32 i, total_len, l4_len=0;
-
- u8 *pkt = (u8 *) ip;
-
- total_len = spp_net_to_host_byte_order_16(&ip->payload_length);
-
- /* we rarely need to debug > 200 bytes of packet */
- if(total_len > 200) {
- total_len = 200;
- }
-
- printf("\n======== PRINTING PKT START======\n");
- printf("======== IPv6 PAYLOAD LEN %d ===========\n", total_len);
- for (i=0; i < 40; i++) {
- printf(" %02X ", *(pkt + i));
- if(i%16==15)
- printf("\n");
- }
-
- if (ip->next_header == IPV6_PROTO_TCP) {
- printf("\n======== TCP HEADER =================\n");
- l4_len = 20;
- }
- else if (ip->next_header == IPV6_PROTO_UDP) {
- printf("\n======== UDP HEADER =================\n");
- l4_len = 8;
- }
- else if (ip->next_header == IPV6_PROTO_ICMPV6) {
- printf("\n======== ICMP HEADER =================\n");
- l4_len = 8;
- }
-
- for (i=40; i < (l4_len + 40); i++) {
- printf(" %02X ", *(pkt + i));
- }
-
- printf("\n======== LAYER4 PAYLOAD ===================\n");
- for (i=(l4_len + 40); i < total_len; i++) {
- printf(" %02X ", *(pkt + i));
- if(i%16==15)
- printf("\n");
- }
-
- printf("\n======== PRINTING PKT END =======\n");
-}
-
-
-
-PLATFORM_SPP_INIT_FUNCTION(cnat_util_init);
-#endif