summaryrefslogtreecommitdiffstats
path: root/src/boost/libs/fiber/examples/hip
diff options
context:
space:
mode:
Diffstat (limited to 'src/boost/libs/fiber/examples/hip')
-rw-r--r--src/boost/libs/fiber/examples/hip/Makefile29
-rw-r--r--src/boost/libs/fiber/examples/hip/multiple_streams.cpp111
-rw-r--r--src/boost/libs/fiber/examples/hip/single_stream.cpp96
3 files changed, 236 insertions, 0 deletions
diff --git a/src/boost/libs/fiber/examples/hip/Makefile b/src/boost/libs/fiber/examples/hip/Makefile
new file mode 100644
index 00000000..d40e8c1a
--- /dev/null
+++ b/src/boost/libs/fiber/examples/hip/Makefile
@@ -0,0 +1,29 @@
+HIP_PATH := /opt/rocm/hip
+
+HIPCC := $(HIP_PATH)/bin/hipcc
+
+CPPFLAGS := -O2 -std=c++11
+LDFLAGS := -L/usr/local/lib
+INCLUDES := -I/usr/local/include -I$(HIP_PATH)/include
+LIBRARIES := -lboost_fiber -lboost_context -lboost_system -lboost_filesystem
+
+all: build
+
+build: single_stream multiple_streams
+
+single_stream.o:single_stream.cpp
+ $(HIPCC) $(INCLUDES) $(CPPFLAGS) -o $@ -c $<
+
+single_stream: single_stream.o
+ $(HIPCC) $(LDFLAGS) -o $@ $+ $(LIBRARIES)
+
+multiple_streams.o:multiple_streams.cpp
+ $(HIPCC) $(INCLUDES) $(CPPFLAGS) -o $@ -c $<
+
+multiple_streams: multiple_streams.o
+ $(HIPCC) $(LDFLAGS) -o $@ $+ $(LIBRARIES)
+
+clean:
+ rm -f single_stream single_stream.o multiple_streams multiple_streams.o
+
+clobber: clean
diff --git a/src/boost/libs/fiber/examples/hip/multiple_streams.cpp b/src/boost/libs/fiber/examples/hip/multiple_streams.cpp
new file mode 100644
index 00000000..75a7449c
--- /dev/null
+++ b/src/boost/libs/fiber/examples/hip/multiple_streams.cpp
@@ -0,0 +1,111 @@
+
+// Copyright Oliver Kowalke 2017.
+// Distributed under the Boost Software License, Version 1.0.
+// (See accompanying file LICENSE_1_0.txt or copy at
+// http://www.boost.org/LICENSE_1_0.txt)
+
+#include <chrono>
+#include <cstdlib>
+#include <iostream>
+#include <memory>
+#include <random>
+#include <tuple>
+
+#include <hip/hip_runtime.h>
+
+#include <boost/assert.hpp>
+#include <boost/bind.hpp>
+#include <boost/intrusive_ptr.hpp>
+
+#include <boost/fiber/all.hpp>
+#include <boost/fiber/hip/waitfor.hpp>
+
+__global__
+void vector_add(hipLaunchParm lp, int * a, int * b, int * c, int size) {
+ int idx = threadIdx.x + blockIdx.x * blockDim.x;
+ if ( idx < size) {
+ c[idx] = a[idx] + b[idx];
+ }
+}
+
+int main() {
+ try {
+ bool done = false;
+ boost::fibers::fiber f1( [&done]{
+ std::cout << "f1: entered" << std::endl;
+ try {
+ hipStream_t stream0, stream1;
+ hipStreamCreate( & stream0);
+ hipStreamCreate( & stream1);
+ int size = 1024 * 1024;
+ int full_size = 20 * size;
+ int * host_a, * host_b, * host_c;
+ hipHostMalloc( & host_a, full_size * sizeof( int), hipHostMallocDefault);
+ hipHostMalloc( & host_b, full_size * sizeof( int), hipHostMallocDefault);
+ hipHostMalloc( & host_c, full_size * sizeof( int), hipHostMallocDefault);
+ int * dev_a0, * dev_b0, * dev_c0;
+ int * dev_a1, * dev_b1, * dev_c1;
+ hipMalloc( & dev_a0, size * sizeof( int) );
+ hipMalloc( & dev_b0, size * sizeof( int) );
+ hipMalloc( & dev_c0, size * sizeof( int) );
+ hipMalloc( & dev_a1, size * sizeof( int) );
+ hipMalloc( & dev_b1, size * sizeof( int) );
+ hipMalloc( & dev_c1, size * sizeof( int) );
+ std::minstd_rand generator;
+ std::uniform_int_distribution<> distribution(1, 6);
+ for ( int i = 0; i < full_size; ++i) {
+ host_a[i] = distribution( generator);
+ host_b[i] = distribution( generator);
+ }
+ for ( int i = 0; i < full_size; i += 2 * size) {
+ hipMemcpyAsync( dev_a0, host_a + i, size * sizeof( int), hipMemcpyHostToDevice, stream0);
+ hipMemcpyAsync( dev_a1, host_a + i + size, size * sizeof( int), hipMemcpyHostToDevice, stream1);
+ hipMemcpyAsync( dev_b0, host_b + i, size * sizeof( int), hipMemcpyHostToDevice, stream0);
+ hipMemcpyAsync( dev_b1, host_b + i + size, size * sizeof( int), hipMemcpyHostToDevice, stream1);
+ hipLaunchKernel( vector_add, dim3(size / 256), dim3(256), 0, stream0, dev_a0, dev_b0, dev_c0, size);
+ hipLaunchKernel( vector_add, dim3(size / 256), dim3(256), 0, stream1, dev_a1, dev_b1, dev_c1, size);
+ hipMemcpyAsync( host_c + i, dev_c0, size * sizeof( int), hipMemcpyDeviceToHost, stream0);
+ hipMemcpyAsync( host_c + i + size, dev_c1, size * sizeof( int), hipMemcpyDeviceToHost, stream1);
+ }
+ auto results = boost::fibers::hip::waitfor_all( stream0, stream1);
+ for ( auto & result : results) {
+ BOOST_ASSERT( stream0 == std::get< 0 >( result) || stream1 == std::get< 0 >( result) );
+ BOOST_ASSERT( hipSuccess == std::get< 1 >( result) );
+ }
+ std::cout << "f1: GPU computation finished" << std::endl;
+ hipHostFree( host_a);
+ hipHostFree( host_b);
+ hipHostFree( host_c);
+ hipFree( dev_a0);
+ hipFree( dev_b0);
+ hipFree( dev_c0);
+ hipFree( dev_a1);
+ hipFree( dev_b1);
+ hipFree( dev_c1);
+ hipStreamDestroy( stream0);
+ hipStreamDestroy( stream1);
+ done = true;
+ } catch ( std::exception const& ex) {
+ std::cerr << "exception: " << ex.what() << std::endl;
+ }
+ std::cout << "f1: leaving" << std::endl;
+ });
+ boost::fibers::fiber f2([&done]{
+ std::cout << "f2: entered" << std::endl;
+ while ( ! done) {
+ std::cout << "f2: sleeping" << std::endl;
+ boost::this_fiber::sleep_for( std::chrono::milliseconds( 1 ) );
+ }
+ std::cout << "f2: leaving" << std::endl;
+ });
+ f1.join();
+ f2.join();
+ std::cout << "done." << std::endl;
+ return EXIT_SUCCESS;
+ } catch ( std::exception const& e) {
+ std::cerr << "exception: " << e.what() << std::endl;
+ } catch (...) {
+ std::cerr << "unhandled exception" << std::endl;
+ }
+ return EXIT_FAILURE;
+}
diff --git a/src/boost/libs/fiber/examples/hip/single_stream.cpp b/src/boost/libs/fiber/examples/hip/single_stream.cpp
new file mode 100644
index 00000000..1959528e
--- /dev/null
+++ b/src/boost/libs/fiber/examples/hip/single_stream.cpp
@@ -0,0 +1,96 @@
+
+// Copyright Oliver Kowalke 2017.
+// Distributed under the Boost Software License, Version 1.0.
+// (See accompanying file LICENSE_1_0.txt or copy at
+// http://www.boost.org/LICENSE_1_0.txt)
+
+#include <chrono>
+#include <cstdlib>
+#include <iostream>
+#include <memory>
+#include <random>
+#include <tuple>
+
+#include <hip/hip_runtime.h>
+
+#include <boost/assert.hpp>
+#include <boost/bind.hpp>
+#include <boost/intrusive_ptr.hpp>
+
+#include <boost/fiber/all.hpp>
+#include <boost/fiber/hip/waitfor.hpp>
+
+__global__
+void vector_add(hipLaunchParm lp, int * a, int * b, int * c, int size) {
+ int idx = threadIdx.x + blockIdx.x * blockDim.x;
+ if ( idx < size) {
+ c[idx] = a[idx] + b[idx];
+ }
+}
+
+int main() {
+ try {
+ bool done = false;
+ boost::fibers::fiber f1([&done]{
+ std::cout << "f1: entered" << std::endl;
+ try {
+ hipStream_t stream;
+ hipStreamCreate( & stream);
+ int size = 1024 * 1024;
+ int full_size = 20 * size;
+ int * host_a, * host_b, * host_c;
+ hipHostMalloc( & host_a, full_size * sizeof( int), hipHostMallocDefault);
+ hipHostMalloc( & host_b, full_size * sizeof( int), hipHostMallocDefault);
+ hipHostMalloc( & host_c, full_size * sizeof( int), hipHostMallocDefault);
+ int * dev_a, * dev_b, * dev_c;
+ hipMalloc( & dev_a, size * sizeof( int) );
+ hipMalloc( & dev_b, size * sizeof( int) );
+ hipMalloc( & dev_c, size * sizeof( int) );
+ std::minstd_rand generator;
+ std::uniform_int_distribution<> distribution(1, 6);
+ for ( int i = 0; i < full_size; ++i) {
+ host_a[i] = distribution( generator);
+ host_b[i] = distribution( generator);
+ }
+ for ( int i = 0; i < full_size; i += size) {
+ hipMemcpyAsync( dev_a, host_a + i, size * sizeof( int), hipMemcpyHostToDevice, stream);
+ hipMemcpyAsync( dev_b, host_b + i, size * sizeof( int), hipMemcpyHostToDevice, stream);
+ hipLaunchKernel( vector_add, dim3(size / 256), dim3(256), 0, stream, dev_a, dev_b, dev_c, size);
+ hipMemcpyAsync( host_c + i, dev_c, size * sizeof( int), hipMemcpyDeviceToHost, stream);
+ }
+ auto result = boost::fibers::hip::waitfor_all( stream);
+ BOOST_ASSERT( stream == std::get< 0 >( result) );
+ BOOST_ASSERT( hipSuccess == std::get< 1 >( result) );
+ std::cout << "f1: GPU computation finished" << std::endl;
+ hipHostFree( host_a);
+ hipHostFree( host_b);
+ hipHostFree( host_c);
+ hipFree( dev_a);
+ hipFree( dev_b);
+ hipFree( dev_c);
+ hipStreamDestroy( stream);
+ done = true;
+ } catch ( std::exception const& ex) {
+ std::cerr << "exception: " << ex.what() << std::endl;
+ }
+ std::cout << "f1: leaving" << std::endl;
+ });
+ boost::fibers::fiber f2([&done]{
+ std::cout << "f2: entered" << std::endl;
+ while ( ! done) {
+ std::cout << "f2: sleeping" << std::endl;
+ boost::this_fiber::sleep_for( std::chrono::milliseconds( 1 ) );
+ }
+ std::cout << "f2: leaving" << std::endl;
+ });
+ f1.join();
+ f2.join();
+ std::cout << "done." << std::endl;
+ return EXIT_SUCCESS;
+ } catch ( std::exception const& e) {
+ std::cerr << "exception: " << e.what() << std::endl;
+ } catch (...) {
+ std::cerr << "unhandled exception" << std::endl;
+ }
+ return EXIT_FAILURE;
+}
generated by cgit v1.2.3 (git 2.39.1) at 2025-01-03 11:40:34 +0000