From ea69804c612147541f67ab2ac2ceee0d4a229c05 Mon Sep 17 00:00:00 2001 From: Dariusz Sciebura Date: Tue, 23 Jan 2024 09:27:15 +0000 Subject: [PATCH] Add missing isConnected override to uv transport --- gloo/transport/uv/pair.cc | 5 +++++ gloo/transport/uv/pair.h | 2 ++ 2 files changed, 7 insertions(+) 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_;