/*M/////////////////////////////////////////////////////////////////////////////////////// // // IMPORTANT: READ BEFORE DOWNLOADING, COPYING, INSTALLING OR USING. // // By downloading, copying, installing or using the software you agree to this license. // If you do not agree to this license, do not download, install, // copy or use the software. // // // License Agreement // For Open Source Computer Vision Library // // Copyright (C) 2013, OpenCV Foundation, all rights reserved. // Third party copyrights are property of their respective owners. // // Redistribution and use in source and binary forms, with or without modification, // are permitted provided that the following conditions are met: // // * Redistribution's of source code must retain the above copyright notice, // this list of conditions and the following disclaimer. // // * Redistribution's in binary form must reproduce the above copyright notice, // this list of conditions and the following disclaimer in the documentation // and/or other materials provided with the distribution. // // * The name of the copyright holders may not be used to endorse or promote products // derived from this software without specific prior written permission. // // This software is provided by the copyright holders and contributors "as is" and // any express or implied warranties, including, but not limited to, the implied // warranties of merchantability and fitness for a particular purpose are disclaimed. // In no event shall the OpenCV Foundation or contributors be liable for any direct, // indirect, incidental, special, exemplary, or consequential damages // (including, but not limited to, procurement of substitute goods or services; // loss of use, data, or profits; or business interruption) however caused // and on any theory of liability, whether in contract, strict liability, // or tort (including negligence or otherwise) arising in any way out of // the use of this software, even if advised of the possibility of such damage. // //M*/ #include "test_precomp.hpp" #include "opencv2/ts/ocl_test.hpp" using namespace cvtest; using namespace testing; using namespace cv; namespace cvtest { namespace ocl { #define UMAT_TEST_SIZES testing::Values(cv::Size(1, 1), cv::Size(1,128), cv::Size(128, 1), \ cv::Size(128, 128), cv::Size(640, 480), cv::Size(751, 373), cv::Size(1200, 1200)) /////////////////////////////// Basic Tests //////////////////////////////// PARAM_TEST_CASE(UMatBasicTests, int, int, Size, bool) { Mat a; UMat ua; int type; int depth; int cn; Size size; bool useRoi; Size roi_size; Rect roi; virtual void SetUp() { depth = GET_PARAM(0); cn = GET_PARAM(1); size = GET_PARAM(2); useRoi = GET_PARAM(3); type = CV_MAKE_TYPE(depth, cn); a = randomMat(size, type, -100, 100); a.copyTo(ua); int roi_shift_x = randomInt(0, size.width-1); int roi_shift_y = randomInt(0, size.height-1); roi_size = Size(size.width - roi_shift_x, size.height - roi_shift_y); roi = Rect(roi_shift_x, roi_shift_y, roi_size.width, roi_size.height); } }; TEST_P(UMatBasicTests, createUMat) { if(useRoi) { ua = UMat(ua, roi); } int dims = randomInt(2,6); int _sz[CV_MAX_DIM]; for( int i = 0; igetBufferPoolController(); if (c) { size_t oldMaxReservedSize = c->getMaxReservedSize(); c->freeAllReservedBuffers(); c->setMaxReservedSize(sz.area() * 10); for (int i = 0; i < ITERATIONS; i++) { UMat um(Size(sz.width + i, sz.height + i), CV_8UC1); UMat um2(Size(sz.width + 2 * i, sz.height + 2 * i), CV_8UC1); } c->setMaxReservedSize(oldMaxReservedSize); c->freeAllReservedBuffers(); } else std::cout << "Skipped, no OpenCL" << std::endl; } class CV_UMatTest : public cvtest::BaseTest { public: CV_UMatTest() {} ~CV_UMatTest() {} protected: void run(int); struct test_excep { test_excep(const string& _s=string("")) : s(_s) { } string s; }; bool TestUMat(); void checkDiff(const Mat& m1, const Mat& m2, const string& s) { if (cvtest::norm(m1, m2, NORM_INF) != 0) throw test_excep(s); } void checkDiffF(const Mat& m1, const Mat& m2, const string& s) { if (cvtest::norm(m1, m2, NORM_INF) > 1e-5) throw test_excep(s); } }; #define STR(a) STR2(a) #define STR2(a) #a #define CHECK_DIFF(a, b) checkDiff(a, b, "(" #a ") != (" #b ") at l." STR(__LINE__)) #define CHECK_DIFF_FLT(a, b) checkDiffF(a, b, "(" #a ") !=(eps) (" #b ") at l." STR(__LINE__)) bool CV_UMatTest::TestUMat() { try { Mat a(100, 100, CV_16SC2), b, c; randu(a, Scalar::all(-100), Scalar::all(100)); Rect roi(1, 3, 5, 4); Mat ra(a, roi), rb, rc, rc0; UMat ua, ura, ub, urb, uc, urc; a.copyTo(ua); ua.copyTo(b); CHECK_DIFF(a, b); ura = ua(roi); ura.copyTo(rb); CHECK_DIFF(ra, rb); ra += Scalar::all(1.f); { Mat temp = ura.getMat(ACCESS_RW); temp += Scalar::all(1.f); } ra.copyTo(rb); CHECK_DIFF(ra, rb); b = a.clone(); ra = a(roi); rb = b(roi); randu(b, Scalar::all(-100), Scalar::all(100)); b.copyTo(ub); urb = ub(roi); /*std::cout << "==============================================\nbefore op (CPU):\n"; std::cout << "ra: " << ra << std::endl; std::cout << "rb: " << rb << std::endl;*/ ra.copyTo(ura); rb.copyTo(urb); ra.release(); rb.release(); ura.copyTo(ra); urb.copyTo(rb); /*std::cout << "==============================================\nbefore op (GPU):\n"; std::cout << "ra: " << ra << std::endl; std::cout << "rb: " << rb << std::endl;*/ cv::max(ra, rb, rc); cv::max(ura, urb, urc); urc.copyTo(rc0); /*std::cout << "==============================================\nafter op:\n"; std::cout << "rc: " << rc << std::endl; std::cout << "rc0: " << rc0 << std::endl;*/ CHECK_DIFF(rc0, rc); { UMat tmp = rc0.getUMat(ACCESS_WRITE); cv::max(ura, urb, tmp); } CHECK_DIFF(rc0, rc); ura.copyTo(urc); cv::max(urc, urb, urc); urc.copyTo(rc0); CHECK_DIFF(rc0, rc); rc = ra ^ rb; cv::bitwise_xor(ura, urb, urc); urc.copyTo(rc0); /*std::cout << "==============================================\nafter op:\n"; std::cout << "ra: " << rc0 << std::endl; std::cout << "rc: " << rc << std::endl;*/ CHECK_DIFF(rc0, rc); rc = ra + rb; cv::add(ura, urb, urc); urc.copyTo(rc0); CHECK_DIFF(rc0, rc); cv::subtract(ra, Scalar::all(5), rc); cv::subtract(ura, Scalar::all(5), urc); urc.copyTo(rc0); CHECK_DIFF(rc0, rc); } catch (const test_excep& e) { ts->printf(cvtest::TS::LOG, "%s\n", e.s.c_str()); ts->set_failed_test_info(cvtest::TS::FAIL_MISMATCH); return false; } return true; } void CV_UMatTest::run( int /* start_from */) { printf("Use OpenCL: %s\nHave OpenCL: %s\n", cv::ocl::useOpenCL() ? "TRUE" : "FALSE", cv::ocl::haveOpenCL() ? "TRUE" : "FALSE" ); if (!TestUMat()) return; ts->set_failed_test_info(cvtest::TS::OK); } TEST(Core_UMat, base) { CV_UMatTest test; test.safe_run(); } TEST(Core_UMat, getUMat) { { int a[3] = { 1, 2, 3 }; Mat m = Mat(1, 1, CV_32SC3, a); UMat u = m.getUMat(ACCESS_READ); EXPECT_NE((void*)NULL, u.u); } { Mat m(10, 10, CV_8UC1), ref; for (int y = 0; y < m.rows; ++y) { uchar * const ptr = m.ptr(y); for (int x = 0; x < m.cols; ++x) ptr[x] = (uchar)(x + y * 2); } ref = m.clone(); Rect r(1, 1, 8, 8); ref(r).setTo(17); { UMat um = m(r).getUMat(ACCESS_WRITE); um.setTo(17); } double err = cvtest::norm(m, ref, NORM_INF); if (err > 0) { std::cout << "m: " << std::endl << m << std::endl; std::cout << "ref: " << std::endl << ref << std::endl; } EXPECT_EQ(0., err); } } TEST(UMat, Sync) { UMat um(10, 10, CV_8UC1); { Mat m = um.getMat(ACCESS_WRITE); m.setTo(cv::Scalar::all(17)); } um.setTo(cv::Scalar::all(19)); EXPECT_EQ(0, cvtest::norm(um.getMat(ACCESS_READ), cv::Mat(um.size(), um.type(), 19), NORM_INF)); } TEST(UMat, setOpenCL) { // save the current state bool useOCL = cv::ocl::useOpenCL(); Mat m = (Mat_(3,3)<<0,1,2,3,4,5,6,7,8); cv::ocl::setUseOpenCL(true); UMat um1; m.copyTo(um1); cv::ocl::setUseOpenCL(false); UMat um2; m.copyTo(um2); cv::ocl::setUseOpenCL(true); countNonZero(um1); countNonZero(um2); um1.copyTo(um2); EXPECT_MAT_NEAR(um1, um2, 0); EXPECT_MAT_NEAR(um1, m, 0); um2.copyTo(um1); EXPECT_MAT_NEAR(um1, m, 0); EXPECT_MAT_NEAR(um1, um2, 0); cv::ocl::setUseOpenCL(false); countNonZero(um1); countNonZero(um2); um1.copyTo(um2); EXPECT_MAT_NEAR(um1, um2, 0); EXPECT_MAT_NEAR(um1, m, 0); um2.copyTo(um1); EXPECT_MAT_NEAR(um1, um2, 0); EXPECT_MAT_NEAR(um1, m, 0); // reset state to the previous one cv::ocl::setUseOpenCL(useOCL); } TEST(UMat, ReadBufferRect) { UMat m(1, 10000, CV_32FC2, Scalar::all(-1)); Mat t(1, 9000, CV_32FC2, Scalar::all(-200)), t2(1, 9000, CV_32FC2, Scalar::all(-1)); m.colRange(0, 9000).copyTo(t); EXPECT_MAT_NEAR(t, t2, 0); } // Use iGPU or OPENCV_OPENCL_DEVICE=:CPU: to catch problem TEST(UMat, DISABLED_synchronization_map_unmap) { class TestParallelLoopBody : public cv::ParallelLoopBody { UMat u_; public: TestParallelLoopBody(const UMat& u) : u_(u) { } void operator() (const cv::Range& range) const { printf("range: %d, %d -- begin\n", range.start, range.end); for (int i = 0; i < 10; i++) { printf("%d: %d map...\n", range.start, i); Mat m = u_.getMat(cv::ACCESS_READ); printf("%d: %d unmap...\n", range.start, i); m.release(); } printf("range: %d, %d -- end\n", range.start, range.end); } }; try { UMat u(1000, 1000, CV_32FC1); parallel_for_(cv::Range(0, 2), TestParallelLoopBody(u)); } catch (const cv::Exception& e) { FAIL() << "Exception: " << e.what(); ADD_FAILURE(); } catch (...) { FAIL() << "Exception!"; } } } } // namespace cvtest::ocl TEST(UMat, DISABLED_bug_with_unmap) { for (int i = 0; i < 20; i++) { try { Mat m = Mat(1000, 1000, CV_8UC1); UMat u = m.getUMat(ACCESS_READ); UMat dst; add(u, Scalar::all(0), dst); // start async operation u.release(); m.release(); } catch (const cv::Exception& e) { printf("i = %d... %s\n", i, e.what()); ADD_FAILURE(); } catch (...) { printf("i = %d...\n", i); ADD_FAILURE(); } } } TEST(UMat, DISABLED_bug_with_unmap_in_class) { class Logic { public: Logic() {} void processData(InputArray input) { Mat m = input.getMat(); { Mat dst; m.convertTo(dst, CV_32FC1); // some additional CPU-based per-pixel processing into dst intermediateResult = dst.getUMat(ACCESS_READ); std::cout << "data processed..." << std::endl; } // problem is here: dst::~Mat() std::cout << "leave ProcessData()" << std::endl; } UMat getResult() const { return intermediateResult; } protected: UMat intermediateResult; }; try { Mat m = Mat(1000, 1000, CV_8UC1); Logic l; l.processData(m); UMat result = l.getResult(); } catch (const cv::Exception& e) { printf("exception... %s\n", e.what()); ADD_FAILURE(); } catch (...) { printf("exception... \n"); ADD_FAILURE(); } } TEST(UMat, Test_same_behaviour_read_and_read) { bool exceptionDetected = false; try { UMat u(Size(10, 10), CV_8UC1); Mat m = u.getMat(ACCESS_READ); UMat dst; add(u, Scalar::all(1), dst); } catch (...) { exceptionDetected = true; } ASSERT_FALSE(exceptionDetected); // no data race, 2+ reads are valid } // VP: this test (and probably others from same_behaviour series) is not valid in my opinion. TEST(UMat, DISABLED_Test_same_behaviour_read_and_write) { bool exceptionDetected = false; try { UMat u(Size(10, 10), CV_8UC1); Mat m = u.getMat(ACCESS_READ); add(u, Scalar::all(1), u); } catch (...) { exceptionDetected = true; } ASSERT_TRUE(exceptionDetected); // data race } TEST(UMat, DISABLED_Test_same_behaviour_write_and_read) { bool exceptionDetected = false; try { UMat u(Size(10, 10), CV_8UC1); Mat m = u.getMat(ACCESS_WRITE); UMat dst; add(u, Scalar::all(1), dst); } catch (...) { exceptionDetected = true; } ASSERT_TRUE(exceptionDetected); // data race } TEST(UMat, DISABLED_Test_same_behaviour_write_and_write) { bool exceptionDetected = false; try { UMat u(Size(10, 10), CV_8UC1); Mat m = u.getMat(ACCESS_WRITE); add(u, Scalar::all(1), u); } catch (...) { exceptionDetected = true; } ASSERT_TRUE(exceptionDetected); // data race }