Templatize Asio awaitables for gRPC interfaces (#93)

Author: canepat

cmd/ethbackend_coroutines.cpp

@@ -65,7 +65,7 @@ int main(int argc, char* argv[]) {
 
         // TODO(canepat): handle also secure channel for remote
         silkrpc::ChannelFactory create_channel = [&]() {
-            return ::grpc::CreateChannel(target, ::grpc::InsecureChannelCredentials());
+            return grpc::CreateChannel(target, grpc::InsecureChannelCredentials());
         };
         // TODO(canepat): handle also local (shared-memory) database
         silkrpc::ContextPool context_pool{1, create_channel};

cmd/kv_seek_async_coroutines.cpp

@@ -96,7 +96,7 @@ int main(int argc, char* argv[]) {
 
         // TODO(canepat): handle also secure channel for remote
         silkrpc::ChannelFactory create_channel = [&]() {
-            return ::grpc::CreateChannel(target, ::grpc::InsecureChannelCredentials());
+            return grpc::CreateChannel(target, grpc::InsecureChannelCredentials());
         };
         // TODO(canepat): handle also local (shared-memory) database
         silkrpc::ContextPool context_pool{1, create_channel};

examples/get_latest_block.cpp

@@ -85,7 +85,7 @@ int main(int argc, char* argv[]) {
 
         // TODO(canepat): handle also secure channel for remote
         silkrpc::ChannelFactory create_channel = [&]() {
-            return ::grpc::CreateChannel(target, ::grpc::InsecureChannelCredentials());
+            return grpc::CreateChannel(target, grpc::InsecureChannelCredentials());
         };
         // TODO(canepat): handle also local (shared-memory) database
         silkrpc::ContextPool context_pool{1, create_channel};

silkrpc/context_pool.cpp

@@ -44,8 +44,8 @@ ContextPool::ContextPool(std::size_t pool_size, ChannelFactory create_channel) :
     for (std::size_t i{0}; i < pool_size; ++i) {
         auto io_context = std::make_shared<asio::io_context>();
         auto grpc_channel = create_channel();
-        auto grpc_queue = std::make_unique<::grpc::CompletionQueue>();
-        auto grpc_runner = std::make_unique<grpc::CompletionRunner>(*grpc_queue, *io_context);
+        auto grpc_queue = std::make_unique<grpc::CompletionQueue>();
+        auto grpc_runner = std::make_unique<CompletionRunner>(*grpc_queue, *io_context);
         auto database = std::make_unique<ethdb::kv::RemoteDatabase>(*io_context, grpc_channel, grpc_queue.get()); // TODO(canepat): move elsewhere
         auto backend = std::make_unique<ethbackend::BackEnd>(*io_context, grpc_channel, grpc_queue.get()); // TODO(canepat): move elsewhere
         contexts_.push_back({io_context, std::move(grpc_queue), std::move(grpc_runner), std::move(database), std::move(backend)});

silkrpc/context_pool.hpp

@@ -35,15 +35,15 @@ namespace silkrpc {
 
 struct Context {
     std::shared_ptr<asio::io_context> io_context;
-    std::unique_ptr<::grpc::CompletionQueue> grpc_queue;
-    std::unique_ptr<grpc::CompletionRunner> grpc_runner;
+    std::unique_ptr<grpc::CompletionQueue> grpc_queue;
+    std::unique_ptr<CompletionRunner> grpc_runner;
     std::unique_ptr<ethdb::Database> database;
     std::unique_ptr<ethbackend::BackEnd> backend;
 };
 
 std::ostream& operator<<(std::ostream& out, const Context& c);
 
-using ChannelFactory = std::function<std::shared_ptr<::grpc::Channel>()>;
+using ChannelFactory = std::function<std::shared_ptr<grpc::Channel>()>;
 
 class ContextPool {
 public:
@@ -63,7 +63,7 @@ class ContextPool {
 private:
     // The pool of contexts
     std::vector<Context> contexts_;
-    std::vector<::grpc::CompletionQueue> queues_;
+    std::vector<grpc::CompletionQueue> queues_;
 
     // The work-tracking executors that keep the io_contexts running
     std::list<asio::execution::any_executor<>> work_;