system.cpp 34.4 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14
/*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) 2000-2008, Intel Corporation, all rights reserved.
// Copyright (C) 2009, Willow Garage Inc., all rights reserved.
I
Ilya Lavrenov 已提交
15
// Copyright (C) 2015, Itseez Inc., all rights reserved.
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45
// 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 Intel Corporation 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 "precomp.hpp"

46 47 48 49 50 51
#ifdef _MSC_VER
# if _MSC_VER >= 1700
#  pragma warning(disable:4447) // Disable warning 'main' signature found without threading model
# endif
#endif

I
Ilya Lavrenov 已提交
52 53 54 55 56 57 58
#if defined ANDROID || defined __linux__
#  include <unistd.h>
#  include <fcntl.h>
#  include <elf.h>
#  include <linux/auxvec.h>
#endif

59
#if defined WIN32 || defined _WIN32 || defined WINCE
60 61 62 63
#ifndef _WIN32_WINNT           // This is needed for the declaration of TryEnterCriticalSection in winbase.h with Visual Studio 2005 (and older?)
  #define _WIN32_WINNT 0x0400  // http://msdn.microsoft.com/en-us/library/ms686857(VS.85).aspx
#endif
#include <windows.h>
64
#if (_WIN32_WINNT >= 0x0602)
65
  #include <synchapi.h>
66
#endif
67 68 69 70
#undef small
#undef min
#undef max
#undef abs
71 72 73 74
#include <tchar.h>
#if defined _MSC_VER
  #if _MSC_VER >= 1400
    #include <intrin.h>
75
  #elif defined _M_IX86
76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92
    static void __cpuid(int* cpuid_data, int)
    {
        __asm
        {
            push ebx
            push edi
            mov edi, cpuid_data
            mov eax, 1
            cpuid
            mov [edi], eax
            mov [edi + 4], ebx
            mov [edi + 8], ecx
            mov [edi + 12], edx
            pop edi
            pop ebx
        }
    }
I
avx2  
Ilya Lavrenov 已提交
93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108
    static void __cpuidex(int* cpuid_data, int, int)
    {
        __asm
        {
            push edi
            mov edi, cpuid_data
            mov eax, 7
            mov ecx, 0
            cpuid
            mov [edi], eax
            mov [edi + 4], ebx
            mov [edi + 8], ecx
            mov [edi + 12], edx
            pop edi
        }
    }
109 110
  #endif
#endif
111 112 113

#ifdef HAVE_WINRT
#include <wrl/client.h>
G
GregoryMorse 已提交
114 115 116 117
#ifndef __cplusplus_winrt
#include <windows.storage.h>
#pragma comment(lib, "runtimeobject.lib")
#endif
118 119 120

std::wstring GetTempPathWinRT()
{
G
GregoryMorse 已提交
121
#ifdef __cplusplus_winrt
122
    return std::wstring(Windows::Storage::ApplicationData::Current->TemporaryFolder->Path->Data());
G
GregoryMorse 已提交
123 124 125 126 127 128 129 130 131 132 133
#else
    Microsoft::WRL::ComPtr<ABI::Windows::Storage::IApplicationDataStatics> appdataFactory;
    Microsoft::WRL::ComPtr<ABI::Windows::Storage::IApplicationData> appdataRef;
    Microsoft::WRL::ComPtr<ABI::Windows::Storage::IStorageFolder> storagefolderRef;
    Microsoft::WRL::ComPtr<ABI::Windows::Storage::IStorageItem> storageitemRef;
    HSTRING str;
    HSTRING_HEADER hstrHead;
    std::wstring wstr;
    if (FAILED(WindowsCreateStringReference(RuntimeClass_Windows_Storage_ApplicationData,
                                            (UINT32)wcslen(RuntimeClass_Windows_Storage_ApplicationData), &hstrHead, &str)))
        return wstr;
G
GregoryMorse 已提交
134
    if (FAILED(RoGetActivationFactory(str, IID_PPV_ARGS(appdataFactory.ReleaseAndGetAddressOf()))))
G
GregoryMorse 已提交
135 136 137 138 139 140 141 142 143 144 145 146 147 148
        return wstr;
    if (FAILED(appdataFactory->get_Current(appdataRef.ReleaseAndGetAddressOf())))
        return wstr;
    if (FAILED(appdataRef->get_TemporaryFolder(storagefolderRef.ReleaseAndGetAddressOf())))
        return wstr;
    if (FAILED(storagefolderRef.As(&storageitemRef)))
        return wstr;
    str = NULL;
    if (FAILED(storageitemRef->get_Path(&str)))
        return wstr;
    wstr = WindowsGetStringRawBuffer(str, NULL);
    WindowsDeleteString(str);
    return wstr;
#endif
149 150 151 152
}

std::wstring GetTempFileNameWinRT(std::wstring prefix)
{
153 154 155
    wchar_t guidStr[40];
    GUID g;
    CoCreateGuid(&g);
156
    wchar_t* mask = L"%08x_%04x_%04x_%02x%02x_%02x%02x%02x%02x%02x%02x";
157 158 159 160
    swprintf(&guidStr[0], sizeof(guidStr)/sizeof(wchar_t), mask,
             g.Data1, g.Data2, g.Data3, UINT(g.Data4[0]), UINT(g.Data4[1]),
             UINT(g.Data4[2]), UINT(g.Data4[3]), UINT(g.Data4[4]),
             UINT(g.Data4[5]), UINT(g.Data4[6]), UINT(g.Data4[7]));
161 162 163 164 165

    return prefix + std::wstring(guidStr);
}

#endif
166 167 168 169 170
#else
#include <pthread.h>
#include <sys/time.h>
#include <time.h>

171
#if defined __MACH__ && defined __APPLE__
172 173 174 175 176 177 178 179 180 181 182 183
#include <mach/mach.h>
#include <mach/mach_time.h>
#endif

#endif

#ifdef _OPENMP
#include "omp.h"
#endif

#include <stdarg.h>

184
#if defined __linux__ || defined __APPLE__ || defined __EMSCRIPTEN__
185 186
#include <unistd.h>
#include <stdio.h>
187
#include <sys/types.h>
A
Andrey Kamaev 已提交
188 189
#if defined ANDROID
#include <sys/sysconf.h>
190
#endif
A
Andrey Kamaev 已提交
191
#endif
192

193 194 195 196
#ifdef ANDROID
# include <android/log.h>
#endif

197 198 199
namespace cv
{

200 201
Exception::Exception() { code = 0; line = 0; }

202
Exception::Exception(int _code, const String& _err, const String& _func, const String& _file, int _line)
203 204 205 206 207 208 209 210 211
: code(_code), err(_err), func(_func), file(_file), line(_line)
{
    formatMessage();
}

Exception::~Exception() throw() {}

/*!
 \return the error description and the context as a text string.
212
 */
