diff --git a/.gitignore b/.gitignore index 7e1ef8dfd..e4012589a 100644 --- a/.gitignore +++ b/.gitignore @@ -52,6 +52,8 @@ src/distributed/data_rpc_messages.capnp src/distributed/data_rpc_messages.hpp src/distributed/durability_rpc_messages.capnp src/distributed/durability_rpc_messages.hpp +src/distributed/dynamic_worker_rpc_messages.capnp +src/distributed/dynamic_worker_rpc_messages.hpp src/distributed/index_rpc_messages.capnp src/distributed/index_rpc_messages.hpp src/distributed/plan_rpc_messages.capnp diff --git a/src/database/distributed_graph_db.cpp b/src/database/distributed_graph_db.cpp index 3c3b8283a..c1403e6e2 100644 --- a/src/database/distributed_graph_db.cpp +++ b/src/database/distributed_graph_db.cpp @@ -990,7 +990,6 @@ Worker::Worker(Config config) // Durability recovery. We need to check this flag for workers that are added // after the "main" cluster recovery. if (impl_->config_.db_recover_on_startup) { - // What we should recover. // What we should recover (version, transaction_id) pair. auto snapshot_to_recover = impl_->cluster_discovery_.snapshot_to_recover(); diff --git a/src/distributed/dynamic_worker_rpc_messages.capnp b/src/distributed/dynamic_worker_rpc_messages.capnp deleted file mode 100644 index 7a76c5be4..000000000 --- a/src/distributed/dynamic_worker_rpc_messages.capnp +++ /dev/null @@ -1,18 +0,0 @@ -# -*- buffer-read-only: t; -*- -# vim: readonly -# DO NOT EDIT! Generated using LCP from 'dynamic_worker_rpc_messages.lcp' - -@0x8c53f6c9a0c71b05; - -using Cxx = import "/capnp/c++.capnp"; -$Cxx.namespace("distributed::capnp"); - -using Utils = import "/utils/serialization.capnp"; - -struct DynamicWorkerRes { - recoverIndices @0 :List(Utils.Pair(Text, Text)); -} - -struct DynamicWorkerReq { -} - diff --git a/src/distributed/dynamic_worker_rpc_messages.hpp b/src/distributed/dynamic_worker_rpc_messages.hpp deleted file mode 100644 index 824b70b84..000000000 --- a/src/distributed/dynamic_worker_rpc_messages.hpp +++ /dev/null @@ -1,48 +0,0 @@ -// -*- buffer-read-only: t; -*- -// vim: readonly -// DO NOT EDIT! Generated using LCP from 'dynamic_worker_rpc_messages.lcp' - -#pragma once - -#include <string> -#include <vector> - -#include "communication/rpc/messages.hpp" -#include "distributed/dynamic_worker_rpc_messages.capnp.h" - -namespace distributed { - -struct DynamicWorkerReq { - using Capnp = capnp::DynamicWorkerReq; - static const communication::rpc::MessageType TypeInfo; - DynamicWorkerReq() {} - - void Save(capnp::DynamicWorkerReq::Builder *builder) const; - - static std::unique_ptr<DynamicWorkerReq> Construct( - const capnp::DynamicWorkerReq::Reader &reader); - - void Load(const capnp::DynamicWorkerReq::Reader &reader); -}; - -struct DynamicWorkerRes { - using Capnp = capnp::DynamicWorkerRes; - static const communication::rpc::MessageType TypeInfo; - DynamicWorkerRes() {} - explicit DynamicWorkerRes( - std::vector<std::pair<std::string, std::string>> recover_indices) - : recover_indices(recover_indices) {} - - std::vector<std::pair<std::string, std::string>> recover_indices; - - void Save(capnp::DynamicWorkerRes::Builder *builder) const; - - static std::unique_ptr<DynamicWorkerRes> Construct( - const capnp::DynamicWorkerRes::Reader &reader); - - void Load(const capnp::DynamicWorkerRes::Reader &reader); -}; - -using DynamicWorkerRpc = - communication::rpc::RequestResponse<DynamicWorkerReq, DynamicWorkerRes>; -}