Add removal for backupWorkerCache

2020-03-23 12:47:42 -07:00 · 2020-03-23 12:47:42 -07:00 · f0f4e42a4c
parent a8c2acdba0
commit f0f4e42a4c
1 changed files with 1 additions and 0 deletions
--- a/fdbserver/worker.actor.cpp
+++ b/fdbserver/worker.actor.cpp
@ -1175,6 +1175,7 @@ ACTOR Future<Void> workerServer(
 					ReplyPromise<InitializeBackupReply> backupReady = req.reply;
 					backupWorkerCache.set(req.reqId, backupReady.getFuture());
 					Future<Void> backupProcess = backupWorker(recruited, req, dbInfo);
+					backupProcess = storageCache.removeOnReady(req.reqId, backupProcess);
 					errorForwarders.add(forwardError(errors, Role::BACKUP, recruited.id(), backupProcess));
 					TraceEvent("BackupInitRequest", req.reqId).detail("BackupId", recruited.id());
 					InitializeBackupReply reply(recruited, req.backupEpoch);