CVS update of sequoia/src/org/continuent/sequoia/controller/scheduler (1 file)

    Date: Monday, October 23, 2006 @ 18:58:31
  Author: stephane
    Path: .../sequoia/sequoia/src/org/continuent/sequoia/controller/scheduler

Modified: AbstractScheduler.java (1.65 -> 1.66)

Fix for SEQUOIA-823 :

Now setting a fake transaction id to autocommit read requests that are 
broadcasted.


------------------------+
 AbstractScheduler.java |    9 +++++++++
 1 files changed, 9 insertions(+)


Index: 
sequoia/src/org/continuent/sequoia/controller/scheduler/AbstractScheduler.java
diff -u 
sequoia/src/org/continuent/sequoia/controller/scheduler/AbstractScheduler.java:1.65
 
sequoia/src/org/continuent/sequoia/controller/scheduler/AbstractScheduler.java:1.66
--- 
sequoia/src/org/continuent/sequoia/controller/scheduler/AbstractScheduler.java:1.65
 Fri Aug 25 00:40:22 2006
+++ 
sequoia/src/org/continuent/sequoia/controller/scheduler/AbstractScheduler.java  
    Mon Oct 23 18:58:31 2006
@@ -416,6 +416,15 @@
       activeReadRequests.put(id, request);
     }
 
+    // Assign a unique transaction id to requests in autocommit mode as well
+    if (request.isAutoCommit()&& request.isMustBroadcast())
+    {
+      long fakeTid = getNextTransactionId();
+      fakeTid = fakeTid & DistributedRequestManager.TRANSACTION_ID_BIT_MASK;
+      fakeTid = fakeTid | controllerId;
+      request.setTransactionId(fakeTid);
+    }
+    
     try
     {
       scheduleNonSuspendedReadRequest(request);