213 214 215 216 217 218 219 220 221
const char* Exception::what() const throw() { return msg.c_str(); }

void Exception::formatMessage()
{
    if( func.size() > 0 )
        msg = format("%s:%d: error: (%d) %s in function %s\n", file.c_str(), line, code, err.c_str(), func.c_str());
    else
        msg = format("%s:%d: error: (%d) %s\n", file.c_str(), line, code, err.c_str());
}
222

223 224 225
struct HWFeatures
{
    enum { MAX_FEATURE = CV_HARDWARE_MAX_FEATURE };
226 227

    HWFeatures(void)
I
avx2  
Ilya Lavrenov 已提交
228
    {
229 230 231
        memset( have, 0, sizeof(have) );
        x86_family = 0;
    }
232 233

    static HWFeatures initialize(void)
234 235
    {
        HWFeatures f;
236 237
        int cpuid_data[4] = { 0, 0, 0, 0 };

238 239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259 260 261 262
    #if defined _MSC_VER && (defined _M_IX86 || defined _M_X64)
        __cpuid(cpuid_data, 1);
    #elif defined __GNUC__ && (defined __i386__ || defined __x86_64__)
        #ifdef __x86_64__
        asm __volatile__
        (
         "movl $1, %%eax\n\t"
         "cpuid\n\t"
         :[eax]"=a"(cpuid_data[0]),[ebx]"=b"(cpuid_data[1]),[ecx]"=c"(cpuid_data[2]),[edx]"=d"(cpuid_data[3])
         :
         : "cc"
        );
        #else
        asm volatile
        (
         "pushl %%ebx\n\t"
         "movl $1,%%eax\n\t"
         "cpuid\n\t"
         "popl %%ebx\n\t"
         : "=a"(cpuid_data[0]), "=c"(cpuid_data[2]), "=d"(cpuid_data[3])
         :
         : "cc"
        );
        #endif
    #endif
263

264 265 266
        f.x86_family = (cpuid_data[0] >> 8) & 15;
        if( f.x86_family >= 6 )
        {
267 268 269 270 271
            f.have[CV_CPU_MMX]    = (cpuid_data[3] & (1 << 23)) != 0;
            f.have[CV_CPU_SSE]    = (cpuid_data[3] & (1<<25)) != 0;
            f.have[CV_CPU_SSE2]   = (cpuid_data[3] & (1<<26)) != 0;
            f.have[CV_CPU_SSE3]   = (cpuid_data[2] & (1<<0)) != 0;
            f.have[CV_CPU_SSSE3]  = (cpuid_data[2] & (1<<9)) != 0;
I
Ilya Lavrenov 已提交
272
            f.have[CV_CPU_FMA3]  = (cpuid_data[2] & (1<<12)) != 0;
273 274
            f.have[CV_CPU_SSE4_1] = (cpuid_data[2] & (1<<19)) != 0;
            f.have[CV_CPU_SSE4_2] = (cpuid_data[2] & (1<<20)) != 0;
275
            f.have[CV_CPU_POPCNT] = (cpuid_data[2] & (1<<23)) != 0;
276
            f.have[CV_CPU_AVX]    = (((cpuid_data[2] & (1<<28)) != 0)&&((cpuid_data[2] & (1<<27)) != 0));//OS uses XSAVE_XRSTORE and CPU support AVX
I
avx2  
Ilya Lavrenov 已提交
277 278 279 280 281 282 283 284 285 286 287 288 289 290 291 292 293 294 295

            // make the second call to the cpuid command in order to get
            // information about extended features like AVX2
        #if defined _MSC_VER && (defined _M_IX86 || defined _M_X64)
            __cpuidex(cpuid_data, 7, 0);
        #elif defined __GNUC__ && (defined __i386__ || defined __x86_64__)
            #ifdef __x86_64__
            asm __volatile__
            (
             "movl $7, %%eax\n\t"
             "movl $0, %%ecx\n\t"
             "cpuid\n\t"
             :[eax]"=a"(cpuid_data[0]),[ebx]"=b"(cpuid_data[1]),[ecx]"=c"(cpuid_data[2]),[edx]"=d"(cpuid_data[3])
             :
             : "cc"
            );
            #else
            asm volatile
            (
I
Ilya Lavrenov 已提交
296
             "pushl %%ebx\n\t"
I
avx2  
Ilya Lavrenov 已提交
297 298 299
             "movl $7,%%eax\n\t"
             "movl $0,%%ecx\n\t"
             "cpuid\n\t"
I
Ilya Lavrenov 已提交
300 301 302
             "movl %%ebx, %0\n\t"
             "popl %%ebx\n\t"
             : "=r"(cpuid_data[1]), "=c"(cpuid_data[2])
I
avx2  
Ilya Lavrenov 已提交
303 304 305 306 307 308 309
             :
             : "cc"
            );
            #endif
        #endif
            f.have[CV_CPU_AVX2]   = (cpuid_data[1] & (1<<5)) != 0;

I
Ilya Lavrenov 已提交
310 311 312 313 314 315 316 317 318
            f.have[CV_CPU_AVX_512F]       = (cpuid_data[1] & (1<<16)) != 0;
            f.have[CV_CPU_AVX_512DQ]      = (cpuid_data[1] & (1<<17)) != 0;
            f.have[CV_CPU_AVX_512IFMA512] = (cpuid_data[1] & (1<<21)) != 0;
            f.have[CV_CPU_AVX_512PF]      = (cpuid_data[1] & (1<<26)) != 0;
            f.have[CV_CPU_AVX_512ER]      = (cpuid_data[1] & (1<<27)) != 0;
            f.have[CV_CPU_AVX_512CD]      = (cpuid_data[1] & (1<<28)) != 0;
            f.have[CV_CPU_AVX_512BW]      = (cpuid_data[1] & (1<<30)) != 0;
            f.have[CV_CPU_AVX_512VL]      = (cpuid_data[1] & (1<<31)) != 0;
            f.have[CV_CPU_AVX_512VBMI]    = (cpuid_data[2] &  (1<<1)) != 0;
319
        }
320

I
Ilya Lavrenov 已提交
321
    #if defined ANDROID || defined __linux__
I
Ilya Lavrenov 已提交
322 323 324
    #ifdef __aarch64__
        f.have[CV_CPU_NEON] = true;
    #else
I
Ilya Lavrenov 已提交
325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342
        int cpufile = open("/proc/self/auxv", O_RDONLY);

        if (cpufile >= 0)
        {
            Elf32_auxv_t auxv;
            const size_t size_auxv_t = sizeof(Elf32_auxv_t);

            while (read(cpufile, &auxv, sizeof(Elf32_auxv_t)) == size_auxv_t)
            {
                if (auxv.a_type == AT_HWCAP)
                {
                    f.have[CV_CPU_NEON] = (auxv.a_un.a_val & 4096) != 0;
                    break;
                }
            }

            close(cpufile);
        }
I
Ilya Lavrenov 已提交
343 344
    #endif
    #elif (defined __clang__ || defined __APPLE__) && (defined __ARM_NEON__ || (defined __ARM_NEON && defined __aarch64__))
I
Ilya Lavrenov 已提交
345 346 347
        f.have[CV_CPU_NEON] = true;
    #endif

348 349
        return f;
    }
350

351 352 353
    int x86_family;
    bool have[MAX_FEATURE+1];
};
354 355

