trafodion-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From se...@apache.org
Subject [11/12] incubator-trafodion git commit: Fix for TLOG looping in deleteEntriesOlderThanASN JIRA [TRAFODION-2253]
Date Fri, 30 Sep 2016 21:05:58 GMT
Fix for TLOG looping in deleteEntriesOlderThanASN
JIRA [TRAFODION-2253]


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

Branch: refs/heads/master
Commit: cc1f8f30726bb72725bc65f37338f1fc8ba5685e
Parents: 5a720fc
Author: Sean Broeder <sbroeder@edev06.esgyn.local>
Authored: Fri Sep 30 01:50:11 2016 +0000
Committer: Sean Broeder <sbroeder@edev06.esgyn.local>
Committed: Fri Sep 30 01:50:11 2016 +0000

----------------------------------------------------------------------
 .../src/main/java/org/trafodion/dtm/TmAuditTlog.java          | 7 +++----
 1 file changed, 3 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-trafodion/blob/cc1f8f30/core/sqf/src/seatrans/tm/hbasetmlib2/src/main/java/org/trafodion/dtm/TmAuditTlog.java
----------------------------------------------------------------------
diff --git a/core/sqf/src/seatrans/tm/hbasetmlib2/src/main/java/org/trafodion/dtm/TmAuditTlog.java
b/core/sqf/src/seatrans/tm/hbasetmlib2/src/main/java/org/trafodion/dtm/TmAuditTlog.java
index 3c7a2c0..ede3b8c 100644
--- a/core/sqf/src/seatrans/tm/hbasetmlib2/src/main/java/org/trafodion/dtm/TmAuditTlog.java
+++ b/core/sqf/src/seatrans/tm/hbasetmlib2/src/main/java/org/trafodion/dtm/TmAuditTlog.java
@@ -171,7 +171,6 @@ public class TmAuditTlog {
    public static final int TLOG_SLEEP = 1000;      // One second
    public static final int TLOG_SLEEP_INCR = 5000; // Five seconds
    public static final int TLOG_RETRY_ATTEMPTS = 5;
-   private int RETRY_ATTEMPTS;
 
    /**
     * tlogThreadPool - pool of thread for asynchronous requests
@@ -268,7 +267,7 @@ public class TmAuditTlog {
                if (LOG.isTraceEnabled()) LOG.trace("deleteEntriesOlderThanASNX -- location
being refreshed : "
                     + location.getRegionInfo().getRegionNameAsString() + "endKey: "
                     + Hex.encodeHexString(location.getRegionInfo().getEndKey()) + " for ASN:
" + auditSeqNum);
-               if(retryCount == RETRY_ATTEMPTS) {
+               if(retryCount == TLOG_RETRY_ATTEMPTS) {
                   LOG.error("Exceeded retry attempts (" + retryCount + ") in deleteEntriesOlderThanASNX
for ASN: " + auditSeqNum);
                   // We have received our reply in the form of an exception,
                   // so decrement outstanding count and wake up waiters to avoid
@@ -287,7 +286,7 @@ public class TmAuditTlog {
             }
             retryCount++;
 
-            if (retryCount < RETRY_ATTEMPTS && retry == true) {
+            if (retryCount < TLOG_RETRY_ATTEMPTS && retry == true) {
                try {
                   Thread.sleep(retrySleep);
                } catch(InterruptedException ex) {
@@ -296,7 +295,7 @@ public class TmAuditTlog {
 
                retrySleep += TLOG_SLEEP_INCR;
             }
-       } while (retryCount < RETRY_ATTEMPTS && retry == true);
+       } while (retryCount < TLOG_RETRY_ATTEMPTS && retry == true);
        // We have received our reply so decrement outstanding count
        transactionState.requestPendingCountDec(false);
 


Mime
View raw message