| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ |
| 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ |
| 7 | 7 |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/memory/weak_ptr.h" | 10 #include "base/memory/weak_ptr.h" |
| (...skipping 23 matching lines...) Expand all Loading... |
| 34 // - designating the new version to be the 'active' version | 34 // - designating the new version to be the 'active' version |
| 35 class ServiceWorkerRegisterJob | 35 class ServiceWorkerRegisterJob |
| 36 : public ServiceWorkerRegisterJobBase, | 36 : public ServiceWorkerRegisterJobBase, |
| 37 public EmbeddedWorkerInstance::Listener { | 37 public EmbeddedWorkerInstance::Listener { |
| 38 public: | 38 public: |
| 39 typedef base::Callback<void(ServiceWorkerStatusCode status, | 39 typedef base::Callback<void(ServiceWorkerStatusCode status, |
| 40 ServiceWorkerRegistration* registration, | 40 ServiceWorkerRegistration* registration, |
| 41 ServiceWorkerVersion* version)> | 41 ServiceWorkerVersion* version)> |
| 42 RegistrationCallback; | 42 RegistrationCallback; |
| 43 | 43 |
| 44 // For registration jobs. |
| 44 CONTENT_EXPORT ServiceWorkerRegisterJob( | 45 CONTENT_EXPORT ServiceWorkerRegisterJob( |
| 45 base::WeakPtr<ServiceWorkerContextCore> context, | 46 base::WeakPtr<ServiceWorkerContextCore> context, |
| 46 const GURL& pattern, | 47 const GURL& pattern, |
| 47 const GURL& script_url); | 48 const GURL& script_url); |
| 49 |
| 50 // For update jobs. |
| 51 CONTENT_EXPORT ServiceWorkerRegisterJob( |
| 52 base::WeakPtr<ServiceWorkerContextCore> context, |
| 53 ServiceWorkerRegistration* registration); |
| 48 virtual ~ServiceWorkerRegisterJob(); | 54 virtual ~ServiceWorkerRegisterJob(); |
| 49 | 55 |
| 50 // Registers a callback to be called when the promise would resolve (whether | 56 // Registers a callback to be called when the promise would resolve (whether |
| 51 // successfully or not). Multiple callbacks may be registered. If |process_id| | 57 // successfully or not). Multiple callbacks may be registered. If |process_id| |
| 52 // is not -1, it's added to the existing clients when deciding in which | 58 // is not -1, it's added to the existing clients when deciding in which |
| 53 // process to create the Service Worker instance. If there are no existing | 59 // process to create the Service Worker instance. If there are no existing |
| 54 // clients, a new RenderProcessHost will be created. | 60 // clients, a new RenderProcessHost will be created. |
| 55 void AddCallback(const RegistrationCallback& callback, int process_id); | 61 void AddCallback(const RegistrationCallback& callback, int process_id); |
| 56 | 62 |
| 57 // ServiceWorkerRegisterJobBase implementation: | 63 // ServiceWorkerRegisterJobBase implementation: |
| 58 virtual void Start() OVERRIDE; | 64 virtual void Start() OVERRIDE; |
| 59 virtual void Abort() OVERRIDE; | 65 virtual void Abort() OVERRIDE; |
| 60 virtual bool Equals(ServiceWorkerRegisterJobBase* job) OVERRIDE; | 66 virtual bool Equals(ServiceWorkerRegisterJobBase* job) OVERRIDE; |
| 61 virtual RegistrationJobType GetType() OVERRIDE; | 67 virtual RegistrationJobType GetType() OVERRIDE; |
| 62 | 68 |
| 69 // TODO(michaeln): Use the registration listerer's OnVersionAttributesChanged |
| 70 // method to replace these methods, have the host listen for changes |
| 71 // to their registration. |
| 72 CONTENT_EXPORT static void AssociateInstallingVersionToDocuments( |
| 73 base::WeakPtr<ServiceWorkerContextCore> context, |
| 74 ServiceWorkerVersion* version); |
| 75 static void AssociateWaitingVersionToDocuments( |
| 76 base::WeakPtr<ServiceWorkerContextCore> context, |
| 77 ServiceWorkerVersion* version); |
| 78 static void AssociateActiveVersionToDocuments( |
| 79 base::WeakPtr<ServiceWorkerContextCore> context, |
| 80 ServiceWorkerVersion* version); |
| 81 CONTENT_EXPORT static void DisassociateVersionFromDocuments( |
| 82 base::WeakPtr<ServiceWorkerContextCore> context, |
| 83 ServiceWorkerVersion* version); |
| 84 |
| 63 private: | 85 private: |
| 64 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerProviderHostWaitingVersionTest, | 86 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerProviderHostWaitingVersionTest, |
| 65 AssociateInstallingVersionToDocuments); | 87 AssociateInstallingVersionToDocuments); |
| 66 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerProviderHostWaitingVersionTest, | 88 FRIEND_TEST_ALL_PREFIXES(ServiceWorkerProviderHostWaitingVersionTest, |
| 67 DisassociateVersionFromDocuments); | 89 DisassociateVersionFromDocuments); |
| 68 | 90 |
| 69 enum Phase { | 91 enum Phase { |
| 70 INITIAL, | 92 INITIAL, |
| 71 START, | 93 START, |
| 72 REGISTER, | 94 REGISTER, |
| (...skipping 17 matching lines...) Expand all Loading... |
| 90 scoped_refptr<ServiceWorkerVersion> new_version; | 112 scoped_refptr<ServiceWorkerVersion> new_version; |
| 91 }; | 113 }; |
| 92 | 114 |
| 93 void set_registration(ServiceWorkerRegistration* registration); | 115 void set_registration(ServiceWorkerRegistration* registration); |
| 94 ServiceWorkerRegistration* registration(); | 116 ServiceWorkerRegistration* registration(); |
| 95 void set_new_version(ServiceWorkerVersion* version); | 117 void set_new_version(ServiceWorkerVersion* version); |
| 96 ServiceWorkerVersion* new_version(); | 118 ServiceWorkerVersion* new_version(); |
| 97 | 119 |
| 98 void SetPhase(Phase phase); | 120 void SetPhase(Phase phase); |
| 99 | 121 |
| 100 void HandleExistingRegistrationAndContinue( | 122 void ContinueWithRegistration( |
| 123 ServiceWorkerStatusCode status, |
| 124 const scoped_refptr<ServiceWorkerRegistration>& registration); |
| 125 void ContinueWithUpdate( |
| 101 ServiceWorkerStatusCode status, | 126 ServiceWorkerStatusCode status, |
| 102 const scoped_refptr<ServiceWorkerRegistration>& registration); | 127 const scoped_refptr<ServiceWorkerRegistration>& registration); |
| 103 void RegisterAndContinue(ServiceWorkerStatusCode status); | 128 void RegisterAndContinue(ServiceWorkerStatusCode status); |
| 104 void UpdateAndContinue(ServiceWorkerStatusCode status); | 129 void UpdateAndContinue(); |
| 105 void OnStartWorkerFinished(ServiceWorkerStatusCode status); | 130 void OnStartWorkerFinished(ServiceWorkerStatusCode status); |
| 106 void OnStoreRegistrationComplete(ServiceWorkerStatusCode status); | 131 void OnStoreRegistrationComplete(ServiceWorkerStatusCode status); |
| 107 void InstallAndContinue(); | 132 void InstallAndContinue(); |
| 108 void OnInstallFinished(ServiceWorkerStatusCode status); | 133 void OnInstallFinished(ServiceWorkerStatusCode status); |
| 109 void ActivateAndContinue(); | 134 void ActivateAndContinue(); |
| 110 void OnActivateFinished(ServiceWorkerStatusCode status); | 135 void OnActivateFinished(ServiceWorkerStatusCode status); |
| 111 void Complete(ServiceWorkerStatusCode status); | 136 void Complete(ServiceWorkerStatusCode status); |
| 112 void CompleteInternal(ServiceWorkerStatusCode status); | 137 void CompleteInternal(ServiceWorkerStatusCode status); |
| 113 | |
| 114 void ResolvePromise(ServiceWorkerStatusCode status, | 138 void ResolvePromise(ServiceWorkerStatusCode status, |
| 115 ServiceWorkerRegistration* registration, | 139 ServiceWorkerRegistration* registration, |
| 116 ServiceWorkerVersion* version); | 140 ServiceWorkerVersion* version); |
| 117 | 141 |
| 118 // EmbeddedWorkerInstance::Listener override of OnPausedAfterDownload. | 142 // EmbeddedWorkerInstance::Listener override of OnPausedAfterDownload. |
| 119 virtual void OnPausedAfterDownload() OVERRIDE; | 143 virtual void OnPausedAfterDownload() OVERRIDE; |
| 120 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; | 144 virtual bool OnMessageReceived(const IPC::Message& message) OVERRIDE; |
| 121 | 145 |
| 122 // Associates an installing version to documents matched with a scope of the | 146 void OnCompareScriptResourcesComplete( |
| 123 // version. | 147 ServiceWorkerVersion* current_version, |
| 124 CONTENT_EXPORT static void AssociateInstallingVersionToDocuments( | 148 ServiceWorkerStatusCode status, |
| 125 base::WeakPtr<ServiceWorkerContextCore> context, | 149 int compare_result); |
| 126 ServiceWorkerVersion* version); | |
| 127 | |
| 128 // Associates a waiting version to documents matched with a scope of the | |
| 129 // version. | |
| 130 static void AssociateWaitingVersionToDocuments( | |
| 131 base::WeakPtr<ServiceWorkerContextCore> context, | |
| 132 ServiceWorkerVersion* version); | |
| 133 | |
| 134 // Associates an active version to documents matched with a scope of the | |
| 135 // version. | |
| 136 static void AssociateActiveVersionToDocuments( | |
| 137 base::WeakPtr<ServiceWorkerContextCore> context, | |
| 138 ServiceWorkerVersion* version); | |
| 139 | |
| 140 // Disassociates a version specified by |version_id| from documents. | |
| 141 CONTENT_EXPORT static void DisassociateVersionFromDocuments( | |
| 142 base::WeakPtr<ServiceWorkerContextCore> context, | |
| 143 ServiceWorkerVersion* version); | |
| 144 | 150 |
| 145 // The ServiceWorkerContextCore object should always outlive this. | 151 // The ServiceWorkerContextCore object should always outlive this. |
| 146 base::WeakPtr<ServiceWorkerContextCore> context_; | 152 base::WeakPtr<ServiceWorkerContextCore> context_; |
| 147 | 153 |
| 154 RegistrationJobType job_type_; |
| 148 const GURL pattern_; | 155 const GURL pattern_; |
| 149 const GURL script_url_; | 156 const GURL script_url_; |
| 150 std::vector<RegistrationCallback> callbacks_; | 157 std::vector<RegistrationCallback> callbacks_; |
| 151 std::vector<int> pending_process_ids_; | 158 std::vector<int> pending_process_ids_; |
| 152 Phase phase_; | 159 Phase phase_; |
| 153 Internal internal_; | 160 Internal internal_; |
| 154 bool is_promise_resolved_; | 161 bool is_promise_resolved_; |
| 155 ServiceWorkerStatusCode promise_resolved_status_; | 162 ServiceWorkerStatusCode promise_resolved_status_; |
| 156 scoped_refptr<ServiceWorkerRegistration> promise_resolved_registration_; | 163 scoped_refptr<ServiceWorkerRegistration> promise_resolved_registration_; |
| 157 scoped_refptr<ServiceWorkerVersion> promise_resolved_version_; | 164 scoped_refptr<ServiceWorkerVersion> promise_resolved_version_; |
| 158 base::WeakPtrFactory<ServiceWorkerRegisterJob> weak_factory_; | 165 base::WeakPtrFactory<ServiceWorkerRegisterJob> weak_factory_; |
| 159 | 166 |
| 160 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerRegisterJob); | 167 DISALLOW_COPY_AND_ASSIGN(ServiceWorkerRegisterJob); |
| 161 }; | 168 }; |
| 162 | 169 |
| 163 } // namespace content | 170 } // namespace content |
| 164 | 171 |
| 165 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ | 172 #endif // CONTENT_BROWSER_SERVICE_WORKER_SERVICE_WORKER_REGISTER_JOB_H_ |
| OLD | NEW |