Movatterモバイル変換

[0]ホーム
URL:

Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

 Sign up
Appearance settings

Commit598094c

Browse files
committed
Make HttpClientCodec#initialBufferSize configurable,closeAsyncHttpClient#1405
1 parenta0e60a5 commit598094c

File tree

5 files changed

+24
-2
lines changed

5 files changed

+24
-2
lines changed

‎client/src/main/java/org/asynchttpclient/AsyncHttpClientConfig.java‎

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -241,6 +241,8 @@ public interface AsyncHttpClientConfig {
241241

242242
intgetHttpClientCodecMaxChunkSize();
243243

244+
intgetHttpClientInitialBufferSize();
245+
244246
booleanisDisableZeroCopy();
245247

246248
intgetHandshakeTimeout();

‎client/src/main/java/org/asynchttpclient/DefaultAsyncHttpClientConfig.java‎

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,6 +116,7 @@ public class DefaultAsyncHttpClientConfig implements AsyncHttpClientConfig {
116116
privatefinalinthttpClientCodecMaxInitialLineLength;
117117
privatefinalinthttpClientCodecMaxHeaderSize;
118118
privatefinalinthttpClientCodecMaxChunkSize;
119+
privatefinalinthttpClientInitialBufferSize;
119120
privatefinalintchunkedFileChunkSize;
120121
privatefinalintwebSocketMaxBufferSize;
121122
privatefinalintwebSocketMaxFrameSize;
@@ -197,6 +198,7 @@ private DefaultAsyncHttpClientConfig(//
197198
inthttpClientCodecMaxInitialLineLength,//
198199
inthttpClientCodecMaxHeaderSize,//
199200
inthttpClientCodecMaxChunkSize,//
201+
inthttpClientInitialBufferSize,//
200202
intchunkedFileChunkSize,//
201203
intwebSocketMaxBufferSize,//
202204
intwebSocketMaxFrameSize,//
@@ -272,6 +274,7 @@ private DefaultAsyncHttpClientConfig(//
272274
this.httpClientCodecMaxInitialLineLength =httpClientCodecMaxInitialLineLength;
273275
this.httpClientCodecMaxHeaderSize =httpClientCodecMaxHeaderSize;
274276
this.httpClientCodecMaxChunkSize =httpClientCodecMaxChunkSize;
277+
this.httpClientInitialBufferSize =httpClientInitialBufferSize;
275278
this.chunkedFileChunkSize =chunkedFileChunkSize;
276279
this.webSocketMaxBufferSize =webSocketMaxBufferSize;
277280
this.webSocketMaxFrameSize =webSocketMaxFrameSize;
@@ -540,6 +543,11 @@ public int getHttpClientCodecMaxChunkSize() {
540543
returnhttpClientCodecMaxChunkSize;
541544
}
542545

546+
@Override
547+
publicintgetHttpClientInitialBufferSize() {
548+
returnhttpClientInitialBufferSize;
549+
}
550+
543551
@Override
544552
publicintgetChunkedFileChunkSize() {
545553
returnchunkedFileChunkSize;
@@ -673,6 +681,7 @@ public static class Builder {
673681
privateinthttpClientCodecMaxInitialLineLength =defaultHttpClientCodecMaxInitialLineLength();
674682
privateinthttpClientCodecMaxHeaderSize =defaultHttpClientCodecMaxHeaderSize();
675683
privateinthttpClientCodecMaxChunkSize =defaultHttpClientCodecMaxChunkSize();
684+
privateinthttpClientInitialBufferSize =defaultHttpClientInitialBufferSize();
676685
privateintchunkedFileChunkSize =defaultChunkedFileChunkSize();
677686
privateintwebSocketMaxBufferSize =defaultWebSocketMaxBufferSize();
678687
privateintwebSocketMaxFrameSize =defaultWebSocketMaxFrameSize();
@@ -1043,6 +1052,11 @@ public Builder setHttpClientCodecMaxChunkSize(int httpClientCodecMaxChunkSize) {
10431052
returnthis;
10441053
}
10451054

1055+
publicBuildersetHttpClientInitialBufferSize(inthttpClientInitialBufferSize) {
1056+
this.httpClientInitialBufferSize =httpClientInitialBufferSize;
1057+
returnthis;
1058+
}
1059+
10461060
publicBuildersetChunkedFileChunkSize(intchunkedFileChunkSize) {
10471061
this.chunkedFileChunkSize =chunkedFileChunkSize;
10481062
returnthis;
@@ -1173,6 +1187,7 @@ public DefaultAsyncHttpClientConfig build() {
11731187
httpClientCodecMaxInitialLineLength,//
11741188
httpClientCodecMaxHeaderSize,//
11751189
httpClientCodecMaxChunkSize,//
1190+
httpClientInitialBufferSize,//
11761191
chunkedFileChunkSize,//
11771192
webSocketMaxBufferSize,//
11781193
webSocketMaxFrameSize,//

‎client/src/main/java/org/asynchttpclient/config/AsyncHttpClientConfigDefaults.java‎

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,6 @@
1212
*/
1313
packageorg.asynchttpclient.config;
1414

15-
1615
publicfinalclassAsyncHttpClientConfigDefaults {
1716

1817
privateAsyncHttpClientConfigDefaults() {
@@ -164,6 +163,10 @@ public static int defaultHttpClientCodecMaxChunkSize() {
164163
returnAsyncHttpClientConfigHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT_CONFIG_ROOT +"httpClientCodecMaxChunkSize");
165164
}
166165

166+
publicstaticintdefaultHttpClientInitialBufferSize() {
167+
returnAsyncHttpClientConfigHelper.getAsyncHttpClientConfig().getInt(ASYNC_CLIENT_CONFIG_ROOT +"httpClientInitialBufferSize");
168+
}
169+
167170
publicstaticbooleandefaultDisableZeroCopy() {
168171
returnAsyncHttpClientConfigHelper.getAsyncHttpClientConfig().getBoolean(ASYNC_CLIENT_CONFIG_ROOT +"disableZeroCopy");
169172
}

‎client/src/main/java/org/asynchttpclient/netty/channel/ChannelManager.java‎

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -329,7 +329,8 @@ private HttpClientCodec newHttpClientCodec() {
329329
config.getHttpClientCodecMaxHeaderSize(),//
330330
config.getHttpClientCodecMaxChunkSize(),//
331331
false,//
332-
config.isValidateResponseHeaders());
332+
config.isValidateResponseHeaders(),//
333+
config.getHttpClientInitialBufferSize());
333334
}
334335

335336
privateSslHandlercreateSslHandler(StringpeerHost,intpeerPort) {

‎client/src/main/resources/ahc-default.properties‎

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,7 @@ org.asynchttpclient.soRcvBuf=-1
3535
org.asynchttpclient.httpClientCodecMaxInitialLineLength=4096
3636
org.asynchttpclient.httpClientCodecMaxHeaderSize=8192
3737
org.asynchttpclient.httpClientCodecMaxChunkSize=8192
38+
org.asynchttpclient.httpClientInitialBufferSize=128
3839
org.asynchttpclient.disableZeroCopy=false
3940
org.asynchttpclient.handshakeTimeout=10000
4041
org.asynchttpclient.chunkedFileChunkSize=8192

0 commit comments

Comments
 (0)
[8]ページ先頭
©2009-2025 Movatter.jp