X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=src%2Fkernel.cpp;h=6856a00d1dea9f441020e67b8415ca21c1507825;hb=fe1da4fa013d6f7750e3e4759cb0b93495e8abf1;hp=7d8a66ad268f33ca4128af258ccc0ca468548a41;hpb=a042ef41f2db5ec89154d82b5522dfb5dcad40d5;p=novacoin.git diff --git a/src/kernel.cpp b/src/kernel.cpp index 7d8a66a..6856a00 100644 --- a/src/kernel.cpp +++ b/src/kernel.cpp @@ -1,4 +1,7 @@ // Copyright (c) 2012-2013 The PPCoin developers +// Copyright (c) 2013-2015 The Novacoin developers +// Distributed under the MIT/X11 software license, see the accompanying +// file COPYING or http://www.opensource.org/licenses/mit-license.php. // Distributed under the MIT/X11 software license, see the accompanying // file COPYING or http://www.opensource.org/licenses/mit-license.php. @@ -377,7 +380,7 @@ bool CheckStakeKernelHash(uint32_t nBits, const CBlock& blockFrom, uint32_t nTxP uint256 hashBlockFrom = blockFrom.GetHash(); - CBigNum bnCoinDayWeight = CBigNum(nValueIn) * GetWeight((int64_t)txPrev.nTime, (int64_t)nTimeTx) / COIN / (24 * 60 * 60); + CBigNum bnCoinDayWeight = CBigNum(nValueIn) * GetWeight((int64_t)txPrev.nTime, (int64_t)nTimeTx) / COIN / nOneDay; targetProofOfStake = (bnCoinDayWeight * bnTargetPerCoinDay).getuint256(); // Calculate hash @@ -423,53 +426,160 @@ bool CheckStakeKernelHash(uint32_t nBits, const CBlock& blockFrom, uint32_t nTxP return true; } -// Precompute hashing state for static part of kernel -void GetKernelMidstate(uint64_t nStakeModifier, uint32_t nBlockTime, uint32_t nTxOffset, uint32_t nInputTxTime, uint32_t nOut, SHA256_CTX &ctx) -{ - // Build static part of kernel - CDataStream ssKernel(SER_GETHASH, 0); - ssKernel << nStakeModifier; - ssKernel << nBlockTime << nTxOffset << nInputTxTime << nOut; - CDataStream::const_iterator it = ssKernel.begin(); - - // Init sha256 context and update it - // with first 24 bytes of kernel - SHA256_Init(&ctx); - SHA256_Update(&ctx, (unsigned char*)&it[0], 8 + 16); -} +#ifdef USE_ASM + +// kernel padding +static const uint32_t block1_suffix[9] = { 0x80000000, 0, 0, 0, 0, 0, 0, 0, 0xe0000000 }; +static const uint32_t block1_suffix_4way[4 * 9] = { + 0x00000080, 0x00000080, 0x00000080, 0x00000080, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0xe0000000, 0xe0000000, 0xe0000000, 0xe0000000 +}; + +// hash padding +static const uint32_t block2_suffix[8] = { 0x80000000, 0, 0, 0, 0, 0, 0, 0x00010000 }; +static const uint32_t block2_suffix_4way[4 * 8] = { + 0x00000080, 0x00000080, 0x00000080, 0x00000080, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0, 0, 0, 0, + 0x00010000, 0x00010000, 0x00010000, 0x00010000 +}; + +extern "C" int sha256_use_4way(); +extern "C" void sha256_init(uint32_t *state); +extern "C" void sha256_transform(uint32_t *state, const uint32_t *block, int swap); +extern "C" void sha256_init_4way(uint32_t *state); +extern "C" void sha256_transform_4way(uint32_t *state, const uint32_t *block, int swap); +extern "C" void copy_swap_hashes(uint32_t *blocks, uint32_t *state); // Generic block copy function + +#ifdef USE_SSSE3 +extern "C" int sha256_use_ssse3(); +extern "C" void copy_swap_hashes_ssse3(uint32_t *blocks, uint32_t *state); // SSSE3 optimized block copy function + +void (*copy_swap)(uint32_t *, uint32_t *) = (sha256_use_ssse3() != 0) ? ©_swap_hashes_ssse3 : copy_swap_hashes; +#else +void (*copy_swap)(uint32_t *, uint32_t *) = ©_swap_hashes; +#endif + +bool fUse4Way = sha256_use_4way() != 0; class ScanMidstateWorker { public: ScanMidstateWorker() { } - ScanMidstateWorker(SHA256_CTX ctx, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, uint32_t nIntervalBegin, uint32_t nIntervalEnd) + ScanMidstateWorker(unsigned char *kernel, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, uint32_t nIntervalBegin, uint32_t nIntervalEnd) + : kernel(kernel), nBits(nBits), nInputTxTime(nInputTxTime), bnValueIn(nValueIn), nIntervalBegin(nIntervalBegin), nIntervalEnd(nIntervalEnd) { - workerSolutions = vector >(); - - workerCtx = ctx; - this->nBits = nBits; - this->nInputTxTime = nInputTxTime; - this->nValueIn = nValueIn; - this->nIntervalBegin = nIntervalBegin; - this->nIntervalEnd = nIntervalEnd; + solutions = vector >(); } - void Do() + void Do_4way() { + SetThreadPriority(THREAD_PRIORITY_LOWEST); + + // Compute maximum possible target to filter out majority of obviously insufficient hashes CBigNum bnTargetPerCoinDay; bnTargetPerCoinDay.SetCompact(nBits); + uint256 nMaxTarget = (bnTargetPerCoinDay * bnValueIn * nStakeMaxAge / COIN / nOneDay).getuint256(); + + uint32_t state1[4 * 8] __attribute__((aligned(16))); + uint32_t state2[4 * 8] __attribute__((aligned(16))); + uint32_t blocks1[4 * 16] __attribute__((aligned(16))); + uint32_t blocks2[4 * 16] __attribute__((aligned(16))); + + vector vRow = vector(4); + uint32_t *pnKernel = (uint32_t *) kernel; + + for(int i = 0; i < 7; i++) + { + uint32_t nVal = pnKernel[i]; + fill(vRow.begin(), vRow.end(), nVal); + + for (int j = 0; j < 4; j++) + { + memcpy(&blocks1[i*4], &vRow[0], 16); + } + } + + memcpy(&blocks1[28], &block1_suffix_4way[0], 36*4); // sha256 padding + memcpy(&blocks2[32], &block2_suffix_4way[0], 32*4); + + // Search forward in time from the given timestamp + // Stopping search in case of shutting down + for (uint32_t nTimeTx=nIntervalBegin, nMaxTarget32 = nMaxTarget.Get32(7); nTimeTx= CBigNum(nHashProofOfStake)) + solutions.push_back(std::pair(nHashProofOfStake, nTime)); + } + } + } + } + + void Do_generic() + { + SetThreadPriority(THREAD_PRIORITY_LOWEST); + // Init new sha256 context and update it + // with first 24 bytes of kernel + SHA256_CTX workerCtx; + SHA256_Init(&workerCtx); + SHA256_Update(&workerCtx, kernel, 8 + 16); SHA256_CTX ctx = workerCtx; + // Sha256 result buffer + uint32_t hashProofOfStake[8]; + + // Compute maximum possible target to filter out majority of obviously insufficient hashes + CBigNum bnTargetPerCoinDay; + bnTargetPerCoinDay.SetCompact(nBits); + + uint256 nMaxTarget = (bnTargetPerCoinDay * bnValueIn * nStakeMaxAge / COIN / nOneDay).getuint256(), + *pnHashProofOfStake = (uint256 *)&hashProofOfStake; + // Search forward in time from the given timestamp // Stopping search in case of shutting down - for (uint32_t nTimeTx=nIntervalBegin; nTimeTx nMaxTarget32) + continue; + + CBigNum bnCoinDayWeight = bnValueIn * GetWeight((int64_t)nInputTxTime, (int64_t)nTimeTx) / COIN / nOneDay; + CBigNum bnTargetProofOfStake = bnCoinDayWeight * bnTargetPerCoinDay; + + if (bnTargetProofOfStake >= CBigNum(*pnHashProofOfStake)) + solutions.push_back(std::pair(*pnHashProofOfStake, nTimeTx)); + } + } + + void Do() + { + if (fUse4Way) + Do_4way(); + else + Do_generic(); + } + + vector >& GetSolutions() + { + return solutions; + } + +private: + std::vector > solutions; + + uint8_t *kernel; + uint32_t nBits; + uint32_t nInputTxTime; + CBigNum bnValueIn; + uint32_t nIntervalBegin; + uint32_t nIntervalEnd; +}; + +#else +class ScanMidstateWorker +{ +public: + ScanMidstateWorker() + { } + ScanMidstateWorker(unsigned char *kernel, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, uint32_t nIntervalBegin, uint32_t nIntervalEnd) + : nBits(nBits), nInputTxTime(nInputTxTime), bnValueIn(nValueIn), nIntervalBegin(nIntervalBegin), nIntervalEnd(nIntervalEnd) + { + // Init new sha256 context and update it + // with first 24 bytes of kernel + SHA256_Init(&workerCtx); + SHA256_Update(&workerCtx, kernel, 8 + 16); + solutions = vector >(); + } + + void Do() + { + SetThreadPriority(THREAD_PRIORITY_LOWEST); + SHA256_CTX ctx = workerCtx; + + // Sha256 result buffer + uint32_t hashProofOfStake[8]; + + // Compute maximum possible target to filter out majority of obviously insufficient hashes + CBigNum bnTargetPerCoinDay; + bnTargetPerCoinDay.SetCompact(nBits); + + uint256 nMaxTarget = (bnTargetPerCoinDay * bnValueIn * nStakeMaxAge / COIN / nOneDay).getuint256(), + *pnHashProofOfStake = (uint256 *)&hashProofOfStake; + + // Search forward in time from the given timestamp + // Stopping search in case of shutting down + for (uint32_t nTimeTx=nIntervalBegin, nMaxTarget32 = nMaxTarget.Get32(7); nTimeTx maxTarget) + if (hashProofOfStake[7] > nMaxTarget32) continue; - CBigNum bnCoinDayWeight = CBigNum(nValueIn) * GetWeight((int64_t)nInputTxTime, (int64_t)nTimeTx) / COIN / (24 * 60 * 60); + CBigNum bnCoinDayWeight = bnValueIn * GetWeight((int64_t)nInputTxTime, (int64_t)nTimeTx) / COIN / nOneDay; CBigNum bnTargetProofOfStake = bnCoinDayWeight * bnTargetPerCoinDay; - if (bnTargetProofOfStake >= CBigNum(hashProofOfStake)) - { - workerSolutions.push_back(std::pair(hashProofOfStake, nTimeTx)); - } + if (bnTargetProofOfStake >= CBigNum(*pnHashProofOfStake)) + solutions.push_back(std::pair(*pnHashProofOfStake, nTimeTx)); } } - vector > GetSolutions() + vector >& GetSolutions() { - return workerSolutions; + return solutions; } private: SHA256_CTX workerCtx; - std::vector > workerSolutions; + std::vector > solutions; uint32_t nBits; uint32_t nInputTxTime; - int64_t nValueIn; + CBigNum bnValueIn; uint32_t nIntervalBegin; uint32_t nIntervalEnd; }; -// Scan given midstate for solution -bool ScanMidstateForward(SHA256_CTX &ctx, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, std::pair &SearchInterval, std::vector > &solutions) +#endif +// Scan given kernel for solution +bool ScanKernelForward(unsigned char *kernel, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, std::pair &SearchInterval, std::vector > &solutions) { // TODO: custom threads amount uint32_t nThreads = boost::thread::hardware_concurrency(); + uint32_t nPart = (SearchInterval.second - SearchInterval.first) / nThreads; - uint32_t nBegin = SearchInterval.first; - uint32_t nEnd = SearchInterval.second; - uint32_t nPart = (nEnd - nBegin) / nThreads; ScanMidstateWorker *workers = new ScanMidstateWorker[nThreads]; boost::thread_group group; for(size_t i = 0; i < nThreads; i++) { - uint32_t nIntervalBegin = nBegin + nPart * i; - uint32_t nIntervalEnd = nBegin + nPart * (i + 1); - - workers[i] = ScanMidstateWorker(ctx, nBits, nInputTxTime, nValueIn, nIntervalBegin, nIntervalEnd); - + uint32_t nBegin = SearchInterval.first + nPart * i; + uint32_t nEnd = SearchInterval.first + nPart * (i + 1); + workers[i] = ScanMidstateWorker(kernel, nBits, nInputTxTime, nValueIn, nBegin, nEnd); boost::function workerFnc = boost::bind(&ScanMidstateWorker::Do, &workers[i]); group.create_thread(workerFnc); } @@ -560,13 +745,13 @@ bool ScanMidstateForward(SHA256_CTX &ctx, uint32_t nBits, uint32_t nInputTxTime, } // Scan given midstate for solution -bool ScanMidstateBackward(SHA256_CTX &ctx, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, std::pair &SearchInterval, std::pair &solution) +bool ScanContextBackward(SHA256_CTX &ctx, uint32_t nBits, uint32_t nInputTxTime, int64_t nValueIn, std::pair &SearchInterval, std::pair &solution) { CBigNum bnTargetPerCoinDay; bnTargetPerCoinDay.SetCompact(nBits); // Get maximum possible target to filter out the majority of obviously insufficient hashes - CBigNum bnMaxTargetPerCoinDay = bnTargetPerCoinDay * CBigNum(nValueIn) * nStakeMaxAge / COIN / (24 * 60 * 60); + CBigNum bnMaxTargetPerCoinDay = bnTargetPerCoinDay * CBigNum(nValueIn) * nStakeMaxAge / COIN / nOneDay; uint256 maxTarget = bnMaxTargetPerCoinDay.getuint256(); SHA256_CTX ctxCopy = ctx; @@ -591,7 +776,7 @@ bool ScanMidstateBackward(SHA256_CTX &ctx, uint32_t nBits, uint32_t nInputTxTime if (hashProofOfStake > maxTarget) continue; - CBigNum bnCoinDayWeight = CBigNum(nValueIn) * GetWeight((int64_t)nInputTxTime, (int64_t)nTimeTx) / COIN / (24 * 60 * 60); + CBigNum bnCoinDayWeight = CBigNum(nValueIn) * GetWeight((int64_t)nInputTxTime, (int64_t)nTimeTx) / COIN / nOneDay; CBigNum bnTargetProofOfStake = bnCoinDayWeight * bnTargetPerCoinDay; if (bnTargetProofOfStake >= CBigNum(hashProofOfStake))