Arquivos
rocm-systems/runtime/hsa-runtime/core/inc/default_signal.h
T
Sean Keely c9642cf7af Initial IPC signal support.
Added an API for creating signals with attributes.
Added two APIs for IPC operations on signals.
Initial use of exceptions for error handling.

Add ref counting to signals.
Removed spin loops from signal destructors.
Signals are no longer to be destroyed with delete, use DeleteSignal instead.
Added delete safety to doorbells.
Added secondary hsa_signal_t -> Signal* translation path for IPC enabled signals.

Change-Id: Id59065d002f0c2566b0a9425694da2ed27cb7d7f
2017-08-11 18:41:34 -05:00

189 linhas
6.1 KiB
C++

////////////////////////////////////////////////////////////////////////////////
//
// The University of Illinois/NCSA
// Open Source License (NCSA)
//
// Copyright (c) 2014-2015, Advanced Micro Devices, Inc. All rights reserved.
//
// Developed by:
//
// AMD Research and AMD HSA Software Development
//
// Advanced Micro Devices, Inc.
//
// www.amd.com
//
// Permission is hereby granted, free of charge, to any person obtaining a copy
// of this software and associated documentation files (the "Software"), to
// deal with the Software without restriction, including without limitation
// the rights to use, copy, modify, merge, publish, distribute, sublicense,
// and/or sell copies of the Software, and to permit persons to whom the
// Software is furnished to do so, subject to the following conditions:
//
// - Redistributions of source code must retain the above copyright notice,
// this list of conditions and the following disclaimers.
// - Redistributions in binary form must reproduce the above copyright
// notice, this list of conditions and the following disclaimers in
// the documentation and/or other materials provided with the distribution.
// - Neither the names of Advanced Micro Devices, Inc,
// nor the names of its contributors may be used to endorse or promote
// products derived from this Software without specific prior written
// permission.
//
// THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
// IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
// FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL
// THE CONTRIBUTORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR
// OTHER LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
// ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER
// DEALINGS WITH THE SOFTWARE.
//
////////////////////////////////////////////////////////////////////////////////
// HSA runtime C++ interface file.
#ifndef HSA_RUNTME_CORE_INC_DEFAULT_SIGNAL_H_
#define HSA_RUNTME_CORE_INC_DEFAULT_SIGNAL_H_
#include "core/inc/runtime.h"
#include "core/inc/signal.h"
#include "core/util/utils.h"
namespace core {
/// @brief Operations for a simple pure memory based signal.
/// @brief See base class Signal.
class BusyWaitSignal : public Signal {
public:
/// @brief Determines if a Signal* can be safely converted to BusyWaitSignal*
/// via static_cast.
static __forceinline bool IsType(Signal* ptr) {
return ptr->IsType(&rtti_id_);
}
/// @brief See base class Signal.
explicit BusyWaitSignal(SharedSignal* abi_block, bool enableIPC);
// Below are various methods corresponding to the APIs, which load/store the
// signal value or modify the existing signal value automically and with
// specified memory ordering semantics.
hsa_signal_value_t LoadRelaxed();
hsa_signal_value_t LoadAcquire();
void StoreRelaxed(hsa_signal_value_t value);
void StoreRelease(hsa_signal_value_t value);
hsa_signal_value_t WaitRelaxed(hsa_signal_condition_t condition,
hsa_signal_value_t compare_value,
uint64_t timeout, hsa_wait_state_t wait_hint);
hsa_signal_value_t WaitAcquire(hsa_signal_condition_t condition,
hsa_signal_value_t compare_value,
uint64_t timeout, hsa_wait_state_t wait_hint);
void AndRelaxed(hsa_signal_value_t value);
void AndAcquire(hsa_signal_value_t value);
void AndRelease(hsa_signal_value_t value);
void AndAcqRel(hsa_signal_value_t value);
void OrRelaxed(hsa_signal_value_t value);
void OrAcquire(hsa_signal_value_t value);
void OrRelease(hsa_signal_value_t value);
void OrAcqRel(hsa_signal_value_t value);
void XorRelaxed(hsa_signal_value_t value);
void XorAcquire(hsa_signal_value_t value);
void XorRelease(hsa_signal_value_t value);
void XorAcqRel(hsa_signal_value_t value);
void AddRelaxed(hsa_signal_value_t value);
void AddAcquire(hsa_signal_value_t value);
void AddRelease(hsa_signal_value_t value);
void AddAcqRel(hsa_signal_value_t value);
void SubRelaxed(hsa_signal_value_t value);
void SubAcquire(hsa_signal_value_t value);
void SubRelease(hsa_signal_value_t value);
void SubAcqRel(hsa_signal_value_t value);
hsa_signal_value_t ExchRelaxed(hsa_signal_value_t value);
hsa_signal_value_t ExchAcquire(hsa_signal_value_t value);
hsa_signal_value_t ExchRelease(hsa_signal_value_t value);
hsa_signal_value_t ExchAcqRel(hsa_signal_value_t value);
hsa_signal_value_t CasRelaxed(hsa_signal_value_t expected,
hsa_signal_value_t value);
hsa_signal_value_t CasAcquire(hsa_signal_value_t expected,
hsa_signal_value_t value);
hsa_signal_value_t CasRelease(hsa_signal_value_t expected,
hsa_signal_value_t value);
hsa_signal_value_t CasAcqRel(hsa_signal_value_t expected,
hsa_signal_value_t value);
/// @brief see the base class Signal
__forceinline hsa_signal_value_t* ValueLocation() const {
return (hsa_signal_value_t*)&signal_.value;
}
/// @brief see the base class Signal
__forceinline HsaEvent* EopEvent() { return NULL; }
protected:
bool _IsA(rtti_t id) const { return id == &rtti_id_; }
private:
static int rtti_id_;
DISALLOW_COPY_AND_ASSIGN(BusyWaitSignal);
};
/// @brief Simple memory only signal using a new ABI block.
class DefaultSignal : private LocalSignal, public BusyWaitSignal {
public:
/// @brief Determines if a Signal* can be safely converted to BusyWaitSignal*
/// via static_cast.
static __forceinline bool IsType(Signal* ptr) { return ptr->IsType(&rtti_id_); }
/// @brief See base class Signal.
explicit DefaultSignal(hsa_signal_value_t initial_value, bool enableIPC = false)
: LocalSignal(initial_value), BusyWaitSignal(signal(), enableIPC) {}
protected:
bool _IsA(rtti_t id) const {
if (id == &rtti_id_) return true;
return BusyWaitSignal::_IsA(id);
}
private:
static int rtti_id_;
DISALLOW_COPY_AND_ASSIGN(DefaultSignal);
};
} // namespace core
#endif // header guard