Skip to content

sgns::processing::ProcessingCoreImpl

Default implementation of ProcessingCore backed by GlobalDB.

#include <processing_core_impl.hpp>

Inherits from sgns::processing::ProcessingCore

Public Types

Name
enum class Error

Public Functions

Name
ProcessingCoreImpl(std::shared_ptr< sgns::crdt::GlobalDB > db, size_t maximalProcessingSubTaskCount, TokenID tokenId)
~ProcessingCoreImpl()
virtual outcome::result< SGProcessing::SubTaskResult > ProcessSubTask(const SGProcessing::SubTask & subTask, uint32_t initialHashCode) override
virtual float GetProgress() const override

Public Attributes

Name
std::vector< size_t > m_chunkResulHashes
std::vector< size_t > m_validationChunkHashes

Additional inherited members

Public Functions inherited from sgns::processing::ProcessingCore

Name
virtual ~ProcessingCore() =default

Public Types Documentation

enum Error

Enumerator Value Description
MAX_NUMBER_SUBTASKS 1
GLOBALDB_READ_ERROR
NO_BUFFER_FROM_JOB_DATA

Public Functions Documentation

function ProcessingCoreImpl

inline ProcessingCoreImpl(
    std::shared_ptr< sgns::crdt::GlobalDB > db,
    size_t maximalProcessingSubTaskCount,
    TokenID tokenId
)

function ~ProcessingCoreImpl

inline ~ProcessingCoreImpl()

function ProcessSubTask

virtual outcome::result< SGProcessing::SubTaskResult > ProcessSubTask(
    const SGProcessing::SubTask & subTask,
    uint32_t initialHashCode
) override

Parameters:

  • subTask - Subtask that needs to be processed.
  • initialHashCode - Initial hash code used to calculate result hash.

Reimplements: sgns::processing::ProcessingCore::ProcessSubTask

Process a single subtask.

function GetProgress

virtual float GetProgress() const override

Return: Progress percentage (0.0 to 100.0).

Reimplements: sgns::processing::ProcessingCore::GetProgress

Get current processing progress.

Public Attributes Documentation

variable m_chunkResulHashes

std::vector< size_t > m_chunkResulHashes;

variable m_validationChunkHashes

std::vector< size_t > m_validationChunkHashes;

Updated on 2026-04-15 at 11:00:39 -0700