@Mock
    SmbFileHandleImpl handle;

    @Mock
    SmbTreeHandleImpl tree;

    // Prepare SMB2 flow with a given response
    private void setupSmb2(NotifyResponse resp, byte[] fileId) throws Exception {
        when(handle.isValid()).thenReturn(true);
        when(handle.getTree()).thenReturn(tree);
        when(tree.isSMB2()).thenReturn(true);
        when(tree.getConfig()).thenReturn(mock(Configuration.class));

    /**
     * @throws Exception
     */
    @Test
    public void testClose() throws Exception {
        final NotifyOutputStream out = new NotifyOutputStream();
        CloseableUtil.close(out);
        assertThat(out.getNotify(), is("closed"));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testCloseNull() throws Exception {
        CloseableUtil.close((OutputStream) null);

 */
@Deprecated(since = "4.0.0")
public class TransformerException extends Exception {

    public TransformerException(Exception e) {
        super(e);
    }

    public TransformerException(String message, Throwable exception) {
        super(message, exception);
    }

            der.close();
        }
        return collector.toByteArray();
    }

    @Test
    @DisplayName("Round-trip: all fields set encodes and parses back correctly")
    void testRoundTripAllFields() throws Exception {
        ASN1ObjectIdentifier[] mechs = new ASN1ObjectIdentifier[] { OID_KRB, OID_NTLM };
        int flags = NegTokenInit.DELEGATION | NegTokenInit.MUTUAL_AUTHENTICATION | NegTokenInit.INTEGRITY;

        runner.ensureYellow();
    }

    @AfterClass
    public static void afterClass() throws Exception {
        runner.close();
        runner.clean();
    }

    @Before
    public void before() throws Exception {
        runner.admin().indices().prepareDelete("_all").execute().actionGet();
        runner.refresh();

    /**
     * @throws Exception
     */
    @Test
    public void testGetAsObject() throws Exception {
        final NumberConverter converter = new NumberConverter("##0");
        assertThat(converter.getAsObject("100"), is((Object) Long.valueOf("100")));
    }

    /**
     * @throws Exception
     */
    @Test
    public void testGetAsString() throws Exception {

      throws Exception {
    try {
      future.get();
      fail("Expected ExecutionException");
    } catch (ExecutionException e) {
      assertThat(e).hasCauseThat().isSameInstanceAs(expectedCause);
    }
  }

  /** invokeAny(null) throws NPE */
  public void testInvokeAnyImpl_nullTasks() throws Exception {

    }

    /**
     * Test pre-auth integrity with non-SMB3.1.1 should throw exception
     */
    @Test
    @DisplayName("Pre-auth integrity should fail with non-SMB3.1.1")
    void testPreauthWithNonSmb311() throws Exception {
        // Setup SMB3.0
        when(negotiateResponse.getSelectedDialect()).thenReturn(DialectVersion.SMB300);

    TestCloseable c2 = closer.register(TestCloseable.normal());

    IOException exception = new IOException();

    try {
      try {
        throw exception;
      } catch (Throwable e) {
        throw closer.rethrow(e);
      } finally {
        closer.close();
      }
    } catch (Throwable caught) {
      assertThat(caught).isEqualTo(exception);
    }

    assertTrue(c1.isClosed());
    assertTrue(c2.isClosed());

    @DisplayName("createChannelTransport should fail with null addresses")
    void testCreateChannelTransportWithNullAddresses() {
        // Use reflection to access private method for testing
        Exception exception = assertThrows(Exception.class, () -> {
            java.lang.reflect.Method method =
                    MultiChannelManager.class.getDeclaredMethod("createChannelTransport", InetAddress.class, InetAddress.class);