mirrors/eclair
1
0
Fork 0
mirror of https://github.com/ACINQ/eclair.git synced 2025-03-03 17:36:56 +01:00
Code Issues Projects Releases Wiki Activity

Add debug logs to transport handler (#1488)

Browse source
This commit is contained in:
Pierre-Marie Padiou 2020-07-17 16:35:31 +02:00 • committed by GitHub
parent e06325e03b
commit 65facab141
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eclair-core/src/main/scala/fr/acinq/eclair/crypto/TransportHandler.scala
View file

@ -183,7 +183,7 @@ class TransportHandler[T: ClassTag](keyPair: KeyPair, rs: Option[ByteVector], co
connection ! Tcp.ResumeReading connection ! Tcp.ResumeReading
stay using d.copy(decryptor = dec1) stay using d.copy(decryptor = dec1)
} else { } else {
log.debug(s"read {} messages, waiting for readacks", plaintextMessages.size) log.debug("read {} messages, waiting for readacks", plaintextMessages.size)
val unackedReceived = sendToListener(d.listener, plaintextMessages) val unackedReceived = sendToListener(d.listener, plaintextMessages)
stay using NormalData(d.encryptor, dec1, d.listener, d.sendBuffer, unackedReceived, d.unackedSent) stay using NormalData(d.encryptor, dec1, d.listener, d.sendBuffer, unackedReceived, d.unackedSent)
} }
@ -191,6 +191,7 @@ class TransportHandler[T: ClassTag](keyPair: KeyPair, rs: Option[ByteVector], co
case Event(ReadAck(msg: T), d: NormalData[T]) => case Event(ReadAck(msg: T), d: NormalData[T]) =>
// how many occurences of this message are still unacked? // how many occurences of this message are still unacked?
val remaining = d.unackedReceived.getOrElse(msg, 0) - 1 val remaining = d.unackedReceived.getOrElse(msg, 0) - 1
log.debug("acking message {}", msg)
// if all occurences have been acked then we remove the entry from the map // if all occurences have been acked then we remove the entry from the map
val unackedReceived1 = if (remaining > 0) d.unackedReceived + (msg -> remaining) else d.unackedReceived - msg val unackedReceived1 = if (remaining > 0) d.unackedReceived + (msg -> remaining) else d.unackedReceived - msg
if (unackedReceived1.isEmpty) { if (unackedReceived1.isEmpty) {
@ -198,6 +199,7 @@ class TransportHandler[T: ClassTag](keyPair: KeyPair, rs: Option[ByteVector], co
connection ! Tcp.ResumeReading connection ! Tcp.ResumeReading
stay using d.copy(unackedReceived = unackedReceived1) stay using d.copy(unackedReceived = unackedReceived1)
} else { } else {
log.debug("still waiting for readacks, unacked={}", unackedReceived1)
stay using d.copy(unackedReceived = unackedReceived1) stay using d.copy(unackedReceived = unackedReceived1)
} }