summaryrefslogtreecommitdiff
path: root/storage/ndb/src/kernel/blocks/dbacc
diff options
context:
space:
mode:
authorunknown <jonas@perch.ndb.mysql.com>2006-06-05 15:32:18 +0200
committerunknown <jonas@perch.ndb.mysql.com>2006-06-05 15:32:18 +0200
commit674e6e95660b108922eec7101938101ecf9720cb (patch)
treecdd820b99b7a56013858d2c98c98e4f5a7665d28 /storage/ndb/src/kernel/blocks/dbacc
parent3f950c925e327a10e79be3cebc8d57d40018bda9 (diff)
downloadmariadb-git-674e6e95660b108922eec7101938101ecf9720cb.tar.gz
ndb - dbacc -
fix gcc4 compile error storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp: add block to remove gcc compiler error storage/ndb/src/kernel/blocks/dblqh/DblqhMain.cpp: add jamEntry
Diffstat (limited to 'storage/ndb/src/kernel/blocks/dbacc')
-rw-r--r--storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp40
1 files changed, 21 insertions, 19 deletions
diff --git a/storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp b/storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp
index ffb3d673713..dc8b123f10f 100644
--- a/storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp
+++ b/storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp
@@ -1262,27 +1262,29 @@ Dbacc::startNext(Signal* signal, OperationrecPtr lastOp)
ptrCheckGuard(nextOp, coprecsize, operationrec);
nextbits = nextOp.p->m_op_bits;
- bool same = nextOp.p->is_same_trans(lastOp.p);
-
- if (!same && ((opbits & Operationrec::OP_ACC_LOCK_MODE) ||
- (nextbits & Operationrec::OP_LOCK_MODE)))
{
- jam();
+ const bool same = nextOp.p->is_same_trans(lastOp.p);
+
+ if (!same && ((opbits & Operationrec::OP_ACC_LOCK_MODE) ||
+ (nextbits & Operationrec::OP_LOCK_MODE)))
+ {
+ jam();
+ /**
+ * Not same transaction
+ * and either last had exclusive lock
+ * or next had exclusive lock
+ */
+ return;
+ }
+
/**
- * Not same transaction
- * and either last had exclusive lock
- * or next had exclusive lock
+ * same trans and X-lock
*/
- return;
- }
-
- /**
- * same trans and X-lock
- */
- if (same && (opbits & Operationrec::OP_ACC_LOCK_MODE))
- {
- jam();
- goto upgrade;
+ if (same && (opbits & Operationrec::OP_ACC_LOCK_MODE))
+ {
+ jam();
+ goto upgrade;
+ }
}
/**
@@ -1294,7 +1296,7 @@ Dbacc::startNext(Signal* signal, OperationrecPtr lastOp)
jam();
goto upgrade;
}
-
+
/**
* There is a shared parallell queue & and exclusive op is first in queue
*/