tephra-hbase-compat-2.0-base/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [455:470]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void ensureValidTxLifetime(RegionCoprocessorEnvironment env,
      @SuppressWarnings("unused") OperationWithAttributes op, @Nullable Transaction tx)
      throws IOException {
    if (tx == null) {
      return;
    }

    boolean validLifetime =
        (TxUtils.getTimestamp(tx.getTransactionId()) + txMaxLifetimeMillis) > System
            .currentTimeMillis();
    if (!validLifetime) {
      throw new DoNotRetryIOException(
          String.format("Transaction %s has exceeded max lifetime %s ms", tx.getTransactionId(),
            txMaxLifetimeMillis));
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.3/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [455:470]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void ensureValidTxLifetime(RegionCoprocessorEnvironment env,
      @SuppressWarnings("unused") OperationWithAttributes op, @Nullable Transaction tx)
      throws IOException {
    if (tx == null) {
      return;
    }

    boolean validLifetime =
        (TxUtils.getTimestamp(tx.getTransactionId()) + txMaxLifetimeMillis) > System
            .currentTimeMillis();
    if (!validLifetime) {
      throw new DoNotRetryIOException(
          String.format("Transaction %s has exceeded max lifetime %s ms", tx.getTransactionId(),
            txMaxLifetimeMillis));
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



tephra-hbase-compat-2.4/src/main/java/org/apache/tephra/hbase/coprocessor/TransactionProcessor.java [455:470]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
  protected void ensureValidTxLifetime(RegionCoprocessorEnvironment env,
      @SuppressWarnings("unused") OperationWithAttributes op, @Nullable Transaction tx)
      throws IOException {
    if (tx == null) {
      return;
    }

    boolean validLifetime =
        (TxUtils.getTimestamp(tx.getTransactionId()) + txMaxLifetimeMillis) > System
            .currentTimeMillis();
    if (!validLifetime) {
      throw new DoNotRetryIOException(
          String.format("Transaction %s has exceeded max lifetime %s ms", tx.getTransactionId(),
            txMaxLifetimeMillis));
    }
  }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -