The Tor Browser / file comparison
comparison: dom/workers/WorkerScope.cpp
dom/workers/WorkerScope.cpp
- branch
- TOR_BUG_9701
- changeset 15
- b8a032363ba2
equal
deleted
inserted
replaced
| -1:000000000000 | 0:d007ec2f0681 |
|---|---|
| 1 /* -*- Mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; tab-width: 40 -*- */ | |
| 2 /* vim: set ts=2 et sw=2 tw=80: */ | |
| 3 /* This Source Code Form is subject to the terms of the Mozilla Public | |
| 4 * License, v. 2.0. If a copy of the MPL was not distributed with this | |
| 5 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */ | |
| 6 | |
| 7 #include "WorkerScope.h" | |
| 8 | |
| 9 #include "jsapi.h" | |
| 10 #include "mozilla/EventListenerManager.h" | |
| 11 #include "mozilla/dom/FunctionBinding.h" | |
| 12 #include "mozilla/dom/DedicatedWorkerGlobalScopeBinding.h" | |
| 13 #include "mozilla/dom/SharedWorkerGlobalScopeBinding.h" | |
| 14 #include "mozilla/dom/Console.h" | |
| 15 | |
| 16 #ifdef ANDROID | |
| 17 #include <android/log.h> | |
| 18 #endif | |
| 19 | |
| 20 #include "Location.h" | |
| 21 #include "Navigator.h" | |
| 22 #include "Principal.h" | |
| 23 #include "RuntimeService.h" | |
| 24 #include "ScriptLoader.h" | |
| 25 #include "WorkerPrivate.h" | |
| 26 | |
| 27 #define UNWRAP_WORKER_OBJECT(Interface, obj, value) \ | |
| 28 UnwrapObject<prototypes::id::Interface##_workers, \ | |
| 29 mozilla::dom::Interface##Binding_workers::NativeType>(obj, value) | |
| 30 | |
| 31 using namespace mozilla; | |
| 32 using namespace mozilla::dom; | |
| 33 USING_WORKERS_NAMESPACE | |
| 34 | |
| 35 BEGIN_WORKERS_NAMESPACE | |
| 36 | |
| 37 WorkerGlobalScope::WorkerGlobalScope(WorkerPrivate* aWorkerPrivate) | |
| 38 : mWorkerPrivate(aWorkerPrivate) | |
| 39 { | |
| 40 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 41 | |
| 42 SetIsDOMBinding(); | |
| 43 } | |
| 44 | |
| 45 WorkerGlobalScope::~WorkerGlobalScope() | |
| 46 { | |
| 47 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 48 } | |
| 49 | |
| 50 NS_IMPL_CYCLE_COLLECTION_CLASS(WorkerGlobalScope) | |
| 51 | |
| 52 NS_IMPL_CYCLE_COLLECTION_TRAVERSE_BEGIN_INHERITED(WorkerGlobalScope, | |
| 53 DOMEventTargetHelper) | |
| 54 tmp->mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 55 NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mLocation) | |
| 56 NS_IMPL_CYCLE_COLLECTION_TRAVERSE(mNavigator) | |
| 57 NS_IMPL_CYCLE_COLLECTION_TRAVERSE_END | |
| 58 | |
| 59 NS_IMPL_CYCLE_COLLECTION_UNLINK_BEGIN_INHERITED(WorkerGlobalScope, | |
| 60 DOMEventTargetHelper) | |
| 61 tmp->mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 62 NS_IMPL_CYCLE_COLLECTION_UNLINK(mLocation) | |
| 63 NS_IMPL_CYCLE_COLLECTION_UNLINK(mNavigator) | |
| 64 NS_IMPL_CYCLE_COLLECTION_UNLINK_END | |
| 65 | |
| 66 NS_IMPL_CYCLE_COLLECTION_TRACE_BEGIN_INHERITED(WorkerGlobalScope, | |
| 67 DOMEventTargetHelper) | |
| 68 tmp->mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 69 | |
| 70 tmp->mWorkerPrivate->TraceTimeouts(aCallbacks, aClosure); | |
| 71 NS_IMPL_CYCLE_COLLECTION_TRACE_END | |
| 72 | |
| 73 NS_IMPL_ADDREF_INHERITED(WorkerGlobalScope, DOMEventTargetHelper) | |
| 74 NS_IMPL_RELEASE_INHERITED(WorkerGlobalScope, DOMEventTargetHelper) | |
| 75 | |
| 76 NS_INTERFACE_MAP_BEGIN_CYCLE_COLLECTION(WorkerGlobalScope) | |
| 77 NS_INTERFACE_MAP_ENTRY(nsIGlobalObject) | |
| 78 NS_INTERFACE_MAP_END_INHERITING(DOMEventTargetHelper) | |
| 79 | |
| 80 JSObject* | |
| 81 WorkerGlobalScope::WrapObject(JSContext* aCx) | |
| 82 { | |
| 83 MOZ_CRASH("We should never get here!"); | |
| 84 } | |
| 85 | |
| 86 already_AddRefed<Console> | |
| 87 WorkerGlobalScope::GetConsole() | |
| 88 { | |
| 89 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 90 | |
| 91 if (!mConsole) { | |
| 92 mConsole = new Console(nullptr); | |
| 93 MOZ_ASSERT(mConsole); | |
| 94 } | |
| 95 | |
| 96 return mConsole.forget(); | |
| 97 } | |
| 98 | |
| 99 already_AddRefed<WorkerLocation> | |
| 100 WorkerGlobalScope::Location() | |
| 101 { | |
| 102 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 103 | |
| 104 if (!mLocation) { | |
| 105 WorkerPrivate::LocationInfo& info = mWorkerPrivate->GetLocationInfo(); | |
| 106 | |
| 107 mLocation = WorkerLocation::Create(info); | |
| 108 MOZ_ASSERT(mLocation); | |
| 109 } | |
| 110 | |
| 111 nsRefPtr<WorkerLocation> location = mLocation; | |
| 112 return location.forget(); | |
| 113 } | |
| 114 | |
| 115 already_AddRefed<WorkerNavigator> | |
| 116 WorkerGlobalScope::Navigator() | |
| 117 { | |
| 118 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 119 | |
| 120 if (!mNavigator) { | |
| 121 mNavigator = WorkerNavigator::Create(mWorkerPrivate->OnLine()); | |
| 122 MOZ_ASSERT(mNavigator); | |
| 123 } | |
| 124 | |
| 125 nsRefPtr<WorkerNavigator> navigator = mNavigator; | |
| 126 return navigator.forget(); | |
| 127 } | |
| 128 | |
| 129 already_AddRefed<WorkerNavigator> | |
| 130 WorkerGlobalScope::GetExistingNavigator() const | |
| 131 { | |
| 132 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 133 | |
| 134 nsRefPtr<WorkerNavigator> navigator = mNavigator; | |
| 135 return navigator.forget(); | |
| 136 } | |
| 137 | |
| 138 void | |
| 139 WorkerGlobalScope::Close(JSContext* aCx) | |
| 140 { | |
| 141 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 142 | |
| 143 mWorkerPrivate->CloseInternal(aCx); | |
| 144 } | |
| 145 | |
| 146 OnErrorEventHandlerNonNull* | |
| 147 WorkerGlobalScope::GetOnerror() | |
| 148 { | |
| 149 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 150 | |
| 151 EventListenerManager* elm = GetExistingListenerManager(); | |
| 152 return elm ? elm->GetOnErrorEventHandler() : nullptr; | |
| 153 } | |
| 154 | |
| 155 void | |
| 156 WorkerGlobalScope::SetOnerror(OnErrorEventHandlerNonNull* aHandler) | |
| 157 { | |
| 158 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 159 | |
| 160 EventListenerManager* elm = GetOrCreateListenerManager(); | |
| 161 if (elm) { | |
| 162 elm->SetEventHandler(aHandler); | |
| 163 } | |
| 164 } | |
| 165 | |
| 166 void | |
| 167 WorkerGlobalScope::ImportScripts(JSContext* aCx, | |
| 168 const Sequence<nsString>& aScriptURLs, | |
| 169 ErrorResult& aRv) | |
| 170 { | |
| 171 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 172 scriptloader::Load(aCx, mWorkerPrivate, aScriptURLs, aRv); | |
| 173 } | |
| 174 | |
| 175 int32_t | |
| 176 WorkerGlobalScope::SetTimeout(JSContext* aCx, | |
| 177 Function& aHandler, | |
| 178 const int32_t aTimeout, | |
| 179 const Sequence<JS::Value>& aArguments, | |
| 180 ErrorResult& aRv) | |
| 181 { | |
| 182 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 183 return mWorkerPrivate->SetTimeout(aCx, &aHandler, EmptyString(), aTimeout, | |
| 184 aArguments, false, aRv); | |
| 185 } | |
| 186 | |
| 187 int32_t | |
| 188 WorkerGlobalScope::SetTimeout(JSContext* /* unused */, | |
| 189 const nsAString& aHandler, | |
| 190 const int32_t aTimeout, | |
| 191 const Sequence<JS::Value>& /* unused */, | |
| 192 ErrorResult& aRv) | |
| 193 { | |
| 194 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 195 Sequence<JS::Value> dummy; | |
| 196 return mWorkerPrivate->SetTimeout(GetCurrentThreadJSContext(), nullptr, | |
| 197 aHandler, aTimeout, dummy, false, aRv); | |
| 198 } | |
| 199 | |
| 200 void | |
| 201 WorkerGlobalScope::ClearTimeout(int32_t aHandle, ErrorResult& aRv) | |
| 202 { | |
| 203 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 204 mWorkerPrivate->ClearTimeout(aHandle); | |
| 205 } | |
| 206 | |
| 207 int32_t | |
| 208 WorkerGlobalScope::SetInterval(JSContext* aCx, | |
| 209 Function& aHandler, | |
| 210 const Optional<int32_t>& aTimeout, | |
| 211 const Sequence<JS::Value>& aArguments, | |
| 212 ErrorResult& aRv) | |
| 213 { | |
| 214 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 215 | |
| 216 int32_t timeout = aTimeout.WasPassed() ? aTimeout.Value() : 0; | |
| 217 | |
| 218 return mWorkerPrivate->SetTimeout(aCx, &aHandler, EmptyString(), timeout, | |
| 219 aArguments, !!timeout, aRv); | |
| 220 } | |
| 221 | |
| 222 int32_t | |
| 223 WorkerGlobalScope::SetInterval(JSContext* /* unused */, | |
| 224 const nsAString& aHandler, | |
| 225 const Optional<int32_t>& aTimeout, | |
| 226 const Sequence<JS::Value>& /* unused */, | |
| 227 ErrorResult& aRv) | |
| 228 { | |
| 229 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 230 | |
| 231 Sequence<JS::Value> dummy; | |
| 232 | |
| 233 int32_t timeout = aTimeout.WasPassed() ? aTimeout.Value() : 0; | |
| 234 | |
| 235 return mWorkerPrivate->SetTimeout(GetCurrentThreadJSContext(), nullptr, | |
| 236 aHandler, timeout, dummy, !!timeout, aRv); | |
| 237 } | |
| 238 | |
| 239 void | |
| 240 WorkerGlobalScope::ClearInterval(int32_t aHandle, ErrorResult& aRv) | |
| 241 { | |
| 242 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 243 mWorkerPrivate->ClearTimeout(aHandle); | |
| 244 } | |
| 245 | |
| 246 void | |
| 247 WorkerGlobalScope::Atob(const nsAString& aAtob, nsAString& aOutput, ErrorResult& aRv) const | |
| 248 { | |
| 249 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 250 aRv = nsContentUtils::Atob(aAtob, aOutput); | |
| 251 } | |
| 252 | |
| 253 void | |
| 254 WorkerGlobalScope::Btoa(const nsAString& aBtoa, nsAString& aOutput, ErrorResult& aRv) const | |
| 255 { | |
| 256 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 257 aRv = nsContentUtils::Btoa(aBtoa, aOutput); | |
| 258 } | |
| 259 | |
| 260 void | |
| 261 WorkerGlobalScope::Dump(const Optional<nsAString>& aString) const | |
| 262 { | |
| 263 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 264 | |
| 265 if (!aString.WasPassed()) { | |
| 266 return; | |
| 267 } | |
| 268 | |
| 269 if (!mWorkerPrivate->DumpEnabled()) { | |
| 270 return; | |
| 271 } | |
| 272 | |
| 273 NS_ConvertUTF16toUTF8 str(aString.Value()); | |
| 274 | |
| 275 #ifdef ANDROID | |
| 276 __android_log_print(ANDROID_LOG_INFO, "Gecko", "%s", str.get()); | |
| 277 #endif | |
| 278 fputs(str.get(), stdout); | |
| 279 fflush(stdout); | |
| 280 } | |
| 281 | |
| 282 DedicatedWorkerGlobalScope::DedicatedWorkerGlobalScope(WorkerPrivate* aWorkerPrivate) | |
| 283 : WorkerGlobalScope(aWorkerPrivate) | |
| 284 { | |
| 285 } | |
| 286 | |
| 287 /* static */ bool | |
| 288 DedicatedWorkerGlobalScope::Visible(JSContext* aCx, JSObject* aObj) | |
| 289 { | |
| 290 DedicatedWorkerGlobalScope* self = nullptr; | |
| 291 nsresult rv = UNWRAP_WORKER_OBJECT(DedicatedWorkerGlobalScope, aObj, self); | |
| 292 return NS_SUCCEEDED(rv) && self; | |
| 293 } | |
| 294 | |
| 295 JSObject* | |
| 296 DedicatedWorkerGlobalScope::WrapGlobalObject(JSContext* aCx) | |
| 297 { | |
| 298 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 299 MOZ_ASSERT(!mWorkerPrivate->IsSharedWorker()); | |
| 300 | |
| 301 JS::CompartmentOptions options; | |
| 302 mWorkerPrivate->CopyJSCompartmentOptions(options); | |
| 303 | |
| 304 // We're wrapping the global, so the scope is undefined. | |
| 305 JS::Rooted<JSObject*> scope(aCx); | |
| 306 | |
| 307 return DedicatedWorkerGlobalScopeBinding_workers::Wrap(aCx, this, this, | |
| 308 options, | |
| 309 GetWorkerPrincipal()); | |
| 310 } | |
| 311 | |
| 312 void | |
| 313 DedicatedWorkerGlobalScope::PostMessage(JSContext* aCx, | |
| 314 JS::Handle<JS::Value> aMessage, | |
| 315 const Optional<Sequence<JS::Value>>& aTransferable, | |
| 316 ErrorResult& aRv) | |
| 317 { | |
| 318 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 319 mWorkerPrivate->PostMessageToParent(aCx, aMessage, aTransferable, aRv); | |
| 320 } | |
| 321 | |
| 322 SharedWorkerGlobalScope::SharedWorkerGlobalScope(WorkerPrivate* aWorkerPrivate, | |
| 323 const nsCString& aName) | |
| 324 : WorkerGlobalScope(aWorkerPrivate), mName(aName) | |
| 325 { | |
| 326 } | |
| 327 | |
| 328 /* static */ bool | |
| 329 SharedWorkerGlobalScope::Visible(JSContext* aCx, JSObject* aObj) | |
| 330 { | |
| 331 SharedWorkerGlobalScope* self = nullptr; | |
| 332 nsresult rv = UNWRAP_WORKER_OBJECT(SharedWorkerGlobalScope, aObj, self); | |
| 333 return NS_SUCCEEDED(rv) && self; | |
| 334 } | |
| 335 | |
| 336 JSObject* | |
| 337 SharedWorkerGlobalScope::WrapGlobalObject(JSContext* aCx) | |
| 338 { | |
| 339 mWorkerPrivate->AssertIsOnWorkerThread(); | |
| 340 MOZ_ASSERT(mWorkerPrivate->IsSharedWorker()); | |
| 341 | |
| 342 JS::CompartmentOptions options; | |
| 343 mWorkerPrivate->CopyJSCompartmentOptions(options); | |
| 344 | |
| 345 // We're wrapping the global, so the scope is undefined. | |
| 346 JS::Rooted<JSObject*> scope(aCx); | |
| 347 | |
| 348 return SharedWorkerGlobalScopeBinding_workers::Wrap(aCx, this, this, options, | |
| 349 GetWorkerPrincipal()); | |
| 350 } | |
| 351 | |
| 352 bool | |
| 353 GetterOnlyJSNative(JSContext* aCx, unsigned aArgc, JS::Value* aVp) | |
| 354 { | |
| 355 JS_ReportErrorNumber(aCx, js_GetErrorMessage, nullptr, JSMSG_GETTER_ONLY); | |
| 356 return false; | |
| 357 } | |
| 358 | |
| 359 END_WORKERS_NAMESPACE |
