OLD | NEW |
| (Empty) |
1 diff --git a/source/common/udata.cpp b/source/common/udata.cpp | |
2 index e6d8a35..80bea06 100644 | |
3 --- a/source/common/udata.cpp | |
4 +++ b/source/common/udata.cpp | |
5 @@ -1,7 +1,7 @@ | |
6 /* | |
7 ****************************************************************************** | |
8 * | |
9 -* Copyright (C) 1999-2014, International Business Machines | |
10 +* Copyright (C) 1999-2015, International Business Machines | |
11 * Corporation and others. All Rights Reserved. | |
12 * | |
13 ****************************************************************************** | |
14 @@ -29,6 +29,7 @@ might have to #include some other header | |
15 #include "charstr.h" | |
16 #include "cmemory.h" | |
17 #include "cstring.h" | |
18 +#include "mutex.h" | |
19 #include "putilimp.h" | |
20 #include "uassert.h" | |
21 #include "ucln_cmn.h" | |
22 @@ -100,14 +101,15 @@ static UDataMemory *udata_findCachedData(const char *path)
; | |
23 * that they really need, reducing the size of binaries that take advantage | |
24 * of this. | |
25 */ | |
26 -static UDataMemory *gCommonICUDataArray[10] = { NULL }; | |
27 +static UDataMemory *gCommonICUDataArray[10] = { NULL }; // Access protected b
y icu global mutex. | |
28 | |
29 -static UBool gHaveTriedToLoadCommonData = FALSE; /* See extendICUData(). */ | |
30 +static u_atomic_int32_t gHaveTriedToLoadCommonData = ATOMIC_INT32_T_INITIALIZER
(0); // See extendICUData(). | |
31 | |
32 static UHashtable *gCommonDataCache = NULL; /* Global hash table of opened IC
U data files. */ | |
33 static icu::UInitOnce gCommonDataCacheInitOnce = U_INITONCE_INITIALIZER; | |
34 | |
35 -static UDataFileAccess gDataFileAccess = UDATA_DEFAULT_ACCESS; | |
36 +static UDataFileAccess gDataFileAccess = UDATA_DEFAULT_ACCESS; // Access not
synchronized. | |
37 + // Modifying i
s documented as thread-unsafe. | |
38 | |
39 static UBool U_CALLCONV | |
40 udata_cleanup(void) | |
41 @@ -124,7 +126,7 @@ udata_cleanup(void) | |
42 udata_close(gCommonICUDataArray[i]); | |
43 gCommonICUDataArray[i] = NULL; | |
44 } | |
45 - gHaveTriedToLoadCommonData = FALSE; | |
46 + gHaveTriedToLoadCommonData = 0; | |
47 | |
48 return TRUE; /* Everything was cleaned up */ | |
49 } | |
50 @@ -139,14 +141,16 @@ findCommonICUDataByName(const char *inBasename) | |
51 if (pData == NULL) | |
52 return FALSE; | |
53 | |
54 - for (i = 0; i < UPRV_LENGTHOF(gCommonICUDataArray); ++i) { | |
55 - if ((gCommonICUDataArray[i] != NULL) && (gCommonICUDataArray[i]->pHeade
r == pData->pHeader)) { | |
56 - /* The data pointer is already in the array. */ | |
57 - found = TRUE; | |
58 - break; | |
59 + { | |
60 + Mutex lock; | |
61 + for (i = 0; i < UPRV_LENGTHOF(gCommonICUDataArray); ++i) { | |
62 + if ((gCommonICUDataArray[i] != NULL) && (gCommonICUDataArray[i]->pH
eader == pData->pHeader)) { | |
63 + /* The data pointer is already in the array. */ | |
64 + found = TRUE; | |
65 + break; | |
66 + } | |
67 } | |
68 } | |
69 - | |
70 return found; | |
71 } | |
72 | |
73 @@ -663,7 +667,11 @@ openCommonData(const char *path, /* Path from Ope
nChoice? */ | |
74 if(commonDataIndex >= UPRV_LENGTHOF(gCommonICUDataArray)) { | |
75 return NULL; | |
76 } | |
77 - if(gCommonICUDataArray[commonDataIndex] == NULL) { | |
78 + { | |
79 + Mutex lock; | |
80 + if(gCommonICUDataArray[commonDataIndex] != NULL) { | |
81 + return gCommonICUDataArray[commonDataIndex]; | |
82 + } | |
83 int32_t i; | |
84 for(i = 0; i < commonDataIndex; ++i) { | |
85 if(gCommonICUDataArray[i]->pHeader == &U_ICUDATA_ENTRY_POINT.hd
r) { | |
86 @@ -671,23 +679,26 @@ openCommonData(const char *path, /* Path from Op
enChoice? */ | |
87 return NULL; | |
88 } | |
89 } | |
90 + } | |
91 | |
92 - /* Add the linked-in data to the list. */ | |
93 - /* | |
94 - * This is where we would check and call weakly linked partial-data
-library | |
95 - * access functions. | |
96 - */ | |
97 - /* | |
98 - if (uprv_getICUData_collation) { | |
99 - setCommonICUDataPointer(uprv_getICUData_collation(), FALSE, pEr
rorCode); | |
100 - } | |
101 - if (uprv_getICUData_conversion) { | |
102 - setCommonICUDataPointer(uprv_getICUData_conversion(), FALSE, pE
rrorCode); | |
103 - } | |
104 - */ | |
105 - setCommonICUDataPointer(&U_ICUDATA_ENTRY_POINT.hdr, FALSE, pErrorCo
de); | |
106 + /* Add the linked-in data to the list. */ | |
107 + /* | |
108 + * This is where we would check and call weakly linked partial-data-lib
rary | |
109 + * access functions. | |
110 + */ | |
111 + /* | |
112 + if (uprv_getICUData_collation) { | |
113 + setCommonICUDataPointer(uprv_getICUData_collation(), FALSE, pErrorC
ode); | |
114 + } | |
115 + if (uprv_getICUData_conversion) { | |
116 + setCommonICUDataPointer(uprv_getICUData_conversion(), FALSE, pError
Code); | |
117 + } | |
118 + */ | |
119 + setCommonICUDataPointer(&U_ICUDATA_ENTRY_POINT.hdr, FALSE, pErrorCode); | |
120 + { | |
121 + Mutex lock; | |
122 + return gCommonICUDataArray[commonDataIndex]; | |
123 } | |
124 - return gCommonICUDataArray[commonDataIndex]; | |
125 } | |
126 | |
127 | |
128 @@ -795,7 +806,7 @@ static UBool extendICUData(UErrorCode *pErr) | |
129 static UMutex extendICUDataMutex = U_MUTEX_INITIALIZER; | |
130 umtx_lock(&extendICUDataMutex); | |
131 #endif | |
132 - if(!gHaveTriedToLoadCommonData) { | |
133 + if(!umtx_loadAcquire(gHaveTriedToLoadCommonData)) { | |
134 /* See if we can explicitly open a .dat file for the ICUData. */ | |
135 pData = openCommonData( | |
136 U_ICUDATA_NAME, /* "icudt20l" , for example.
*/ | |
137 @@ -820,7 +831,7 @@ static UBool extendICUData(UErrorCode *pErr) | |
138 pErr); /* setCommonICUData honors errors; N
OP if error set */ | |
139 } | |
140 | |
141 - gHaveTriedToLoadCommonData = TRUE; | |
142 + umtx_storeRelease(gHaveTriedToLoadCommonData, 1); | |
143 } | |
144 | |
145 didUpdate = findCommonICUDataByName(U_ICUDATA_NAME); /* Return 'true' when
a racing writes out the extended */ | |
146 @@ -1398,5 +1409,6 @@ udata_getInfo(UDataMemory *pData, UDataInfo *pInfo) { | |
147 | |
148 U_CAPI void U_EXPORT2 udata_setFileAccess(UDataFileAccess access, UErrorCode *
/*status*/) | |
149 { | |
150 + // Note: this function is documented as not thread safe. | |
151 gDataFileAccess = access; | |
152 } | |
OLD | NEW |