diff --git a/services/backup/docker-server/contents/server/src/Reactors/client/blob/BlobPutClientReactor.h b/services/backup/docker-server/contents/server/src/Reactors/client/blob/BlobPutClientReactor.h --- a/services/backup/docker-server/contents/server/src/Reactors/client/blob/BlobPutClientReactor.h +++ b/services/backup/docker-server/contents/server/src/Reactors/client/blob/BlobPutClientReactor.h @@ -35,6 +35,7 @@ GRPC_CHUNK_SIZE_LIMIT - GRPC_METADATA_SIZE_PER_MESSAGE; folly::MPMCQueue dataChunks; std::condition_variable *terminationNotifier; + bool dataExists = false; public: BlobPutClientReactor( @@ -47,6 +48,7 @@ std::shared_ptr previousResponse) override; void doneCallback() override; grpc::Status getStatus() const; + bool getDataExists() const; }; BlobPutClientReactor::BlobPutClientReactor( @@ -81,6 +83,7 @@ return nullptr; } if (previousResponse->dataexists()) { + this->dataExists = true; return std::make_unique(grpc::Status::OK); } std::string dataChunk; @@ -100,6 +103,10 @@ return this->status; } +bool BlobPutClientReactor::getDataExists() const { + return this->dataExists; +} + } // namespace reactor } // namespace network } // namespace comm