[services] Blob - Fix test name for storage manager tests
ClosedPublic
Actions

	#pragma once

	#include "ClientReadReactorBase.h"			#include "BlobGetClientReactor.h"

	#include "../_generated/blob.grpc.pb.h"
	#include "../_generated/blob.pb.h"

	#include <folly/MPMCQueue.h>
	#include <grpcpp/grpcpp.h>

	#include <memory>
	#include <string>

	namespace comm {			namespace comm {
	namespace network {			namespace network {
	namespace reactor {			namespace reactor {

	class BlobGetClientReactor
	: public ClientReadReactorBase<blob::GetRequest, blob::GetResponse> {
	std::string holder;
	std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks;

	public:
	BlobGetClientReactor(
	const std::string &holder,
	std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks);

	std::unique_ptr<grpc::Status>
	readResponse(blob::GetResponse &response) override;
	void doneCallback() override;
	grpc::Status getStatus() const;
	};

	BlobGetClientReactor::BlobGetClientReactor(			BlobGetClientReactor::BlobGetClientReactor(
	const std::string &holder,			const std::string &holder,
	std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks)			std::shared_ptr<folly::MPMCQueue<std::string>> dataChunks)
	: holder(holder), dataChunks(dataChunks) {			: holder(holder), dataChunks(dataChunks) {
	}			}

	std::unique_ptr<grpc::Status>			std::unique_ptr<grpc::Status>
	BlobGetClientReactor::readResponse(blob::GetResponse &response) {			BlobGetClientReactor::readResponse(blob::GetResponse &response) {
	Show All 17 Lines

[services] Blob - Fix test name for storage manager testsClosedPublicActions