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¶
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¶
Return: Progress percentage (0.0 to 100.0).
Reimplements: sgns::processing::ProcessingCore::GetProgress
Get current processing progress.
Public Attributes Documentation¶
variable m_chunkResulHashes¶
variable m_validationChunkHashes¶
Updated on 2026-04-15 at 11:00:39 -0700