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

problem: breaks grpc connection on large messages

Browse Source
This commit is contained in:
Igor Artamonov
2022-03-05 20:07:51 -05:00
parent 2b8603df98
commit bb45fa0699
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/kotlin/io/emeraldpay/dshackle/upstream/grpc/GrpcUpstreams.kt
View File

@@ -69,6 +69,8 @@ class GrpcUpstreams(
fun start(): Flux<UpstreamChange> { fun start(): Flux<UpstreamChange> {
val channel: ManagedChannelBuilder<*> = if (auth != null && StringUtils.isNotEmpty(auth.ca)) { val channel: ManagedChannelBuilder<*> = if (auth != null && StringUtils.isNotEmpty(auth.ca)) {
NettyChannelBuilder.forAddress(host, port) NettyChannelBuilder.forAddress(host, port)
// some messages are very large. many of them in megabytes, some even in gigabytes (ex. ETH Traces)
.maxInboundMessageSize(Int.MAX_VALUE)
.useTransportSecurity() .useTransportSecurity()
.enableRetry() .enableRetry()
.maxRetryAttempts(3) .maxRetryAttempts(3)