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,

        }

        final String errorCode = UUID.randomUUID().toString();
        if (logger.isDebugEnabled()) {
            logger.debug("[{}] {}", errorCode, stacktraceString.get().replace("\n", "\\n"));
        } else {
            logger.warn("[{}] {}", errorCode, cause.getMessage());
        }
        return "error_code:" + errorCode;
    }

                throw new IOException("Invalid payload size: " + size);
            }
            final int errorCode = Encdec.dec_uint32le(BUF, 9) & 0xFFFFFFFF;
            if (resp.command == ServerMessageBlock.SMB_COM_READ_ANDX && (errorCode == 0 || errorCode == 0x80000005)) { // overflow indicator normal for pipe
                final SmbComReadAndXResponse r = (SmbComReadAndXResponse) resp;

        // Arrange
        String server = "testServer";
        int access = 123;
        int errorCode = 12345;

        doAnswer(invocation -> {
            MsrpcLsarOpenPolicy2 rpc = invocation.getArgument(0);
            rpc.retval = errorCode; // Simulate RPC error
            return null;
        }).when(mockDcerpcHandle).sendrecv(any(MsrpcLsarOpenPolicy2.class));

    }

    /**
     * @return the errorCode
     */
    @Override
    public final int getErrorCode() {
        return this.errorCode;
    }

    /**
     * Sets the error code for this message block
     * @param errorCode
     *            the errorCode to set
     */
    public final void setErrorCode(final int errorCode) {
        this.errorCode = errorCode;
    }

    /**

  override fun trackFailure(
    call: RealCall,
    e: IOException?,
  ) {
    var noNewExchangesEvent = false
    withLock {
      if (e is StreamResetException) {
        when {
          e.errorCode == ErrorCode.REFUSED_STREAM -> {
            // Stop using this connection on the 2nd REFUSED_STREAM error.
            refusedStreamCount++
            if (refusedStreamCount > 1) {

    // Test error code generation
    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
    public void test_exceptionTypes() {

        // Setter methods for testing
        public void setGrantedCredits(int grantedCredits) {
            this.grantedCredits = grantedCredits;
        }

        public void setErrorCode(int errorCode) {
            this.errorCode = errorCode;
        }

        public void setVerifyFailed(boolean verifyFailed) {
            this.verifyFailed = verifyFailed;
        }
    }

    @BeforeEach
    void setUp() {

            return false;
        }

        @Override
        public boolean isError() {
            return errorCode != 0;
        }

        @Override
        public void error() {
            this.errorCode = -1;
        }

        @Override
        public Long getExpiration() {
            return expiration;
        }

        @Override
        public void setExpiration(Long exp) {

    }

    @Test
    void testToString() {
        smb.command = ServerMessageBlock.SMB_COM_ECHO;
        smb.errorCode = 0;
        smb.mid = 1;
        String str = smb.toString();
        assertTrue(str.contains("command=SMB_COM_ECHO"));
        assertTrue(str.contains("errorCode=0"));
        assertTrue(str.contains("mid=1"));
    }

    @Test
    void testToStringUnknownCommand() {