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

less verbose debug logging in ddata (#22384)

Browse source 
* less verbose debug logging in ddata #22170

* less verbose debug logging in ddata 2 #22170
This commit is contained in:
ortigali 2017-02-24 14:38:14 +05:00 • committed by Patrik Nordwall
parent 2510f20fd0
commit adf7e8271e
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-distributed-data/src/main/scala/akka/cluster/ddata/Replicator.scala
View file

@ -1176,7 +1176,7 @@ final class Replicator(settings: ReplicatorSettings) extends Actor with ActorLog
def receiveGet(key: KeyR, consistency: ReadConsistency, req: Option[Any]): Unit = { def receiveGet(key: KeyR, consistency: ReadConsistency, req: Option[Any]): Unit = {
val localValue = getData(key.id) val localValue = getData(key.id)
log.debug("Received Get for key [{}], local data [{}]", key, localValue) log.debug("Received Get for key [{}]", key)
if (isLocalGet(consistency)) { if (isLocalGet(consistency)) {
val reply = localValue match { val reply = localValue match {
case Some(DataEnvelope(DeletedData, _, _)) ⇒ DataDeleted(key, req) case Some(DataEnvelope(DeletedData, _, _)) ⇒ DataDeleted(key, req)
@ -1222,7 +1222,7 @@ final class Replicator(settings: ReplicatorSettings) extends Actor with ActorLog
} }
} match { } match {
case Success((envelope, delta)) ⇒ case Success((envelope, delta)) ⇒
log.debug("Received Update for key [{}], old data [{}], new data [{}], delta [{}]", key, localValue, envelope.data, delta) log.debug("Received Update for key [{}]", key)
// handle the delta // handle the delta
delta match { delta match {