StakeSquid/dshackle
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

change default timeout time (#680)

Browse Source
This commit is contained in:
EugeneDrpc
2025-07-10 12:15:36 +02:00
committed by GitHub
parent e644ead250
commit 5461b7893d
3 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/io/emeraldpay/dshackle/Defaults.kt
View File

@@ -23,7 +23,7 @@ class Defaults {
companion object { companion object {
const val maxMessageSize: Int = 32 * 1024 * 1024 const val maxMessageSize: Int = 32 * 1024 * 1024
const val maxMetadataSize = 16384 const val maxMetadataSize = 16384
val timeout: Duration = Duration.ofSeconds(60) val timeout: Duration = Duration.ofSeconds(85)
val timeoutInternal: Duration = timeout.dividedBy(4) val timeoutInternal: Duration = timeout.dividedBy(4)
val internalCallsTimeout = Duration.ofSeconds(5) val internalCallsTimeout = Duration.ofSeconds(5)
val retryConnection: Duration = Duration.ofSeconds(10) val retryConnection: Duration = Duration.ofSeconds(10)

2
src/main/kotlin/io/emeraldpay/dshackle/upstream/ethereum/subscribe/WebsocketPendingTxes.kt
View File

@@ -37,7 +37,7 @@ class WebsocketPendingTxes(
override fun createConnection(): Flux<TransactionId> { override fun createConnection(): Flux<TransactionId> {
return wsSubscriptions.subscribe(ChainRequest("eth_subscribe", ListParams(EthereumEgressSubscription.METHOD_PENDING_TXES))) return wsSubscriptions.subscribe(ChainRequest("eth_subscribe", ListParams(EthereumEgressSubscription.METHOD_PENDING_TXES)))
.data .data
.timeout(Duration.ofSeconds(60), Mono.empty()) .timeout(Duration.ofSeconds(85), Mono.empty())
.map { .map {
// comes as a JS string, i.e., within quotes // comes as a JS string, i.e., within quotes
val value = ByteArray(it.size - 2) val value = ByteArray(it.size - 2)

4
src/main/kotlin/io/emeraldpay/dshackle/upstream/generic/GenericIngressSubscription.kt
View File

@@ -47,9 +47,9 @@ class GenericSubscriptionConnect(
return conn.subscribe(ChainRequest(topic, ListParams(getParams(params) as List<Any>))) return conn.subscribe(ChainRequest(topic, ListParams(getParams(params) as List<Any>)))
.data .data
.timeout( .timeout(
Duration.ofSeconds(60), Duration.ofSeconds(85),
Mono.empty<ByteArray?>().doOnEach { Mono.empty<ByteArray?>().doOnEach {
log.warn("Timeout during subscription to $topic") log.warn("Timeout during subscription to $topic after 85 seconds")
}, },
) )
.onErrorResume { .onErrorResume {