public LeaseRequest lease()

in httpclient5/src/main/java/org/apache/hc/client5/http/impl/io/PoolingHttpClientConnectionManager.java [289:379]
86 lines of code
20 McCabe index (conditional complexity)

    public LeaseRequest lease(
            final String id,
            final HttpRoute route,
            final Timeout requestTimeout,
            final Object state) {
        Args.notNull(route, "HTTP route");
        if (LOG.isDebugEnabled()) {
            LOG.debug("{} endpoint lease request ({}) {}", id, requestTimeout, ConnPoolSupport.formatStats(route, state, pool));
        }
        final Future<PoolEntry<HttpRoute, ManagedHttpClientConnection>> leaseFuture = this.pool.lease(route, state, requestTimeout, null);
        return new LeaseRequest() {

            private volatile ConnectionEndpoint endpoint;

            @Override
            public synchronized ConnectionEndpoint get(
                    final Timeout timeout) throws InterruptedException, ExecutionException, TimeoutException {
                Args.notNull(timeout, "Operation timeout");
                if (this.endpoint != null) {
                    return this.endpoint;
                }
                final PoolEntry<HttpRoute, ManagedHttpClientConnection> poolEntry;
                try {
                    poolEntry = leaseFuture.get(timeout.getDuration(), timeout.getTimeUnit());
                } catch (final TimeoutException ex) {
                    leaseFuture.cancel(true);
                    throw ex;
                }
                if (LOG.isDebugEnabled()) {
                    LOG.debug("{} endpoint leased {}", id, ConnPoolSupport.formatStats(route, state, pool));
                }
                final ConnectionConfig connectionConfig = resolveConnectionConfig(route);
                try {
                    if (poolEntry.hasConnection()) {
                        final TimeValue timeToLive = connectionConfig.getTimeToLive();
                        if (TimeValue.isNonNegative(timeToLive)) {
                            if (timeToLive.getDuration() == 0
                                    || Deadline.calculate(poolEntry.getCreated(), timeToLive).isExpired()) {
                                poolEntry.discardConnection(CloseMode.GRACEFUL);
                            }
                        }
                    }
                    if (poolEntry.hasConnection()) {
                        final TimeValue timeValue = resolveValidateAfterInactivity(connectionConfig);
                        if (TimeValue.isNonNegative(timeValue)) {
                            if (timeValue.getDuration() == 0
                                    || Deadline.calculate(poolEntry.getUpdated(), timeValue).isExpired()) {
                                final ManagedHttpClientConnection conn = poolEntry.getConnection();
                                boolean stale;
                                try {
                                    stale = conn.isStale();
                                } catch (final IOException ignore) {
                                    stale = true;
                                }
                                if (stale) {
                                    if (LOG.isDebugEnabled()) {
                                        LOG.debug("{} connection {} is stale", id, ConnPoolSupport.getId(conn));
                                    }
                                    poolEntry.discardConnection(CloseMode.IMMEDIATE);
                                }
                            }
                        }
                    }
                    final ManagedHttpClientConnection conn = poolEntry.getConnection();
                    if (conn != null) {
                        conn.activate();
                    } else {
                        poolEntry.assignConnection(connFactory.createConnection(null));
                    }
                    this.endpoint = new InternalConnectionEndpoint(poolEntry);
                    if (LOG.isDebugEnabled()) {
                        LOG.debug("{} acquired {}", id, ConnPoolSupport.getId(endpoint));
                    }
                    return this.endpoint;
                } catch (final Exception ex) {
                    if (LOG.isDebugEnabled()) {
                        LOG.debug("{} endpoint lease failed", id);
                    }
                    pool.release(poolEntry, false);
                    throw new ExecutionException(ex.getMessage(), ex);
                }
            }

            @Override
            public boolean cancel() {
                return leaseFuture.cancel(true);
            }

        };

    }