* we've chosen to instead use a signature that benefits existing users -- and is still safe.
   *
   * For convertAll, I haven't looked as closely at *how* much existing users benefit, so we should
   * keep an eye out for problems that new users encounter. Note also that convertAll could support

        String message = "Test error message";
        Exception cause = new RuntimeException("Root cause");

        DataStoreCrawlingException exception = new DataStoreCrawlingException(url, message, cause);

        assertEquals(url, exception.getUrl());
        assertEquals(message, exception.getMessage());
        assertEquals(cause, exception.getCause());
        assertFalse(exception.aborted());
    }

    }

    /**
     * Builds a comprehensive error message from a throwable and its causes.
     * This method traverses the cause chain and concatenates all error messages.
     *
     * @param t the throwable to build message from
     * @return a string containing all error messages in the cause chain
     */
    protected String buildThrowableMessage(final Throwable t) {
        final StringBuilder buf = new StringBuilder(100);

        // Strictly, this doesn't necessarily indicate a hidden 'this' in the case of
        // static initializer. But there seems no way to tell in that case. :(
        // This may cause issues when an anonymous class is created inside a static initializer,
        // and the class's constructor's first parameter happens to be the enclosing class.
        // In such case, we may mistakenly think that the class is within a non-static context

   *
   * The connection is implicit, and will generally relate to the last [connectionAcquired] event.
   *
   * This will usually be invoked only 1 time for a single [Call], exceptions are a limited set of
   * cases including failure recovery.
   *
   * Prior to OkHttp 4.3 this was incorrectly invoked when the client was ready to read the response
   * body. This was misleading for tracing because it was too early.
   */

        assertEquals(cause, exception.getCause(), "Cause should match the provided throwable");
    }

    @Test
    void testMessageAndCauseConstructor() {
        // Test the constructor with both message and cause arguments
        String message = "Test message with cause";
        Throwable cause = new IllegalArgumentException("Invalid argument");
        RequestTimeoutException exception = new RequestTimeoutException(message, cause);

        assertNull(exception.getCause(), "Cause should be null for string constructor");
    }

    @Test
    void testThrowableConstructor() {
        // Test the constructor with a cause
        Throwable cause = new RuntimeException("Root cause of timeout");
        ConnectionTimeoutException exception = new ConnectionTimeoutException(cause);
        assertEquals("java.lang.RuntimeException: Root cause of timeout", exception.getMessage(),

   */
  override fun close() {
    close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null)
  }

  internal fun close(
    connectionCode: ErrorCode,
    streamCode: ErrorCode,
    cause: IOException?,
  ) {
    assertLockNotHeld()

    ignoreIoExceptions {
      shutdown(connectionCode)
    }

    var streamsToClose: Array<Http2Stream>? = null
    withLock {

        // Test constructor with null component name and valid cause
        Throwable cause = new RuntimeException("Test cause");
        ContainerNotAvailableException exception = new ContainerNotAvailableException(null, cause);

        assertEquals("null is not available.", exception.getMessage());
        assertEquals(cause, exception.getCause());
        assertNull(exception.getComponentName());
    }

    /**
     * Creates a new DataStoreException with the specified message and cause.
     *
     * @param message the error message
     * @param cause the underlying cause of this exception
     */
    public DataStoreException(final String message, final Throwable cause) {
        super(message, cause);
    }

    /**
     * Creates a new DataStoreException with the specified message.
     *