static HWFeatures  featuresEnabled = HWFeatures::initialize(), featuresDisabled = HWFeatures();
356 357 358 359 360 361 362 363 364
static HWFeatures* currentFeatures = &featuresEnabled;

bool checkHardwareSupport(int feature)
{
    CV_DbgAssert( 0 <= feature && feature <= CV_HARDWARE_MAX_FEATURE );
    return currentFeatures->have[feature];
}


365 366
volatile bool useOptimizedFlag = true;
#ifdef HAVE_IPP
367 368
struct IPPInitializer
{
A
Alexander Alekhin 已提交
369 370 371 372 373 374 375 376
    IPPInitializer(void)
    {
#if IPP_VERSION_MAJOR >= 8
        ippInit();
#else
        ippStaticInit();
#endif
    }
377 378 379 380 381
};

IPPInitializer ippInitializer;
#endif

382
volatile bool USE_SSE2 = featuresEnabled.have[CV_CPU_SSE2];
383 384
volatile bool USE_SSE4_2 = featuresEnabled.have[CV_CPU_SSE4_2];
volatile bool USE_AVX = featuresEnabled.have[CV_CPU_AVX];
I
avx2  
Ilya Lavrenov 已提交
385
volatile bool USE_AVX2 = featuresEnabled.have[CV_CPU_AVX2];
386

387 388 389 390
void setUseOptimized( bool flag )
{
    useOptimizedFlag = flag;
    currentFeatures = flag ? &featuresEnabled : &featuresDisabled;
391
    USE_SSE2 = currentFeatures->have[CV_CPU_SSE2];
392 393 394 395 396 397

    ipp::setUseIPP(flag);
    ocl::setUseOpenCL(flag);
#ifdef HAVE_TEGRA_OPTIMIZATION
    ::tegra::setUseTegra(flag);
#endif
398 399
}

400
bool useOptimized(void)
401 402 403
{
    return useOptimizedFlag;
}
404 405

int64 getTickCount(void)
406
{
407
#if defined WIN32 || defined _WIN32 || defined WINCE
408 409 410 411 412 413 414
    LARGE_INTEGER counter;
    QueryPerformanceCounter( &counter );
    return (int64)counter.QuadPart;
#elif defined __linux || defined __linux__
    struct timespec tp;
    clock_gettime(CLOCK_MONOTONIC, &tp);
    return (int64)tp.tv_sec*1000000000 + tp.tv_nsec;
415
#elif defined __MACH__ && defined __APPLE__
416
    return (int64)mach_absolute_time();
417
#else
418 419 420 421 422 423 424
    struct timeval tv;
    struct timezone tz;
    gettimeofday( &tv, &tz );
    return (int64)tv.tv_sec*1000000 + tv.tv_usec;
#endif
}

425
double getTickFrequency(void)
426
{
427
#if defined WIN32 || defined _WIN32 || defined WINCE
428 429 430 431 432
    LARGE_INTEGER freq;
    QueryPerformanceFrequency(&freq);
    return (double)freq.QuadPart;
#elif defined __linux || defined __linux__
    return 1e9;
433
#elif defined __MACH__ && defined __APPLE__
434 435 436 437 438 439 440
    static double freq = 0;
    if( freq == 0 )
    {
        mach_timebase_info_data_t sTimebaseInfo;
        mach_timebase_info(&sTimebaseInfo);
        freq = sTimebaseInfo.denom*1e9/sTimebaseInfo.numer;
    }
441
    return freq;
442 443 444 445 446
#else
    return 1e6;
#endif
}

