if (log.isDebugEnabled()) {
                log.debug("Trying address {}", addr);
            }
            try (SmbTransportImpl trans = getSmbTransport(tf, addr, port, exclusive, forceSigning).unwrap(SmbTransportImpl.class)) {
                try {
                    trans.ensureConnected();
                } catch (final IOException e) {
                    removeTransport(trans);

     */
    public static ByteBuffer map(final FileChannel channel, final MapMode mode) {
        assertArgumentNotNull("channel", channel);
        assertArgumentNotNull("mode", mode);

        try {
            return channel.map(mode, 0, channel.size());
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

    /**
     * Returns the size of the file.

        try {
            dataIndexHelper.crawl("test-session");
            assertTrue("Should complete quickly with empty config list", true);
        } catch (Exception e) {
            assertTrue("Exception handling should be fast", true);
        }
    }

    @Test
    public void test_crawl_withConfigIdList_emptyList() {
        try {

     * @return An {@link InputStream} to read the resource represented by the URL.
     */
    public static InputStream openStream(final URL url) {
        assertArgumentNotNull("url", url);

        try {
            final URLConnection connection = url.openConnection();
            connection.setUseCaches(false);
            return connection.getInputStream();
        } catch (final IOException e) {

                builder.startObject();
                builder.field("string", "test");
                builder.endObject();
                return builder;
            }
        };

        try {
            String result = SearchEngineUtil.getXContentString(xContent, XContentType.JSON);
            assertNotNull(result);
            assertTrue(result.contains("string"));

      isSocket = false,
    )
  }

  @Throws(IOException::class)
  fun flushRequest() {
    try {
      codec.flushRequest()
    } catch (e: IOException) {
      call.eventListener.requestFailed(call, e)
      trackFailure(e)
      throw e
    }
  }

  @Throws(IOException::class)
  fun finishRequest() {
    try {
      codec.finishRequest()
    } catch (e: IOException) {

  override fun afterHandshake(sslSocket: SSLSocket) {
    try {
      removeMethod.invoke(null, sslSocket)
    } catch (e: IllegalAccessException) {
      throw AssertionError("failed to remove ALPN", e)
    } catch (e: InvocationTargetException) {
      throw AssertionError("failed to remove ALPN", e)
    }
  }

  override fun getSelectedProtocol(sslSocket: SSLSocket): String? {
    try {

        // purge crawling sessions
        try {
            crawlingInfoService.deleteBefore(systemHelper.getCurrentTimeAsLong());
        } catch (final Exception e) {
            logger.error("Failed to purge crawling sessions.", e);
            resultBuf.append(e.getMessage()).append("\n");
        }

        // purge search logs
        try {

        activeDescriptorsById.put(descriptor.getId(), descriptor);
        if (rootTestDescriptor == null) {
            rootTestDescriptor = descriptor;
            try {
                delegate.started(descriptor, testStartEvent);
            } catch (IllegalArgumentException illegalArgumentException) {
                logTracing(descriptor.getId(), illegalArgumentException);
            }

                final long seqNo = getLongValue(result, "_seq_no");
                final long primaryTerm = getLongValue(result, "_primary_term");

                // Try to delete with optimistic concurrency
                try (CurlResponse deleteResponse = ComponentUtil.getCurlHelper() //
                        .delete("/" + getIndexName() + "/_doc/" + operationName //