mirror of
https://github.com/MariaDB/server.git
synced 2026-01-06 05:22:24 +03:00
Merge tulin@bk-internal.mysql.com:/home/bk/mysql-5.0-ndb
into poseidon.ndb.mysql.com:/home/tomas/mysql-5.1-clean BitKeeper/etc/logging_ok: auto-union mysql-test/mysql-test-run.sh: Auto merged sql/ha_ndbcluster.cc: Auto merged sql/ha_ndbcluster.h: Auto merged sql/mysqld.cc: Auto merged sql/sql_class.h: Auto merged sql/sql_parse.cc: Auto merged sql/sql_select.cc: Auto merged storage/ndb/include/debugger/SignalLoggerManager.hpp: Auto merged storage/ndb/include/kernel/ndb_limits.h: Auto merged storage/ndb/include/kernel/signaldata/AccScan.hpp: Auto merged storage/ndb/include/kernel/signaldata/NextScan.hpp: Auto merged storage/ndb/include/kernel/signaldata/ScanFrag.hpp: Auto merged storage/ndb/include/kernel/signaldata/ScanTab.hpp: Auto merged storage/ndb/include/kernel/signaldata/TcCommit.hpp: Auto merged storage/ndb/include/ndbapi/NdbIndexScanOperation.hpp: Auto merged storage/ndb/include/ndbapi/NdbScanOperation.hpp: Auto merged storage/ndb/include/ndbapi/NdbTransaction.hpp: Auto merged storage/ndb/src/common/debugger/SignalLoggerManager.cpp: Auto merged storage/ndb/src/common/debugger/signaldata/ScanTab.cpp: Auto merged storage/ndb/src/kernel/blocks/dbacc/DbaccInit.cpp: Auto merged storage/ndb/src/kernel/blocks/dbacc/DbaccMain.cpp: Auto merged storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp: Auto merged storage/ndb/src/kernel/blocks/dbdict/Dbdict.hpp: Auto merged storage/ndb/src/kernel/blocks/dbdict/SchemaFile.hpp: Auto merged storage/ndb/src/kernel/blocks/dbdict/printSchemaFile.cpp: Auto merged storage/ndb/src/kernel/blocks/dblqh/Dblqh.hpp: Auto merged storage/ndb/src/kernel/blocks/dblqh/DblqhMain.cpp: Auto merged storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp: Auto merged storage/ndb/src/kernel/blocks/dbtup/Dbtup.hpp: Auto merged storage/ndb/src/kernel/blocks/dbtup/DbtupGen.cpp: Auto merged storage/ndb/src/kernel/blocks/dbtup/Makefile.am: Auto merged storage/ndb/src/kernel/vm/Makefile.am: Auto merged storage/ndb/src/ndbapi/NdbDictionaryImpl.cpp: Auto merged storage/ndb/src/ndbapi/NdbScanOperation.cpp: Auto merged storage/ndb/src/ndbapi/NdbTransaction.cpp: Auto merged storage/ndb/test/include/HugoTransactions.hpp: Auto merged storage/ndb/test/ndbapi/testDict.cpp: Auto merged storage/ndb/test/ndbapi/testNodeRestart.cpp: Auto merged storage/ndb/test/ndbapi/testOIBasic.cpp: Auto merged storage/ndb/test/ndbapi/testScan.cpp: Auto merged storage/ndb/test/ndbapi/testScanPerf.cpp: Auto merged storage/ndb/test/run-test/daily-devel-tests.txt: Auto merged storage/ndb/test/src/HugoOperations.cpp: Auto merged storage/ndb/test/src/HugoTransactions.cpp: Auto merged
This commit is contained in:
unknown
365
storage/ndb/include/kernel/signaldata/ScanFrag.hpp
Normal file
365
storage/ndb/include/kernel/signaldata/ScanFrag.hpp
Normal file
@@ -0,0 +1,365 @@
|
||||
/* Copyright (C) 2003 MySQL AB
|
||||
|
||||
This program is free software; you can redistribute it and/or modify
|
||||
it under the terms of the GNU General Public License as published by
|
||||
the Free Software Foundation; either version 2 of the License, or
|
||||
(at your option) any later version.
|
||||
|
||||
This program is distributed in the hope that it will be useful,
|
||||
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
||||
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
||||
GNU General Public License for more details.
|
||||
|
||||
You should have received a copy of the GNU General Public License
|
||||
along with this program; if not, write to the Free Software
|
||||
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
||||
|
||||
#ifndef SCAN_FRAG_HPP
|
||||
#define SCAN_FRAG_HPP
|
||||
|
||||
#include "SignalData.hpp"
|
||||
#include "ndb_limits.h"
|
||||
|
||||
class ScanFragReq {
|
||||
/**
|
||||
* Sender(s)
|
||||
*/
|
||||
friend class Dbtc;
|
||||
friend class Backup;
|
||||
friend class Suma;
|
||||
|
||||
/**
|
||||
* Reciver(s)
|
||||
*/
|
||||
friend class Dblqh;
|
||||
public:
|
||||
STATIC_CONST( SignalLength = 12 );
|
||||
|
||||
friend bool printSCAN_FRAGREQ(FILE *, const Uint32*, Uint32, Uint16);
|
||||
|
||||
public:
|
||||
Uint32 senderData;
|
||||
Uint32 resultRef; // Where to send the result
|
||||
Uint32 savePointId;
|
||||
Uint32 requestInfo;
|
||||
Uint32 tableId;
|
||||
Uint32 fragmentNoKeyLen;
|
||||
Uint32 schemaVersion;
|
||||
Uint32 transId1;
|
||||
Uint32 transId2;
|
||||
Uint32 clientOpPtr;
|
||||
Uint32 batch_size_rows;
|
||||
Uint32 batch_size_bytes;
|
||||
|
||||
static Uint32 getLockMode(const Uint32 & requestInfo);
|
||||
static Uint32 getHoldLockFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getKeyinfoFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getReadCommittedFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getRangeScanFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getDescendingFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getTupScanFlag(const Uint32 & requestInfo);
|
||||
static Uint32 getAttrLen(const Uint32 & requestInfo);
|
||||
static Uint32 getScanPrio(const Uint32 & requestInfo);
|
||||
|
||||
static void setLockMode(Uint32 & requestInfo, Uint32 lockMode);
|
||||
static void setHoldLockFlag(Uint32 & requestInfo, Uint32 holdLock);
|
||||
static void setKeyinfoFlag(Uint32 & requestInfo, Uint32 keyinfo);
|
||||
static void setReadCommittedFlag(Uint32 & requestInfo, Uint32 readCommitted);
|
||||
static void setRangeScanFlag(Uint32 & requestInfo, Uint32 rangeScan);
|
||||
static void setDescendingFlag(Uint32 & requestInfo, Uint32 descending);
|
||||
static void setTupScanFlag(Uint32 & requestInfo, Uint32 tupScan);
|
||||
static void setAttrLen(Uint32 & requestInfo, Uint32 attrLen);
|
||||
static void setScanPrio(Uint32& requestInfo, Uint32 prio);
|
||||
};
|
||||
|
||||
class KeyInfo20 {
|
||||
/**
|
||||
* Sender(s)
|
||||
*/
|
||||
friend class Dblqh;
|
||||
|
||||
/**
|
||||
* Reciver(s)
|
||||
*/
|
||||
friend class Backup;
|
||||
friend class NdbOperation;
|
||||
friend class NdbScanReceiver;
|
||||
public:
|
||||
STATIC_CONST( HeaderLength = 5);
|
||||
STATIC_CONST( DataLength = 20 );
|
||||
|
||||
|
||||
static Uint32 setScanInfo(Uint32 noOfOps, Uint32 scanNo);
|
||||
static Uint32 getScanNo(Uint32 scanInfo);
|
||||
static Uint32 getScanOp(Uint32 scanInfo);
|
||||
|
||||
public:
|
||||
Uint32 clientOpPtr;
|
||||
Uint32 keyLen;
|
||||
Uint32 scanInfo_Node;
|
||||
Uint32 transId1;
|
||||
Uint32 transId2;
|
||||
Uint32 keyData[DataLength];
|
||||
};
|
||||
|
||||
class ScanFragConf {
|
||||
/**
|
||||
* Sender(s)
|
||||
*/
|
||||
friend class Dblqh;
|
||||
|
||||
/**
|
||||
* Reciver(s)
|
||||
*/
|
||||
friend class Dbtc;
|
||||
friend class Backup;
|
||||
friend class Suma;
|
||||
public:
|
||||
STATIC_CONST( SignalLength = 6 );
|
||||
|
||||
public:
|
||||
Uint32 senderData;
|
||||
Uint32 completedOps;
|
||||
Uint32 fragmentCompleted;
|
||||
Uint32 transId1;
|
||||
Uint32 transId2;
|
||||
Uint32 total_len;
|
||||
};
|
||||
|
||||
class ScanFragRef {
|
||||
/**
|
||||
* Sender(s)
|
||||
*/
|
||||
friend class Dblqh;
|
||||
|
||||
/**
|
||||
* Reciver(s)
|
||||
*/
|
||||
friend class Dbtc;
|
||||
friend class Backup;
|
||||
friend class Suma;
|
||||
public:
|
||||
STATIC_CONST( SignalLength = 4 );
|
||||
public:
|
||||
enum ErrorCode {
|
||||
ZNO_FREE_TC_CONREC_ERROR = 484,
|
||||
ZTOO_FEW_CONCURRENT_OPERATIONS = 485,
|
||||
ZTOO_MANY_CONCURRENT_OPERATIONS = 486,
|
||||
ZSCAN_NO_FRAGMENT_ERROR = 487,
|
||||
ZTOO_MANY_ACTIVE_SCAN_ERROR = 488,
|
||||
ZNO_FREE_SCANREC_ERROR = 489,
|
||||
ZWRONG_BATCH_SIZE = 1230,
|
||||
ZSTANDBY_SCAN_ERROR = 1209,
|
||||
ZSCAN_BOOK_ACC_OP_ERROR = 1219,
|
||||
ZUNKNOWN_TRANS_ERROR = 1227
|
||||
};
|
||||
|
||||
Uint32 senderData;
|
||||
Uint32 transId1;
|
||||
Uint32 transId2;
|
||||
Uint32 errorCode;
|
||||
};
|
||||
|
||||
/**
|
||||
* This is part of Scan Fragment protocol
|
||||
*
|
||||
* Not to be confused with ScanNextReq in Scan Table protocol
|
||||
*/
|
||||
class ScanFragNextReq {
|
||||
/**
|
||||
* Sender(s)
|
||||
*/
|
||||
friend class Dbtc;
|
||||
friend class Backup;
|
||||
friend class Suma;
|
||||
|
||||
/**
|
||||
* Reciver(s)
|
||||
*/
|
||||
friend class Dblqh;
|
||||
|
||||
friend bool printSCANFRAGNEXTREQ(FILE * output, const Uint32 * theData,
|
||||
Uint32 len, Uint16 receiverBlockNo);
|
||||
public:
|
||||
STATIC_CONST( SignalLength = 6 );
|
||||
|
||||
public:
|
||||
Uint32 senderData;
|
||||
Uint32 closeFlag;
|
||||
Uint32 transId1;
|
||||
Uint32 transId2;
|
||||
Uint32 batch_size_rows;
|
||||
Uint32 batch_size_bytes;
|
||||
};
|
||||
|
||||
/**
|
||||
* Request Info
|
||||
*
|
||||
* a = Length of attrinfo - 16 Bits (16-31)
|
||||
* l = Lock Mode - 1 Bit 5
|
||||
* h = Hold lock - 1 Bit 7
|
||||
* k = Keyinfo - 1 Bit 8
|
||||
* r = read committed - 1 Bit 9
|
||||
* x = range scan - 1 Bit 6
|
||||
* z = descending - 1 Bit 10
|
||||
* t = tup scan -1 Bit 11 (implies x=z=0)
|
||||
* p = Scan prio - 4 Bits (12-15) -> max 15
|
||||
*
|
||||
* 1111111111222222222233
|
||||
* 01234567890123456789012345678901
|
||||
* lxhkrztppppaaaaaaaaaaaaaaaa
|
||||
*/
|
||||
#define SF_LOCK_MODE_SHIFT (5)
|
||||
#define SF_LOCK_MODE_MASK (1)
|
||||
|
||||
#define SF_HOLD_LOCK_SHIFT (7)
|
||||
#define SF_KEYINFO_SHIFT (8)
|
||||
#define SF_READ_COMMITTED_SHIFT (9)
|
||||
#define SF_RANGE_SCAN_SHIFT (6)
|
||||
#define SF_DESCENDING_SHIFT (10)
|
||||
#define SF_TUP_SCAN_SHIFT (11)
|
||||
|
||||
#define SF_ATTR_LEN_SHIFT (16)
|
||||
#define SF_ATTR_LEN_MASK (65535)
|
||||
|
||||
#define SF_PRIO_SHIFT 12
|
||||
#define SF_PRIO_MASK 15
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getLockMode(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_LOCK_MODE_SHIFT) & SF_LOCK_MODE_MASK;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getHoldLockFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_HOLD_LOCK_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getKeyinfoFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_KEYINFO_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getRangeScanFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_RANGE_SCAN_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getDescendingFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_DESCENDING_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getTupScanFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_TUP_SCAN_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getReadCommittedFlag(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_READ_COMMITTED_SHIFT) & 1;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getAttrLen(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_ATTR_LEN_SHIFT) & SF_ATTR_LEN_MASK;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
ScanFragReq::getScanPrio(const Uint32 & requestInfo){
|
||||
return (requestInfo >> SF_PRIO_SHIFT) & SF_PRIO_MASK;
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setScanPrio(UintR & requestInfo, UintR val){
|
||||
ASSERT_MAX(val, SF_PRIO_MASK, "ScanFragReq::setScanPrio");
|
||||
requestInfo |= (val << SF_PRIO_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setLockMode(UintR & requestInfo, UintR val){
|
||||
ASSERT_MAX(val, SF_LOCK_MODE_MASK, "ScanFragReq::setLockMode");
|
||||
requestInfo |= (val << SF_LOCK_MODE_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setHoldLockFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setHoldLockFlag");
|
||||
requestInfo |= (val << SF_HOLD_LOCK_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setKeyinfoFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setKeyinfoFlag");
|
||||
requestInfo |= (val << SF_KEYINFO_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setReadCommittedFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setReadCommittedFlag");
|
||||
requestInfo |= (val << SF_READ_COMMITTED_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setRangeScanFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setRangeScanFlag");
|
||||
requestInfo |= (val << SF_RANGE_SCAN_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setDescendingFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setDescendingFlag");
|
||||
requestInfo |= (val << SF_DESCENDING_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setTupScanFlag(UintR & requestInfo, UintR val){
|
||||
ASSERT_BOOL(val, "ScanFragReq::setTupScanFlag");
|
||||
requestInfo |= (val << SF_TUP_SCAN_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
void
|
||||
ScanFragReq::setAttrLen(UintR & requestInfo, UintR val){
|
||||
ASSERT_MAX(val, SF_ATTR_LEN_MASK, "ScanFragReq::setAttrLen");
|
||||
requestInfo |= (val << SF_ATTR_LEN_SHIFT);
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
KeyInfo20::setScanInfo(Uint32 opNo, Uint32 scanNo){
|
||||
ASSERT_MAX(opNo, 1023, "KeyInfo20::setScanInfo");
|
||||
ASSERT_MAX(scanNo, 255, "KeyInfo20::setScanInfo");
|
||||
return (opNo << 8) + scanNo;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
KeyInfo20::getScanNo(Uint32 scanInfo){
|
||||
return scanInfo & 0xFF;
|
||||
}
|
||||
|
||||
inline
|
||||
Uint32
|
||||
KeyInfo20::getScanOp(Uint32 scanInfo){
|
||||
return (scanInfo >> 8) & 0x3FF;
|
||||
}
|
||||
|
||||
#endif
|
||||
Reference in New Issue
Block a user