Skip to content

Commit 290d281

Browse files
Expose SETTING_GRPC_MAX_MSG_SIZE for opensearch.yml.
Signed-off-by: Finn Carroll <[email protected]>
1 parent f0e5003 commit 290d281

File tree

2 files changed

+5
-1
lines changed

2 files changed

+5
-1
lines changed

modules/transport-grpc/src/main/java/org/opensearch/transport/grpc/GrpcPlugin.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -52,6 +52,7 @@
5252
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONCURRENT_CONNECTION_CALLS;
5353
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONNECTION_AGE;
5454
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONNECTION_IDLE;
55+
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_MSG_SIZE;
5556
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PORT;
5657
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PUBLISH_HOST;
5758
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PUBLISH_PORT;
@@ -220,6 +221,7 @@ public List<Setting<?>> getSettings() {
220221
SETTING_GRPC_BIND_HOST,
221222
SETTING_GRPC_WORKER_COUNT,
222223
SETTING_GRPC_MAX_CONCURRENT_CONNECTION_CALLS,
224+
SETTING_GRPC_MAX_MSG_SIZE,
223225
SETTING_GRPC_MAX_CONNECTION_AGE,
224226
SETTING_GRPC_MAX_CONNECTION_IDLE,
225227
SETTING_GRPC_KEEPALIVE_TIMEOUT

modules/transport-grpc/src/test/java/org/opensearch/transport/grpc/GrpcPluginTests.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -41,6 +41,7 @@
4141
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONCURRENT_CONNECTION_CALLS;
4242
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONNECTION_AGE;
4343
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_CONNECTION_IDLE;
44+
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_MAX_MSG_SIZE;
4445
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PORT;
4546
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PUBLISH_HOST;
4647
import static org.opensearch.transport.grpc.Netty4GrpcServerTransport.SETTING_GRPC_PUBLISH_PORT;
@@ -115,12 +116,13 @@ public void testGetSettings() {
115116
"SETTING_GRPC_MAX_CONCURRENT_CONNECTION_CALLS should be included",
116117
settings.contains(SETTING_GRPC_MAX_CONCURRENT_CONNECTION_CALLS)
117118
);
119+
assertTrue("SETTING_GRPC_MAX_MSG_SIZE should be included", settings.contains(SETTING_GRPC_MAX_MSG_SIZE));
118120
assertTrue("SETTING_GRPC_MAX_CONNECTION_AGE should be included", settings.contains(SETTING_GRPC_MAX_CONNECTION_AGE));
119121
assertTrue("SETTING_GRPC_MAX_CONNECTION_IDLE should be included", settings.contains(SETTING_GRPC_MAX_CONNECTION_IDLE));
120122
assertTrue("SETTING_GRPC_KEEPALIVE_TIMEOUT should be included", settings.contains(SETTING_GRPC_KEEPALIVE_TIMEOUT));
121123

122124
// Verify the number of settings
123-
assertEquals("Should return 11 settings", 11, settings.size());
125+
assertEquals("Should return 12 settings", 12, settings.size());
124126
}
125127

126128
public void testGetQueryUtilsBeforeCreateComponents() {

0 commit comments

Comments
 (0)