summary | shortlog | log | commit | commitdiff | tree
raw | patch | inline | side by side (parent: 521f83a)
raw | patch | inline | side by side (parent: 521f83a)
| author | Tinku Mannan <tmannan@ti.com> | |
| Fri, 19 Sep 2014 14:29:13 +0000 (10:29 -0400) | ||
| committer | Tinku Mannan <tmannan@ti.com> | |
| Mon, 22 Sep 2014 21:33:36 +0000 (17:33 -0400) |
16 files changed:
index 72a8c9c3fe6dc5175b00b691dad4614effeceba5..816cba7856bc77baa87d27c50096ca430bbb7311 100755 (executable)
install -c -m 755 $(ARMV7BINDIR)/netapi/test/net_test_loopback_$(DEVICE) $(INSTALL_BIN_BASE_DIR)/net_test_loopback_$(DEVICE)
install -c -m 755 $(ARMV7BINDIR)/netapi/test/net_test_router_$(DEVICE) $(INSTALL_BIN_BASE_DIR)/net_test_router_$(DEVICE)
install -c -m 755 $(ARMV7BINDIR)/netapi/test/net_test_bench_$(DEVICE) $(INSTALL_BIN_BASE_DIR)/net_test_bench_$(DEVICE)
+ install -c -m 755 $(ARMV7BINDIR)/netapi/test/nt_bridge_$(DEVICE) $(INSTALL_BIN_BASE_DIR)/nt_bridge_$(DEVICE)
+ install -c -m 755 tools/eqos/dumpqos.sh $(INSTALL_BIN_BASE_DIR)/dumpqos.sh
install -d $(SYSCONFDIR)/transportnetlib/test
$(CP) test/net_test_config.txt $(SYSCONFDIR)/transportnetlib/test
install -c -m 755 tools/net_test_loopback_setup.sh $(SYSCONFDIR)/transportnetlib/test
install -c -m 755 tools/net_test_router_setup.sh $(SYSCONFDIR)/transportnetlib/test
install -c -m 755 tools/irqset.sh $(SYSCONFDIR)/transportnetlib/test
install -c -m 755 tools/dsp_core_setup.sh $(SYSCONFDIR)/transportnetlib/test
-
+ install -c -m 755 tools/eqos/parse_ale.sh $(SYSCONFDIR)/transportnetlib/test
+ install -c -m 755 tools/eqos/parse_ale.awk $(SYSCONFDIR)/transportnetlib/test
+ $(CP) test/eqos_config1.txt $(SYSCONFDIR)/transportnetlib/test
+ $(CP) test/eqos_config2.txt $(SYSCONFDIR)/transportnetlib/test
installdemo:
install -d $(INSTALL_BIN_BASE_DIR)
install -c -m 755 $(ARMV7BINDIR)/netapi/demo/transport_dpi_demo $(INSTALL_BIN_BASE_DIR)/
index 1b457f75949cd0e75eace9df3788ac455db2a30a..76972e6b31d5c2129c8a2c53af793d92337929d2 100755 (executable)
/// @cond INTERNAL
/* PA control buffer pool (internal) */
-#define TUNE_NETAPI_CONFIG_MAX_CTL_RXTX_BUF_SIZE 520
+#define TUNE_NETAPI_CONFIG_MAX_CTL_RXTX_BUF_SIZE 632
#define TUNE_NETAPI_CONFIG_NUM_CTL_RX_BUF 16
#define TUNE_NETAPI_CONFIG_NUM_CTL_TX_BUF 16
/// @endcond
index 5ad7b5b409caa3a5dc31c3c207f826a99462ba50..dd0cde68b2553d40c9d62873cc3860f03cda615f 100755 (executable)
nwalRouteType_t routeType; /**< Optional: Routing priority,
* @see nwal.h for nwalRouteType_t
*/
+ uint16_t egress_swith_port; /* learned swithc port #, from ale_table */
} NETCP_CFG_ROUTE_T;
index 823b28bca2bef1066653626d9b55241e8506a2df..4b08a6f034f5b3a8b0ef2921028b1b56c788c8e8 100755 (executable)
NETCP_CFG_MACIF_T netapi_netcpCfgCreateMacInterface(NETAPI_T h,
uint8_t *p_mac,
uint8_t *p_mac_remote,
- int iface_no,
- int switch_port,
+ int iface_no, /* index, from 0 to n */
+ int switch_port,
NETCP_CFG_ROUTE_HANDLE_T route,
NETCP_CFG_VLAN_T vlan, //future
uint16_t etherType,
CPPI_PARAM_NOT_SPECIFIED, /* Use default flow configured to NWAL if packet is routed to host */
QMSS_PARAM_NOT_SPECIFIED, /* Use default queue configured to NWAL if packet is routed to host */
0,
+ 0,
0
};
nwal_RetValue retValue;
NetapiNwalTransInfo_t *pTransInfo;
nwal_TransID_t trans_id;
-
+ nwal_AppId appId;
if ((!n) || (!p_mac)) {*err = NETAPI_ERR_BAD_INPUT; return -1;}
*err =0;
/* set up MacInfo */
memcpy(&macInfo.macAddr,p_mac,6);
+
if(p_mac_remote)
{
macInfo.validParams |= NWAL_SET_MAC_VALID_PARAM_REMOTE_MAC;
{
macInfo.validParams |=
NWAL_SET_MAC_VALID_PARAM_ROUTE_TYPE;
+
+ if(route->routeType == NWAL_ROUTE_PKTTYPE_EQOS)
+ {
+ macInfo.egress_switch_port = route->egress_swith_port;
+ //macInfo.appRxPktFlowId = route->p_flow;
+ //macInfo.appRxPktQueue = route->p_dest_q;
+ macInfo.routeType = NWAL_ROUTE_PKTTYPE_EQOS;
+ printf("netapi_netcpCfgCreateMacInterface: mac: 0x%x:0x%x:0x%x:0x%x:0x%x:0x%x, swp: 0x%x\n",
+ macInfo.macAddr[0],
+ macInfo.macAddr[1],
+ macInfo.macAddr[2],
+ macInfo.macAddr[3],
+ macInfo.macAddr[4],
+ macInfo.macAddr[5],
+ macInfo.egress_switch_port);
+ macInfo.matchAction = NWAL_MATCH_ACTION_HOST;
+ }
}
+
netapip_netcpCfgBuildRoute(route,
&macInfo.appRxPktFlowId,
&macInfo.appRxPktQueue,
&macInfo.routeType);
}
+
+
+ appId = (nwal_AppId) (NETAPI_NETCP_MATCH_GENERIC_MAC | iface_no);
+
retValue = nwal_setMacIface( ((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle,
trans_id,
- (nwal_AppId) (NETAPI_NETCP_MATCH_GENERIC_MAC | iface_no),
+ appId,
&macInfo,
&pTransInfo->handle);
if(retValue != nwal_OK)
p_mac, iface_no, state,vlan,
(void *) pTransInfo->handle);
netapip_freeTransInfo(pTransInfo);
- return (NETAPI_NETCP_MATCH_GENERIC_MAC | iface_no);
+ return (NETCP_CFG_MACIF_T)appId;
}
/********************************************************************
index 5479199143e16ecd63db971173f2c5649ee7cb40..5d4287e926d50c1a78630c0daa0201b3c2d360c8 100755 (executable)
IFDMA_OBJS= $(ARMV7OBJDIR)/netapi/test/ifdma_test.o
-NTB_OBJS= $(ARMV7OBJDIR)/netapi/test/nt_bridge.o $(ARMV7OBJDIR)/netapi/test/stubs.o
+NTB_OBJS= $(ARMV7OBJDIR)/netapi/test/nt_bridge.o $(ARMV7OBJDIR)/netapi/test/fdb.o $(ARMV7OBJDIR)/netapi/test/stubs.o
NT_BENCH_OBJS= $(ARMV7OBJDIR)/netapi/test/net_test_bench.o $(ARMV7OBJDIR)/netapi/test/stubs.o
all: tests
-tests: $(ARMV7BINDIR)/netapi/test/.created $(ARMV7BINDIR)/netapi/test/net_test_loopback_$(DEVICE) $(ARMV7BINDIR)/netapi/test/net_test_router_$(DEVICE) $(ARMV7BINDIR)/netapi/test/net_test_bench_$(DEVICE)
+tests: $(ARMV7BINDIR)/netapi/test/.created $(ARMV7BINDIR)/netapi/test/net_test_loopback_$(DEVICE) $(ARMV7BINDIR)/netapi/test/net_test_router_$(DEVICE) $(ARMV7BINDIR)/netapi/test/net_test_bench_$(DEVICE) $(ARMV7BINDIR)/netapi/test/nt_bridge_$(DEVICE)
clean:
rm -f $(ARMV7OBJDIR)/netapi/test/*.o
diff --git a/ti/runtime/netapi/test/eqos_config1.txt b/ti/runtime/netapi/test/eqos_config1.txt
--- /dev/null
@@ -0,0 +1,24 @@
+queueBase = 6440
+flowBase = 0
+vlanId = 0
+ingressDefPri = 0
+port = 1
+mode = dscp
+priority_override= 0
+pbit_map_default = 0 0
+pbit_map_0 = 0 0
+pbit_map_1 = 0 0
+pbit_map_2 = 0 0
+pbit_map_3 = 0 0
+pbit_map_4 = 0 0
+pbit_map_5 = 0 8
+pbit_map_6 = 0 0
+pbit_map_7 = 0 0
+#dscp_ma flow queue
+dscp_map_default = 0 0
+dscp_map_0 = 0 0
+dscp_map_1 = 0 0
+dscp_map_2 = 0 0
+dscp_map_3 = 0 0
+dscp_map_4 = 0 0
+
diff --git a/ti/runtime/netapi/test/eqos_config2.txt b/ti/runtime/netapi/test/eqos_config2.txt
--- /dev/null
@@ -0,0 +1,24 @@
+queueBase = 6440
+flowBase = 0
+vlanId = 0
+ingressDefPri = 0
+port = 2
+mode = dscp
+priority_override= 0
+pbit_map_default = 0 0
+pbit_map_0 = 0 0
+pbit_map_1 = 0 0
+pbit_map_2 = 0 0
+pbit_map_3 = 0 0
+pbit_map_4 = 0 0
+pbit_map_5 = 0 8
+pbit_map_6 = 0 0
+pbit_map_7 = 0 0
+#dscp_ma flow queue
+dscp_map_default = 0 0
+dscp_map_0 = 0 0
+dscp_map_1 = 0 0
+dscp_map_2 = 0 0
+dscp_map_3 = 0 0
+dscp_map_4 = 0 0
+
diff --git a/ti/runtime/netapi/test/fdb.c b/ti/runtime/netapi/test/fdb.c
--- /dev/null
@@ -0,0 +1,425 @@
+/**********************************************************
+ * file: fdb.c
+ * purpose: netcp configurations routines
+ **************************************************************
+ * FILE: fdb.c
+ *
+ * DESCRIPTION: linux bridge forwarding data base processing for
+ * user space offload
+ *
+ * REVISION HISTORY:
+ *
+ * Copyright (c) Texas Instruments Incorporated 2013
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ *
+ * Neither the name of Texas Instruments Incorporated nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ ****************************************************************************/
+#include "stdlib.h"
+#include "stdio.h"
+#include "netapi.h"
+#include "fdb.h"
+
+
+extern FDB_ENTRY_T ale_cfg[];
+extern NETCP_CFG_ROUTE_T test_route[];
+extern uint16_t num_learned_macs;
+
+
+
+static OFFLOAD_DB_T our_fdb[2][OFFMAX]; //list offloaded, current and next
+static OFFLOAD_DB_T perm_do[PFDBMAX]; //white list
+static OFFLOAD_DB_T perm_dont[FDBMAX]; //black list`
+static OFFLOAD_DB_T learned[OFFMAX]; //filtered learned list`
+static int cur_off =-1; //which db has been loaded
+static int n_cur_off=0; //# of items offloaded
+
+//linux bridge fdb stuff
+//static struct our_fdb_entry linux_fdb[FDBMAX];
+
+//**********************************************************
+//Internal prototypes
+//**********************************************************
+
+//find a free slot
+int ntoff_find_free_slot(OFFLOAD_DB_T * pdb,int sz)
+{
+int s;
+for(s=0;s<sz;s++)
+{
+ if (pdb[s].flags==0x00000000)
+ {
+ return s;
+ }
+}
+return -1;
+}
+
+//find matching slot
+int ntoff_find_slot(OFFLOAD_DB_T * pdb,__u8 * p_mac, __u8 switch_port,int sz)
+{
+int s;
+for(s=0;s<sz;s++)
+{
+ if (pdb[s].flags==0x00000000) continue;
+ if (pdb[s].switch_port != switch_port) continue;
+ if (memcmp(p_mac, &pdb[s].mac_addr[0],6)) continue;
+ return s;
+}
+return -1;
+}
+
+//delete
+void ntoff_delete(OFFLOAD_DB_T pdb[], int sz)
+{
+}
+
+//startup
+int ntoff_start(void)
+{
+ return 0;
+}
+
+//shutdown
+int ntoff_stop(void)
+{
+ ntoff_delete(&our_fdb[cur_off][0], n_cur_off);
+ return 0;
+}
+
+//*************************************************
+//manipulate the permanent do & don't lists
+//************************************************
+int ntoff_add_do_perm(unsigned char *p_mac,int switch_port)
+{
+ int s = ntoff_find_free_slot(perm_do,PFDBMAX);
+ if (s<0) return -1; //no room
+ memcpy(perm_do[s].mac_addr,p_mac,6);
+ perm_do[s].switch_port=switch_port;
+ perm_do[s].flags=OUR_FSB_INUSE|OUR_FSB_PERM;
+ return 0;
+}
+int ntoff_del_do_perm(unsigned char *p_mac, int switch_port)
+{
+ int s = ntoff_find_slot(perm_do,p_mac,switch_port,PFDBMAX);
+ if (s<0) return -1; //not found
+ perm_do[s].flags=0x00000000; //mark it is as free
+ return 0;
+
+}
+int ntoff_add_dont_perm(unsigned char *p_mac, int switch_port)
+{
+ int s = ntoff_find_free_slot(perm_dont,FDBMAX);
+ if (s<0) return -1; //no room
+ memcpy(perm_dont[s].mac_addr,p_mac,6);
+ perm_dont[s].switch_port=switch_port;
+ perm_dont[s].flags=OUR_FSB_INUSE|OUR_FSB_PERM;
+ return 0;
+
+}
+int ntoff_del_dont_perm(unsigned char *p_mac, int switch_port)
+{
+ int s = ntoff_find_slot(perm_dont,p_mac,switch_port,FDBMAX);
+ if (s<0) return -1; //not found
+ perm_dont[s].flags=0x00000000; //mark it is as free
+ return 0;
+}
+//**************************
+//ADD macs
+//**************************
+int ntoff_add_macs(NETAPI_T h, NETCP_CFG_ROUTE_HANDLE_T r , int fast)
+{
+ int i;
+ int err;
+ NETCP_CFG_ROUTE_HANDLE_T route;
+ NETCP_CFG_FLOW_T flow;
+ nwalLocCxtInfo_t info;
+ NETAPI_HANDLE_T * n = (NETAPI_HANDLE_T *) h;
+
+ memset(&route, 0, sizeof(NETCP_CFG_ROUTE_HANDLE_T));
+ memset(&flow, 0, sizeof(NETCP_CFG_FLOW_T));
+
+ memset(&info, 0, sizeof(nwalLocCxtInfo_t));
+
+ nwal_getLocCxtInfo(((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle, &info);
+
+
+ n_cur_off=0;
+ //perm entries 1st
+ for(i=0;i<PFDBMAX;i++)
+ {
+ if (perm_do[i].flags & OUR_FSB_INUSE)
+ {
+ netapi_netcpCfgCreateMacInterface(
+ h,
+ &perm_do[i].mac_addr[0],
+ NULL,
+ n_cur_off,
+ 0,
+ //perm_do[i].switch_port == 1 ? (NETCP_CFG_ROUTE_HANDLE_T)&test_route[0]:(NETCP_CFG_ROUTE_HANDLE_T)&test_route[1],
+ (NETCP_CFG_ROUTE_HANDLE_T)&test_route[perm_do[i].switch_port -1],
+ (NETCP_CFG_VLAN_T ) NULL,
+ 0,
+ 1,
+ &err);
+ perm_do[i].ifno = n_cur_off;
+ n_cur_off+=1;
+ }
+ }
+ printf("ntoff_add_mac: num_learned_macs: %d\n", num_learned_macs);
+ //learned list next
+ for(i=0; (i < num_learned_macs) && (i < 32) ;i++)
+
+ //for(i=0;(i<OFFMAX)&&(n_cur_off<OFFMAX);i++)
+ {
+ if (learned[i].flags & OUR_FSB_INUSE)
+ {
+ printf("ntoff_add_macs: index: %d\n", i);
+ netapi_netcpCfgCreateMacInterface(
+ h,
+ &learned[i].mac_addr[0],
+ NULL,
+ n_cur_off,
+ 0,
+ //learned[i].switch_port == 1 ? (NETCP_CFG_ROUTE_HANDLE_T)&test_route[0]:(NETCP_CFG_ROUTE_HANDLE_T)&test_route[1],
+ (NETCP_CFG_ROUTE_HANDLE_T)&test_route[learned[i].switch_port-1],
+ (NETCP_CFG_VLAN_T ) NULL,
+ 0,
+ 1,
+ &err);
+ learned[i].ifno = n_cur_off;
+ n_cur_off+=1;
+ }
+ }
+ return n_cur_off;
+}
+//***************************
+//DEL MACS
+//***************************
+int ntoff_del_macs(NETAPI_T h)
+{
+int i;
+int err;
+
+ //perm entries
+ for(i=0;i<PFDBMAX;i++)
+ {
+ if (perm_do[i].flags & OUR_FSB_INUSE)
+ {
+ netapi_netcpCfgDelMac(h, perm_do[i].ifno ,&err);
+ perm_do[i].ifno = 0;
+ n_cur_off-=1;
+ }
+ }
+ //learned entries
+ for(i=0;(i<OFFMAX)&&(n_cur_off>=0);i++)
+ {
+ if (learned[i].flags & OUR_FSB_INUSE)
+ {
+ netapi_netcpCfgDelMac(h, learned[i].ifno ,&err);
+ learned[i].ifno = 0;
+ n_cur_off-=1;
+ }
+ }
+ return 0;
+
+}
+
+
+
+//*************************
+//do_offload
+// - read what linux is seeing
+// - build newoffload list:
+// -- perm do list +
+// -- newoffload (sorted by maxage)
+// -- oldoffload
+//*************************
+#if 0
+int ntoff_do_offload(NETAPI_T nh, int fast)
+{
+ int next_cur = !cur_off;
+ int i;
+ int new_count=0;
+ //read bridges DB
+ new = ntoff_read_fdb(linux_fdb,FDBMAX);
+ new = nt_sort_and_filter_fdb(linux_fdb,learned,new); //sort list, filter out ones that match perm_do[], perm_dont[];
+
+ //build the new offload db
+ //1st copy over permanent entries frin perm_do[] list
+ for(i=0; (new_count<OFFMAX)&&(i<PFDBMAX); )
+ {
+ if (perm_do[i].switch_port == 0xff)
+ {
+ i+=1;
+ }
+ else
+ {
+ our_fdb[next_cur][new_count].mac_addr= perm_do[i].mac_addr;
+ our_fdb[next_cur][new_count].switch_port = perm_do[i].switch_port;
+ our_fdb[next_cur][new_count].flags=OUR_FSB_INUSE|OUR_FSB_PERM;
+ i+=1;
+ new_count+=1;
+ }
+ }
+ //now copy over sorted & filtered new entries from linux's db
+ for (i=0;(new_count<OFFMAX) && (i<new))
+ {
+ our_fdb[next_cur][new_count].mac_addr= linux_fdb[i].mac_addr;
+ our_fdb[next_cur][new_count].switch_port= linux_fdb[i].switch_port;
+ our_fdb[next_cur][new_count].flags=OUR_FSB_INUSE;
+ i+=1;
+ new_count+=1;
+ }
+ //if we have room, now copy ones from the old list that we want to keep
+ for (i=0; (new_count<OFFMAX) && (i<OFFMAX); )
+ {
+
+ }
+
+ //mark the rest of the entries as not in use
+ for(i=new_count; i< OFFMAX; i++) our_fdb[next_cur][new_count].flags=0x00000000;
+
+
+ //delete old entries
+ ntoff_delete(&our_fdb[cur_off][0], n_cur_off);
+
+ //add new entries
+ ntoff_add(&our_fdb[next_cur][0], new_count);
+
+ //flip entries
+ cur_off= next_cur;
+ n_cur_off= new_count;
+
+}
+
+
+//******************
+// read the fdb
+// return #entries
+//******************
+int ntoff_read_fdb(struct our_fdb_entry fdb[], int max_fdb)
+{
+ FILE * f = fopen("/sys/class/net/br0/brforward", "r");
+ //FILE * f = fopen("blah.fdb", "r");
+ int n=0;
+ if (f) {
+ n = fread(fdb, sizeof(struct our_fdb_entry),max_fdb , f);
+ fclose(f);
+ }
+ return n;
+}
+#endif
+
+/********************************
+ * filter & sort learned list
+ *********************************/
+int ntoff_sort_and_filter(struct our_fdb_entry raw[],OFFLOAD_DB_T pl[] ,int sz)
+{
+ int i,j;
+ int s;
+
+ for(i=0,j=0; (i<sz)&&(j<OFFMAX);)
+ {
+ if(raw[i].is_local) {i+=1; continue;}
+ if(raw[i].ageing_timer_value > THRESH_OFF) { i+=1; continue;}
+ s = ntoff_find_slot(perm_dont,&raw[i].mac_addr[0], raw[i].switch_port,FDBMAX);
+ if (s>=0) {i+=1; continue;}
+ s = ntoff_find_slot(perm_do,&raw[i].mac_addr[0], raw[i].switch_port,PFDBMAX);
+ if (s>=0) {i+=1; continue;}
+ //OK to learn
+ pl[j].switch_port = raw[i].switch_port;
+ memcpy(&pl[j].mac_addr[0], &raw[i].mac_addr[0],6);
+ pl[j].flags = OUR_FSB_INUSE | OUR_FSB_LEARN;
+ j+=1;
+ i+=1;
+ }
+ //zap the rest of the table
+ for(i=j;i<OFFMAX;i++) pl[i].flags= 0x00;
+
+ return j;
+}
+
+/*******************************
+ * learn what the Linux bridge knows
+ ******************************************/
+int ntoff_learn(void)
+{
+ int new;
+ new = ntoff_sort_and_filter(&ale_cfg, learned,32);
+ return 0;
+
+}
+
+//*******************************
+//show stuff
+//*******************************
+void nt_print_fdb(char* title, OFFLOAD_DB_T *p, int sz)
+{
+ int i;
+ printf("%s \n", title);
+ printf("MAC switch_port FLAGS\n");
+
+ for (i=0;i<sz;i++)
+ {
+ if (p[i].flags & OUR_FSB_INUSE) printf("%x-%x-%x-%x-%x-%x %d %x\n",
+ p[i].mac_addr[0],
+ p[i].mac_addr[1],
+ p[i].mac_addr[2],
+ p[i].mac_addr[3],
+ p[i].mac_addr[4],
+ p[i].mac_addr[5],
+ p[i].switch_port, p[i].flags);
+}
+}
+
+void ntoff_show(void)
+{
+ nt_print_fdb("perm_dont:",perm_dont,FDBMAX);
+ nt_print_fdb("perm do:", perm_do,PFDBMAX);
+ nt_print_fdb("learned:", learned, OFFMAX);
+}
+
+//#define TEST
+#ifdef TEST
+unsigned char m1[6] = {0x00,0x01,0x2,0x3,0x4,0x5};
+unsigned char m2[6] = {0x00,0x01,0x2,0x3,0x4,0x6};
+
+void main()
+{
+ ntoff_start();
+ ntoff_add_do_perm(m1,1);
+ ntoff_add_do_perm(m2,2);
+ ntoff_learn();
+ ntoff_show();
+ ntoff_del_do_perm(m2,2);
+ ntoff_del_do_perm(m1,1);
+ ntoff_stop();
+
+}
+
+#endif
diff --git a/ti/runtime/netapi/test/fdb.h b/ti/runtime/netapi/test/fdb.h
--- /dev/null
@@ -0,0 +1,140 @@
+/**********************************************************
+ * file: fdb.h
+ * purpose: netcp configurations routines
+ **************************************************************
+ * FILE: fdb.c
+ *
+ * DESCRIPTION: linux bridge forwarding data base processing for
+ * user space offload
+ *
+ * REVISION HISTORY:
+ *
+ * Copyright (c) Texas Instruments Incorporated 2013
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ *
+ * Neither the name of Texas Instruments Incorporated nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ ****************************************************************************/
+#include "stdlib.h"
+#include "stdio.h"
+#include "netapi.h"
+//#include "fdb.h"
+
+#define __u8 unsigned char
+#define __u32 unsigned int
+#define FDBMAX 128
+#define PFDBMAX 8
+#define OFFMAX 16
+#define THRESH_OFF 50 //aging timer threshold: don't bother offloading entries < THRESH_OFF
+
+#define MAX_INTERFACES 2
+#define MAX_DSCP_ENTRIES 64
+#define MAX_PBIT_ENTRIES 8
+
+#define ntBridge_INIT_CONFIG_FLOW_BASE "flowBase"
+#define ntBridge_INIT_CONFIG_QUEUE_BASE "queueBase"
+#define ntBridge_INIT_CONFIG_VLAN_ID "vlanId"
+#define ntBridge_INIT_CONFIG_INGRESS_DEF_PRI "ingressDefPri"
+#define ntBridge_INIT_CONFIG_PORT "port"
+#define ntBridge_INIT_CONFIG_DSCP_MAP_DEFAULT "dscp_map_default"
+#define ntBridge_INIT_CONFIG_PBIT_MAP_DEFAULT "pbit_map_default"
+
+//#define ntBridge_INIT_CONFIG_DSCP_MAP "dscpMap"
+//#define ntBridge_INIT_CONFIG_PBIT_MAP "pbitMap"
+#define ntBridge_INIT_CONFIG_QOS_MODE "mode"
+
+
+typedef struct{
+ char flowBase[512];
+ char queueBase[512];
+ char vlanId[512];
+ char ingressDefPri[512];
+ char port[512];
+ char dscpMapQDefault[512];
+ char dscpMapFDefault[512];
+ char dscpMapQ[64][512];
+ char dscpMapF[64][512];
+ char pbitMapQDefault[512];
+ char pbitMapFDefault[512];
+ char pbitMapQ[8][512];
+ char pbitMapF[8][512];
+ char ctrlBitMap[512];
+} ntBridgeCfgFile_T;
+
+
+typedef struct{
+ char mac[32][512];
+ char switch_port[32][512];
+} ntBridgeAleCfgFile_T;
+
+typedef struct {
+unsigned char mac[32][6];
+uint8_t switch_port[32];
+} ntBridgeAleCfg_T;
+
+//the bridge fdb entry
+typedef struct our_fdb_entry
+{
+ uint8_t mac_addr[6];
+ uint8_t switch_port;
+ uint8_t is_local;
+ uint32_t ageing_timer_value; //jiffies
+ uint32_t unused;
+} FDB_ENTRY_T;
+
+//our offload db
+typedef struct offload_db_t
+{
+ __u8 mac_addr[6];
+ __u8 switch_port; //
+ __u8 ifno; //
+ __u32 spare0;
+ __u32 flags;
+#define OUR_FSB_INUSE 0x80000000
+#define OUR_FSB_PERM 0x40000000
+#define OUR_FSB_LEARN 0x20000000
+#define OUR_FSB_SKIP 0x00000001
+} OFFLOAD_DB_T;
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
index 4ac3aca795a99983e9fb4f56ba2e16989750723d..19dacdd5ac79a80281a9a6213a6d7d91e525f407 100755 (executable)
printf("\n");
}
-#if 0
-#ifdef netTest_MULTI_THREAD
- for (i=0;i < TUNE_NETAPI_NUM_CORES;i++)
- {
- if(scheduler[i])
- {
- netapi_schedGetStats(scheduler[i],&tmp_npL[0],&tmp_cyclesL[0],&tmp_ccyclesL[0]);
- npL = tmp_npL[0]+tmp_npL[1];
- cyclesL = tmp_cyclesL[0]+tmp_cyclesL[1];
- ccyclesL = tmp_ccyclesL[0]+tmp_ccyclesL[1];
- }
- }
-#else
-netapi_schedGetStats(our_sched, &npL,&cyclesL,&ccyclesL);
-#endif
-#endif
if(pPaStats)
{
}
}
+
+void parse_simple_param_u8(char* input_str, uint8_t *val)
+{
+ if (strlen(input_str))
+ {
+ *val = (uint8_t)strtol(input_str, NULL, 0);
+ }
+}
+
void parse_simple_param_u16(char* input_str, uint16_t *val)
{
if (strlen(input_str))
index f6c373a8731b0b5d3e7f08cb75fbadefe172229d..8d1c3b7a40871aef62eea6cffe2c207b6d60254b 100755 (executable)
long exceptionPktsOther;
} netTestStats_T;
-#if 1
typedef struct
{
long ip[5];
long udp[2];
} netTestHead_T;
-#endif
+
+
+
+
+
void house(NETAPI_SCHED_HANDLE_T *s);
void netTest_utilCreateInterfaces(uint8_t num_macs, uint8_t num_ips);
PKTIO_METADATA_T meta[], int n_pkts,
uint64_t ts );
+void parse_simple_param_u8(char* input_str, uint8_t *val);
+void parse_simple_param_u16(char* input_str, uint16_t *val);
+void parse_simple_param_u32(char* input_str, uint32_t *val);
+
#endif
diff --git a/ti/runtime/netapi/test/nt_bridge.c b/ti/runtime/netapi/test/nt_bridge.c
--- /dev/null
@@ -0,0 +1,1238 @@
+/******************************************
+ * File: nt_bridge.c
+ * Purpose: netcp bridge offload prototypes.
+ **************************************************************
+ * FILE: nt_bench.c
+ *
+ * DESCRIPTION: netapi user space transport
+ * library test application : benchmarks
+ *
+ * REVISION HISTORY: rev 0.0.1
+ *
+ * Copyright (c) Texas Instruments Incorporated 2013-2014
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions
+ * are met:
+ *
+ * Redistributions of source code must retain the above copyright
+ * notice, this list of conditions and the following disclaimer.
+ *
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the
+ * distribution.
+ *
+ * Neither the name of Texas Instruments Incorporated nor the names of
+ * its contributors may be used to endorse or promote products derived
+ * from this software without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+
+ *****************************************/
+
+#include <stdio.h>
+#include <stdlib.h>
+#include <unistd.h>
+#include <string.h>
+#include <signal.h>
+#include <pthread.h>
+#include <sched.h>
+
+#include "trie.h"
+#include "string.h"
+#include "netapi.h"
+#include "pktio.h"
+#include <ti/drv/sa/salld.h>
+#include "net_test_sa_utils.h"
+#include "net_test_utils.h"
+#include "net_test_thread_utils.h"
+#include "fdb.h"
+
+#if defined(DEVICE_K2H)
+#include <ti/drv/qmss/device/k2h/src/qmss_device.c>
+#include <ti/drv/cppi/device/k2h/src/cppi_device.c>
+#elif defined (DEVICE_K2K)
+#include <ti/drv/qmss/device/k2k/src/qmss_device.c>
+#include <ti/drv/cppi/device/k2k/src/cppi_device.c>
+#elif defined (DEVICE_K2L)
+#include <ti/drv/qmss/device/k2l/src/qmss_device.c>
+#include <ti/drv/cppi/device/k2l/src/cppi_device.c>
+#elif defined (DEVICE_K2E)
+#include <ti/drv/qmss/device/k2e/src/qmss_device.c>
+#include <ti/drv/cppi/device/k2e/src/cppi_device.c>
+#else /*Default */
+#include <ti/drv/qmss/device/k2h/src/qmss_device.c>
+#include <ti/drv/cppi/device/k2h/src/cppi_device.c>
+#endif /* Device */
+
+#define netapi_timing_start hplib_mUtilGetPmuCCNT
+
+extern Rm_ServiceHandle *rmClientServiceHandle;
+
+static int scnt=0;
+static int QUIT=0;
+static int XMIT=0;
+static int CAP=0;
+volatile int RESET=0; //to reset stats
+volatile int MAC=0;
+volatile int FAST=1;
+
+uint16_t num_learned_macs = 0;
+
+uint16_t num_configured_interfaces = 0;
+
+static ntBridgeCfgFile_T config_file[MAX_INTERFACES];
+
+NETCP_CFG_ROUTE_T test_route[MAX_INTERFACES];
+
+static ntBridgeAleCfgFile_T ale_config_file;
+FDB_ENTRY_T ale_cfg[32];
+
+
+//*********************for checksum test
+unsigned short checksum(unsigned short *p, int len)
+{
+ unsigned short s=0;
+ int i;
+ for(i=0;i<len/2;i++) s+=p[i];
+ if (len&0x1) s+=(p[len/2+1]<<8);
+ return s;
+}
+
+#define NCSUM 1600
+unsigned long csum_val[NCSUM];
+unsigned long csum_num[NCSUM];
+unsigned long long csum_tim[NCSUM];
+//***********************************************
+
+#define CHECK_SET_PARAM(ARG1, ARG2) \
+ do { \
+ if(strcmp(key, ARG1) == 0) { \
+ if(d1)strncpy(ARG2,d1,netTest_CONFIG_STRING_LEN); \
+ continue; \
+ } \
+ } while(0)
+
+#define CHECK_SET_PARAM2(ARG1, ARG2, ARG3) \
+ do { \
+ if(strcmp(key, ARG1) == 0) { \
+ if(d1) strncpy(ARG2,d1,netTest_CONFIG_STRING_LEN); \
+ if(d2) strncpy(ARG3,d2,netTest_CONFIG_STRING_LEN); \
+ continue; \
+ } \
+ } while(0)
+
+
+void parse_simple_param_u8(char* input_str, uint8_t *val)
+{
+ if (strlen(input_str))
+ {
+ *val = (uint8_t)strtol(input_str, NULL, 0);
+ }
+}
+
+void parse_simple_param_u16(char* input_str, uint16_t *val)
+{
+ if (strlen(input_str))
+ {
+ *val = (uint16_t)strtol(input_str, NULL, 0);
+ }
+}
+
+void parse_simple_param_u32(char* input_str, uint32_t *val)
+{
+ if (strlen(input_str))
+ {
+ *val = (uint32_t)strtol(input_str, NULL, 0);
+ }
+}
+void parse_dscp_entry_default(char* input_str_queue,
+ char* input_str_flow,
+ paEQosModeConfig_t* pQosShapperCfg)
+{
+ int i;
+ if (strlen(input_str_queue) && strlen(input_str_flow))
+ {
+ for(i=0;i<MAX_DSCP_ENTRIES;i++)
+ {
+ pQosShapperCfg->dscpMap[i].flowOffset =(uint16_t)strtol(input_str_flow, NULL, 0);
+ pQosShapperCfg->dscpMap[i].queueOffset = (uint16_t)strtol(input_str_queue, NULL, 0);
+ }
+ }
+}
+void parse_dscp_entry(ntBridgeCfgFile_T *pConfig, paEQosModeConfig_t* pQosShapperCfg)
+{
+ int i;
+
+ for(i=0;i<MAX_DSCP_ENTRIES;i++)
+ {
+ if ((pConfig->dscpMapF[i][0]) && (pConfig->dscpMapQ[i][0]))
+ {
+ pQosShapperCfg->dscpMap[i].flowOffset =atoi(&pConfig->dscpMapF[i][0]);
+ pQosShapperCfg->dscpMap[i].queueOffset = atoi(&pConfig->dscpMapQ[i][0]);
+ printf("parse_dsp_entry[%d]: flowOffset: %d, queueOffset: %d\n",
+ i,
+ pQosShapperCfg->dscpMap[i].flowOffset,
+ pQosShapperCfg->dscpMap[i].queueOffset);
+ }
+ else
+ {
+ pQosShapperCfg->dscpMap[i].flowOffset =0;
+ pQosShapperCfg->dscpMap[i].queueOffset = 0;
+ }
+ }
+}
+
+unsigned char ntUtilHex2Dec(char *p_s)
+{
+ int val;
+ sscanf(p_s,"%x",&val);
+ return val&0xff;
+}
+
+void parse_pbit_entry_default(char* input_str_queue,
+ char* input_str_flow,
+ paEQosModeConfig_t* pQosShapperCfg)
+{
+ int i;
+ if (strlen(input_str_queue) && strlen(input_str_flow))
+ {
+ for(i=0;i<MAX_PBIT_ENTRIES;i++)
+ {
+ pQosShapperCfg->pbitMap[i].flowOffset =(uint16_t)strtol(input_str_flow, NULL, 0);
+ pQosShapperCfg->pbitMap[i].queueOffset = (uint16_t)strtol(input_str_queue, NULL, 0);
+ }
+ }
+}
+
+void parse_pbit_entry(ntBridgeCfgFile_T *pConfig, paEQosModeConfig_t* pQosShapperCfg)
+{
+ int i;
+
+ for(i=0;i<MAX_PBIT_ENTRIES;i++)
+ {
+ if ((pConfig->pbitMapF[i][0]) && (pConfig->pbitMapQ[i][0]))
+ {
+ pQosShapperCfg->pbitMap[i].flowOffset =atoi(&pConfig->pbitMapF[i][0]);
+ pQosShapperCfg->pbitMap[i].queueOffset = atoi(&pConfig->pbitMapQ[i][0]);
+ printf("parse_pbit_entry[%d]: flowOffset: %d, queueOffset: %d\n",
+ i,
+ pQosShapperCfg->pbitMap[i].flowOffset,
+ pQosShapperCfg->pbitMap[i].queueOffset);
+ }
+ else
+ {
+ pQosShapperCfg->pbitMap[i].flowOffset =0;
+ pQosShapperCfg->pbitMap[i].queueOffset = 0;
+ }
+ }
+}
+void parseOneMac(char * p_mac_str, uint8_t *p_mac)
+{
+ int index = 0;
+ int i;
+ if (strlen(&p_mac_str[0]))
+ {
+ char *pch = strtok (&(p_mac_str[0]),":");
+
+ while (pch != NULL)
+ {
+ p_mac[index] = ntUtilHex2Dec(pch);
+ index++;
+ pch = strtok (NULL,":");
+ }
+ //printf("parseOneMac: 0x%x: 0x%x: 0x%x: 0x%x: 0x%x:0x%x\n",
+ //p_mac[0],p_mac[1],p_mac[2],p_mac[3],p_mac[4],p_mac[5]);
+ }
+}
+
+
+
+void parseMac(ntBridgeAleCfgFile_T *pConfig, FDB_ENTRY_T *pAleCfg)
+{
+ int i;
+ int port = 0;
+ FDB_ENTRY_T *tmp = pAleCfg;
+ for(i=0;i<32;i++)
+ {
+ if (strlen(&pConfig->mac[i][0]))
+ {
+ parseOneMac((char*)&pConfig->mac[i][0], (uint8_t*)&tmp->mac_addr);
+ sscanf(&pConfig->switch_port[i][0],"swp%d",&tmp->switch_port);
+ tmp++;
+ num_learned_macs++;
+ /* check port to be 1 or 2 */
+ //printf("parseMac: port: %d\n", tmp->switch_port);
+ }
+}
+
+
+
+}
+void parseMode(ntBridgeCfgFile_T *pConfig, paEQosModeConfig_t* pQosShapperCfg)
+{
+
+ if (strlen(&pConfig->ctrlBitMap[0]))
+ {
+ printf("parseMode: mode: %s\n", &pConfig->ctrlBitMap[0]);
+ if (strcmp(pConfig->ctrlBitMap, "dscp") == 0)
+ {
+ pQosShapperCfg->ctrlBitMap = 0; pa_IF_EQoS_ROUTE_DP_BIT_MODE;
+
+ }
+ else if (strcmp(pConfig->ctrlBitMap, "pbit") == 0)
+ {
+ pQosShapperCfg->ctrlBitMap = pa_IF_EQoS_ROUTE_DP_BIT_MODE;
+ }
+ else
+ {
+ netapi_Log("parseMode(), invalid QOS Mode in config file \n");
+ }
+ }
+}
+
+
+
+paEQosModeConfig_t netTestQosShapperCfg[MAX_INTERFACES];
+
+
+/* Default Qos Shapper configuration for eth0 and eth1 */
+paEQosModeConfig_t netTestQosShapperCfg1 =
+{
+ pa_IF_EQoS_ROUTE_DP_BIT_MODE,
+ {0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7},
+ {0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7},
+ 1,
+ 0,
+ 0,
+ 0,
+ 0
+};
+paEQosModeConfig_t netTestQosShapperCfg2 =
+{
+ pa_IF_EQoS_ROUTE_DP_BIT_MODE,
+ {0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7},
+ {0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7,0,0,0,1,0,2,0,3,0,4,0,5,0,6,0,7},
+ 2,
+ 0,
+ 0,
+ 0,
+ 0
+};
+
+void ntBrideProcessCfgFile(FILE * fpr, ntBridgeCfgFile_T *pConfig)
+{
+ char line[MAX_LINE_LENGTH + 1];
+ int i;
+ static int sa_count = 0;
+
+ char *key, *ep;
+ char * d1, *d2, *d3;
+ char tokens[] = " :=;\n";
+ char temp_str[50];
+ memset(line, 0, MAX_LINE_LENGTH + 1);
+ //memset(pConfig, 0, sizeof(netTestConfigFile_t));
+ while (fgets(line, MAX_LINE_LENGTH + 1, fpr))
+ {
+ if(line[0]=='#')
+ continue; //skip comment
+ key = (char *)strtok(line, tokens);
+
+ d1 = (char *)strtok(NULL, tokens);
+ if (!key)
+ continue;
+ if (!d1)
+ continue;
+
+ if(strlen(d1) == 0)
+ {
+ continue;
+ }
+
+ d2 = (char *)strtok(NULL, tokens);
+
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_FLOW_BASE,&(pConfig->flowBase[0]));
+
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_QUEUE_BASE,&(pConfig->queueBase[0]));
+
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_VLAN_ID,&(pConfig->vlanId[0]));
+
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_PORT,&(pConfig->port[0]));
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_INGRESS_DEF_PRI,&(pConfig->ingressDefPri[0]));
+
+ CHECK_SET_PARAM(ntBridge_INIT_CONFIG_QOS_MODE,&(pConfig->ctrlBitMap[0]));
+ CHECK_SET_PARAM2(ntBridge_INIT_CONFIG_DSCP_MAP_DEFAULT,&pConfig->dscpMapFDefault[0],&pConfig->dscpMapQDefault[0]);
+ CHECK_SET_PARAM2(ntBridge_INIT_CONFIG_PBIT_MAP_DEFAULT,&pConfig->pbitMapFDefault[0],&pConfig->pbitMapQDefault[0]);
+
+
+ for(i=0;i<MAX_DSCP_ENTRIES;i++)
+ {
+ sprintf(temp_str,"dscp_map_%d",i);
+
+ CHECK_SET_PARAM2(temp_str,&pConfig->dscpMapF[i][0],&pConfig->dscpMapQ[i][0]);
+ }
+
+ for(i=0;i< MAX_PBIT_ENTRIES;i++)
+ {
+ sprintf(temp_str,"pbit_map_%d",i);
+ CHECK_SET_PARAM2(temp_str,&pConfig->pbitMapF[i][0],&pConfig->pbitMapQ[i][0]);
+ }
+ }
+}
+void ntBrideProcessAleCfgFile(FILE * fpr, ntBridgeAleCfgFile_T *pConfig)
+{
+ char line[MAX_LINE_LENGTH + 1];
+ int i;
+ static int sa_count = 0;
+
+ char *key, *ep;
+ char * d1, *d2, *d3;
+ char tokens[] = " =;\n";
+ char temp_str[50];
+ memset(line, 0, MAX_LINE_LENGTH + 1);
+ //memset(pConfig, 0, sizeof(netTestConfigFile_t));
+ while (fgets(line, MAX_LINE_LENGTH + 1, fpr))
+ {
+ if(line[0]=='#')
+ continue; //skip comment
+ key = (char *)strtok(line, tokens);
+
+ d1 = (char *)strtok(NULL, tokens);
+ if (!key)
+ continue;
+ if (!d1)
+ continue;
+
+ if(strlen(d1) == 0)
+ {
+ continue;
+ }
+
+ d2 = (char *)strtok(NULL, tokens);
+
+
+ for(i=0;i< 32;i++)
+ {
+ sprintf(temp_str,"mac%d",i);
+ CHECK_SET_PARAM2(temp_str,&pConfig->mac[i][0],&pConfig->switch_port[i][0]);
+ }
+ }
+}
+
+//sig handler
+void netTest_utilMySig(int x)
+{
+ QUIT=1;
+ scnt+=1;
+ printf(">ifdma-test: recv'd signal %d cnt=%d\n",x,scnt);
+ if (scnt > 10) {printf(">ifdma-test: WARNING EXITING WITH PROPER SHUTDOWN, LUTS LEFT ACTIVE\n");exit(1);}
+}
+void recv_cb_net(struct PKTIO_HANDLE_Tag * channel, Ti_Pkt* p_recv[],
+ PKTIO_METADATA_T meta[], int n_pkts,
+ uint64_t ts );
+
+
+/*************debug********************/
+void netTest_utilDumpDescr(unsigned long *p, int n)
+{
+ printf("--------dump of descriptor %d %x\n", n, (int) p);
+ printf("> %x %x %x %x %x %x %x %x\n",p[0],p[1],p[2],p[3],p[4],p[5],p[6],p[7]);
+ printf("> %x %x %x %x %x %x %x %x\n",p[8],p[9],p[10],p[11],p[12],p[13],p[14],p[15]);
+ printf("-----------------------------\n");
+}
+void netTest_utilDumpHeader(unsigned long *p, int n, int a, int r)
+{
+ printf("--------dump of header %d %x appID=%x flag1=%x\n", n, (int) p,a,r);
+ printf("> %0x %0x %0x %0x %0x %0x %0x %0x\n",
+ ntohl(p[0]),ntohl(p[1]),ntohl(p[2]),ntohl(p[3]),
+ ntohl(p[4]),ntohl(p[5]),ntohl(p[6]),ntohl(p[7]) );
+
+ printf("-----------------------------\n");
+}
+/*****************************************/
+
+
+unsigned long long CALIB=0;
+unsigned long long calibrate_idle(void)
+{
+ volatile unsigned long long at1;
+ volatile unsigned long long at2;
+ volatile unsigned long pt1;
+ volatile unsigned long pt2;
+ unsigned long long calib;
+ at1 = hplib_mUtilGetTimestamp();
+ pt1=netapi_timing_start();
+ for(;;)
+ {
+ pt2=netapi_timing_start() ;
+ if ((pt2-pt1) >= 100000) break;
+ }
+ at2 = hplib_mUtilGetTimestamp();
+
+ calib = ((unsigned long long) (pt2-pt1))/(at2-at1);
+ printf("calibrate: arm time=%lld -> arm cycles=%d calib=%lld\n", at2-at1, pt2-pt1, calib);
+
+ return calib;
+}
+
+/*******************************************
+ *************NETAPI OBJECTS***************
+ *****************************************/
+static NETAPI_CFG_T our_netapi_default_cfg=
+{
+TUNE_NETAPI_PERM_MEM_SZ,
+128, //start of packet offset for hw to place data on rx for default flow
+TUNE_NETAPI_QM_CONFIG_MAX_DESC_NUM, //max number of descriptors in system
+TUNE_NETAPI_NUM_GLOBAL_DESC, //total we will use
+TUNE_NETAPI_DEFAULT_NUM_BUFFERS*2, //#descriptors+buffers in default heap
+64, //#descriptors w/o buffers in default heap
+TUNE_NETAPI_DEFAULT_BUFFER_SIZE+128+128, //size of buffers in default heap
+128, //tail room
+256, //extra room,
+0,
+NULL
+};
+
+Pktlib_HeapHandle OurHeap; //default heap, used by producer
+PKTIO_CFG_T netcp_rx_cfg={PKTIO_RX, PKTIO_NA, PKTIO_NA, 8};
+PKTIO_CFG_T netcp_tx_cfg={PKTIO_TX, PKTIO_NA, PKTIO_NA, 12};
+PKTIO_HANDLE_T * netcp_rx_chan;
+PKTIO_HANDLE_T * netcp_tx_chan;
+NETAPI_T netapi_handle;
+
+PKTIO_CONTROL_T zap_channel_control={PKTIO_CLEAR, NULL};
+PKTIO_CONTROL_T poll_cannel_control={PKTIO_SET_POLL_FLAGS, NULL, nwal_POLL_DEFAULT_GLOB_PKT_Q};
+
+//template for fast path
+nwalTxPktInfo_t txPktInfoNoCrypto =
+{
+ NULL, /* p_pkt */
+ NWAL_TX_FLAG1_META_DATA_VALID, /* txFlags */
+ 0, /* lpbackPass */
+ 0, /* enetport */
+ 0, /* msuSize */
+ 0, /* startOffset */
+ 0, /* saOffBytes */
+ 0, /* saPayLoadLen */
+ 0, /* saAhIcvOffBytes */
+ 0, /* saAhMacSize */
+ 0, /* etherLenOffBytes */
+ netTest_MAC_HEADER_LEN, /* ipOffBytes */
+ netTest_MAC_HEADER_LEN +netTest_IP_HEADER_LEN, /* l4OffBytes */
+ netTest_UDP_HEADER_LEN, /* l4HdrLen */
+ 0, /* pseudoHdrChecksum */
+ 0 /* pLoadLen */
+};
+
+
+
+NETCP_CFG_ROUTE_T test_route1 =
+{
+0,
+NULL,
+NULL,
+0, //* to be filled in
+1
+};
+NETCP_CFG_ROUTE_T test_route2 =
+{
+0,
+NULL,
+NULL,
+0, //* to be filled in
+2
+};
+
+
+//#define WITH_QOS
+#ifdef WITH_QOS //send to qos input queue, set in device tree (6409)
+//#define QOSQ 6410 /* for wrr */
+#define QOSQ 6409 /* for SP */
+PKTIO_CFG_T direct_to_cpsw_cfg={PKTIO_TX, PKTIO_GLOBAL, QOSQ, 8};
+#else //send direct to 648, the CPSW input queue
+PKTIO_CFG_T direct_to_cpsw_cfg={PKTIO_TX, PKTIO_GLOBAL, 648, 8};
+#endif
+
+PKTIO_HANDLE_T * cpsw_tx_chan[MAX_INTERFACES];
+
+//NETCP_CFG_FLOW_T flow;
+
+
+/*************************END NETAPI OBJECTS***********************/
+
+static unsigned char all_mac[]={0,0,0,0,0,0};
+static unsigned char test_mac0[]={0,0,0,0,0,0xf};
+static unsigned char test_mac1[]={0,0,0,0,0,0xff};
+static unsigned char test_mac2[]={0xd4,0xbe,0xd9,0,0xd3,0x7e};
+static unsigned char test_mac3[]={0,0x15,0x60,0xa1,0xf7,0xbe};
+static unsigned char test_mac4[]={0xff,0xff,0xff,0x00,0x00,0x00};
+//static unsigned char test_mac0[]={0xd4,0xbe,0xd9,0x00,0xd3,0x7e};
+int test_port0 = 1;
+//static unsigned char test_mac1[]={0x00,0x15,0x60,0xa1,0xf7,0xbe};
+int test_port1 = 2;
+
+static unsigned long last_header[32/sizeof(unsigned long)];
+
+
+//stats
+int pkt_rx=0;
+int pkt_tx=0;
+unsigned long long pkt_rx_cycles=0L;
+unsigned long long pkt_tx_cycles=0L;
+unsigned long long pkt_cb_cycles=0L;
+unsigned long long idle_cycles=0L;
+volatile unsigned long long start_time;
+unsigned long long end_time;
+
+paSysStats_t netcp_stats;
+
+
+
+void netTest_utilStatsCbMt(NETAPI_T h, paSysStats_t* pPaStats)
+{
+ if(pPaStats)
+ {
+ memcpy(&netcp_stats,pPaStats, sizeof(paSysStats_t));
+ }
+}
+void netTest_utilsStatsCb(NETAPI_T h, paSysStats_t* pPaStats)
+{
+ if(pPaStats)
+ {
+ printf("C1 number of packets: %d\n", pPaStats->classify1.nPackets);
+ printf("C1 number IPv4 packets: %d\n", pPaStats->classify1.nIpv4Packets);
+ printf("C1 number IPv6 packets: %d\n", pPaStats->classify1.nIpv6Packets);
+ printf("C1 number Custom packets: %d\n", pPaStats->classify1.nCustomPackets);
+ printf("C1 number SRIO packets: %d\n", pPaStats->classify1.nSrioPackets);
+ printf("C1 number LLC/SNAP Fail packets: %d\n", pPaStats->classify1.nLlcSnapFail);
+ printf("C1 number table matched: %d\n", pPaStats->classify1.nTableMatch);
+ printf("C1 number failed table matched: %d\n", pPaStats->classify1.nNoTableMatch);
+ printf("C1 number IP Fragmented packets: %d\n", pPaStats->classify1.nIpFrag);
+ printf("C1 number IP Depth Overflow: %d\n", pPaStats->classify1.nIpDepthOverflow);
+ printf("C1 number VLAN Depth Overflow: %d\n", pPaStats->classify1.nVlanDepthOverflow);
+ printf("C1 number GRE Depth Overflow: %d\n", pPaStats->classify1.nGreDepthOverflow);
+ printf("C1 number MPLS Packets: %d\n", pPaStats->classify1.nMplsPackets);
+ printf ("C1 number of parse fail: %d\n",pPaStats->classify1.nParseFail);
+ printf("C1 number of Invalid IPv6 Opt: %d\n", pPaStats->classify1.nInvalidIPv6Opt);
+ printf("C1 number of TX IP Fragments: %d\n", pPaStats->classify1.nTxIpFrag);
+ printf ("C1 number of silent discard: %d\n",pPaStats->classify1.nSilentDiscard);
+ printf("C1 number of invalid control: %d\n", pPaStats->classify1.nInvalidControl);
+ printf ("C1 number of invalid states: %d\n",pPaStats->classify1.nInvalidState);
+ printf ("C1 number of system fails: %d\n",pPaStats->classify1.nSystemFail);
+ printf ("C2 number Packets : %d\n",pPaStats->classify2.nPackets);
+ printf ("C2 number udp : %d\n",pPaStats->classify2.nUdp);
+ printf ("C2 number tcp : %d\n",pPaStats->classify2.nTcp);
+ printf ("C2 number Custom : %d\n",pPaStats->classify2.nCustom);
+ printf ("C2 number silent drop : %d\n",pPaStats->classify2.nSilentDiscard);
+ printf ("C2 number invalid cntrl : %d\n\n",pPaStats->classify2.nInvalidControl);
+ printf ("C2 number Modify Stats Cmd Fail : %d\n\n",pPaStats->modify.nCommandFail);
+ }
+}
+
+
+//**********************************
+//producer thread
+//*********************************
+void producer_thread(int coreid)
+{
+int err;
+int i;
+Ti_Pkt * tip;
+unsigned char * pData;
+int len;
+PKTIO_METADATA_T meta = {PKTIO_META_IFDMA_TX,{0},0};
+int np;
+cpu_set_t cpu_set;
+unsigned long t1;
+unsigned long t2;
+
+ CPU_ZERO( &cpu_set);
+ CPU_SET( coreid, &cpu_set);
+ hplib_utilSetupThread(coreid,
+ &cpu_set,
+ hplib_spinLock_Type_LOL);
+ start_time = hplib_mUtilGetTimestamp();
+
+ /* Poll the default pktio channel for pkts from network */
+ for(i=0;!((volatile) QUIT);i++)
+ {
+ if (FAST)
+ {
+ //netapi_netcpCfgReqStats(netapi_handle, netTest_utilStatsCbMt, 0,&err);
+ sleep(2);
+ continue;
+ }
+ t1 = netapi_timing_start();
+ np = netapi_pktioPoll(netcp_rx_chan,NULL,&err);
+ t2 = netapi_timing_start();
+ pkt_rx+=np;
+ if (np)
+ {
+ pkt_rx_cycles += (t2-t1);
+ }
+ else
+ {
+ idle_cycles += (t2-t1);
+ }
+ if (RESET)
+ {
+ idle_cycles=0LL;
+ start_time = hplib_mUtilGetTimestamp();
+ pkt_rx=pkt_tx=0;
+ pkt_rx_cycles=pkt_tx_cycles=0LL;
+ pkt_cb_cycles=0LL;
+ RESET=0;
+ }
+ }
+ end_time = hplib_mUtilGetTimestamp();
+ printf("nt-bench: receiver DONE %d pkts rx, pkt poll cycles=% u; pkt rx cycle=%u pkt tx cycles=%u idle cycles=%lld duration=%lld ticks idle pct= %lld\n",
+ pkt_rx,
+ (unsigned)(pkt_rx ? (pkt_rx_cycles - pkt_cb_cycles)/pkt_rx : 0),
+ (unsigned) (pkt_rx ? (pkt_rx_cycles) /pkt_rx : 0),
+ (unsigned) (pkt_tx ? (pkt_tx_cycles) /pkt_tx : 0),
+ idle_cycles, (end_time-start_time),
+ (idle_cycles*100) /( CALIB* (end_time-start_time))
+ );
+ printf("Leaving producer_thread\n");
+}
+
+
+void nt_setupQosShapper(NETAPI_T h, paEQosModeConfig_t *pqosCfg)
+{
+ int i;
+ paEmacPortConfig_t ctrl;
+ nwalLocCxtInfo_t info;
+ NETAPI_HANDLE_T * n = (NETAPI_HANDLE_T *) h;
+
+ memset(&info, 0, sizeof(nwalLocCxtInfo_t));
+
+ memset(&ctrl, 0, sizeof(paEmacPortConfig_t));
+
+ ctrl.cfgType = pa_EMAC_PORT_CFG_EQoS_MODE;
+ ctrl.numEntries = 1;
+
+ ctrl.u.eQoSModeCfg = pqosCfg;
+
+ if(pqosCfg->flowBase)
+ {
+ printf("nt_setupQosShapper: flowBase from config file: %d\n", pqosCfg->flowBase);
+ ctrl.u.eQoSModeCfg->flowBase = pqosCfg->flowBase;
+ }
+ else
+ {
+ nwal_getLocCxtInfo(((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle, &info);
+ printf("nt_setupQosShapper: flowBase from nwal: %d\n", info.rxPktFlowId);
+ ctrl.u.eQoSModeCfg->flowBase = info.rxPktFlowId;
+ }
+ nwal_emacPortCfg(((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle, &ctrl);
+}
+
+
+
+//******************************
+// main program
+//*****************************
+int main(int argc, char **argv)
+{
+ int err,i;
+ int32_t errCode;
+ Pktlib_HeapIfTable* pPktifTable;
+ Pktlib_HeapCfg heapCfg;
+ long t1, t2 ;
+ cpu_set_t cpu_set;
+ FILE* fpr[MAX_INTERFACES];
+
+ //install signal handler for ^c
+ signal(SIGINT,netTest_utilMySig);
+
+ for(i=0; i < MAX_INTERFACES; i++)
+ {
+ fpr[i] = NULL;
+ }
+
+ memset(&config_file[0], 0, sizeof(ntBridgeCfgFile_T)*MAX_INTERFACES);
+ memset(&netTestQosShapperCfg[0], 0, sizeof(paEQosModeConfig_t)*MAX_INTERFACES);
+ memset(&ale_cfg, 0, sizeof(ntBridgeAleCfg_T));
+ memset(&ale_cfg, 0, sizeof(FDB_ENTRY_T)*32);
+
+ /* USE defautl Qos Shapper Configuration for 2 ports unless config files provided */
+ memcpy(&netTestQosShapperCfg[0], &netTestQosShapperCfg1, sizeof(paEQosModeConfig_t));
+ memcpy(&netTestQosShapperCfg[1], &netTestQosShapperCfg2, sizeof(paEQosModeConfig_t));
+
+ if (argc == 2)
+ {
+ fpr[0] = fopen(argv[1], "r");
+ num_configured_interfaces = 1;
+ }
+ else if (argc == 3)
+ {
+ fpr[0] = fopen(argv[1], "r");
+ fpr[1] = fopen(argv[2], "r");
+ num_configured_interfaces = 2;
+
+ }
+ else
+ {
+ printf("No qos shapper input files, using default settings\n");
+ num_configured_interfaces = 2;
+ }
+
+ for (i=0;i< num_configured_interfaces;i++)
+ {
+ if (fpr[i])
+ {
+ ntBrideProcessCfgFile(fpr[i], &config_file[i]);
+
+ parse_dscp_entry_default((char*)&config_file[i].dscpMapQDefault,
+ (char*)&config_file[i].dscpMapFDefault,
+ &netTestQosShapperCfg[i]);
+ parse_pbit_entry_default((char*)&config_file[i].pbitMapQDefault,
+ (char*)&config_file[i].pbitMapFDefault,
+ &netTestQosShapperCfg[i]);
+
+ parse_simple_param_u16((char*)&config_file[i].queueBase, &netTestQosShapperCfg[i].queueBase);
+ printf("main: netTestQos Cfg: queueBase: %d\n",netTestQosShapperCfg[i].queueBase);
+
+ parse_simple_param_u8((char*)&config_file[i].flowBase, &netTestQosShapperCfg[i].flowBase);
+ printf("main: netTestQos Cfg: flowBase: %d\n",netTestQosShapperCfg[i].flowBase);
+
+ parse_simple_param_u16((char*)&config_file[i].vlanId, &netTestQosShapperCfg[i].vlanId);
+ printf("main: netTestQos Cfg: vlanId: %d\n",netTestQosShapperCfg[i].vlanId);
+
+ parse_simple_param_u8((char*)&config_file[i].port, &netTestQosShapperCfg[i].port);
+ printf("main: netTestQos Cfg: port: %d\n",netTestQosShapperCfg[i].port);
+
+ parse_simple_param_u8((char*)&config_file[i].ingressDefPri, &netTestQosShapperCfg[i].ingressDefPri);
+ printf("main: netTestQos Cfg: ingressDefPri: %d\n",netTestQosShapperCfg[i].ingressDefPri);
+
+ parse_dscp_entry(&config_file[i], &netTestQosShapperCfg[i]);
+ parse_pbit_entry(&config_file[i], &netTestQosShapperCfg[i]);
+ parseMode(&config_file[i], &netTestQosShapperCfg[i]);
+
+ }
+ }
+
+#if 0
+ if (initRm())
+ {
+ printf("main: initRm() returned error\n");
+ exit(1);
+ }
+#endif
+ CPU_ZERO( &cpu_set);
+ CPU_SET( 0, &cpu_set);
+ hplib_utilSetupThread(0,
+ &cpu_set,
+ hplib_spinLock_Type_LOL);
+
+
+ /*******************************************/
+ /*************NETAPI STARTUP****************/
+ /*******************************************/
+
+ /* create netapi */
+ our_netapi_default_cfg.rmHandle = rmClientServiceHandle;
+ netapi_handle = netapi_init(NETAPI_SYS_MASTER, &our_netapi_default_cfg);
+ if (netapi_handle == NULL)
+ {
+ printf("main: netapi_init failure, exiting\n");
+ exit(1);
+ }
+
+ netapi_netcpCfgExceptions(netapi_handle,
+ NETCP_CFG_ALL_EXCEPTIONS,
+ NETCP_CFG_ACTION_DISCARD,
+ (NETCP_CFG_ROUTE_HANDLE_T) NULL);
+
+ /* open the main heap */
+ OurHeap = Pktlib_findHeapByName("netapi");
+ if (!OurHeap) {printf("findheapbyname fail\n"); exit(1);}
+
+ for(i = 0; i < MAX_INTERFACES; i++)
+ {
+ char temp_str[50] = {0};
+ direct_to_cpsw_cfg.qnum = netTestQosShapperCfg[i].queueBase;
+ sprintf(temp_str,"cpsw_tx%d",i);
+ cpsw_tx_chan[i]= netapi_pktioCreate(netapi_handle,&temp_str[0],NULL,
+ &direct_to_cpsw_cfg, &err);
+ if (!cpsw_tx_chan[i])
+ {
+ printf("pktio open %s failed err=%d\n", &temp_str[0], err);
+ exit(1);
+ }
+ }
+
+#if 0
+ direct_to_cpsw_cfg.qnum = netTestQosShapperCfg2.queueBase;
+
+ cpsw_tx_chan2= netapi_pktioCreate(netapi_handle,"cpsw_tx2",NULL,
+ &direct_to_cpsw_cfg, &err);
+ if (!cpsw_tx_chan2){printf("pktio open CPSW TX2 failed err=%d\n",err); exit(1);}
+#endif
+
+
+ //if we want to relay network packets, we create a handle to the
+ //default netcp receive queue here
+ netcp_rx_chan= netapi_pktioOpen(netapi_handle, NETCP_RX, (PKTIO_CB) recv_cb_net, &netcp_rx_cfg, &err);
+ if (!netcp_rx_chan) {printf("pktio open RX failed err=%d\n",err); exit(1);}
+
+ netcp_tx_chan= netapi_pktioOpen(netapi_handle, NETCP_TX, (PKTIO_CB) NULL, &netcp_tx_cfg, &err);
+ if (!netcp_tx_chan) {printf("pktio open TX failed err=%d\n",err); exit(1);}
+ else //install a fast path template into the NETCP TX channel
+ {
+ PKTIO_CONTROL_T control2;
+ control2.op = PKTIO_UPDATE_FAST_PATH;
+ PKTIO_CFG_T cfg2;
+ cfg2.fast_path_cfg.fp_send_option = PKTIO_FP_NO_CRYPTO_NO_CKSUM_PORT;
+ cfg2.fast_path_cfg.txPktInfo= &txPktInfoNoCrypto;
+ netapi_pktioControl(netcp_tx_chan, NULL, &cfg2, &control2, &err);
+ }
+
+ //build route for cpsw
+ NETCP_CFG_FLOW_T flow;
+ flow.dma_engine = 1;
+ for (i = 0; i < MAX_INTERFACES;i++)
+ {
+ if(netTestQosShapperCfg[i].flowBase)
+ {
+ flow.dma_engine = 1;
+ flow.flowid = netTestQosShapperCfg[i].flowBase;
+ test_route[i].p_flow = &flow;
+ }
+ else
+ {
+ test_route[i].p_flow =NETCP_DEFAULT_FLOW;
+ }
+ test_route[i].egress_swith_port = netTestQosShapperCfg[i].port;
+ test_route[i].routeType = NWAL_ROUTE_PKTTYPE_EQOS;
+ test_route[i].valid_params = NETCP_CFG_VALID_PARAM_ROUTE_TYPE;
+ test_route[i].p_dest_q = cpsw_tx_chan[i];
+ }
+
+/*********************************************/
+/*****************end NETAPI STARTUP**********/
+/*********************************************/
+
+
+
+ //calibrate idle
+ CALIB = calibrate_idle();
+ ntoff_start();
+ ntoff_add_do_perm(&test_mac0[0],test_port0);
+ ntoff_add_do_perm(&test_mac1[0],test_port1);
+ //ntoff_add_do_perm(&test_mac2[0],test_port0);
+ //ntoff_add_do_perm(&test_mac3[0],test_port1);
+ //ntoff_add_do_perm(&test_mac4[0],test_port0);
+
+//**************************************
+//Create a worked thread
+//***************************************
+ {
+ pthread_t *thrs;
+ int procs =1;
+ char c;
+ thrs = malloc( sizeof( pthread_t ) * procs );
+ if (thrs == NULL)
+ {
+ perror( "malloc" );
+ return -1;
+ }
+ printf( "net_test_bridge: Starting %d threads...\n", procs );
+
+ if (pthread_create( &thrs[0], NULL, (void*)producer_thread,
+ (void *)1 ))
+ {
+ perror( "pthread_create" );
+ exit(1);
+ }
+ //this thread of execution (main) now just waits on user input
+ for(;;)
+ {
+ printf(">");
+ c=getchar();
+ if (c=='c') {CAP=!CAP; printf("CAPTURE= %d\n", CAP); }
+ else if (c=='t') {XMIT=!XMIT; printf("XMIT= %d\n", XMIT); }
+ else if (c=='l')
+ {
+ FILE* fprAle = NULL;
+ system("/etc/transportnetlib/test/parse_ale.sh");
+ fprAle = fopen("ale_table.txt","r");
+ if (fprAle)
+ {
+ ntBrideProcessAleCfgFile(fprAle, &ale_config_file);
+ //for(i=0;i<32;i++)
+ parseMac(&ale_config_file, &ale_cfg[0]);
+ for(i=0;i<num_learned_macs;i++)
+ {
+ printf("parseOneMac[%d]: 0x%x: 0x%x: 0x%x: 0x%x: 0x%x:0x%x, switch port: %d\n",
+ i,
+ ale_cfg[i].mac_addr[0],
+ ale_cfg[i].mac_addr[1],
+ ale_cfg[i].mac_addr[2],
+ ale_cfg[i].mac_addr[3],
+ ale_cfg[i].mac_addr[4],
+ ale_cfg[i].mac_addr[5],
+ ale_cfg[i].switch_port);
+ }
+ ntoff_learn();
+ ntoff_show();
+ }
+ }
+ else if (c=='m')
+ {
+ unsigned add1 = netapi_timing_start();
+ if (!MAC)
+ {
+ //add macs
+ ntoff_add_macs(netapi_handle,
+ FAST? &test_route1: NULL,
+ FAST );
+
+ add1 = netapi_timing_start()-add1;
+ printf("adding MACs cycles=%d err=%x\n", add1,err);
+ MAC=1;
+ }
+
+ else
+ printf("MAC already offloaded\n");
+ }
+
+ else if (c=='!') system("sh");
+ else if (c=='n')
+ {
+ unsigned add2 = netapi_timing_start();
+ if (MAC)
+ {
+ ntoff_del_macs(netapi_handle);
+
+ add2 = netapi_timing_start()-add2;
+ printf("removing MAC cycles=%d\n",add2);
+ MAC=0;
+ } else printf("no mac offloaded\n");
+ }
+ else if (c=='f')
+ {
+ FAST=!FAST; printf("bridge offload = %s\n", FAST ? "netcp" : "user space");
+ if (!FAST) XMIT=1;
+ }
+ else if (c=='j')
+ {
+ netapi_netcpCfgReqStats(netapi_handle, netTest_utilStatsCbMt, 0,&err);
+ sleep(1);
+ netapi_netcpPoll(netapi_handle);
+ netTest_utilsStatsCb(netapi_handle, &netcp_stats);
+
+ }
+ else if (c=='s')
+ {
+ unsigned long long et= hplib_mUtilGetTimestamp();
+ printf(">NT_BENCH STATS: %d received %d xmitted, %lld idle cycles, %lld duration ticks idle=%lld\n",
+ pkt_rx,pkt_tx,
+ idle_cycles,
+ (et-start_time),
+ (idle_cycles*100)/(CALIB*(et-start_time))
+ );
+ Pktlib_HeapStats pktLibHeapStats;
+ Pktlib_getHeapStats(OurHeap, &pktLibHeapStats);
+ printf("main heap stats> #free=%d #zb=%d #garbage=%d\n",
+ pktLibHeapStats.numFreeDataPackets,
+ pktLibHeapStats.numZeroBufferPackets,
+ pktLibHeapStats.numPacketsinGarbage);
+ }
+ else if (c=='S')
+ {
+ system("/usr/bin/dumpqos.sh");
+ }
+ else if (c=='r')
+ {
+ RESET=1;
+ }
+ else if (c=='h')
+ {
+ printf("> 'q' to quit, 's' for Heap stats, 'S' for QOS stats \n");
+ printf(" 'c' to toggle capture, 'd' to dump capture, 'r' to reset idle counters\n");
+ printf(" 'm' to add macs, 'n' to remove macs 'l' to learn macs\n");
+ printf(" 'f' toggle s/w or netcp offload, '!' shell, 'S' Chksum Stats, 'h' for help\n");
+ }
+ else if (c=='d')
+ {
+ netTest_utilDumpHeader(&last_header[0], 0,0,0);
+ }
+#if 0
+ else if (c=='S')
+ {
+ int j;
+ printf(" pktsz npkts cycles/pkt_ckksum\n");
+ for(j=0;j<NCSUM;j++)
+ {
+ if(!csum_num[j]) continue;
+ printf("%d %ld %lld\n", j,
+ csum_num[j],
+ (unsigned long long) csum_tim[j]/csum_num[j]);
+
+ }
+ }
+#endif
+ else if (c == 'z')
+ {
+ nwalCtlInfo_t nwalCtrl;
+ NETAPI_HANDLE_T * n = (NETAPI_HANDLE_T *) netapi_handle;
+ memset(&nwalCtrl, 0, sizeof(nwalCtlInfo_t));
+ nwalCtrl.pktCtl= NWAL_CTRL_CFG_EMAC_IF_EGRESS_EQOS_MODE;
+ nwalCtrl.matchAction = NWAL_MATCH_ACTION_HOST;
+ nwalCtrl.appRxPktFlowId = NWAL_FLOW_NOT_SPECIFIED;
+ nwalCtrl.appRxPktQueue = NWAL_QUEUE_NOT_SPECIFIED;
+
+ for (i=0; i < MAX_INTERFACES;i++)
+ {
+ nt_setupQosShapper(netapi_handle,(paEQosModeConfig_t*)&netTestQosShapperCfg[i]);
+ }
+ nwal_control(((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle, &nwalCtrl);
+ }
+ else if (c=='q')
+ {
+ nwalCtlInfo_t nwalCtrl;
+ NETAPI_HANDLE_T * n = (NETAPI_HANDLE_T *) netapi_handle;
+ memset(&nwalCtrl, 0, sizeof(nwalCtlInfo_t));
+ nwalCtrl.pktCtl = NWAL_CTRL_CFG_EMAC_IF_EGRESS_EQOS_MODE;
+ nwalCtrl.matchAction = NWAL_MATCH_ACTION_DISCARD;
+ nwal_control(((NETAPI_GLOBAL_T*) (n->global))->nwal_context.nwalInstHandle, &nwalCtrl);
+
+ QUIT=1;
+ break;
+ }
+ }
+
+ //wait for completion
+ printf("main task now pending on thread completion\n");
+ for (i = 0; i < procs; i++)
+ pthread_join( thrs[i], NULL );
+
+ free( thrs);
+ }
+
+ /*************************************************
+ ************CLEAN UP****************************
+ ************************************************/
+ //get rid of rule, in the case that we are relaying packets
+ //also close our netcp rx channel
+ if (MAC)
+ {
+ ntoff_del_macs(netapi_handle);
+#if 0
+ netapi_netcpCfgDelMac(netapi_handle,0,&err);
+ netapi_netcpCfgDelMac(netapi_handle,1,&err);
+#endif
+ }
+ ntoff_stop();
+ netapi_pktioClose(netcp_rx_chan,&err);
+ netapi_pktioClose(netcp_tx_chan,&err);
+ for(i=0;i < MAX_INTERFACES; i++)
+ {
+ netapi_pktioDelete(cpsw_tx_chan[i],&err);
+ }
+
+
+ //done
+ netapi_shutdown(netapi_handle);
+ //!finished!
+}
+static inline void sendit(Ti_Pkt *tip, int len, int out_port)
+{
+ int err=0;
+ PKTIO_METADATA_T meta2 = {PKTIO_META_TX,{0},0};
+ nwalTxPktInfo_t meta_tx2={0};
+ if (len<60)
+ {
+ unsigned int templen;
+ char * p_pkt;
+ len=60;
+ Pktlib_getDataBuffer(tip,(uint8_t**)&p_pkt,&templen);//ignore templen
+ Cppi_setData (Cppi_DescType_HOST, (Cppi_Desc *) tip, p_pkt,len);
+ }
+ Pktlib_setPacketLen(tip,len);
+ meta_tx2.txFlag1 = NWAL_TX_FLAG1_META_DATA_VALID ;
+ meta_tx2.ploadLen = len ;
+ meta_tx2.enetPort=out_port;
+ meta2.u.tx_meta=&meta_tx2;
+ netapi_pktioSend(netcp_tx_chan,tip,&meta2,&err);
+}
+
+//receive callback for packets from net (for consumer)
+void recv_cb_net(struct PKTIO_HANDLE_Tag * channel, Ti_Pkt* p_recv[],
+ PKTIO_METADATA_T meta[], int n_pkts,
+ uint64_t ts )
+{
+ int i;
+ Ti_Pkt * tip;
+ int len;
+ unsigned long t1;
+ unsigned long t2;
+ unsigned long t3;
+ unsigned long t4;
+ pasahoLongInfo_t* protoInfo;
+ int ifno;
+ int out_port;
+
+ t1= netapi_timing_start();
+ for(i=0;i<n_pkts;i++)
+ {
+ tip = p_recv[i];
+ len = Pktlib_getPacketLen(tip);
+
+ if (CAP)
+ {
+ unsigned int templen;
+ char * p_pkt;
+ unsigned long val;
+ unsigned long cs1;
+ unsigned long cs2;
+ Pktlib_getDataBuffer(tip,(uint8_t**)&p_pkt,&templen);//ignore templen
+ memcpy(last_header,p_pkt,32);
+ cs1= netapi_timing_start();
+ val= (unsigned long) checksum((unsigned short *)p_pkt,len);
+ cs2= netapi_timing_start();
+ templen = (len > NCSUM)? NCSUM-1: len;
+ csum_num[templen]+=1;
+ csum_val[templen]+=val;
+ csum_tim[templen]+= (unsigned long long) (cs2-cs1);
+ }
+
+ if (XMIT)
+ {
+ protoInfo=nwal_mGetProtoInfo(tip);
+ ifno = nwal_mGetRxEmacPort( protoInfo);
+ //----------------------------------------------------
+ //very trivial bridging -> just output to other port!
+ //----------------------------------------------------
+ if (ifno ==1) out_port=2; else out_port=1;
+ t3= netapi_timing_start();
+ sendit(tip,len,out_port);
+ pkt_tx+=1;
+ t4= netapi_timing_start();
+ pkt_tx_cycles += (t4-t3);
+ }
+ else
+ {
+ Pktlib_freePacket((Ti_Pkt*)tip);
+ }
+ }
+ t2 = netapi_timing_start();
+ pkt_cb_cycles += (t2-t1);
+ }
+
+
+
+
+
diff --git a/ti/runtime/netapi/tools/eqos/dumpqos.sh b/ti/runtime/netapi/tools/eqos/dumpqos.sh
--- /dev/null
@@ -0,0 +1,118 @@
+#!/bin/sh\r
+#dump L2 Shaper Config and Stats\r
+#\r
+echo "**************eth0 L2 QOS:*********************"\r
+echo " "\r
+echo "HP Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-hp/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-hp/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-hp/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-hp/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR0 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr0/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr0/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr0/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr0/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR1 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr1/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr1/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr1/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr1/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR2 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr2/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr2/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr2/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr2/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR3 Queue:"\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr3/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr3/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr3/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr3/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR4 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr4/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr4/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr4/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr4/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR5 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr5/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr5/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr5/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-wrr5/bytes_discarded`\r
+echo " "\r
+\r
+echo "BE Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-be/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-be/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-be/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l21-be/bytes_discarded`\r
+echo " "\r
+\r
+echo "***********eth1 L2 QOS:**********************"\r
+echo " "\r
+echo "HP Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-hp/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-hp/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-hp/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-hp/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR0 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr0/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr0/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr0/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr0/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR1 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr1/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr1/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr1/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr1/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR2 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr2/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr2/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr2/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr2/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR3 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr3/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr3/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr3/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr3/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR4 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr4/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr4/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr4/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr4/bytes_discarded`\r
+echo " "\r
+\r
+echo "WRR5 Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr5/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr5/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr5/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-wrr5/bytes_discarded`\r
+echo " "\r
+\r
+echo "BE Queue: "\r
+echo " - Packets Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-be/packets_forwarded`\r
+echo " - Packets Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-be/packets_discarded`\r
+echo " - Bytes Sent = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-be/bytes_forwarded`\r
+echo " - Bytes Dropped = " `cat /sys/devices/soc.0/hwqueue.6/qos-inputs-2//statistics/l22-be/bytes_discarded`\r
+echo " "\r
diff --git a/ti/runtime/netapi/tools/eqos/parse_ale.awk b/ti/runtime/netapi/tools/eqos/parse_ale.awk
--- /dev/null
@@ -0,0 +1,21 @@
+BEGIN {j=0}
+// { for(i=1;i<=NF;i++){
+ if ($i ~ "addr") {f=1}
+ else if ($i ~ "port") {f=2;}
+ else if (f==1)
+ {
+ split($i,x,",")
+ printf("mac%d = %s ", j,x[1]);
+ j++;
+ f=0;
+ }
+ else if (f==2)
+ {
+ printf("swp%d \n", $i);
+ f=0;
+ }
+ }
+ }
+
+END {}
+
diff --git a/ti/runtime/netapi/tools/eqos/parse_ale.sh b/ti/runtime/netapi/tools/eqos/parse_ale.sh
--- /dev/null
@@ -0,0 +1 @@
+cat /sys/devices/soc.0/2090000.netcp/ale_table| grep "touched" | grep "addr" | awk -f /etc/transportnetlib/test/parse_ale.awk > ale_table.txt
diff --git a/ti/runtime/netapi/tools/nt_bridge_setup.sh b/ti/runtime/netapi/tools/nt_bridge_setup.sh
--- /dev/null
@@ -0,0 +1,22 @@
+#!/bin/sh
+
+if [ -z "$1"]
+ then
+ echo "Need to supply device type, either k2h, k2k"
+ exit 1
+fi
+
+# start up RM server
+/usr/bin/rmServer.out /usr/bin/device/$1/global-resource-list.dtb /usr/bin/device/$1/policy_dsp_arm.dtb
+export KERNEL_VER=$(uname -r)
+#install kernel module
+echo $KERNEL_VER
+insmod /lib/modules/$KERNEL_VER/extra/hplibmod.ko
+# run net_test_loopback applicaton, default location of config file is in /etc/transportnetlib/test,
+:
+#reprogram qos tree shaper rates
+echo "312500000" > /sys/devices/soc.0/hwqueue.4/qos-inputs-2/qos-tree-2/output_rate
+echo "312500000" > /sys/devices/soc.0/hwqueue.4/qos-inputs-2/qos-tree-3/output_rate
+
+# default config file name is net_test_config.txt
+/usr/bin/nt_bridge_$1 eqos_config1.txt eqos_config2.txt