*/
package jcifs.smb;

import jcifs.CIFSException;

/**
 * Output stream for writing to SMB named pipes.
 *
 * This class provides a stream-based interface for writing
 * data to SMB named pipes over the network.
 *
 * @author mbechler
 */
public class SmbPipeOutputStream extends SmbFileOutputStream {

    private final SmbPipeHandleImpl handle;

    /**

 * <code>WriteFile</code>, and <code>CloseFile</code> interface was
 * being used.
 * </td>
 * </tr>
 * </table>
 *
 * <p>
 * See <a href="../../../pipes.html">Using jCIFS to Connect to Win32
 * Named Pipes</a> for a detailed description of how to use jCIFS with
 * Win32 Named Pipe server processes.
 *
 */

public class SmbNamedPipe extends SmbFile implements SmbPipeResource {

## Changelog since v1.17.5

## Changes by Kind

### API Change
 - Fix bug where sending a status update completely wipes managedFields for some types. ([#90032](https://github.com/kubernetes/kubernetes/pull/90032), [@apelisse](https://github.com/apelisse)) [SIG API Machinery and Testing]

### Bug or Regression

 * <code>WriteFile</code>, and <code>CloseFile</code> interface was
 * being used.
 * </td></tr>
 * </table>
 *
 * <p>See <a href="../../../pipes.html">Using jCIFS to Connect to Win32
 * Named Pipes</a> for a detailed description of how to use jCIFS with
 * Win32 Named Pipe server processes.
 *
 */

public class SmbNamedPipe extends SmbFile {

    /**

import jcifs.internal.smb2.ioctl.Smb2IoctlResponse;
import jcifs.internal.smb2.ioctl.SrvPipePeekResponse;

/**
 * Input stream for reading from SMB named pipes.
 *
 * This class provides a stream-based interface for reading
 * data from SMB named pipes over the network.
 *
 * @author mbechler
 */
public class SmbPipeInputStream extends SmbFileInputStream {

    private final SmbPipeHandleImpl handle;

    /**

            MalformedURLException ex =
                    assertThrows(MalformedURLException.class, () -> new SmbNamedPipe(url, SmbPipeResource.PIPE_TYPE_RDWR, ctx()));
            assertEquals("Named pipes are only valid on IPC$", ex.getMessage());
        }

        @Test
        @DisplayName("Null context throws NPE (invalid input)")
        void nullContextThrows() {

            System.arraycopy(ciphertext, 0, result, GCM_IV_SIZE, ciphertext.length);

            return result;

        } finally {
            // Securely wipe plaintext bytes - guaranteed by try-finally
            if (plaintextBytes != null) {
                SecureKeyManager.secureWipe(plaintextBytes);
            }
        }
    }

import jcifs.smb1.smb1.SmbFileInputStream;
import jcifs.smb1.smb1.SmbFileOutputStream;
import jcifs.smb1.smb1.SmbNamedPipe;
import jcifs.smb1.util.Encdec;

/**
 * DCERPC handle implementation using SMB named pipes for transport
 */
public class DcerpcPipeHandle extends DcerpcHandle {

    SmbNamedPipe pipe;
    SmbFileInputStream in = null;
    SmbFileOutputStream out = null;
    boolean isStart = true;

    /**

        return result;
    }

    @Override
    public int available() throws IOException {
        if (LogStream.level >= 3) {
            SmbFile.log.println("Named Pipe available() does not apply to TRANSACT Named Pipes");
        }
        return 0;
    }

    int receive(final byte[] b, int off, final int len) {
        int i;

        if (len > pipe_buf.length - used) {
            byte[] tmp;

import jcifs.smb.SmbNamedPipe;
import jcifs.smb.SmbPipeHandleInternal;
import jcifs.util.Encdec;

/**
 * DCE/RPC handle implementation for named pipe communications.
 * This class provides DCE/RPC communication over SMB named pipes.
 */
public class DcerpcPipeHandle extends DcerpcHandle {

    /* This 0x20000 bit is going to get chopped! */