blob: 885a325f8d628495279cf1cc9cce450cae57abeb (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
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
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*
* Copyright 2011 Google Inc.
*
* Use of this source code is governed by a BSD-style license that can be
* found in the LICENSE file.
*/
#include "SkThread.h"
#include <pthread.h>
#include <errno.h>
/**
We prefer the GCC intrinsic implementation of the atomic operations over the
SkMutex-based implementation. The SkMutex version suffers from static
destructor ordering problems.
Note clang also defines the GCC version macros and implements the intrinsics.
TODO: Verify that gcc-style __sync_* intrinsics work on ARM
According to this the intrinsics are supported on ARM in LLVM 2.7+
http://llvm.org/releases/2.7/docs/ReleaseNotes.html
*/
#if (__GNUC__ == 4 && __GNUC_MINOR__ >= 1) || __GNUC__ > 4
#if (defined(__x86_64) || defined(__i386__))
#define GCC_INTRINSIC
#endif
#endif
#if defined(GCC_INTRINSIC)
int32_t sk_atomic_inc(int32_t* addr)
{
return __sync_fetch_and_add(addr, 1);
}
int32_t sk_atomic_dec(int32_t* addr)
{
return __sync_fetch_and_add(addr, -1);
}
#else
SkMutex gAtomicMutex;
int32_t sk_atomic_inc(int32_t* addr)
{
SkAutoMutexAcquire ac(gAtomicMutex);
int32_t value = *addr;
*addr = value + 1;
return value;
}
int32_t sk_atomic_dec(int32_t* addr)
{
SkAutoMutexAcquire ac(gAtomicMutex);
int32_t value = *addr;
*addr = value - 1;
return value;
}
#endif
//////////////////////////////////////////////////////////////////////////////
static void print_pthread_error(int status)
{
switch (status) {
case 0: // success
break;
case EINVAL:
printf("pthread error [%d] EINVAL\n", status);
break;
case EBUSY:
printf("pthread error [%d] EBUSY\n", status);
break;
default:
printf("pthread error [%d] unknown\n", status);
break;
}
}
SkMutex::SkMutex(bool isGlobal) : fIsGlobal(isGlobal)
{
if (sizeof(pthread_mutex_t) > sizeof(fStorage))
{
SkDEBUGF(("pthread mutex size = %d\n", sizeof(pthread_mutex_t)));
SkASSERT(!"mutex storage is too small");
}
int status;
pthread_mutexattr_t attr;
status = pthread_mutexattr_init(&attr);
print_pthread_error(status);
SkASSERT(0 == status);
status = pthread_mutex_init((pthread_mutex_t*)fStorage, &attr);
print_pthread_error(status);
SkASSERT(0 == status);
}
SkMutex::~SkMutex()
{
int status = pthread_mutex_destroy((pthread_mutex_t*)fStorage);
// only report errors on non-global mutexes
if (!fIsGlobal)
{
print_pthread_error(status);
SkASSERT(0 == status);
}
}
void SkMutex::acquire()
{
int status = pthread_mutex_lock((pthread_mutex_t*)fStorage);
print_pthread_error(status);
SkASSERT(0 == status);
}
void SkMutex::release()
{
int status = pthread_mutex_unlock((pthread_mutex_t*)fStorage);
print_pthread_error(status);
SkASSERT(0 == status);
}
|
