void ensureDFSResolved_throws() throws Exception {
        // Arrange: configure the mock to throw
        doThrow(new CIFSException("DFS resolution failed")).when(handle).ensureDFSResolved();

        // Act + Assert: exception is propagated with message
        CIFSException ex = assertThrows(CIFSException.class, () -> handle.ensureDFSResolved());

     * {@inheritDoc}
     *
     * @see java.lang.AutoCloseable#close()
     */
    @Override
    public void close() throws CIFSException {
        if (this.next != null) {
            doClose();
        }
    }

    @Override
    public void remove() {
        throw new UnsupportedOperationException("remove");
    }

            throw new IOException("Witness unregister RPC failed", e);
        }
    }
    
    public WitnessHeartbeatResponse heartbeat(WitnessHeartbeatRequest request) throws IOException {
        try {
            WitnessHeartbeatStub stub = new WitnessHeartbeatStub(request);
            handle.sendrecv(stub);
            return stub.getResponse();
        } catch (Exception e) {

            when(mockDeferredBuffer.dec_ndr_long()).thenReturn(-1); // Invalid _name_buffers

            // When/Then: Should throw exception
            NdrException thrown = assertThrows(NdrException.class, () -> entry.decode(mockNdrBuffer));
            assertEquals(NdrException.INVALID_CONFORMANCE, thrown.getMessage());
        }
    }

    @Nested
    @DisplayName("SamrSamArray Tests")
    class SamrSamArrayTests {

            emptyEnv.get("non.existent.property");
            fail("Should throw ConfigPropertyNotFoundException");
        } catch (ConfigPropertyNotFoundException e) {
            assertTrue(e.getMessage().contains("non.existent.property"));
        }

        try {
            emptyEnv.is("non.existent.boolean");
            fail("Should throw ConfigPropertyNotFoundException");
        } catch (ConfigPropertyNotFoundException e) {

     * @param listener the response listener
     * @throws UnsupportedOperationException always thrown as this operation is not implemented
     */
    @Override
    public void searchView(org.opensearch.action.admin.indices.view.SearchViewAction.Request request,
            ActionListener<SearchResponse> listener) {
        throw new UnsupportedOperationException("Not implemented yet");
    }

    /**

        handle.sendrecv(rpc);
        if (rpc.retval != 0) {
            throw new SmbException(rpc.retval, false);
        }
    }

    /**
     * Closes this SAM domain handle.
     *
     * @throws IOException if an I/O error occurs during handle closure
     */
    public void close() throws IOException {
        final MsrpcSamrCloseHandle rpc = new MsrpcSamrCloseHandle(this);
        handle.sendrecv(rpc);

                throw de;
            }

            final MsrpcSamrConnect2 rpc2 = new MsrpcSamrConnect2(server, access, this);
            handle.sendrecv(rpc2);
        }
    }

    /**
     * Closes this SAM policy handle.
     *
     * @throws IOException if an I/O error occurs during handle closure
     */
    public void close() throws IOException {

    if (!"Upgrade".equals(headerConnection, ignoreCase = true)) {
      throw ProtocolException(
        "Expected 'Connection' header value 'Upgrade' but was '$headerConnection'",
      )
    }

    val headerUpgrade = response.header("Upgrade")
    if (!"websocket".equals(headerUpgrade, ignoreCase = true)) {
      throw ProtocolException(
        "Expected 'Upgrade' header value 'websocket' but was '$headerUpgrade'",

                }
            }
        }
        try {
            factory.setFeature(XMLConstants.FEATURE_SECURE_PROCESSING, true);
        } catch (final ParserConfigurationException e) {
            throw new ParserConfigurationRuntimeException(e);
        }
        return factory;
    }

    /**
     * Creates a new {@link DocumentBuilder}.
     *
     * @return A new {@link DocumentBuilder}.
     */