trafodion-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ansha...@apache.org
Subject [12/15] incubator-trafodion git commit: Update TrxRegionEndpoint.java.tmpl
Date Thu, 15 Sep 2016 22:48:07 GMT
Update TrxRegionEndpoint.java.tmpl

Project: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/commit/de003953
Tree: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/tree/de003953
Diff: http://git-wip-us.apache.org/repos/asf/incubator-trafodion/diff/de003953

Branch: refs/heads/master
Commit: de0039530f7b0755cda83af88bbe9824290a7420
Parents: 8c7a9dc
Author: Sean Broeder <sean.broeder@esgyn.com>
Authored: Tue Sep 13 14:29:10 2016 -0700
Committer: GitHub <noreply@github.com>
Committed: Tue Sep 13 14:29:10 2016 -0700

----------------------------------------------------------------------
 .../transactional/TrxRegionEndpoint.java.tmpl    | 19 ++++++-------------
 1 file changed, 6 insertions(+), 13 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/de003953/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
----------------------------------------------------------------------
diff --git a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
index 0bf28d2..4419ba5 100644
--- a/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
+++ b/core/sqf/src/seatrans/hbase-trx/src/main/java/org/apache/hadoop/hbase/coprocessor/transactional/TrxRegionEndpoint.java.tmpl
@@ -5933,9 +5933,7 @@ CoprocessorService, Coprocessor {
   public boolean commitIfPossible(final long transactionId, final long startEpoch, final
long commitId, final int participantNum,
                                   final boolean regionTx, final boolean autoCommit) throws
IOException {
 
-//    if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- ENTRY txId: "
-//               + transactionId);
-    LOG.info("TrxRegionEndpoint coprocessor: commitIfPossible -- ENTRY txId: "
+    if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- ENTRY txId: "
                + transactionId);
 
     checkBlockNonPhase2(transactionId);
@@ -5944,8 +5942,7 @@ CoprocessorService, Coprocessor {
     
     if (! autoCommit) {
        boolean result = ( status == COMMIT_OK || status == COMMIT_OK_READ_ONLY) ? true :
false;
-//       if (LOG.isTraceEnabled()) LOG.trace("commitIfPossible -- autoCommit is false, returning
early with result " + result);
-       LOG.info("commitIfPossible -- autoCommit is false, returning early with result " +
result);
+       if (LOG.isTraceEnabled()) LOG.trace("commitIfPossible -- autoCommit is false, returning
early with result " + result);
        return result;
     }
   
@@ -5954,23 +5951,19 @@ CoprocessorService, Coprocessor {
        // Process local memory
        try {
          commit(transactionId, participantNum);
-//         if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " + transactionId + " COMMIT_OK");
-         LOG.info("TrxRegionEndpoint coprocessor: commitIfPossible -- EXIT txId: " + transactionId
+ " COMMIT_OK");
+         if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " + transactionId + " COMMIT_OK");
          return true;
        } catch (Throwable e) {
-//        if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
- txId " + transactionId + ", Caught exception after internal commit call "
-        LOG.info("TrxRegionEndpoint coprocessor: commitIfPossible - txId " + transactionId
+ ", Caught exception after internal commit call "
+        if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
- txId " + transactionId + ", Caught exception after internal commit call "
                     + e.getMessage() + " " + stackTraceToString(e));
         throw new IOException(e.toString());
        }
     } else if (status == COMMIT_OK_READ_ONLY) {
-//            if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " 
-            LOG.info("TrxRegionEndpoint coprocessor: commitIfPossible -- EXIT txId: " 
+            if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " 
             + transactionId + " COMMIT_OK_READ_ONLY");
             return true;
     }
-//    if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " 
-    LOG.info("TrxRegionEndpoint coprocessor: commitIfPossible -- EXIT txId: " 
+    if (LOG.isTraceEnabled()) LOG.trace("TrxRegionEndpoint coprocessor: commitIfPossible
-- EXIT txId: " 
               + transactionId + " Commit Unsuccessful");
     return false;
   }


Mime
View raw message