447
#if defined __GNUC__ && (defined __i386__ || defined __x86_64__ || defined __ppc__)
448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468
#if defined(__i386__)

int64 getCPUTickCount(void)
{
    int64 x;
    __asm__ volatile (".byte 0x0f, 0x31" : "=A" (x));
    return x;
}
#elif defined(__x86_64__)

int64 getCPUTickCount(void)
{
    unsigned hi, lo;
    __asm__ __volatile__ ("rdtsc" : "=a"(lo), "=d"(hi));
    return (int64)lo | ((int64)hi << 32);
}

#elif defined(__ppc__)

int64 getCPUTickCount(void)
{
469
    int64 result = 0;
470 471 472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488
    unsigned upper, lower, tmp;
    __asm__ volatile(
                     "0:                  \n"
                     "\tmftbu   %0           \n"
                     "\tmftb    %1           \n"
                     "\tmftbu   %2           \n"
                     "\tcmpw    %2,%0        \n"
                     "\tbne     0b         \n"
                     : "=r"(upper),"=r"(lower),"=r"(tmp)
                     );
    return lower | ((int64)upper << 32);
}

#else

#error "RDTSC not defined"

#endif

489
#elif defined _MSC_VER && defined WIN32 && defined _M_IX86
490 491 492 493 494 495 496 497 498

int64 getCPUTickCount(void)
{
    __asm _emit 0x0f;
    __asm _emit 0x31;
}

#else

V
vbystricky 已提交
499 500 501 502 503 504
//#ifdef HAVE_IPP
//int64 getCPUTickCount(void)
//{
//    return ippGetCpuClocks();
//}
//#else
505
int64 getCPUTickCount(void)
506 507 508
{
    return getTickCount();
}
V
vbystricky 已提交
509
//#endif
510 511 512

#endif

513
const String& getBuildInformation()
514
{
515
    static String build_info =
516 517 518 519 520
#include "version_string.inc"
    ;
    return build_info;
}

521
String format( const char* fmt, ... )
522
{
I
Ilya Lavrenov 已提交
523
    AutoBuffer<char, 1024> buf;
524

I
Ilya Lavrenov 已提交
525
    for ( ; ; )
526
    {
I
Ilya Lavrenov 已提交
527
        va_list va;
528
        va_start(va, fmt);
I
Ilya Lavrenov 已提交
529 530
        int bsize = static_cast<int>(buf.size()),
                len = vsnprintf((char *)buf, bsize, fmt, va);
531 532
        va_end(va);

I
Ilya Lavrenov 已提交
533 534 535 536 537 538 539
        if (len < 0 || len >= bsize)
        {
            buf.resize(std::max(bsize << 1, len + 1));
            continue;
        }
        return String((char *)buf, len);
    }
540 541
}

542
String tempfile( const char* suffix )
543
{
544
    String fname;
G
GregoryMorse 已提交
545 546
#ifndef HAVE_WINRT
    const char *temp_dir = getenv("OPENCV_TEMP_PATH");
547
#endif
548

549
#if defined WIN32 || defined _WIN32
550 551
#ifdef HAVE_WINRT
    RoInitialize(RO_INIT_MULTITHREADED);
G
GregoryMorse 已提交
552 553 554 555
    std::wstring temp_dir = L"";
    const wchar_t* opencv_temp_dir = GetTempPathWinRT().c_str();
    if (opencv_temp_dir)
        temp_dir = std::wstring(opencv_temp_dir);
556 557 558 559

    std::wstring temp_file;
    temp_file = GetTempFileNameWinRT(L"ocv");
    if (temp_file.empty())
G
GregoryMorse 已提交
560
        return String();
561 562 563 564

    temp_file = temp_dir + std::wstring(L"\\") + temp_file;
    DeleteFileW(temp_file.c_str());

565 566 567
    char aname[MAX_PATH];
    size_t copied = wcstombs(aname, temp_file.c_str(), MAX_PATH);
    CV_Assert((copied != MAX_PATH) && (copied != (size_t)-1));
G
GregoryMorse 已提交
568
    fname = String(aname);
569 570
    RoUninitialize();
#else
571 572
    char temp_dir2[MAX_PATH] = { 0 };
    char temp_file[MAX_PATH] = { 0 };
573

574 575 576 577 578
    if (temp_dir == 0 || temp_dir[0] == 0)
    {
        ::GetTempPathA(sizeof(temp_dir2), temp_dir2);
        temp_dir = temp_dir2;
    }
579
    if(0 == ::GetTempFileNameA(temp_dir, "ocv", 0, temp_file))
580
        return String();
581

R
Roy Reapor 已提交
582 583
    DeleteFileA(temp_file);

584
    fname = temp_file;
585
#endif
586 587 588 589 590 591 592 593
# else
#  ifdef ANDROID
    //char defaultTemplate[] = "/mnt/sdcard/__opencv_temp.XXXXXX";
    char defaultTemplate[] = "/data/local/tmp/__opencv_temp.XXXXXX";
#  else
    char defaultTemplate[] = "/tmp/__opencv_temp.XXXXXX";
#  endif

594
    if (temp_dir == 0 || temp_dir[0] == 0)
595 596 597 598 599 600
        fname = defaultTemplate;
    else
    {
        fname = temp_dir;
        char ech = fname[fname.size() - 1];
        if(ech != '/' && ech != '\\')
601 602
            fname = fname + "/";
        fname = fname + "__opencv_temp.XXXXXX";
603 604 605
    }

    const int fd = mkstemp((char*)fname.c_str());
606
    if (fd == -1) return String();
607

608 609
    close(fd);
    remove(fname.c_str());
610
# endif
611

612
    if (suffix)
613 614
    {
        if (suffix[0] != '.')
615
            return fname + "." + suffix;
616
        else
617
            return fname + suffix;
618 619
    }
    return fname;
620 621
}

