Package net.jini.core.transaction.server

Examples of net.jini.core.transaction.server.ServerTransaction


     * This method is not synchronized.
     * @param txn the <code>Txn</code> being recovered.
     */
    void recover(Txn txn) {
  // Try to get the transaction
  ServerTransaction st = null;
  try {
      st = txn.getTransaction(proxyPreparer);
  } catch (Throwable t) {
      // log, but otherwise ignore
      if (logger.isLoggable(Levels.FAILED))
View Full Code Here


            transactionsLogger.log(Level.FINEST,
          "Created new TxnManagerTransaction ID is: {0}", new Long(tid));
  }

  Transaction tr = txntr.getTransaction();
  ServerTransaction str = null;

        try {
      str = serverTransaction(tr);
      txns.put(new Long(str.id), txntr);
View Full Code Here

  if (txntr == null)
      throw new UnknownTransactionException("unknown transaction");

        Transaction tn = (Transaction) txntr.getTransaction();
        ServerTransaction tr = serverTransaction(tn);

        if (tr == null)
           throw new UnknownTransactionException(
               "TxnManagerImpl: getTransaction: "
                                             + "unable to find transaction(" +
View Full Code Here

  typeCheck(rep);
  rep.pickID();

  if (opsLogger.isLoggable(Level.FINER) && (tr != null)) {
      ServerTransaction str = serverTransaction(tr);
      opsLogger.log(Level.FINER, "OutriggerServerImpl: write under " +
                "transaction [mgr:{0} id:{1}]",
    new Object[]{str.mgr, new Long(str.id)});
  }
View Full Code Here

      typeCheck(entries[i]);
      entries[i].pickID();
  }

  if (opsLogger.isLoggable(Level.FINER) && (tr != null)) {
      ServerTransaction str = serverTransaction(tr);
      opsLogger.log(Level.FINER, "OutriggerServerImpl: write<multiple> " +
        "under transaction [mgr:{0} id:{1}]",
    new Object[]{str.mgr, new Long(str.id)});
  }
View Full Code Here

  final long currentOrdinal = operationJournal.currentOrdinal();

  // Register a watcher for this client
  tmpl = setupTmpl(tmpl);

        ServerTransaction str = serverTransaction(tr);
  Txn txn = enterTxn(tr);

  final Uuid cookie = UuidFactory.generate();
  final long eventID = nextID();
  final long now = System.currentTimeMillis();
View Full Code Here

  listener =
      (RemoteEventListener)listenerPreparer.prepareProxy(listener);
  final long currentOrdinal = operationJournal.currentOrdinal();

        ServerTransaction str = serverTransaction(tr);
  Txn txn = enterTxn(tr);

  for (int i=0; i<tmpls.length; i++) {
      typeCheck(tmpls[i]);
  }
View Full Code Here

  }

  checkLimit(limit);
  checkTimeout(timeout);

  ServerTransaction str = serverTransaction(tr);
  Txn txn = enterTxn(tr);

  /* Don't bother if transaction is not active,
   * synchronize so we get the most recent answer,
   * not because we need to make anything atomic.
View Full Code Here

  if (leaseTime < 1 && leaseTime != Lease.ANY) {
      throw logAndThrowIllegalArg(
     "leaseTime = " + leaseTime + ", must be postive or Lease.ANY");
  }

  ServerTransaction str = serverTransaction(tr);
  Txn txn = enterTxn(tr);

  /* Don't bother if transaction is not active,
   * synchronize so we get the most recent answer,
   * not because we need to make anything atomic.
View Full Code Here

  throws TransactionException, RemoteException
    {
  iteratorLogger.entering("OutriggerServerImpl", "contents");

  typeCheck(tmpl);
  ServerTransaction str = serverTransaction(tr);

  Txn txn = enterTxn(tr);

  /* Don't bother if transaction is not active,
   * synchronize so we get the most recent answer,
View Full Code Here

TOP

Related Classes of net.jini.core.transaction.server.ServerTransaction

Copyright © 2018 www.massapicom. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.