]> git.saurik.com Git - apple/icu.git/blame - icuSources/common/serv.cpp
ICU-59180.0.1.tar.gz
[apple/icu.git] / icuSources / common / serv.cpp
CommitLineData
f3c0d7a5
A
1// © 2016 and later: Unicode, Inc. and others.
2// License & terms of use: http://www.unicode.org/copyright.html
46f4442e
A
3/**
4*******************************************************************************
b331163b 5* Copyright (C) 2001-2014, International Business Machines Corporation.
729e4ab9 6* All Rights Reserved.
46f4442e
A
7*******************************************************************************
8*/
b75a7d8f
A
9
10#include "unicode/utypes.h"
11
12#if !UCONFIG_NO_SERVICE
13
73c04bcf 14#include "serv.h"
b75a7d8f
A
15#include "umutex.h"
16
17#undef SERVICE_REFCOUNT
18
19// in case we use the refcount stuff
20
21U_NAMESPACE_BEGIN
22
b75a7d8f 23/*
46f4442e
A
24******************************************************************
25*/
b75a7d8f
A
26
27const UChar ICUServiceKey::PREFIX_DELIMITER = 0x002F; /* '/' */
28
29ICUServiceKey::ICUServiceKey(const UnicodeString& id)
46f4442e 30: _id(id) {
b75a7d8f
A
31}
32
33ICUServiceKey::~ICUServiceKey()
34{
35}
36
37const UnicodeString&
38ICUServiceKey::getID() const
39{
46f4442e 40 return _id;
b75a7d8f
A
41}
42
43UnicodeString&
44ICUServiceKey::canonicalID(UnicodeString& result) const
45{
46f4442e 46 return result.append(_id);
b75a7d8f
A
47}
48
49UnicodeString&
50ICUServiceKey::currentID(UnicodeString& result) const
51{
46f4442e 52 return canonicalID(result);
b75a7d8f
A
53}
54
55UnicodeString&
56ICUServiceKey::currentDescriptor(UnicodeString& result) const
57{
46f4442e
A
58 prefix(result);
59 result.append(PREFIX_DELIMITER);
60 return currentID(result);
b75a7d8f
A
61}
62
63UBool
64ICUServiceKey::fallback()
65{
46f4442e 66 return FALSE;
b75a7d8f
A
67}
68
69UBool
70ICUServiceKey::isFallbackOf(const UnicodeString& id) const
71{
46f4442e 72 return id == _id;
b75a7d8f
A
73}
74
75UnicodeString&
76ICUServiceKey::prefix(UnicodeString& result) const
77{
46f4442e 78 return result;
b75a7d8f
A
79}
80
81UnicodeString&
82ICUServiceKey::parsePrefix(UnicodeString& result)
83{
46f4442e
A
84 int32_t n = result.indexOf(PREFIX_DELIMITER);
85 if (n < 0) {
86 n = 0;
87 }
88 result.remove(n);
89 return result;
b75a7d8f
A
90}
91
92UnicodeString&
93ICUServiceKey::parseSuffix(UnicodeString& result)
94{
46f4442e
A
95 int32_t n = result.indexOf(PREFIX_DELIMITER);
96 if (n >= 0) {
97 result.remove(0, n+1);
98 }
99 return result;
b75a7d8f
A
100}
101
102#ifdef SERVICE_DEBUG
103UnicodeString&
104ICUServiceKey::debug(UnicodeString& result) const
105{
46f4442e 106 debugClass(result);
b331163b 107 result.append((UnicodeString)" id: ");
46f4442e
A
108 result.append(_id);
109 return result;
b75a7d8f
A
110}
111
112UnicodeString&
113ICUServiceKey::debugClass(UnicodeString& result) const
114{
b331163b 115 return result.append((UnicodeString)"ICUServiceKey");
b75a7d8f
A
116}
117#endif
118
374ca955 119UOBJECT_DEFINE_RTTI_IMPLEMENTATION(ICUServiceKey)
b75a7d8f
A
120
121/*
46f4442e
A
122******************************************************************
123*/
b75a7d8f 124
4388f060
A
125ICUServiceFactory::~ICUServiceFactory() {}
126
b75a7d8f 127SimpleFactory::SimpleFactory(UObject* instanceToAdopt, const UnicodeString& id, UBool visible)
46f4442e 128: _instance(instanceToAdopt), _id(id), _visible(visible)
b75a7d8f
A
129{
130}
131
132SimpleFactory::~SimpleFactory()
133{
46f4442e 134 delete _instance;
b75a7d8f
A
135}
136
137UObject*
138SimpleFactory::create(const ICUServiceKey& key, const ICUService* service, UErrorCode& status) const
139{
46f4442e
A
140 if (U_SUCCESS(status)) {
141 UnicodeString temp;
142 if (_id == key.currentID(temp)) {
143 return service->cloneInstance(_instance);
144 }
b75a7d8f 145 }
46f4442e 146 return NULL;
b75a7d8f
A
147}
148
149void
150SimpleFactory::updateVisibleIDs(Hashtable& result, UErrorCode& status) const
151{
46f4442e
A
152 if (_visible) {
153 result.put(_id, (void*)this, status); // cast away const
154 } else {
155 result.remove(_id);
156 }
b75a7d8f
A
157}
158
159UnicodeString&
374ca955 160SimpleFactory::getDisplayName(const UnicodeString& id, const Locale& /* locale */, UnicodeString& result) const
b75a7d8f 161{
46f4442e
A
162 if (_visible && _id == id) {
163 result = _id;
164 } else {
165 result.setToBogus();
166 }
167 return result;
b75a7d8f
A
168}
169
170#ifdef SERVICE_DEBUG
171UnicodeString&
172SimpleFactory::debug(UnicodeString& toAppendTo) const
173{
46f4442e 174 debugClass(toAppendTo);
b331163b 175 toAppendTo.append((UnicodeString)" id: ");
46f4442e 176 toAppendTo.append(_id);
b331163b
A
177 toAppendTo.append((UnicodeString)", visible: ");
178 toAppendTo.append(_visible ? (UnicodeString)"T" : (UnicodeString)"F");
46f4442e 179 return toAppendTo;
b75a7d8f
A
180}
181
182UnicodeString&
183SimpleFactory::debugClass(UnicodeString& toAppendTo) const
184{
b331163b 185 return toAppendTo.append((UnicodeString)"SimpleFactory");
b75a7d8f
A
186}
187#endif
188
374ca955 189UOBJECT_DEFINE_RTTI_IMPLEMENTATION(SimpleFactory)
b75a7d8f
A
190
191/*
46f4442e
A
192******************************************************************
193*/
b75a7d8f 194
4388f060
A
195ServiceListener::~ServiceListener() {}
196
374ca955 197UOBJECT_DEFINE_RTTI_IMPLEMENTATION(ServiceListener)
b75a7d8f
A
198
199/*
46f4442e
A
200******************************************************************
201*/
b75a7d8f 202
46f4442e
A
203// Record the actual id for this service in the cache, so we can return it
204// even if we succeed later with a different id.
b75a7d8f
A
205class CacheEntry : public UMemory {
206private:
46f4442e 207 int32_t refcount;
b75a7d8f
A
208
209public:
46f4442e
A
210 UnicodeString actualDescriptor;
211 UObject* service;
212
213 /**
214 * Releases a reference to the shared resource.
215 */
216 ~CacheEntry() {
217 delete service;
218 }
219
220 CacheEntry(const UnicodeString& _actualDescriptor, UObject* _service)
221 : refcount(1), actualDescriptor(_actualDescriptor), service(_service) {
222 }
223
224 /**
225 * Instantiation creates an initial reference, so don't call this
226 * unless you're creating a new pointer to this. Management of
227 * that pointer will have to know how to deal with refcounts.
228 * Return true if the resource has not already been released.
229 */
230 CacheEntry* ref() {
231 ++refcount;
232 return this;
233 }
234
235 /**
236 * Destructions removes a reference, so don't call this unless
237 * you're removing pointer to this somewhere. Management of that
238 * pointer will have to know how to deal with refcounts. Once
239 * the refcount drops to zero, the resource is released. Return
240 * false if the resouce has been released.
241 */
242 CacheEntry* unref() {
243 if ((--refcount) == 0) {
244 delete this;
245 return NULL;
246 }
247 return this;
248 }
249
250 /**
251 * Return TRUE if there is at least one reference to this and the
252 * resource has not been released.
253 */
254 UBool isShared() const {
255 return refcount > 1;
256 }
b75a7d8f
A
257};
258
259// UObjectDeleter for serviceCache
374ca955
A
260U_CDECL_BEGIN
261static void U_CALLCONV
b75a7d8f 262cacheDeleter(void* obj) {
46f4442e 263 U_NAMESPACE_USE ((CacheEntry*)obj)->unref();
b75a7d8f
A
264}
265
266/**
46f4442e
A
267* Deleter for UObjects
268*/
374ca955 269static void U_CALLCONV
b75a7d8f 270deleteUObject(void *obj) {
46f4442e 271 U_NAMESPACE_USE delete (UObject*) obj;
b75a7d8f 272}
374ca955 273U_CDECL_END
b75a7d8f
A
274
275/*
46f4442e
A
276******************************************************************
277*/
b75a7d8f
A
278
279class DNCache : public UMemory {
280public:
46f4442e
A
281 Hashtable cache;
282 const Locale locale;
283
284 DNCache(const Locale& _locale)
285 : cache(), locale(_locale)
286 {
4388f060 287 // cache.setKeyDeleter(uprv_deleteUObject);
46f4442e 288 }
b75a7d8f
A
289};
290
291
292/*
46f4442e
A
293******************************************************************
294*/
b75a7d8f
A
295
296StringPair*
297StringPair::create(const UnicodeString& displayName,
298 const UnicodeString& id,
299 UErrorCode& status)
300{
46f4442e
A
301 if (U_SUCCESS(status)) {
302 StringPair* sp = new StringPair(displayName, id);
303 if (sp == NULL || sp->isBogus()) {
304 status = U_MEMORY_ALLOCATION_ERROR;
305 delete sp;
306 return NULL;
307 }
308 return sp;
b75a7d8f 309 }
46f4442e 310 return NULL;
b75a7d8f
A
311}
312
313UBool
314StringPair::isBogus() const {
46f4442e 315 return displayName.isBogus() || id.isBogus();
b75a7d8f
A
316}
317
318StringPair::StringPair(const UnicodeString& _displayName,
319 const UnicodeString& _id)
46f4442e
A
320: displayName(_displayName)
321, id(_id)
b75a7d8f
A
322{
323}
324
46f4442e
A
325U_CDECL_BEGIN
326static void U_CALLCONV
374ca955 327userv_deleteStringPair(void *obj) {
46f4442e 328 U_NAMESPACE_USE delete (StringPair*) obj;
b75a7d8f 329}
46f4442e 330U_CDECL_END
b75a7d8f
A
331
332/*
46f4442e
A
333******************************************************************
334*/
b75a7d8f 335
51004dcb 336static UMutex lock = U_MUTEX_INITIALIZER;
4388f060 337
b75a7d8f 338ICUService::ICUService()
46f4442e 339: name()
46f4442e
A
340, timestamp(0)
341, factories(NULL)
342, serviceCache(NULL)
343, idCache(NULL)
344, dnCache(NULL)
b75a7d8f 345{
b75a7d8f
A
346}
347
348ICUService::ICUService(const UnicodeString& newName)
46f4442e 349: name(newName)
46f4442e
A
350, timestamp(0)
351, factories(NULL)
352, serviceCache(NULL)
353, idCache(NULL)
354, dnCache(NULL)
355{
b75a7d8f
A
356}
357
358ICUService::~ICUService()
46f4442e
A
359{
360 {
361 Mutex mutex(&lock);
362 clearCaches();
363 delete factories;
364 factories = NULL;
365 }
b75a7d8f
A
366}
367
368UObject*
369ICUService::get(const UnicodeString& descriptor, UErrorCode& status) const
370{
46f4442e 371 return get(descriptor, NULL, status);
b75a7d8f
A
372}
373
374UObject*
375ICUService::get(const UnicodeString& descriptor, UnicodeString* actualReturn, UErrorCode& status) const
376{
46f4442e 377 UObject* result = NULL;
b75a7d8f
A
378 ICUServiceKey* key = createKey(&descriptor, status);
379 if (key) {
46f4442e
A
380 result = getKey(*key, actualReturn, status);
381 delete key;
b75a7d8f 382 }
46f4442e 383 return result;
b75a7d8f
A
384}
385
386UObject*
387ICUService::getKey(ICUServiceKey& key, UErrorCode& status) const
388{
46f4442e 389 return getKey(key, NULL, status);
b75a7d8f
A
390}
391
392// this is a vector that subclasses of ICUService can override to further customize the result object
393// before returning it. All other public get functions should call this one.
394
395UObject*
396ICUService::getKey(ICUServiceKey& key, UnicodeString* actualReturn, UErrorCode& status) const
397{
46f4442e 398 return getKey(key, actualReturn, NULL, status);
b75a7d8f
A
399}
400
401// make it possible to call reentrantly on systems that don't have reentrant mutexes.
402// we can use this simple approach since we know the situation where we're calling
403// reentrantly even without knowing the thread.
404class XMutex : public UMemory {
405public:
51004dcb 406 inline XMutex(UMutex *mutex, UBool reentering)
46f4442e
A
407 : fMutex(mutex)
408 , fActive(!reentering)
409 {
410 if (fActive) umtx_lock(fMutex);
411 }
412 inline ~XMutex() {
413 if (fActive) umtx_unlock(fMutex);
414 }
b75a7d8f
A
415
416private:
51004dcb 417 UMutex *fMutex;
46f4442e 418 UBool fActive;
b75a7d8f
A
419};
420
421struct UVectorDeleter {
46f4442e
A
422 UVector* _obj;
423 UVectorDeleter() : _obj(NULL) {}
424 ~UVectorDeleter() { delete _obj; }
b75a7d8f
A
425};
426
427// called only by factories, treat as private
428UObject*
429ICUService::getKey(ICUServiceKey& key, UnicodeString* actualReturn, const ICUServiceFactory* factory, UErrorCode& status) const
430{
46f4442e 431 if (U_FAILURE(status)) {
b75a7d8f 432 return NULL;
b75a7d8f
A
433 }
434
46f4442e
A
435 if (isDefault()) {
436 return handleDefault(key, actualReturn, status);
437 }
b75a7d8f 438
46f4442e 439 ICUService* ncthis = (ICUService*)this; // cast away semantic const
b75a7d8f 440
46f4442e
A
441 CacheEntry* result = NULL;
442 {
443 // The factory list can't be modified until we're done,
444 // otherwise we might update the cache with an invalid result.
445 // The cache has to stay in synch with the factory list.
446 // ICU doesn't have monitors so we can't use rw locks, so
447 // we single-thread everything using this service, for now.
448
449 // if factory is not null, we're calling from within the mutex,
450 // and since some unix machines don't have reentrant mutexes we
451 // need to make sure not to try to lock it again.
4388f060 452 XMutex mutex(&lock, factory != NULL);
46f4442e
A
453
454 if (serviceCache == NULL) {
455 ncthis->serviceCache = new Hashtable(status);
456 if (ncthis->serviceCache == NULL) {
457 return NULL;
458 }
459 if (U_FAILURE(status)) {
460 delete serviceCache;
461 return NULL;
462 }
463 serviceCache->setValueDeleter(cacheDeleter);
b75a7d8f 464 }
b75a7d8f 465
46f4442e
A
466 UnicodeString currentDescriptor;
467 UVectorDeleter cacheDescriptorList;
468 UBool putInCache = FALSE;
b75a7d8f 469
46f4442e
A
470 int32_t startIndex = 0;
471 int32_t limit = factories->size();
472 UBool cacheResult = TRUE;
b75a7d8f 473
46f4442e
A
474 if (factory != NULL) {
475 for (int32_t i = 0; i < limit; ++i) {
476 if (factory == (const ICUServiceFactory*)factories->elementAt(i)) {
477 startIndex = i + 1;
478 break;
479 }
480 }
481 if (startIndex == 0) {
482 // throw new InternalError("Factory " + factory + "not registered with service: " + this);
483 status = U_ILLEGAL_ARGUMENT_ERROR;
484 return NULL;
485 }
486 cacheResult = FALSE;
b75a7d8f
A
487 }
488
46f4442e
A
489 do {
490 currentDescriptor.remove();
491 key.currentDescriptor(currentDescriptor);
492 result = (CacheEntry*)serviceCache->get(currentDescriptor);
493 if (result != NULL) {
494 break;
495 }
496
497 // first test of cache failed, so we'll have to update
498 // the cache if we eventually succeed-- that is, if we're
499 // going to update the cache at all.
500 putInCache = TRUE;
501
502 int32_t index = startIndex;
503 while (index < limit) {
504 ICUServiceFactory* f = (ICUServiceFactory*)factories->elementAt(index++);
505 UObject* service = f->create(key, this, status);
506 if (U_FAILURE(status)) {
507 delete service;
508 return NULL;
509 }
510 if (service != NULL) {
511 result = new CacheEntry(currentDescriptor, service);
512 if (result == NULL) {
513 delete service;
514 status = U_MEMORY_ALLOCATION_ERROR;
515 return NULL;
516 }
517
518 goto outerEnd;
519 }
520 }
521
522 // prepare to load the cache with all additional ids that
523 // will resolve to result, assuming we'll succeed. We
524 // don't want to keep querying on an id that's going to
525 // fallback to the one that succeeded, we want to hit the
526 // cache the first time next goaround.
527 if (cacheDescriptorList._obj == NULL) {
4388f060 528 cacheDescriptorList._obj = new UVector(uprv_deleteUObject, NULL, 5, status);
46f4442e
A
529 if (U_FAILURE(status)) {
530 return NULL;
531 }
532 }
533 UnicodeString* idToCache = new UnicodeString(currentDescriptor);
534 if (idToCache == NULL || idToCache->isBogus()) {
535 status = U_MEMORY_ALLOCATION_ERROR;
536 return NULL;
537 }
538
539 cacheDescriptorList._obj->addElement(idToCache, status);
b75a7d8f 540 if (U_FAILURE(status)) {
46f4442e
A
541 return NULL;
542 }
543 } while (key.fallback());
544outerEnd:
545
546 if (result != NULL) {
547 if (putInCache && cacheResult) {
548 serviceCache->put(result->actualDescriptor, result, status);
549 if (U_FAILURE(status)) {
550 delete result;
551 return NULL;
552 }
553
554 if (cacheDescriptorList._obj != NULL) {
555 for (int32_t i = cacheDescriptorList._obj->size(); --i >= 0;) {
556 UnicodeString* desc = (UnicodeString*)cacheDescriptorList._obj->elementAt(i);
557 serviceCache->put(*desc, result, status);
558 if (U_FAILURE(status)) {
559 delete result;
560 return NULL;
561 }
562
563 result->ref();
564 cacheDescriptorList._obj->removeElementAt(i);
565 }
566 }
b75a7d8f
A
567 }
568
46f4442e
A
569 if (actualReturn != NULL) {
570 // strip null prefix
571 if (result->actualDescriptor.indexOf((UChar)0x2f) == 0) { // U+002f=slash (/)
572 actualReturn->remove();
573 actualReturn->append(result->actualDescriptor,
574 1,
575 result->actualDescriptor.length() - 1);
576 } else {
577 *actualReturn = result->actualDescriptor;
578 }
579
580 if (actualReturn->isBogus()) {
581 status = U_MEMORY_ALLOCATION_ERROR;
582 delete result;
583 return NULL;
584 }
585 }
b75a7d8f 586
46f4442e
A
587 UObject* service = cloneInstance(result->service);
588 if (putInCache && !cacheResult) {
589 delete result;
590 }
591 return service;
b75a7d8f 592 }
b75a7d8f 593 }
b75a7d8f 594
46f4442e 595 return handleDefault(key, actualReturn, status);
b75a7d8f
A
596}
597
598UObject*
374ca955 599ICUService::handleDefault(const ICUServiceKey& /* key */, UnicodeString* /* actualIDReturn */, UErrorCode& /* status */) const
b75a7d8f 600{
46f4442e 601 return NULL;
b75a7d8f 602}
46f4442e 603
b75a7d8f
A
604UVector&
605ICUService::getVisibleIDs(UVector& result, UErrorCode& status) const {
46f4442e 606 return getVisibleIDs(result, NULL, status);
b75a7d8f
A
607}
608
609UVector&
610ICUService::getVisibleIDs(UVector& result, const UnicodeString* matchID, UErrorCode& status) const
611{
46f4442e 612 result.removeAllElements();
b75a7d8f 613
46f4442e
A
614 if (U_FAILURE(status)) {
615 return result;
616 }
b75a7d8f 617
46f4442e 618 {
4388f060 619 Mutex mutex(&lock);
46f4442e
A
620 const Hashtable* map = getVisibleIDMap(status);
621 if (map != NULL) {
622 ICUServiceKey* fallbackKey = createKey(matchID, status);
623
b331163b 624 for (int32_t pos = UHASH_FIRST;;) {
46f4442e
A
625 const UHashElement* e = map->nextElement(pos);
626 if (e == NULL) {
627 break;
628 }
629
630 const UnicodeString* id = (const UnicodeString*)e->key.pointer;
631 if (fallbackKey != NULL) {
632 if (!fallbackKey->isFallbackOf(*id)) {
633 continue;
634 }
635 }
636
637 UnicodeString* idClone = new UnicodeString(*id);
638 if (idClone == NULL || idClone->isBogus()) {
639 delete idClone;
640 status = U_MEMORY_ALLOCATION_ERROR;
641 break;
642 }
643 result.addElement(idClone, status);
644 if (U_FAILURE(status)) {
645 delete idClone;
646 break;
647 }
648 }
649 delete fallbackKey;
b75a7d8f 650 }
b75a7d8f 651 }
46f4442e
A
652 if (U_FAILURE(status)) {
653 result.removeAllElements();
654 }
655 return result;
b75a7d8f
A
656}
657
658const Hashtable*
659ICUService::getVisibleIDMap(UErrorCode& status) const {
46f4442e 660 if (U_FAILURE(status)) return NULL;
b75a7d8f 661
46f4442e 662 // must only be called when lock is already held
b75a7d8f 663
46f4442e 664 ICUService* ncthis = (ICUService*)this; // cast away semantic const
b75a7d8f 665 if (idCache == NULL) {
46f4442e
A
666 ncthis->idCache = new Hashtable(status);
667 if (idCache == NULL) {
668 status = U_MEMORY_ALLOCATION_ERROR;
669 } else if (factories != NULL) {
670 for (int32_t pos = factories->size(); --pos >= 0;) {
671 ICUServiceFactory* f = (ICUServiceFactory*)factories->elementAt(pos);
672 f->updateVisibleIDs(*idCache, status);
673 }
674 if (U_FAILURE(status)) {
675 delete idCache;
676 ncthis->idCache = NULL;
677 }
678 }
b75a7d8f 679 }
b75a7d8f 680
46f4442e 681 return idCache;
b75a7d8f
A
682}
683
46f4442e 684
b75a7d8f
A
685UnicodeString&
686ICUService::getDisplayName(const UnicodeString& id, UnicodeString& result) const
687{
46f4442e 688 return getDisplayName(id, result, Locale::getDefault());
b75a7d8f
A
689}
690
691UnicodeString&
692ICUService::getDisplayName(const UnicodeString& id, UnicodeString& result, const Locale& locale) const
693{
46f4442e 694 {
46f4442e 695 UErrorCode status = U_ZERO_ERROR;
4388f060 696 Mutex mutex(&lock);
46f4442e
A
697 const Hashtable* map = getVisibleIDMap(status);
698 if (map != NULL) {
699 ICUServiceFactory* f = (ICUServiceFactory*)map->get(id);
700 if (f != NULL) {
701 f->getDisplayName(id, locale, result);
702 return result;
703 }
704
705 // fallback
706 UErrorCode status = U_ZERO_ERROR;
707 ICUServiceKey* fallbackKey = createKey(&id, status);
708 while (fallbackKey->fallback()) {
709 UnicodeString us;
710 fallbackKey->currentID(us);
711 f = (ICUServiceFactory*)map->get(us);
712 if (f != NULL) {
713 f->getDisplayName(id, locale, result);
714 delete fallbackKey;
715 return result;
716 }
717 }
718 delete fallbackKey;
719 }
720 }
721 result.setToBogus();
722 return result;
b75a7d8f
A
723}
724
725UVector&
726ICUService::getDisplayNames(UVector& result, UErrorCode& status) const
727{
46f4442e 728 return getDisplayNames(result, Locale::getDefault(), NULL, status);
b75a7d8f
A
729}
730
731
732UVector&
733ICUService::getDisplayNames(UVector& result, const Locale& locale, UErrorCode& status) const
734{
46f4442e 735 return getDisplayNames(result, locale, NULL, status);
b75a7d8f
A
736}
737
738UVector&
739ICUService::getDisplayNames(UVector& result,
740 const Locale& locale,
741 const UnicodeString* matchID,
742 UErrorCode& status) const
743{
46f4442e
A
744 result.removeAllElements();
745 result.setDeleter(userv_deleteStringPair);
746 if (U_SUCCESS(status)) {
747 ICUService* ncthis = (ICUService*)this; // cast away semantic const
4388f060 748 Mutex mutex(&lock);
b75a7d8f 749
46f4442e
A
750 if (dnCache != NULL && dnCache->locale != locale) {
751 delete dnCache;
752 ncthis->dnCache = NULL;
b75a7d8f
A
753 }
754
46f4442e
A
755 if (dnCache == NULL) {
756 const Hashtable* m = getVisibleIDMap(status);
4388f060
A
757 if (U_FAILURE(status)) {
758 return result;
759 }
760 ncthis->dnCache = new DNCache(locale);
761 if (dnCache == NULL) {
762 status = U_MEMORY_ALLOCATION_ERROR;
763 return result;
764 }
46f4442e 765
b331163b 766 int32_t pos = UHASH_FIRST;
4388f060
A
767 const UHashElement* entry = NULL;
768 while ((entry = m->nextElement(pos)) != NULL) {
769 const UnicodeString* id = (const UnicodeString*)entry->key.pointer;
770 ICUServiceFactory* f = (ICUServiceFactory*)entry->value.pointer;
771 UnicodeString dname;
772 f->getDisplayName(*id, locale, dname);
773 if (dname.isBogus()) {
774 status = U_MEMORY_ALLOCATION_ERROR;
775 } else {
776 dnCache->cache.put(dname, (void*)id, status); // share pointer with visibleIDMap
777 if (U_SUCCESS(status)) {
778 continue;
46f4442e 779 }
46f4442e 780 }
4388f060
A
781 delete dnCache;
782 ncthis->dnCache = NULL;
783 return result;
b75a7d8f 784 }
b75a7d8f 785 }
b75a7d8f 786 }
b75a7d8f 787
46f4442e
A
788 ICUServiceKey* matchKey = createKey(matchID, status);
789 /* To ensure that all elements in the hashtable are iterated, set pos to -1.
790 * nextElement(pos) will skip the position at pos and begin the iteration
791 * at the next position, which in this case will be 0.
792 */
b331163b 793 int32_t pos = UHASH_FIRST;
46f4442e
A
794 const UHashElement *entry = NULL;
795 while ((entry = dnCache->cache.nextElement(pos)) != NULL) {
796 const UnicodeString* id = (const UnicodeString*)entry->value.pointer;
797 if (matchKey != NULL && !matchKey->isFallbackOf(*id)) {
798 continue;
799 }
800 const UnicodeString* dn = (const UnicodeString*)entry->key.pointer;
801 StringPair* sp = StringPair::create(*id, *dn, status);
802 result.addElement(sp, status);
803 if (U_FAILURE(status)) {
804 result.removeAllElements();
805 break;
806 }
b75a7d8f 807 }
46f4442e 808 delete matchKey;
b75a7d8f 809
46f4442e 810 return result;
b75a7d8f
A
811}
812
813URegistryKey
814ICUService::registerInstance(UObject* objToAdopt, const UnicodeString& id, UErrorCode& status)
815{
46f4442e 816 return registerInstance(objToAdopt, id, TRUE, status);
b75a7d8f
A
817}
818
819URegistryKey
820ICUService::registerInstance(UObject* objToAdopt, const UnicodeString& id, UBool visible, UErrorCode& status)
821{
46f4442e
A
822 ICUServiceKey* key = createKey(&id, status);
823 if (key != NULL) {
824 UnicodeString canonicalID;
825 key->canonicalID(canonicalID);
826 delete key;
b75a7d8f 827
46f4442e
A
828 ICUServiceFactory* f = createSimpleFactory(objToAdopt, canonicalID, visible, status);
829 if (f != NULL) {
830 return registerFactory(f, status);
831 }
b75a7d8f 832 }
46f4442e
A
833 delete objToAdopt;
834 return NULL;
b75a7d8f
A
835}
836
837ICUServiceFactory*
838ICUService::createSimpleFactory(UObject* objToAdopt, const UnicodeString& id, UBool visible, UErrorCode& status)
839{
46f4442e
A
840 if (U_SUCCESS(status)) {
841 if ((objToAdopt != NULL) && (!id.isBogus())) {
842 return new SimpleFactory(objToAdopt, id, visible);
843 }
844 status = U_ILLEGAL_ARGUMENT_ERROR;
b75a7d8f 845 }
46f4442e 846 return NULL;
b75a7d8f
A
847}
848
849URegistryKey
850ICUService::registerFactory(ICUServiceFactory* factoryToAdopt, UErrorCode& status)
851{
46f4442e
A
852 if (U_SUCCESS(status) && factoryToAdopt != NULL) {
853 Mutex mutex(&lock);
b75a7d8f 854
46f4442e
A
855 if (factories == NULL) {
856 factories = new UVector(deleteUObject, NULL, status);
857 if (U_FAILURE(status)) {
858 delete factories;
859 return NULL;
860 }
861 }
862 factories->insertElementAt(factoryToAdopt, 0, status);
863 if (U_SUCCESS(status)) {
864 clearCaches();
865 } else {
866 delete factoryToAdopt;
867 factoryToAdopt = NULL;
868 }
b75a7d8f 869 }
b75a7d8f 870
46f4442e
A
871 if (factoryToAdopt != NULL) {
872 notifyChanged();
873 }
b75a7d8f 874
46f4442e 875 return (URegistryKey)factoryToAdopt;
b75a7d8f
A
876}
877
878UBool
879ICUService::unregister(URegistryKey rkey, UErrorCode& status)
880{
46f4442e
A
881 ICUServiceFactory *factory = (ICUServiceFactory*)rkey;
882 UBool result = FALSE;
883 if (factory != NULL && factories != NULL) {
884 Mutex mutex(&lock);
b75a7d8f 885
46f4442e
A
886 if (factories->removeElement(factory)) {
887 clearCaches();
888 result = TRUE;
889 } else {
890 status = U_ILLEGAL_ARGUMENT_ERROR;
891 delete factory;
892 }
b75a7d8f 893 }
46f4442e
A
894 if (result) {
895 notifyChanged();
896 }
897 return result;
b75a7d8f
A
898}
899
900void
901ICUService::reset()
902{
46f4442e
A
903 {
904 Mutex mutex(&lock);
905 reInitializeFactories();
906 clearCaches();
907 }
908 notifyChanged();
b75a7d8f
A
909}
910
911void
912ICUService::reInitializeFactories()
913{
46f4442e
A
914 if (factories != NULL) {
915 factories->removeAllElements();
916 }
b75a7d8f
A
917}
918
919UBool
920ICUService::isDefault() const
921{
46f4442e 922 return countFactories() == 0;
b75a7d8f
A
923}
924
925ICUServiceKey*
926ICUService::createKey(const UnicodeString* id, UErrorCode& status) const
927{
46f4442e 928 return (U_FAILURE(status) || id == NULL) ? NULL : new ICUServiceKey(*id);
b75a7d8f
A
929}
930
931void
932ICUService::clearCaches()
933{
46f4442e
A
934 // callers synchronize before use
935 ++timestamp;
936 delete dnCache;
937 dnCache = NULL;
938 delete idCache;
939 idCache = NULL;
940 delete serviceCache; serviceCache = NULL;
b75a7d8f
A
941}
942
943void
944ICUService::clearServiceCache()
945{
46f4442e
A
946 // callers synchronize before use
947 delete serviceCache; serviceCache = NULL;
b75a7d8f
A
948}
949
950UBool
951ICUService::acceptsListener(const EventListener& l) const
952{
729e4ab9 953 return dynamic_cast<const ServiceListener*>(&l) != NULL;
b75a7d8f
A
954}
955
956void
957ICUService::notifyListener(EventListener& l) const
958{
46f4442e 959 ((ServiceListener&)l).serviceChanged(*this);
b75a7d8f
A
960}
961
962UnicodeString&
963ICUService::getName(UnicodeString& result) const
964{
46f4442e 965 return result.append(name);
b75a7d8f
A
966}
967
968int32_t
969ICUService::countFactories() const
970{
46f4442e 971 return factories == NULL ? 0 : factories->size();
b75a7d8f
A
972}
973
974int32_t
975ICUService::getTimestamp() const
976{
46f4442e 977 return timestamp;
b75a7d8f
A
978}
979
980U_NAMESPACE_END
981
982/* UCONFIG_NO_SERVICE */
983#endif