impeller::PipelineLibraryVK Class Reference

#include <pipeline_library_vk.h>

Inheritance diagram for impeller::PipelineLibraryVK:

Public Member Functions
	~PipelineLibraryVK () override
void	DidAcquireSurfaceFrame ()
const std::shared_ptr< PipelineCacheVK > &	GetPSOCache () const
const std::shared_ptr< fml::ConcurrentTaskRunner > &	GetWorkerTaskRunner () const
Public Member Functions inherited from impeller::PipelineLibrary
virtual	~PipelineLibrary ()
PipelineFuture< PipelineDescriptor >	GetPipeline (std::optional< PipelineDescriptor > descriptor)
PipelineFuture< ComputePipelineDescriptor >	GetPipeline (std::optional< ComputePipelineDescriptor > descriptor)

Private Member Functions
bool	IsValid () const override
PipelineFuture< PipelineDescriptor >	GetPipeline (PipelineDescriptor descriptor) override
PipelineFuture< ComputePipelineDescriptor >	GetPipeline (ComputePipelineDescriptor descriptor) override
void	RemovePipelinesWithEntryPoint (std::shared_ptr< const ShaderFunction > function) override

Additional Inherited Members
Static Public Member Functions inherited from impeller::BackendCast< PipelineLibraryVK, PipelineLibrary >
static PipelineLibraryVK &	Cast (PipelineLibrary &base)
static const PipelineLibraryVK &	Cast (const PipelineLibrary &base)
static PipelineLibraryVK *	Cast (PipelineLibrary *base)
static const PipelineLibraryVK *	Cast (const PipelineLibrary *base)
Protected Member Functions inherited from impeller::PipelineLibrary
	PipelineLibrary ()

Detailed Description

Definition at line 26 of file pipeline_library_vk.h.

Constructor & Destructor Documentation

~PipelineLibraryVK()

impeller::PipelineLibraryVK::~PipelineLibraryVK ( )

overridedefault

Member Function Documentation

DidAcquireSurfaceFrame()

void impeller::PipelineLibraryVK::DidAcquireSurfaceFrame

(

)

Definition at line 257 of file pipeline_library_vk.cc.

                                               {
  if (++frames_acquired_ == 50u) {
    PersistPipelineCacheToDisk();
  }
}

GetPipeline() [1/2]

PipelineFuture< ComputePipelineDescriptor > impeller::PipelineLibraryVK::GetPipeline ( ComputePipelineDescriptor  descriptor )

overrideprivatevirtual

Implements impeller::PipelineLibrary.

Definition at line 200 of file pipeline_library_vk.cc.

                                          {
  Lock lock(compute_pipelines_mutex_);
  if (auto found = compute_pipelines_.find(descriptor);
      found != compute_pipelines_.end()) {
    return found->second;
  }
 
  if (!IsValid()) {
    return {
        descriptor,
        RealizedFuture<std::shared_ptr<Pipeline<ComputePipelineDescriptor>>>(
            nullptr)};
  }
 
  auto promise = std::make_shared<
      std::promise<std::shared_ptr<Pipeline<ComputePipelineDescriptor>>>>();
  auto pipeline_future = PipelineFuture<ComputePipelineDescriptor>{
      descriptor, promise->get_future()};
  compute_pipelines_[descriptor] = pipeline_future;
 
  auto weak_this = weak_from_this();
 
  worker_task_runner_->PostTask([descriptor, weak_this, promise]() {
    auto self = weak_this.lock();
    if (!self) {
      promise->set_value(nullptr);
      VALIDATION_LOG << "Pipeline library was collected before the pipeline "
                        "could be created.";
      return;
    }
 
    auto pipeline =
        PipelineLibraryVK::Cast(*self).CreateComputePipeline(descriptor);
    if (!pipeline) {
      promise->set_value(nullptr);
      VALIDATION_LOG << "Could not create pipeline: " << descriptor.GetLabel();
      return;
    }
 
    promise->set_value(std::move(pipeline));
  });
 
  return pipeline_future;
}

GetPipeline() [2/2]

PipelineFuture< PipelineDescriptor > impeller::PipelineLibraryVK::GetPipeline ( PipelineDescriptor  descriptor )

overrideprivatevirtual

Implements impeller::PipelineLibrary.

Definition at line 159 of file pipeline_library_vk.cc.

                                   {
  Lock lock(pipelines_mutex_);
  if (auto found = pipelines_.find(descriptor); found != pipelines_.end()) {
    return found->second;
  }
 
  if (!IsValid()) {
    return {
        descriptor,
        RealizedFuture<std::shared_ptr<Pipeline<PipelineDescriptor>>>(nullptr)};
  }
 
  auto promise = std::make_shared<
      NoExceptionPromise<std::shared_ptr<Pipeline<PipelineDescriptor>>>>();
  auto pipeline_future =
      PipelineFuture<PipelineDescriptor>{descriptor, promise->get_future()};
  pipelines_[descriptor] = pipeline_future;
 
  auto weak_this = weak_from_this();
 
  worker_task_runner_->PostTask([descriptor, weak_this, promise]() {
    auto thiz = weak_this.lock();
    if (!thiz) {
      promise->set_value(nullptr);
      VALIDATION_LOG << "Pipeline library was collected before the pipeline "
                        "could be created.";
      return;
    }
 
    promise->set_value(PipelineVK::Create(
        descriptor,                                            //
        PipelineLibraryVK::Cast(*thiz).device_holder_.lock(),  //
        weak_this                                              //
        ));
  });
 
  return pipeline_future;
}

GetPSOCache()

const std::shared_ptr< PipelineCacheVK > & impeller::PipelineLibraryVK::GetPSOCache

(

)

const

Definition at line 274 of file pipeline_library_vk.cc.

                                                                           {
  return pso_cache_;
}

GetWorkerTaskRunner()

const std::shared_ptr< fml::ConcurrentTaskRunner > & impeller::PipelineLibraryVK::GetWorkerTaskRunner

(

)

const

Definition at line 279 of file pipeline_library_vk.cc.

                                             {
  return worker_task_runner_;
}

IsValid()

bool impeller::PipelineLibraryVK::IsValid ( ) const

overrideprivatevirtual

Implements impeller::PipelineLibrary.

Definition at line 48 of file pipeline_library_vk.cc.

                                      {
  return is_valid_;
}

RemovePipelinesWithEntryPoint()

void impeller::PipelineLibraryVK::RemovePipelinesWithEntryPoint ( std::shared_ptr< const ShaderFunction >  function )

overrideprivatevirtual

Implements impeller::PipelineLibrary.

Definition at line 247 of file pipeline_library_vk.cc.

                                                  {
  Lock lock(pipelines_mutex_);
 
  fml::erase_if(pipelines_, [&](auto item) {
    return item->first.GetEntrypointForStage(function->GetStage())
        ->IsEqual(*function);
  });
}

---

The documentation for this class was generated from the following files:

• impeller/renderer/backend/vulkan/pipeline_library_vk.h
• impeller/renderer/backend/vulkan/pipeline_library_vk.cc