summaryrefslogtreecommitdiffstats
path: root/js
diff options
context:
space:
mode:
authorGaming4JC <g4jc@hyperbola.info>2019-12-14 10:35:26 -0500
committerGaming4JC <g4jc@hyperbola.info>2019-12-17 06:25:30 -0500
commite0eee318c6bc14d8b6f107cdb2726941881ae311 (patch)
tree2c185d074579b23bb7a6587cded0170f5ea42b17 /js
parent4a5ed79c6c5b73ac010a80c2fa5c3d6545278243 (diff)
downloadUXP-e0eee318c6bc14d8b6f107cdb2726941881ae311.tar
UXP-e0eee318c6bc14d8b6f107cdb2726941881ae311.tar.gz
UXP-e0eee318c6bc14d8b6f107cdb2726941881ae311.tar.lz
UXP-e0eee318c6bc14d8b6f107cdb2726941881ae311.tar.xz
UXP-e0eee318c6bc14d8b6f107cdb2726941881ae311.zip
Bug 1390082 - Implement AsyncGeneratorQueue with simpler array operations.
Tag #1287 Note: Without ReadableStream implementation
Diffstat (limited to 'js')
-rw-r--r--js/src/vm/AsyncIteration.cpp62
1 files changed, 52 insertions, 10 deletions
diff --git a/js/src/vm/AsyncIteration.cpp b/js/src/vm/AsyncIteration.cpp
index 256f247b0..300179374 100644
--- a/js/src/vm/AsyncIteration.cpp
+++ b/js/src/vm/AsyncIteration.cpp
@@ -315,6 +315,53 @@ AsyncGeneratorObject::create(JSContext* cx, HandleFunction asyncGen, HandleValue
return asyncGenObj;
}
+static MOZ_MUST_USE bool
+InternalEnqueue(JSContext* cx, HandleArrayObject queue, HandleValue val)
+{
+ uint32_t length;
+ if (!GetLengthProperty(cx, queue, &length))
+ return false;
+
+ if (length >= MAX_ARRAY_INDEX) {
+ ReportOutOfMemory(cx);
+ return false;
+ }
+
+ if (!DefineElement(cx, queue, length, val))
+ return false;
+ return SetLengthProperty(cx, queue, length + 1);
+}
+
+static MOZ_MUST_USE bool
+InternalDequeue(JSContext* cx, HandleArrayObject queue, MutableHandleValue val)
+{
+ uint32_t length;
+ if (!GetLengthProperty(cx, queue, &length))
+ return false;
+
+ MOZ_ASSERT(length != 0, "Queue should not be empty here");
+
+ if (!GetElement(cx, queue, queue, 0, val))
+ return false;
+
+ uint32_t newlength = length - 1;
+ RootedValue tmp(cx);
+ for (uint32_t i = 0; i < newlength; i++) {
+ if (!GetElement(cx, queue, queue, i + 1, &tmp))
+ return false;
+ if (!DefineElement(cx, queue, i, tmp))
+ return false;
+ }
+ ObjectOpResult result;
+ if (!DeleteElement(cx, queue, newlength, result))
+ return false;
+ if (!result) {
+ RootedId id(cx, INT_TO_JSID(newlength));
+ return result.reportError(cx, queue, id);
+ }
+ return SetLengthProperty(cx, queue, newlength);
+}
+
/* static */ MOZ_MUST_USE bool
AsyncGeneratorObject::enqueueRequest(JSContext* cx, Handle<AsyncGeneratorObject*> asyncGenObj,
Handle<AsyncGeneratorRequest*> request)
@@ -339,11 +386,8 @@ AsyncGeneratorObject::enqueueRequest(JSContext* cx, Handle<AsyncGeneratorObject*
}
RootedArrayObject queue(cx, asyncGenObj->queue());
-
- FixedInvokeArgs<1> args(cx);
- args[0].setObject(*request);
- args.setThis(ObjectValue(*queue));
- return CallJSNative(cx, array_push, args);
+ RootedValue requestVal(cx, ObjectValue(*request));
+ return InternalEnqueue(cx, queue, requestVal);
}
/* static */ AsyncGeneratorRequest*
@@ -356,13 +400,11 @@ AsyncGeneratorObject::dequeueRequest(JSContext* cx, Handle<AsyncGeneratorObject*
}
RootedArrayObject queue(cx, asyncGenObj->queue());
-
- FixedInvokeArgs<0> args(cx);
- args.setThis(ObjectValue(*queue));
- if (!CallJSNative(cx, array_shift, args))
+ RootedValue requestVal(cx);
+ if (!InternalDequeue(cx, queue, &requestVal))
return nullptr;
- return &args.rval().toObject().as<AsyncGeneratorRequest>();
+ return &requestVal.toObject().as<AsyncGeneratorRequest>();
}
/* static */ AsyncGeneratorRequest*