| // Copyright 2017 The Dawn Authors |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| #include "dawn_native/Device.h" |
| |
| #include "dawn_native/Adapter.h" |
| #include "dawn_native/AttachmentState.h" |
| #include "dawn_native/BindGroup.h" |
| #include "dawn_native/BindGroupLayout.h" |
| #include "dawn_native/Buffer.h" |
| #include "dawn_native/CommandBuffer.h" |
| #include "dawn_native/CommandEncoder.h" |
| #include "dawn_native/ComputePipeline.h" |
| #include "dawn_native/DynamicUploader.h" |
| #include "dawn_native/ErrorData.h" |
| #include "dawn_native/ErrorScope.h" |
| #include "dawn_native/ErrorScopeTracker.h" |
| #include "dawn_native/Fence.h" |
| #include "dawn_native/FenceSignalTracker.h" |
| #include "dawn_native/Instance.h" |
| #include "dawn_native/PipelineLayout.h" |
| #include "dawn_native/Queue.h" |
| #include "dawn_native/RenderBundleEncoder.h" |
| #include "dawn_native/RenderPipeline.h" |
| #include "dawn_native/Sampler.h" |
| #include "dawn_native/ShaderModule.h" |
| #include "dawn_native/Surface.h" |
| #include "dawn_native/SwapChain.h" |
| #include "dawn_native/Texture.h" |
| #include "dawn_native/ValidationUtils_autogen.h" |
| |
| #include <unordered_set> |
| |
| namespace dawn_native { |
| |
| // DeviceBase::Caches |
| |
| // The caches are unordered_sets of pointers with special hash and compare functions |
| // to compare the value of the objects, instead of the pointers. |
| template <typename Object> |
| using ContentLessObjectCache = |
| std::unordered_set<Object*, typename Object::HashFunc, typename Object::EqualityFunc>; |
| |
| struct DeviceBase::Caches { |
| ContentLessObjectCache<AttachmentStateBlueprint> attachmentStates; |
| ContentLessObjectCache<BindGroupLayoutBase> bindGroupLayouts; |
| ContentLessObjectCache<ComputePipelineBase> computePipelines; |
| ContentLessObjectCache<PipelineLayoutBase> pipelineLayouts; |
| ContentLessObjectCache<RenderPipelineBase> renderPipelines; |
| ContentLessObjectCache<SamplerBase> samplers; |
| ContentLessObjectCache<ShaderModuleBase> shaderModules; |
| }; |
| |
| // DeviceBase |
| |
| DeviceBase::DeviceBase(AdapterBase* adapter, const DeviceDescriptor* descriptor) |
| : mAdapter(adapter), |
| mRootErrorScope(AcquireRef(new ErrorScope())), |
| mCurrentErrorScope(mRootErrorScope.Get()) { |
| mCaches = std::make_unique<DeviceBase::Caches>(); |
| mErrorScopeTracker = std::make_unique<ErrorScopeTracker>(this); |
| mFenceSignalTracker = std::make_unique<FenceSignalTracker>(this); |
| mDynamicUploader = std::make_unique<DynamicUploader>(this); |
| SetDefaultToggles(); |
| |
| if (descriptor != nullptr) { |
| ApplyExtensions(descriptor); |
| } |
| |
| mFormatTable = BuildFormatTable(this); |
| } |
| |
| DeviceBase::~DeviceBase() { |
| // Devices must explicitly free the uploader |
| ASSERT(mDynamicUploader == nullptr); |
| ASSERT(mDeferredCreateBufferMappedAsyncResults.empty()); |
| |
| ASSERT(mCaches->attachmentStates.empty()); |
| ASSERT(mCaches->bindGroupLayouts.empty()); |
| ASSERT(mCaches->computePipelines.empty()); |
| ASSERT(mCaches->pipelineLayouts.empty()); |
| ASSERT(mCaches->renderPipelines.empty()); |
| ASSERT(mCaches->samplers.empty()); |
| ASSERT(mCaches->shaderModules.empty()); |
| } |
| |
| void DeviceBase::BaseDestructor() { |
| if (mLossStatus != LossStatus::Alive) { |
| // if device is already lost, we may still have fences and error scopes to clear since |
| // the time the device was lost, clear them now before we destruct the device. |
| mErrorScopeTracker->Tick(GetCompletedCommandSerial()); |
| mFenceSignalTracker->Tick(GetCompletedCommandSerial()); |
| return; |
| } |
| // Assert that errors are device loss so that we can continue with destruction |
| AssertAndIgnoreDeviceLossError(WaitForIdleForDestruction()); |
| Destroy(); |
| mLossStatus = LossStatus::AlreadyLost; |
| } |
| |
| void DeviceBase::HandleError(wgpu::ErrorType type, const char* message) { |
| if (type == wgpu::ErrorType::DeviceLost) { |
| HandleLoss(message); |
| } |
| // Still forward device loss to error scope so it can reject them all |
| mCurrentErrorScope->HandleError(type, message); |
| } |
| |
| void DeviceBase::InjectError(wgpu::ErrorType type, const char* message) { |
| if (ConsumedError(ValidateErrorType(type))) { |
| return; |
| } |
| if (DAWN_UNLIKELY(type == wgpu::ErrorType::NoError)) { |
| HandleError(wgpu::ErrorType::Validation, "Invalid injected error NoError"); |
| return; |
| } |
| HandleError(type, message); |
| } |
| |
| void DeviceBase::ConsumeError(std::unique_ptr<ErrorData> error) { |
| ASSERT(error != nullptr); |
| HandleError(error->GetType(), error->GetMessage().c_str()); |
| } |
| |
| void DeviceBase::SetUncapturedErrorCallback(wgpu::ErrorCallback callback, void* userdata) { |
| mRootErrorScope->SetCallback(callback, userdata); |
| } |
| |
| void DeviceBase::SetDeviceLostCallback(wgpu::DeviceLostCallback callback, void* userdata) { |
| mDeviceLostCallback = callback; |
| mDeviceLostUserdata = userdata; |
| } |
| |
| void DeviceBase::PushErrorScope(wgpu::ErrorFilter filter) { |
| if (ConsumedError(ValidateErrorFilter(filter))) { |
| return; |
| } |
| mCurrentErrorScope = AcquireRef(new ErrorScope(filter, mCurrentErrorScope.Get())); |
| } |
| |
| bool DeviceBase::PopErrorScope(wgpu::ErrorCallback callback, void* userdata) { |
| if (DAWN_UNLIKELY(mCurrentErrorScope.Get() == mRootErrorScope.Get())) { |
| return false; |
| } |
| mCurrentErrorScope->SetCallback(callback, userdata); |
| mCurrentErrorScope = Ref<ErrorScope>(mCurrentErrorScope->GetParent()); |
| |
| return true; |
| } |
| |
| ErrorScope* DeviceBase::GetCurrentErrorScope() { |
| ASSERT(mCurrentErrorScope.Get() != nullptr); |
| return mCurrentErrorScope.Get(); |
| } |
| |
| MaybeError DeviceBase::ValidateObject(const ObjectBase* object) const { |
| ASSERT(object != nullptr); |
| if (DAWN_UNLIKELY(object->GetDevice() != this)) { |
| return DAWN_VALIDATION_ERROR("Object from a different device."); |
| } |
| if (DAWN_UNLIKELY(object->IsError())) { |
| return DAWN_VALIDATION_ERROR("Object is an error."); |
| } |
| return {}; |
| } |
| |
| MaybeError DeviceBase::ValidateIsAlive() const { |
| if (DAWN_LIKELY(mLossStatus == LossStatus::Alive)) { |
| return {}; |
| } |
| return DAWN_DEVICE_LOST_ERROR("Device is lost"); |
| } |
| |
| void DeviceBase::HandleLoss(const char* message) { |
| if (mLossStatus == LossStatus::AlreadyLost) { |
| return; |
| } |
| |
| Destroy(); |
| mLossStatus = LossStatus::AlreadyLost; |
| |
| if (mDeviceLostCallback) { |
| mDeviceLostCallback(message, mDeviceLostUserdata); |
| } |
| } |
| |
| void DeviceBase::LoseForTesting() { |
| mLossStatus = LossStatus::BeingLost; |
| // Assert that errors are device loss so that we can continue with destruction |
| AssertAndIgnoreDeviceLossError(WaitForIdleForDestruction()); |
| HandleError(wgpu::ErrorType::DeviceLost, "Device lost for testing"); |
| } |
| |
| bool DeviceBase::IsLost() const { |
| return mLossStatus != LossStatus::Alive; |
| } |
| |
| AdapterBase* DeviceBase::GetAdapter() const { |
| return mAdapter; |
| } |
| |
| dawn_platform::Platform* DeviceBase::GetPlatform() const { |
| return GetAdapter()->GetInstance()->GetPlatform(); |
| } |
| |
| ErrorScopeTracker* DeviceBase::GetErrorScopeTracker() const { |
| return mErrorScopeTracker.get(); |
| } |
| |
| FenceSignalTracker* DeviceBase::GetFenceSignalTracker() const { |
| return mFenceSignalTracker.get(); |
| } |
| |
| ResultOrError<const Format*> DeviceBase::GetInternalFormat(wgpu::TextureFormat format) const { |
| size_t index = ComputeFormatIndex(format); |
| if (index >= mFormatTable.size()) { |
| return DAWN_VALIDATION_ERROR("Unknown texture format"); |
| } |
| |
| const Format* internalFormat = &mFormatTable[index]; |
| if (!internalFormat->isSupported) { |
| return DAWN_VALIDATION_ERROR("Unsupported texture format"); |
| } |
| |
| return internalFormat; |
| } |
| |
| const Format& DeviceBase::GetValidInternalFormat(wgpu::TextureFormat format) const { |
| size_t index = ComputeFormatIndex(format); |
| ASSERT(index < mFormatTable.size()); |
| ASSERT(mFormatTable[index].isSupported); |
| return mFormatTable[index]; |
| } |
| |
| ResultOrError<BindGroupLayoutBase*> DeviceBase::GetOrCreateBindGroupLayout( |
| const BindGroupLayoutDescriptor* descriptor) { |
| BindGroupLayoutBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->bindGroupLayouts.find(&blueprint); |
| if (iter != mCaches->bindGroupLayouts.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| BindGroupLayoutBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreateBindGroupLayoutImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->bindGroupLayouts.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncacheBindGroupLayout(BindGroupLayoutBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->bindGroupLayouts.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| ResultOrError<ComputePipelineBase*> DeviceBase::GetOrCreateComputePipeline( |
| const ComputePipelineDescriptor* descriptor) { |
| ComputePipelineBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->computePipelines.find(&blueprint); |
| if (iter != mCaches->computePipelines.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| ComputePipelineBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreateComputePipelineImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->computePipelines.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncacheComputePipeline(ComputePipelineBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->computePipelines.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| ResultOrError<PipelineLayoutBase*> DeviceBase::GetOrCreatePipelineLayout( |
| const PipelineLayoutDescriptor* descriptor) { |
| PipelineLayoutBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->pipelineLayouts.find(&blueprint); |
| if (iter != mCaches->pipelineLayouts.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| PipelineLayoutBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreatePipelineLayoutImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->pipelineLayouts.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncachePipelineLayout(PipelineLayoutBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->pipelineLayouts.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| ResultOrError<RenderPipelineBase*> DeviceBase::GetOrCreateRenderPipeline( |
| const RenderPipelineDescriptor* descriptor) { |
| RenderPipelineBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->renderPipelines.find(&blueprint); |
| if (iter != mCaches->renderPipelines.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| RenderPipelineBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreateRenderPipelineImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->renderPipelines.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncacheRenderPipeline(RenderPipelineBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->renderPipelines.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| ResultOrError<SamplerBase*> DeviceBase::GetOrCreateSampler( |
| const SamplerDescriptor* descriptor) { |
| SamplerBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->samplers.find(&blueprint); |
| if (iter != mCaches->samplers.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| SamplerBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreateSamplerImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->samplers.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncacheSampler(SamplerBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->samplers.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| ResultOrError<ShaderModuleBase*> DeviceBase::GetOrCreateShaderModule( |
| const ShaderModuleDescriptor* descriptor) { |
| ShaderModuleBase blueprint(this, descriptor); |
| |
| auto iter = mCaches->shaderModules.find(&blueprint); |
| if (iter != mCaches->shaderModules.end()) { |
| (*iter)->Reference(); |
| return *iter; |
| } |
| |
| ShaderModuleBase* backendObj; |
| DAWN_TRY_ASSIGN(backendObj, CreateShaderModuleImpl(descriptor)); |
| backendObj->SetIsCachedReference(); |
| mCaches->shaderModules.insert(backendObj); |
| return backendObj; |
| } |
| |
| void DeviceBase::UncacheShaderModule(ShaderModuleBase* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->shaderModules.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| Ref<AttachmentState> DeviceBase::GetOrCreateAttachmentState( |
| AttachmentStateBlueprint* blueprint) { |
| auto iter = mCaches->attachmentStates.find(blueprint); |
| if (iter != mCaches->attachmentStates.end()) { |
| return static_cast<AttachmentState*>(*iter); |
| } |
| |
| Ref<AttachmentState> attachmentState = AcquireRef(new AttachmentState(this, *blueprint)); |
| attachmentState->SetIsCachedReference(); |
| mCaches->attachmentStates.insert(attachmentState.Get()); |
| return attachmentState; |
| } |
| |
| Ref<AttachmentState> DeviceBase::GetOrCreateAttachmentState( |
| const RenderBundleEncoderDescriptor* descriptor) { |
| AttachmentStateBlueprint blueprint(descriptor); |
| return GetOrCreateAttachmentState(&blueprint); |
| } |
| |
| Ref<AttachmentState> DeviceBase::GetOrCreateAttachmentState( |
| const RenderPipelineDescriptor* descriptor) { |
| AttachmentStateBlueprint blueprint(descriptor); |
| return GetOrCreateAttachmentState(&blueprint); |
| } |
| |
| Ref<AttachmentState> DeviceBase::GetOrCreateAttachmentState( |
| const RenderPassDescriptor* descriptor) { |
| AttachmentStateBlueprint blueprint(descriptor); |
| return GetOrCreateAttachmentState(&blueprint); |
| } |
| |
| void DeviceBase::UncacheAttachmentState(AttachmentState* obj) { |
| ASSERT(obj->IsCachedReference()); |
| size_t removedCount = mCaches->attachmentStates.erase(obj); |
| ASSERT(removedCount == 1); |
| } |
| |
| // Object creation API methods |
| |
| BindGroupBase* DeviceBase::CreateBindGroup(const BindGroupDescriptor* descriptor) { |
| BindGroupBase* result = nullptr; |
| |
| if (ConsumedError(CreateBindGroupInternal(&result, descriptor))) { |
| return BindGroupBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| BindGroupLayoutBase* DeviceBase::CreateBindGroupLayout( |
| const BindGroupLayoutDescriptor* descriptor) { |
| BindGroupLayoutBase* result = nullptr; |
| |
| if (ConsumedError(CreateBindGroupLayoutInternal(&result, descriptor))) { |
| return BindGroupLayoutBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| BufferBase* DeviceBase::CreateBuffer(const BufferDescriptor* descriptor) { |
| BufferBase* result = nullptr; |
| |
| if (ConsumedError(CreateBufferInternal(&result, descriptor))) { |
| return BufferBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| WGPUCreateBufferMappedResult DeviceBase::CreateBufferMapped( |
| const BufferDescriptor* descriptor) { |
| BufferBase* buffer = nullptr; |
| uint8_t* data = nullptr; |
| |
| uint64_t size = descriptor->size; |
| if (ConsumedError(CreateBufferInternal(&buffer, descriptor)) || |
| ConsumedError(buffer->MapAtCreation(&data))) { |
| // Map failed. Replace the buffer with an error buffer. |
| if (buffer != nullptr) { |
| delete buffer; |
| } |
| buffer = BufferBase::MakeErrorMapped(this, size, &data); |
| } |
| |
| ASSERT(buffer != nullptr); |
| if (data == nullptr) { |
| // |data| may be nullptr if there was an OOM in MakeErrorMapped. |
| // Non-zero dataLength and nullptr data is used to indicate there should be |
| // mapped data but the allocation failed. |
| ASSERT(buffer->IsError()); |
| } else { |
| memset(data, 0, size); |
| } |
| |
| WGPUCreateBufferMappedResult result = {}; |
| result.buffer = reinterpret_cast<WGPUBuffer>(buffer); |
| result.data = data; |
| result.dataLength = size; |
| |
| return result; |
| } |
| void DeviceBase::CreateBufferMappedAsync(const BufferDescriptor* descriptor, |
| wgpu::BufferCreateMappedCallback callback, |
| void* userdata) { |
| WGPUCreateBufferMappedResult result = CreateBufferMapped(descriptor); |
| |
| WGPUBufferMapAsyncStatus status = WGPUBufferMapAsyncStatus_Success; |
| if (IsLost()) { |
| status = WGPUBufferMapAsyncStatus_DeviceLost; |
| } else if (result.data == nullptr || result.dataLength != descriptor->size) { |
| status = WGPUBufferMapAsyncStatus_Error; |
| } |
| |
| DeferredCreateBufferMappedAsync deferred_info; |
| deferred_info.callback = callback; |
| deferred_info.status = status; |
| deferred_info.result = result; |
| deferred_info.userdata = userdata; |
| |
| // The callback is deferred so it matches the async behavior of WebGPU. |
| mDeferredCreateBufferMappedAsyncResults.push_back(deferred_info); |
| } |
| CommandEncoder* DeviceBase::CreateCommandEncoder(const CommandEncoderDescriptor* descriptor) { |
| return new CommandEncoder(this, descriptor); |
| } |
| ComputePipelineBase* DeviceBase::CreateComputePipeline( |
| const ComputePipelineDescriptor* descriptor) { |
| ComputePipelineBase* result = nullptr; |
| |
| if (ConsumedError(CreateComputePipelineInternal(&result, descriptor))) { |
| return ComputePipelineBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| PipelineLayoutBase* DeviceBase::CreatePipelineLayout( |
| const PipelineLayoutDescriptor* descriptor) { |
| PipelineLayoutBase* result = nullptr; |
| |
| if (ConsumedError(CreatePipelineLayoutInternal(&result, descriptor))) { |
| return PipelineLayoutBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| QueueBase* DeviceBase::CreateQueue() { |
| QueueBase* result = nullptr; |
| |
| if (ConsumedError(CreateQueueInternal(&result))) { |
| return QueueBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| SamplerBase* DeviceBase::CreateSampler(const SamplerDescriptor* descriptor) { |
| SamplerBase* result = nullptr; |
| |
| if (ConsumedError(CreateSamplerInternal(&result, descriptor))) { |
| return SamplerBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| RenderBundleEncoder* DeviceBase::CreateRenderBundleEncoder( |
| const RenderBundleEncoderDescriptor* descriptor) { |
| RenderBundleEncoder* result = nullptr; |
| |
| if (ConsumedError(CreateRenderBundleEncoderInternal(&result, descriptor))) { |
| return RenderBundleEncoder::MakeError(this); |
| } |
| |
| return result; |
| } |
| RenderPipelineBase* DeviceBase::CreateRenderPipeline( |
| const RenderPipelineDescriptor* descriptor) { |
| RenderPipelineBase* result = nullptr; |
| |
| if (ConsumedError(CreateRenderPipelineInternal(&result, descriptor))) { |
| return RenderPipelineBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| ShaderModuleBase* DeviceBase::CreateShaderModule(const ShaderModuleDescriptor* descriptor) { |
| ShaderModuleBase* result = nullptr; |
| |
| if (ConsumedError(CreateShaderModuleInternal(&result, descriptor))) { |
| return ShaderModuleBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| SwapChainBase* DeviceBase::CreateSwapChain(Surface* surface, |
| const SwapChainDescriptor* descriptor) { |
| SwapChainBase* result = nullptr; |
| |
| if (ConsumedError(CreateSwapChainInternal(&result, surface, descriptor))) { |
| return SwapChainBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| TextureBase* DeviceBase::CreateTexture(const TextureDescriptor* descriptor) { |
| TextureBase* result = nullptr; |
| |
| if (ConsumedError(CreateTextureInternal(&result, descriptor))) { |
| return TextureBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| TextureViewBase* DeviceBase::CreateTextureView(TextureBase* texture, |
| const TextureViewDescriptor* descriptor) { |
| TextureViewBase* result = nullptr; |
| |
| if (ConsumedError(CreateTextureViewInternal(&result, texture, descriptor))) { |
| return TextureViewBase::MakeError(this); |
| } |
| |
| return result; |
| } |
| |
| // Other Device API methods |
| |
| void DeviceBase::Tick() { |
| // We need to do the deferred callback even if Device is lost since Buffer Map Async will |
| // send callback with device lost status when device is lost. |
| { |
| auto deferredResults = std::move(mDeferredCreateBufferMappedAsyncResults); |
| for (const auto& deferred : deferredResults) { |
| deferred.callback(deferred.status, deferred.result, deferred.userdata); |
| } |
| } |
| if (ConsumedError(ValidateIsAlive())) { |
| return; |
| } |
| if (ConsumedError(TickImpl())) { |
| return; |
| } |
| |
| mErrorScopeTracker->Tick(GetCompletedCommandSerial()); |
| mFenceSignalTracker->Tick(GetCompletedCommandSerial()); |
| } |
| |
| void DeviceBase::Reference() { |
| ASSERT(mRefCount != 0); |
| mRefCount++; |
| } |
| |
| void DeviceBase::Release() { |
| ASSERT(mRefCount != 0); |
| mRefCount--; |
| if (mRefCount == 0) { |
| delete this; |
| } |
| } |
| |
| void DeviceBase::ApplyToggleOverrides(const DeviceDescriptor* deviceDescriptor) { |
| ASSERT(deviceDescriptor); |
| |
| for (const char* toggleName : deviceDescriptor->forceEnabledToggles) { |
| Toggle toggle = GetAdapter()->GetInstance()->ToggleNameToEnum(toggleName); |
| if (toggle != Toggle::InvalidEnum) { |
| mTogglesSet.SetToggle(toggle, true); |
| } |
| } |
| for (const char* toggleName : deviceDescriptor->forceDisabledToggles) { |
| Toggle toggle = GetAdapter()->GetInstance()->ToggleNameToEnum(toggleName); |
| if (toggle != Toggle::InvalidEnum) { |
| mTogglesSet.SetToggle(toggle, false); |
| } |
| } |
| } |
| |
| void DeviceBase::ApplyExtensions(const DeviceDescriptor* deviceDescriptor) { |
| ASSERT(deviceDescriptor); |
| ASSERT(GetAdapter()->SupportsAllRequestedExtensions(deviceDescriptor->requiredExtensions)); |
| |
| mEnabledExtensions = GetAdapter()->GetInstance()->ExtensionNamesToExtensionsSet( |
| deviceDescriptor->requiredExtensions); |
| } |
| |
| std::vector<const char*> DeviceBase::GetEnabledExtensions() const { |
| return mEnabledExtensions.GetEnabledExtensionNames(); |
| } |
| |
| std::vector<const char*> DeviceBase::GetTogglesUsed() const { |
| return mTogglesSet.GetEnabledToggleNames(); |
| } |
| |
| bool DeviceBase::IsExtensionEnabled(Extension extension) const { |
| return mEnabledExtensions.IsEnabled(extension); |
| } |
| |
| bool DeviceBase::IsToggleEnabled(Toggle toggle) const { |
| return mTogglesSet.IsEnabled(toggle); |
| } |
| |
| bool DeviceBase::IsValidationEnabled() const { |
| return !IsToggleEnabled(Toggle::SkipValidation); |
| } |
| |
| size_t DeviceBase::GetLazyClearCountForTesting() { |
| return mLazyClearCountForTesting; |
| } |
| |
| void DeviceBase::IncrementLazyClearCountForTesting() { |
| ++mLazyClearCountForTesting; |
| } |
| |
| void DeviceBase::SetDefaultToggles() { |
| // Sets the default-enabled toggles |
| mTogglesSet.SetToggle(Toggle::LazyClearResourceOnFirstUse, true); |
| } |
| |
| // Implementation details of object creation |
| |
| MaybeError DeviceBase::CreateBindGroupInternal(BindGroupBase** result, |
| const BindGroupDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateBindGroupDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, CreateBindGroupImpl(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateBindGroupLayoutInternal( |
| BindGroupLayoutBase** result, |
| const BindGroupLayoutDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateBindGroupLayoutDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, GetOrCreateBindGroupLayout(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateBufferInternal(BufferBase** result, |
| const BufferDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateBufferDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, CreateBufferImpl(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateComputePipelineInternal( |
| ComputePipelineBase** result, |
| const ComputePipelineDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateComputePipelineDescriptor(this, descriptor)); |
| } |
| |
| if (descriptor->layout == nullptr) { |
| ComputePipelineDescriptor descriptorWithDefaultLayout = *descriptor; |
| |
| DAWN_TRY_ASSIGN( |
| descriptorWithDefaultLayout.layout, |
| PipelineLayoutBase::CreateDefault(this, &descriptor->computeStage.module, 1)); |
| // Ref will keep the pipeline layout alive until the end of the function where |
| // the pipeline will take another reference. |
| Ref<PipelineLayoutBase> layoutRef = AcquireRef(descriptorWithDefaultLayout.layout); |
| |
| DAWN_TRY_ASSIGN(*result, GetOrCreateComputePipeline(&descriptorWithDefaultLayout)); |
| } else { |
| DAWN_TRY_ASSIGN(*result, GetOrCreateComputePipeline(descriptor)); |
| } |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreatePipelineLayoutInternal( |
| PipelineLayoutBase** result, |
| const PipelineLayoutDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidatePipelineLayoutDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, GetOrCreatePipelineLayout(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateQueueInternal(QueueBase** result) { |
| DAWN_TRY(ValidateIsAlive()); |
| DAWN_TRY_ASSIGN(*result, CreateQueueImpl()); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateRenderBundleEncoderInternal( |
| RenderBundleEncoder** result, |
| const RenderBundleEncoderDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateRenderBundleEncoderDescriptor(this, descriptor)); |
| } |
| *result = new RenderBundleEncoder(this, descriptor); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateRenderPipelineInternal( |
| RenderPipelineBase** result, |
| const RenderPipelineDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateRenderPipelineDescriptor(this, descriptor)); |
| } |
| |
| if (descriptor->layout == nullptr) { |
| RenderPipelineDescriptor descriptorWithDefaultLayout = *descriptor; |
| |
| const ShaderModuleBase* modules[2]; |
| modules[0] = descriptor->vertexStage.module; |
| uint32_t count; |
| if (descriptor->fragmentStage == nullptr) { |
| count = 1; |
| } else { |
| modules[1] = descriptor->fragmentStage->module; |
| count = 2; |
| } |
| |
| DAWN_TRY_ASSIGN(descriptorWithDefaultLayout.layout, |
| PipelineLayoutBase::CreateDefault(this, modules, count)); |
| // Ref will keep the pipeline layout alive until the end of the function where |
| // the pipeline will take another reference. |
| Ref<PipelineLayoutBase> layoutRef = AcquireRef(descriptorWithDefaultLayout.layout); |
| |
| DAWN_TRY_ASSIGN(*result, GetOrCreateRenderPipeline(&descriptorWithDefaultLayout)); |
| } else { |
| DAWN_TRY_ASSIGN(*result, GetOrCreateRenderPipeline(descriptor)); |
| } |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateSamplerInternal(SamplerBase** result, |
| const SamplerDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateSamplerDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, GetOrCreateSampler(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateShaderModuleInternal(ShaderModuleBase** result, |
| const ShaderModuleDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateShaderModuleDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, GetOrCreateShaderModule(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateSwapChainInternal(SwapChainBase** result, |
| Surface* surface, |
| const SwapChainDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateSwapChainDescriptor(this, surface, descriptor)); |
| } |
| |
| if (surface == nullptr) { |
| DAWN_TRY_ASSIGN(*result, CreateSwapChainImpl(descriptor)); |
| } else { |
| ASSERT(descriptor->implementation == 0); |
| |
| NewSwapChainBase* previousSwapChain = surface->GetAttachedSwapChain(); |
| NewSwapChainBase* newSwapChain; |
| DAWN_TRY_ASSIGN(newSwapChain, |
| CreateSwapChainImpl(surface, previousSwapChain, descriptor)); |
| |
| if (previousSwapChain != nullptr) { |
| ASSERT(!previousSwapChain->IsAttached()); |
| } |
| ASSERT(newSwapChain->IsAttached()); |
| |
| surface->SetAttachedSwapChain(newSwapChain); |
| *result = newSwapChain; |
| } |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateTextureInternal(TextureBase** result, |
| const TextureDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateTextureDescriptor(this, descriptor)); |
| } |
| DAWN_TRY_ASSIGN(*result, CreateTextureImpl(descriptor)); |
| return {}; |
| } |
| |
| MaybeError DeviceBase::CreateTextureViewInternal(TextureViewBase** result, |
| TextureBase* texture, |
| const TextureViewDescriptor* descriptor) { |
| DAWN_TRY(ValidateIsAlive()); |
| DAWN_TRY(ValidateObject(texture)); |
| TextureViewDescriptor desc = GetTextureViewDescriptorWithDefaults(texture, descriptor); |
| if (IsValidationEnabled()) { |
| DAWN_TRY(ValidateTextureViewDescriptor(texture, &desc)); |
| } |
| DAWN_TRY_ASSIGN(*result, CreateTextureViewImpl(texture, &desc)); |
| return {}; |
| } |
| |
| // Other implementation details |
| |
| DynamicUploader* DeviceBase::GetDynamicUploader() const { |
| return mDynamicUploader.get(); |
| } |
| |
| void DeviceBase::SetToggle(Toggle toggle, bool isEnabled) { |
| mTogglesSet.SetToggle(toggle, isEnabled); |
| } |
| |
| } // namespace dawn_native |