"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
  %LAUNCHER_CLASS% ^
  %MAVEN_ARGS% ^
  %*
if ERRORLEVEL 1 goto error
goto end

:error
set ERROR_CODE=1

:end
@endlocal & set ERROR_CODE=%ERROR_CODE%

if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending

    @Test
    public void test_errorCodeGeneration() {
        long timestamp = System.currentTimeMillis();
        String errorCode = "error_code:" + Long.toHexString(timestamp);

        assertTrue(errorCode.startsWith("error_code:"));
        assertTrue(errorCode.length() > 11); // "error_code:" is 11 chars
    }

    // Test with different exception types
    @Test
    public void test_exceptionTypes() {

        } else {
            final String errorCode = UUID.randomUUID().toString();
            message = escapeJsonKeyValue("error_code:", errorCode);
            if (logger.isDebugEnabled()) {
                logger.debug("[{}] {}", errorCode, stacktraceString.get().replace("\n", "\\n"));
            } else if (status >= 500) {
                logger.warn("[{}] {}", errorCode, t.getMessage());
            }
        }

      assertThat(expected.errorCode).isEqualTo(ErrorCode.REFUSED_STREAM)
    }
  }

  @Test
  fun recoverFromOneInternalErrorRequiresNewConnection() {
    recoverFromOneHttp2ErrorRequiresNewConnection(ErrorCode.INTERNAL_ERROR)
  }

  @Test
  fun recoverFromOneCancelRequiresNewConnection() {
    recoverFromOneHttp2ErrorRequiresNewConnection(ErrorCode.CANCEL)
  }

        super(message, cause);
        errorCode = ERROR_UNKNOWN;
    }

    /**
     * Creates a new exception with the specified message and error code.
     *
     * @param message the error message
     * @param errorCode the error code
     */
    public LlmException(final String message, final String errorCode) {
        super(message);
        this.errorCode = errorCode;
    }

    /**

   * underlying input and output streams and shuts down internal task queues.
   */
  override fun close() {
    close(ErrorCode.NO_ERROR, ErrorCode.CANCEL, null)
  }

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

    ignoreIoExceptions {
      shutdown(connectionCode)
    }

    if (streamId == 0) throw IOException("TYPE_RST_STREAM streamId == 0")
    val errorCodeInt = source.readInt()
    val errorCode =
      ErrorCode.fromHttp2(errorCodeInt) ?: throw IOException(
        "TYPE_RST_STREAM unexpected error code: $errorCodeInt",
      )
    handler.rstStream(streamId, errorCode)
  }

  @Throws(IOException::class)
  private fun readSettings(
    handler: Handler,
    length: Int,

                public void onError(final String phase, final String errorCode) {
                    try {
                        sendSseEvent(writer, "error", Map.of("phase", phase, "message", errorCode, "errorCode", errorCode));
                        if (logger.isDebugEnabled()) {
                            logger.debug("SSE error event sent. phase={}, error={}", phase, errorCode);
                        }

import mockwebserver3.MockWebServer
import mockwebserver3.SocketEffect.CloseStream
import okhttp3.CallEvent.ConnectEnd
import okhttp3.CallEvent.ConnectFailed
import okhttp3.CallEvent.ConnectStart
import okhttp3.internal.http2.ErrorCode
import okhttp3.testing.Flaky
import org.junit.jupiter.api.AfterEach
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.Timeout

import mockwebserver3.MockWebServer
import mockwebserver3.SocketEffect.CloseStream
import mockwebserver3.junit5.StartStop
import okhttp3.internal.http.RecordingProxySelector
import okhttp3.internal.http2.ErrorCode
import okhttp3.testing.PlatformRule
import org.junit.jupiter.api.BeforeEach
import org.junit.jupiter.api.RepeatedTest
import org.junit.jupiter.api.Test
import org.junit.jupiter.api.extension.RegisterExtension

@Burst