new TransferResource(null, null, "http://maven.org/test/test-resource", new File("file"), null);
            DefaultRepositorySystemSession session = new DefaultRepositorySystemSession(h -> false); // no close handle

            // for technical reasons we cannot throw here, even if delegate does cancel transfer
            listener.transferInitiated(event(session, resource, TransferEvent.EventType.INITIATED));

 *
 * @author mbechler
 */
public class Smb2TreeDisconnectRequest extends ServerMessageBlock2Request<Smb2TreeDisconnectResponse> {

    /**
     * Creates a new SMB2 tree disconnect request to close a tree connection.
     *
     * @param config the CIFS configuration
     */
    public Smb2TreeDisconnectRequest(final Configuration config) {
        super(config, SMB2_TREE_DISCONNECT);
    }

    @Override

    val socket = Socket()
    socket.connect(serverSocket.localSocketAddress)
    val socketSource = socket.source().buffer()

    assertThat(socket.isHealthy(socketSource)).isTrue()

    serverSocket.close()
    assertThat(socket.isHealthy(socketSource)).isFalse()
  }

  @Test
  fun testDurationTimeUnit() {
    assertThat(checkDuration("timeout", 0, TimeUnit.MILLISECONDS)).isEqualTo(0)

            }
            return URLConnection.guessContentTypeFromName(path);
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        } finally {
            CloseableUtil.close(is);
        }
    }

 */
public enum HandleType {
    /**
     * No durability - standard handle
     */
    NONE(0),

    /**
     * SMB 2.1 durable handle - survives network loss
     */
    DURABLE_V1(1),

    /**
     * SMB 3.0 durable handle V2 - with timeout configuration
     */
    DURABLE_V2(2),

    /**
     * SMB 3.0 persistent handle - survives server reboot
     */

                        .pluginTypes("org.codelibs.opensearch.extension.ExtensionPlugin"));
        runner.ensureYellow();
    }

    @Override
    protected void tearDown() throws Exception {
        runner.close();
        runner.clean();
    }

    public void test_buildWithDefault() throws Exception {
        final String id = "BuildTest";
        final Suggester suggester = Suggester.builder().build(runner.client(), id);

      call: Call,
      connection: Connection,
    ) {
      lastSocket = connection.socket()
    }

    override fun requestHeadersStart(call: Call) {
      if (shouldClose) {
        lastSocket!!.close()
      }
    }
  }

  @Test
  fun socketFailureOnLargeRequestHeaders() {
    server.enqueue(MockResponse())
    server.enqueue(MockResponse())
    server.start()

    val call1 =

    }

    void close(final int f, final long lastWriteTime) throws SmbException {

        if (LogStream.level >= 3) {
            log.println("close: " + f);
        }

        /*
         * Close Request / Response
         */

        send(new SmbComClose(f, lastWriteTime), blank_resp());
    }

    void close(final long lastWriteTime) throws SmbException {

        super.setUp();
    }

    @Override
    public void tearDown() throws Exception {
        super.tearDown();
        // close runner
        runner.close();
        // delete all files
        runner.clean();
    }

    public void test_addIncludeUrlFilter_singleTx() {
        final String sessionId = "session1";

            }
            this.closed = true;
        } finally {
            this.signingLock.unlock();
        }
    }

    /**
     * Close the signing digest and securely wipe keys
     */
    @Override
    public void close() {
        secureWipeKey();
    }