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 @@ -33,6 +33,7 @@ virtual std::unique_ptr writeResponse(Response *response) = 0; virtual void initialize(){}; + virtual void validate(){}; virtual void doneCallback(){}; virtual void terminateCallback(){}; }; @@ -42,6 +43,7 @@ this->status = status; try { this->terminateCallback(); + this->validate(); } catch (std::runtime_error &e) { this->status = grpc::Status(grpc::StatusCode::INTERNAL, e.what()); } diff --git a/services/blob/src/Reactors/server/base-reactors/ServerWriteReactorBase.h b/services/blob/src/Reactors/server/base-reactors/ServerWriteReactorBase.h --- a/services/blob/src/Reactors/server/base-reactors/ServerWriteReactorBase.h +++ b/services/blob/src/Reactors/server/base-reactors/ServerWriteReactorBase.h @@ -33,6 +33,7 @@ virtual std::unique_ptr writeResponse(Response *response) = 0; virtual void initialize(){}; + virtual void validate(){}; virtual void doneCallback(){}; virtual void terminateCallback(){}; }; @@ -42,6 +43,7 @@ this->status = status; try { this->terminateCallback(); + this->validate(); } catch (std::runtime_error &e) { this->status = grpc::Status(grpc::StatusCode::INTERNAL, e.what()); }