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 @@ -54,6 +54,9 @@ if (this->done) { return; } + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->StartWritesDone(); this->status = status; this->done = true; 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 @@ -34,6 +34,9 @@ if (this->done) { return; } + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->status = status; this->done = true; } 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 @@ -56,6 +56,9 @@ if (this->done) { return; } + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->status = status; this->done = true; this->StartWritesDone(); diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerBidiReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerBidiReactorBase.h --- a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerBidiReactorBase.h +++ b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerBidiReactorBase.h @@ -61,6 +61,9 @@ void ServerBidiReactorBase::terminate( ServerBidiReactorStatus status) { this->status = status; + if (!this->status.status.ok()) { + std::cout << "error: " << this->status.status.error_message() << std::endl; + } if (this->status.sendLastResponse) { this->StartWriteAndFinish( &this->response, grpc::WriteOptions(), this->status.status); diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerReadReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerReadReactorBase.h --- a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerReadReactorBase.h +++ b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerReadReactorBase.h @@ -33,6 +33,9 @@ template void ServerReadReactorBase::terminate(grpc::Status status) { + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->status = status; this->Finish(status); } diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerWriteReactorBase.h b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerWriteReactorBase.h --- a/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerWriteReactorBase.h +++ b/services/backup/docker-server/contents/server/src/Reactors/server/base-reactors/ServerWriteReactorBase.h @@ -36,6 +36,9 @@ template void ServerWriteReactorBase::terminate(grpc::Status status) { + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->status = status; this->Finish(status); } diff --git a/services/blob/src/Reactors/server/base-reactors/ServerBidiReactorBase.h b/services/blob/src/Reactors/server/base-reactors/ServerBidiReactorBase.h --- a/services/blob/src/Reactors/server/base-reactors/ServerBidiReactorBase.h +++ b/services/blob/src/Reactors/server/base-reactors/ServerBidiReactorBase.h @@ -61,6 +61,9 @@ void ServerBidiReactorBase::terminate( ServerBidiReactorStatus status) { this->status = status; + if (!this->status.status.ok()) { + std::cout << "error: " << this->status.status.error_message() << std::endl; + } if (this->status.sendLastResponse) { this->StartWriteAndFinish( &this->response, grpc::WriteOptions(), this->status.status); diff --git a/services/blob/src/Reactors/server/base-reactors/ServerReadReactorBase.h b/services/blob/src/Reactors/server/base-reactors/ServerReadReactorBase.h --- a/services/blob/src/Reactors/server/base-reactors/ServerReadReactorBase.h +++ b/services/blob/src/Reactors/server/base-reactors/ServerReadReactorBase.h @@ -33,6 +33,9 @@ template void ServerReadReactorBase::terminate(grpc::Status status) { + if (!this->status.ok()) { + std::cout << "error: " << this->status.error_message() << std::endl; + } this->status = status; this->Finish(status); }