summaryrefslogtreecommitdiffstats
path: root/library/cpp/yt/memory/blob.cpp
diff options
context:
space:
mode:
authorsavrus <[email protected]>2022-02-10 16:50:48 +0300
committerDaniil Cherednik <[email protected]>2022-02-10 16:50:48 +0300
commit2ee4b26133812e990e7958fc1863d8d5f8ee7f7b (patch)
tree5d5cb817648f650d76cf1076100726fd9b8448e8 /library/cpp/yt/memory/blob.cpp
parent2056f5ae3bf6e5a65e9885e0add085c708cca5b8 (diff)
Restoring authorship annotation for <[email protected]>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/yt/memory/blob.cpp')
-rw-r--r--library/cpp/yt/memory/blob.cpp100
1 files changed, 50 insertions, 50 deletions
diff --git a/library/cpp/yt/memory/blob.cpp b/library/cpp/yt/memory/blob.cpp
index 542592ab28e..86000b033bc 100644
--- a/library/cpp/yt/memory/blob.cpp
+++ b/library/cpp/yt/memory/blob.cpp
@@ -21,7 +21,7 @@ TBlob::TBlob(
if (size == 0) {
Reset();
} else {
- Allocate(std::max(size, InitialBlobCapacity));
+ Allocate(std::max(size, InitialBlobCapacity));
Size_ = size;
if (initiailizeStorage) {
::memset(Begin_, 0, Size_);
@@ -34,12 +34,12 @@ TBlob::TBlob(
TRef data,
bool pageAligned)
: PageAligned_(pageAligned)
-{
+{
SetTagCookie(tagCookie);
- Reset();
+ Reset();
Append(data);
-}
-
+}
+
TBlob::TBlob(const TBlob& other)
: PageAligned_(other.PageAligned_)
{
@@ -47,13 +47,13 @@ TBlob::TBlob(const TBlob& other)
if (other.Size_ == 0) {
Reset();
} else {
- Allocate(std::max(InitialBlobCapacity, other.Size_));
+ Allocate(std::max(InitialBlobCapacity, other.Size_));
::memcpy(Begin_, other.Begin_, other.Size_);
Size_ = other.Size_;
}
}
-TBlob::TBlob(TBlob&& other) noexcept
+TBlob::TBlob(TBlob&& other) noexcept
: Begin_(other.Begin_)
, Size_(other.Size_)
, Capacity_(other.Capacity_)
@@ -65,13 +65,13 @@ TBlob::TBlob(TBlob&& other) noexcept
TBlob::~TBlob()
{
- Free();
+ Free();
}
void TBlob::Reserve(size_t newCapacity)
{
if (newCapacity > Capacity_) {
- Reallocate(newCapacity);
+ Reallocate(newCapacity);
}
}
@@ -79,13 +79,13 @@ void TBlob::Resize(size_t newSize, bool initializeStorage /*= true*/)
{
if (newSize > Size_) {
if (newSize > Capacity_) {
- size_t newCapacity;
+ size_t newCapacity;
if (Capacity_ == 0) {
- newCapacity = std::max(InitialBlobCapacity, newSize);
+ newCapacity = std::max(InitialBlobCapacity, newSize);
} else {
- newCapacity = std::max(static_cast<size_t>(Capacity_ * BlobCapacityMultiplier), newSize);
+ newCapacity = std::max(static_cast<size_t>(Capacity_ * BlobCapacityMultiplier), newSize);
}
- Reallocate(newCapacity);
+ Reallocate(newCapacity);
}
if (initializeStorage) {
::memset(Begin_ + Size_, 0, newSize - Size_);
@@ -103,7 +103,7 @@ TBlob& TBlob::operator = (const TBlob& rhs)
return *this;
}
-TBlob& TBlob::operator = (TBlob&& rhs) noexcept
+TBlob& TBlob::operator = (TBlob&& rhs) noexcept
{
if (this != &rhs) {
this->~TBlob();
@@ -151,61 +151,61 @@ char* TBlob::DoAllocate(size_t size)
: NYTAlloc::Allocate(size));
}
-void TBlob::Allocate(size_t newCapacity)
-{
+void TBlob::Allocate(size_t newCapacity)
+{
YT_VERIFY(!Begin_);
Begin_ = DoAllocate(newCapacity);
- Capacity_ = newCapacity;
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+ Capacity_ = newCapacity;
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
TRefCountedTrackerFacade::AllocateTagInstance(TagCookie_);
TRefCountedTrackerFacade::AllocateSpace(TagCookie_, newCapacity);
-#endif
-}
+#endif
+}
-void TBlob::Reallocate(size_t newCapacity)
-{
+void TBlob::Reallocate(size_t newCapacity)
+{
if (!Begin_) {
- Allocate(newCapacity);
- return;
- }
+ Allocate(newCapacity);
+ return;
+ }
char* newBegin = DoAllocate(newCapacity);
::memcpy(newBegin, Begin_, Size_);
NYTAlloc::FreeNonNull(Begin_);
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
TRefCountedTrackerFacade::AllocateSpace(TagCookie_, newCapacity);
TRefCountedTrackerFacade::FreeSpace(TagCookie_, Capacity_);
-#endif
- Begin_ = newBegin;
- Capacity_ = newCapacity;
-}
-
-void TBlob::Free()
-{
+#endif
+ Begin_ = newBegin;
+ Capacity_ = newCapacity;
+}
+
+void TBlob::Free()
+{
if (!Begin_) {
- return;
- }
+ return;
+ }
NYTAlloc::FreeNonNull(Begin_);
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
TRefCountedTrackerFacade::FreeTagInstance(TagCookie_);
TRefCountedTrackerFacade::FreeSpace(TagCookie_, Capacity_);
-#endif
+#endif
Reset();
-}
-
+}
+
void TBlob::SetTagCookie(TRefCountedTypeCookie tagCookie)
-{
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+{
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
TagCookie_ = tagCookie;
-#endif
-}
+#endif
+}
void TBlob::SetTagCookie(const TBlob& other)
-{
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+{
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
TagCookie_ = other.TagCookie_;
-#endif
-}
-
+#endif
+}
+
void swap(TBlob& left, TBlob& right)
{
if (&left != &right) {
@@ -213,9 +213,9 @@ void swap(TBlob& left, TBlob& right)
std::swap(left.Size_, right.Size_);
std::swap(left.Capacity_, right.Capacity_);
std::swap(left.PageAligned_, right.PageAligned_);
-#ifdef YT_ENABLE_REF_COUNTED_TRACKING
+#ifdef YT_ENABLE_REF_COUNTED_TRACKING
std::swap(left.TagCookie_, right.TagCookie_);
-#endif
+#endif
}
}