fix: allow disk errors to cancel the actor before recruiting logs

This commit is contained in:
Evan Tschannen 2018-06-10 20:27:19 -07:00
parent 134b5d6f65
commit a5c2a8ee8a
1 changed files with 3 additions and 0 deletions

View File

@ -2019,6 +2019,9 @@ ACTOR Future<Void> tLog( IKeyValueStore* persistentData, IDiskQueue* persistentQ
Void _ = wait( checkEmptyQueue(&self) && checkRecovered(&self) );
}
//Disk errors need a chance to kill this actor.
Void _ = wait(delay(0.0));
if(recovered.canBeSet()) recovered.send(Void());
self.sharedActors.send( cleanupPeekTrackers(&self) );