/* Copyright (C) 2014 InfiniDB, Inc. 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; version 2 of the License. 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., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. */ #pragma once #include "columncommand.h" #include "blocksize.h" #include "oamcache.h" namespace primitiveprocessor { class PseudoCC : public ColumnCommand { public: PseudoCC(); ~PseudoCC() override; SCommand duplicate() override; void createCommand(messageqcpp::ByteStream&) override; void resetCommand(messageqcpp::ByteStream&) override; protected: void loadData() override; private: template void loadSingleValue(W val); template void loadPMNumber(); template void loadRIDs(); template void loadSegmentNum(); template void loadDBRootNum(); template void loadPartitionNum(); template void loadLBID(); uint32_t function; uint64_t valueFromUM; uint128_t bigValueFromUM; }; template #ifdef __GNUC__ // The "official" GCC version for InfiniDB is 4.5.3. This flag breaks at least 4.4.3 & 4.4.5, // so just don't do it for anything younger than 4.5.0. #if __GNUC__ > 4 || (__GNUC__ == 4 && __GNUC_MINOR__ >= 5) __attribute__((optimize("no-tree-vectorize"))) #endif #endif void PseudoCC::loadSingleValue(W val) { W* bData = (W*)bpp->blockData; for (uint32_t i = 0; i < BLOCK_SIZE; i++) bData[i] = val; // this breaks when using tree-vectorization // memcpy(&bData[i], &val, sizeof(W)); // this always works } template void PseudoCC::loadPMNumber() { uint32_t pmNum = oam::OamCache::makeOamCache()->getLocalPMId(); loadSingleValue(pmNum); } /* This returns extent-relative rids */ template void PseudoCC::loadRIDs() { uint32_t i; uint64_t baseRid = rowgroup::getExtentRelativeRid(bpp->baseRid); W* bData = (W*)bpp->blockData; for (i = 0; i < BLOCK_SIZE; i++) { // W val = baseRid + i; // memcpy(&bData[i], &val, sizeof(W)); bData[i] = baseRid + i; // breaks with tree-vectorization } } template void PseudoCC::loadSegmentNum() { uint16_t segNum; rowgroup::getLocationFromRid(bpp->baseRid, nullptr, &segNum, nullptr, nullptr); loadSingleValue(segNum); } template void PseudoCC::loadPartitionNum() { uint32_t partNum; rowgroup::getLocationFromRid(bpp->baseRid, &partNum, nullptr, nullptr, nullptr); loadSingleValue(partNum); } template void PseudoCC::loadDBRootNum() { loadSingleValue(bpp->dbRoot); } template void PseudoCC::loadLBID() { uint32_t i; W* bData = (W*)bpp->blockData; for (i = 0; i < BLOCK_SIZE; i++) { // W val = ColumnCommand::getLBID() + (i * sizeof(W)) / BLOCK_SIZE; // memcpy(&bData[i], &val, sizeof(W)); bData[i] = ColumnCommand::getLBID() + (i * sizeof(W)) / BLOCK_SIZE; // breaks with tree-vectorization } } } // namespace primitiveprocessor