mirror of
https://gitlab.winehq.org/wine/wine-gecko.git
synced 2024-09-13 09:24:08 -07:00
99782186da
Switch from using the interface objects from the Xrays compartment to wrapping interface objects and interface prototype objects in Xrays. Make dom binding Xrays deal with both instance objects and interface and interface prototype objects.
487 lines
12 KiB
C++
487 lines
12 KiB
C++
/* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */
|
|
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#include "Worker.h"
|
|
|
|
#include "mozilla/dom/DOMJSClass.h"
|
|
#include "mozilla/dom/BindingUtils.h"
|
|
|
|
#include "EventTarget.h"
|
|
#include "RuntimeService.h"
|
|
#include "WorkerPrivate.h"
|
|
|
|
#include "WorkerInlines.h"
|
|
|
|
#define PROPERTY_FLAGS \
|
|
(JSPROP_ENUMERATE | JSPROP_SHARED)
|
|
|
|
#define FUNCTION_FLAGS \
|
|
JSPROP_ENUMERATE
|
|
|
|
USING_WORKERS_NAMESPACE
|
|
|
|
using namespace mozilla::dom;
|
|
using mozilla::ErrorResult;
|
|
|
|
namespace {
|
|
|
|
class Worker
|
|
{
|
|
static DOMJSClass sClass;
|
|
static JSPropertySpec sProperties[];
|
|
static JSFunctionSpec sFunctions[];
|
|
|
|
enum
|
|
{
|
|
STRING_onerror = 0,
|
|
STRING_onmessage,
|
|
|
|
STRING_COUNT
|
|
};
|
|
|
|
static const char* const sEventStrings[STRING_COUNT];
|
|
|
|
protected:
|
|
enum {
|
|
// The constructor function holds a WorkerPrivate* in its first reserved
|
|
// slot.
|
|
CONSTRUCTOR_SLOT_PARENT = 0
|
|
};
|
|
|
|
public:
|
|
static JSClass*
|
|
Class()
|
|
{
|
|
return sClass.ToJSClass();
|
|
}
|
|
|
|
static JSObject*
|
|
InitClass(JSContext* aCx, JSObject* aObj, JSObject* aParentProto,
|
|
bool aMainRuntime)
|
|
{
|
|
JSObject* proto =
|
|
js::InitClassWithReserved(aCx, aObj, aParentProto, Class(), Construct, 0,
|
|
sProperties, sFunctions, NULL, NULL);
|
|
if (!proto) {
|
|
return NULL;
|
|
}
|
|
|
|
if (!aMainRuntime) {
|
|
WorkerPrivate* parent = GetWorkerPrivateFromContext(aCx);
|
|
parent->AssertIsOnWorkerThread();
|
|
|
|
JSObject* constructor = JS_GetConstructor(aCx, proto);
|
|
if (!constructor)
|
|
return NULL;
|
|
js::SetFunctionNativeReserved(constructor, CONSTRUCTOR_SLOT_PARENT,
|
|
PRIVATE_TO_JSVAL(parent));
|
|
}
|
|
|
|
return proto;
|
|
}
|
|
|
|
static WorkerPrivate*
|
|
GetInstancePrivate(JSContext* aCx, JSObject* aObj, const char* aFunctionName);
|
|
|
|
protected:
|
|
static JSBool
|
|
ConstructInternal(JSContext* aCx, unsigned aArgc, jsval* aVp,
|
|
bool aIsChromeWorker, JSClass* aClass)
|
|
{
|
|
if (!aArgc) {
|
|
JS_ReportError(aCx, "Constructor requires at least one argument!");
|
|
return false;
|
|
}
|
|
|
|
JSString* scriptURL = JS_ValueToString(aCx, JS_ARGV(aCx, aVp)[0]);
|
|
if (!scriptURL) {
|
|
return false;
|
|
}
|
|
|
|
jsval priv = js::GetFunctionNativeReserved(JSVAL_TO_OBJECT(JS_CALLEE(aCx, aVp)),
|
|
CONSTRUCTOR_SLOT_PARENT);
|
|
|
|
RuntimeService* runtimeService;
|
|
WorkerPrivate* parent;
|
|
|
|
if (JSVAL_IS_VOID(priv)) {
|
|
runtimeService = RuntimeService::GetOrCreateService();
|
|
if (!runtimeService) {
|
|
JS_ReportError(aCx, "Failed to create runtime service!");
|
|
return false;
|
|
}
|
|
parent = NULL;
|
|
}
|
|
else {
|
|
runtimeService = RuntimeService::GetService();
|
|
parent = static_cast<WorkerPrivate*>(JSVAL_TO_PRIVATE(priv));
|
|
parent->AssertIsOnWorkerThread();
|
|
}
|
|
|
|
JSObject* obj = JS_NewObject(aCx, aClass, nullptr, nullptr);
|
|
if (!obj) {
|
|
return false;
|
|
}
|
|
|
|
nsRefPtr<WorkerPrivate> worker =
|
|
WorkerPrivate::Create(aCx, obj, parent, scriptURL, aIsChromeWorker);
|
|
if (!worker) {
|
|
return false;
|
|
}
|
|
|
|
// Worker now owned by the JS object.
|
|
NS_ADDREF(worker.get());
|
|
js::SetReservedSlot(obj, DOM_OBJECT_SLOT, PRIVATE_TO_JSVAL(worker));
|
|
|
|
if (!runtimeService->RegisterWorker(aCx, worker)) {
|
|
return false;
|
|
}
|
|
|
|
// Worker now also owned by its thread.
|
|
NS_ADDREF(worker.get());
|
|
|
|
JS_SET_RVAL(aCx, aVp, OBJECT_TO_JSVAL(obj));
|
|
return true;
|
|
}
|
|
|
|
private:
|
|
// No instance of this class should ever be created so these are explicitly
|
|
// left without an implementation to prevent linking in case someone tries to
|
|
// make one.
|
|
Worker();
|
|
~Worker();
|
|
|
|
static JSBool
|
|
GetEventListener(JSContext* aCx, JSHandleObject aObj, JSHandleId aIdval, JSMutableHandleValue aVp)
|
|
{
|
|
JS_ASSERT(JSID_IS_INT(aIdval));
|
|
JS_ASSERT(JSID_TO_INT(aIdval) >= 0 && JSID_TO_INT(aIdval) < STRING_COUNT);
|
|
|
|
const char* name = sEventStrings[JSID_TO_INT(aIdval)];
|
|
WorkerPrivate* worker = GetInstancePrivate(aCx, aObj, name);
|
|
if (!worker) {
|
|
return !JS_IsExceptionPending(aCx);
|
|
}
|
|
|
|
NS_ConvertASCIItoUTF16 nameStr(name + 2);
|
|
ErrorResult rv;
|
|
JSObject* listener = worker->GetEventListener(nameStr, rv);
|
|
|
|
if (rv.Failed()) {
|
|
JS_ReportError(aCx, "Failed to get listener!");
|
|
}
|
|
|
|
aVp.set(listener ? OBJECT_TO_JSVAL(listener) : JSVAL_NULL);
|
|
return true;
|
|
}
|
|
|
|
static JSBool
|
|
SetEventListener(JSContext* aCx, JSHandleObject aObj, JSHandleId aIdval, JSBool aStrict,
|
|
JSMutableHandleValue aVp)
|
|
{
|
|
JS_ASSERT(JSID_IS_INT(aIdval));
|
|
JS_ASSERT(JSID_TO_INT(aIdval) >= 0 && JSID_TO_INT(aIdval) < STRING_COUNT);
|
|
|
|
const char* name = sEventStrings[JSID_TO_INT(aIdval)];
|
|
WorkerPrivate* worker = GetInstancePrivate(aCx, aObj, name);
|
|
if (!worker) {
|
|
return !JS_IsExceptionPending(aCx);
|
|
}
|
|
|
|
JSObject* listener;
|
|
if (!JS_ValueToObject(aCx, aVp, &listener)) {
|
|
return false;
|
|
}
|
|
|
|
NS_ConvertASCIItoUTF16 nameStr(name + 2);
|
|
ErrorResult rv;
|
|
worker->SetEventListener(nameStr, listener, rv);
|
|
|
|
if (rv.Failed()) {
|
|
JS_ReportError(aCx, "Failed to set listener!");
|
|
return false;
|
|
}
|
|
|
|
return true;
|
|
}
|
|
|
|
static JSBool
|
|
Construct(JSContext* aCx, unsigned aArgc, jsval* aVp)
|
|
{
|
|
return ConstructInternal(aCx, aArgc, aVp, false, Class());
|
|
}
|
|
|
|
static void
|
|
Finalize(JSFreeOp* aFop, JSObject* aObj)
|
|
{
|
|
JS_ASSERT(JS_GetClass(aObj) == Class());
|
|
WorkerPrivate* worker =
|
|
UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
if (worker) {
|
|
worker->_finalize(aFop);
|
|
}
|
|
}
|
|
|
|
static void
|
|
Trace(JSTracer* aTrc, JSObject* aObj)
|
|
{
|
|
JS_ASSERT(JS_GetClass(aObj) == Class());
|
|
WorkerPrivate* worker =
|
|
UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
if (worker) {
|
|
worker->_trace(aTrc);
|
|
}
|
|
}
|
|
|
|
static JSBool
|
|
Terminate(JSContext* aCx, unsigned aArgc, jsval* aVp)
|
|
{
|
|
JSObject* obj = JS_THIS_OBJECT(aCx, aVp);
|
|
if (!obj) {
|
|
return false;
|
|
}
|
|
|
|
const char*& name = sFunctions[0].name;
|
|
WorkerPrivate* worker = GetInstancePrivate(aCx, obj, name);
|
|
if (!worker) {
|
|
return !JS_IsExceptionPending(aCx);
|
|
}
|
|
|
|
return worker->Terminate(aCx);
|
|
}
|
|
|
|
static JSBool
|
|
PostMessage(JSContext* aCx, unsigned aArgc, jsval* aVp)
|
|
{
|
|
JSObject* obj = JS_THIS_OBJECT(aCx, aVp);
|
|
if (!obj) {
|
|
return false;
|
|
}
|
|
|
|
const char*& name = sFunctions[1].name;
|
|
WorkerPrivate* worker = GetInstancePrivate(aCx, obj, name);
|
|
if (!worker) {
|
|
return !JS_IsExceptionPending(aCx);
|
|
}
|
|
|
|
jsval message;
|
|
jsval transferable = JSVAL_VOID;
|
|
if (!JS_ConvertArguments(aCx, aArgc, JS_ARGV(aCx, aVp), "v/v",
|
|
&message, &transferable)) {
|
|
return false;
|
|
}
|
|
|
|
return worker->PostMessage(aCx, message, transferable);
|
|
}
|
|
};
|
|
|
|
MOZ_STATIC_ASSERT(prototypes::MaxProtoChainLength == 3,
|
|
"The MaxProtoChainLength must match our manual DOMJSClasses");
|
|
|
|
DOMJSClass Worker::sClass = {
|
|
{
|
|
"Worker",
|
|
JSCLASS_IS_DOMJSCLASS | JSCLASS_HAS_RESERVED_SLOTS(2) |
|
|
JSCLASS_IMPLEMENTS_BARRIERS,
|
|
JS_PropertyStub, JS_PropertyStub, JS_PropertyStub, JS_StrictPropertyStub,
|
|
JS_EnumerateStub, JS_ResolveStub, JS_ConvertStub, Finalize,
|
|
NULL, NULL, NULL, NULL, Trace
|
|
},
|
|
{
|
|
{ prototypes::id::EventTarget_workers, prototypes::id::_ID_Count,
|
|
prototypes::id::_ID_Count },
|
|
false,
|
|
&sWorkerNativePropertyHooks
|
|
}
|
|
};
|
|
|
|
JSPropertySpec Worker::sProperties[] = {
|
|
{ sEventStrings[STRING_onerror], STRING_onerror, PROPERTY_FLAGS,
|
|
JSOP_WRAPPER(GetEventListener), JSOP_WRAPPER(SetEventListener) },
|
|
{ sEventStrings[STRING_onmessage], STRING_onmessage, PROPERTY_FLAGS,
|
|
JSOP_WRAPPER(GetEventListener), JSOP_WRAPPER(SetEventListener) },
|
|
{ 0, 0, 0, JSOP_NULLWRAPPER, JSOP_NULLWRAPPER }
|
|
};
|
|
|
|
JSFunctionSpec Worker::sFunctions[] = {
|
|
JS_FN("terminate", Terminate, 0, FUNCTION_FLAGS),
|
|
JS_FN("postMessage", PostMessage, 1, FUNCTION_FLAGS),
|
|
JS_FS_END
|
|
};
|
|
|
|
const char* const Worker::sEventStrings[STRING_COUNT] = {
|
|
"onerror",
|
|
"onmessage"
|
|
};
|
|
|
|
class ChromeWorker : public Worker
|
|
{
|
|
static DOMJSClass sClass;
|
|
|
|
public:
|
|
static JSClass*
|
|
Class()
|
|
{
|
|
return sClass.ToJSClass();
|
|
}
|
|
|
|
static JSObject*
|
|
InitClass(JSContext* aCx, JSObject* aObj, JSObject* aParentProto,
|
|
bool aMainRuntime)
|
|
{
|
|
JSObject* proto =
|
|
js::InitClassWithReserved(aCx, aObj, aParentProto, Class(), Construct, 0,
|
|
NULL, NULL, NULL, NULL);
|
|
if (!proto) {
|
|
return NULL;
|
|
}
|
|
|
|
if (!aMainRuntime) {
|
|
WorkerPrivate* parent = GetWorkerPrivateFromContext(aCx);
|
|
parent->AssertIsOnWorkerThread();
|
|
|
|
JSObject* constructor = JS_GetConstructor(aCx, proto);
|
|
if (!constructor)
|
|
return NULL;
|
|
js::SetFunctionNativeReserved(constructor, CONSTRUCTOR_SLOT_PARENT,
|
|
PRIVATE_TO_JSVAL(parent));
|
|
}
|
|
|
|
return proto;
|
|
}
|
|
|
|
private:
|
|
// No instance of this class should ever be created so these are explicitly
|
|
// left without an implementation to prevent linking in case someone tries to
|
|
// make one.
|
|
ChromeWorker();
|
|
~ChromeWorker();
|
|
|
|
static WorkerPrivate*
|
|
GetInstancePrivate(JSContext* aCx, JSObject* aObj, const char* aFunctionName)
|
|
{
|
|
if (aObj) {
|
|
JSClass* classPtr = JS_GetClass(aObj);
|
|
if (classPtr == Class()) {
|
|
return UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
}
|
|
}
|
|
|
|
return Worker::GetInstancePrivate(aCx, aObj, aFunctionName);
|
|
}
|
|
|
|
static JSBool
|
|
Construct(JSContext* aCx, unsigned aArgc, jsval* aVp)
|
|
{
|
|
return ConstructInternal(aCx, aArgc, aVp, true, Class());
|
|
}
|
|
|
|
static void
|
|
Finalize(JSFreeOp* aFop, JSObject* aObj)
|
|
{
|
|
JS_ASSERT(JS_GetClass(aObj) == Class());
|
|
WorkerPrivate* worker =
|
|
UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
if (worker) {
|
|
worker->_finalize(aFop);
|
|
}
|
|
}
|
|
|
|
static void
|
|
Trace(JSTracer* aTrc, JSObject* aObj)
|
|
{
|
|
JS_ASSERT(JS_GetClass(aObj) == Class());
|
|
WorkerPrivate* worker =
|
|
UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
if (worker) {
|
|
worker->_trace(aTrc);
|
|
}
|
|
}
|
|
};
|
|
|
|
MOZ_STATIC_ASSERT(prototypes::MaxProtoChainLength == 3,
|
|
"The MaxProtoChainLength must match our manual DOMJSClasses");
|
|
|
|
DOMJSClass ChromeWorker::sClass = {
|
|
{ "ChromeWorker",
|
|
JSCLASS_IS_DOMJSCLASS | JSCLASS_HAS_RESERVED_SLOTS(2) |
|
|
JSCLASS_IMPLEMENTS_BARRIERS,
|
|
JS_PropertyStub, JS_PropertyStub, JS_PropertyStub, JS_StrictPropertyStub,
|
|
JS_EnumerateStub, JS_ResolveStub, JS_ConvertStub, Finalize,
|
|
NULL, NULL, NULL, NULL, Trace,
|
|
},
|
|
{
|
|
{ prototypes::id::EventTarget_workers, prototypes::id::_ID_Count,
|
|
prototypes::id::_ID_Count },
|
|
false,
|
|
&sWorkerNativePropertyHooks
|
|
}
|
|
};
|
|
|
|
WorkerPrivate*
|
|
Worker::GetInstancePrivate(JSContext* aCx, JSObject* aObj,
|
|
const char* aFunctionName)
|
|
{
|
|
JSClass* classPtr = JS_GetClass(aObj);
|
|
if (classPtr == Class() || classPtr == ChromeWorker::Class()) {
|
|
return UnwrapDOMObject<WorkerPrivate>(aObj, eRegularDOMObject);
|
|
}
|
|
|
|
JS_ReportErrorNumber(aCx, js_GetErrorMessage, NULL, JSMSG_INCOMPATIBLE_PROTO,
|
|
Class()->name, aFunctionName, classPtr->name);
|
|
return NULL;
|
|
}
|
|
|
|
} // anonymous namespace
|
|
|
|
BEGIN_WORKERS_NAMESPACE
|
|
|
|
namespace worker {
|
|
|
|
JSObject*
|
|
InitClass(JSContext* aCx, JSObject* aGlobal, JSObject* aProto,
|
|
bool aMainRuntime)
|
|
{
|
|
return Worker::InitClass(aCx, aGlobal, aProto, aMainRuntime);
|
|
}
|
|
|
|
} // namespace worker
|
|
|
|
WorkerCrossThreadDispatcher*
|
|
GetWorkerCrossThreadDispatcher(JSContext* aCx, jsval aWorker)
|
|
{
|
|
if (JSVAL_IS_PRIMITIVE(aWorker)) {
|
|
return NULL;
|
|
}
|
|
|
|
WorkerPrivate* w =
|
|
Worker::GetInstancePrivate(aCx, JSVAL_TO_OBJECT(aWorker),
|
|
"GetWorkerCrossThreadDispatcher");
|
|
if (!w) {
|
|
return NULL;
|
|
}
|
|
return w->GetCrossThreadDispatcher();
|
|
}
|
|
|
|
|
|
namespace chromeworker {
|
|
|
|
bool
|
|
InitClass(JSContext* aCx, JSObject* aGlobal, JSObject* aProto,
|
|
bool aMainRuntime)
|
|
{
|
|
return !!ChromeWorker::InitClass(aCx, aGlobal, aProto, aMainRuntime);
|
|
}
|
|
|
|
} // namespace chromeworker
|
|
|
|
bool
|
|
ClassIsWorker(JSClass* aClass)
|
|
{
|
|
return Worker::Class() == aClass || ChromeWorker::Class() == aClass;
|
|
}
|
|
|
|
END_WORKERS_NAMESPACE
|