622 623 624 625 626 627 628 629 630
static CvErrorCallback customErrorCallback = 0;
static void* customErrorCallbackData = 0;
static bool breakOnError = false;

bool setBreakOnError(bool value)
{
    bool prevVal = breakOnError;
    breakOnError = value;
    return prevVal;
631
}
632 633 634

void error( const Exception& exc )
{
635
    if (customErrorCallback != 0)
636 637 638 639 640 641 642 643 644 645 646 647
        customErrorCallback(exc.code, exc.func.c_str(), exc.err.c_str(),
                            exc.file.c_str(), exc.line, customErrorCallbackData);
    else
    {
        const char* errorStr = cvErrorStr(exc.code);
        char buf[1 << 16];

        sprintf( buf, "OpenCV Error: %s (%s) in %s, file %s, line %d",
            errorStr, exc.err.c_str(), exc.func.size() > 0 ?
            exc.func.c_str() : "unknown function", exc.file.c_str(), exc.line );
        fprintf( stderr, "%s\n", buf );
        fflush( stderr );
648
#  ifdef __ANDROID__
649 650
        __android_log_print(ANDROID_LOG_ERROR, "cv::error()", "%s", buf);
#  endif
651
    }
652

653 654 655 656 657
    if(breakOnError)
    {
        static volatile int* p = 0;
        *p = 0;
    }
658

659 660
    throw exc;
}
661

662 663 664 665 666
void error(int _code, const String& _err, const char* _func, const char* _file, int _line)
{
    error(cv::Exception(_code, _err, _func, _file, _line));
}

667 668 669 670 671
CvErrorCallback
redirectError( CvErrorCallback errCallback, void* userdata, void** prevUserdata)
{
    if( prevUserdata )
        *prevUserdata = customErrorCallbackData;
672

673
    CvErrorCallback prevCallback = customErrorCallback;
674 675

    customErrorCallback     = errCallback;
676
    customErrorCallbackData = userdata;
677

678 679
    return prevCallback;
}
680

681 682 683 684 685 686 687 688 689 690 691 692 693 694 695 696 697 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 717 718 719 720 721 722 723 724 725 726 727 728 729 730 731 732 733 734 735 736 737 738 739 740 741
}

CV_IMPL int cvCheckHardwareSupport(int feature)
{
    CV_DbgAssert( 0 <= feature && feature <= CV_HARDWARE_MAX_FEATURE );
    return cv::currentFeatures->have[feature];
}

CV_IMPL int cvUseOptimized( int flag )
{
    int prevMode = cv::useOptimizedFlag;
    cv::setUseOptimized( flag != 0 );
    return prevMode;
}

CV_IMPL int64  cvGetTickCount(void)
{
    return cv::getTickCount();
}

CV_IMPL double cvGetTickFrequency(void)
{
    return cv::getTickFrequency()*1e-6;
}

CV_IMPL CvErrorCallback
cvRedirectError( CvErrorCallback errCallback, void* userdata, void** prevUserdata)
{
    return cv::redirectError(errCallback, userdata, prevUserdata);
}

CV_IMPL int cvNulDevReport( int, const char*, const char*,
                            const char*, int, void* )
{
    return 0;
}

CV_IMPL int cvStdErrReport( int, const char*, const char*,
                            const char*, int, void* )
{
    return 0;
}

CV_IMPL int cvGuiBoxReport( int, const char*, const char*,
                            const char*, int, void* )
{
    return 0;
}

CV_IMPL int cvGetErrInfo( const char**, const char**, const char**, int* )
{
    return 0;
}


CV_IMPL const char* cvErrorStr( int status )
{
    static char buf[256];

    switch (status)
    {
742 743 744 745 746 747 748 749 750 751 752 753
    case CV_StsOk :                  return "No Error";
    case CV_StsBackTrace :           return "Backtrace";
    case CV_StsError :               return "Unspecified error";
    case CV_StsInternal :            return "Internal error";
    case CV_StsNoMem :               return "Insufficient memory";
    case CV_StsBadArg :              return "Bad argument";
    case CV_StsNoConv :              return "Iterations do not converge";
    case CV_StsAutoTrace :           return "Autotrace call";
    case CV_StsBadSize :             return "Incorrect size of input array";
    case CV_StsNullPtr :             return "Null pointer";
    case CV_StsDivByZero :           return "Division by zero occured";
    case CV_BadStep :                return "Image step is wrong";
754 755
    case CV_StsInplaceNotSupported : return "Inplace operation is not supported";
    case CV_StsObjectNotFound :      return "Requested object was not found";
756 757 758 759 760 761 762 763 764 765 766 767 768 769
    case CV_BadDepth :               return "Input image depth is not supported by function";
    case CV_StsUnmatchedFormats :    return "Formats of input arguments do not match";
    case CV_StsUnmatchedSizes :      return "Sizes of input arguments do not match";
    case CV_StsOutOfRange :          return "One of arguments\' values is out of range";
    case CV_StsUnsupportedFormat :   return "Unsupported format or combination of formats";
    case CV_BadCOI :                 return "Input COI is not supported";
    case CV_BadNumChannels :         return "Bad number of channels";
    case CV_StsBadFlag :             return "Bad flag (parameter or structure field)";
    case CV_StsBadPoint :            return "Bad parameter of type CvPoint";
    case CV_StsBadMask :             return "Bad type of mask argument";
    case CV_StsParseError :          return "Parsing error";
    case CV_StsNotImplemented :      return "The function/feature is not implemented";
    case CV_StsBadMemBlock :         return "Memory block has been corrupted";
    case CV_StsAssert :              return "Assertion failed";
V
Vladislav Vinogradov 已提交
770
    case CV_GpuNotSupported :        return "No CUDA support";
771 772 773
    case CV_GpuApiCallError :        return "Gpu API call";
    case CV_OpenGlNotSupported :     return "No OpenGL support";
    case CV_OpenGlApiCallError :     return "OpenGL API call";
774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789
    };

    sprintf(buf, "Unknown %s code %d", status >= 0 ? "status":"error", status);
    return buf;
}

