aboutsummaryrefslogtreecommitdiffstats
path: root/components/script/serviceworker_manager.rs
diff options
context:
space:
mode:
authorJosh Matthews <josh@joshmatthews.net>2024-10-18 13:26:54 -0400
committerGitHub <noreply@github.com>2024-10-18 17:26:54 +0000
commitb85093ad7461122447298d91acd19040c31c42a9 (patch)
treeb83e2e52452cf3e93caefa0461bf66be25c97205 /components/script/serviceworker_manager.rs
parenta58da5aa832a67c827021592fe0397a532491c4c (diff)
downloadservo-b85093ad7461122447298d91acd19040c31c42a9.tar.gz
servo-b85093ad7461122447298d91acd19040c31c42a9.zip
Prevent moving CanGc values between threads/tasks (#33902)
* Make CanGc non-sendable, and add documentation. Signed-off-by: Josh Matthews <josh@joshmatthews.net> * Update CanGc usage to fix usages that were moved between threads/tasks. Signed-off-by: Josh Matthews <josh@joshmatthews.net> --------- Signed-off-by: Josh Matthews <josh@joshmatthews.net>
Diffstat (limited to 'components/script/serviceworker_manager.rs')
-rw-r--r--components/script/serviceworker_manager.rs26
1 files changed, 9 insertions, 17 deletions
diff --git a/components/script/serviceworker_manager.rs b/components/script/serviceworker_manager.rs
index 034da394310..3be5d3a9ef2 100644
--- a/components/script/serviceworker_manager.rs
+++ b/components/script/serviceworker_manager.rs
@@ -29,7 +29,7 @@ use crate::dom::serviceworkerglobalscope::{
ServiceWorkerControlMsg, ServiceWorkerGlobalScope, ServiceWorkerScriptMsg,
};
use crate::dom::serviceworkerregistration::longest_prefix_match;
-use crate::script_runtime::{CanGc, ThreadSafeJSContext};
+use crate::script_runtime::ThreadSafeJSContext;
enum Message {
FromResource(CustomResponseMediator),
@@ -250,12 +250,10 @@ impl ServiceWorkerManager {
None
}
- fn handle_message(&mut self, can_gc: CanGc) {
+ fn handle_message(&mut self) {
while let Ok(message) = self.receive_message() {
let should_continue = match message {
- Message::FromConstellation(msg) => {
- self.handle_message_from_constellation(*msg, can_gc)
- },
+ Message::FromConstellation(msg) => self.handle_message_from_constellation(*msg),
Message::FromResource(msg) => self.handle_message_from_resource(msg),
};
if !should_continue {
@@ -290,7 +288,7 @@ impl ServiceWorkerManager {
}
}
- fn handle_message_from_constellation(&mut self, msg: ServiceWorkerMsg, can_gc: CanGc) -> bool {
+ fn handle_message_from_constellation(&mut self, msg: ServiceWorkerMsg) -> bool {
match msg {
ServiceWorkerMsg::Timeout(_scope) => {
// TODO: https://w3c.github.io/ServiceWorker/#terminate-service-worker
@@ -307,7 +305,7 @@ impl ServiceWorkerManager {
self.handle_register_job(job);
},
JobType::Update => {
- self.handle_update_job(job, can_gc);
+ self.handle_update_job(job);
},
JobType::Unregister => {
// TODO: https://w3c.github.io/ServiceWorker/#unregister-algorithm
@@ -382,7 +380,7 @@ impl ServiceWorkerManager {
}
/// <https://w3c.github.io/ServiceWorker/#update>
- fn handle_update_job(&mut self, job: Job, can_gc: CanGc) {
+ fn handle_update_job(&mut self, job: Job) {
// Step 1: Get registation
if let Some(registration) = self.registrations.get_mut(&job.scope_url) {
// Step 3.
@@ -405,12 +403,8 @@ impl ServiceWorkerManager {
// Very roughly steps 5 to 18.
// TODO: implement all steps precisely.
- let (new_worker, join_handle, control_sender, context, closing) = update_serviceworker(
- self.own_sender.clone(),
- job.scope_url.clone(),
- scope_things,
- can_gc,
- );
+ let (new_worker, join_handle, control_sender, context, closing) =
+ update_serviceworker(self.own_sender.clone(), job.scope_url.clone(), scope_things);
// Since we've just started the worker thread, ensure we can shut it down later.
registration.note_worker_thread(join_handle, control_sender, context, closing);
@@ -449,7 +443,6 @@ fn update_serviceworker(
own_sender: IpcSender<ServiceWorkerMsg>,
scope_url: ServoUrl,
scope_things: ScopeThings,
- can_gc: CanGc,
) -> (
ServiceWorker,
JoinHandle<()>,
@@ -475,7 +468,6 @@ fn update_serviceworker(
control_receiver,
context_sender,
closing.clone(),
- can_gc,
);
let context = context_receiver
@@ -512,7 +504,7 @@ impl ServiceWorkerManagerFactory for ServiceWorkerManager {
resource_port,
constellation_sender,
)
- .handle_message(CanGc::note())
+ .handle_message()
};
if thread::Builder::new()
.name("SvcWorkerManager".to_owned())