}

    @Test
    public void testScrollTimeout() {
        // Test setting scroll timeout
        SuggestSettingsBuilder result = builder.scrollTimeout("10s");
        assertEquals(builder, result); // Test method chaining
        assertEquals("10s", builder.timeoutSettings.scrollTimeout);

        // Test updating scroll timeout
        builder.scrollTimeout("30s");

        Exception timeoutError = new java.net.SocketTimeoutException("Operation timed out");

        // Test fallback logic
        assertTrue(errorHandler.shouldFallbackToTcp(hardwareError), "Hardware errors should suggest TCP fallback");
        assertFalse(errorHandler.shouldFallbackToTcp(timeoutError), "Timeout errors should not immediately suggest TCP fallback");

        // Test error classification using public API

    }

    @Test
    @DisplayName("Test constructor with name and timeout sets correct fields")
    void testConstructorWithNameAndTimeout() {
        // Test with pipe name and timeout
        String pipeName = "TestPipe";
        long timeout = 5000L;
        FsctlPipeWaitRequest request = new FsctlPipeWaitRequest(pipeName, timeout);

        // Verify size calculation

    reading the full response body. If a call requires redirects or retries all must complete within
    one timeout period.

    Use `OkHttpClient.Builder.callTimeout()` to specify the default duration and `Call.timeout()` to
    specify the timeout of an individual call.

 *  New: Return values and fields are now non-null unless otherwise annotated.

    }

    /**
     * Sets the scroll timeout.
     * @param timeout The scroll timeout.
     * @return This builder instance.
     */
    public SuggestSettingsBuilder scrollTimeout(final String timeout) {
        timeoutSettings.setScrollTimeout(timeout);
        return this;
    }

    /**
     * Sets the search timeout.
     * @param timeout The search timeout.
     * @return This builder instance.
     */

            this.indexTimeout = timeout;
        }

        /**
         * Sets the bulk timeout.
         * @param timeout The bulk timeout.
         */
        public void setBulkTimeout(final String timeout) {
            this.bulkTimeout = timeout;
        }

        /**
         * Sets the indices timeout.
         * @param timeout The indices timeout.
         */

    }

    /**
     * Gets the timeout for PDF extraction in milliseconds.
     * @return the timeout in milliseconds
     */
    public long getTimeout() {
        return timeout;
    }

    /**
     * Sets the timeout for PDF extraction in milliseconds.
     * @param timeout the timeout in milliseconds
     */
    public void setTimeout(final long timeout) {
        this.timeout = timeout;
    }

            }
            if (exitValue != 0) {
                final StringBuilder out = new StringBuilder();
                if (processTimeout) {
                    out.append("Process is terminated due to ").append(timeout).append(" second exceeded.\n");
                }
                out.append("Exit Code: ").append(exitValue).append("\nOutput:\n").append(it.getOutput());
                throw new JobProcessingException(out.toString());

      for (Thread hook : hooks) {
        hook.start();
      }
      for (Thread hook : hooks) {
        hook.join();
      }
    }
  }

  /* Half of a 1-second timeout in nanoseconds */
  private static final long HALF_SECOND_NANOS = NANOSECONDS.convert(1L, SECONDS) / 2;

  public void testShutdownAndAwaitTermination_immediateShutdown() throws Exception {

// Lock - block until write lock is taken or timeout has occurred.
func (di *distLockInstance) GetLock(ctx context.Context, timeout *dynamicTimeout) (LockContext, error) {
	lockSource := getSource(2)
	start := UTCNow()

	newCtx, cancel := context.WithCancel(ctx)
	if !di.rwMutex.GetLock(newCtx, cancel, di.opsID, lockSource, dsync.Options{
		Timeout:       timeout.Timeout(),
		RetryInterval: timeout.RetryInterval(),
	}) {