AtHeartEngineer/linea-monorepo
1
0
Fork 0
mirror of https://github.com/vacp2p/linea-monorepo.git synced 2026-01-07 22:54:08 -05:00
Code Issues Packages Projects Releases Wiki Activity

coordinator: reduce unnecessary JSON-RPC requests (#1114)

Browse Source
This commit is contained in:
Fluent Crafter
2025-06-09 09:55:54 +01:00
committed by GitHub
parent fcb4658377
commit 4e5625bdc0
2 changed files with 15 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
coordinator/ethereum/message-anchoring/src/main/kotlin/linea/anchoring/MessageAnchoringService.kt
View File

@@ -31,6 +31,10 @@ class MessageAnchoringService(
log = log,
) {
override fun action(): SafeFuture<*> {
if (eventsQueue.isEmpty()) {
log.trace("No messages in the queue to anchor")
return SafeFuture.completedFuture(null)
}
return l2MessageService
.getLastAnchoredL1MessageNumber(block = l2HighestBlockTag)
.thenApply { lastAnchoredL1MessageNumber ->

16
coordinator/ethereum/message-anchoring/src/main/kotlin/linea/anchoring/clients/L1MessageSentEventsPoller.kt
View File

@@ -10,6 +10,7 @@ import org.apache.logging.log4j.LogManager
import org.apache.logging.log4j.Logger
import tech.pegasys.teku.infrastructure.async.SafeFuture
import java.util.Deque
import java.util.concurrent.atomic.AtomicLong
import kotlin.time.Duration
class L1MessageSentEventsPoller(
@@ -37,14 +38,18 @@ class L1MessageSentEventsPoller(
l1HighestBlock = l1HighestBlock,
log = log,
)
private val lastFetchedMessageNumber: AtomicLong = AtomicLong(0L)
private fun nextMessageNumberToFetchFromL1(): SafeFuture<ULong> {
val queueLastMessage = eventsQueue.peekLast()
if (queueLastMessage != null) {
return SafeFuture.completedFuture(queueLastMessage.messageNumber.inc())
if (lastFetchedMessageNumber.get() > 0) {
return SafeFuture.completedFuture(lastFetchedMessageNumber.get().inc().toULong())
} else {
return l2MessageService.getLastAnchoredL1MessageNumber(block = l2HighestBlock)
.thenApply { it.inc() }
return l2MessageService
.getLastAnchoredL1MessageNumber(block = l2HighestBlock)
.thenApply {
lastFetchedMessageNumber.set(it.toLong())
it.inc()
}
}
}
@@ -75,6 +80,7 @@ class L1MessageSentEventsPoller(
}
.thenApply { events ->
eventsQueue.addAll(events.map { it.event })
events.lastOrNull()?.also { lastFetchedMessageNumber.set(it.event.messageNumber.toLong()) }
}
}
}