Skip to content

Commit f1e170e

Browse files
committed
using zero deadline instead of Deadline.now to avoid race condition
1 parent 90c3a8b commit f1e170e

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

commons-redis/src/main/scala/com/avsystem/commons/redis/actor/ClusterMonitoringActor.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ final class ClusterMonitoringActor(
4949
private val connections = new mutable.HashMap[NodeAddress, ActorRef]
5050
private val clients = new mutable.HashMap[NodeAddress, RedisNodeClient]
5151
private var state = Opt.empty[ClusterState]
52-
private var suspendUntil = Deadline.now
52+
private var suspendUntil = Deadline(Duration.Zero)
5353
private var scheduledRefresh = Opt.empty[Cancellable]
5454
private val seedFailures = new ArrayBuffer[Throwable]
5555

0 commit comments

Comments
 (0)