Change DtmAdjustOldestXid

knizhnik · knizhnik · commit 14d6ed8cef7e · 2015-11-06T18:27:15.000+03:00
diff --git a/contrib/pg_tsdtm/pg_dtm.c b/contrib/pg_tsdtm/pg_dtm.c
@@ -393,6 +393,10 @@ static TransactionId DtmAdjustOldestXid(TransactionId xid)
         DtmTransStatus *ts, *prev = NULL;
         timestamp_t cutoff_time = dtm_get_current_time() - DtmVacuumDelay*USEC;
         SpinLockAcquire(&local->lock);
+        ts = (DtmTransStatus*)hash_search(xid2status, &xid, HASH_FIND, NULL);
+        if (ts != NULL) { 
+            cutoff_time = ts->cid - DtmVacuumDelay*USEC;
+        }                
         for (ts = local->trans_list_head; ts != NULL && ts->cid < cutoff_time; prev = ts, ts = ts->next) { 
             if (prev != NULL) { 
                 hash_search(xid2status, &prev->xid, HASH_REMOVE, NULL);
diff --git a/contrib/pg_tsdtm/tests/transfers.go b/contrib/pg_tsdtm/tests/transfers.go
@@ -10,9 +10,9 @@ import (
 )
 
 const (
-    TRANSFER_CONNECTIONS = 100
+    TRANSFER_CONNECTIONS = 10
     INIT_AMOUNT = 10000
-    N_ITERATIONS = 1000
+    N_ITERATIONS = 10000
     N_ACCOUNTS = 100000
 )
 
