Page MenuHomePhabricator
Files F3713774

D3121.id9352.diff
No OneTemporary
Actions

D3121.id9352.diff
View Options

diff --git a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.h b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.h
--- a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.h
+++ b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.h
@@ -28,6 +28,7 @@
void OnReadInitialMetadataDone(bool ok) override;
void OnReadDone(bool ok) override;
+ void OnDone(const grpc::Status &status) override;
void close();
void setOnOpenCallback(std::function<void()> onOpenCallback);
diff --git a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp
--- a/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp
+++ b/native/cpp/CommonCpp/grpc/ClientGetReadReactor.cpp
@@ -55,3 +55,8 @@
std::lock_guard<std::mutex> guard{this->setReadyStateMutex};
this->setReadyState(SocketStatus::OPEN);
}
+
+void ClientGetReadReactor::OnDone(const grpc::Status &status) {
+ std::lock_guard<std::mutex> guard{this->setReadyStateMutex};
+ this->setReadyState(SocketStatus::CLOSED);
+}

File Metadata

Mime Type
text/plain
Expires
Thu, Jan 9, 7:47 AM (8 h, 52 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2830296
Default Alt Text
D3121.id9352.diff (1012 B)

Event Timeline