4052 Pekka Nousiainen 2012-10-27 [merge]
merge to 7.2
modified:
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
4051 Pekka Nousiainen 2012-10-24 [merge]
merge to 7.2
modified:
storage/ndb/src/kernel/blocks/ERROR_codes.txt
storage/ndb/src/kernel/blocks/dbtc/Dbtc.hpp
storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
storage/ndb/src/ndbapi/ndberror.c
storage/ndb/test/ndbapi/testBasic.cpp
storage/ndb/test/run-test/daily-basic-tests.txt
=== modified file 'storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp'
--- a/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp 2012-10-24 11:26:37 +0000
+++ b/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp 2012-10-27 11:47:45 +0000
@@ -4255,7 +4255,11 @@ Dbtc::CommitAckMarker::insert_in_commit_
Uint32 instanceKey,
NodeId node_id)
{
- Uint32 item = instanceKey + (node_id << 16);
+ const NodeInfo& nodeInfo = tc->getNodeInfo(node_id);
+ Uint32 workers = nodeInfo.m_lqh_workers;
+ assert(instanceKey != 0);
+ Uint32 instanceNo = workers == 0 ? 0 : 1 + (instanceKey - 1) % workers;
+ Uint32 item = instanceNo + (node_id << 16);
CommitAckMarkerBuffer::DataBufferPool & pool =
tc->c_theCommitAckMarkerBufferPool;
// check for duplicate (todo DataBuffer method find-or-append)
No bundle (reason: useless for push emails).
| Thread |
|---|
| • bzr push into mysql-5.5-cluster-7.2 branch (pekka.nousiainen:4051 to 4052) | Pekka Nousiainen | 27 Oct |