[Commit-gnuradio] r7768 - gnuradio/branches/developers/eb/gcell/src/apps

[eb]

Author: eb
Date: 2008-02-21 11:55:44 -0700 (Thu, 21 Feb 2008)
New Revision: 7768

Modified:
   gnuradio/branches/developers/eb/gcell/src/apps/benchmark_dma.cc
Log:
work-in-progress

Modified: gnuradio/branches/developers/eb/gcell/src/apps/benchmark_dma.cc
===================================================================
--- gnuradio/branches/developers/eb/gcell/src/apps/benchmark_dma.cc     
2008-02-21 18:35:16 UTC (rev 7767)
+++ gnuradio/branches/developers/eb/gcell/src/apps/benchmark_dma.cc     
2008-02-21 18:55:44 UTC (rev 7768)
@@ -76,60 +76,68 @@
     gbi = (gbi + dma_size) & GETBUFMASK;
   }
 
-  mb_time t_start = mb_time::time();
+  for (int iter = 0; iter < 1; iter++){
 
-  ci = 0;
-  njds[0] = 0;
-  njds[1] = 0;
+    mb_time t_start = mb_time::time();
+
+    nsubmitted = 0;
+    ncompleted = 0;
+
+    ci = 0;
+    njds[0] = 0;
+    njds[1] = 0;
   
-  // submit the first batch
-  for (int i = 0; i < NJDS; i++){
-    if (mgr->submit_job(all_jds[i])){
-      jds[ci][njds[ci]++] = all_jds[i];
-      nsubmitted++;
+    // submit the first batch
+    for (int i = 0; i < NJDS; i++){
+      if (mgr->submit_job(all_jds[i])){
+       jds[ci][njds[ci]++] = all_jds[i];
+       nsubmitted++;
+      }
+      else {
+       printf("submit_job(jds[%d]) failed, status = %d\n",
+              i, all_jds[i]->status);
+      }
     }
-    else {
-      printf("submit_job(jds[%d]) failed, status = %d\n",
-            i, all_jds[i]->status);
-    }
-  }
   
-  while (ncompleted < njobs){
-    njds[ci^1] = 0;
-    int n = mgr->wait_jobs(njds[ci], jds[ci], done, GC_WAIT_ANY);
-    // printf("%2d\n", n);
-    if (n < 0){
-      fprintf(stderr, "mgr->wait_jobs failed\n");
-      break;
-    }
-    for (unsigned int i = 0; i < njds[ci]; i++){
-      if (!done[i]){   // remember for next iteration
-       jds[ci^1][njds[ci^1]++] = jds[ci][i];
+    while (ncompleted < njobs){
+      njds[ci^1] = 0;
+      int n = mgr->wait_jobs(njds[ci], jds[ci], done, GC_WAIT_ANY);
+      // printf("%2d\n", n);
+      if (n < 0){
+       fprintf(stderr, "mgr->wait_jobs failed\n");
+       break;
       }
-      else {
-       ncompleted++;
-       // printf("ncompleted = %7d\n", ncompleted);
-       if (nsubmitted < njobs){                    // submit another one
-         if (mgr->submit_job(jds[ci][i])){
-           jds[ci^1][njds[ci^1]++] = jds[ci][i];  // remember for next iter
-           nsubmitted++;
+      for (unsigned int i = 0; i < njds[ci]; i++){
+       if (!done[i]){  // remember for next iteration
+         jds[ci^1][njds[ci^1]++] = jds[ci][i];
+       }
+       else {
+         ncompleted++;
+         // printf("ncompleted = %7d\n", ncompleted);
+         if (nsubmitted < njobs){                  // submit another one
+           if (mgr->submit_job(jds[ci][i])){
+             jds[ci^1][njds[ci^1]++] = jds[ci][i];  // remember for next iter
+             nsubmitted++;
+           }
+           else {
+             printf("submit_job(jds[%d]) failed, status = %d\n",
+                    i, jds[ci][i]->status);
+           }
          }
-         else {
-           printf("submit_job(jds[%d]) failed, status = %d\n",
-                  i, jds[ci][i]->status);
-         }
        }
       }
+      ci ^= 1; // toggle current
     }
-    ci ^= 1;   // toggle current
+
+    // stop timing
+    mb_time t_stop = mb_time::time();
+
+    double delta = (t_stop - t_start).double_time();
+    printf("nspes: %2d  udelay: %4d  elapsed_time: %7.3f  dma_size: %5d  
dma_throughput: %7.3e\n",
+          mgr->nspes(), usecs, delta, dma_size,  (double) njobs * dma_size / 
delta);
+
   }
 
-  // stop timing
-  mb_time t_stop = mb_time::time();
-  double delta = (t_stop - t_start).double_time();
-  printf("nspes: %2d  udelay: %4d  elapsed_time: %7.3f  dma_size: %5d  
dma_throughput: %7.3e\n",
-        mgr->nspes(), usecs, delta, dma_size,  (double) njobs * dma_size / 
delta);
-
   delete mgr;
 }