Skip to content

Commit

Permalink
fix state update timeout for remember-entities (#6479)
Browse files Browse the repository at this point in the history
We were using the wrong state timeout value, which only gave us 2s to recover R-E data. We're now using the correct value.
  • Loading branch information
Aaronontheweb committed Mar 2, 2023
1 parent 1151651 commit dde36e9
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions src/contrib/cluster/Akka.Cluster.Sharding/Shard.cs
Original file line number Diff line number Diff line change
Expand Up @@ -1117,7 +1117,7 @@ private void TryLoadRememberedEntities()
Timers.StartSingleTimer(
RememberEntityTimeoutKey,
new RememberEntityTimeout(RememberEntitiesShardStore.GetEntities.Instance),
_settings.TuningParameters.WaitingForStateTimeout);
_settings.TuningParameters.UpdatingStateTimeout);
Context.Become(AwaitingRememberedEntities);
}
else
Expand Down Expand Up @@ -1254,7 +1254,7 @@ private void SendToRememberStore(IActorRef store, IImmutableSet<EntityId> storin
Timers.StartSingleTimer(
RememberEntityTimeoutKey,
new RememberEntityTimeout(update),
_settings.TuningParameters.UpdatingStateTimeout);
_settings.TuningParameters.WaitingForStateTimeout);

Context.Become(WaitingForRememberEntitiesStore(update, startTime));
}
Expand Down

0 comments on commit dde36e9

Please sign in to comment.