Package org.xtreemfs.babudb.api.dev.transaction

Examples of org.xtreemfs.babudb.api.dev.transaction.OperationInternal


                        // get the processing logic for the dedicated logEntry
                        // type
                        InMemoryProcessing processingLogic = txnMan.getProcessingLogic().get(type);
                       
                        // deserialize the arguments retrieved from the logEntry
                        OperationInternal operation = processingLogic.convertToOperation(processingLogic
                                .deserializeRequest(le.getPayload()));
                       
                        // execute the in-memory logic
                        try {
                            processingLogic.process(operation);
View Full Code Here


        List<Object> operationResults = new ArrayList<Object>();
               
        // in memory processing
        for (int i = 0; i < txn.size(); i++) {
            try {
                OperationInternal operation = txn.get(i);
                txn.lockResponsibleWorker(operation.getDatabaseName());
                operationResults.add(
                        inMemoryProcessing.get(operation.getType()).process(operation));
               
            } catch (BabuDBException be) {
               
                // have there already been some successful executions?
                if (i > 0) {
View Full Code Here

TOP

Related Classes of org.xtreemfs.babudb.api.dev.transaction.OperationInternal

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.