From 805261b476c995cc28b1f1121c0147a92ab34065 Mon Sep 17 00:00:00 2001 From: "David.Noble@microsoft.com" Date: Wed, 17 Jul 2019 01:46:29 -0700 Subject: [PATCH] Added allocator-related RntbdTransportClient.Options --- .../directconnectivity/rntbd/RntbdEndpoint.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/direct-impl/src/main/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdEndpoint.java b/direct-impl/src/main/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdEndpoint.java index 47731243..cf53a19b 100644 --- a/direct-impl/src/main/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdEndpoint.java +++ b/direct-impl/src/main/java/com/microsoft/azure/cosmosdb/internal/directconnectivity/rntbd/RntbdEndpoint.java @@ -91,6 +91,10 @@ public interface RntbdEndpoint extends AutoCloseable { return this.allocator; } + public int bufferPageSize() { + return this.options.bufferPageSize(); + } + public int connectionTimeout() { final long value = this.options.connectionTimeout().toMillis(); assert value <= Integer.MAX_VALUE; @@ -101,6 +105,10 @@ public interface RntbdEndpoint extends AutoCloseable { return this.options.idleTimeout().toNanos(); } + public int maxBufferCapacity() { + return this.options.maxBufferCapacity(); + } + public int maxChannelsPerEndpoint() { return this.options.maxChannelsPerEndpoint(); } @@ -151,8 +159,10 @@ public interface RntbdEndpoint extends AutoCloseable { @Override public void serialize(Config value, JsonGenerator generator, SerializerProvider provider) throws IOException { generator.writeStartObject(); + generator.writeNumberField("bufferPageSize", value.bufferPageSize()); generator.writeNumberField("connectionTimeout", value.connectionTimeout()); generator.writeNumberField("idleConnectionTimeout", value.idleConnectionTimeout()); + generator.writeNumberField("maxBufferCapacity", value.maxBufferCapacity()); generator.writeNumberField("maxChannelPerEndpoint", value.maxChannelsPerEndpoint()); generator.writeNumberField("maxRequestsPerChannel", value.maxChannelsPerEndpoint()); generator.writeNumberField("receiveHangDetectionTime", value.receiveHangDetectionTime());