Commit 0fa0f1ee authored by yhirano@chromium.org's avatar yhirano@chromium.org

[ServiceWorker] Use appopriate type parameters for WebCallbacks (1/3)

 - WebServiceWorkerRegistration* (ownership transferred)
  => WebPassOwnPtr<WebServiceWorkerRegistration>
 - WebVector<WebServiceWorkerRegistration*> (ownership transferred)
  => WebPassOwnPtr<WebVector<WebServiceWorkerRegistration*>>
 - WebServiceWorkerError* (ownership transferred)
  => const WebServiceWorkerError&

This CL also fixes a memory leak in GetRegistrationsCallback::onSuccess.

1/3: https://codereview.chromium.org/1312343004/
2/3: https://codereview.chromium.org/1318953002/
3/3: https://codereview.chromium.org/1316293002/

BUG=493531, 525340

Review URL: https://codereview.chromium.org/1312343004

git-svn-id: svn://svn.chromium.org/blink/trunk@201321 bbb929c8-8fbe-4397-9dbb-9b2b20218538
parent 0d554e5a
...@@ -64,22 +64,18 @@ public: ...@@ -64,22 +64,18 @@ public:
: m_resolver(resolver) { } : m_resolver(resolver) { }
~RegistrationCallback() override { } ~RegistrationCallback() override { }
// Takes ownership of |registrationRaw|. void onSuccess(WebPassOwnPtr<WebServiceWorkerRegistration> registration) override
void onSuccess(WebServiceWorkerRegistration* registrationRaw) override
{ {
OwnPtr<WebServiceWorkerRegistration> registration = adoptPtr(registrationRaw);
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
m_resolver->resolve(ServiceWorkerRegistration::create(m_resolver->executionContext(), registration.release())); m_resolver->resolve(ServiceWorkerRegistration::create(m_resolver->executionContext(), registration.release()));
} }
// Takes ownership of |errorRaw|. void onError(const WebServiceWorkerError& error) override
void onError(WebServiceWorkerError* errorRaw) override
{ {
OwnPtr<WebServiceWorkerError> error = adoptPtr(errorRaw);
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), *error)); m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), error));
} }
private: private:
...@@ -93,10 +89,9 @@ public: ...@@ -93,10 +89,9 @@ public:
: m_resolver(resolver) { } : m_resolver(resolver) { }
~GetRegistrationCallback() override { } ~GetRegistrationCallback() override { }
// Takes ownership of |registrationRaw|. void onSuccess(WebPassOwnPtr<WebServiceWorkerRegistration> r) override
void onSuccess(WebServiceWorkerRegistration* registrationRaw) override
{ {
OwnPtr<WebServiceWorkerRegistration> registration = adoptPtr(registrationRaw); OwnPtr<WebServiceWorkerRegistration> registration = r.release();
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
if (!registration) { if (!registration) {
...@@ -107,13 +102,11 @@ public: ...@@ -107,13 +102,11 @@ public:
m_resolver->resolve(ServiceWorkerRegistration::create(m_resolver->executionContext(), registration.release())); m_resolver->resolve(ServiceWorkerRegistration::create(m_resolver->executionContext(), registration.release()));
} }
// Takes ownership of |errorRaw|. void onError(const WebServiceWorkerError& error) override
void onError(WebServiceWorkerError* errorRaw) override
{ {
OwnPtr<WebServiceWorkerError> error = adoptPtr(errorRaw);
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), *error)); m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), error));
} }
private: private:
...@@ -127,22 +120,24 @@ public: ...@@ -127,22 +120,24 @@ public:
: m_resolver(resolver) { } : m_resolver(resolver) { }
~GetRegistrationsCallback() override { } ~GetRegistrationsCallback() override { }
// Takes ownership of |registrationsRaw|. void onSuccess(WebPassOwnPtr<WebVector<WebServiceWorkerRegistration*>> webPassRegistrations) override
void onSuccess(WebVector<WebServiceWorkerRegistration*>* registrationsRaw) override
{ {
OwnPtr<WebVector<WebServiceWorkerRegistration*>> registrations = adoptPtr(registrationsRaw); Vector<OwnPtr<WebServiceWorkerRegistration>> registrations;
OwnPtr<WebVector<WebServiceWorkerRegistration*>> webRegistrations = webPassRegistrations.release();
for (auto& registration : *webRegistrations) {
registrations.append(adoptPtr(registration));
}
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
m_resolver->resolve(ServiceWorkerRegistrationArray::take(m_resolver.get(), registrations.release())); m_resolver->resolve(ServiceWorkerRegistrationArray::take(m_resolver.get(), &registrations));
} }
// Takes ownership of |errorRaw|. void onError(const WebServiceWorkerError& error) override
void onError(WebServiceWorkerError* errorRaw) override
{ {
OwnPtr<WebServiceWorkerError> error = adoptPtr(errorRaw);
if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped()) if (!m_resolver->executionContext() || m_resolver->executionContext()->activeDOMObjectsAreStopped())
return; return;
m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), *error)); m_resolver->reject(ServiceWorkerError::take(m_resolver.get(), error));
} }
private: private:
...@@ -154,15 +149,12 @@ class ServiceWorkerContainer::GetRegistrationForReadyCallback : public WebServic ...@@ -154,15 +149,12 @@ class ServiceWorkerContainer::GetRegistrationForReadyCallback : public WebServic
public: public:
explicit GetRegistrationForReadyCallback(ReadyProperty* ready) explicit GetRegistrationForReadyCallback(ReadyProperty* ready)
: m_ready(ready) { } : m_ready(ready) { }
~GetRegistrationForReadyCallback() { } ~GetRegistrationForReadyCallback() override { }
// Takes ownership of |registrationRaw|. void onSuccess(WebPassOwnPtr<WebServiceWorkerRegistration> registration) override
void onSuccess(WebServiceWorkerRegistration* registrationRaw) override
{ {
ASSERT(registrationRaw);
ASSERT(m_ready->state() == ReadyProperty::Pending); ASSERT(m_ready->state() == ReadyProperty::Pending);
OwnPtr<WebServiceWorkerRegistration> registration = adoptPtr(registrationRaw);
if (m_ready->executionContext() && !m_ready->executionContext()->activeDOMObjectsAreStopped()) if (m_ready->executionContext() && !m_ready->executionContext()->activeDOMObjectsAreStopped())
m_ready->resolve(ServiceWorkerRegistration::create(m_ready->executionContext(), registration.release())); m_ready->resolve(ServiceWorkerRegistration::create(m_ready->executionContext(), registration.release()));
} }
......
...@@ -83,11 +83,11 @@ private: ...@@ -83,11 +83,11 @@ private:
class ServiceWorkerRegistrationArray { class ServiceWorkerRegistrationArray {
STATIC_ONLY(ServiceWorkerRegistrationArray); STATIC_ONLY(ServiceWorkerRegistrationArray);
public: public:
static HeapVector<Member<ServiceWorkerRegistration>> take(ScriptPromiseResolver* resolver, PassOwnPtr<WebVector<WebServiceWorkerRegistration*>> webServiceWorkerRegistrations) static HeapVector<Member<ServiceWorkerRegistration>> take(ScriptPromiseResolver* resolver, Vector<OwnPtr<WebServiceWorkerRegistration>>* webServiceWorkerRegistrations)
{ {
HeapVector<Member<ServiceWorkerRegistration>> registrations; HeapVector<Member<ServiceWorkerRegistration>> registrations;
for (WebServiceWorkerRegistration* registration : *webServiceWorkerRegistrations) for (auto& registration : *webServiceWorkerRegistrations)
registrations.append(ServiceWorkerRegistration::create(resolver->executionContext(), adoptPtr(registration))); registrations.append(ServiceWorkerRegistration::create(resolver->executionContext(), registration.release()));
return registrations; return registrations;
} }
}; };
......
...@@ -32,6 +32,7 @@ ...@@ -32,6 +32,7 @@
#define WebServiceWorkerProvider_h #define WebServiceWorkerProvider_h
#include "public/platform/WebCallbacks.h" #include "public/platform/WebCallbacks.h"
#include "public/platform/WebPassOwnPtr.h"
#include "public/platform/WebServiceWorkerRegistration.h" #include "public/platform/WebServiceWorkerRegistration.h"
#include "public/platform/WebVector.h" #include "public/platform/WebVector.h"
...@@ -51,12 +52,34 @@ public: ...@@ -51,12 +52,34 @@ public:
// events. Must be cleared before the client becomes invalid. // events. Must be cleared before the client becomes invalid.
virtual void setClient(WebServiceWorkerProviderClient*) { } virtual void setClient(WebServiceWorkerProviderClient*) { }
// The WebServiceWorkerRegistration and WebServiceWorkerError ownership are class WebServiceWorkerRegistrationCallbacks : public WebCallbacks<WebPassOwnPtr<WebServiceWorkerRegistration>, const WebServiceWorkerError&> {
// passed to the WebServiceWorkerRegistrationCallbacks implementation. public:
typedef WebCallbacks<WebServiceWorkerRegistration*, WebServiceWorkerError*> WebServiceWorkerRegistrationCallbacks; void onSuccess(WebServiceWorkerRegistration* r) { onSuccess(adoptWebPtr(r)); }
typedef WebCallbacks<WebServiceWorkerRegistration*, WebServiceWorkerError*> WebServiceWorkerGetRegistrationCallbacks; void onError(WebServiceWorkerError* e)
typedef WebCallbacks<WebVector<WebServiceWorkerRegistration*>*, WebServiceWorkerError*> WebServiceWorkerGetRegistrationsCallbacks; {
typedef WebCallbacks<WebServiceWorkerRegistration*, void> WebServiceWorkerGetRegistrationForReadyCallbacks; onError(*e);
delete e;
}
virtual void onSuccess(WebPassOwnPtr<WebServiceWorkerRegistration>) = 0;
virtual void onError(const WebServiceWorkerError&) = 0;
};
using WebServiceWorkerGetRegistrationCallbacks = WebServiceWorkerRegistrationCallbacks;
class WebServiceWorkerGetRegistrationsCallbacks : public WebCallbacks<WebPassOwnPtr<WebVector<WebServiceWorkerRegistration*>>, const WebServiceWorkerError&> {
public:
void onSuccess(WebVector<WebServiceWorkerRegistration*>* r) { onSuccess(adoptWebPtr(r)); }
void onError(WebServiceWorkerError* e)
{
onError(*e);
delete e;
}
virtual void onSuccess(WebPassOwnPtr<WebVector<WebServiceWorkerRegistration*>>) = 0;
virtual void onError(const WebServiceWorkerError&) = 0;
};
class WebServiceWorkerGetRegistrationForReadyCallbacks : public WebCallbacks<WebPassOwnPtr<WebServiceWorkerRegistration>, void> {
public:
void onSuccess(WebServiceWorkerRegistration* r) { onSuccess(adoptWebPtr(r)); }
virtual void onSuccess(WebPassOwnPtr<WebServiceWorkerRegistration>) = 0;
};
virtual void registerServiceWorker(const WebURL& pattern, const WebURL& scriptUrl, WebServiceWorkerRegistrationCallbacks*) { } virtual void registerServiceWorker(const WebURL& pattern, const WebURL& scriptUrl, WebServiceWorkerRegistrationCallbacks*) { }
virtual void getRegistration(const WebURL& documentURL, WebServiceWorkerGetRegistrationCallbacks*) { } virtual void getRegistration(const WebURL& documentURL, WebServiceWorkerGetRegistrationCallbacks*) { }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment