void isOpen_delegates(boolean state) throws Exception {
        // Arrange
        SmbPipeOutputStream out = newStream();
        when(handle.isOpen()).thenReturn(state);

        // Act
        boolean result = out.isOpen();

        // Assert
        assertEquals(state, result, "isOpen should reflect handle state");
        verify(handle, times(1)).isOpen();
    }

    @Test

       <Rule>
               <ID>max-versions</ID>
               <Status>Enabled</Status>
               <NoncurrentVersionExpiration>
                       <NewerNoncurrentVersions>2</NewerNoncurrentVersions>
               </NoncurrentVersionExpiration>
       </Rule>
       <Rule>
               <ID>delete-all-versions</ID>
               <Status>Enabled</Status>
               <Filter>
                       <Tag>

        boolean more;
        do {
            int n;

            send(req, resp);

            if (resp.status != WinError.ERROR_SUCCESS && resp.status != WinError.ERROR_MORE_DATA) {
                throw new SmbException(resp.status, true);
            }
            more = resp.status == WinError.ERROR_MORE_DATA;

            n = more ? resp.numEntries - 1 : resp.numEntries;

        response.status = 0;
        response.numEntries = 2;
        byte[] buffer = { 0x00, 0x00, 0x12, 0x34, 0x02, 0x00, 0x05, 0x00 };
        response.readParametersWireFormat(buffer, 0, buffer.length);

        String resultString = response.toString();
        assertTrue(resultString.contains("status=0"), "toString should contain the status.");

     */
    @Test
    void testIsConnected() {
        when(smbTreeHandle.isConnected()).thenReturn(true);
        assertTrue(smbTreeHandle.isConnected(), "isConnected() should return true");
        when(smbTreeHandle.isConnected()).thenReturn(false);
        assertFalse(smbTreeHandle.isConnected(), "isConnected() should return false after status change");
    }

    /**

                .append(",workstation=")
                .append(this.workstation)
                .append(",isEstablished=")
                .append(this.isEstablished)
                .append(",state=")
                .append(this.state)
                .append(",serverChallenge=");
        if (this.serverChallenge == null) {
            ret.append("null");
        } else {

    /**
     * Evaluates this guard's boolean condition. This method is always called with the associated
     * monitor already occupied. Implementations of this method must depend only on state protected
     * by the associated monitor, and must not modify that state.
     */
    public abstract boolean isSatisfied();
  }

  /** Whether this monitor is fair. */
  private final boolean fair;

* fix kubectl taint e2e flake: add retries for removing taint ([#33872](https://github.com/kubernetes/kubernetes/pull/33872), [@kevin-wangzefeng](https://github.com/kevin-wangzefeng))
* portfordwardtester: avoid data loss during send+close+exit ([#37103](https://github.com/kubernetes/kubernetes/pull/37103), [@sttts](https://github.com/sttts))

    protected static DcerpcBinding parseBinding(final String str) throws DcerpcException {
        int state, mark, si;
        final char[] arr = str.toCharArray();
        String proto = null, key = null;
        DcerpcBinding binding = null;

        state = mark = si = 0;
        do {
            final char ch = arr[si];

            switch (state) {
            case 0:
                if (ch == ':') {

        assertEquals(info3.path, decodedInfo3.path);
        assertEquals(info3.comment, decodedInfo3.comment);
        assertEquals(info3.state, decodedInfo3.state);
        assertEquals(info3.num_stores, decodedInfo3.num_stores);
        assertEquals(info3.stores[0].state, decodedInfo3.stores[0].state);
        assertEquals(info3.stores[0].server_name, decodedInfo3.stores[0].server_name);