HPLIB API integration changes
authorTinku Mannan <tmannan@ti.com>
Thu, 1 Nov 2012 20:34:05 +0000 (16:34 -0400)
committerTinku Mannan <tmannan@ti.com>
Thu, 1 Nov 2012 20:34:05 +0000 (16:34 -0400)
ti/runtime/netapi/build/Makefile
ti/runtime/netapi/netapi_util.h
ti/runtime/netapi/netsync.h
ti/runtime/netapi/src/netapi_sched.c
ti/runtime/netapi/test/build/Makefile
ti/runtime/netapi/test/net_test.c

index 692cfe370b8dc8b5f0732289a02d870071ef296f..d0a8bcc4b6598faeeff52090cc3b30095a3f882d 100755 (executable)
@@ -51,7 +51,7 @@ COMMONSRCC = \
     pktio.c \
     netapi_navig.c\
 
-CFLAGS= $(DEBUG_FLAG) -I$(NETAPI_INC_DIR) -I.  -I $(SRCDIR) -I$(PDK_INSTALL_PATH) -I$(NWAL_INSTALL_PATH) -I$(PKTLIB_INSTALL_PATH) -I$(TRANS_SDK_INSTALL_PATH) -I$(QMSS_INC_DIR) -I$(CPPI_INC_DIR) -I$(HPLIB_INC_DIR) -I$(QMSS_DEV_DIR) -I$(CPPI_DEV_DIR) -I$(NETAPI_NAVIG_INIT_SRC) -I$(SA_INSTALL_PATH) -D__ARMv7 -D_VIRTUAL_ADDR_SUPPORT -D__LINUX_USER_SPACE -D_LITTLE_ENDIAN=1 -DMAKEFILE_BUILD -pthread -D _GNU_SOURCE
+CFLAGS+= $(DEBUG_FLAG) -I$(NETAPI_INC_DIR) -I.  -I $(SRCDIR) -I$(PDK_INSTALL_PATH) -I$(NWAL_INSTALL_PATH) -I$(PKTLIB_INSTALL_PATH) -I$(TRANS_SDK_INSTALL_PATH) -I$(QMSS_INC_DIR) -I$(CPPI_INC_DIR) -I$(HPLIB_INC_DIR) -I$(QMSS_DEV_DIR) -I$(CPPI_DEV_DIR) -I$(NETAPI_NAVIG_INIT_SRC) -I$(SA_INSTALL_PATH) -D__ARMv7 -D_VIRTUAL_ADDR_SUPPORT -D__LINUX_USER_SPACE -D_LITTLE_ENDIAN=1 -DMAKEFILE_BUILD -pthread -D _GNU_SOURCE
 INCS = -I$(strip $(subst ;, -I,$(subst $(space),\$(space),$(INCDIR))))
 all: lib
 
index 931d5e48678e56d63c7fff52ec0099ebfb2eb9a6..d0a289c969f8c83063a7e673b6f213982f461674 100755 (executable)
@@ -78,7 +78,7 @@ void Osal_cache_op_measure_reset(void);
 unsigned int Osal_cache_op_measure(int * p_n) ;
 
 //utility to convert virt2phy, phy2virt
-#define _Osal_qmssVirtToPhy hplib_mVM_VirtToPhy
+#define _Osal_qmssVirtToPhy hplib_mVMVirtToPhy
 
-#define _Osal_qmssPhyToVirt hplib_mVM_PhyToVirt
+#define _Osal_qmssPhyToVirt hplib_mVMPhyToVirt
 #endif
index b290949821deb0b0cc9b468c2c578c26d0b03be7..b3d3938701ef805518dee048091832f147db468a 100755 (executable)
 
 
 
-#define NETAPI_ATOMIC_INIT32 HPLIB_ATOMIC_INIT32
+#define NETAPI_ATOMIC_INIT32 HPLIB_mATOMIC32_INIT
 
 #define netapi_atomic_read32 hplib_mAtomic32Read
 
 
 #define NETAPI_atomic_dec32(p) HPLIB_mAtomic32Dec
 
-#define netapi_atomic_add_return32 hplib_mAtomic32DecReturn
-
+#define netapi_atomic_add_return32 hplib_mAtomic32AddReturn
 
 #define netapi_atomic_sub_return32 hplib_mAtomic32SubReturn
 
 /*******************************************************
  ****************memory barrier************************
 ******************************************************/
