hip.cpp 2.02 KB
Newer Older
Paul's avatar
Paul committed
1

Paul's avatar
Paul committed
2
#include <migraph/gpu/hip.hpp>
Paul's avatar
Paul committed
3

Paul's avatar
Paul committed
4
#include <migraph/manage_ptr.hpp>
Paul's avatar
Paul committed
5
6
7
8
#include <miopen/miopen.h>

#include <vector>

Paul's avatar
Paul committed
9
namespace migraph {
Paul's avatar
Paul committed
10
namespace gpu {
Paul's avatar
Paul committed
11

Paul's avatar
Paul committed
12
using hip_ptr = MIGRAPH_MANAGE_PTR(void, hipFree);
Paul's avatar
Paul committed
13

Paul's avatar
Paul committed
14
15
16
17
18
std::string hip_error(int error)
{
    return hipGetErrorString(static_cast<hipError_t>(error));
}

Paul's avatar
Paul committed
19
hip_ptr allocate_gpu(std::size_t sz)
Paul's avatar
Paul committed
20
21
{
    void* result;
Paul's avatar
Paul committed
22
23
24
    auto status = hipMalloc(&result, sz);
    if(status != hipSuccess)
        MIGRAPH_THROW("Gpu allocation failed: " + hip_error(status));
Paul's avatar
Paul committed
25
26
27
    return hip_ptr{result};
}

Paul's avatar
Paul committed
28
29
30
31
32
33
34
35
36
37
38
39
template <class T>
hip_ptr write_to_gpu(const T& x)
{
    using type = typename T::value_type;
    auto size  = x.size() * sizeof(type);
    return write_to_gpu(x.data(), size);
}

template <class T>
std::vector<T> read_from_gpu(const void* x, std::size_t sz)
{
    std::vector<T> result(sz);
Paul's avatar
Paul committed
40
41
42
    auto status = hipMemcpy(result.data(), x, sz * sizeof(T), hipMemcpyDeviceToHost);
    if(status != hipSuccess)
        MIGRAPH_THROW("Copy from gpu failed: " + hip_error(status));
Paul's avatar
Paul committed
43
44
45
    return result;
}

Paul's avatar
Paul committed
46
47
hip_ptr write_to_gpu(const void* x, std::size_t sz)
{
Paul's avatar
Paul committed
48
    auto result = allocate_gpu(sz);
Paul's avatar
Paul committed
49
50
51
    auto status = hipMemcpy(result.get(), x, sz, hipMemcpyHostToDevice);
    if(status != hipSuccess)
        MIGRAPH_THROW("Copy to gpu failed: " + hip_error(status));
Paul's avatar
Paul committed
52
53
54
    return result;
}

Paul's avatar
Paul committed
55
argument allocate_gpu(shape s)
Paul's avatar
Paul committed
56
{
Paul's avatar
Paul committed
57
    auto p = share(allocate_gpu(s.bytes()+1));
Paul's avatar
Paul committed
58
59
60
    return {s, [p]() mutable { return reinterpret_cast<char*>(p.get()); }};
}

Paul's avatar
Paul committed
61
argument to_gpu(argument arg)
Paul's avatar
Paul committed
62
63
64
65
66
{
    auto p = share(write_to_gpu(arg.data(), arg.get_shape().bytes()));
    return {arg.get_shape(), [p]() mutable { return reinterpret_cast<char*>(p.get()); }};
}

Paul's avatar
Paul committed
67
argument from_gpu(argument arg)
Paul's avatar
Paul committed
68
{
Paul's avatar
Paul committed
69
    argument result;
Paul's avatar
Paul committed
70
71
72
73
74
75
76
77
    arg.visit([&](auto x) {
        using type = typename decltype(x)::value_type;
        auto v     = read_from_gpu<type>(arg.data(), x.get_shape().bytes() / sizeof(type));
        result     = {x.get_shape(), [v]() mutable { return reinterpret_cast<char*>(v.data()); }};
    });
    return result;
}

Paul's avatar
Paul committed
78
} // namespace gpu
Paul's avatar
Paul committed
79

Paul's avatar
Paul committed
80
} // namespace migraph