Chromium Code Reviews| Index: src/core/SkCachedData.cpp |
| diff --git a/src/core/SkCachedData.cpp b/src/core/SkCachedData.cpp |
| new file mode 100644 |
| index 0000000000000000000000000000000000000000..19bc42fc82c3a780ce70a35d4c50238dbded8ad3 |
| --- /dev/null |
| +++ b/src/core/SkCachedData.cpp |
| @@ -0,0 +1,126 @@ |
| +/* |
| + * Copyright 2014 Google Inc. |
| + * |
| + * Use of this source code is governed by a BSD-style license that can be |
| + * found in the LICENSE file. |
| + */ |
| + |
| +#include "SkCachedData_priv.h" |
| +#include "SkRefCnt.h" |
| +#include "SkDiscardableMemory.h" |
| + |
| +SkCachedData::SkCachedData(void* data, size_t size) |
| + : fData(data) |
| + , fSize(size) |
| + , fRefCnt(2) // 1 owner, not in cache |
| +{} |
| + |
| +void SkCachedData::ref() { |
| + const int32_t count = sk_atomic_add(&fRefCnt, 2) + 2; |
| + const int owners = count >> 1; |
| + const int in_cache = count & 1; |
| + |
| + SkASSERT(owners >= 2); |
| + |
| + if (2 == owners) { |
| + sk_membar_acquire__after_atomic_dec(); |
| + if (in_cache) { |
|
mtklein
2014/09/23 22:16:55
So, if I add SkASSERT(in_cache) just before each i
reed2
2014/09/24 01:23:57
Sounds like I need to expand my tests to (try to)
|
| + this->lock(); |
| + } |
| + } |
| +} |
| + |
| +void SkCachedData::unref() { |
| + const int32_t count = sk_atomic_add(&fRefCnt, -2) - 2; |
| + const int owners = count >> 1; |
| + const int in_cache = count & 1; |
| + |
| + switch (owners) { |
| + case 0: |
| + sk_membar_acquire__after_atomic_dec(); |
| + SkDELETE(this); |
| + break; |
| + case 1: |
| + sk_membar_acquire__after_atomic_dec(); |
| + if (in_cache) { |
| + this->unlock(); |
| + } |
| + break; |
| + default: |
| + break; |
| + } |
| +} |
| + |
| +void SkCachedData::ref_from_cache() { |
| + SkASSERT(0 == (fRefCnt & 1)); |
| + sk_atomic_add(&fRefCnt, 3); |
| +} |
| + |
| +void SkCachedData::unref_from_cache() { |
| + SkASSERT(1 == (fRefCnt & 1)); |
| + sk_atomic_add(&fRefCnt, -3); |
| +} |
| + |
| +/////////////////////////////////////////////////////////////////////////////////////////////////// |
| + |
| +class SkCachedData_Discardable : public SkCachedData { |
| +public: |
| + // we take ownership of dm |
| + SkCachedData_Discardable(SkDiscardableMemory* dm, size_t size) |
| + : INHERITED(dm->data(), size) |
| + , fDM(dm) |
| + , fSuccessfulLock(false) |
| + {} |
| + |
| + virtual ~SkCachedData_Discardable() { |
| + SkDELETE(fDM); |
| + } |
| + |
| +protected: |
| + virtual void onLock() SK_OVERRIDE { |
| + fSuccessfulLock = fDM->lock(); |
| + this->setData(fSuccessfulLock ? fDM->data() : NULL); |
| + } |
| + |
| + virtual void onUnlock() SK_OVERRIDE { |
| + if (fSuccessfulLock) { |
| + fDM->unlock(); |
| + } |
| + } |
| + |
| +private: |
| + SkDiscardableMemory* fDM; |
| + bool fSuccessfulLock; |
| + |
| + typedef SkCachedData INHERITED; |
| +}; |
| + |
| +class SkCachedData_Malloc : public SkCachedData { |
| +public: |
| + // data was allocated via sk_malloc |
| + SkCachedData_Malloc(void* data, size_t size) : INHERITED(data, size), fMallocData(data) {} |
| + |
| + virtual ~SkCachedData_Malloc() { |
| + sk_free(fMallocData); |
| + } |
| + |
| + virtual void onLock() SK_OVERRIDE { |
| + this->setData(fMallocData); |
| + } |
| + |
| + virtual void onUnlock() SK_OVERRIDE {} |
| + |
| +private: |
| + void* fMallocData; |
| + |
| + typedef SkCachedData INHERITED; |
| +}; |
| + |
| +SkCachedData* SkCachedData::Create(size_t size, SkDiscardableMemory* dm) { |
| + if (dm) { |
| + return SkNEW_ARGS(SkCachedData_Discardable, (dm, size)); |
| + } else { |
| + return SkNEW_ARGS(SkCachedData_Malloc, (sk_malloc_throw(size), size)); |
| + } |
| +} |
| + |