use asynchronous recovery feature in Faster.
This commit is contained in:
Родитель
953e3d4873
Коммит
d1bd0a57e9
|
@ -106,7 +106,7 @@ namespace DurableTask.Netherite.Faster
|
|||
{
|
||||
await this.blobManager.FindCheckpointsAsync();
|
||||
this.blobManager.TraceHelper.FasterProgress($"Recovering FasterKV");
|
||||
this.fht.Recover(numPagesToPreload: 0); //TODO make this RecoverAsync once available in Faster
|
||||
await this.fht.RecoverAsync(numPagesToPreload: 0);
|
||||
this.mainSession = this.CreateASession();
|
||||
return (this.blobManager.CheckpointInfo.CommitLogPosition, this.blobManager.CheckpointInfo.InputQueuePosition);
|
||||
}
|
||||
|
|
Загрузка…
Ссылка в новой задаче