gpt4 book ai didi

org.objectweb.howl.log.xa.XALogger.putDone()方法的使用及代码示例

转载 作者:知者 更新时间:2024-03-22 12:29:05 25 4
gpt4 key购买 nike

本文整理了Java中org.objectweb.howl.log.xa.XALogger.putDone()方法的一些代码示例,展示了XALogger.putDone()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。XALogger.putDone()方法的具体详情如下:
包路径:org.objectweb.howl.log.xa.XALogger
类名称:XALogger
方法名:putDone

XALogger.putDone介绍

[英]Write a DONE record to the log.

Remove XACommittingTx object from the list of active transactions.
[中]将完成的记录写入日志。
从活动事务列表中删除XACommittingTx对象。

代码示例

代码示例来源:origin: org.ow2.jotm/jotm-core

/**
 * write the Done record to the Howl Log
 * @param xaDnRec the Done Record
 * @param xaCmTx the XACommittingTx
 * @throws LogException could not log the record
 * @throws IOException
 * @throws InterruptedException
 */
public void howlDoneLog(byte [][] xaDnRec, XACommittingTx xaCmTx) throws LogException, IOException, InterruptedException {
  if (TraceTm.recovery.isDebugEnabled()) {
    TraceTm.recovery.debug("Done howl log");
  }
  xaLog.putDone(xaDnRec, xaCmTx);
}

代码示例来源:origin: org.kuali.jotm/jotm-core

/**
 * write the Done record to the Howl Log
 * @param xaDnRec the Done Record
 * @param xaCmTx the XACommittingTx
 * @throws LogException could not log the record
 * @throws IOException
 * @throws InterruptedException
 */
public void howlDoneLog(byte [][] xaDnRec, XACommittingTx xaCmTx) throws LogException, IOException, InterruptedException {
  if (TraceTm.recovery.isDebugEnabled()) {
    TraceTm.recovery.debug("Done howl log");
  }
  xaLog.putDone(xaDnRec, xaCmTx);
}

代码示例来源:origin: org.apache.geronimo/com.springsource.org.apache.geronimo.transaction

public void commit(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{COMMIT};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: apache/felix

public void commit(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{COMMIT};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

public void rollback(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{ROLLBACK};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: org.apache.geronimo.components/geronimo-transaction

public void rollback(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{ROLLBACK};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: apache/felix

public void rollback(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{ROLLBACK};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: org.apache.geronimo.components/geronimo-transaction

public void commit(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{COMMIT};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: org.apache.servicemix.transaction/org.apache.servicemix.transaction

public void commit(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{COMMIT};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

代码示例来源:origin: org.apache.geronimo/com.springsource.org.apache.geronimo.transaction

public void rollback(Xid xid, Object logMark) throws LogException {
    //the data is theoretically unnecessary but is included to help with debugging and because HOWL currently requires it.
    byte[][] data = new byte[4][];
    data[0] = new byte[]{ROLLBACK};
    data[1] = intToBytes(xid.getFormatId());
    data[2] = xid.getGlobalTransactionId();
    data[3] = xid.getBranchQualifier();
    try {
      logger.putDone(data, (XACommittingTx) logMark);
//            logger.putDone(null, (XACommittingTx) logMark);
    } catch (LogClosedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogRecordSizeException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (LogFileOverflowException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (InterruptedException e) {
      throw (IllegalStateException) new IllegalStateException().initCause(e);
    } catch (IOException e) {
      throw new LogException(e);
    }
  }

25 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com