throw new IOException("RDMA send failed", e);
        }
    }
    
    @Override
    public ByteBuffer receive(int timeout) throws IOException {
        try {
            RdmaCompletionEvent event = endpoint.getCqProcessor().getCqEvent(timeout);
            if (event != null) {
                return event.getBuffer();
            }
            return null;
        } catch (Exception e) {

    // This class can make no hard guarantees.  The methods in this class are inherently flaky, but
    // we try hard to make them robust in practice.  We could additionally try to add in a system
    // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
    // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
    // user-specified -XX:+DisableExplicitGC.
    //

    } catch (ExecutionException e) {
      rethrow(e);
    }
    throw new AssertionError("Unreachable");
  }

  @Override
  public V get(long timeout, TimeUnit unit)
      throws InterruptedException, ExecutionException, TimeoutException {
    try {
      super.get(timeout, unit);
    } catch (ExecutionException e) {
      rethrow(e);
    }
    throw new AssertionError("Unreachable");
  }

    protected long currentEndRecordNumber;

    /** List of page numbers for pagination navigation. */
    protected List<String> pageNumberList;

    /** Flag indicating whether the results are partial due to timeout or other issues. */
    protected boolean partialResults;

    /** The actual search query executed against the search engine. */
    protected String searchQuery;

	// Wait for all to connect
	// Parallel writes per server.
	b.Run("bytes", func(b *testing.B) {
		for par := 1; par <= 32; par *= 2 {
			b.Run("par="+strconv.Itoa(par*runtime.GOMAXPROCS(0)), func(b *testing.B) {
				defer timeout(60 * time.Second)()
				ctx, cancel := context.WithTimeout(b.Context(), 30*time.Second)
				defer cancel()
				b.ReportAllocs()
				b.SetBytes(int64(len(payload) * 2))
				b.ResetTimer()
				t := time.Now()

    }

    // Test execute method with process timeout
    @Test
    public void test_execute_processTimeout() {
        createRequiredDirectories();
        suggestJob.timeout(1);
        suggestJob.processTimeout = true;

        mockProcessHelper.setExitValue(1);
        mockProcessHelper.setOutput("Timeout occurred");

        String result = suggestJob.execute();

    // This class can make no hard guarantees.  The methods in this class are inherently flaky, but
    // we try hard to make them robust in practice.  We could additionally try to add in a system
    // load timeout multiplier.  Or we could try to use a CPU time bound instead of wall clock time
    // bound.  But these ideas are harder to implement.  We do not try to detect or handle a
    // user-specified -XX:+DisableExplicitGC.
    //

            throw new SQLRuntimeException(ex);
        }
    }

    /**
     * Sets the query timeout.
     *
     * @param statement
     *            {@link Statement}. Must not be {@literal null}.
     * @param queryTimeout
     *            Query timeout.
     * @see Statement#setQueryTimeout(int)
     */

     *
     * @param error the error to check
     * @return true if error might be recoverable, false otherwise
     */
    private boolean isRecoverableError(Exception error) {
        // Timeout errors are often recoverable
        if (error instanceof SocketTimeoutException) {
            return true;
        }

        // Some socket errors might be recoverable

          // No client for CONNECT tunnels:
          client = null,
          carrier = this,
          socket = socket,
        )
      socket.source.timeout().timeout(readTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      socket.sink.timeout().timeout(writeTimeoutMillis.toLong(), TimeUnit.MILLISECONDS)
      tunnelCodec.writeRequest(nextRequest.headers, requestLine)
      tunnelCodec.finishRequest()
      val response =