Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(218)

Unified Diff: src/d8.cc

Issue 1224843008: Revert of Fix bug when transferring SharedArrayBuffer to multiple Workers. (Closed) Base URL: https://chromium.googlesource.com/v8/v8.git@master
Patch Set: Created 5 years, 5 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « src/d8.h ('k') | test/mjsunit/d8-worker-sharedarraybuffer.js » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: src/d8.cc
diff --git a/src/d8.cc b/src/d8.cc
index a66213e19f83185607d217f606b63994b3fbac2b..7db6f3ed9e442081528e05140bd25b8911e26cb6 100644
--- a/src/d8.cc
+++ b/src/d8.cc
@@ -1533,26 +1533,22 @@
SerializationData::~SerializationData() {
- // Any ArrayBuffer::Contents are owned by this SerializationData object if
- // ownership hasn't been transferred out via ReadArrayBufferContents.
- // SharedArrayBuffer::Contents may be used by multiple threads, so must be
+ // Any ArrayBuffer::Contents are owned by this SerializationData object.
+ // SharedArrayBuffer::Contents may be used by other threads, so must be
// cleaned up by the main thread in Shell::CleanupWorkers().
- for (int i = 0; i < array_buffer_contents_.length(); ++i) {
- ArrayBuffer::Contents& contents = array_buffer_contents_[i];
- if (contents.Data()) {
- Shell::array_buffer_allocator->Free(contents.Data(),
- contents.ByteLength());
- }
- }
-}
-
-
-void SerializationData::WriteTag(SerializationTag tag) { data_.Add(tag); }
+ for (int i = 0; i < array_buffer_contents.length(); ++i) {
+ ArrayBuffer::Contents& contents = array_buffer_contents[i];
+ Shell::array_buffer_allocator->Free(contents.Data(), contents.ByteLength());
+ }
+}
+
+
+void SerializationData::WriteTag(SerializationTag tag) { data.Add(tag); }
void SerializationData::WriteMemory(const void* p, int length) {
if (length > 0) {
- i::Vector<uint8_t> block = data_.AddBlock(0, length);
+ i::Vector<uint8_t> block = data.AddBlock(0, length);
memcpy(&block[0], p, length);
}
}
@@ -1560,18 +1556,18 @@
void SerializationData::WriteArrayBufferContents(
const ArrayBuffer::Contents& contents) {
- array_buffer_contents_.Add(contents);
+ array_buffer_contents.Add(contents);
WriteTag(kSerializationTagTransferredArrayBuffer);
- int index = array_buffer_contents_.length() - 1;
+ int index = array_buffer_contents.length() - 1;
Write(index);
}
void SerializationData::WriteSharedArrayBufferContents(
const SharedArrayBuffer::Contents& contents) {
- shared_array_buffer_contents_.Add(contents);
+ shared_array_buffer_contents.Add(contents);
WriteTag(kSerializationTagTransferredSharedArrayBuffer);
- int index = shared_array_buffer_contents_.length() - 1;
+ int index = shared_array_buffer_contents.length() - 1;
Write(index);
}
@@ -1583,7 +1579,7 @@
void SerializationData::ReadMemory(void* p, int length, int* offset) const {
if (length > 0) {
- memcpy(p, &data_[*offset], length);
+ memcpy(p, &data[*offset], length);
(*offset) += length;
}
}
@@ -1592,20 +1588,16 @@
void SerializationData::ReadArrayBufferContents(ArrayBuffer::Contents* contents,
int* offset) const {
int index = Read<int>(offset);
- DCHECK(index < array_buffer_contents_.length());
- *contents = array_buffer_contents_[index];
- // Ownership of this ArrayBuffer::Contents is passed to the caller. Neuter
- // our copy so it won't be double-free'd when this SerializationData is
- // destroyed.
- array_buffer_contents_[index] = ArrayBuffer::Contents();
+ DCHECK(index < array_buffer_contents.length());
+ *contents = array_buffer_contents[index];
}
void SerializationData::ReadSharedArrayBufferContents(
SharedArrayBuffer::Contents* contents, int* offset) const {
int index = Read<int>(offset);
- DCHECK(index < shared_array_buffer_contents_.length());
- *contents = shared_array_buffer_contents_[index];
+ DCHECK(index < shared_array_buffer_contents.length());
+ *contents = shared_array_buffer_contents[index];
}
@@ -2048,9 +2040,7 @@
return false;
}
- ArrayBuffer::Contents contents = array_buffer->IsExternal()
- ? array_buffer->GetContents()
- : array_buffer->Externalize();
+ ArrayBuffer::Contents contents = array_buffer->Externalize();
array_buffer->Neuter();
out_data->WriteArrayBufferContents(contents);
} else {
@@ -2079,14 +2069,9 @@
return false;
}
- SharedArrayBuffer::Contents contents;
- if (sab->IsExternal()) {
- contents = sab->GetContents();
- } else {
- contents = sab->Externalize();
- externalized_shared_contents_.Add(contents);
- }
+ SharedArrayBuffer::Contents contents = sab->Externalize();
out_data->WriteSharedArrayBufferContents(contents);
+ externalized_shared_contents_.Add(contents);
} else if (value->IsObject()) {
Handle<Object> object = Handle<Object>::Cast(value);
if (FindInObjectList(object, *seen_objects)) {
@@ -2202,8 +2187,8 @@
case kSerializationTagTransferredArrayBuffer: {
ArrayBuffer::Contents contents;
data.ReadArrayBufferContents(&contents, offset);
- result = ArrayBuffer::New(isolate, contents.Data(), contents.ByteLength(),
- ArrayBufferCreationMode::kInternalized);
+ result =
+ ArrayBuffer::New(isolate, contents.Data(), contents.ByteLength());
break;
}
case kSerializationTagTransferredSharedArrayBuffer: {
« no previous file with comments | « src/d8.h ('k') | test/mjsunit/d8-worker-sharedarraybuffer.js » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698