From 2adc7d5a20f3ff9b758af6e61271ee95b596b227 Mon Sep 17 00:00:00 2001 From: flakey5 <73616808+flakey5@users.noreply.github.com> Date: Sat, 19 Nov 2022 20:58:22 -0800 Subject: [PATCH] Fix some compile errors --- src/dataqueue/queue.cc | 8 ++++---- src/node_blob.cc | 9 +++++---- src/node_blob.h | 4 ++-- 3 files changed, 11 insertions(+), 10 deletions(-) diff --git a/src/dataqueue/queue.cc b/src/dataqueue/queue.cc index 3070d92c75bd70..a1bb3b5a78ccc2 100644 --- a/src/dataqueue/queue.cc +++ b/src/dataqueue/queue.cc @@ -60,7 +60,7 @@ class DataQueueImpl final : public DataQueue, : entries_(std::move(list)), idempotent_(true), size_(Just(size)), - capped_size_(Just(0UL)) {} + capped_size_(Just(0UL)) {} // Constructor for a non-idempotent DataQueue. This kind of queue can have // entries added to it over time. The size is set to 0 initially. The queue @@ -69,7 +69,7 @@ class DataQueueImpl final : public DataQueue, // providing a size. DataQueueImpl(Maybe cap = Nothing()) : idempotent_(false), - size_(Just(0UL)), + size_(Just(0UL)), capped_size_(cap) {} // Disallow moving and copying. @@ -176,7 +176,7 @@ class DataQueueImpl final : public DataQueue, size_t capped_size; size_t size; if (capped_size_.To(&capped_size) && size_.To(&size)) { - return capped_size > size ? Just(capped_size - size) : Just(0UL); + return capped_size > size ? Just(capped_size - size) : Just(0UL); } return Nothing(); } @@ -613,7 +613,7 @@ class EmptyEntry final : public EntryBase { return std::make_unique(); } - Maybe size() const override { return Just(0UL); } + Maybe size() const override { return Just(0UL); } bool isIdempotent() const override { return true; } diff --git a/src/node_blob.cc b/src/node_blob.cc index 6aa05803bc9d1d..1974bb015b7edb 100644 --- a/src/node_blob.cc +++ b/src/node_blob.cc @@ -159,6 +159,7 @@ MaybeLocal Blob::GetArrayBuffer(Environment* env) { size_t len = length(); std::shared_ptr store = ArrayBuffer::NewBackingStore(env->isolate(), len); + /*if (len > 0) { unsigned char* dest = static_cast(store->Data()); size_t total = 0; @@ -176,7 +177,7 @@ MaybeLocal Blob::GetArrayBuffer(Environment* env) { } BaseObjectPtr Blob::Slice(Environment* env, size_t start, size_t end) { - return Create(env, this->data_queue->slice(start, v8::Just(end))); + return Create(env, this->data_queue_->slice(start, v8::Just(end))); } Blob::Blob( @@ -184,7 +185,7 @@ Blob::Blob( v8::Local obj, std::shared_ptr data_queue) : BaseObject(env, obj), - data_queue(data_queue) { + data_queue_(data_queue) { MakeWeak(); } @@ -205,7 +206,7 @@ BaseObject::TransferMode Blob::GetTransferMode() const { } std::unique_ptr Blob::CloneForMessaging() const { - return std::make_unique(data_queue); + return std::make_unique(data_queue_); } void Blob::StoreDataObject(const v8::FunctionCallbackInfo& args) { @@ -410,7 +411,7 @@ BlobBindingData::BlobBindingData(Environment* env, Local wrap) } void BlobBindingData::MemoryInfo(MemoryTracker* tracker) const { - tracker->TrackField("data_objects", data_objects_); + tracker->TrackField("data_objects_", data_objects_); } void BlobBindingData::store_data_object( diff --git a/src/node_blob.h b/src/node_blob.h index eacadefda95ae5..a81b0189e3843d 100644 --- a/src/node_blob.h +++ b/src/node_blob.h @@ -53,7 +53,7 @@ class Blob : public BaseObject { BaseObjectPtr Slice(Environment* env, size_t start, size_t end); - inline size_t length() const { return this->data_queue->size().ToChecked(); } + inline size_t length() const { return this->data_queue_->size().ToChecked(); } class BlobTransferData : public worker::TransferData { public: @@ -82,7 +82,7 @@ class Blob : public BaseObject { std::shared_ptr data_queue); private: - std::shared_ptr data_queue; + std::shared_ptr data_queue_; }; // TODO(@flakey5): revisit when DataQueue is complete