testStream = new PrintStream(testOutput);

        // Reset LogStream instance using reflection
        resetLogStreamInstance();
    }

    @AfterEach
    void tearDown() throws Exception {
        // Restore original state
        System.setErr(originalErr);
        LogStream.level = originalLevel;
        // Reset instance using reflection
        resetLogStreamInstance();
    }

        verify(smbFile, times(1)).length();

        // zero size -> reject
        reset(smbFile);
        when(smbFile.length()).thenReturn(0L);
        assertFalse(filter.accept(smbFile), "Zero size should be rejected");
        verify(smbFile, times(1)).length();

        // positive size -> accept
        reset(smbFile);
        when(smbFile.length()).thenReturn(42L);

    }

    /**
     * Resets the search criteria and displays all search log entries.
     *
     * @param form the search form to reset
     * @return HTML response with the reset search log list
     */
    @Execute
    @Secured({ ROLE, ROLE + VIEW })
    public HtmlResponse reset(final SearchForm form) {
        saveToken();
        searchLogPager.clear();

		b, err := iter.MarshalJSON()
		return sql.FromBytes(b), err
	}
	return nil, fmt.Errorf("iterToValue: unknown JSON type: %s", iter.Type().String())
}

// Reset the record.
func (r *Record) Reset() {
	r.object = simdjson.Object{}
}

// Clone the record and if possible use the destination provided.
func (r *Record) Clone(dst sql.Record) sql.Record {
	other, ok := dst.(*Record)
	if !ok {

                            : Math.min(MAX_RETRY_DELAY, retryDelayMs * multiplier);
                    Thread.sleep(delay);
                }

                // Attempt to reset the connection
                connection.reset();

                // Verify connection is working
                if (connection.getState() == RdmaConnection.RdmaConnectionState.ESTABLISHED) {

    /**
     * Resets the {@link InputStream}.
     *
     * @param is the input stream (must not be {@literal null})
     * @see InputStream#reset()
     */
    public static void reset(final InputStream is) {
        assertArgumentNotNull("is", is);

        try {
            is.reset();
        } catch (final IOException e) {
            throw new IORuntimeException(e);
        }
    }

import jcifs.smb.SmbException;

@ExtendWith(MockitoExtension.class)
class SamrPolicyHandleTest {

    @Mock
    private DcerpcHandle mockHandle;

    @BeforeEach
    void setUp() {
        // Reset mocks before each test
        reset(mockHandle);
    }

    @Test
    void testConstructor_SuccessfulConnect4() throws IOException {
        // Test case: Constructor with successful MsrpcSamrConnect4

        assertTrue(response.hasMoreElements());
    }

    @Test
    @DisplayName("Test reset method")
    void testReset() {
        // Set some values
        response.setDataCount(50);

        // Call reset
        response.reset();

        // After reset, hasMore should be true
        assertTrue(response.hasMoreElements());
    }

    @Test

import java.io.IOException

/** Thrown when an HTTP/2 stream is canceled without damage to the socket that carries it. */
class StreamResetException(
  @JvmField val errorCode: ErrorCode,

    platform.assumeHttp2Support()
  }

  @Test
  fun serverTruncatesRequestOnLongPostHttp1() {
    // "java.net.SocketException: Socket closed" thrown reading response after
    // "java.net.SocketException: Connection reset by peer" writing request
    assumeNotWindows()

    serverTruncatesRequestOnLongPost(https = false)
  }

  @Test
  fun serverTruncatesRequestOnLongPostHttp2() {
    enableProtocol(Protocol.HTTP_2)