socketFactory[proxyServer2] = server2.socketAddress

    println("\n\nRequest to ${server2.socketAddress}")
    executeSynchronously(request)
      .apply {
        // We may have a single failed request if not clean shutdown
        if (cleanClose) {
          assertSuccessful()
          assertCode(200)

          assertThat(server2.requestCount).isEqualTo(1)
        } else {

## Version 3.14.2

_2019-05-19_

 *  Fix: Lock in a route when recovering from an HTTP/2 connection error. We had a bug where two
    calls that failed at the same time could cause OkHttp to crash with a `NoSuchElementException`
    instead of the expected `IOException`.

 *  Fix: Don't crash with a `NullPointerException` when formatting an error message describing a

        for (final Ingester ingester : ingestFactory.getIngesters()) {
            try {
                target = ingester.process(target, paramMap);
            } catch (final Exception e) {
                logger.warn("[{}] Failed to process ingester", ingester.getClass().getSimpleName(), e);
            }
        }
        return target;
    }

    /**
     * Commits any remaining documents in the cache to the index.

        try {
            EVERYONE = new SID("S-1-1-0");
            CREATOR_OWNER = new SID("S-1-3-0");
            SYSTEM = new SID("S-1-5-18");
        } catch (final SmbException se) {
            log.error("Failed to create builtin SIDs", se);
        }
    }

    /**
     * Convert a sid_t to byte array
     *
     * @param sid the RPC sid_t structure to convert
     * @return byte encoded form
     */

                try {
                    this.password = pwAuth.getAnsiHash(this.ctx, this.server.encryptionKey);
                } catch (final GeneralSecurityException e) {
                    throw new RuntimeCIFSException("Failed to encrypt password", e);
                }
                this.passwordLength = this.password.length;
            } else if (this.ctx.getConfig().isDisablePlainTextPasswords()) {

     * @param flag the flag to set
     */
    public void setFlag(final int flag) {
        flags |= flag;
    }

    /**
     * Get the result of the DCERPC call.
     * @return result exception if the call failed, null otherwise
     */
    public DcerpcException getResult() {
        if (result != 0) {
            return new DcerpcException(result);
        }
        return null;
    }

        // Circuit breaker should have handled concurrent operations
        assertTrue(successCount.get() > 0, "Should have some successful operations");
        assertTrue(failureCount.get() > 0, "Should have some failed operations");
    }

    @Test
    public void testHalfOpenMaxAttempts() throws Exception {
        // Open circuit
        circuitBreaker.trip();

        // Wait for reset timeout

      } catch (e: Exception) {
        val tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs)
        logger.log(
          buildString {
            append("<-- HTTP FAILED: $e.")
            append(" ${redactUrl(request.url)} (${tookMs}ms)")
          },
        )
        throw e
      }

      val tookMs = TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startNs)

                    }
                }
            } catch (final IOException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to read data.", e);
                }
                return StringUtil.EMPTY;
            }

            return buf.toString().trim();
        }

        private boolean isSpaceChar(final int c) {

      call: Call,
      handshake: Handshake?,
    ) {
      logger.removeHandler(loggerHandler)
    }

    override fun callEnd(call: Call) {
      // Cleanup log handler if failed.
      logger.removeHandler(loggerHandler)
    }

    override fun connectionAcquired(
      call: Call,
      connection: Connection,
    ) {
      if (random != null) {