raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

remove debug logging for cancel timer (#30773)

Browse source 
* too verbose and not much value
This commit is contained in:
Patrik Nordwall 2021-10-08 14:50:45 +02:00 • committed by GitHub
parent be0cf7c38b
commit 87bfeaeb2c
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 0 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-typed/src/main/scala/akka/actor/typed/internal/TimerSchedulerImpl.scala
View file

@ -145,13 +145,11 @@ import scala.concurrent.duration.FiniteDuration
} }
private def cancelTimer(timer: Timer[T]): Unit = { private def cancelTimer(timer: Timer[T]): Unit = {
ctx.log.debug("Cancel timer [{}] with generation [{}]", timer.key, timer.generation)
timer.task.cancel() timer.task.cancel()
timers -= timer.key timers -= timer.key
} }
override def cancelAll(): Unit = { override def cancelAll(): Unit = {
ctx.log.debug("Cancel all timers")
timers.valuesIterator.foreach { timer => timers.valuesIterator.foreach { timer =>
timer.task.cancel() timer.task.cancel()
} }

2
akka-actor/src/main/scala/akka/actor/dungeon/TimerSchedulerImpl.scala
View file

@ -112,13 +112,11 @@ import akka.util.OptionVal
} }
private def cancelTimer(timer: Timer): Unit = { private def cancelTimer(timer: Timer): Unit = {
log.debug("Cancel timer [{}] with generation [{}]", timer.key, timer.generation)
timer.task.cancel() timer.task.cancel()
timers -= timer.key timers -= timer.key
} }
override def cancelAll(): Unit = { override def cancelAll(): Unit = {
log.debug("Cancel all timers")
timers.valuesIterator.foreach { timer => timers.valuesIterator.foreach { timer =>
timer.task.cancel() timer.task.cancel()
} }