Commit088948a

oleksiys

committed

+ related to the issue

1 parentd500dd7 commit088948aCopy full SHA for 088948a

File tree

+14

-1

lines changed

src/main/java/com/ning/http/client/providers/grizzly
- ConnectionManager.java
- GrizzlyAsyncHttpProvider.java

+14

-1

lines changed

Lines changed: 6 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -32,6 +32,7 @@`
`32`	`32`	`importorg.glassfish.grizzly.Grizzly;`
`33`	`33`	`importorg.glassfish.grizzly.GrizzlyFuture;`
`34`	`34`	`importorg.glassfish.grizzly.attributes.Attribute;`
	`35`	`+importorg.glassfish.grizzly.connectionpool.ConnectionInfo;`
`35`	`36`	`importorg.glassfish.grizzly.connectionpool.Endpoint;`
`36`	`37`	`importorg.glassfish.grizzly.connectionpool.MultiEndpointPool;`
`37`	`38`	`importorg.glassfish.grizzly.connectionpool.SingleEndpointPool;`
`@@ -209,6 +210,11 @@ void destroy() {`
`209`	`210`	`pool.close();`
`210`	`211`	`}`
`211`	`212`
	`213`	`+booleanisReadyInPool(finalConnectionc) {`
	`214`	`+finalConnectionInfo<SocketAddress>ci =pool.getConnectionInfo(c);`
	`215`	`+returnci !=null &&ci.isReady();`
	`216`	`+ }`
	`217`	`+`
`212`	`218`	`staticbooleanisKeepAlive(finalConnectionconnection) {`
`213`	`219`	`return !IS_NOT_KEEP_ALIVE.isSet(connection);`
`214`	`220`	`}`

Lines changed: 8 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -253,8 +253,15 @@ protected void initializeTransport(final AsyncHttpClientConfig clientConfig) {`
`253`	`253`	`newIdleTimeoutFilter.TimeoutResolver() {`
`254`	`254`	`@Override`
`255`	`255`	`publiclonggetTimeout(finalFilterChainContextctx) {`
	`256`	`+finalConnectionconnection =ctx.getConnection();`
	`257`	`+`
	`258`	`+if (connectionManager.isReadyInPool(connection)) {`
	`259`	`+// if the connection is in pool - let ConnectionManager take care of its life cycle`
	`260`	`+returnIdleTimeoutFilter.FOREVER;`
	`261`	`+ }`
	`262`	`+`
`256`	`263`	`finalHttpTransactionContextcontext`
`257`		`- =HttpTransactionContext.currentTransaction(ctx.getConnection());`
	`264`	`+ =HttpTransactionContext.currentTransaction(connection);`
`258`	`265`	`if (context !=null) {`
`259`	`266`	`if (context.isWSRequest) {`
`260`	`267`	`returnclientConfig.getWebSocketTimeout();`

Comments

(0)