diff --git a/src/storage/v3/shard_worker.hpp b/src/storage/v3/shard_worker.hpp index e47f02e97..3ec1d9bb9 100644 --- a/src/storage/v3/shard_worker.hpp +++ b/src/storage/v3/shard_worker.hpp @@ -18,6 +18,9 @@ #include +#include "coordinator/coordinator.hpp" +#include "coordinator/shard_map.hpp" +#include "io/address.hpp" #include "io/future.hpp" #include "io/rsm/raft.hpp" #include "io/time.hpp" @@ -121,10 +124,13 @@ class ShardWorker { } bool Process(Cron &&cron) { - Time ret = Cron(); + Time next_cron = Cron(); + cron.request_next_cron_at.Fill(next_cron); return true; } + bool Process(InitializeRsm &&initialize_rsm) { return true; } + bool Process(Handle &&handle) { return true; } Time Cron() {