ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [49/50] [abbrv] incubator-ignite git commit: Merge branches 'ignite-181' and 'sprint-1' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-181
Date Mon, 09 Feb 2015 08:55:54 GMT
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f5901bc1/modules/core/src/main/java/org/apache/ignite/configuration/TransactionConfiguration.java
----------------------------------------------------------------------
diff --cc modules/core/src/main/java/org/apache/ignite/configuration/TransactionConfiguration.java
index 0000000,ee01f3c..13ac061
mode 000000,100644..100644
--- a/modules/core/src/main/java/org/apache/ignite/configuration/TransactionConfiguration.java
+++ b/modules/core/src/main/java/org/apache/ignite/configuration/TransactionConfiguration.java
@@@ -1,0 -1,202 +1,205 @@@
+ /*
+  * Licensed to the Apache Software Foundation (ASF) under one or more
+  * contributor license agreements.  See the NOTICE file distributed with
+  * this work for additional information regarding copyright ownership.
+  * The ASF licenses this file to You under the Apache License, Version 2.0
+  * (the "License"); you may not use this file except in compliance with
+  * the License.  You may obtain a copy of the License at
+  *
+  *      http://www.apache.org/licenses/LICENSE-2.0
+  *
+  * Unless required by applicable law or agreed to in writing, software
+  * distributed under the License is distributed on an "AS IS" BASIS,
+  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+  * See the License for the specific language governing permissions and
+  * limitations under the License.
+  */
+ 
+ package org.apache.ignite.configuration;
+ 
+ import org.apache.ignite.transactions.*;
+ 
+ import java.io.*;
+ 
+ /**
+  * Transactions configuration.
+  */
+ public class TransactionConfiguration implements Serializable {
++    /** */
++    private static final long serialVersionUID = 0L;
++
+     /** Default value for 'txSerializableEnabled' flag. */
+     public static final boolean DFLT_TX_SERIALIZABLE_ENABLED = false;
+ 
+     /** Default concurrency mode. */
+     public static final IgniteTxConcurrency DFLT_TX_CONCURRENCY = IgniteTxConcurrency.PESSIMISTIC;
+ 
+     /** Default transaction isolation level. */
+     public static final IgniteTxIsolation DFLT_TX_ISOLATION = IgniteTxIsolation.REPEATABLE_READ;
+ 
+     /** Default transaction timeout. */
+     public static final long DFLT_TRANSACTION_TIMEOUT = 0;
+ 
+     /** Default size of pessimistic transactions log. */
+     public static final int DFLT_PESSIMISTIC_TX_LOG_LINGER = 10_000;
+ 
+     /** Default transaction serializable flag. */
+     private boolean txSerEnabled = DFLT_TX_SERIALIZABLE_ENABLED;
+ 
+     /** Transaction isolation. */
+     private IgniteTxIsolation dfltIsolation = DFLT_TX_ISOLATION;
+ 
+     /** Cache concurrency. */
+     private IgniteTxConcurrency dfltConcurrency = DFLT_TX_CONCURRENCY;
+ 
+     /** Default transaction timeout. */
+     private long dfltTxTimeout = DFLT_TRANSACTION_TIMEOUT;
+ 
+     /** Pessimistic tx log size. */
+     private int pessimisticTxLogSize;
+ 
+     /** Pessimistic tx log linger. */
+     private int pessimisticTxLogLinger = DFLT_PESSIMISTIC_TX_LOG_LINGER;
+ 
+     /**
+      * Empty constructor.
+      */
+     public TransactionConfiguration() {
+         // No-op.
+     }
+ 
+     /**
+      * @param cfg Configuration to copy.
+      */
+     public TransactionConfiguration(TransactionConfiguration cfg) {
+         dfltConcurrency = cfg.getDefaultTxConcurrency();
+         dfltIsolation = cfg.getDefaultTxIsolation();
+         dfltTxTimeout = cfg.getDefaultTxTimeout();
+         pessimisticTxLogLinger = cfg.getPessimisticTxLogLinger();
+         pessimisticTxLogSize = cfg.getPessimisticTxLogSize();
+         txSerEnabled = cfg.isTxSerializableEnabled();
+     }
+ 
+     /**
+      * Gets flag to enable/disable {@link IgniteTxIsolation#SERIALIZABLE} isolation
+      * level for cache transactions. Serializable level does carry certain overhead and
+      * if not used, should be disabled. Default value is {@code false}.
+      *
+      * @return {@code True} if serializable transactions are enabled, {@code false} otherwise.
+      */
+     public boolean isTxSerializableEnabled() {
+         return txSerEnabled;
+     }
+ 
+     /**
+      * Enables/disables serializable cache transactions. See {@link #isTxSerializableEnabled()}
for more information.
+      *
+      * @param txSerEnabled Flag to enable/disable serializable cache transactions.
+      */
+     public void setTxSerializableEnabled(boolean txSerEnabled) {
+         this.txSerEnabled = txSerEnabled;
+     }
+ 
+     /**
+      * Default cache transaction concurrency to use when one is not explicitly
+      * specified. Default value is defined by {@link #DFLT_TX_CONCURRENCY}.
+      *
+      * @return Default cache transaction concurrency.
+      * @see IgniteTx
+      */
+     public IgniteTxConcurrency getDefaultTxConcurrency() {
+         return dfltConcurrency;
+     }
+ 
+     /**
+      * Sets default transaction concurrency.
+      *
+      * @param dfltConcurrency Default cache transaction concurrency.
+      */
+     public void setDefaultTxConcurrency(IgniteTxConcurrency dfltConcurrency) {
+         this.dfltConcurrency = dfltConcurrency;
+     }
+ 
+     /**
+      * Default cache transaction isolation to use when one is not explicitly
+      * specified. Default value is defined by {@link #DFLT_TX_ISOLATION}.
+      *
+      * @return Default cache transaction isolation.
+      * @see IgniteTx
+      */
+     public IgniteTxIsolation getDefaultTxIsolation() {
+         return dfltIsolation;
+     }
+ 
+     /**
+      * Sets default transaction isolation.
+      *
+      * @param dfltIsolation Default cache transaction isolation.
+      */
+     public void setDefaultTxIsolation(IgniteTxIsolation dfltIsolation) {
+         this.dfltIsolation = dfltIsolation;
+     }
+ 
+     /**
+      * Gets default transaction timeout. Default value is defined by {@link #DFLT_TRANSACTION_TIMEOUT}
+      * which is {@code 0} and means that transactions will never time out.
+      *
+      * @return Default transaction timeout.
+      */
+     public long getDefaultTxTimeout() {
+         return dfltTxTimeout;
+     }
+ 
+     /**
+      * Sets default transaction timeout in milliseconds. By default this value is defined
by {@link
+      * #DFLT_TRANSACTION_TIMEOUT}.
+      *
+      * @param dfltTxTimeout Default transaction timeout.
+      */
+     public void setDefaultTxTimeout(long dfltTxTimeout) {
+         this.dfltTxTimeout = dfltTxTimeout;
+     }
+ 
+     /**
+      * Gets size of pessimistic transactions log stored on node in order to recover transaction
commit if originating
+      * node has left grid before it has sent all messages to transaction nodes.
+      * <p>
+      * If not set, default value is {@code 0} which means unlimited log size.
+      *
+      * @return Pessimistic transaction log size.
+      */
+     public int getPessimisticTxLogSize() {
+         return pessimisticTxLogSize;
+     }
+ 
+     /**
+      * Sets pessimistic transactions log size.
+      *
+      * @param pessimisticTxLogSize Pessimistic transactions log size.
+      * @see #getPessimisticTxLogSize()
+      */
+     public void setPessimisticTxLogSize(int pessimisticTxLogSize) {
+         this.pessimisticTxLogSize = pessimisticTxLogSize;
+     }
+ 
+     /**
+      * Gets delay, in milliseconds, after which pessimistic recovery entries will be cleaned
up for failed node.
+      * <p>
+      * If not set, default value is {@link #DFLT_PESSIMISTIC_TX_LOG_LINGER}.
+      *
+      * @return Pessimistic log cleanup delay in milliseconds.
+      */
+     public int getPessimisticTxLogLinger() {
+         return pessimisticTxLogLinger;
+     }
+ 
+     /**
+      * Sets cleanup delay for pessimistic transaction recovery log for failed node, in milliseconds.
+      *
+      * @param pessimisticTxLogLinger Pessimistic log cleanup delay.
+      * @see #getPessimisticTxLogLinger()
+      */
+     public void setPessimisticTxLogLinger(int pessimisticTxLogLinger) {
+         this.pessimisticTxLogLinger = pessimisticTxLogLinger;
+     }
+ }

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f5901bc1/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/GridCacheAdapter.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f5901bc1/modules/core/src/main/java/org/apache/ignite/internal/processors/closure/GridClosureProcessor.java
----------------------------------------------------------------------

http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/f5901bc1/pom.xml
----------------------------------------------------------------------


Mime
View raw message