rippled
Loading...
Searching...
No Matches
NodeStoreScheduler.h
1#ifndef XRPL_APP_MAIN_NODESTORESCHEDULER_H_INCLUDED
2#define XRPL_APP_MAIN_NODESTORESCHEDULER_H_INCLUDED
3
4#include <xrpld/core/JobQueue.h>
5
6#include <xrpl/nodestore/Scheduler.h>
7
8namespace ripple {
9
12{
13public:
14 explicit NodeStoreScheduler(JobQueue& jobQueue);
15
16 void
17 scheduleTask(NodeStore::Task& task) override;
18 void
19 onFetch(NodeStore::FetchReport const& report) override;
20 void
21 onBatchWrite(NodeStore::BatchWriteReport const& report) override;
22
23private:
25};
26
27} // namespace ripple
28
29#endif
A pool of threads to perform work.
Definition JobQueue.h:39
A NodeStore::Scheduler which uses the JobQueue.
void onFetch(NodeStore::FetchReport const &report) override
Reports completion of a fetch Allows the scheduler to monitor the node store's performance.
void scheduleTask(NodeStore::Task &task) override
Schedules a task.
void onBatchWrite(NodeStore::BatchWriteReport const &report) override
Reports the completion of a batch write 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:6
Contains information about a batch write operation.
Contains information about a fetch operation.
Derived classes perform scheduled tasks.
Definition Task.h:9