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

Removing logging from EBEDD

Browse source
This commit is contained in:
Viktor Klang 2011-02-27 23:17:59 +01:00
parent a6bfe644d5
commit dea85ef81f
2 changed files with 2 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor/src/main/scala/akka/dispatch/ExecutorBasedEventDrivenDispatcher.scala
View file

@ -116,12 +116,11 @@ class ExecutorBasedEventDrivenDispatcher(
} }
} }
private[akka] def start = log.slf4j.debug("Starting up {}\n\twith throughput [{}]", this, throughput) private[akka] def start {}
private[akka] def shutdown { private[akka] def shutdown {
val old = executorService.getAndSet(config.createLazyExecutorService(threadFactory)) val old = executorService.getAndSet(config.createLazyExecutorService(threadFactory))
if (old ne null) { if (old ne null) {
log.slf4j.debug("Shutting down {}", this)
old.shutdownNow() old.shutdownNow()
} }
} }
@ -137,7 +136,6 @@ class ExecutorBasedEventDrivenDispatcher(
} }
} }
} }
else log.slf4j.warn("{} is shut down,\n\tignoring the rest of the messages in the mailbox of\n\t{}", this, mbox)
private[akka] def reRegisterForExecution(mbox: MessageQueue with ExecutableMailbox): Unit = private[akka] def reRegisterForExecution(mbox: MessageQueue with ExecutableMailbox): Unit =
registerForExecution(mbox) registerForExecution(mbox)
@ -145,12 +143,10 @@ class ExecutorBasedEventDrivenDispatcher(
override val toString = getClass.getSimpleName + "[" + name + "]" override val toString = getClass.getSimpleName + "[" + name + "]"
def suspend(actorRef: ActorRef) { def suspend(actorRef: ActorRef) {
log.slf4j.debug("Suspending {}",actorRef.uuid)
getMailbox(actorRef).suspended.tryLock getMailbox(actorRef).suspended.tryLock
} }
def resume(actorRef: ActorRef) { def resume(actorRef: ActorRef) {
log.slf4j.debug("Resuming {}",actorRef.uuid)
val mbox = getMailbox(actorRef) val mbox = getMailbox(actorRef)
mbox.suspended.tryUnlock mbox.suspended.tryUnlock
reRegisterForExecution(mbox) reRegisterForExecution(mbox)

3
akka-actor/src/main/scala/akka/dispatch/MessageHandling.scala
View file

@ -36,7 +36,7 @@ object MessageDispatcher {
/** /**
* @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a> * @author <a href="http://jonasboner.com">Jonas Bon&#233;r</a>
*/ */
trait MessageDispatcher extends Logging { trait MessageDispatcher {
import MessageDispatcher._ import MessageDispatcher._
protected val uuids = new ConcurrentSkipListSet[Uuid] protected val uuids = new ConcurrentSkipListSet[Uuid]
@ -106,7 +106,6 @@ trait MessageDispatcher extends Logging {
Actor.registry.actorFor(uuid) match { Actor.registry.actorFor(uuid) match {
case Some(actor) => actor.stop case Some(actor) => actor.stop
case None => case None =>
log.slf4j.error("stopAllLinkedActors couldn't find linked actor: " + uuid)
} }
} }
} }