Page MenuHomePhorge
Files F32226143

D3626.1765212045.diff
No OneTemporary
Actions

Size
3 KB
Referenced Files
None
Subscribers
None

D3626.1765212045.diff
View Options

diff --git a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientBidiReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientBidiReactorBase.h
--- a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientBidiReactorBase.h
+++ b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientBidiReactorBase.h
@@ -36,10 +36,15 @@
template <class Request, class Response>
void ClientBidiReactorBase<Request, Response>::nextWrite() {
this->request = Request();
- std::unique_ptr<grpc::Status> status =
- this->prepareRequest(this->request, this->response);
- if (status != nullptr) {
- this->terminate(*status);
+ try {
+ std::unique_ptr<grpc::Status> status =
+ this->prepareRequest(this->request, this->response);
+ if (status != nullptr) {
+ this->terminate(*status);
+ return;
+ }
+ } catch (std::runtime_error &e) {
+ this->terminate(grpc::Status(grpc::StatusCode::INTERNAL, e.what()));
return;
}
this->StartWrite(&this->request);
diff --git a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientReadReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientReadReactorBase.h
--- a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientReadReactorBase.h
+++ b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientReadReactorBase.h
@@ -68,10 +68,14 @@
this->terminate(grpc::Status::OK);
return;
}
- std::unique_ptr<grpc::Status> status = this->readResponse(this->response);
- if (status != nullptr) {
- this->terminate(*status);
- return;
+ try {
+ std::unique_ptr<grpc::Status> status = this->readResponse(this->response);
+ if (status != nullptr) {
+ this->terminate(*status);
+ return;
+ }
+ } catch (std::runtime_error &e) {
+ this->terminate(grpc::Status(grpc::StatusCode::INTERNAL, e.what()));
}
this->StartRead(&this->response);
}
diff --git a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientWriteReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientWriteReactorBase.h
--- a/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientWriteReactorBase.h
+++ b/services/backup/docker-server/contents/server/src/Reactors/client/base-reactors/ClientWriteReactorBase.h
@@ -30,10 +30,14 @@
template <class Request, class Response>
void ClientWriteReactorBase<Request, Response>::nextWrite() {
this->request = Request();
- std::unique_ptr<grpc::Status> status = this->prepareRequest(this->request);
- if (status != nullptr) {
- this->terminate(*status);
- return;
+ try {
+ std::unique_ptr<grpc::Status> status = this->prepareRequest(this->request);
+ if (status != nullptr) {
+ this->terminate(*status);
+ return;
+ }
+ } catch (std::runtime_error &e) {
+ this->terminate(grpc::Status(grpc::StatusCode::INTERNAL, e.what()));
}
this->StartWrite(&this->request);
if (!this->initialized) {

File Metadata

Mime Type
text/plain
Expires
Mon, Dec 8, 4:40 PM (4 h, 49 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
5849241
Default Alt Text
D3626.1765212045.diff (3 KB)

Event Timeline