Demo works -- initial commit

bespoke-silicon-group · Jan 23, 2023 · d82e875 · d82e875
1 parent e0348a1
commit d82e875
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 5 deletions.
diff --git a/examples/cuda/test_host_stream/main.cpp b/examples/cuda/test_host_stream/main.cpp
@@ -54,6 +54,9 @@
  * This test streams data through circular buffers on the host through the manycore
  * in a chain, then streams back to the host. Validation is that the data received
  * matches the data pattern sent.
+ * 
+ * This test demonstrates how host can be run concurrently with manycore code in a
+ * streaming or cooperative manner.
  */
 
 int kernel_host_stream(int argc, char **argv) {
@@ -143,16 +146,16 @@ int kernel_host_stream(int argc, char **argv) {
                 }
             }
 
-            //int timeout = hb_mc_device_pod_wait_for_tile_group_finish_any(device, pod, 1);
-            hb_mc_request_packet_t rqst;
-            int rc = hb_mc_manycore_request_rx(device->mc, &rqst, 1);
+            // Check for finish
+            hb_mc_device_pod_wait_for_tile_group_finish_any(device, pod, 1);
         } while (packets_recv < NUM_PACKETS);
 
         /*****************************************************************************************************************
         * Freeze the tiles and memory manager cleanup. 
         ******************************************************************************************************************/
         BSG_CUDA_CALL(hb_mc_device_finish(device)); 
 
+        // Fail if data is not expected
         if (mismatch) { 
                 return HB_MC_FAIL;
         }

diff --git a/libraries/bsg_manycore_cuda.cpp b/libraries/bsg_manycore_cuda.cpp
@@ -1815,7 +1815,7 @@ int hb_mc_device_podv_wait_for_tile_group_finish_any(hb_mc_device_t *device,
         while (1) {
                 hb_mc_request_packet_t rqst;
 
-                // perform a blocking read from the request fifo
+                // perform a read from the request fifo
                 int rc;
                 if ((rc = hb_mc_manycore_request_rx(device->mc, &rqst, timeout)) != HB_MC_SUCCESS)
                     return rc;
@@ -1881,7 +1881,6 @@ int hb_mc_device_podv_wait_for_tile_group_finish_any(hb_mc_device_t *device,
                            "value but no matching tile-group",
                            __func__);
         }
-        return HB_MC_TIMEOUT;
 }
 
 /**