NETAPI net test application updates
[keystone-rtos/netapi.git] / ti / runtime / netapi / test / ifdma_test.c
index 8df5fbbcd85fb15d3252d0a302c7c69a8db22224..c53f34301610e034499e7f3f60143e2891975256 100755 (executable)
@@ -47,6 +47,7 @@
 #include <string.h>\r
 #include <signal.h>\r
 #include <pthread.h>\r
+#include <sched.h>\r
 \r
 #include "trie.h"\r
 #include "string.h"\r
@@ -162,6 +163,12 @@ void consumer_thread(int coreid)
 {\r
 int err;\r
 int np;\r
+cpu_set_t cpu_set;\r
+\r
+    CPU_ZERO( &cpu_set);\r
+    CPU_SET( 1, &cpu_set);\r
+    hplib_utilSetupThread(1, &cpu_set);\r
+\r
      for(;!((volatile)QUIT);)\r
      {\r
          np = netapi_pktioPoll(rx_chan,NULL,&err);\r
@@ -183,6 +190,13 @@ unsigned char * pData;
 int len;\r
 PKTIO_METADATA_T meta = {PKTIO_META_IFDMA_TX,{0},0};\r
 int np;\r
+cpu_set_t cpu_set;\r
+\r
+\r
+    CPU_ZERO( &cpu_set);\r
+    CPU_SET( 2, &cpu_set);\r
+    hplib_utilSetupThread(2, &cpu_set);\r
+\r
 #ifdef INTERNAL_PACKETS\r
       //generate packets internally by allocating from OurHeap (the NETAPI \r
       //default) and send to receiver via ifdma pktio channel\r
@@ -229,9 +243,14 @@ int main(int argc, char **argv)
     Pktlib_HeapIfTable*  pPktifTable;\r
     Pktlib_HeapCfg heapCfg;\r
     long t1, t2 ;\r
+    cpu_set_t cpu_set;\r
+\r
 \r
      //install signal handler for ^c\r
     signal(SIGINT,netTest_utilMySig);\r
+    CPU_ZERO( &cpu_set);\r
+    CPU_SET( 0, &cpu_set);\r
+    hplib_utilSetupThread(0, &cpu_set);\r
 \r
 \r
     /*******************************************/\r