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

imcrease gRPC message size limit

Browse Source
This commit is contained in:
Maksim Fomenkov
2022-11-29 16:04:56 +04:00
parent f780a545ef
commit 81f825f1c1
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
build.gradle
View File

@@ -36,7 +36,7 @@ group = 'io.emeraldpay.dshackle'
// Version schema: // Version schema:
// x.x.x for production, following SemVer model // x.x.x for production, following SemVer model
// x.x.x-SNAPSHOT for development // x.x.x-SNAPSHOT for development
version = '0.15.0-SNAPSHOT' version = '0.16.0-SNAPSHOT'
java { java {
sourceCompatibility = JavaVersion.VERSION_13 sourceCompatibility = JavaVersion.VERSION_13

3
src/main/kotlin/io/emeraldpay/dshackle/GrpcServer.kt
View File

@@ -46,6 +46,7 @@ open class GrpcServer(
log.info("Listening Native gRPC on ${mainConfig.host}:${mainConfig.port}") log.info("Listening Native gRPC on ${mainConfig.host}:${mainConfig.port}")
val serverBuilder = NettyServerBuilder val serverBuilder = NettyServerBuilder
.forAddress(InetSocketAddress(mainConfig.host, mainConfig.port)) .forAddress(InetSocketAddress(mainConfig.host, mainConfig.port))
.maxInboundMessageSize(Int.MAX_VALUE)
.let { .let {
if (mainConfig.accessLogConfig.enabled) { if (mainConfig.accessLogConfig.enabled) {
it.intercept(accessHandler) it.intercept(accessHandler)
@@ -65,7 +66,7 @@ open class GrpcServer(
val server = serverBuilder.build() val server = serverBuilder.build()
this.server = server this.server = server
Thread { server.start() }.run() server.start()
log.info("GRPC Server started") log.info("GRPC Server started")
} }