diff options
author | unknown <jonas@perch.ndb.mysql.com> | 2006-06-05 15:32:18 +0200 |
---|---|---|
committer | unknown <jonas@perch.ndb.mysql.com> | 2006-06-05 15:32:18 +0200 |
commit | 674e6e95660b108922eec7101938101ecf9720cb (patch) | |
tree | cdd820b99b7a56013858d2c98c98e4f5a7665d28 /storage/ndb/src/kernel/blocks/dbacc | |
parent | 3f950c925e327a10e79be3cebc8d57d40018bda9 (diff) | |
download | mariadb-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.cpp | 40 |
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 */ |