|
11 | 11 |
|
12 | 12 | #include <sycl/exception.hpp>
|
13 | 13 |
|
| 14 | +namespace __ESIMD_DNS { |
| 15 | + |
14 | 16 | // This function implements atomic update of pre-existing variable in the
|
15 | 17 | // absense of C++ 20's atomic_ref.
|
| 18 | + |
| 19 | +template <typename Ty> Ty atomic_load(Ty *ptr) { |
| 20 | +#ifdef _WIN32 |
| 21 | + // TODO: Windows will be supported soon |
| 22 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 23 | +#else |
| 24 | + return __atomic_load(ptr, __ATOMIC_SEQ_CST); |
| 25 | +#endif |
| 26 | +} |
| 27 | + |
| 28 | +template <typename Ty> Ty atomic_store(Ty *ptr, Ty val) { |
| 29 | +#ifdef _WIN32 |
| 30 | + // TODO: Windows will be supported soon |
| 31 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 32 | +#else |
| 33 | + __atomic_store(ptr, val, __ATOMIC_SEQ_CST); |
| 34 | +#endif |
| 35 | +} |
| 36 | + |
16 | 37 | template <typename Ty> Ty atomic_add_fetch(Ty *ptr, Ty val) {
|
17 | 38 | #ifdef _WIN32
|
18 | 39 | // TODO: Windows will be supported soon
|
19 | 40 | __ESIMD_UNSUPPORTED_ON_HOST;
|
20 | 41 | #else
|
21 |
| - return __atomic_add_fetch(ptr, val, __ATOMIC_RELAXED); |
| 42 | + return __atomic_add_fetch(ptr, val, __ATOMIC_SEQ_CST); |
| 43 | +#endif |
| 44 | +} |
| 45 | + |
| 46 | +template <typename Ty> Ty atomic_sub_fetch(Ty *ptr, Ty val) { |
| 47 | +#ifdef _WIN32 |
| 48 | + // TODO: Windows will be supported soon |
| 49 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 50 | +#else |
| 51 | + return __atomic_sub_fetch(ptr, val, __ATOMIC_SEQ_CST); |
| 52 | +#endif |
| 53 | +} |
| 54 | + |
| 55 | +template <typename Ty> Ty atomic_and_fetch(Ty *ptr, Ty val) { |
| 56 | +#ifdef _WIN32 |
| 57 | + // TODO: Windows will be supported soon |
| 58 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 59 | +#else |
| 60 | + return __atomic_and_fetch(ptr, val, __ATOMIC_SEQ_CST); |
| 61 | +#endif |
| 62 | +} |
| 63 | + |
| 64 | +template <typename Ty> Ty atomic_or_fetch(Ty *ptr, Ty val) { |
| 65 | +#ifdef _WIN32 |
| 66 | + // TODO: Windows will be supported soon |
| 67 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 68 | +#else |
| 69 | + return __atomic_or_fetch(ptr, val, __ATOMIC_SEQ_CST); |
22 | 70 | #endif
|
23 | 71 | }
|
24 | 72 |
|
| 73 | +template <typename Ty> Ty atomic_xor_fetch(Ty *ptr, Ty val) { |
| 74 | +#ifdef _WIN32 |
| 75 | + // TODO: Windows will be supported soon |
| 76 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 77 | +#else |
| 78 | + return __atomic_xor_fetch(ptr, val, __ATOMIC_SEQ_CST); |
| 79 | +#endif |
| 80 | +} |
| 81 | + |
| 82 | +template <typename Ty> Ty atomic_min(Ty *ptr, Ty val) { |
| 83 | +#ifdef _WIN32 |
| 84 | + // TODO: Windows will be supported soon |
| 85 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 86 | +#else |
| 87 | + Ty _old, _new; |
| 88 | + do { |
| 89 | + _old = *ptr; |
| 90 | + _new = std::min<Ty>(_old, val); |
| 91 | + } while (!__atomic_compare_exchange_n(ptr, &_old, _new, false, |
| 92 | + __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)); |
| 93 | + return _new; |
| 94 | +#endif |
| 95 | +} |
| 96 | + |
| 97 | +template <typename Ty> Ty atomic_max(Ty *ptr, Ty val) { |
| 98 | +#ifdef _WIN32 |
| 99 | + // TODO: Windows will be supported soon |
| 100 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 101 | +#else |
| 102 | + Ty _old, _new; |
| 103 | + do { |
| 104 | + _old = *ptr; |
| 105 | + _new = std::max<Ty>(_old, val); |
| 106 | + } while (!__atomic_compare_exchange_n(ptr, &_old, _new, false, |
| 107 | + __ATOMIC_SEQ_CST, __ATOMIC_SEQ_CST)); |
| 108 | + return _new; |
| 109 | +#endif |
| 110 | +} |
| 111 | + |
| 112 | +template <typename Ty> Ty atomic_cmpxchg(Ty *ptr, Ty expected, Ty desired) { |
| 113 | +#ifdef _WIN32 |
| 114 | + // TODO: Windows will be supported soon |
| 115 | + __ESIMD_UNSUPPORTED_ON_HOST; |
| 116 | +#else |
| 117 | + Ty _old = expected; |
| 118 | + __atomic_compare_exchange_n(ptr, &_old, desired, false, __ATOMIC_SEQ_CST, |
| 119 | + __ATOMIC_SEQ_CST); |
| 120 | + return *ptr; |
| 121 | +#endif |
| 122 | +} |
| 123 | + |
| 124 | +} // namespace __ESIMD_DNS |
| 125 | + |
25 | 126 | /// @endcond ESIMD_DETAIL
|
0 commit comments