CV_IMPL int cvGetErrMode(void)
{
    return 0;
}

CV_IMPL int cvSetErrMode(int)
{
    return 0;
}

790
CV_IMPL int cvGetErrStatus(void)
791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812
{
    return 0;
}

CV_IMPL void cvSetErrStatus(int)
{
}


CV_IMPL void cvError( int code, const char* func_name,
                      const char* err_msg,
                      const char* file_name, int line )
{
    cv::error(cv::Exception(code, err_msg, func_name, file_name, line));
}

/* function, which converts int to int */
CV_IMPL int
cvErrorFromIppStatus( int status )
{
    switch (status)
    {
813 814 815 816 817 818 819 820
    case CV_BADSIZE_ERR:               return CV_StsBadSize;
    case CV_BADMEMBLOCK_ERR:           return CV_StsBadMemBlock;
    case CV_NULLPTR_ERR:               return CV_StsNullPtr;
    case CV_DIV_BY_ZERO_ERR:           return CV_StsDivByZero;
    case CV_BADSTEP_ERR:               return CV_BadStep;
    case CV_OUTOFMEM_ERR:              return CV_StsNoMem;
    case CV_BADARG_ERR:                return CV_StsBadArg;
    case CV_NOTDEFINED_ERR:            return CV_StsError;
821
    case CV_INPLACE_NOT_SUPPORTED_ERR: return CV_StsInplaceNotSupported;
822 823 824 825 826 827 828 829 830 831 832 833 834 835
    case CV_NOTFOUND_ERR:              return CV_StsObjectNotFound;
    case CV_BADCONVERGENCE_ERR:        return CV_StsNoConv;
    case CV_BADDEPTH_ERR:              return CV_BadDepth;
    case CV_UNMATCHED_FORMATS_ERR:     return CV_StsUnmatchedFormats;
    case CV_UNSUPPORTED_COI_ERR:       return CV_BadCOI;
    case CV_UNSUPPORTED_CHANNELS_ERR:  return CV_BadNumChannels;
    case CV_BADFLAG_ERR:               return CV_StsBadFlag;
    case CV_BADRANGE_ERR:              return CV_StsBadArg;
    case CV_BADCOEF_ERR:               return CV_StsBadArg;
    case CV_BADFACTOR_ERR:             return CV_StsBadArg;
    case CV_BADPOINT_ERR:              return CV_StsBadPoint;

    default:
      return CV_StsError;
836 837 838
    }
}

839 840 841
namespace cv {
bool __termination = false;
}
842

843 844 845 846 847 848 849
namespace cv
{

#if defined WIN32 || defined _WIN32 || defined WINCE

struct Mutex::Impl
{
850 851 852 853 854 855 856 857 858
    Impl()
    {
#if (_WIN32_WINNT >= 0x0600)
        ::InitializeCriticalSectionEx(&cs, 1000, 0);
#else
        ::InitializeCriticalSection(&cs);
#endif
        refcount = 1;
    }
859
    ~Impl() { DeleteCriticalSection(&cs); }
860

861 862 863
    void lock() { EnterCriticalSection(&cs); }
    bool trylock() { return TryEnterCriticalSection(&cs) != 0; }
    void unlock() { LeaveCriticalSection(&cs); }
864

865 866 867
    CRITICAL_SECTION cs;
    int refcount;
};
868

869 870 871 872
#else

struct Mutex::Impl
{
I
Ilya Lavrenov 已提交
873 874 875 876 877 878 879 880 881 882 883
    Impl()
    {
        pthread_mutexattr_t attr;
        pthread_mutexattr_init(&attr);
        pthread_mutexattr_settype(&attr, PTHREAD_MUTEX_RECURSIVE);
        pthread_mutex_init(&mt, &attr);
        pthread_mutexattr_destroy(&attr);

        refcount = 1;
    }
    ~Impl() { pthread_mutex_destroy(&mt); }
884

I
Ilya Lavrenov 已提交
885 886 887
    void lock() { pthread_mutex_lock(&mt); }
    bool trylock() { return pthread_mutex_trylock(&mt) == 0; }
    void unlock() { pthread_mutex_unlock(&mt); }
888

I
Ilya Lavrenov 已提交
889
    pthread_mutex_t mt;
890 891 892 893 894 895 896 897 898
    int refcount;
};

#endif

Mutex::Mutex()
{
    impl = new Mutex::Impl;
}
899

900 901 902 903 904 905
Mutex::~Mutex()
{
    if( CV_XADD(&impl->refcount, -1) == 1 )
        delete impl;
    impl = 0;
}
906

907 908 909 910 911 912 913 914 915 916 917 918 919 920
Mutex::Mutex(const Mutex& m)
{
    impl = m.impl;
    CV_XADD(&impl->refcount, 1);
}

Mutex& Mutex::operator = (const Mutex& m)
{
    CV_XADD(&m.impl->refcount, 1);
    if( CV_XADD(&impl->refcount, -1) == 1 )
        delete impl;
    impl = m.impl;
    return *this;
}
921

922 923
void Mutex::lock() { impl->lock(); }
void Mutex::unlock() { impl->unlock(); }
924
bool Mutex::trylock() { return impl->trylock(); }
925

A
Alexander Alekhin 已提交
926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953

//////////////////////////////// thread-local storage ////////////////////////////////

class TLSStorage
{
    std::vector<void*> tlsData_;
public:
    TLSStorage() { tlsData_.reserve(16); }
    ~TLSStorage();
    inline void* getData(int key) const
    {
        CV_DbgAssert(key >= 0);
        return (key < (int)tlsData_.size()) ? tlsData_[key] : NULL;
    }
    inline void setData(int key, void* data)
    {
        CV_DbgAssert(key >= 0);
        if (key >= (int)tlsData_.size())
        {
            tlsData_.resize(key + 1, NULL);
        }
        tlsData_[key] = data;
    }

