rippled
Loading...
Searching...
No Matches
NodeStoreScheduler.h
1#pragma once
2
3#include <xrpl/core/JobQueue.h>
4#include <xrpl/nodestore/Scheduler.h>
5
6namespace xrpl {
7
10{
11public:
12 explicit NodeStoreScheduler(JobQueue& jobQueue);
13
14 void
15 scheduleTask(NodeStore::Task& task) override;
16 void
17 onFetch(NodeStore::FetchReport const& report) override;
18 void
19 onBatchWrite(NodeStore::BatchWriteReport const& report) override;
20
21private:
23};
24
25} // namespace xrpl
A pool of threads to perform work.
Definition JobQueue.h:37
A NodeStore::Scheduler which uses the JobQueue.
void onBatchWrite(NodeStore::BatchWriteReport const &report) override
Reports the completion of a batch write Allows the scheduler to monitor the node store's performance.
void scheduleTask(NodeStore::Task &task) override
Schedules a task.
void onFetch(NodeStore::FetchReport const &report) override
Reports completion of a fetch Allows the scheduler to monitor the node store's performance.
Scheduling for asynchronous backend activity.
Use hash_* containers for keys that do not need a cryptographically secure hashing algorithm.
Definition algorithm.h:5
Contains information about a batch write operation.
Contains information about a fetch operation.
Derived classes perform scheduled tasks.
Definition Task.h:8