diff --git a/services/backup/docker-server/contents/server/src/BackupServiceImpl.h b/services/backup/docker-server/contents/server/src/BackupServiceImpl.h --- a/services/backup/docker-server/contents/server/src/BackupServiceImpl.h +++ b/services/backup/docker-server/contents/server/src/BackupServiceImpl.h @@ -28,8 +28,9 @@ backup::RecoverBackupKeyResponse> * RecoverBackupKey(grpc::CallbackServerContext *context) override; - grpc::ServerBidiReactor - *PullBackup(grpc::CallbackServerContext *context) override; + grpc::ServerWriteReactor *PullBackup( + grpc::CallbackServerContext *context, + const backup::PullBackupRequest *request) override; }; } // namespace network diff --git a/services/backup/docker-server/contents/server/src/BackupServiceImpl.cpp b/services/backup/docker-server/contents/server/src/BackupServiceImpl.cpp --- a/services/backup/docker-server/contents/server/src/BackupServiceImpl.cpp +++ b/services/backup/docker-server/contents/server/src/BackupServiceImpl.cpp @@ -38,9 +38,13 @@ return new reactor::RecoverBackupKeyReactor(); } -grpc::ServerBidiReactor * -BackupServiceImpl::PullBackup(grpc::CallbackServerContext *context) { - return new reactor::PullBackupReactor(); +grpc::ServerWriteReactor * +BackupServiceImpl::PullBackup( + grpc::CallbackServerContext *context, + const backup::PullBackupRequest *request) { + reactor::PullBackupReactor *reactor = new reactor::PullBackupReactor(request); + reactor->NextWrite(); + return reactor; } } // namespace network