    inline static TLSStorage* get();
};

#ifdef WIN32
A
Alexander Alekhin 已提交
954
#ifdef _MSC_VER
A
Alexander Alekhin 已提交
955
#pragma warning(disable:4505) // unreferenced local function has been removed
A
Alexander Alekhin 已提交
956
#endif
A
Alexander Alekhin 已提交
957 958 959 960 961 962 963 964 965 966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989 990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015

#ifdef HAVE_WINRT
    // using C++11 thread attribute for local thread data
    static __declspec( thread ) TLSStorage* g_tlsdata = NULL;

    static void deleteThreadData()
    {
        if (g_tlsdata)
        {
            delete g_tlsdata;
            g_tlsdata = NULL;
        }
    }

    inline TLSStorage* TLSStorage::get()
    {
        if (!g_tlsdata)
        {
            g_tlsdata = new TLSStorage;
        }
        return g_tlsdata;
    }
#else
#ifdef WINCE
#   define TLS_OUT_OF_INDEXES ((DWORD)0xFFFFFFFF)
#endif
    static DWORD tlsKey = TLS_OUT_OF_INDEXES;

    static void deleteThreadData()
    {
        if(tlsKey != TLS_OUT_OF_INDEXES)
        {
            delete (TLSStorage*)TlsGetValue(tlsKey);
            TlsSetValue(tlsKey, NULL);
        }
    }

    inline TLSStorage* TLSStorage::get()
    {
        if (tlsKey == TLS_OUT_OF_INDEXES)
        {
            tlsKey = TlsAlloc();
            CV_Assert(tlsKey != TLS_OUT_OF_INDEXES);
        }
        TLSStorage* d = (TLSStorage*)TlsGetValue(tlsKey);
        if (!d)
        {
            d = new TLSStorage;
            TlsSetValue(tlsKey, d);
        }
        return d;
    }
#endif //HAVE_WINRT

#if defined CVAPI_EXPORTS && defined WIN32 && !defined WINCE
#ifdef HAVE_WINRT
    #pragma warning(disable:4447) // Disable warning 'main' signature found without threading model
#endif

1016
extern "C"
1017
BOOL WINAPI DllMain(HINSTANCE, DWORD fdwReason, LPVOID lpReserved)
A
Alexander Alekhin 已提交
1018 1019 1020
{
    if (fdwReason == DLL_THREAD_DETACH || fdwReason == DLL_PROCESS_DETACH)
    {
1021
        if (lpReserved != NULL) // called after ExitProcess() call
1022
        {
1023
            cv::__termination = true;
1024 1025 1026 1027 1028 1029 1030 1031
        }
        else
        {
            // Not allowed to free resources if lpReserved is non-null
            // http://msdn.microsoft.com/en-us/library/windows/desktop/ms682583.aspx
            cv::deleteThreadAllocData();
            cv::deleteThreadData();
        }
A
Alexander Alekhin 已提交
1032 1033
    }
    return TRUE;
1034
}
A
Alexander Alekhin 已提交
1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067 1068 1069 1070 1071 1072 1073 1074 1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087 1088 1089 1090 1091 1092 1093 1094 1095 1096 1097 1098 1099 1100 1101 1102 1103 1104 1105 1106 1107 1108 1109
#endif

#else
    static pthread_key_t tlsKey = 0;
    static pthread_once_t tlsKeyOnce = PTHREAD_ONCE_INIT;

    static void deleteTLSStorage(void* data)
    {
        delete (TLSStorage*)data;
    }

    static void makeKey()
    {
        int errcode = pthread_key_create(&tlsKey, deleteTLSStorage);
        CV_Assert(errcode == 0);
    }

    inline TLSStorage* TLSStorage::get()
    {
        pthread_once(&tlsKeyOnce, makeKey);
        TLSStorage* d = (TLSStorage*)pthread_getspecific(tlsKey);
        if( !d )
        {
            d = new TLSStorage;
            pthread_setspecific(tlsKey, d);
        }
        return d;
    }
#endif

class TLSContainerStorage
{
    cv::Mutex mutex_;
    std::vector<TLSDataContainer*> tlsContainers_;
public:
    TLSContainerStorage() { }
    ~TLSContainerStorage()
    {
        for (size_t i = 0; i < tlsContainers_.size(); i++)
        {
            CV_DbgAssert(tlsContainers_[i] == NULL); // not all keys released
            tlsContainers_[i] = NULL;
        }
    }

    int allocateKey(TLSDataContainer* pContainer)
    {
        cv::AutoLock lock(mutex_);
        tlsContainers_.push_back(pContainer);
        return (int)tlsContainers_.size() - 1;
    }
    void releaseKey(int id, TLSDataContainer* pContainer)
    {
        cv::AutoLock lock(mutex_);
        CV_Assert(tlsContainers_[id] == pContainer);
        tlsContainers_[id] = NULL;
        // currently, we don't go into thread's TLSData and release data for this key
    }

