提交 36d17d11 编写于 作者: T tangwei12

add RequestCheckpointNotify in grpc

上级 a9ac2007
...@@ -203,7 +203,7 @@ class RequestCheckpointNotify final : public RequestBase { ...@@ -203,7 +203,7 @@ class RequestCheckpointNotify final : public RequestBase {
virtual ~RequestCheckpointNotify() {} virtual ~RequestCheckpointNotify() {}
std::string GetReqName() override { return request_->Varname(); } std::string GetReqName() override { return "checkpoint_notify"; }
void Process() override { void Process() override {
auto scope = request_->GetMutableLocalScope(); auto scope = request_->GetMutableLocalScope();
...@@ -214,6 +214,11 @@ class RequestCheckpointNotify final : public RequestBase { ...@@ -214,6 +214,11 @@ class RequestCheckpointNotify final : public RequestBase {
request_handler_->Handle(nullptr_str, scope, invar, &outvar, nullptr_str); request_handler_->Handle(nullptr_str, scope, invar, &outvar, nullptr_str);
Finish(reply_, &responder_); Finish(reply_, &responder_);
} }
protected:
sendrecv::CheckpointMessage request_;
sendrecv::VoidMessage reply_;
ServerAsyncResponseWriter<sendrecv::VoidMessage> responder_;
} }
void AsyncGRPCServer::WaitServerReady() { void AsyncGRPCServer::WaitServerReady() {
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册