From 9317f8f5336f989aade75ceb925391262b1ccdca Mon Sep 17 00:00:00 2001 From: Dan Sinclair Date: Thu, 21 Sep 2017 16:19:19 -0400 Subject: Move CFX_SharedCopyOnWrite to SharedCopyOnWrite This CL renames CFX_SharedCopyOnWrite to SharedCopyOnWrite and moves to the fxcrt namespace. Bug: pdfium:898 Change-Id: Iced796b9f341407720e2a88f11d1916df56fe68c Reviewed-on: https://pdfium-review.googlesource.com/14617 Commit-Queue: dsinclair Reviewed-by: Tom Sepez --- core/fxcrt/cfx_shared_copy_on_write.h | 85 --------------- core/fxcrt/cfx_shared_copy_on_write_unittest.cpp | 128 ----------------------- core/fxcrt/shared_copy_on_write.h | 91 ++++++++++++++++ core/fxcrt/shared_copy_on_write_unittest.cpp | 128 +++++++++++++++++++++++ 4 files changed, 219 insertions(+), 213 deletions(-) delete mode 100644 core/fxcrt/cfx_shared_copy_on_write.h delete mode 100644 core/fxcrt/cfx_shared_copy_on_write_unittest.cpp create mode 100644 core/fxcrt/shared_copy_on_write.h create mode 100644 core/fxcrt/shared_copy_on_write_unittest.cpp (limited to 'core/fxcrt') diff --git a/core/fxcrt/cfx_shared_copy_on_write.h b/core/fxcrt/cfx_shared_copy_on_write.h deleted file mode 100644 index f897368813..0000000000 --- a/core/fxcrt/cfx_shared_copy_on_write.h +++ /dev/null @@ -1,85 +0,0 @@ -// Copyright 2016 PDFium Authors. All rights reserved. -// Use of this source code is governed by a BSD-style license that can be -// found in the LICENSE file. - -// Original code copyright 2014 Foxit Software Inc. http://www.foxitsoftware.com - -#ifndef CORE_FXCRT_CFX_SHARED_COPY_ON_WRITE_H_ -#define CORE_FXCRT_CFX_SHARED_COPY_ON_WRITE_H_ - -#include "core/fxcrt/fx_system.h" -#include "core/fxcrt/retain_ptr.h" - -// A shared object with Copy on Write semantics that makes it appear as -// if each one were independent. -template -class CFX_SharedCopyOnWrite { - public: - CFX_SharedCopyOnWrite() {} - CFX_SharedCopyOnWrite(const CFX_SharedCopyOnWrite& other) - : m_pObject(other.m_pObject) {} - ~CFX_SharedCopyOnWrite() {} - - template - ObjClass* Emplace(Args... params) { - m_pObject.Reset(new CountedObj(params...)); - return m_pObject.Get(); - } - - CFX_SharedCopyOnWrite& operator=(const CFX_SharedCopyOnWrite& that) { - if (*this != that) - m_pObject = that.m_pObject; - return *this; - } - - void SetNull() { m_pObject.Reset(); } - const ObjClass* GetObject() const { return m_pObject.Get(); } - - template - ObjClass* GetPrivateCopy(Args... params) { - if (!m_pObject) - return Emplace(params...); - if (!m_pObject->HasOneRef()) - m_pObject.Reset(new CountedObj(*m_pObject)); - return m_pObject.Get(); - } - - bool operator==(const CFX_SharedCopyOnWrite& that) const { - return m_pObject == that.m_pObject; - } - bool operator!=(const CFX_SharedCopyOnWrite& that) const { - return !(*this == that); - } - explicit operator bool() const { return !!m_pObject; } - - private: - class CountedObj : public ObjClass { - public: - template - // NOLINTNEXTLINE(runtime/explicit) - CountedObj(Args... params) : ObjClass(params...), m_RefCount(0) {} - - CountedObj(const CountedObj& src) : ObjClass(src), m_RefCount(0) {} - ~CountedObj() { m_RefCount = 0; } - - bool HasOneRef() const { return m_RefCount == 1; } - void Retain() { m_RefCount++; } - void Release() { - ASSERT(m_RefCount); - if (--m_RefCount == 0) - delete this; - } - - private: - // To ensure ref counts do not overflow, consider the worst possible case: - // the entire address space contains nothing but pointers to this object. - // Since the count increments with each new pointer, the largest value is - // the number of pointers that can fit into the address space. The size of - // the address space itself is a good upper bound on it. - intptr_t m_RefCount; - }; - - RetainPtr m_pObject; -}; - -#endif // CORE_FXCRT_CFX_SHARED_COPY_ON_WRITE_H_ diff --git a/core/fxcrt/cfx_shared_copy_on_write_unittest.cpp b/core/fxcrt/cfx_shared_copy_on_write_unittest.cpp deleted file mode 100644 index 797837465b..0000000000 --- a/core/fxcrt/cfx_shared_copy_on_write_unittest.cpp +++ /dev/null @@ -1,128 +0,0 @@ -// Copyright 2016 PDFium Authors. All rights reserved. -// Use of this source code is governed by a BSD-style license that can be -// found in the LICENSE file. - -#include "core/fxcrt/cfx_shared_copy_on_write.h" - -#include -#include - -#include "testing/gtest/include/gtest/gtest.h" - -namespace { - -class Observer { - public: - void OnConstruct(const std::string& name) { construction_counts_[name]++; } - void OnDestruct(const std::string& name) { destruction_counts_[name]++; } - int GetConstructionCount(const std::string& name) { - return construction_counts_[name]; - } - int GetDestructionCount(const std::string& name) { - return destruction_counts_[name]; - } - - private: - std::map construction_counts_; - std::map destruction_counts_; -}; - -class Object { - public: - Object(Observer* observer, const std::string& name) - : name_(name), observer_(observer) { - observer->OnConstruct(name_); - } - Object(const Object& that) : name_(that.name_), observer_(that.observer_) { - observer_->OnConstruct(name_); - } - ~Object() { observer_->OnDestruct(name_); } - - private: - std::string name_; - Observer* observer_; -}; - -} // namespace - -TEST(fxcrt, SharedCopyOnWriteNull) { - Observer observer; - { - CFX_SharedCopyOnWrite ptr; - EXPECT_EQ(nullptr, ptr.GetObject()); - } -} - -TEST(fxcrt, SharedCopyOnWriteCopy) { - Observer observer; - { - CFX_SharedCopyOnWrite ptr1; - ptr1.Emplace(&observer, std::string("one")); - { - CFX_SharedCopyOnWrite ptr2 = ptr1; - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - } - { - CFX_SharedCopyOnWrite ptr3(ptr1); - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - } - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - } - EXPECT_EQ(1, observer.GetDestructionCount("one")); -} - -TEST(fxcrt, SharedCopyOnWriteAssignOverOld) { - Observer observer; - { - CFX_SharedCopyOnWrite ptr1; - ptr1.Emplace(&observer, std::string("one")); - ptr1.Emplace(&observer, std::string("two")); - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(1, observer.GetConstructionCount("two")); - EXPECT_EQ(1, observer.GetDestructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("two")); - } - EXPECT_EQ(1, observer.GetDestructionCount("two")); -} - -TEST(fxcrt, SharedCopyOnWriteAssignOverRetained) { - Observer observer; - { - CFX_SharedCopyOnWrite ptr1; - ptr1.Emplace(&observer, std::string("one")); - CFX_SharedCopyOnWrite ptr2(ptr1); - ptr1.Emplace(&observer, std::string("two")); - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(1, observer.GetConstructionCount("two")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("two")); - } - EXPECT_EQ(1, observer.GetDestructionCount("one")); - EXPECT_EQ(1, observer.GetDestructionCount("two")); -} - -TEST(fxcrt, SharedCopyOnWriteGetModify) { - Observer observer; - { - CFX_SharedCopyOnWrite ptr; - EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - - EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); - EXPECT_EQ(1, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - { - CFX_SharedCopyOnWrite other(ptr); - EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); - EXPECT_EQ(2, observer.GetConstructionCount("one")); - EXPECT_EQ(0, observer.GetDestructionCount("one")); - } - EXPECT_EQ(2, observer.GetConstructionCount("one")); - EXPECT_EQ(1, observer.GetDestructionCount("one")); - } - EXPECT_EQ(2, observer.GetDestructionCount("one")); -} diff --git a/core/fxcrt/shared_copy_on_write.h b/core/fxcrt/shared_copy_on_write.h new file mode 100644 index 0000000000..c04730d5e0 --- /dev/null +++ b/core/fxcrt/shared_copy_on_write.h @@ -0,0 +1,91 @@ +// Copyright 2016 PDFium Authors. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +// Original code copyright 2014 Foxit Software Inc. http://www.foxitsoftware.com + +#ifndef CORE_FXCRT_SHARED_COPY_ON_WRITE_H_ +#define CORE_FXCRT_SHARED_COPY_ON_WRITE_H_ + +#include "core/fxcrt/fx_system.h" +#include "core/fxcrt/retain_ptr.h" + +namespace fxcrt { + +// A shared object with Copy on Write semantics that makes it appear as +// if each one were independent. +template +class SharedCopyOnWrite { + public: + SharedCopyOnWrite() {} + SharedCopyOnWrite(const SharedCopyOnWrite& other) + : m_pObject(other.m_pObject) {} + ~SharedCopyOnWrite() {} + + template + ObjClass* Emplace(Args... params) { + m_pObject.Reset(new CountedObj(params...)); + return m_pObject.Get(); + } + + SharedCopyOnWrite& operator=(const SharedCopyOnWrite& that) { + if (*this != that) + m_pObject = that.m_pObject; + return *this; + } + + void SetNull() { m_pObject.Reset(); } + const ObjClass* GetObject() const { return m_pObject.Get(); } + + template + ObjClass* GetPrivateCopy(Args... params) { + if (!m_pObject) + return Emplace(params...); + if (!m_pObject->HasOneRef()) + m_pObject.Reset(new CountedObj(*m_pObject)); + return m_pObject.Get(); + } + + bool operator==(const SharedCopyOnWrite& that) const { + return m_pObject == that.m_pObject; + } + bool operator!=(const SharedCopyOnWrite& that) const { + return !(*this == that); + } + explicit operator bool() const { return !!m_pObject; } + + private: + class CountedObj : public ObjClass { + public: + template + // NOLINTNEXTLINE(runtime/explicit) + CountedObj(Args... params) : ObjClass(params...), m_RefCount(0) {} + + CountedObj(const CountedObj& src) : ObjClass(src), m_RefCount(0) {} + ~CountedObj() { m_RefCount = 0; } + + bool HasOneRef() const { return m_RefCount == 1; } + void Retain() { m_RefCount++; } + void Release() { + ASSERT(m_RefCount); + if (--m_RefCount == 0) + delete this; + } + + private: + // To ensure ref counts do not overflow, consider the worst possible case: + // the entire address space contains nothing but pointers to this object. + // Since the count increments with each new pointer, the largest value is + // the number of pointers that can fit into the address space. The size of + // the address space itself is a good upper bound on it. + intptr_t m_RefCount; + }; + + RetainPtr m_pObject; +}; + +} // namespace fxcrt + +using fxcrt::SharedCopyOnWrite; + +#endif // CORE_FXCRT_SHARED_COPY_ON_WRITE_H_ diff --git a/core/fxcrt/shared_copy_on_write_unittest.cpp b/core/fxcrt/shared_copy_on_write_unittest.cpp new file mode 100644 index 0000000000..a683767054 --- /dev/null +++ b/core/fxcrt/shared_copy_on_write_unittest.cpp @@ -0,0 +1,128 @@ +// Copyright 2016 PDFium Authors. All rights reserved. +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "core/fxcrt/shared_copy_on_write.h" + +#include +#include + +#include "testing/gtest/include/gtest/gtest.h" + +namespace { + +class Observer { + public: + void OnConstruct(const std::string& name) { construction_counts_[name]++; } + void OnDestruct(const std::string& name) { destruction_counts_[name]++; } + int GetConstructionCount(const std::string& name) { + return construction_counts_[name]; + } + int GetDestructionCount(const std::string& name) { + return destruction_counts_[name]; + } + + private: + std::map construction_counts_; + std::map destruction_counts_; +}; + +class Object { + public: + Object(Observer* observer, const std::string& name) + : name_(name), observer_(observer) { + observer->OnConstruct(name_); + } + Object(const Object& that) : name_(that.name_), observer_(that.observer_) { + observer_->OnConstruct(name_); + } + ~Object() { observer_->OnDestruct(name_); } + + private: + std::string name_; + Observer* observer_; +}; + +} // namespace + +TEST(SharedCopyOnWrite, Null) { + Observer observer; + { + SharedCopyOnWrite ptr; + EXPECT_EQ(nullptr, ptr.GetObject()); + } +} + +TEST(SharedCopyOnWrite, Copy) { + Observer observer; + { + SharedCopyOnWrite ptr1; + ptr1.Emplace(&observer, std::string("one")); + { + SharedCopyOnWrite ptr2 = ptr1; + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + } + { + SharedCopyOnWrite ptr3(ptr1); + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + } + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + } + EXPECT_EQ(1, observer.GetDestructionCount("one")); +} + +TEST(SharedCopyOnWrite, AssignOverOld) { + Observer observer; + { + SharedCopyOnWrite ptr1; + ptr1.Emplace(&observer, std::string("one")); + ptr1.Emplace(&observer, std::string("two")); + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(1, observer.GetConstructionCount("two")); + EXPECT_EQ(1, observer.GetDestructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("two")); + } + EXPECT_EQ(1, observer.GetDestructionCount("two")); +} + +TEST(SharedCopyOnWrite, AssignOverRetained) { + Observer observer; + { + SharedCopyOnWrite ptr1; + ptr1.Emplace(&observer, std::string("one")); + SharedCopyOnWrite ptr2(ptr1); + ptr1.Emplace(&observer, std::string("two")); + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(1, observer.GetConstructionCount("two")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("two")); + } + EXPECT_EQ(1, observer.GetDestructionCount("one")); + EXPECT_EQ(1, observer.GetDestructionCount("two")); +} + +TEST(SharedCopyOnWrite, GetModify) { + Observer observer; + { + SharedCopyOnWrite ptr; + EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + + EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); + EXPECT_EQ(1, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + { + SharedCopyOnWrite other(ptr); + EXPECT_NE(nullptr, ptr.GetPrivateCopy(&observer, std::string("one"))); + EXPECT_EQ(2, observer.GetConstructionCount("one")); + EXPECT_EQ(0, observer.GetDestructionCount("one")); + } + EXPECT_EQ(2, observer.GetConstructionCount("one")); + EXPECT_EQ(1, observer.GetDestructionCount("one")); + } + EXPECT_EQ(2, observer.GetDestructionCount("one")); +} -- cgit v1.2.3