    void destroyData(int key, void* data)
    {
        cv::AutoLock lock(mutex_);
        TLSDataContainer* k = tlsContainers_[key];
        if (!k)
            return;
        try
        {
            k->deleteDataInstance(data);
        }
        catch (...)
        {
            CV_DbgAssert(k == NULL); // Debug this!
        }
    }
};
1110 1111 1112 1113 1114 1115 1116 1117

// This is a wrapper function that will ensure 'tlsContainerStorage' is constructed on first use.
// For more information: http://www.parashift.com/c++-faq/static-init-order-on-first-use.html
static TLSContainerStorage& getTLSContainerStorage()
{
    static TLSContainerStorage *tlsContainerStorage = new TLSContainerStorage();
    return *tlsContainerStorage;
}
A
Alexander Alekhin 已提交
1118 1119 1120 1121

TLSDataContainer::TLSDataContainer()
    : key_(-1)
{
1122
    key_ = getTLSContainerStorage().allocateKey(this);
1123 1124
}

A
Alexander Alekhin 已提交
1125 1126
TLSDataContainer::~TLSDataContainer()
{
1127
    getTLSContainerStorage().releaseKey(key_, this);
A
Alexander Alekhin 已提交
1128 1129 1130 1131 1132 1133 1134 1135 1136 1137 1138 1139 1140 1141 1142 1143 1144 1145 1146 1147 1148 1149 1150 1151
    key_ = -1;
}

void* TLSDataContainer::getData() const
{
    CV_Assert(key_ >= 0);
    TLSStorage* tlsData = TLSStorage::get();
    void* data = tlsData->getData(key_);
    if (!data)
    {
        data = this->createDataInstance();
        CV_DbgAssert(data != NULL);
        tlsData->setData(key_, data);
    }
    return data;
}

TLSStorage::~TLSStorage()
{
    for (int i = 0; i < (int)tlsData_.size(); i++)
    {
        void*& data = tlsData_[i];
        if (data)
        {
1152
            getTLSContainerStorage().destroyData(i, data);
A
Alexander Alekhin 已提交
1153 1154 1155 1156 1157 1158
            data = NULL;
        }
    }
    tlsData_.clear();
}

1159 1160 1161 1162 1163 1164 1165 1166 1167


TLSData<CoreTLSData>& getCoreTlsData()
{
    static TLSData<CoreTLSData> *value = new TLSData<CoreTLSData>();
    return *value;
}


1168

1169 1170 1171
#ifdef CV_COLLECT_IMPL_DATA
void setImpl(int flags)
{
1172
    CoreTLSData* data = getCoreTlsData().get();
1173 1174 1175 1176 1177 1178 1179
    data->implFlags = flags;
    data->implCode.clear();
    data->implFun.clear();
}

void addImpl(int flag, const char* func)
{
1180
    CoreTLSData* data = getCoreTlsData().get();
1181 1182 1183 1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194
    data->implFlags |= flag;
    if(func) // use lazy collection if name was not specified
    {
        size_t index = data->implCode.size();
        if(!index || (data->implCode[index-1] != flag || data->implFun[index-1].compare(func))) // avoid duplicates
        {
            data->implCode.push_back(flag);
            data->implFun.push_back(func);
        }
    }
}

int getImpl(std::vector<int> &impl, std::vector<String> &funName)
{
1195
    CoreTLSData* data = getCoreTlsData().get();
1196 1197 1198 1199 1200 1201 1202
    impl = data->implCode;
    funName = data->implFun;
    return data->implFlags; // return actual flags for lazy collection
}

bool useCollection()
{
1203
    CoreTLSData* data = getCoreTlsData().get();
1204 1205 1206 1207 1208
    return data->useCollection;
}

void setUseCollection(bool flag)
{
1209
    CoreTLSData* data = getCoreTlsData().get();
1210 1211 1212 1213
    data->useCollection = flag;
}
#endif

I
Ilya Lavrenov 已提交
1214 1215 1216
namespace ipp
{

I
Ilya Lavrenov 已提交
1217
static int ippStatus = 0; // 0 - all is ok, -1 - IPP functions failed
I
Ilya Lavrenov 已提交
1218 1219
static const char * funcname = NULL, * filename = NULL;
static int linen = 0;
I
Ilya Lavrenov 已提交
1220 1221

void setIppStatus(int status, const char * const _funcname, const char * const _filename, int _line)
I
Ilya Lavrenov 已提交
1222
{
I
Ilya Lavrenov 已提交
1223 1224 1225 1226
    ippStatus = status;
    funcname = _funcname;
    filename = _filename;
    linen = _line;
I
Ilya Lavrenov 已提交
1227 1228 1229 1230
}

int getIppStatus()
{
I
Ilya Lavrenov 已提交
1231 1232 1233 1234 1235 1236
    return ippStatus;
}

String getIppErrorLocation()
{
    return format("%s:%d %s", filename ? filename : "", linen, funcname ? funcname : "");
I
Ilya Lavrenov 已提交
1237 1238
}

1239 1240 1241
bool useIPP()
{
#ifdef HAVE_IPP
1242
    CoreTLSData* data = getCoreTlsData().get();
1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253 1254 1255 1256 1257 1258
    if(data->useIPP < 0)
    {
        const char* pIppEnv = getenv("OPENCV_IPP");
        if(pIppEnv && (cv::String(pIppEnv) == "disabled"))
            data->useIPP = false;
        else
            data->useIPP = true;
    }
    return (data->useIPP > 0);
#else
    return false;
#endif
}

void setUseIPP(bool flag)
{
1259
    CoreTLSData* data = getCoreTlsData().get();
1260 1261 1262 1263 1264 1265 1266 1267
#ifdef HAVE_IPP
    data->useIPP = flag;
#else
    (void)flag;
    data->useIPP = false;
#endif
}

I
Ilya Lavrenov 已提交
1268 1269
} // namespace ipp

1270 1271
} // namespace cv

1272 1273 1274 1275 1276 1277
#ifdef HAVE_TEGRA_OPTIMIZATION

namespace tegra {

bool useTegra()
{
1278
    cv::CoreTLSData* data = cv::getCoreTlsData().get();
1279 1280 1281 1282 1283 1284 1285 1286 1287 1288 1289 1290 1291 1292 1293

    if (data->useTegra < 0)
    {
        const char* pTegraEnv = getenv("OPENCV_TEGRA");
        if (pTegraEnv && (cv::String(pTegraEnv) == "disabled"))
            data->useTegra = false;
        else
            data->useTegra = true;
    }

    return (data->useTegra > 0);
}

void setUseTegra(bool flag)
{
1294
    cv::CoreTLSData* data = cv::getCoreTlsData().get();
1295 1296 1297 1298 1299 1300 1301
    data->useTegra = flag;
}

} // namespace tegra

#endif

1302
/* End of file. */