Examples of addModification()

Examples of org.infinispan.transaction.xa.TransactionXaAdapter.addModification()

175
176
177
178
179
180
181
182
183
184
185
      }
      Object rv;
      rv = invokeNextAndRollbackTxOnFailure(ctx, command);
      if (!ctx.isInTxScope())
         transactionLog.logNoTxWrite(command);
      if (command.isSuccessful() && shouldAddMod) xaAdapter.addModification(command);
      return rv;
   }

   public TransactionXaAdapter enlist(InvocationContext ctx) throws SystemException, RollbackException {
      Transaction transaction = tm.getTransaction();
View Full Code Here

Examples of org.jboss.cache.TransactionEntry.addModification()

323
324
325
326
327
328
329
330
331
332
333
      {
         if (log.isTraceEnabled())
            log.trace("Data gravitation performed under global transaction " + gtx + ".  Not broadcasting cleanups until the tx commits.  Adding to tx mod list instead.");
         transactionMods.put(gtx, cleanup);
         TransactionEntry te = getTransactionEntry(gtx);
         te.addModification(cleanup);
      }
   }

   private Object[] gravitateData(Fqn fqn) throws Exception
   {
View Full Code Here

Examples of org.jboss.cache.transaction.TransactionContext.addModification()

242
243
244
245
246
247
248
249
250
251
252
         childNode.markAsDeleted(false);
         //if we'll rollback the tx data should be added to the node again
         Map oldData = new HashMap(childNode.getDataDirect());
         PutDataMapCommand command = commandsFactory.buildPutDataMapCommand(ctx.getGlobalTransaction(), fqn, oldData);
         // txTable.get(gtx).addUndoOperation(command); --- now need to make sure this is added to the normal mods list instead
         transactionContext.addModification(command);
         //we're prepared for rollback, now reset the node
         childNode.clearDataDirect();
         if (createdNodes != null)
         {
            createdNodes.add(childNode);
View Full Code Here

Examples of org.jboss.cache.transaction.TransactionEntry.addModification()

318
319
320
321
322
323
324
325
326
327
328
         {
            log.trace("Data gravitation performed under global transaction " + gtx + ".  Not broadcasting cleanups until the tx commits.  Adding to tx mod list instead.");
         }
         transactionMods.put(gtx, cleanup);
         TransactionEntry te = getTransactionEntry(gtx);
         te.addModification(cleanup);
      }
   }

   private GravitateResult gravitateData(Fqn fqn) throws Exception
   {
View Full Code Here

Examples of org.nasutekds.server.core.ModifyDNOperationBasis.addModification()

2569
2570
2571
2572
2573
2574
2575
2576
2577
2578
2579
       AttributeType attrType =
         DirectoryServer.getAttributeType(DS_SYNC_CONFLICT, true);
       Attribute attr = Attributes.create(attrType, AttributeValues.create(
           attrType, targetDN.toNormalizedString()));
       Modification mod = new Modification(ModificationType.REPLACE, attr);
       newOp.addModification(mod);
     }
     else
     {
       AttributeType attrType =
         DirectoryServer.getAttributeType(DS_SYNC_CONFLICT, true);
View Full Code Here

Examples of org.nasutekds.server.workflowelement.localbackend.LocalBackendModifyDNOperation.addModification()

470
471
472
473
474
475
476
477
478
479
480
    op.setAttachment(SYNCHROCONTEXT,
        new ModifyDnContext(cn, "uniqueid", "newparentId"));
    LocalBackendModifyDNOperation localOp =
      new LocalBackendModifyDNOperation(op);
    for (Modification mod : mods)
      localOp.addModification(mod);
    ModifyDNMsg msg = new ModifyDNMsg(localOp);

    msg.setAssured(isAssured);
    msg.setAssuredMode(assuredMode);
    msg.setSafeDataLevel(safeDataLevel);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.