onert::backend::trix::ops::BulkPipelineLayer Class Reference

#include <BulkPipelineLayer.h>

Collaboration diagram for onert::backend::trix::ops::BulkPipelineLayer:

Public Member Functions
	BulkPipelineLayer ()
	~BulkPipelineLayer () override
void	configure (const std::vector< const IPortableTensor * > &inputs, std::vector< IPortableTensor * > &outputs, const std::vector< std::string > &binary_path)
void	run () override
void	prepare () override
Public Member Functions inherited from onert::exec::IFunction
virtual	~IFunction ()=default

Detailed Description

Definition at line 28 of file BulkPipelineLayer.h.

Constructor & Destructor Documentation

BulkPipelineLayer()

onert::backend::trix::ops::BulkPipelineLayer::BulkPipelineLayer

(

)

Definition at line 25 of file BulkPipelineLayer.cc.

                                     : _inputs(), _outputs()
{
  // DO NOTHING
}

~BulkPipelineLayer()

onert::backend::trix::ops::BulkPipelineLayer::~BulkPipelineLayer ( )

override

Definition at line 30 of file BulkPipelineLayer.cc.

{
  // DO NOTHING - _pipeline_manager will be automatically cleaned up by unique_ptr
}

Member Function Documentation

configure()

void onert::backend::trix::ops::BulkPipelineLayer::configure	(	const std::vector< const IPortableTensor * > &	inputs,
		std::vector< IPortableTensor * > &	outputs,
		const std::vector< std::string > &	binary_path
	)

Definition at line 35 of file BulkPipelineLayer.cc.

{
  _inputs = inputs;
  _outputs = outputs;
 
  // Configure BulkPipeLineManager
  BulkPipelineManager::PipelineConfig config;
  config.model_paths = binary_path;
  config.device_id = 0;      // default device id = 0
  config.n_owner_models = 2; // Use 2 owner models for buffer sharing
  config.n_inputs = inputs.size();
  config.n_outputs = outputs.size();
 
  _pipeline_manager = std::make_unique<BulkPipelineManager>(config);
 
  if (!_pipeline_manager->initialize())
  {
    throw std::runtime_error("Failed to initialize BulkPipelineManager");
  }
}

prepare()

void onert::backend::trix::ops::BulkPipelineLayer::prepare ( )

overridevirtual

Reimplemented from onert::exec::IFunction.

Definition at line 72 of file BulkPipelineLayer.cc.

{
  // DO NOTHING
}

run()

void onert::backend::trix::ops::BulkPipelineLayer::run ( )

overridevirtual

Implements onert::exec::IFunction.

Definition at line 58 of file BulkPipelineLayer.cc.

{
  try
  {
    _pipeline_manager->execute(_inputs, _outputs);
  }
  catch (const std::exception &e)
  {
    _pipeline_manager->shutdown();
    std::cerr << "BulkPipelineLayer execution failed: " << e.what() << std::endl;
    throw;
  }
}

---

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

• runtime/onert/backend/trix/ops/BulkPipelineLayer.h
• runtime/onert/backend/trix/ops/BulkPipelineLayer.cc