passwordField.setAccessible(true);

        // Verify password exists before wipe
        char[] passwordBefore = (char[]) passwordField.get(authenticator);
        assertNotNull(passwordBefore, "Password should exist before wipe");
        assertArrayEquals(testPassword.toCharArray(), passwordBefore, "Password should match before wipe");

        // Wipe the password
        authenticator.secureWipePassword();

          branches:
            - "${branch_specifier}"
          url: "https://github.com/elastic/elasticsearch.git"
          basedir: ""
          wipe-workspace: true
    triggers: []
    wrappers:
      - timeout:
          type: absolute
          timeout: 480
          fail: true
      - ansicolor
      - timestamps
      - gradle-build-scan

    }

    @Test
    @DisplayName("Test with various pipe name formats")
    void testVariousPipeNameFormats() {
        // Test various pipe name formats
        String[] pipeNames =
                { "\\\\server\\PIPE\\testpipe", "\\PIPE\\LANMAN", "\\PIPE\\srvsvc", "\\PIPE\\wkssvc", "PIPE\\test", "testpipe" };

        for (String pipeName : pipeNames) {
            // Act

        // The actual user home dir will be a subfolder using the name of the distribution.
        gradleUserHomeDir = intTestHomeDir
        // The user home dir is not wiped out by clean. Move the daemon working space underneath the build dir so they don't pile up on CI.
        // The actual daemon registry dir will be a subfolder using the name of the distribution.

        void constructsWithIpcShare(String url) throws Exception {
            // Arrange & Act
            SmbNamedPipe pipe = new SmbNamedPipe(url, SmbPipeResource.PIPE_TYPE_RDWR, ctx());

            // Assert: type is named pipe and pipe type preserved
            assertEquals(SmbConstants.TYPE_NAMED_PIPE, pipe.getType(), "Type should be TYPE_NAMED_PIPE");

                Arguments.of(WinError.ERROR_BAD_PIPE, "The pipe state is invalid."),
                Arguments.of(WinError.ERROR_PIPE_BUSY, "All pipe instances are busy."),
                Arguments.of(WinError.ERROR_NO_DATA, "The pipe is being closed."),
                Arguments.of(WinError.ERROR_PIPE_NOT_CONNECTED, "No process is on the other end of the pipe."),
                Arguments.of(WinError.ERROR_MORE_DATA, "More data is available."),

    private final String path;
    private final SmbNamedPipe pipe;
    private final byte[] tmp = new byte[1];
    private final boolean dcePipe;

    TransactNamedPipeOutputStream(final SmbNamedPipe pipe) throws IOException {
        super(pipe, false, pipe.pipeType & 0xFFFF00FF | SmbFile.O_EXCL);
        this.pipe = pipe;
        this.dcePipe = (pipe.pipeType & SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT) == SmbNamedPipe.PIPE_TYPE_DCE_TRANSACT;

import okhttp3.internal.http2.Header
import okio.ByteString

/**
 * Representation of an individual case (set of headers and wire format). There are many cases for a
 * single story.  This class is used reflectively with Moshi to parse stories.
 */
data class Case(
  val seqno: Int = 0,
  val wire: ByteString? = null,
  val headers: List<Map<String, String>>,
) : Cloneable {
  val headersList: List<Header>
    get() {

 * <ul>
 * <li><code>CallNamedPipe</code> A message-type pipe call that opens,
 * writes to, reads from, and closes the pipe in a single operation.
 * <li><code>TransactNamedPipe</code> A message-type pipe call that
 * writes to and reads from an existing pipe descriptor in one operation.
 * <li><code>CreateFile</code>, <code>ReadFile</code>,
 * <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can

 * <li> <code>CallNamedPipe</code> A message-type pipe call that opens,
 *      writes to, reads from, and closes the pipe in a single operation.
 * <li> <code>TransactNamedPipe</code> A message-type pipe call that
 *      writes to and reads from an existing pipe descriptor in one operation.
 * <li> <code>CreateFile</code>, <code>ReadFile</code>,
 *      <code>WriteFile</code>, and <code>CloseFile</code> A byte-type pipe can