D3516.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D3516.diff
View Options

	diff --git a/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h b/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h
	new file mode 100644
	--- /dev/null
	+++ b/services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h
	@@ -0,0 +1,45 @@
	+#pragma once
	+
	+#include "ServerReadReactorBase.h"
	+
	+#include "../_generated/backup.grpc.pb.h"
	+#include "../_generated/backup.pb.h"
	+
	+#include <iostream>
	+#include <memory>
	+#include <string>
	+
	+namespace comm {
	+namespace network {
	+namespace reactor {
	+
	+class SendLogReactor : public ServerReadReactorBase<
	+ backup::SendLogRequest,
	+ google::protobuf::Empty> {
	+
	+public:
	+ using ServerReadReactorBase<backup::SendLogRequest, google::protobuf::Empty>::
	+ ServerReadReactorBase;
	+
	+ std::unique_ptr<grpc::Status>
	+ readRequest(backup::SendLogRequest request) override;
	+ void doneCallback() override;
	+};
	+
	+std::unique_ptr<grpc::Status>
	+SendLogReactor::readRequest(backup::SendLogRequest request) {
	+ // TODO implement
	+ std::cout << "handle request log chunk " << request.logdata().size()
	+ << std::endl;
	+ return nullptr;
	+}
	+
	+void SendLogReactor::doneCallback() {
	+ // TODO implement
	+ std::cout << "receive logs done " << this->status.error_code() << "/"
	+ << this->status.error_message() << std::endl;
	+}
	+
	+} // namespace reactor
	+} // namespace network
	+} // namespace comm