diff --git a/gloo/transport/uv/pair.cc b/gloo/transport/uv/pair.cc index 817acc662..636583945 100644 --- a/gloo/transport/uv/pair.cc +++ b/gloo/transport/uv/pair.cc @@ -52,6 +52,11 @@ const Address& Pair::address() const { return addr_; } +bool Pair::isConnected() { + std::lock_guard lock(mutex_); + return state_ == CONNECTED; +} + void Pair::connect(const std::vector& bytes) { const auto peer = Address(bytes); diff --git a/gloo/transport/uv/pair.h b/gloo/transport/uv/pair.h index 56557892e..510c9619b 100644 --- a/gloo/transport/uv/pair.h +++ b/gloo/transport/uv/pair.h @@ -150,6 +150,8 @@ class Pair : public ::gloo::transport::Pair { void close() override; + bool isConnected() override; + private: std::mutex mutex_; std::condition_variable cv_;