-#define netapi_mb hplib_MB
-#define netapi_rmb hplib_RMB
-#define netapi_wmb hplib_WMB
+#define netapi_mb hplib_mMemBarrier
+#define netapi_rmb hplib_mReadMemBarrier
+#define netapi_wmb hplib_mWriteMemBarrier
 
 
 #endif
index e6ff8d879879feb8e6952100177beb05646459e0..9794d1eaac652ea85d76be6aa1410cce5c2257d8 100755 (executable)
@@ -70,7 +70,7 @@ NETAPI_SCHED_HANDLE_T * netapi_schedOpen(NETAPI_T n, NETAPI_SCHED_CONFIG_T * p_c
   if(!ph) {*p_err= NETAPI_ERR_NOMEM; return NULL;}
   if(!p_config) {*p_err=  NETAPI_ERR_BAD_INPUT; return NULL;}
   memcpy(&ph->config,p_config,sizeof(NETAPI_SCHED_CONFIG_T));
-  ph->start =   hplib_mUtil_GetTimestamp();
+  ph->start =   hplib_mUtilGetTimestamp();
   ph->back = (void *) n;
   if (ph->config.valid_flags & NETAPI_SCHED_DURATION)
   {
@@ -103,7 +103,7 @@ int netapi_schedWaitForEvents(NETAPI_SCHED_HANDLE_T *s, int *p_err)
 {
   int err;
   *p_err=0;
-  unsigned long long t =  hplib_mUtil_GetTimestamp();
+  unsigned long long t =  hplib_mUtilGetTimestamp();
   int next_house;
   volatile int pkts;
   volatile unsigned long t1;
@@ -116,15 +116,15 @@ int netapi_schedWaitForEvents(NETAPI_SCHED_HANDLE_T *s, int *p_err)
   for(;t< s->shutdown_time;)
   {
 #ifndef NO_TIMER
-    t = hplib_mUtil_GetTimestamp();
+    t = hplib_mUtilGetTimestamp();
 #endif
     next_house -=1;
     //poll all  pktio channels we have open in RX mode 
      //Osal_cache_op_measure_reset();
      cache_op_b2= Osal_cache_op_measure(&n_c_ops);
-     t1=hplib_mUtil_GetTickCount();
+     t1=hplib_mUtilGetTickCount();
      pkts=pktio_pollAll((NETAPI_T) s->back, NULL, &err);
-     t2=hplib_mUtil_GetTickCount();
+     t2=hplib_mUtilGetTickCount();
      if (pkts)
      {
         s->num_pkts+= (unsigned long long) pkts;
index b4550ceba91eecb37dab5357d38cfac1be3fc204..483fb0a1ece8c17e39823f3f66578dd896380187 100755 (executable)
@@ -42,7 +42,7 @@ PKTUTL_LIB=$(SA_INSTALL_PATH)/ti/mas/pktutl/gcarmv7a/pktutl_c.av7A
 CC = $(CROSS_TOOL_INSTALL_PATH)/$(CROSS_TOOL_PRFX)gcc
 AR = $(CROSS_TOOL_INSTALL_PATH)/$(CROSS_TOOL_PRFX)ar -r
 
-CFLAGS= $(DEBUG_FLAG) -I../ -I. -I$(NETAPI_INC_DIR) -I$(NETAPI_INC_DIR)/src -I$(HPLIB_INC_DIR) -I$(PDK_INSTALL_PATH)  -I$(NWAL_INSTALL_PATH) -I$(PKTLIB_INSTALL_PATH) -I$(HPLIB_INSTALL_PATH) -I$(TRANS_SDK_INSTALL_PATH) -I$(QMSS_INC_DIR) -I$(CPPI_INC_DIR) -I$(SA_INC_DIR) -D__ARMv7 -D_VIRTUAL_ADDR_SUPPORT -D__LINUX_USER_SPACE -D_LITTLE_ENDIAN=1 -DMAKEFILE_BUILD -pthread -D _GNU_SOURCE
+CFLAGS+= $(DEBUG_FLAG) -I../ -I. -I$(NETAPI_INC_DIR) -I$(NETAPI_INC_DIR)/src -I$(HPLIB_INC_DIR) -I$(PDK_INSTALL_PATH)  -I$(NWAL_INSTALL_PATH) -I$(PKTLIB_INSTALL_PATH) -I$(HPLIB_INSTALL_PATH) -I$(TRANS_SDK_INSTALL_PATH) -I$(QMSS_INC_DIR) -I$(CPPI_INC_DIR) -I$(SA_INC_DIR) -D__ARMv7 -D_VIRTUAL_ADDR_SUPPORT -D__LINUX_USER_SPACE -D_LITTLE_ENDIAN=1 -DMAKEFILE_BUILD -pthread -D _GNU_SOURCE
 # Linker options
 INTERNALLINKDEFS = --start-group -L$(ARMV7LIBDIR) -L$(PDK_ARMV7LIBDIR) $(NETAPI_LIB) $(PKTLIB_LIB) $(HP_LIB) $(QMSS_LIB) $(CPPI_LIB) $(NWAL_LIB) $(PA_LIB) $(SA_LIB) $(AES_LIB) $(SHA1_LIB) $(PKTUTL_LIB) -lrt --end-group
 
index 732e109c17b69c7dc2dbb50a4d562dee633f37fe..95005792245cb89ac26d317326ae755f1773c1a0 100755 (executable)
@@ -61,7 +61,7 @@
 #include <sys/resource.h>
 #include "net_test.h"
 #include <ti/drv/sa/salld.h>
-#define EXPERIMENTAL
+//#define EXPERIMENTAL
 #ifdef EXPERIMENTAL
 #include "router.c"
 Trie * our_router;
@@ -82,6 +82,7 @@ unsigned int ip[MAX_ROUTES]={BE(0x0a0100c8),BE(0x0a00000a),BE(0x0a02000a),BE(0xc
 
 #ifdef MULTI_THREAD
 __thread int our_core;
+    cpu_set_t cpu_set;
 #endif
 
 //#define TEST_TIMERS
@@ -965,9 +966,9 @@ for(j=0;j<200/nfrags;j++)
     buffer[2]= (temp&0xff00)>>8;
     buffer[3]= (temp&0xff);
     Pktlib_setPacketLen(tip, temp);
-    v1= hplib_mUtil_GetTickCount();
+    v1= hplib_mUtilGetTickCount();
     paEx_reassemLibProc(tip, 0xffff);
-    v2= hplib_mUtil_GetTickCount();
+    v2= hplib_mUtilGetTickCount();
     sum1+= v2-v1;
   }
   sum2 += v2-v1;
@@ -994,8 +995,8 @@ int sum =0;
    printf("calibration loop .. ");
    for(i=0;i<1000;i++)
    {
-   vv1= hplib_mUtil_GetTickCount();
-   vv2= hplib_mUtil_GetTickCount();
+   vv1= hplib_mUtilGetTickCount();
+   vv2= hplib_mUtilGetTickCount();
    sum+=(vv2-vv1);
    }
    printf(" accuracy = +- %d cycles\n", sum/1000);
@@ -1005,15 +1006,15 @@ PKTIO_METADATA_T meta[10]={0};
 //send single, recv single
 for(i=0;i<ntrials;i++)
 {
-   vv1= hplib_mUtil_GetTickCount();
+   vv1= hplib_mUtilGetTickCount();
    tip=Pktlib_allocPacket(OurHeap,PKT_LEN);
-   vv2= hplib_mUtil_GetTickCount();
+   vv2= hplib_mUtilGetTickCount();
    Pktlib_getDataBuffer(tip,&pData,&len);
-   vv3= hplib_mUtil_GetTickCount();
+   vv3= hplib_mUtilGetTickCount();
    pktio_send(our_chan,tip,&meta[0],&err);
-   vv4= hplib_mUtil_GetTickCount();
+   vv4= hplib_mUtilGetTickCount();
    n=pktio_poll(our_chan,NULL , &err);
-   vv5=   hplib_mUtil_GetTickCount();
+   vv5=   hplib_mUtilGetTickCount();
    timings[0]+=(vv6-vv4);
    timings[1]+=(vv5-vv4);
    timings[3]+=(vv4-vv3); 
@@ -1241,7 +1242,7 @@ void flip_and_send_pkt(Ti_Pkt *tip,  unsigned char * p_pkt, int len, int flag)
             //meta_tx.authIvSize=0;
 
             /* post it to netcp sb tx channel*/
-            meta_tx.appCtxId = (nwal_AppId)hplib_mUtil_GetTickCount();
+            meta_tx.appCtxId = (nwal_AppId)hplib_mUtilGetTickCount();
             meta.u.tx_sb_meta=&meta_tx;
 
 #ifdef NET_TEST_ENABLE_SIDE_BAND_LOW_LEVEL_API
@@ -1371,12 +1372,12 @@ void recv_cb_bench(struct PKTIO_HANDLE_Tag * channel, Ti_Pkt* p_recv[],
                          uint64_t ts )
 {
    int i;
-   vv6=   hplib_mUtil_GetTickCount();
+   vv6=   hplib_mUtilGetTickCount();
    for (i=0;i<n_pkts; i++) 
    {
      Pktlib_freePacket(p_recv[i]);
    }
-   vv11 = hplib_mUtil_GetTickCount();
+   vv11 = hplib_mUtilGetTickCount();
 }
 
 /****************************************************************************************/
@@ -1427,7 +1428,7 @@ unsigned long time, delta_time;
         if ((int)meta[i].u.rx_sb_meta->appId == p_sa_info->rx_tunnel)
         {
            
-            time = hplib_mUtil_GetTickCount();
+            time = hplib_mUtilGetTickCount();
            delta_time = time -(unsigned long) meta[i].u.rx_sb_meta->appCtxId;
             stats.total_decrypt_time += delta_time;
             stats.sb_rx+=1;
@@ -1500,7 +1501,7 @@ unsigned long time, delta_time;
            meta_tx.l4OffBytes = 0;
            meta_tx.l4HdrLen = 0;
            meta_tx.ploadLen = 0;
-            time = hplib_mUtil_GetTickCount();
+            time = hplib_mUtilGetTickCount();
             delta_time = time -(unsigned long) meta[i].u.rx_sb_meta->appCtxId;
            stats.total_encrypt_time += delta_time;
         
@@ -1674,7 +1675,7 @@ int coreid=0;
                     meta_tx.pEncIV = &p_pkt[netTest_MAC_HEADER_LEN +netTest_IP_HEADER_LEN + netTest_ESP_HEADER_LEN ];
                 }
                
-                meta_tx.appCtxId = (nwal_AppId)hplib_mUtil_GetTickCount();
+                meta_tx.appCtxId = (nwal_AppId)hplib_mUtilGetTickCount();
                 //printf("recv_cb appCtxId: %lu\n", meta_tx.appCtxId);
 
                 /* post it to netcp sb tx channel*/
@@ -1881,7 +1882,7 @@ unsigned long long tmp_cyclesL[TUNE_NETAPI_NUM_CORES];
 unsigned long long tmp_ccyclesL[TUNE_NETAPI_NUM_CORES]; //cache cycles
 NETAPI_SA_STATS_T netapi_sa_stats;
 
-printf(">*****stats @ %lld (#cbs%d) \n", hplib_mUtil_GetTimestamp(),stats.n_stats_cb);
+printf(">*****stats @ %lld (#cbs%d) \n", hplib_mUtilGetTimestamp(),stats.n_stats_cb);
 //printf("netcp_tx_handle check %x\n", netcp_tx_chan->back);
 printf(">itx=%d rx=%d tx=%d bad=%d slow=%d \n>rx_class0=%d rx_class1=%d rx_class2=%d  secRx=%d  secPRX=%d sb_rx=%d sb_tx=%d auth_ok=%d sec_tx=%d  min_rx=%d min_tx=%d\n",
          stats.itx, stats.rx, stats.tx, stats.n_bad, stats.n_new, 
@@ -2122,7 +2123,7 @@ if ((house_pkts_gened>0) && (! (house_pkts_gened%1000)) )
 
 
    /* set the pkt length */
-   vv1 = hplib_mUtil_GetTickCount();
+   vv1 = hplib_mUtilGetTickCount();
    Pktlib_setPacketLen(tip, len);
 
    /* set up meta data */
@@ -2166,20 +2167,20 @@ if ((house_pkts_gened>0) && (! (house_pkts_gened%1000)) )
    if(!first)
    {
        first++;
-       nwal_flow_vv1= hplib_mUtil_GetTickCount();
+       nwal_flow_vv1= hplib_mUtilGetTickCount();
        if(nwal_initPSCmdInfo(PKTIO_GET_NWAL_INSTANCE(netcp_tx_chan),
                              &meta_tx,
                              &flowPSCmdInfo) != nwal_OK)
        {
            printf("nwal_initPSCmdInfo() ERROR \n");
        }
-       nwal_flow_vv2= hplib_mUtil_GetTickCount();
+       nwal_flow_vv2= hplib_mUtilGetTickCount();
        nwal_sum_flow_vv1 += (nwal_flow_vv1-vv1); 
        nwal_sum_flow_vv2 += (nwal_flow_vv2-nwal_flow_vv1); 
    }
        
    cache_op_b1= Osal_cache_op_measure(&n_c_ops);
-   vv2= hplib_mUtil_GetTickCount();
+   vv2= hplib_mUtilGetTickCount();
 #ifdef BEND_UDP_SEND
    nwal_mCmdSetL4CkSumPort(  tip,
                              &flowPSCmdInfo,
@@ -2199,7 +2200,7 @@ if ((house_pkts_gened>0) && (! (house_pkts_gened%1000)) )
    Qmss_queuePushDescSize (flowPSCmdInfo.txQueue, 
                         pPktDesc, 
                         NWAL_DESC_SIZE);
-   vv3= hplib_mUtil_GetTickCount();
+   vv3= hplib_mUtilGetTickCount();
    cache_op_b2= Osal_cache_op_measure(&n_c_ops);
 
    sum_vv1 += (vv2-vv1);
@@ -2835,12 +2836,16 @@ static void parse_config_file(FILE * fpr, netTestConfigFile_t *pConfig)
 NETAPI_T worker_nh[TUNE_NETAPI_NUM_CORES];
 void slow_path_thread(int coreid)
 {
-int err;
-worker_nh[coreid]=netapi_init(NETAPI_NO_MASTER,NULL);
-netapi_setCookie(worker_nh[coreid],coreid);
-our_core=coreid;
-scheduler[coreid] =netapi_schedOpen(worker_nh[coreid],&our_sched_cfg, &err);
-if (!scheduler[coreid]) {printf("sched create failed for core%d\n",coreid); exit(1);}
+    int err;
+    printf("slow_path_thread, mypid: %d\n", gettid());
+    hplib_Util_SetupCore(coreid, &cpu_set);
+    worker_nh[coreid]=netapi_init(NETAPI_NO_MASTER,NULL);
+    netapi_setCookie(worker_nh[coreid],coreid);
+    our_core=coreid;
+    scheduler[coreid] =netapi_schedOpen(worker_nh[coreid],&our_sched_cfg, &err);
+    if (!scheduler[coreid]) {printf("sched create failed for core%d\n",coreid); exit(1);}
+
+
 
 /*********************************************/
 /**************Entry point into scheduler ****/
@@ -2852,12 +2857,16 @@ netapi_shutdown(worker_nh[coreid]);
 }
 void fast_path_thread(int coreid)
 {
-int err;
-worker_nh[coreid]=netapi_init(NETAPI_NO_MASTER,NULL);
-netapi_setCookie(worker_nh[coreid],coreid);
-our_core=coreid;
-scheduler[coreid] =netapi_schedOpen(worker_nh[coreid],&our_sched_cfg, &err);
-if (!scheduler[coreid]) {printf("sched create failed for core%d\n",coreid); exit(1);}
+    int err;
+    printf("fast_path_thread, mypid: %d\n", gettid());
+    hplib_Util_SetupCore(coreid, &cpu_set);
+    worker_nh[coreid]=netapi_init(NETAPI_NO_MASTER,NULL);
+    netapi_setCookie(worker_nh[coreid],coreid);
+    our_core=coreid;
+    scheduler[coreid] =netapi_schedOpen(worker_nh[coreid],&our_sched_cfg, &err);
+    if (!scheduler[coreid]) {printf("sched create failed for core%d\n",coreid); exit(1);}
+
+;
 
 /*********************************************/
 /**************Entry point into scheduler ****/
@@ -2884,7 +2893,6 @@ int main(int argc, char **argv)
     FILE * fpr = NULL;
 
 
-
     err= getrlimit(RLIMIT_STACK,&rl);
     if (!err) printf(" stack limit = %d\n",rl.rlim_cur); else printf("getrlimit failed\n");
 #if 0
@@ -2946,10 +2954,27 @@ for (i=0;i<n_dst_ips;i++)
 }
 #endif
 
+
+    /************** tmannan: core setup begin ************************/
+    CPU_SET( 0, &cpu_set);
+
+    if (sched_setaffinity( gettid(), sizeof( cpu_set_t ), &cpu_set ))
+    {
+        perror( "sched_setaffinity" );
+        printf("main() , sched_setaffinity error\n");
+        return hplib_FAILURE;
+    }
+    else 
+         printf("main() , ************* sched_setaffinity sucess ******************\n");
+
+
+hplib_Util_Init_NetapiProc();
+
+    /**************** tmannan: core setup end ***********************/
+
 /*******************************************/
 /*************NETAPI STARTUP****************/
 /*******************************************/
-
 /* create netapi */
 netapi_handle = netapi_init(NETAPI_SYS_MASTER, &our_netapi_default_cfg);
 
@@ -3323,6 +3348,7 @@ srand((unsigned) np2process);
 
 #ifdef MULTI_THREAD
 {
+        CPU_ZERO( &cpu_set );
        pthread_t *thrs;
         int procs =2;  //get this from config eventually
         char c;
@@ -3470,39 +3496,39 @@ Qmss_QueueHnd freeQ=Pktlib_getInternalHeapQueue(h);
 for(i=0;i<n_trials;i++)
 {
     //raw pop
-    t1= hplib_mUtil_GetTickCount();
+    t1= hplib_mUtilGetTickCount();
     pHd[0] = (Ti_Pkt *)QMSS_DESC_PTR(PKTIO_QMSS_QUEUE_POP_RAW (freeQ));
     for(j=1;j<NTOPOP;j++)
     {
-       tempVA  =  hplib_mVM_PhyToVirt(pHd[j-1]);
+       tempVA  =  hplib_mVMPhyToVirt(pHd[j-1]);
        netapi_pld(tempVA);
         //__builtin_prefetch(tempVA);
        pHd[j] = (Ti_Pkt *)QMSS_DESC_PTR(PKTIO_QMSS_QUEUE_POP_RAW (freeQ));
        sumf+= (int) (   ((Cppi_HostDesc *) tempVA)->origBuffPtr -
                   ((Cppi_HostDesc *) tempVA)->buffPtr);
     }
-    tempVA  =  hplib_mVM_PhyToVirt(pHd[j-1]);
+    tempVA  =  hplib_mVMPhyToVirt(pHd[j-1]);
     sumf+= (int) (   ((Cppi_HostDesc *) tempVA)->origBuffPtr -
                   ((Cppi_HostDesc *) tempVA)->buffPtr);
-    t2=hplib_mUtil_GetTickCount();
+    t2=hplib_mUtilGetTickCount();
     sumt+= (t2-t1);
 
     //invalidate/wb 
     for(j=0;j<NTOPOP;j++)
     {
-        tempVA  =  hplib_mVM_PhyToVirt(pHd[j]);
+        tempVA  =  hplib_mVMPhyToVirt(pHd[j]);
         hplib_CacheWbInv(tempVA,128);
     }
 
     //raw push 
-    t1=hplib_mUtil_GetTickCount();
+    t1=hplib_mUtilGetTickCount();
     for(j=0;j<NTOPOP;j++)
     {
         PKTIO_QMSS_QUEUE_PUSH_DESC_SIZE_RAW (freeQ,
                                              (void *) pHd[j],
                                              128);
     }
-    t2=hplib_mUtil_GetTickCount();
+    t2=hplib_mUtilGetTickCount();
     sump += (t2-t1);
 }
 printf("\nfast poppush: np=%d  pop=%d  push=%d sumf=%d\n", (n_trials*NTOPOP),
@@ -3538,14 +3564,14 @@ Qmss_QueueHnd freeQ;
 //loop forever
 for(;max_pkts>0;)
 {
-    t1= hplib_mUtil_GetTickCount();
+    t1= hplib_mUtilGetTickCount();
     pHd[0] = (Ti_Pkt *)QMSS_DESC_PTR(PKTIO_QMSS_QUEUE_POP_RAW (rxQ));
     if (!pHd[0]) continue;
     //got pkt
     for(i=1;(i<n) && (pHd[i-1]);i++)
     {
         //convert previous descriptor PA -> VA
-        tempVA  =  hplib_mVM_PhyToVirt(pHd[i-1]); 
+        tempVA  =  hplib_mVMPhyToVirt(pHd[i-1]); 
 
         //try and preload desriptor
          __builtin_prefetch(tempVA);
@@ -3575,7 +3601,7 @@ for(;max_pkts>0;)
     if(pHd[i-1])
     {
         //convert previous descriptor PA -> VA
-        tempVA  =  hplib_mVM_PhyToVirt(pHd[i-1]); 
+        tempVA  =  hplib_mVMPhyToVirt(pHd[i-1]); 
 
         /* extract some meta data */
 #if 1
@@ -3591,7 +3617,7 @@ for(;max_pkts>0;)
         Cppi_getData (Cppi_DescType_HOST, (Cppi_Desc*)tempVA, &buf[jj], &len[jj]);
         jj+=1;
     }
-    t2= hplib_mUtil_GetTickCount();
+    t2= hplib_mUtilGetTickCount();
     j+=(pHd[i-1]? i: (i-1)) ;
     if (jj>(M-n)) jj=0;
     l+=1;  //n batches
@@ -3616,18 +3642,18 @@ for(;max_pkts>0;)
         {
 
         //tempVA=Qmss_osalConvertDescPhyToVirt(pHd[k]);
-        tempVA  =  hplib_mVM_PhyToVirt(pHd[k]);
+        tempVA  =  hplib_mVMPhyToVirt(pHd[k]);
         freeQ=Qmss_getQueueHandle(Cppi_getReturnQueue (Cppi_DescType_HOST, (Cppi_Desc *)tempVA));
         hplib_CacheWbInv(tempVA,128);
         //would need to wbInv buffer also in practice. Also need to walk
         // descriptor chain 
-        t11= hplib_mUtil_GetTickCount();
+        t11= hplib_mUtilGetTickCount();
        // Pktlib_freePacket(tempVA);
         PKTIO_QMSS_QUEUE_PUSH_DESC_SIZE_RAW (freeQ,
                                              (void *) pHd[k],
                                              128);
 
-        t12= hplib_mUtil_GetTickCount();
+        t12= hplib_mUtilGetTickCount();
         sumf += (t12-t11);       
         }
     }
@@ -3671,7 +3697,7 @@ static inline void send_it(Ti_Pkt *tip, int len, ROUTE_SEC_T * p_sec, int out_po
   int err=0;
   PKTIO_METADATA_T meta2 = {PKTIO_META_TX,{0},0};
   nwalTxPktInfo_t meta_tx2={0};
-  st1=hplib_mUtil_GetTickCount();
+  st1=hplib_mUtilGetTickCount();
   if (len<60) 
   { 
      unsigned int templen;
@@ -3698,7 +3724,7 @@ static inline void send_it(Ti_Pkt *tip, int len, ROUTE_SEC_T * p_sec, int out_po
   meta2.u.tx_meta=&meta_tx2;
   pktio_send(netcp_tx_chan,tip,&meta2,&err);
   stats.tx +=1;
-  st2=hplib_mUtil_GetTickCount();
+  st2=hplib_mUtilGetTickCount();
   stats.send_cycles += (unsigned long long) (st2-st1);  
 } 
 void recv_cb_router(struct PKTIO_HANDLE_Tag * channel, Ti_Pkt* p_recv[],
@@ -3728,7 +3754,7 @@ int coreid=our_core;  //who we are(thread local)
 #else
 int coreid=0;
 #endif
-t1=hplib_mUtil_GetTickCount();
+t1=hplib_mUtilGetTickCount();
 ct1 =Osal_cache_op_measure(&n_c_ops);
 for(i=0;i<n_pkts;i++)
 {
@@ -3818,7 +3844,7 @@ for(i=0;i<n_pkts;i++)
               break;
        }
 }
-t2=hplib_mUtil_GetTickCount();
+t2=hplib_mUtilGetTickCount();
 ct2 =Osal_cache_op_measure(&n_c_ops);
 stats.app_cycles +=  (unsigned long long) (t2-t1);
 stats.tx_cache_cycles += (unsigned long long) (ct2-ct1);