diff --git a/eclair-core/src/main/scala/fr/acinq/eclair/blockchain/electrum/ElectrumWallet.scala b/eclair-core/src/main/scala/fr/acinq/eclair/blockchain/electrum/ElectrumWallet.scala index dd401b3f5..f2aab61d5 100644 --- a/eclair-core/src/main/scala/fr/acinq/eclair/blockchain/electrum/ElectrumWallet.scala +++ b/eclair-core/src/main/scala/fr/acinq/eclair/blockchain/electrum/ElectrumWallet.scala @@ -1,6 +1,6 @@ package fr.acinq.eclair.blockchain.electrum -import akka.actor.{ActorRef, LoggingFSM, Props} +import akka.actor.{ActorRef, FSM, Props} import fr.acinq.bitcoin.Crypto.{PrivateKey, PublicKey} import fr.acinq.bitcoin.DeterministicWallet.{ExtendedPrivateKey, derivePrivateKey, hardened} import fr.acinq.bitcoin.{Base58, Base58Check, BinaryData, Block, Crypto, DeterministicWallet, OP_PUSHDATA, OutPoint, SIGHASH_ALL, Satoshi, Script, ScriptWitness, SigVersion, Transaction, TxIn, TxOut} @@ -28,7 +28,7 @@ import scala.util.{Failure, Success, Try} * @param client * @param params */ -class ElectrumWallet(seed: BinaryData, client: ActorRef, params: ElectrumWallet.WalletParameters) extends LoggingFSM[ElectrumWallet.State, ElectrumWallet.Data] { +class ElectrumWallet(seed: BinaryData, client: ActorRef, params: ElectrumWallet.WalletParameters) extends FSM[ElectrumWallet.State, ElectrumWallet.Data] { import ElectrumWallet._ import params._ diff --git a/eclair-core/src/main/scala/fr/acinq/eclair/channel/Channel.scala b/eclair-core/src/main/scala/fr/acinq/eclair/channel/Channel.scala index baa07af42..1ffb2925d 100644 --- a/eclair-core/src/main/scala/fr/acinq/eclair/channel/Channel.scala +++ b/eclair-core/src/main/scala/fr/acinq/eclair/channel/Channel.scala @@ -2,7 +2,7 @@ package fr.acinq.eclair.channel import java.nio.charset.StandardCharsets -import akka.actor.{ActorRef, FSM, LoggingFSM, OneForOneStrategy, Props, Status, SupervisorStrategy} +import akka.actor.{ActorRef, FSM, OneForOneStrategy, Props, Status, SupervisorStrategy} import akka.event.Logging.MDC import akka.pattern.pipe import fr.acinq.bitcoin.Crypto.{PublicKey, ripemd160, sha256} @@ -45,7 +45,7 @@ object Channel { } -class Channel(val nodeParams: NodeParams, wallet: EclairWallet, remoteNodeId: PublicKey, blockchain: ActorRef, router: ActorRef, relayer: ActorRef)(implicit ec: ExecutionContext = ExecutionContext.Implicits.global) extends LoggingFSM[State, Data] with FSMDiagnosticActorLogging[State, Data] { +class Channel(val nodeParams: NodeParams, wallet: EclairWallet, remoteNodeId: PublicKey, blockchain: ActorRef, router: ActorRef, relayer: ActorRef)(implicit ec: ExecutionContext = ExecutionContext.Implicits.global) extends FSM[State, Data] with FSMDiagnosticActorLogging[State, Data] { import Channel._ diff --git a/eclair-core/src/main/scala/fr/acinq/eclair/io/Peer.scala b/eclair-core/src/main/scala/fr/acinq/eclair/io/Peer.scala index 130fdc898..9a7468bcd 100644 --- a/eclair-core/src/main/scala/fr/acinq/eclair/io/Peer.scala +++ b/eclair-core/src/main/scala/fr/acinq/eclair/io/Peer.scala @@ -2,7 +2,7 @@ package fr.acinq.eclair.io import java.net.InetSocketAddress -import akka.actor.{ActorRef, LoggingFSM, OneForOneStrategy, PoisonPill, Props, Status, SupervisorStrategy, Terminated} +import akka.actor.{ActorRef, FSM, OneForOneStrategy, PoisonPill, Props, Status, SupervisorStrategy, Terminated} import fr.acinq.bitcoin.Crypto.{PrivateKey, PublicKey} import fr.acinq.bitcoin.{BinaryData, Crypto, DeterministicWallet, MilliSatoshi, Satoshi} import fr.acinq.eclair._ @@ -20,7 +20,7 @@ import scala.util.Random /** * Created by PM on 26/08/2016. */ -class Peer(nodeParams: NodeParams, remoteNodeId: PublicKey, previousKnownAddress: Option[InetSocketAddress], authenticator: ActorRef, watcher: ActorRef, router: ActorRef, relayer: ActorRef, wallet: EclairWallet, storedChannels: Set[HasCommitments]) extends LoggingFSM[Peer.State, Peer.Data] { +class Peer(nodeParams: NodeParams, remoteNodeId: PublicKey, previousKnownAddress: Option[InetSocketAddress], authenticator: ActorRef, watcher: ActorRef, router: ActorRef, relayer: ActorRef, wallet: EclairWallet, storedChannels: Set[HasCommitments]) extends FSM[Peer.State, Peer.Data] { import Peer._ diff --git a/eclair-core/src/main/scala/fr/acinq/eclair/payment/PaymentLifecycle.scala b/eclair-core/src/main/scala/fr/acinq/eclair/payment/PaymentLifecycle.scala index f3c104d80..f0fddbc54 100644 --- a/eclair-core/src/main/scala/fr/acinq/eclair/payment/PaymentLifecycle.scala +++ b/eclair-core/src/main/scala/fr/acinq/eclair/payment/PaymentLifecycle.scala @@ -1,6 +1,6 @@ package fr.acinq.eclair.payment -import akka.actor.{ActorRef, FSM, LoggingFSM, Props, Status} +import akka.actor.{ActorRef, FSM, Props, Status} import fr.acinq.bitcoin.Crypto.PublicKey import fr.acinq.bitcoin.{BinaryData, MilliSatoshi} import fr.acinq.eclair._ @@ -42,7 +42,7 @@ case object WAITING_FOR_PAYMENT_COMPLETE extends State /** * Created by PM on 26/08/2016. */ -class PaymentLifecycle(sourceNodeId: PublicKey, router: ActorRef, register: ActorRef) extends LoggingFSM[State, Data] { +class PaymentLifecycle(sourceNodeId: PublicKey, router: ActorRef, register: ActorRef) extends FSM[State, Data] { import PaymentLifecycle._ diff --git a/eclair-node/src/main/resources/application.conf b/eclair-node/src/main/resources/application.conf index b5d711a84..476eba17e 100644 --- a/eclair-node/src/main/resources/application.conf +++ b/eclair-node/src/main/resources/application.conf @@ -1,19 +1,6 @@ akka { loggers = ["akka.event.slf4j.Slf4jLogger"] - loglevel = "DEBUG" - - actor { - debug { - # enable DEBUG logging of all LoggingFSMs for events, transitions and timers - fsm = on - } - } - - http { - host-connection-pool { - max-open-requests = 64 - } - } + loglevel = "INFO" io { tcp { @@ -25,7 +12,9 @@ akka { # configured receive buffer size. When using value 'unlimited' it will # try to read all from the receive buffer. # As per BOLT#8 lightning messages are at most 2 + 16 + 65535 + 16 = 65569bytes - # Currently the largest message is update_add_htlc (~1500b), let's + # Currently the largest message is update_add_htlc (~1500b). + # As a tradeoff to reduce the RAM consumption, in conjunction with tcp pull mode, + # the default value is chosen to allow for a decent number of messages to be prefetched. max-received-message-size = 16384b }