230
236
public void unpinAll() {
231
executorServiceStore.unpinAll();
237
if (isCurrentThreadNonstopThread()) {
238
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().unpinAll();
240
executorServiceStore.unpinAll();
237
247
public boolean isPinned(Object key) {
238
return executorServiceStore.isPinned(key);
248
if (isCurrentThreadNonstopThread()) {
249
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().isPinned(key);
251
return executorServiceStore.isPinned(key);
244
258
public void setPinned(Object key, boolean pinned) {
245
executorServiceStore.setPinned(key, pinned);
259
if (isCurrentThreadNonstopThread()) {
260
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().setPinned(key, pinned);
262
executorServiceStore.setPinned(key, pinned);
251
269
public void addStoreListener(StoreListener listener) {
252
executorServiceStore.addStoreListener(listener);
270
if (isCurrentThreadNonstopThread()) {
271
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().addStoreListener(listener);
273
executorServiceStore.addStoreListener(listener);
258
280
public void removeStoreListener(StoreListener listener) {
259
executorServiceStore.removeStoreListener(listener);
281
if (isCurrentThreadNonstopThread()) {
282
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().removeStoreListener(listener);
284
executorServiceStore.removeStoreListener(listener);
273
299
public boolean isCacheCoherent() {
274
return executorServiceStore.isCacheCoherent();
300
if (isCurrentThreadNonstopThread()) {
301
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().isCacheCoherent();
303
return executorServiceStore.isCacheCoherent();
280
310
public boolean isClusterCoherent() {
281
return executorServiceStore.isClusterCoherent();
311
if (isCurrentThreadNonstopThread()) {
312
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().isClusterCoherent();
314
return executorServiceStore.isClusterCoherent();
287
321
public boolean isNodeCoherent() {
288
return executorServiceStore.isNodeCoherent();
322
if (isCurrentThreadNonstopThread()) {
323
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().isNodeCoherent();
325
return executorServiceStore.isNodeCoherent();
294
332
public void setNodeCoherent(boolean coherent) throws UnsupportedOperationException {
295
executorServiceStore.setNodeCoherent(coherent);
333
if (isCurrentThreadNonstopThread()) {
334
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().setNodeCoherent(coherent);
336
executorServiceStore.setNodeCoherent(coherent);
301
343
public void dispose() {
302
executorServiceStore.dispose();
344
if (isCurrentThreadNonstopThread()) {
345
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().dispose();
347
executorServiceStore.dispose();
308
354
public boolean containsKey(Object key) {
309
return executorServiceStore.containsKey(key);
355
if (isCurrentThreadNonstopThread()) {
356
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().containsKey(key);
358
return executorServiceStore.containsKey(key);
315
365
public boolean containsKeyInMemory(Object key) {
316
return executorServiceStore.containsKeyInMemory(key);
366
if (isCurrentThreadNonstopThread()) {
367
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().containsKeyInMemory(key);
369
return executorServiceStore.containsKeyInMemory(key);
322
376
public Results executeQuery(StoreQuery query) {
323
return executorServiceStore.executeQuery(query);
377
if (isCurrentThreadNonstopThread()) {
378
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().executeQuery(query);
380
return executorServiceStore.executeQuery(query);
329
387
public <T> Attribute<T> getSearchAttribute(String attributeName) {
330
return executorServiceStore.getSearchAttribute(attributeName);
388
if (isCurrentThreadNonstopThread()) {
389
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getSearchAttribute(attributeName);
391
return executorServiceStore.getSearchAttribute(attributeName);
336
398
public void flush() throws IOException {
337
executorServiceStore.flush();
399
if (isCurrentThreadNonstopThread()) {
400
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().flush();
402
executorServiceStore.flush();
343
409
public Element get(Object key) {
344
return executorServiceStore.get(key);
410
if (isCurrentThreadNonstopThread()) {
411
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().get(key);
413
return executorServiceStore.get(key);
350
420
public int getInMemorySize() {
351
return executorServiceStore.getInMemorySize();
421
if (isCurrentThreadNonstopThread()) {
422
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getInMemorySize();
424
return executorServiceStore.getInMemorySize();
357
431
public long getInMemorySizeInBytes() {
358
return executorServiceStore.getInMemorySizeInBytes();
432
if (isCurrentThreadNonstopThread()) {
433
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getInMemorySizeInBytes();
435
return executorServiceStore.getInMemorySizeInBytes();
364
442
public List getKeys() {
365
return executorServiceStore.getKeys();
443
if (isCurrentThreadNonstopThread()) {
444
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getKeys();
446
return executorServiceStore.getKeys();
371
453
public Element getQuiet(Object key) {
372
return executorServiceStore.getQuiet(key);
454
if (isCurrentThreadNonstopThread()) {
455
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getQuiet(key);
457
return executorServiceStore.getQuiet(key);
378
464
public Map<Object, Element> getAllQuiet(Collection<?> keys) {
379
return executorServiceStore.getAllQuiet(keys);
465
if (isCurrentThreadNonstopThread()) {
466
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getAllQuiet(keys);
468
return executorServiceStore.getAllQuiet(keys);
385
475
public Map<Object, Element> getAll(Collection<?> keys) {
386
return executorServiceStore.getAll(keys);
476
if (isCurrentThreadNonstopThread()) {
477
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getAll(keys);
479
return executorServiceStore.getAll(keys);
392
486
public int getSize() {
393
return executorServiceStore.getSize();
487
if (isCurrentThreadNonstopThread()) {
488
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getSize();
490
return executorServiceStore.getSize();
399
497
public int getTerracottaClusteredSize() {
400
return executorServiceStore.getTerracottaClusteredSize();
498
if (isCurrentThreadNonstopThread()) {
499
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getTerracottaClusteredSize();
501
return executorServiceStore.getTerracottaClusteredSize();
406
508
public boolean put(Element element) throws CacheException {
407
return executorServiceStore.put(element);
509
if (isCurrentThreadNonstopThread()) {
510
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().put(element);
512
return executorServiceStore.put(element);
413
519
public void putAll(Collection<Element> elements) throws CacheException {
414
executorServiceStore.putAll(elements);
520
if (isCurrentThreadNonstopThread()) {
521
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().putAll(elements);
523
executorServiceStore.putAll(elements);
420
530
public Element putIfAbsent(Element element) throws NullPointerException {
421
return executorServiceStore.putIfAbsent(element);
531
if (isCurrentThreadNonstopThread()) {
532
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().putIfAbsent(element);
534
return executorServiceStore.putIfAbsent(element);
427
541
public boolean putWithWriter(Element element, CacheWriterManager writerManager) throws CacheException {
428
return executorServiceStore.putWithWriter(element, writerManager);
542
if (isCurrentThreadNonstopThread()) {
543
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().putWithWriter(element, writerManager);
545
return executorServiceStore.putWithWriter(element, writerManager);
434
552
public Element remove(Object key) {
435
return executorServiceStore.remove(key);
553
if (isCurrentThreadNonstopThread()) {
554
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().remove(key);
556
return executorServiceStore.remove(key);
441
563
public void removeAll(final Collection<?> keys) {
442
executorServiceStore.removeAll(keys);
564
if (isCurrentThreadNonstopThread()) {
565
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().removeAll(keys);
567
executorServiceStore.removeAll(keys);
448
574
public void removeAll() throws CacheException {
449
executorServiceStore.removeAll();
575
if (isCurrentThreadNonstopThread()) {
576
nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().removeAll();
578
executorServiceStore.removeAll();
455
585
public Element removeElement(Element element, ElementValueComparator comparator) throws NullPointerException {
456
return executorServiceStore.removeElement(element, comparator);
586
if (isCurrentThreadNonstopThread()) {
587
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().removeElement(element, comparator);
589
return executorServiceStore.removeElement(element, comparator);
462
596
public Element removeWithWriter(Object key, CacheWriterManager writerManager) throws CacheException {
463
return executorServiceStore.removeWithWriter(key, writerManager);
597
if (isCurrentThreadNonstopThread()) {
598
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().removeWithWriter(key, writerManager);
600
return executorServiceStore.removeWithWriter(key, writerManager);
469
607
public boolean replace(Element old, Element element, ElementValueComparator comparator) throws NullPointerException,
470
608
IllegalArgumentException {
471
return executorServiceStore.replace(old, element, comparator);
609
if (isCurrentThreadNonstopThread()) {
610
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().replace(old, element, comparator);
612
return executorServiceStore.replace(old, element, comparator);
477
619
public Element replace(Element element) throws NullPointerException {
478
return executorServiceStore.replace(element);
620
if (isCurrentThreadNonstopThread()) {
621
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().replace(element);
623
return executorServiceStore.replace(element);
484
630
public Set getLocalKeys() {
485
return executorServiceStore.getLocalKeys();
631
if (isCurrentThreadNonstopThread()) {
632
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getLocalKeys();
634
return executorServiceStore.getLocalKeys();
491
641
public CacheConfiguration.TransactionalMode getTransactionalMode() {
492
return executorServiceStore.getTransactionalMode();
642
if (isCurrentThreadNonstopThread()) {
643
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().getTransactionalMode();
645
return executorServiceStore.getTransactionalMode();
498
652
public Element unlockedGet(Object key) {
499
return executorServiceStore.unlockedGet(key);
653
if (isCurrentThreadNonstopThread()) {
654
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().unlockedGet(key);
656
return executorServiceStore.unlockedGet(key);
505
663
public Element unlockedGetQuiet(Object key) {
506
return executorServiceStore.unlockedGetQuiet(key);
664
if (isCurrentThreadNonstopThread()) {
665
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().unlockedGetQuiet(key);
667
return executorServiceStore.unlockedGetQuiet(key);
512
674
public Element unsafeGet(Object key) {
513
return executorServiceStore.unsafeGet(key);
675
if (isCurrentThreadNonstopThread()) {
676
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().unsafeGet(key);
678
return executorServiceStore.unsafeGet(key);
519
685
public Element unsafeGetQuiet(Object key) {
520
return executorServiceStore.unsafeGetQuiet(key);
686
if (isCurrentThreadNonstopThread()) {
687
return nonstopActiveDelegateHolder.getUnderlyingTerracottaStore().unsafeGetQuiet(key);
689
return executorServiceStore.unsafeGetQuiet(key);
526
696
public <V> V executeClusterOperation(ClusterOperation<V> operation) {
527
return executorServiceStore.executeClusterOperation(operation);
697
if (isCurrentThreadNonstopThread()) {
699
return operation.performClusterOperation();
700
} catch (Exception e) {
701
throw new RuntimeException(e);
704
return executorServiceStore.executeClusterOperation(operation);