/* Copyright (c) 2016 PaddlePaddle Authors. All Rights Reserve. Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. */ #ifndef PADDLE_ONLY_CPU /// This unittest checks GpuMatrix/CpuMatrix get same result, so disable when /// only cpu version. #include "paddle/utils/Util.h" #include "paddle/math/Matrix.h" #include "paddle/math/SparseMatrix.h" #include #include "paddle/gserver/tests/TestUtil.h" #include "paddle/utils/Stat.h" #include "TensorCheck.h" #include "paddle/math/cross_map_normal_op.h" #include "paddle/math/Function.h" using namespace paddle; // NOLINT using namespace std; // NOLINT using autotest::TensorCheckEqual; using autotest::TensorCheckErr; void testMatrixProjectionForward(int contextStart, int contextLength, bool padding, int batchSize, int inputDim) { MatrixPtr cpuInput = std::make_shared(batchSize, inputDim); MatrixPtr gpuInput = std::make_shared(batchSize, inputDim); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); int pad = std::max(0, -contextStart) + std::max(0, contextStart + contextLength - 1); if (pad == 0) padding = false; MatrixPtr cpuWeight = nullptr; MatrixPtr gpuWeight = nullptr; if (padding) { cpuWeight = std::make_shared(pad, inputDim); gpuWeight = std::make_shared(pad, inputDim); cpuWeight->randomizeUniform(); gpuWeight->copyFrom(*cpuWeight); } IVectorPtr cpuSequence; generateSequenceStartPositions(batchSize, cpuSequence); IVectorPtr gpuSequence = IVector::create(cpuSequence->getSize(), true); gpuSequence->copyFrom(*cpuSequence); MatrixPtr cpuOutput = std::make_shared(batchSize, inputDim * contextLength); MatrixPtr gpuOutput = std::make_shared(batchSize, inputDim * contextLength); cpuOutput->randomizeUniform(); gpuOutput->copyFrom(*cpuOutput); // calculate int beginPad = std::max(0, -contextStart); cpuOutput->contextProjectionForward(cpuInput, cpuWeight, *cpuSequence, contextLength, contextStart, beginPad, padding); gpuOutput->contextProjectionForward(gpuInput, gpuWeight, *gpuSequence, contextLength, contextStart, beginPad, padding); TensorCheckEqual(*cpuOutput, *gpuOutput); } void testMatrixProjectionBackward(int contextStart, int contextLength, bool padding, int batchSize, int inputDim) { MatrixPtr cpuOutputGrad = std::make_shared(batchSize, inputDim * contextLength); MatrixPtr gpuOutputGrad = std::make_shared(batchSize, inputDim * contextLength); cpuOutputGrad->randomizeUniform(); gpuOutputGrad->copyFrom(*cpuOutputGrad); IVectorPtr cpuSequence; generateSequenceStartPositions(batchSize, cpuSequence); IVectorPtr gpuSequence = IVector::create(cpuSequence->getSize(), true); gpuSequence->copyFrom(*cpuSequence); MatrixPtr cpuInputGrad = std::make_shared(batchSize, inputDim); MatrixPtr gpuInputGrad = std::make_shared(batchSize, inputDim); cpuInputGrad->randomizeUniform(); gpuInputGrad->copyFrom(*cpuInputGrad); int pad = std::max(0, -contextStart) + std::max(0, contextStart + contextLength - 1); if (pad == 0) padding = false; MatrixPtr cpuWeightGrad = nullptr; MatrixPtr gpuWeightGrad = nullptr; if (padding) { cpuWeightGrad = std::make_shared(pad, inputDim); gpuWeightGrad = std::make_shared(pad, inputDim); cpuWeightGrad->randomizeUniform(); gpuWeightGrad->copyFrom(*cpuWeightGrad); } // calculate int beginPad = std::max(0, -contextStart); cpuOutputGrad->contextProjectionBackward(cpuInputGrad, cpuWeightGrad, *cpuSequence, contextLength, contextStart, beginPad, padding); gpuOutputGrad->contextProjectionBackwardData( gpuInputGrad, *gpuSequence, contextLength, contextStart); if (padding) { gpuOutputGrad->contextProjectionBackwardWeight(gpuWeightGrad, *gpuSequence, contextLength, contextStart, pad, beginPad); } TensorCheckErr(*cpuInputGrad, *gpuInputGrad); if (padding) { TensorCheckErr(*cpuWeightGrad, *gpuWeightGrad); } } TEST(Matrix, projection) { for (auto contextStart : {-5, -3, -1, 0, 3}) { for (auto contextLength : {1, 2, 5, 7}) { for (auto trainablePadding : {false, true}) { for (auto batchSize : {1, 2, 5, 20, 100}) { for (auto inputDim : {15, 32, 63, 128, 200}) { VLOG(3) << " contextStart=" << contextStart << " contextLength=" << contextLength << " trainablePadding=" << trainablePadding << " batchSize=" << batchSize << " inputDim=" << inputDim; testMatrixProjectionForward(contextStart, contextLength, trainablePadding, batchSize, inputDim); testMatrixProjectionBackward(contextStart, contextLength, trainablePadding, batchSize, inputDim); } } } } } } void testMatrixMaxSequence(int batchSize, int inputDim) { // forward MatrixPtr cpuInput = std::make_shared(batchSize, inputDim); MatrixPtr gpuInput = std::make_shared(batchSize, inputDim); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); IVectorPtr cpuSequence; generateSequenceStartPositions(batchSize, cpuSequence); IVectorPtr gpuSequence = IVector::create(cpuSequence->getSize(), true); gpuSequence->copyFrom(*cpuSequence); int newBatchSize = cpuSequence->getSize() - 1; MatrixPtr cpuOutput = std::make_shared(newBatchSize, inputDim); MatrixPtr gpuOutput = std::make_shared(newBatchSize, inputDim); cpuOutput->zero(); gpuOutput->zero(); IVectorPtr cpuIndex = nullptr; IVectorPtr gpuIndex = nullptr; IVector::resizeOrCreate(cpuIndex, newBatchSize * inputDim, false); IVector::resizeOrCreate(gpuIndex, newBatchSize * inputDim, true); cpuIndex->zeroMem(); gpuIndex->zeroMem(); cpuOutput->maxSequenceForward(*cpuInput, *cpuSequence, *cpuIndex); gpuOutput->maxSequenceForward(*gpuInput, *gpuSequence, *gpuIndex); TensorCheckEqual(*cpuOutput, *gpuOutput); TensorCheckEqual(*cpuIndex, *gpuIndex); // backward MatrixPtr cpuOutputGrad = std::make_shared(newBatchSize, inputDim); MatrixPtr gpuOutputGrad = std::make_shared(newBatchSize, inputDim); cpuOutputGrad->randomizeUniform(); gpuOutputGrad->copyFrom(*cpuOutputGrad); MatrixPtr cpuInputGrad = std::make_shared(batchSize, inputDim); MatrixPtr gpuInputGrad = std::make_shared(batchSize, inputDim); cpuInputGrad->randomizeUniform(); gpuInputGrad->copyFrom(*cpuInputGrad); cpuInputGrad->maxSequenceBackward(*cpuOutputGrad, *cpuSequence, *cpuIndex); gpuInputGrad->maxSequenceBackward(*gpuOutputGrad, *gpuSequence, *gpuIndex); TensorCheckEqual(*cpuInputGrad, *gpuInputGrad); } TEST(Matrix, maxSequence) { for (auto batchSize : {1, 10, 128, 1000, 6000}) { for (auto inputDim : {1, 32, 100, 512}) { VLOG(3) << " batchSize=" << batchSize << " inputDim=" << inputDim; testMatrixMaxSequence(batchSize, inputDim); } } } void testMatrixGetSum(int height, int width) { MatrixPtr cpuInput = std::make_shared(height, width); MatrixPtr gpuInput = std::make_shared(height, width); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); #ifndef PADDLE_TYPE_DOUBLE int x = log10(height * width); real err = 1e-6 * pow(10, x); #else real err = 1e-8; #endif real cpuSum = cpuInput->getSum(); real gpuSum = gpuInput->getSum(); EXPECT_LE(fabs(cpuSum - gpuSum), err); } void testMatrixZeroAtOffset(int height, int width) { MatrixPtr cpuA = std::make_shared(height, width); MatrixPtr gpuA = std::make_shared(height, width); MatrixPtr cpuTest = std::make_shared(height, width); cpuA->randomizeUniform(); gpuA->copyFrom(*cpuA); cpuTest->copyFrom(*cpuA); int columnOffset = rand() % width; // NOLINT we just use rand() for test. int numColumns = rand() % (width - columnOffset); // NOLINT if (numColumns == 0) return; cpuA->zeroAtOffset(columnOffset, numColumns); gpuA->zeroAtOffset(columnOffset, numColumns); /* cpuTest */ real* a = cpuTest->getData() + columnOffset; for (int64_t i = 0; i < height; ++i) { for (int64_t j = 0; j < numColumns; ++j) { a[i * width + j] = 0; } } TensorCheckEqual(*cpuA, *gpuA); TensorCheckEqual(*cpuA, *cpuTest); } void testMatrixDeepSwap(int height, int width) { MatrixPtr cpuA = std::make_shared(height, width); MatrixPtr cpuB = std::make_shared(height, width); MatrixPtr cpuCopyA = std::make_shared(height, width); MatrixPtr cpuCopyB = std::make_shared(height, width); cpuA->randomizeUniform(); cpuB->randomizeUniform(); cpuCopyA->copyFrom(*cpuA); cpuCopyB->copyFrom(*cpuB); // swap matrix cpuA and cpuB cpuA->deepSwap(*cpuB); TensorCheckEqual(*cpuA, *cpuCopyB); TensorCheckEqual(*cpuB, *cpuCopyA); } void testMatrixTranspose(int height, int width) { MatrixPtr cpu = std::make_shared(height, width); MatrixPtr gpu = std::make_shared(height, width); MatrixPtr cpuT = std::make_shared(width, height); MatrixPtr gpuT = std::make_shared(width, height); cpu->randomizeUniform(); gpu->copyFrom(*cpu); cpu->transpose(cpuT, false); gpu->transpose(gpuT, false); TensorCheckEqual(*cpuT, *gpuT); } void testMatrixInverse(int height) { MatrixPtr cpu = std::make_shared(height, height); MatrixPtr gpu = std::make_shared(height, height); MatrixPtr cpuI = std::make_shared(height, height); MatrixPtr gpuI = std::make_shared(height, height); /* Make matrix well conditioned: cpu * cpuT + Identity */ cpu->randomizeUniform(); MatrixPtr cpuT = cpu->getTranspose(); MatrixPtr outputCheck = std::make_shared(height, height); outputCheck->mul(cpu, cpuT); cpu->setDiag(1.0); cpu->add(*outputCheck); gpu->copyFrom(*cpu); cpu->inverse(cpuI, false); gpu->inverse(gpuI, false); TensorCheckErr(*cpuI, *gpuI); outputCheck->mul(cpu, cpuI); cpu->setDiag(1.0); TensorCheckErr(*cpu, *outputCheck); } TEST(Matrix, unary) { for (auto height : {1, 3, 11, 73, 128, 200, 330}) { for (auto width : {1, 3, 32, 100, 512, 1000, 3210}) { VLOG(3) << " height=" << height << " width=" << width; testMatrixDeepSwap(height, width); testMatrixZeroAtOffset(height, width); testMatrixGetSum(height, width); testMatrixTranspose(height, width); } // inverse testMatrixInverse(height); } } void testMatrixSoftmax(int height, int width) { MatrixPtr cpuInput = std::make_shared(height, width); MatrixPtr cpuOutput = std::make_shared(height, width); MatrixPtr gpuInput = std::make_shared(height, width); MatrixPtr gpuOutput = std::make_shared(height, width); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); cpuOutput->zero(); gpuOutput->zero(); cpuInput->softmax(*cpuOutput); gpuInput->softmax(*gpuOutput); TensorCheckErr(*cpuOutput, *gpuOutput); } void testSequenceSoftmax(int batchSize) { // forward int inputDim = 1; MatrixPtr cpuInput = std::make_shared(batchSize, inputDim); MatrixPtr gpuInput = std::make_shared(batchSize, inputDim); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); IVectorPtr cpuSequence; generateSequenceStartPositions(batchSize, cpuSequence); IVectorPtr gpuSequence = IVector::create(cpuSequence->getSize(), true); gpuSequence->copyFrom(*cpuSequence); cpuInput->sequenceSoftmax(*cpuInput, *cpuSequence); gpuInput->sequenceSoftmax(*gpuInput, *gpuSequence); TensorCheckErr(*cpuInput, *gpuInput); } void testMatrixSoftmaxThreshold(int height, int width) { MatrixPtr cpuInput = std::make_shared(height, width); MatrixPtr cpuOutput = std::make_shared(height, width); MatrixPtr gpuInput = std::make_shared(height, width); MatrixPtr gpuOutput = std::make_shared(height, width); cpuInput->randomizeUniform(); cpuInput->getData()[0] = 100.0; gpuInput->copyFrom(*cpuInput); cpuOutput->zero(); gpuOutput->zero(); cpuInput->softmax(*cpuOutput); gpuInput->softmax(*gpuOutput); MatrixPtr outputCheck = std::make_shared(height, width); outputCheck->copyFrom(*gpuOutput); // check output zero int cpuCount = 0; int gpuCount = 0; auto zeroNum = [](MatrixPtr out, int& count) { for (size_t i = 0; i < out->getHeight(); i++) { for (size_t j = 0; j < out->getWidth(); j++) { if (out->getElement(i, j) == 0) count++; } } }; zeroNum(cpuOutput, cpuCount); zeroNum(outputCheck, gpuCount); EXPECT_EQ(cpuCount, 0) << "Cpu softmax output value 0"; EXPECT_EQ(gpuCount, 0) << "Gpu softmax output value 0"; } void testMatrixSoftmaxBp(int height, int width) { MatrixPtr cpuInput = std::make_shared(height, width); MatrixPtr cpuOutput = std::make_shared(height, width); MatrixPtr gpuInput = std::make_shared(height, width); MatrixPtr gpuOutput = std::make_shared(height, width); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); cpuOutput->randomizeUniform(); gpuOutput->copyFrom(*cpuOutput); gpuOutput->softmaxBackward(*gpuInput); MatrixPtr sftMaxSum = std::make_shared(height, 1); MatrixPtr sftMaxDot = std::make_shared(height, width); sftMaxDot->dotMul(*cpuOutput, *cpuInput); sftMaxSum->colMerge(*sftMaxDot); cpuOutput->softmaxDerivative(*cpuInput, *sftMaxSum); TensorCheckErr(*cpuOutput, *gpuOutput); } TEST(Matrix, softmax) { for (auto height : {1, 11, 73, 128, 200}) { for (auto width : {1, 32, 100, 512, 1000}) { VLOG(3) << " height=" << height << " width=" << width; testMatrixSoftmax(height, width); testMatrixSoftmaxBp(height, width); testMatrixSoftmaxThreshold(height, width); } testSequenceSoftmax(height); } } void testMatrixAddToRows(int numSamples, int tableSize, int inputDim) { MatrixPtr cpuTable = std::make_shared(tableSize, inputDim); MatrixPtr gpuTable = std::make_shared(tableSize, inputDim); cpuTable->randomizeUniform(); gpuTable->copyFrom(*cpuTable); IVectorPtr cpuIds; IVectorPtr gpuIds; cpuIds = VectorT::create(numSamples, false); gpuIds = VectorT::create(numSamples, true); cpuIds->rand(tableSize); gpuIds->copyFrom(*cpuIds); MatrixPtr cpuOutput = std::make_shared(numSamples, inputDim); MatrixPtr gpuOutput = std::make_shared(numSamples, inputDim); cpuOutput->randomizeUniform(); gpuOutput->copyFrom(*cpuOutput); cpuOutput->addToRows(*cpuTable, *cpuIds); gpuOutput->addToRows(*gpuTable, *gpuIds); TensorCheckErr(*cpuTable, *gpuTable); } TEST(Matrix, tableProjection) { for (auto numSamples : {10, 100, 1000, 10000, 80000}) { for (auto tableSize : {10, 100}) { for (auto inputDim : {20, 50}) { VLOG(3) << " numSamples=" << numSamples << " tableSize=" << tableSize << " inputDim=" << inputDim; testMatrixAddToRows(numSamples, tableSize, inputDim); } } } } void testMatrixMul(bool transa, bool transb, int dimM, int dimN, int dimK) { int heightA = transa == false ? dimM : dimK; int widthA = transa == false ? dimK : dimM; int heightB = transb == false ? dimK : dimN; int widthB = transb == false ? dimN : dimK; int heightC = dimM; int widthC = dimN; MatrixPtr cpuA = std::make_shared(heightA, widthA, transa); MatrixPtr cpuB = std::make_shared(heightB, widthB, transb); MatrixPtr cpuC = std::make_shared(heightC, widthC); MatrixPtr gpuA = std::make_shared(heightA, widthA, transa); MatrixPtr gpuB = std::make_shared(heightB, widthB, transb); MatrixPtr gpuC = std::make_shared(heightC, widthC); real alpha = 1.5; real beta = 2.0; cpuA->randomizeUniform(); cpuB->randomizeUniform(); cpuC->randomizeUniform(); gpuA->copyFrom(*cpuA); gpuB->copyFrom(*cpuB); gpuC->copyFrom(*cpuC); cpuC->mul(cpuA, cpuB, alpha, beta); gpuC->mul(gpuA, gpuB, alpha, beta); TensorCheckErr(*cpuC, *gpuC); } void testSubMatrixMul(bool transa, bool transb, int dimM, int dimN, int dimK) { int heightA = transa == false ? dimM : dimK; int widthA = transa == false ? dimK : dimM; int heightB = transb == false ? dimK : dimN; int widthB = transb == false ? dimN : dimK; int heightC = dimM; int widthC = dimN; MatrixPtr cpuA = std::make_shared(heightA, widthA, transa); MatrixPtr cpuB = std::make_shared(heightB, widthB, transb); MatrixPtr cpuC = std::make_shared(heightC, widthC); MatrixPtr gpuA = std::make_shared(heightA, widthA, transa); MatrixPtr gpuB = std::make_shared(heightB, widthB, transb); MatrixPtr gpuC = std::make_shared(heightC, widthC); real alpha = 1.5; real beta = 2.0; cpuA->randomizeUniform(); cpuB->randomizeUniform(); cpuC->randomizeUniform(); gpuA->copyFrom(*cpuA); gpuB->copyFrom(*cpuB); gpuC->copyFrom(*cpuC); auto subSize = [](int& start, int& end, int dim) { if (dim == 1) { start = 0; end = dim; } else { int subDim = rand() % (dim - 1) + 1; // NOLINT start = rand() % (dim - subDim); // NOLINT end = start + subDim; } }; auto subMatrix = [](MatrixPtr& sub, MatrixPtr matrix, size_t startRow, size_t endRow, size_t startCol, size_t endCol) { if (!matrix->isTransposed()) { sub = matrix->subMatrix(startRow, endRow, startCol, endCol); } else { sub = matrix->subMatrix(startCol, endCol, startRow, endRow); } }; int startM, endM; int startN, endN; int startK, endK; subSize(startM, endM, dimM); subSize(startN, endN, dimN); subSize(startK, endK, dimK); MatrixPtr subCpuA; MatrixPtr subCpuB; MatrixPtr subGpuA; MatrixPtr subGpuB; subMatrix(subCpuA, cpuA, startM, endM, startK, endK); subMatrix(subGpuA, gpuA, startM, endM, startK, endK); subMatrix(subCpuB, cpuB, startK, endK, startN, endN); subMatrix(subGpuB, gpuB, startK, endK, startN, endN); MatrixPtr subCpuC = cpuC->subMatrix(startM, endM, startN, endN); MatrixPtr subGpuC = gpuC->subMatrix(startM, endM, startN, endN); subCpuC->mul(subCpuA, subCpuB, alpha, beta); subGpuC->mul(subGpuA, subGpuB, alpha, beta); TensorCheckErr(*cpuC, *gpuC); } TEST(Matrix, mul) { for (auto transa : {false, true}) { for (auto transb : {false, true}) { for (auto dimM : {1, 9, 53, 127, 345, 1023, 2135}) { for (auto dimN : {1, 5, 37, 256, 1024}) { for (auto dimK : {8, 45, 346, 784, 1025}) { if (true == transa && true == transb) { continue; } VLOG(3) << setiosflags(ios::left) << setfill(' ') << " transa=" << transa << " transb=" << transb << " dimM=" << setw(5) << dimM << " dimN=" << setw(5) << dimN << " dimK=" << setw(5) << dimK; testMatrixMul(transa, transb, dimM, dimN, dimK); testSubMatrixMul(transa, transb, dimM, dimN, dimK); } } } } } } void testVectorRowFunc(int size) { CpuVectorPtr cpu = std::make_shared>(size); GpuVectorPtr gpu = std::make_shared>(size); cpu->rand(); gpu->copyFrom(*cpu); EXPECT_EQ(cpu->getMax(), gpu->getMax()); EXPECT_EQ(cpu->getMin(), gpu->getMin()); EXPECT_EQ(cpu->getAbsMax(), gpu->getAbsMax()); } TEST(Vector, rowFunc) { for (auto size : {1, 5, 31, 90, 150, 500, 1000, 4000}) { VLOG(3) << " size=" << size; testVectorRowFunc(size); } } template void testVectorReset(int size) { std::shared_ptr> cpu = std::make_shared>(size); std::shared_ptr> gpu = std::make_shared>(size); T value = (T)((int)rand() % 100 + 1.0f / ((int)rand() % 100)); cpu->reset(value); gpu->reset(value); TensorCheckEqual(*cpu, *gpu); } template void testVecortSelectFrom(int size) { std::shared_ptr> cpuDst = std::make_shared>(size); std::shared_ptr> gpuDst = std::make_shared>(size); std::shared_ptr> cpuSrc = std::make_shared>(size * 2); std::shared_ptr> gpuSrc = std::make_shared>(size * 2); CpuIVectorPtr cpuIds = std::make_shared>(size); GpuIVectorPtr gpuIds = std::make_shared>(size); if (std::is_same::value) { cpuSrc->rand(); } else { cpuSrc->rand(100000); } gpuSrc->copyFrom(*cpuSrc); cpuIds->rand(size); gpuIds->copyFrom(*cpuIds); cpuDst->selectFrom(*cpuSrc, *cpuIds); gpuDst->selectFrom(*gpuSrc, *gpuIds); TensorCheckEqual(*cpuDst, *gpuDst); } template void testVecotrZeroMem(int size) { std::shared_ptr> cpu = std::make_shared>(size); std::shared_ptr> gpu = std::make_shared>(size); cpu->zeroMem(); gpu->zeroMem(); TensorCheckEqual(*cpu, *gpu); } template void testVectorIsEqual(int size) { std::shared_ptr> cpuA = std::make_shared>(size); std::shared_ptr> cpuB = std::make_shared>(size); std::shared_ptr> gpuA = std::make_shared>(size); std::shared_ptr> gpuB = std::make_shared>(size); if (std::is_same::value) { cpuB->rand(); } else { cpuB->rand(100000); } gpuB->copyFrom(*cpuB); T value = (T)((int)rand() % 100 + 1.0f / ((int)rand() % 100)); cpuA->isEqualTo(*cpuB, value); gpuA->isEqualTo(*gpuB, value); TensorCheckEqual(*cpuA, *gpuA); } TEST(Vector, Equal) { for (auto size : {1, 5, 31, 90, 150, 500, 1000, 4000}) { VLOG(3) << " size=" << size; testVectorReset(size); testVectorReset(size); testVecortSelectFrom(size); testVecortSelectFrom(size); testVecotrZeroMem(size); testVecotrZeroMem(size); testVectorIsEqual(size); testVectorIsEqual(size); } } void testMatrixTopK(int samples, int dim, int beamSize) { MatrixPtr cpuSrc = std::make_shared(samples, dim); MatrixPtr gpuSrc = std::make_shared(samples, dim); MatrixPtr cpuVal = std::make_shared(samples, beamSize); MatrixPtr gpuVal = std::make_shared(samples, beamSize); IVectorPtr cpuIds = std::make_shared(samples * beamSize); IVectorPtr gpuIds = std::make_shared(samples * beamSize); cpuSrc->randomizeUniform(); gpuSrc->copyFrom(*cpuSrc); cpuSrc->rowMax(*cpuIds, *cpuVal); gpuSrc->rowMax(*gpuIds, *gpuVal); TensorCheckEqual(*cpuVal, *gpuVal); } TEST(Matrix, topK) { for (auto samples : {1, 5, 31, 90, 150, 500}) { for (auto dim : {1, 5, 8, 10, 15, 64, 80, 120, 256, 300, 1280, 5120, 50000}) { for (auto beamSize : {1, 5, 10, 20, 40, (int)rand() % dim + 1}) { if (beamSize > dim) continue; VLOG(3) << " samples=" << samples << " beamSize=" << beamSize << " dim=" << dim; testMatrixTopK(samples, dim, beamSize); } } } } void testSMatrixTopK(int samples, int dim, int beamSize, real ratio) { int nnz = samples * dim * ratio; MatrixPtr cpuSrc = std::make_shared(samples, dim, nnz); MatrixPtr gpuSrc = std::make_shared(samples, dim, nnz); MatrixPtr cpuVal = std::make_shared(samples, beamSize); MatrixPtr gpuVal = std::make_shared(samples, beamSize); IVectorPtr cpuIds = std::make_shared(samples * beamSize); IVectorPtr gpuIds = std::make_shared(samples * beamSize); cpuSrc->randomizeUniform(); gpuSrc->copyFrom(*cpuSrc); cpuVal->zero(); cpuIds->zero(); gpuVal->zero(); gpuIds->zero(); cpuSrc->rowMax(*cpuIds, *cpuVal); gpuSrc->rowMax(*gpuIds, *gpuVal); TensorCheckEqual(*cpuVal, *gpuVal); IVectorPtr outCheckIds = std::make_shared(samples * beamSize); outCheckIds->copyFrom(*gpuIds); const int* data1 = cpuIds->getData(); const int* data2 = outCheckIds->getData(); size_t size = cpuIds->getSize(); for (size_t i = 0; i < size; i++) { if (data1[i] == -1 && data1[i] != data2[i]) { EXPECT_EQ(data1[i], data2[i]); } } } TEST(SMatrix, topK) { for (auto samples : {1, 5, 100}) { for (auto dim : {10000, 10000, 50000}) { for (auto beamSize : {1, 5, 40, 100, 500}) { for (auto ratio : {0.01, 0.001}) { if (beamSize > dim) continue; VLOG(3) << " samples=" << samples << " beamSize=" << beamSize << " dim=" << dim << " ratio=" << ratio; testSMatrixTopK(samples, dim, beamSize, ratio); } } } } } void testMatrixSequenceAvgForward(int batchSize, int inputDim, int mode) { MatrixPtr cpuInput = std::make_shared(batchSize, inputDim); MatrixPtr gpuInput = std::make_shared(batchSize, inputDim); cpuInput->randomizeUniform(); gpuInput->copyFrom(*cpuInput); IVectorPtr cpuSequence; generateSequenceStartPositions(batchSize, cpuSequence); IVectorPtr gpuSequence = IVector::create(cpuSequence->getSize(), true); gpuSequence->copyFrom(*cpuSequence); int newBatchSize = cpuSequence->getSize() - 1; MatrixPtr cpuOutput = std::make_shared(newBatchSize, inputDim); MatrixPtr gpuOutput = std::make_shared(newBatchSize, inputDim); cpuOutput->zero(); gpuOutput->zero(); cpuOutput->sequenceAvgForward(*cpuInput, *cpuSequence, mode); gpuOutput->sequenceAvgForward(*gpuInput, *gpuSequence, mode); TensorCheckErr(*cpuOutput, *gpuOutput); } TEST(Matrix, sequenceAvgForward) { for (auto batchSize : {10, 128, 6000}) { for (auto inputDim : {32, 100, 512}) { for (auto mode : {0, 1, 2}) { VLOG(3) << " batchSize=" << batchSize << " inputDim=" << inputDim << " mode=" << mode; testMatrixSequenceAvgForward(batchSize, inputDim, mode); } } } } void testCosSimDerivate(int heightX, int heightY, int width, real scale) { MatrixPtr prevOutX = CpuMatrix::create(heightX, width, false, false); MatrixPtr prevOutY = CpuMatrix::create(heightY, width, false, false); MatrixPtr grad = CpuMatrix::create(heightX, 1, false, false); MatrixPtr output = CpuMatrix::create(heightX, 1, false, false); MatrixPtr prevGradX = CpuMatrix::create(heightX, width, false, false); MatrixPtr prevGradY = CpuMatrix::create(heightY, width, false, false); prevOutX->randomizeUniform(); prevOutY->randomizeUniform(); grad->randomizeUniform(); output->randomizeUniform(); prevGradX->randomizeUniform(); prevGradY->randomizeUniform(); MatrixPtr prevOutXGpu = GpuMatrix::create(heightX, width, false, true); MatrixPtr prevOutYGpu = GpuMatrix::create(heightY, width, false, true); MatrixPtr gradGpu = GpuMatrix::create(heightX, 1, false, true); MatrixPtr outputGpu = GpuMatrix::create(heightX, 1, false, true); MatrixPtr prevGradXGpu = GpuMatrix::create(heightX, width, false, true); MatrixPtr prevGradYGpu = GpuMatrix::create(heightY, width, false, true); prevOutXGpu->copyFrom(*prevOutX); prevOutYGpu->copyFrom(*prevOutY); gradGpu->copyFrom(*grad); outputGpu->copyFrom(*output); prevGradXGpu->copyFrom(*prevGradX); prevGradYGpu->copyFrom(*prevGradY); grad->cosSimDerivative( *output, *prevOutX, *prevOutY, *prevGradX, *prevGradY, scale); gradGpu->cosSimDerivative(*outputGpu, *prevOutXGpu, *prevOutYGpu, *prevGradXGpu, *prevGradYGpu, scale); TensorCheckErr(*prevGradX, *prevGradXGpu); TensorCheckErr(*prevGradY, *prevGradYGpu); } TEST(Matrix, cosSimDerivate) { for (auto heightX : {1, 10, 100}) { for (auto heightY : {1, heightX}) { for (auto width : {1, 10, 100}) { for (auto scale : {1.0, 2.0}) { testCosSimDerivate(heightX, heightY, width, scale); } } } } } void testParamReluBackwardDiff(int height, int width, int w_height, int w_width) { MatrixPtr oGrad = CpuMatrix::create(height, width, false, false); MatrixPtr input = CpuMatrix::create(height, width, false, false); MatrixPtr diff = CpuMatrix::create(height, width, false, false); MatrixPtr w = CpuMatrix::create(w_height, w_width, false, false); oGrad->randomizeUniform(); input->randomizeUniform(); w->randomizeUniform(); diff->randomizeUniform(); input->add(-0.5); MatrixPtr oGradGpu = GpuMatrix::create(height, width, false, true); MatrixPtr inputGpu = GpuMatrix::create(height, width, false, true); MatrixPtr diffGpu = CpuMatrix::create(height, width, false, true); MatrixPtr wGpu = GpuMatrix::create(w_height, w_width, false, true); oGradGpu->copyFrom(*oGrad); inputGpu->copyFrom(*input); wGpu->copyFrom(*w); diffGpu->copyFrom(*diff); diff->paramReluBackwardDiff(*oGrad, *input, *w); diffGpu->paramReluBackwardDiff(*oGradGpu, *inputGpu, *wGpu); TensorCheckErr(*diff, *diffGpu); } TEST(Matrix, paramReluBackwardDiff) { for (auto height : {10, 100}) { for (auto width : {10, 100}) { for (auto w_height : {1, 2}) { for (auto w_width : {1, 2}) { testParamReluBackwardDiff(height, width, w_height, w_width); } } } } } void testClassificationError(int numSamples, int dim) { MatrixPtr cpuError = std::make_shared(numSamples, 1); MatrixPtr gpuError = std::make_shared(numSamples, 1); MatrixPtr cpuOutput = std::make_shared(numSamples, dim); MatrixPtr gpuOutput = std::make_shared(numSamples, dim); IVectorPtr cpuLabel = std::make_shared(numSamples); IVectorPtr gpuLabel = std::make_shared(numSamples); cpuOutput->randomizeUniform(); cpuLabel->rand(dim); gpuOutput->copyFrom(*cpuOutput); gpuLabel->copyFrom(*cpuLabel); cpuError->classificationError(cpuOutput, cpuLabel); gpuError->classificationError(gpuOutput, gpuLabel); TensorCheckEqual(*cpuError, *gpuError); } TEST(Matrix, classificationError) { for (auto numSamples : {1, 10, 100, 1000, 70000}) { for (auto dim : {1, 10, 100, 1000}) { VLOG(3) << " numSamples=" << numSamples << " dim=" << dim; testClassificationError(numSamples, dim); } } } void testMaxPoolFwdBwd(int numSamples, int channels, int imgSizeH, int imgSizeW, int ksizeH, int ksizeW, int strideH, int strideW, int padH, int padW) { int outH = 0, outW = 0; outH = (imgSizeH - ksizeH + 2 * padH + strideH - 1) / strideH + 1; outW = (imgSizeW - ksizeW + 2 * padW + strideW - 1) / strideW + 1; int inWidth = imgSizeH * imgSizeW * channels; MatrixPtr input = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpu = GpuMatrix::create(numSamples, inWidth, false, true); int outWidth = channels * outH * outW; MatrixPtr target = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpu = GpuMatrix::create(numSamples, outWidth, false, true); input->randomizeUniform(); target->randomizeUniform(); inputGpu->copyFrom(*input); targetGpu->copyFrom(*target); target->maxPoolForward(*input, imgSizeH, imgSizeW, channels, ksizeW, ksizeH, strideH, strideW, outH, outW, padH, padW); targetGpu->maxPoolForward(*inputGpu, imgSizeH, imgSizeW, channels, ksizeW, ksizeH, strideH, strideW, outH, outW, padH, padW); MatrixPtr targetCheck = CpuMatrix::create(numSamples, outWidth, false, false); targetCheck->copyFrom(*targetGpu); checkMatrixEqual(target, targetCheck); MatrixPtr inputGrad = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpuGrad = GpuMatrix::create(numSamples, inWidth, false, true); MatrixPtr targetGrad = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpuGrad = GpuMatrix::create(numSamples, outWidth, false, true); inputGrad->randomizeUniform(); targetGrad->randomizeUniform(); inputGpuGrad->copyFrom(*inputGrad); targetGpuGrad->copyFrom(*targetGrad); inputGrad->maxPoolBackward(*input, imgSizeH, imgSizeW, *targetGrad, *target, ksizeW, ksizeH, strideH, strideW, outH, outW, 1.0, 1.0, padH, padW); inputGpuGrad->maxPoolBackward(*inputGpu, imgSizeH, imgSizeW, *targetGpuGrad, *targetGpu, ksizeW, ksizeH, strideH, strideW, outH, outW, 1.0, 1.0, padH, padW); MatrixPtr targetBwdCheck = CpuMatrix::create(numSamples, inWidth, false, false); targetBwdCheck->copyFrom(*inputGpuGrad); checkMatrixEqual(inputGrad, targetBwdCheck); } void testAvgPoolFwdBwd(int numSamples, int channels, int imgSizeH, int imgSizeW, int ksizeH, int ksizeW, int strideH, int strideW, int padH, int padW) { int outH = 0, outW = 0; outH = (imgSizeH - ksizeH + 2 * padH + strideH - 1) / strideH + 1; outW = (imgSizeW - ksizeW + 2 * padW + strideW - 1) / strideW + 1; int inWidth = imgSizeH * imgSizeW * channels; MatrixPtr input = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpu = GpuMatrix::create(numSamples, inWidth, false, true); int outWidth = channels * outH * outW; MatrixPtr target = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpu = GpuMatrix::create(numSamples, outWidth, false, true); input->randomizeUniform(); target->randomizeUniform(); inputGpu->copyFrom(*input); targetGpu->copyFrom(*target); target->avgPoolForward(*input, imgSizeH, imgSizeW, channels, ksizeW, ksizeH, strideH, strideW, outH, outW, padH, padW); targetGpu->avgPoolForward(*inputGpu, imgSizeH, imgSizeW, channels, ksizeW, ksizeH, strideH, strideW, outH, outW, padH, padW); TensorCheckErr(*target, *targetGpu); MatrixPtr inputGrad = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpuGrad = GpuMatrix::create(numSamples, inWidth, false, true); MatrixPtr targetGrad = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpuGrad = GpuMatrix::create(numSamples, outWidth, false, true); inputGrad->randomizeUniform(); targetGrad->randomizeUniform(); inputGpuGrad->copyFrom(*inputGrad); targetGpuGrad->copyFrom(*targetGrad); inputGrad->avgPoolBackward(*targetGrad, imgSizeH, imgSizeW, ksizeW, ksizeH, strideH, strideW, outH, outW, 1.0, 1.0, padH, padW); inputGpuGrad->avgPoolBackward(*targetGpuGrad, imgSizeH, imgSizeW, ksizeW, ksizeH, strideH, strideW, outH, outW, 1.0, 1.0, padH, padW); TensorCheckErr(*inputGrad, *inputGpuGrad); } TEST(Matrix, PoolFwdBwd) { for (auto numSamples : {5, 32}) { for (auto channels : {1, 9, 32}) { for (auto imgSizeH : {14, 28}) { for (auto imgSizeW : {16, 30}) { for (auto sizeX : {2, 5}) { for (auto sizeY : {2, 5}) { for (auto sH : {1, 2}) { for (auto sW : {1, 2}) { for (auto pH : {0, (sizeY - 1) / 2}) { for (auto pW : {0, (sizeX - 1) / 2}) { VLOG(3) << " numSamples=" << numSamples << " channels=" << channels << " imgSizeH=" << imgSizeH << " imgSizeW=" << imgSizeW << " sizeX=" << sizeX << " sizeY=" << sizeY << " strideH=" << sH << " strideW=" << sW << " padingH=" << pH << " padingW=" << pW; testMaxPoolFwdBwd(numSamples, channels, imgSizeH, imgSizeW, sizeX, sizeY, sH, sW, pH, pW); testAvgPoolFwdBwd(numSamples, channels, imgSizeH, imgSizeW, sizeX, sizeY, sH, sW, pH, pW); } } } } } } } } } } } void testMaxOutFwdBwd( int numSamples, int imgSizeH, int imgSizeW, int channels, int groups) { int inWidth = imgSizeH * imgSizeW * channels; int outChannels = channels / groups; int outWidth = imgSizeH * imgSizeW * outChannels; // forward MatrixPtr input = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpu = GpuMatrix::create(numSamples, inWidth, false, true); MatrixPtr target = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpu = GpuMatrix::create(numSamples, outWidth, false, true); IVectorPtr id = CpuIVector::create(numSamples * outWidth, false); IVectorPtr idGpu = GpuIVector::create(numSamples * outWidth, true); input->randomizeUniform(); inputGpu->copyFrom(*input); target->maxoutForward(*input, *id, outChannels, groups); targetGpu->maxoutForward(*inputGpu, *idGpu, outChannels, groups); TensorCheckErr(*target, *targetGpu); TensorCheckEqual(*id, *idGpu); // backward MatrixPtr inputGrad = CpuMatrix::create(numSamples, inWidth, false, false); MatrixPtr inputGpuGrad = GpuMatrix::create(numSamples, inWidth, false, true); MatrixPtr targetGrad = CpuMatrix::create(numSamples, outWidth, false, false); MatrixPtr targetGpuGrad = GpuMatrix::create(numSamples, outWidth, false, true); inputGrad->randomizeUniform(); targetGrad->randomizeUniform(); inputGpuGrad->copyFrom(*inputGrad); targetGpuGrad->copyFrom(*targetGrad); inputGrad->maxoutBackward(*targetGrad, *id, outChannels, groups); inputGpuGrad->maxoutBackward(*targetGpuGrad, *idGpu, outChannels, groups); TensorCheckErr(*inputGrad, *inputGpuGrad); } TEST(Matrix, MaxOutFwdBwd) { for (auto numSamples : {5, 10}) { for (auto channels : {8, 16}) { for (auto imgSizeH : {14, 28}) { for (auto imgSizeW : {16, 30}) { for (auto groups : {2, 4}) { VLOG(3) << " numSamples=" << numSamples << " channels=" << channels << " imgSizeH=" << imgSizeH << " imgSizeW=" << imgSizeW << " groups=" << groups; testMaxOutFwdBwd(numSamples, imgSizeH, imgSizeW, channels, groups); } } } } } } void testCrossMapNormalFwd( int numSamples, int channels, int imgSizeH, int imgSizeW, int sizeX) { float scale = 1.5; float pow = 0.5; int width = imgSizeH * imgSizeW * channels; CpuMatrix inputs(numSamples, width); CpuMatrix denoms(numSamples, width); CpuMatrix outputs(numSamples, width); GpuMatrix inputsGpu(numSamples, width); GpuMatrix denomsGpu(numSamples, width); GpuMatrix outputsGpu(numSamples, width); inputs.randomizeUniform(); outputs.randomizeUniform(); inputsGpu.copyFrom(inputs); outputsGpu.copyFrom(outputs); FuncConfig config; config.set("size", (size_t)sizeX); config.set("scale", scale); config.set("pow", pow); FunctionBase* cpu = FunctionBase::funcRegistrar_.createByType(FUNC_NAME(CrossMapNormal, CPU)); cpu->init(config); // cpu->calc(); CrossMapNormal cpuCross; cpuCross( outputs, denoms, inputs, channels, imgSizeH, imgSizeW, sizeX, scale, pow); CrossMapNormal gpuCross; gpuCross(outputsGpu, denomsGpu, inputsGpu, channels, imgSizeH, imgSizeW, sizeX, scale, pow); TensorCheckErr(outputs, outputsGpu); TensorCheckErr(denoms, denomsGpu); } TEST(Matrix, crossMapNormalFwd) { for (auto numSamples : {5, 32}) { for (auto channels : {1, 5, 32}) { for (auto imgSizeH : {5, 33, 100}) { for (auto imgSizeW : {5, 32, 96}) { for (auto sizeX : {1, 2, 3, 5, 7}) { VLOG(3) << " numSamples=" << numSamples << " channels=" << channels << " imgSizeH=" << imgSizeH << " imgSizeW=" << imgSizeW << " sizeX=" << sizeX; testCrossMapNormalFwd( numSamples, channels, imgSizeH, imgSizeW, sizeX); } } } } } } void testCrossMapNormalBwd( int numSamples, int channels, int imgSizeH, int imgSizeW, int sizeX) { float scale = 1.5; float pow = 0.5; size_t width = imgSizeH * imgSizeW * channels; CpuMatrix inputsGrad(numSamples, width); CpuMatrix inputsValue(numSamples, width); CpuMatrix outputsGrad(numSamples, width); CpuMatrix outputsValue(numSamples, width); CpuMatrix denoms(numSamples, width); outputsGrad.randomizeUniform(); denoms.randomizeUniform(); inputsValue.randomizeUniform(); outputsValue.randomizeUniform(); inputsGrad.randomizeUniform(); denoms.add(0.01); GpuMatrix inputsGradGpu(numSamples, width); GpuMatrix inputsValueGpu(numSamples, width); GpuMatrix outputsGradGpu(numSamples, width); GpuMatrix outputsValueGpu(numSamples, width); GpuMatrix denomsGpu(numSamples, width); outputsGradGpu.copyFrom(outputsGrad); denomsGpu.copyFrom(denoms); inputsValueGpu.copyFrom(inputsValue); outputsValueGpu.copyFrom(outputsValue); inputsGradGpu.copyFrom(inputsGrad); CrossMapNormalGrad cpuCross; cpuCross(inputsGrad, inputsValue, outputsGrad, outputsValue, denoms, channels, imgSizeH, imgSizeW, sizeX, scale, pow); CrossMapNormalGrad gpuCross; gpuCross(inputsGradGpu, inputsValueGpu, outputsGradGpu, outputsValueGpu, denomsGpu, channels, imgSizeH, imgSizeW, sizeX, scale, pow); TensorCheckErr(inputsGrad, inputsGradGpu); } TEST(Matrix, crossMapNormalBwd) { for (auto numSamples : {5, 32}) { for (auto channels : {1, 5, 32}) { for (auto imgSizeH : {5, 33, 100}) { for (auto imgSizeW : {5, 32, 96}) { for (auto sizeX : {1, 2, 3, 5, 7}) { VLOG(3) << " numSamples=" << numSamples << " channels=" << channels << " imgSizeH=" << imgSizeH << " imgSizeW=" << imgSizeW << " sizeX=" << sizeX; testCrossMapNormalBwd( numSamples, channels, imgSizeH, imgSizeW, sizeX); } } } } } } int main(int argc, char** argv) { testing::InitGoogleTest(&argc, argv); initMain(argc, argv); return RUN_ALL_TESTS(); } #endif