tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Apply changes from code-review

Browse Source
This commit is contained in:
gvolfing 2023-01-25 12:42:44 +01:00
parent 3bc9c571a0
commit e24a6a86e4
2 changed files with 5 additions and 14 deletions

2
src/query/v2/interpreter.hpp
View File

@ -16,8 +16,6 @@
#include "coordinator/coordinator.hpp"
#include "coordinator/coordinator_client.hpp"
#include "io/local_transport/local_transport.hpp"
#include "io/simulator/simulator_transport.hpp"
#include "io/transport.hpp"
#include "query/v2/auth_checker.hpp"
#include "query/v2/bindings/cypher_main_visitor.hpp"

17
src/query/v2/request_router.hpp
View File

@ -27,7 +27,8 @@
#include <variant>
#include <vector>
#include "boost/uuid/uuid.hpp"
#include <boost/uuid/uuid.hpp>
#include "coordinator/coordinator.hpp"
#include "coordinator/coordinator_client.hpp"
#include "coordinator/coordinator_rsm.hpp"
@ -744,15 +745,6 @@ class RequestRouter : public RequestRouterInterface {
};
class RequestRouterFactory {
protected:
using LocalTransport = io::Io<io::local_transport::LocalTransport>;
using SimulatorTransport = io::Io<io::simulator::SimulatorTransport>;
using LocalTransportHandlePtr = std::shared_ptr<io::local_transport::LocalTransportHandle>;
using SimulatorTransportHandlePtr = std::shared_ptr<io::simulator::SimulatorHandle>;
using TransportHandleVariant = std::variant<LocalTransportHandlePtr, SimulatorTransportHandlePtr>;
public:
RequestRouterFactory() = default;
RequestRouterFactory(const RequestRouterFactory &) = delete;
@ -767,10 +759,11 @@ class RequestRouterFactory {
};
class LocalRequestRouterFactory : public RequestRouterFactory {
io::Io<memgraph::io::local_transport::LocalTransport> &io_;
using LocalTransportIo = io::Io<io::local_transport::LocalTransport>;
LocalTransportIo &io_;
public:
explicit LocalRequestRouterFactory(io::Io<memgraph::io::local_transport::LocalTransport> &io) : io_(io) {}
explicit LocalRequestRouterFactory(LocalTransportIo &io) : io_(io) {}
std::unique_ptr<RequestRouterInterface> CreateRequestRouter(
const coordinator::Address &coordinator_address) const override {