| 1 | // © 2016 and later: Unicode, Inc. and others. |
| 2 | // License & terms of use: http://www.unicode.org/copyright.html |
| 3 | /* |
| 4 | ******************************************************************************* |
| 5 | * Copyright (C) 2007-2014, International Business Machines Corporation and |
| 6 | * others. All Rights Reserved. |
| 7 | ******************************************************************************* |
| 8 | */ |
| 9 | |
| 10 | #include "unicode/utypes.h" |
| 11 | |
| 12 | #if !UCONFIG_NO_FORMATTING |
| 13 | |
| 14 | #include "zonemeta.h" |
| 15 | |
| 16 | #include "unicode/timezone.h" |
| 17 | #include "unicode/ustring.h" |
| 18 | #include "unicode/putil.h" |
| 19 | #include "unicode/simpletz.h" |
| 20 | #include "unicode/strenum.h" |
| 21 | #include "umutex.h" |
| 22 | #include "uvector.h" |
| 23 | #include "cmemory.h" |
| 24 | #include "gregoimp.h" |
| 25 | #include "cstring.h" |
| 26 | #include "ucln_in.h" |
| 27 | #include "uassert.h" |
| 28 | #include "uresimp.h" |
| 29 | #include "uhash.h" |
| 30 | #include "olsontz.h" |
| 31 | #include "uinvchar.h" |
| 32 | |
| 33 | static icu::UMutex gZoneMetaLock; |
| 34 | |
| 35 | // CLDR Canonical ID mapping table |
| 36 | static UHashtable *gCanonicalIDCache = NULL; |
| 37 | static icu::UInitOnce gCanonicalIDCacheInitOnce = U_INITONCE_INITIALIZER; |
| 38 | |
| 39 | // Metazone mapping table |
| 40 | static UHashtable *gOlsonToMeta = NULL; |
| 41 | static icu::UInitOnce gOlsonToMetaInitOnce = U_INITONCE_INITIALIZER; |
| 42 | |
| 43 | // Available metazone IDs vector and table |
| 44 | static icu::UVector *gMetaZoneIDs = NULL; |
| 45 | static UHashtable *gMetaZoneIDTable = NULL; |
| 46 | static icu::UInitOnce gMetaZoneIDsInitOnce = U_INITONCE_INITIALIZER; |
| 47 | |
| 48 | // Country info vectors |
| 49 | static icu::UVector *gSingleZoneCountries = NULL; |
| 50 | static icu::UVector *gMultiZonesCountries = NULL; |
| 51 | static icu::UInitOnce gCountryInfoVectorsInitOnce = U_INITONCE_INITIALIZER; |
| 52 | |
| 53 | U_CDECL_BEGIN |
| 54 | |
| 55 | /** |
| 56 | * Cleanup callback func |
| 57 | */ |
| 58 | static UBool U_CALLCONV zoneMeta_cleanup(void) |
| 59 | { |
| 60 | if (gCanonicalIDCache != NULL) { |
| 61 | uhash_close(gCanonicalIDCache); |
| 62 | gCanonicalIDCache = NULL; |
| 63 | } |
| 64 | gCanonicalIDCacheInitOnce.reset(); |
| 65 | |
| 66 | if (gOlsonToMeta != NULL) { |
| 67 | uhash_close(gOlsonToMeta); |
| 68 | gOlsonToMeta = NULL; |
| 69 | } |
| 70 | gOlsonToMetaInitOnce.reset(); |
| 71 | |
| 72 | if (gMetaZoneIDTable != NULL) { |
| 73 | uhash_close(gMetaZoneIDTable); |
| 74 | gMetaZoneIDTable = NULL; |
| 75 | } |
| 76 | // delete after closing gMetaZoneIDTable, because it holds |
| 77 | // value objects held by the hashtable |
| 78 | delete gMetaZoneIDs; |
| 79 | gMetaZoneIDs = NULL; |
| 80 | gMetaZoneIDsInitOnce.reset(); |
| 81 | |
| 82 | delete gSingleZoneCountries; |
| 83 | gSingleZoneCountries = NULL; |
| 84 | delete gMultiZonesCountries; |
| 85 | gMultiZonesCountries = NULL; |
| 86 | gCountryInfoVectorsInitOnce.reset(); |
| 87 | |
| 88 | return TRUE; |
| 89 | } |
| 90 | |
| 91 | /** |
| 92 | * Deleter for UChar* string |
| 93 | */ |
| 94 | static void U_CALLCONV |
| 95 | deleteUCharString(void *obj) { |
| 96 | UChar *entry = (UChar*)obj; |
| 97 | uprv_free(entry); |
| 98 | } |
| 99 | |
| 100 | /** |
| 101 | * Deleter for UVector |
| 102 | */ |
| 103 | static void U_CALLCONV |
| 104 | deleteUVector(void *obj) { |
| 105 | delete (icu::UVector*) obj; |
| 106 | } |
| 107 | |
| 108 | /** |
| 109 | * Deleter for OlsonToMetaMappingEntry |
| 110 | */ |
| 111 | static void U_CALLCONV |
| 112 | deleteOlsonToMetaMappingEntry(void *obj) { |
| 113 | icu::OlsonToMetaMappingEntry *entry = (icu::OlsonToMetaMappingEntry*)obj; |
| 114 | uprv_free(entry); |
| 115 | } |
| 116 | |
| 117 | U_CDECL_END |
| 118 | |
| 119 | U_NAMESPACE_BEGIN |
| 120 | |
| 121 | #define ZID_KEY_MAX 128 |
| 122 | |
| 123 | static const char gMetaZones[] = "metaZones" ; |
| 124 | static const char gMetazoneInfo[] = "metazoneInfo" ; |
| 125 | static const char gMapTimezonesTag[] = "mapTimezones" ; |
| 126 | |
| 127 | static const char gKeyTypeData[] = "keyTypeData" ; |
| 128 | static const char gTypeAliasTag[] = "typeAlias" ; |
| 129 | static const char gTypeMapTag[] = "typeMap" ; |
| 130 | static const char gTimezoneTag[] = "timezone" ; |
| 131 | |
| 132 | static const char gPrimaryZonesTag[] = "primaryZones" ; |
| 133 | |
| 134 | static const char gWorldTag[] = "001" ; |
| 135 | |
| 136 | static const UChar gWorld[] = {0x30, 0x30, 0x31, 0x00}; // "001" |
| 137 | |
| 138 | static const UChar gDefaultFrom[] = {0x31, 0x39, 0x37, 0x30, 0x2D, 0x30, 0x31, 0x2D, 0x30, 0x31, |
| 139 | 0x20, 0x30, 0x30, 0x3A, 0x30, 0x30, 0x00}; // "1970-01-01 00:00" |
| 140 | static const UChar gDefaultTo[] = {0x39, 0x39, 0x39, 0x39, 0x2D, 0x31, 0x32, 0x2D, 0x33, 0x31, |
| 141 | 0x20, 0x32, 0x33, 0x3A, 0x35, 0x39, 0x00}; // "9999-12-31 23:59" |
| 142 | |
| 143 | static const UChar gCustomTzPrefix[] = {0x47, 0x4D, 0x54, 0}; // "GMT" |
| 144 | |
| 145 | #define ASCII_DIGIT(c) (((c)>=0x30 && (c)<=0x39) ? (c)-0x30 : -1) |
| 146 | |
| 147 | /* |
| 148 | * Convert a date string used by metazone mappings to UDate. |
| 149 | * The format used by CLDR metazone mapping is "yyyy-MM-dd HH:mm". |
| 150 | */ |
| 151 | static UDate |
| 152 | parseDate (const UChar *text, UErrorCode &status) { |
| 153 | if (U_FAILURE(status)) { |
| 154 | return 0; |
| 155 | } |
| 156 | int32_t len = u_strlen(text); |
| 157 | if (len != 16 && len != 10) { |
| 158 | // It must be yyyy-MM-dd HH:mm (length 16) or yyyy-MM-dd (length 10) |
| 159 | status = U_INVALID_FORMAT_ERROR; |
| 160 | return 0; |
| 161 | } |
| 162 | |
| 163 | int32_t year = 0, month = 0, day = 0, hour = 0, min = 0, n; |
| 164 | int32_t idx; |
| 165 | |
| 166 | // "yyyy" (0 - 3) |
| 167 | for (idx = 0; idx <= 3 && U_SUCCESS(status); idx++) { |
| 168 | n = ASCII_DIGIT((int32_t)text[idx]); |
| 169 | if (n >= 0) { |
| 170 | year = 10*year + n; |
| 171 | } else { |
| 172 | status = U_INVALID_FORMAT_ERROR; |
| 173 | } |
| 174 | } |
| 175 | // "MM" (5 - 6) |
| 176 | for (idx = 5; idx <= 6 && U_SUCCESS(status); idx++) { |
| 177 | n = ASCII_DIGIT((int32_t)text[idx]); |
| 178 | if (n >= 0) { |
| 179 | month = 10*month + n; |
| 180 | } else { |
| 181 | status = U_INVALID_FORMAT_ERROR; |
| 182 | } |
| 183 | } |
| 184 | // "dd" (8 - 9) |
| 185 | for (idx = 8; idx <= 9 && U_SUCCESS(status); idx++) { |
| 186 | n = ASCII_DIGIT((int32_t)text[idx]); |
| 187 | if (n >= 0) { |
| 188 | day = 10*day + n; |
| 189 | } else { |
| 190 | status = U_INVALID_FORMAT_ERROR; |
| 191 | } |
| 192 | } |
| 193 | if (len == 16) { |
| 194 | // "HH" (11 - 12) |
| 195 | for (idx = 11; idx <= 12 && U_SUCCESS(status); idx++) { |
| 196 | n = ASCII_DIGIT((int32_t)text[idx]); |
| 197 | if (n >= 0) { |
| 198 | hour = 10*hour + n; |
| 199 | } else { |
| 200 | status = U_INVALID_FORMAT_ERROR; |
| 201 | } |
| 202 | } |
| 203 | // "mm" (14 - 15) |
| 204 | for (idx = 14; idx <= 15 && U_SUCCESS(status); idx++) { |
| 205 | n = ASCII_DIGIT((int32_t)text[idx]); |
| 206 | if (n >= 0) { |
| 207 | min = 10*min + n; |
| 208 | } else { |
| 209 | status = U_INVALID_FORMAT_ERROR; |
| 210 | } |
| 211 | } |
| 212 | } |
| 213 | |
| 214 | if (U_SUCCESS(status)) { |
| 215 | UDate date = Grego::fieldsToDay(year, month - 1, day) * U_MILLIS_PER_DAY |
| 216 | + hour * U_MILLIS_PER_HOUR + min * U_MILLIS_PER_MINUTE; |
| 217 | return date; |
| 218 | } |
| 219 | return 0; |
| 220 | } |
| 221 | |
| 222 | static void U_CALLCONV initCanonicalIDCache(UErrorCode &status) { |
| 223 | gCanonicalIDCache = uhash_open(uhash_hashUChars, uhash_compareUChars, NULL, &status); |
| 224 | if (gCanonicalIDCache == NULL) { |
| 225 | status = U_MEMORY_ALLOCATION_ERROR; |
| 226 | } |
| 227 | if (U_FAILURE(status)) { |
| 228 | gCanonicalIDCache = NULL; |
| 229 | } |
| 230 | // No key/value deleters - keys/values are from a resource bundle |
| 231 | ucln_i18n_registerCleanup(UCLN_I18N_ZONEMETA, zoneMeta_cleanup); |
| 232 | } |
| 233 | |
| 234 | |
| 235 | const UChar* U_EXPORT2 |
| 236 | ZoneMeta::getCanonicalCLDRID(const UnicodeString &tzid, UErrorCode& status) { |
| 237 | if (U_FAILURE(status)) { |
| 238 | return NULL; |
| 239 | } |
| 240 | |
| 241 | if (tzid.isBogus() || tzid.length() > ZID_KEY_MAX) { |
| 242 | status = U_ILLEGAL_ARGUMENT_ERROR; |
| 243 | return NULL; |
| 244 | } |
| 245 | |
| 246 | // Checking the cached results |
| 247 | umtx_initOnce(gCanonicalIDCacheInitOnce, &initCanonicalIDCache, status); |
| 248 | if (U_FAILURE(status)) { |
| 249 | return NULL; |
| 250 | } |
| 251 | |
| 252 | const UChar *canonicalID = NULL; |
| 253 | |
| 254 | UErrorCode tmpStatus = U_ZERO_ERROR; |
| 255 | UChar utzid[ZID_KEY_MAX + 1]; |
| 256 | tzid.extract(utzid, ZID_KEY_MAX + 1, tmpStatus); |
| 257 | U_ASSERT(tmpStatus == U_ZERO_ERROR); // we checked the length of tzid already |
| 258 | |
| 259 | if (!uprv_isInvariantUString(utzid, -1)) { |
| 260 | // All of known tz IDs are only containing ASCII invariant characters. |
| 261 | status = U_ILLEGAL_ARGUMENT_ERROR; |
| 262 | return NULL; |
| 263 | } |
| 264 | |
| 265 | // Check if it was already cached |
| 266 | umtx_lock(&gZoneMetaLock); |
| 267 | { |
| 268 | canonicalID = (const UChar *)uhash_get(gCanonicalIDCache, utzid); |
| 269 | } |
| 270 | umtx_unlock(&gZoneMetaLock); |
| 271 | |
| 272 | if (canonicalID != NULL) { |
| 273 | return canonicalID; |
| 274 | } |
| 275 | |
| 276 | // If not, resolve CLDR canonical ID with resource data |
| 277 | UBool isInputCanonical = FALSE; |
| 278 | char id[ZID_KEY_MAX + 1]; |
| 279 | tzid.extract(0, 0x7fffffff, id, UPRV_LENGTHOF(id), US_INV); |
| 280 | |
| 281 | // replace '/' with ':' |
| 282 | char *p = id; |
| 283 | while (*p++) { |
| 284 | if (*p == '/') { |
| 285 | *p = ':'; |
| 286 | } |
| 287 | } |
| 288 | |
| 289 | UResourceBundle *top = ures_openDirect(NULL, gKeyTypeData, &tmpStatus); |
| 290 | UResourceBundle *rb = ures_getByKey(top, gTypeMapTag, NULL, &tmpStatus); |
| 291 | ures_getByKey(rb, gTimezoneTag, rb, &tmpStatus); |
| 292 | ures_getByKey(rb, id, rb, &tmpStatus); |
| 293 | if (U_SUCCESS(tmpStatus)) { |
| 294 | // type entry (canonical) found |
| 295 | // the input is the canonical ID. resolve to const UChar* |
| 296 | canonicalID = TimeZone::findID(tzid); |
| 297 | isInputCanonical = TRUE; |
| 298 | } |
| 299 | |
| 300 | if (canonicalID == NULL) { |
| 301 | // If a map element not found, then look for an alias |
| 302 | tmpStatus = U_ZERO_ERROR; |
| 303 | ures_getByKey(top, gTypeAliasTag, rb, &tmpStatus); |
| 304 | ures_getByKey(rb, gTimezoneTag, rb, &tmpStatus); |
| 305 | const UChar *canonical = ures_getStringByKey(rb,id,NULL,&tmpStatus); |
| 306 | if (U_SUCCESS(tmpStatus)) { |
| 307 | // canonical map found |
| 308 | canonicalID = canonical; |
| 309 | } |
| 310 | |
| 311 | if (canonicalID == NULL) { |
| 312 | // Dereference the input ID using the tz data |
| 313 | const UChar *derefer = TimeZone::dereferOlsonLink(tzid); |
| 314 | if (derefer == NULL) { |
| 315 | status = U_ILLEGAL_ARGUMENT_ERROR; |
| 316 | } else { |
| 317 | int32_t len = u_strlen(derefer); |
| 318 | u_UCharsToChars(derefer,id,len); |
| 319 | id[len] = (char) 0; // Make sure it is null terminated. |
| 320 | |
| 321 | // replace '/' with ':' |
| 322 | char *q = id; |
| 323 | while (*q++) { |
| 324 | if (*q == '/') { |
| 325 | *q = ':'; |
| 326 | } |
| 327 | } |
| 328 | |
| 329 | // If a dereference turned something up then look for an alias. |
| 330 | // rb still points to the alias table, so we don't have to go looking |
| 331 | // for it. |
| 332 | tmpStatus = U_ZERO_ERROR; |
| 333 | canonical = ures_getStringByKey(rb,id,NULL,&tmpStatus); |
| 334 | if (U_SUCCESS(tmpStatus)) { |
| 335 | // canonical map for the dereferenced ID found |
| 336 | canonicalID = canonical; |
| 337 | } else { |
| 338 | canonicalID = derefer; |
| 339 | isInputCanonical = TRUE; |
| 340 | } |
| 341 | } |
| 342 | } |
| 343 | } |
| 344 | ures_close(rb); |
| 345 | ures_close(top); |
| 346 | |
| 347 | if (U_SUCCESS(status)) { |
| 348 | U_ASSERT(canonicalID != NULL); // canocanilD must be non-NULL here |
| 349 | |
| 350 | // Put the resolved canonical ID to the cache |
| 351 | umtx_lock(&gZoneMetaLock); |
| 352 | { |
| 353 | const UChar* idInCache = (const UChar *)uhash_get(gCanonicalIDCache, utzid); |
| 354 | if (idInCache == NULL) { |
| 355 | const UChar* key = ZoneMeta::findTimeZoneID(tzid); |
| 356 | U_ASSERT(key != NULL); |
| 357 | if (key != NULL) { |
| 358 | idInCache = (const UChar *)uhash_put(gCanonicalIDCache, (void *)key, (void *)canonicalID, &status); |
| 359 | U_ASSERT(idInCache == NULL); |
| 360 | } |
| 361 | } |
| 362 | if (U_SUCCESS(status) && isInputCanonical) { |
| 363 | // Also put canonical ID itself into the cache if not exist |
| 364 | const UChar *canonicalInCache = (const UChar*)uhash_get(gCanonicalIDCache, canonicalID); |
| 365 | if (canonicalInCache == NULL) { |
| 366 | canonicalInCache = (const UChar *)uhash_put(gCanonicalIDCache, (void *)canonicalID, (void *)canonicalID, &status); |
| 367 | U_ASSERT(canonicalInCache == NULL); |
| 368 | } |
| 369 | } |
| 370 | } |
| 371 | umtx_unlock(&gZoneMetaLock); |
| 372 | } |
| 373 | |
| 374 | return canonicalID; |
| 375 | } |
| 376 | |
| 377 | UnicodeString& U_EXPORT2 |
| 378 | ZoneMeta::getCanonicalCLDRID(const UnicodeString &tzid, UnicodeString &systemID, UErrorCode& status) { |
| 379 | const UChar *canonicalID = getCanonicalCLDRID(tzid, status); |
| 380 | if (U_FAILURE(status) || canonicalID == NULL) { |
| 381 | systemID.setToBogus(); |
| 382 | return systemID; |
| 383 | } |
| 384 | systemID.setTo(TRUE, canonicalID, -1); |
| 385 | return systemID; |
| 386 | } |
| 387 | |
| 388 | const UChar* U_EXPORT2 |
| 389 | ZoneMeta::getCanonicalCLDRID(const TimeZone& tz) { |
| 390 | if (dynamic_cast<const OlsonTimeZone *>(&tz) != NULL) { |
| 391 | // short cut for OlsonTimeZone |
| 392 | const OlsonTimeZone *otz = (const OlsonTimeZone*)&tz; |
| 393 | return otz->getCanonicalID(); |
| 394 | } |
| 395 | UErrorCode status = U_ZERO_ERROR; |
| 396 | UnicodeString tzID; |
| 397 | return getCanonicalCLDRID(tz.getID(tzID), status); |
| 398 | } |
| 399 | |
| 400 | static void U_CALLCONV countryInfoVectorsInit(UErrorCode &status) { |
| 401 | // Create empty vectors |
| 402 | // No deleters for these UVectors, it's a reference to a resource bundle string. |
| 403 | gSingleZoneCountries = new UVector(NULL, uhash_compareUChars, status); |
| 404 | if (gSingleZoneCountries == NULL) { |
| 405 | status = U_MEMORY_ALLOCATION_ERROR; |
| 406 | } |
| 407 | gMultiZonesCountries = new UVector(NULL, uhash_compareUChars, status); |
| 408 | if (gMultiZonesCountries == NULL) { |
| 409 | status = U_MEMORY_ALLOCATION_ERROR; |
| 410 | } |
| 411 | |
| 412 | if (U_FAILURE(status)) { |
| 413 | delete gSingleZoneCountries; |
| 414 | delete gMultiZonesCountries; |
| 415 | gSingleZoneCountries = NULL; |
| 416 | gMultiZonesCountries = NULL; |
| 417 | } |
| 418 | ucln_i18n_registerCleanup(UCLN_I18N_ZONEMETA, zoneMeta_cleanup); |
| 419 | } |
| 420 | |
| 421 | |
| 422 | UnicodeString& U_EXPORT2 |
| 423 | ZoneMeta::getCanonicalCountry(const UnicodeString &tzid, UnicodeString &country, UBool *isPrimary /* = NULL */) { |
| 424 | if (isPrimary != NULL) { |
| 425 | *isPrimary = FALSE; |
| 426 | } |
| 427 | |
| 428 | const UChar *region = TimeZone::getRegion(tzid); |
| 429 | if (region != NULL && u_strcmp(gWorld, region) != 0) { |
| 430 | country.setTo(region, -1); |
| 431 | } else { |
| 432 | country.setToBogus(); |
| 433 | return country; |
| 434 | } |
| 435 | |
| 436 | if (isPrimary != NULL) { |
| 437 | char regionBuf[] = {0, 0, 0}; |
| 438 | |
| 439 | // Checking the cached results |
| 440 | UErrorCode status = U_ZERO_ERROR; |
| 441 | umtx_initOnce(gCountryInfoVectorsInitOnce, &countryInfoVectorsInit, status); |
| 442 | if (U_FAILURE(status)) { |
| 443 | return country; |
| 444 | } |
| 445 | |
| 446 | // Check if it was already cached |
| 447 | UBool cached = FALSE; |
| 448 | UBool singleZone = FALSE; |
| 449 | umtx_lock(&gZoneMetaLock); |
| 450 | { |
| 451 | singleZone = cached = gSingleZoneCountries->contains((void*)region); |
| 452 | if (!cached) { |
| 453 | cached = gMultiZonesCountries->contains((void*)region); |
| 454 | } |
| 455 | } |
| 456 | umtx_unlock(&gZoneMetaLock); |
| 457 | |
| 458 | if (!cached) { |
| 459 | // We need to go through all zones associated with the region. |
| 460 | // This is relatively heavy operation. |
| 461 | |
| 462 | U_ASSERT(u_strlen(region) == 2); |
| 463 | |
| 464 | u_UCharsToChars(region, regionBuf, 2); |
| 465 | |
| 466 | StringEnumeration *ids = TimeZone::createTimeZoneIDEnumeration(UCAL_ZONE_TYPE_CANONICAL_LOCATION, regionBuf, NULL, status); |
| 467 | int32_t idsLen = ids->count(status); |
| 468 | if (U_SUCCESS(status) && idsLen == 1) { |
| 469 | // only the single zone is available for the region |
| 470 | singleZone = TRUE; |
| 471 | } |
| 472 | delete ids; |
| 473 | |
| 474 | // Cache the result |
| 475 | umtx_lock(&gZoneMetaLock); |
| 476 | { |
| 477 | UErrorCode ec = U_ZERO_ERROR; |
| 478 | if (singleZone) { |
| 479 | if (!gSingleZoneCountries->contains((void*)region)) { |
| 480 | gSingleZoneCountries->addElement((void*)region, ec); |
| 481 | } |
| 482 | } else { |
| 483 | if (!gMultiZonesCountries->contains((void*)region)) { |
| 484 | gMultiZonesCountries->addElement((void*)region, ec); |
| 485 | } |
| 486 | } |
| 487 | } |
| 488 | umtx_unlock(&gZoneMetaLock); |
| 489 | } |
| 490 | |
| 491 | if (singleZone) { |
| 492 | *isPrimary = TRUE; |
| 493 | } else { |
| 494 | // Note: We may cache the primary zone map in future. |
| 495 | |
| 496 | // Even a country has multiple zones, one of them might be |
| 497 | // dominant and treated as a primary zone |
| 498 | int32_t idLen = 0; |
| 499 | if (regionBuf[0] == 0) { |
| 500 | u_UCharsToChars(region, regionBuf, 2); |
| 501 | } |
| 502 | |
| 503 | UResourceBundle *rb = ures_openDirect(NULL, gMetaZones, &status); |
| 504 | ures_getByKey(rb, gPrimaryZonesTag, rb, &status); |
| 505 | const UChar *primaryZone = ures_getStringByKey(rb, regionBuf, &idLen, &status); |
| 506 | if (U_SUCCESS(status)) { |
| 507 | if (tzid.compare(primaryZone, idLen) == 0) { |
| 508 | *isPrimary = TRUE; |
| 509 | } else { |
| 510 | // The given ID might not be a canonical ID |
| 511 | UnicodeString canonicalID; |
| 512 | TimeZone::getCanonicalID(tzid, canonicalID, status); |
| 513 | if (U_SUCCESS(status) && canonicalID.compare(primaryZone, idLen) == 0) { |
| 514 | *isPrimary = TRUE; |
| 515 | } |
| 516 | } |
| 517 | } |
| 518 | ures_close(rb); |
| 519 | } |
| 520 | } |
| 521 | |
| 522 | return country; |
| 523 | } |
| 524 | |
| 525 | UnicodeString& U_EXPORT2 |
| 526 | ZoneMeta::getMetazoneID(const UnicodeString &tzid, UDate date, UnicodeString &result) { |
| 527 | UBool isSet = FALSE; |
| 528 | const UVector *mappings = getMetazoneMappings(tzid); |
| 529 | if (mappings != NULL) { |
| 530 | for (int32_t i = 0; i < mappings->size(); i++) { |
| 531 | OlsonToMetaMappingEntry *mzm = (OlsonToMetaMappingEntry*)mappings->elementAt(i); |
| 532 | if (mzm->from <= date && mzm->to > date) { |
| 533 | result.setTo(mzm->mzid, -1); |
| 534 | isSet = TRUE; |
| 535 | break; |
| 536 | } |
| 537 | } |
| 538 | } |
| 539 | if (!isSet) { |
| 540 | result.setToBogus(); |
| 541 | } |
| 542 | return result; |
| 543 | } |
| 544 | |
| 545 | static void U_CALLCONV olsonToMetaInit(UErrorCode &status) { |
| 546 | U_ASSERT(gOlsonToMeta == NULL); |
| 547 | ucln_i18n_registerCleanup(UCLN_I18N_ZONEMETA, zoneMeta_cleanup); |
| 548 | gOlsonToMeta = uhash_open(uhash_hashUChars, uhash_compareUChars, NULL, &status); |
| 549 | if (U_FAILURE(status)) { |
| 550 | gOlsonToMeta = NULL; |
| 551 | } else { |
| 552 | uhash_setKeyDeleter(gOlsonToMeta, deleteUCharString); |
| 553 | uhash_setValueDeleter(gOlsonToMeta, deleteUVector); |
| 554 | } |
| 555 | } |
| 556 | |
| 557 | |
| 558 | const UVector* U_EXPORT2 |
| 559 | ZoneMeta::getMetazoneMappings(const UnicodeString &tzid) { |
| 560 | UErrorCode status = U_ZERO_ERROR; |
| 561 | UChar tzidUChars[ZID_KEY_MAX + 1]; |
| 562 | tzid.extract(tzidUChars, ZID_KEY_MAX + 1, status); |
| 563 | if (U_FAILURE(status) || status == U_STRING_NOT_TERMINATED_WARNING) { |
| 564 | return NULL; |
| 565 | } |
| 566 | |
| 567 | umtx_initOnce(gOlsonToMetaInitOnce, &olsonToMetaInit, status); |
| 568 | if (U_FAILURE(status)) { |
| 569 | return NULL; |
| 570 | } |
| 571 | |
| 572 | // get the mapping from cache |
| 573 | const UVector *result = NULL; |
| 574 | |
| 575 | umtx_lock(&gZoneMetaLock); |
| 576 | { |
| 577 | result = (UVector*) uhash_get(gOlsonToMeta, tzidUChars); |
| 578 | } |
| 579 | umtx_unlock(&gZoneMetaLock); |
| 580 | |
| 581 | if (result != NULL) { |
| 582 | return result; |
| 583 | } |
| 584 | |
| 585 | // miss the cache - create new one |
| 586 | UVector *tmpResult = createMetazoneMappings(tzid); |
| 587 | if (tmpResult == NULL) { |
| 588 | // not available |
| 589 | return NULL; |
| 590 | } |
| 591 | |
| 592 | // put the new one into the cache |
| 593 | umtx_lock(&gZoneMetaLock); |
| 594 | { |
| 595 | // make sure it's already created |
| 596 | result = (UVector*) uhash_get(gOlsonToMeta, tzidUChars); |
| 597 | if (result == NULL) { |
| 598 | // add the one just created |
| 599 | int32_t tzidLen = tzid.length() + 1; |
| 600 | UChar *key = (UChar*)uprv_malloc(tzidLen * sizeof(UChar)); |
| 601 | if (key == NULL) { |
| 602 | // memory allocation error.. just return NULL |
| 603 | result = NULL; |
| 604 | delete tmpResult; |
| 605 | } else { |
| 606 | tzid.extract(key, tzidLen, status); |
| 607 | uhash_put(gOlsonToMeta, key, tmpResult, &status); |
| 608 | if (U_FAILURE(status)) { |
| 609 | // delete the mapping |
| 610 | result = NULL; |
| 611 | delete tmpResult; |
| 612 | } else { |
| 613 | result = tmpResult; |
| 614 | } |
| 615 | } |
| 616 | } else { |
| 617 | // another thread already put the one |
| 618 | delete tmpResult; |
| 619 | } |
| 620 | } |
| 621 | umtx_unlock(&gZoneMetaLock); |
| 622 | |
| 623 | return result; |
| 624 | } |
| 625 | |
| 626 | UVector* |
| 627 | ZoneMeta::createMetazoneMappings(const UnicodeString &tzid) { |
| 628 | UVector *mzMappings = NULL; |
| 629 | UErrorCode status = U_ZERO_ERROR; |
| 630 | |
| 631 | UnicodeString canonicalID; |
| 632 | UResourceBundle *rb = ures_openDirect(NULL, gMetaZones, &status); |
| 633 | ures_getByKey(rb, gMetazoneInfo, rb, &status); |
| 634 | getCanonicalCLDRID(tzid, canonicalID, status); |
| 635 | |
| 636 | if (U_SUCCESS(status)) { |
| 637 | char tzKey[ZID_KEY_MAX + 1]; |
| 638 | int32_t tzKeyLen = canonicalID.extract(0, canonicalID.length(), tzKey, sizeof(tzKey), US_INV); |
| 639 | tzKey[tzKeyLen] = 0; |
| 640 | |
| 641 | // tzid keys are using ':' as separators |
| 642 | char *p = tzKey; |
| 643 | while (*p) { |
| 644 | if (*p == '/') { |
| 645 | *p = ':'; |
| 646 | } |
| 647 | p++; |
| 648 | } |
| 649 | |
| 650 | ures_getByKey(rb, tzKey, rb, &status); |
| 651 | |
| 652 | if (U_SUCCESS(status)) { |
| 653 | UResourceBundle *mz = NULL; |
| 654 | while (ures_hasNext(rb)) { |
| 655 | mz = ures_getNextResource(rb, mz, &status); |
| 656 | |
| 657 | const UChar *mz_name = ures_getStringByIndex(mz, 0, NULL, &status); |
| 658 | const UChar *mz_from = gDefaultFrom; |
| 659 | const UChar *mz_to = gDefaultTo; |
| 660 | |
| 661 | if (ures_getSize(mz) == 3) { |
| 662 | mz_from = ures_getStringByIndex(mz, 1, NULL, &status); |
| 663 | mz_to = ures_getStringByIndex(mz, 2, NULL, &status); |
| 664 | } |
| 665 | |
| 666 | if(U_FAILURE(status)){ |
| 667 | status = U_ZERO_ERROR; |
| 668 | continue; |
| 669 | } |
| 670 | // We do not want to use SimpleDateformat to parse boundary dates, |
| 671 | // because this code could be triggered by the initialization code |
| 672 | // used by SimpleDateFormat. |
| 673 | UDate from = parseDate(mz_from, status); |
| 674 | UDate to = parseDate(mz_to, status); |
| 675 | if (U_FAILURE(status)) { |
| 676 | status = U_ZERO_ERROR; |
| 677 | continue; |
| 678 | } |
| 679 | |
| 680 | OlsonToMetaMappingEntry *entry = (OlsonToMetaMappingEntry*)uprv_malloc(sizeof(OlsonToMetaMappingEntry)); |
| 681 | if (entry == NULL) { |
| 682 | status = U_MEMORY_ALLOCATION_ERROR; |
| 683 | break; |
| 684 | } |
| 685 | entry->mzid = mz_name; |
| 686 | entry->from = from; |
| 687 | entry->to = to; |
| 688 | |
| 689 | if (mzMappings == NULL) { |
| 690 | mzMappings = new UVector(deleteOlsonToMetaMappingEntry, NULL, status); |
| 691 | if (U_FAILURE(status)) { |
| 692 | delete mzMappings; |
| 693 | mzMappings = NULL; |
| 694 | uprv_free(entry); |
| 695 | break; |
| 696 | } |
| 697 | } |
| 698 | |
| 699 | mzMappings->addElement(entry, status); |
| 700 | if (U_FAILURE(status)) { |
| 701 | break; |
| 702 | } |
| 703 | } |
| 704 | ures_close(mz); |
| 705 | if (U_FAILURE(status)) { |
| 706 | if (mzMappings != NULL) { |
| 707 | delete mzMappings; |
| 708 | mzMappings = NULL; |
| 709 | } |
| 710 | } |
| 711 | } |
| 712 | } |
| 713 | ures_close(rb); |
| 714 | return mzMappings; |
| 715 | } |
| 716 | |
| 717 | UnicodeString& U_EXPORT2 |
| 718 | ZoneMeta::getZoneIdByMetazone(const UnicodeString &mzid, const UnicodeString ®ion, UnicodeString &result) { |
| 719 | UErrorCode status = U_ZERO_ERROR; |
| 720 | const UChar *tzid = NULL; |
| 721 | int32_t tzidLen = 0; |
| 722 | char keyBuf[ZID_KEY_MAX + 1]; |
| 723 | int32_t keyLen = 0; |
| 724 | |
| 725 | if (mzid.isBogus() || mzid.length() > ZID_KEY_MAX) { |
| 726 | result.setToBogus(); |
| 727 | return result; |
| 728 | } |
| 729 | |
| 730 | keyLen = mzid.extract(0, mzid.length(), keyBuf, ZID_KEY_MAX + 1, US_INV); |
| 731 | keyBuf[keyLen] = 0; |
| 732 | |
| 733 | UResourceBundle *rb = ures_openDirect(NULL, gMetaZones, &status); |
| 734 | ures_getByKey(rb, gMapTimezonesTag, rb, &status); |
| 735 | ures_getByKey(rb, keyBuf, rb, &status); |
| 736 | |
| 737 | if (U_SUCCESS(status)) { |
| 738 | // check region mapping |
| 739 | if (region.length() == 2 || region.length() == 3) { |
| 740 | keyLen = region.extract(0, region.length(), keyBuf, ZID_KEY_MAX + 1, US_INV); |
| 741 | keyBuf[keyLen] = 0; |
| 742 | tzid = ures_getStringByKey(rb, keyBuf, &tzidLen, &status); |
| 743 | if (status == U_MISSING_RESOURCE_ERROR) { |
| 744 | status = U_ZERO_ERROR; |
| 745 | } |
| 746 | } |
| 747 | if (U_SUCCESS(status) && tzid == NULL) { |
| 748 | // try "001" |
| 749 | tzid = ures_getStringByKey(rb, gWorldTag, &tzidLen, &status); |
| 750 | } |
| 751 | } |
| 752 | ures_close(rb); |
| 753 | |
| 754 | if (tzid == NULL) { |
| 755 | result.setToBogus(); |
| 756 | } else { |
| 757 | result.setTo(tzid, tzidLen); |
| 758 | } |
| 759 | |
| 760 | return result; |
| 761 | } |
| 762 | |
| 763 | static void U_CALLCONV initAvailableMetaZoneIDs () { |
| 764 | U_ASSERT(gMetaZoneIDs == NULL); |
| 765 | U_ASSERT(gMetaZoneIDTable == NULL); |
| 766 | ucln_i18n_registerCleanup(UCLN_I18N_ZONEMETA, zoneMeta_cleanup); |
| 767 | |
| 768 | UErrorCode status = U_ZERO_ERROR; |
| 769 | gMetaZoneIDTable = uhash_open(uhash_hashUnicodeString, uhash_compareUnicodeString, NULL, &status); |
| 770 | if (U_FAILURE(status) || gMetaZoneIDTable == NULL) { |
| 771 | gMetaZoneIDTable = NULL; |
| 772 | return; |
| 773 | } |
| 774 | uhash_setKeyDeleter(gMetaZoneIDTable, uprv_deleteUObject); |
| 775 | // No valueDeleter, because the vector maintain the value objects |
| 776 | gMetaZoneIDs = new UVector(NULL, uhash_compareUChars, status); |
| 777 | if (U_FAILURE(status) || gMetaZoneIDs == NULL) { |
| 778 | gMetaZoneIDs = NULL; |
| 779 | uhash_close(gMetaZoneIDTable); |
| 780 | gMetaZoneIDTable = NULL; |
| 781 | return; |
| 782 | } |
| 783 | gMetaZoneIDs->setDeleter(uprv_free); |
| 784 | |
| 785 | UResourceBundle *rb = ures_openDirect(NULL, gMetaZones, &status); |
| 786 | UResourceBundle *bundle = ures_getByKey(rb, gMapTimezonesTag, NULL, &status); |
| 787 | StackUResourceBundle res; |
| 788 | while (U_SUCCESS(status) && ures_hasNext(bundle)) { |
| 789 | ures_getNextResource(bundle, res.getAlias(), &status); |
| 790 | if (U_FAILURE(status)) { |
| 791 | break; |
| 792 | } |
| 793 | const char *mzID = ures_getKey(res.getAlias()); |
| 794 | int32_t len = static_cast<int32_t>(uprv_strlen(mzID)); |
| 795 | UChar *uMzID = (UChar*)uprv_malloc(sizeof(UChar) * (len + 1)); |
| 796 | if (uMzID == NULL) { |
| 797 | status = U_MEMORY_ALLOCATION_ERROR; |
| 798 | break; |
| 799 | } |
| 800 | u_charsToUChars(mzID, uMzID, len); |
| 801 | uMzID[len] = 0; |
| 802 | UnicodeString *usMzID = new UnicodeString(uMzID); |
| 803 | if (uhash_get(gMetaZoneIDTable, usMzID) == NULL) { |
| 804 | gMetaZoneIDs->addElement((void *)uMzID, status); |
| 805 | uhash_put(gMetaZoneIDTable, (void *)usMzID, (void *)uMzID, &status); |
| 806 | } else { |
| 807 | uprv_free(uMzID); |
| 808 | delete usMzID; |
| 809 | } |
| 810 | } |
| 811 | ures_close(bundle); |
| 812 | ures_close(rb); |
| 813 | |
| 814 | if (U_FAILURE(status)) { |
| 815 | uhash_close(gMetaZoneIDTable); |
| 816 | delete gMetaZoneIDs; |
| 817 | gMetaZoneIDTable = NULL; |
| 818 | gMetaZoneIDs = NULL; |
| 819 | } |
| 820 | } |
| 821 | |
| 822 | const UVector* |
| 823 | ZoneMeta::getAvailableMetazoneIDs() { |
| 824 | umtx_initOnce(gMetaZoneIDsInitOnce, &initAvailableMetaZoneIDs); |
| 825 | return gMetaZoneIDs; |
| 826 | } |
| 827 | |
| 828 | const UChar* |
| 829 | ZoneMeta::findMetaZoneID(const UnicodeString& mzid) { |
| 830 | umtx_initOnce(gMetaZoneIDsInitOnce, &initAvailableMetaZoneIDs); |
| 831 | if (gMetaZoneIDTable == NULL) { |
| 832 | return NULL; |
| 833 | } |
| 834 | return (const UChar*)uhash_get(gMetaZoneIDTable, &mzid); |
| 835 | } |
| 836 | |
| 837 | const UChar* |
| 838 | ZoneMeta::findTimeZoneID(const UnicodeString& tzid) { |
| 839 | return TimeZone::findID(tzid); |
| 840 | } |
| 841 | |
| 842 | |
| 843 | TimeZone* |
| 844 | ZoneMeta::createCustomTimeZone(int32_t offset) { |
| 845 | UBool negative = FALSE; |
| 846 | int32_t tmp = offset; |
| 847 | if (offset < 0) { |
| 848 | negative = TRUE; |
| 849 | tmp = -offset; |
| 850 | } |
| 851 | uint8_t hour, min, sec; |
| 852 | |
| 853 | tmp /= 1000; |
| 854 | sec = static_cast<uint8_t>(tmp % 60); |
| 855 | tmp /= 60; |
| 856 | min = static_cast<uint8_t>(tmp % 60); |
| 857 | hour = static_cast<uint8_t>(tmp / 60); |
| 858 | |
| 859 | UnicodeString zid; |
| 860 | formatCustomID(hour, min, sec, negative, zid); |
| 861 | return new SimpleTimeZone(offset, zid); |
| 862 | } |
| 863 | |
| 864 | UnicodeString& |
| 865 | ZoneMeta::formatCustomID(uint8_t hour, uint8_t min, uint8_t sec, UBool negative, UnicodeString& id) { |
| 866 | // Create normalized time zone ID - GMT[+|-]HH:mm[:ss] |
| 867 | id.setTo(gCustomTzPrefix, -1); |
| 868 | if (hour != 0 || min != 0) { |
| 869 | if (negative) { |
| 870 | id.append((UChar)0x2D); // '-' |
| 871 | } else { |
| 872 | id.append((UChar)0x2B); // '+' |
| 873 | } |
| 874 | // Always use US-ASCII digits |
| 875 | id.append((UChar)(0x30 + (hour%100)/10)); |
| 876 | id.append((UChar)(0x30 + (hour%10))); |
| 877 | id.append((UChar)0x3A); // ':' |
| 878 | id.append((UChar)(0x30 + (min%100)/10)); |
| 879 | id.append((UChar)(0x30 + (min%10))); |
| 880 | if (sec != 0) { |
| 881 | id.append((UChar)0x3A); // ':' |
| 882 | id.append((UChar)(0x30 + (sec%100)/10)); |
| 883 | id.append((UChar)(0x30 + (sec%10))); |
| 884 | } |
| 885 | } |
| 886 | return id; |
| 887 | } |
| 888 | |
| 889 | const UChar* |
| 890 | ZoneMeta::getShortID(const TimeZone& tz) { |
| 891 | const UChar* canonicalID = NULL; |
| 892 | if (dynamic_cast<const OlsonTimeZone *>(&tz) != NULL) { |
| 893 | // short cut for OlsonTimeZone |
| 894 | const OlsonTimeZone *otz = (const OlsonTimeZone*)&tz; |
| 895 | canonicalID = otz->getCanonicalID(); |
| 896 | } |
| 897 | if (canonicalID == NULL) { |
| 898 | return NULL; |
| 899 | } |
| 900 | return getShortIDFromCanonical(canonicalID); |
| 901 | } |
| 902 | |
| 903 | const UChar* |
| 904 | ZoneMeta::getShortID(const UnicodeString& id) { |
| 905 | UErrorCode status = U_ZERO_ERROR; |
| 906 | const UChar* canonicalID = ZoneMeta::getCanonicalCLDRID(id, status); |
| 907 | if (U_FAILURE(status) || canonicalID == NULL) { |
| 908 | return NULL; |
| 909 | } |
| 910 | return ZoneMeta::getShortIDFromCanonical(canonicalID); |
| 911 | } |
| 912 | |
| 913 | const UChar* |
| 914 | ZoneMeta::getShortIDFromCanonical(const UChar* canonicalID) { |
| 915 | const UChar* shortID = NULL; |
| 916 | int32_t len = u_strlen(canonicalID); |
| 917 | char tzidKey[ZID_KEY_MAX + 1]; |
| 918 | |
| 919 | u_UCharsToChars(canonicalID, tzidKey, len); |
| 920 | tzidKey[len] = (char) 0; // Make sure it is null terminated. |
| 921 | |
| 922 | // replace '/' with ':' |
| 923 | char *p = tzidKey; |
| 924 | while (*p++) { |
| 925 | if (*p == '/') { |
| 926 | *p = ':'; |
| 927 | } |
| 928 | } |
| 929 | |
| 930 | UErrorCode status = U_ZERO_ERROR; |
| 931 | UResourceBundle *rb = ures_openDirect(NULL, gKeyTypeData, &status); |
| 932 | ures_getByKey(rb, gTypeMapTag, rb, &status); |
| 933 | ures_getByKey(rb, gTimezoneTag, rb, &status); |
| 934 | shortID = ures_getStringByKey(rb, tzidKey, NULL, &status); |
| 935 | ures_close(rb); |
| 936 | |
| 937 | return shortID; |
| 938 | } |
| 939 | |
| 940 | U_NAMESPACE_END |
| 941 | |
| 942 | #endif /* #if !UCONFIG_NO_FORMATTING */ |
| 943 | |