| 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_EMBEDDED_WORKER_INSTANCE_H_ | 5 #ifndef CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_INSTANCE_H_ |
| 6 #define CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_INSTANCE_H_ | 6 #define CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_INSTANCE_H_ |
| 7 | 7 |
| 8 #include <map> | 8 #include <map> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 49 enum Status { | 49 enum Status { |
| 50 STOPPED, | 50 STOPPED, |
| 51 STARTING, | 51 STARTING, |
| 52 RUNNING, | 52 RUNNING, |
| 53 STOPPING, | 53 STOPPING, |
| 54 }; | 54 }; |
| 55 | 55 |
| 56 class Listener { | 56 class Listener { |
| 57 public: | 57 public: |
| 58 virtual ~Listener() {} | 58 virtual ~Listener() {} |
| 59 virtual void OnScriptLoaded() {} |
| 59 virtual void OnStarted() {} | 60 virtual void OnStarted() {} |
| 60 virtual void OnStopped(Status old_status) {} | 61 virtual void OnStopped(Status old_status) {} |
| 61 virtual void OnPausedAfterDownload() {} | 62 virtual void OnPausedAfterDownload() {} |
| 62 virtual void OnReportException(const base::string16& error_message, | 63 virtual void OnReportException(const base::string16& error_message, |
| 63 int line_number, | 64 int line_number, |
| 64 int column_number, | 65 int column_number, |
| 65 const GURL& source_url) {} | 66 const GURL& source_url) {} |
| 66 virtual void OnReportConsoleMessage(int source_identifier, | 67 virtual void OnReportConsoleMessage(int source_identifier, |
| 67 int message_level, | 68 int message_level, |
| 68 const base::string16& message, | 69 const base::string16& message, |
| 69 int line_number, | 70 int line_number, |
| 70 const GURL& source_url) {} | 71 const GURL& source_url) {} |
| 71 // These should return false if the message is not handled by this | 72 // These should return false if the message is not handled by this |
| 72 // listener. (TODO(kinuko): consider using IPC::Listener interface) | 73 // listener. (TODO(kinuko): consider using IPC::Listener interface) |
| 73 // TODO(kinuko): Deprecate OnReplyReceived. | 74 // TODO(kinuko): Deprecate OnReplyReceived. |
| 74 virtual bool OnMessageReceived(const IPC::Message& message) = 0; | 75 virtual bool OnMessageReceived(const IPC::Message& message) = 0; |
| 75 }; | 76 }; |
| 76 | 77 |
| 77 ~EmbeddedWorkerInstance(); | 78 ~EmbeddedWorkerInstance(); |
| 78 | 79 |
| 79 // Starts the worker. It is invalid to call this when the worker is not in | 80 // Starts the worker. It is invalid to call this when the worker is not in |
| 80 // STOPPED status. |callback| is invoked when the worker's process is created | 81 // STOPPED status. |callback| is invoked after the worker script has been |
| 81 // if necessary and the IPC to evaluate the worker's script is sent. | 82 // started and evaluated, or when an error occurs. |
| 82 // Observer::OnStarted() is run when the worker is actually started. | |
| 83 void Start(int64 service_worker_version_id, | 83 void Start(int64 service_worker_version_id, |
| 84 const GURL& scope, | 84 const GURL& scope, |
| 85 const GURL& script_url, | 85 const GURL& script_url, |
| 86 bool pause_after_download, | 86 bool pause_after_download, |
| 87 const StatusCallback& callback); | 87 const StatusCallback& callback); |
| 88 | 88 |
| 89 // Stops the worker. It is invalid to call this when the worker is | 89 // Stops the worker. It is invalid to call this when the worker is |
| 90 // not in STARTING or RUNNING status. | 90 // not in STARTING or RUNNING status. |
| 91 // This returns false if stopping a worker fails immediately, e.g. when | 91 // This returns false if stopping a worker fails immediately, e.g. when |
| 92 // IPC couldn't be sent to the worker. | 92 // IPC couldn't be sent to the worker. |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 155 | 155 |
| 156 // Called back from Registry when the worker instance has ack'ed that | 156 // Called back from Registry when the worker instance has ack'ed that |
| 157 // it finished loading the script and has started a worker thread. | 157 // it finished loading the script and has started a worker thread. |
| 158 void OnScriptLoaded(int thread_id); | 158 void OnScriptLoaded(int thread_id); |
| 159 | 159 |
| 160 // Called back from Registry when the worker instance has ack'ed that | 160 // Called back from Registry when the worker instance has ack'ed that |
| 161 // it failed to load the script. | 161 // it failed to load the script. |
| 162 void OnScriptLoadFailed(); | 162 void OnScriptLoadFailed(); |
| 163 | 163 |
| 164 // Called back from Registry when the worker instance has ack'ed that | 164 // Called back from Registry when the worker instance has ack'ed that |
| 165 // it finished evaluating the script. | 165 // it finished evaluating the script. This is called before OnStarted. |
| 166 void OnScriptEvaluated(bool success); | 166 void OnScriptEvaluated(bool success); |
| 167 | 167 |
| 168 // Called back from Registry when the worker instance has ack'ed that | 168 // Called back from Registry when the worker instance has ack'ed that its |
| 169 // its WorkerGlobalScope is actually started and parsed. | 169 // WorkerGlobalScope has actually started and evaluated the script. This is |
| 170 // called after OnScriptEvaluated. |
| 170 // This will change the internal status from STARTING to RUNNING. | 171 // This will change the internal status from STARTING to RUNNING. |
| 171 void OnStarted(); | 172 void OnStarted(); |
| 172 | 173 |
| 173 void OnPausedAfterDownload(); | 174 void OnPausedAfterDownload(); |
| 174 | 175 |
| 175 // Called back from Registry when the worker instance has ack'ed that | 176 // Called back from Registry when the worker instance has ack'ed that |
| 176 // its WorkerGlobalScope is actually stopped in the child process. | 177 // its WorkerGlobalScope is actually stopped in the child process. |
| 177 // This will change the internal status from STARTING or RUNNING to | 178 // This will change the internal status from STARTING or RUNNING to |
| 178 // STOPPED. | 179 // STOPPED. |
| 179 void OnStopped(); | 180 void OnStopped(); |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 219 base::TimeTicks start_timing_; | 220 base::TimeTicks start_timing_; |
| 220 | 221 |
| 221 base::WeakPtrFactory<EmbeddedWorkerInstance> weak_factory_; | 222 base::WeakPtrFactory<EmbeddedWorkerInstance> weak_factory_; |
| 222 | 223 |
| 223 DISALLOW_COPY_AND_ASSIGN(EmbeddedWorkerInstance); | 224 DISALLOW_COPY_AND_ASSIGN(EmbeddedWorkerInstance); |
| 224 }; | 225 }; |
| 225 | 226 |
| 226 } // namespace content | 227 } // namespace content |
| 227 | 228 |
| 228 #endif // CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_INSTANCE_H_ | 229 #endif // CONTENT_BROWSER_SERVICE_WORKER_EMBEDDED_WORKER_INSTANCE_H_ |
| OLD | NEW |