YiBoRequestDirector.java 文件源码

/**
 * Establish connection either directly or through a tunnel and retry in case of
 * a recoverable I/O failure
 */
private void tryConnect(
        final RoutedRequest req, final HttpContext context) throws HttpException, IOException {
    HttpRoute route = req.getRoute();

    int connectCount = 0;
    for (;;) {
        // Increment connect count
        connectCount++;
        try {
            if (!managedConn.isOpen()) {
                managedConn.open(route, context, params);
            } else {
                managedConn.setSocketTimeout(HttpConnectionParams.getSoTimeout(params));
            }
            establishRoute(route, context);
            break;
        } catch (IOException ex) {
            try {
                managedConn.close();
            } catch (IOException ignore) {
            }
            if (retryHandler.retryRequest(ex, connectCount, context)) {
                if (Constants.DEBUG) {
                    logger.debug("I/O exception ({}) caught when connecting to the target host: {}",
                            ex.getClass().getName(), ex.getMessage());
                    logger.debug(ex.getMessage(), ex);
                    logger.debug("Retrying connect");
                }
            } else {
                throw ex;
            }
        }
    }
}