server_runner.hpp

Go to the documentation of this file.

#ifndef MAIN_SERVER_RUNNER_HPP
#define MAIN_SERVER_RUNNER_HPP

#include <condition_variable>

#include <grpc++/grpc++.h>
#include <grpc++/impl/codegen/service_type.h>
#include "common/result.hpp"
#include "logger/logger_fwd.hpp"

namespace iroha {
  namespace network {
    struct TlsCredentials;

    class ServerRunner {
     public:
      explicit ServerRunner(
          const std::string &address,
          logger::LoggerPtr log,
          bool reuse = true,
          const boost::optional<std::shared_ptr<const TlsCredentials>>
              &my_tls_creds = boost::none);

      ~ServerRunner();

      ServerRunner &append(std::shared_ptr<grpc::Service> service);

      iroha::expected::Result<int, std::string> run();

      void waitForServersReady();

      void shutdown();

      void shutdown(const std::chrono::system_clock::time_point &deadline);

     private:
      logger::LoggerPtr log_;

      std::unique_ptr<grpc::Server> server_instance_;
      std::mutex wait_for_server_;
      std::condition_variable server_instance_cv_;

      std::string server_address_;
      std::shared_ptr<grpc::ServerCredentials> credentials_;
      bool reuse_;
      std::vector<std::shared_ptr<grpc::Service>> services_;
    };

  }  // namespace network
}  // namespace iroha

#endif  // MAIN_SERVER_RUNNER_HPP