D3246.id9832.diff
No OneTemporary
Actions

Size

1 KB

Referenced Files

None

Subscribers

None

D3246.id9832.diff
View Options

	diff --git a/services/backup/docker-server/contents/server/src/ReactorBase.h b/services/backup/docker-server/contents/server/src/ReactorBase.h
	new file mode 100644
	--- /dev/null
	+++ b/services/backup/docker-server/contents/server/src/ReactorBase.h
	@@ -0,0 +1,62 @@
	+#pragma once
	+
	+#include <grpcpp/grpcpp.h>
	+#include <string>
	+
	+namespace comm {
	+namespace network {
	+
	+template <class Request, class Response>
	+class ReactorBase : public grpc::ServerBidiReactor<Request, Response> {
	+ Request request;
	+ Response response;
	+ bool finished = false;
	+
	+ void finish(grpc::Status status = grpc::Status::OK) {
	+ if (this->finished) {
	+ return;
	+ }
	+ this->finished = true;
	+ this->Finish(status);
	+ }
	+
	+public:
	+ ReactorBase() {
	+ this->StartRead(&this->request);
	+ }
	+
	+ void OnDone() override {
	+ GPR_ASSERT(this->finished);
	+ delete this;
	+ }
	+
	+ void OnReadDone(bool ok) override {
	+ if (!ok) {
	+ this->finish(grpc::Status(grpc::StatusCode::INTERNAL, "reading error"));
	+ return;
	+ }
	+ try {
	+ grpc::Status status = this->handleRequest(this->request, &this->response);
	+ if (status.ok()) {
	+ this->finish(status);
	+ return;
	+ }
	+ this->StartWrite(&this->response);
	+ } catch (std::runtime_error &e) {
	+ this->finish(grpc::Status(grpc::StatusCode::INTERNAL, e.what()));
	+ }
	+ }
	+
	+ void OnWriteDone(bool ok) override {
	+ if (!ok) {
	+ gpr_log(GPR_ERROR, "Server write failed");
	+ return;
	+ }
	+ this->StartRead(&this->request);
	+ }
	+
	+ virtual grpc::Status handleRequest(Request request, Response *response) = 0;
	+};
	+
	+} // namespace network
	+} // namespace comm