clippy: Rename various methods and members to conform to naming guidelines (#33762)

This ensure that methods named `new()` do not take `&self` or return
`Box<Self>`. In addition, method are renamed (or removed when not
necessary) to avoid being prefixed with `from_`.

Signed-off-by: Martin Robinson <mrobinson@igalia.com>
This commit is contained in:
Martin Robinson 2024-10-10 03:21:07 -07:00 committed by GitHub
parent 2805d3ce14
commit 6f87c38cda
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
6 changed files with 55 additions and 57 deletions

View file

@ -110,9 +110,7 @@ pub fn run_worker_event_loop<T, WorkerMsg, Event>(
+ DomObject, + DomObject,
{ {
let scope = worker_scope.upcast::<WorkerGlobalScope>(); let scope = worker_scope.upcast::<WorkerGlobalScope>();
let devtools_port = scope let devtools_receiver = scope.devtools_receiver();
.from_devtools_sender()
.map(|_| scope.from_devtools_receiver());
let task_queue = worker_scope.task_queue(); let task_queue = worker_scope.task_queue();
let event = select! { let event = select! {
recv(worker_scope.control_receiver()) -> msg => T::from_control_msg(msg.unwrap()), recv(worker_scope.control_receiver()) -> msg => T::from_control_msg(msg.unwrap()),
@ -120,7 +118,7 @@ pub fn run_worker_event_loop<T, WorkerMsg, Event>(
task_queue.take_tasks(msg.unwrap()); task_queue.take_tasks(msg.unwrap());
T::from_worker_msg(task_queue.recv().unwrap()) T::from_worker_msg(task_queue.recv().unwrap())
}, },
recv(devtools_port.unwrap_or(&crossbeam_channel::never())) -> msg => recv(devtools_receiver.unwrap_or(&crossbeam_channel::never())) -> msg =>
T::from_devtools_msg(msg.unwrap()), T::from_devtools_msg(msg.unwrap()),
}; };
let mut sequential = vec![]; let mut sequential = vec![];
@ -134,7 +132,7 @@ pub fn run_worker_event_loop<T, WorkerMsg, Event>(
// Batch all events that are ready. // Batch all events that are ready.
// The task queue will throttle non-priority tasks if necessary. // The task queue will throttle non-priority tasks if necessary.
match task_queue.take_tasks_and_recv() { match task_queue.take_tasks_and_recv() {
Err(_) => match devtools_port.map(|port| port.try_recv()) { Err(_) => match devtools_receiver.map(|port| port.try_recv()) {
None => {}, None => {},
Some(Err(_)) => break, Some(Err(_)) => break,
Some(Ok(ev)) => sequential.push(T::from_devtools_msg(ev)), Some(Ok(ev)) => sequential.push(T::from_devtools_msg(ev)),

View file

@ -1017,8 +1017,8 @@ impl TestBindingMethods for TestBinding {
let global = self.global(); let global = self.global();
let handler = PromiseNativeHandler::new( let handler = PromiseNativeHandler::new(
&global, &global,
resolve.map(SimpleHandler::new), resolve.map(SimpleHandler::new_boxed),
reject.map(SimpleHandler::new), reject.map(SimpleHandler::new_boxed),
); );
let p = Promise::new_in_current_realm(comp); let p = Promise::new_in_current_realm(comp);
p.append_native_handler(&handler, comp); p.append_native_handler(&handler, comp);
@ -1030,7 +1030,7 @@ impl TestBindingMethods for TestBinding {
handler: Rc<SimpleCallback>, handler: Rc<SimpleCallback>,
} }
impl SimpleHandler { impl SimpleHandler {
fn new(callback: Rc<SimpleCallback>) -> Box<dyn Callback> { fn new_boxed(callback: Rc<SimpleCallback>) -> Box<dyn Callback> {
Box::new(SimpleHandler { handler: callback }) Box::new(SimpleHandler { handler: callback })
} }
} }

View file

@ -114,15 +114,14 @@ pub struct WorkerGlobalScope {
#[ignore_malloc_size_of = "Defined in ipc-channel"] #[ignore_malloc_size_of = "Defined in ipc-channel"]
#[no_trace] #[no_trace]
/// Optional `IpcSender` for sending the `DevtoolScriptControlMsg` /// A `Sender` for sending messages to devtools. This is unused but is stored here to
/// to the server from within the worker /// keep the channel alive.
from_devtools_sender: Option<IpcSender<DevtoolScriptControlMsg>>, _devtools_sender: Option<IpcSender<DevtoolScriptControlMsg>>,
#[ignore_malloc_size_of = "Defined in std"] #[ignore_malloc_size_of = "Defined in crossbeam"]
#[no_trace] #[no_trace]
/// This `Receiver` will be ignored later if the corresponding /// A `Receiver` for receiving messages from devtools.
/// `IpcSender` doesn't exist devtools_receiver: Option<Receiver<DevtoolScriptControlMsg>>,
from_devtools_receiver: Receiver<DevtoolScriptControlMsg>,
#[no_trace] #[no_trace]
navigation_start: CrossProcessInstant, navigation_start: CrossProcessInstant,
@ -137,12 +136,18 @@ impl WorkerGlobalScope {
worker_type: WorkerType, worker_type: WorkerType,
worker_url: ServoUrl, worker_url: ServoUrl,
runtime: Runtime, runtime: Runtime,
from_devtools_receiver: Receiver<DevtoolScriptControlMsg>, devtools_receiver: Receiver<DevtoolScriptControlMsg>,
closing: Arc<AtomicBool>, closing: Arc<AtomicBool>,
gpu_id_hub: Arc<IdentityHub>, gpu_id_hub: Arc<IdentityHub>,
) -> Self { ) -> Self {
// Install a pipeline-namespace in the current thread. // Install a pipeline-namespace in the current thread.
PipelineNamespace::auto_install(); PipelineNamespace::auto_install();
let devtools_receiver = match init.from_devtools_sender {
Some(..) => Some(devtools_receiver),
None => None,
};
Self { Self {
globalscope: GlobalScope::new_inherited( globalscope: GlobalScope::new_inherited(
init.pipeline_id, init.pipeline_id,
@ -168,8 +173,8 @@ impl WorkerGlobalScope {
runtime: DomRefCell::new(Some(runtime)), runtime: DomRefCell::new(Some(runtime)),
location: Default::default(), location: Default::default(),
navigator: Default::default(), navigator: Default::default(),
from_devtools_sender: init.from_devtools_sender, devtools_receiver,
from_devtools_receiver, _devtools_sender: init.from_devtools_sender,
navigation_start: CrossProcessInstant::now(), navigation_start: CrossProcessInstant::now(),
performance: Default::default(), performance: Default::default(),
} }
@ -193,12 +198,8 @@ impl WorkerGlobalScope {
.prepare_for_new_child() .prepare_for_new_child()
} }
pub fn from_devtools_sender(&self) -> Option<IpcSender<DevtoolScriptControlMsg>> { pub fn devtools_receiver(&self) -> Option<&Receiver<DevtoolScriptControlMsg>> {
self.from_devtools_sender.clone() self.devtools_receiver.as_ref()
}
pub fn from_devtools_receiver(&self) -> &Receiver<DevtoolScriptControlMsg> {
&self.from_devtools_receiver
} }
#[allow(unsafe_code)] #[allow(unsafe_code)]

View file

@ -611,7 +611,8 @@ impl WorkletThread {
hash_map::Entry::Vacant(entry) => { hash_map::Entry::Vacant(entry) => {
debug!("Creating new worklet global scope."); debug!("Creating new worklet global scope.");
let executor = WorkletExecutor::new(worklet_id, self.primary_sender.clone()); let executor = WorkletExecutor::new(worklet_id, self.primary_sender.clone());
let result = global_type.new( let result = WorkletGlobalScope::new(
global_type,
&self.runtime, &self.runtime,
pipeline_id, pipeline_id,
base_url, base_url,

View file

@ -47,6 +47,33 @@ pub struct WorkletGlobalScope {
} }
impl WorkletGlobalScope { impl WorkletGlobalScope {
/// Create a new heap-allocated `WorkletGlobalScope`.
pub fn new(
scope_type: WorkletGlobalScopeType,
runtime: &Runtime,
pipeline_id: PipelineId,
base_url: ServoUrl,
executor: WorkletExecutor,
init: &WorkletGlobalScopeInit,
) -> DomRoot<WorkletGlobalScope> {
match scope_type {
WorkletGlobalScopeType::Test => DomRoot::upcast(TestWorkletGlobalScope::new(
runtime,
pipeline_id,
base_url,
executor,
init,
)),
WorkletGlobalScopeType::Paint => DomRoot::upcast(PaintWorkletGlobalScope::new(
runtime,
pipeline_id,
base_url,
executor,
init,
)),
}
}
/// Create a new stack-allocated `WorkletGlobalScope`. /// Create a new stack-allocated `WorkletGlobalScope`.
pub fn new_inherited( pub fn new_inherited(
pipeline_id: PipelineId, pipeline_id: PipelineId,
@ -178,35 +205,6 @@ pub enum WorkletGlobalScopeType {
Paint, Paint,
} }
impl WorkletGlobalScopeType {
/// Create a new heap-allocated `WorkletGlobalScope`.
pub fn new(
&self,
runtime: &Runtime,
pipeline_id: PipelineId,
base_url: ServoUrl,
executor: WorkletExecutor,
init: &WorkletGlobalScopeInit,
) -> DomRoot<WorkletGlobalScope> {
match *self {
WorkletGlobalScopeType::Test => DomRoot::upcast(TestWorkletGlobalScope::new(
runtime,
pipeline_id,
base_url,
executor,
init,
)),
WorkletGlobalScopeType::Paint => DomRoot::upcast(PaintWorkletGlobalScope::new(
runtime,
pipeline_id,
base_url,
executor,
init,
)),
}
}
}
/// A task which can be performed in the context of a worklet global. /// A task which can be performed in the context of a worklet global.
pub enum WorkletTask { pub enum WorkletTask {
Test(TestWorkletTask), Test(TestWorkletTask),

View file

@ -347,7 +347,7 @@ impl ModuleTree {
let handler = PromiseNativeHandler::new( let handler = PromiseNativeHandler::new(
&owner.global(), &owner.global(),
Some(ModuleHandler::new(Box::new( Some(ModuleHandler::new_boxed(Box::new(
task!(fetched_resolve: move || { task!(fetched_resolve: move || {
this.notify_owner_to_finish(identity, options); this.notify_owner_to_finish(identity, options);
}), }),
@ -383,7 +383,7 @@ impl ModuleTree {
let handler = PromiseNativeHandler::new( let handler = PromiseNativeHandler::new(
&owner.global(), &owner.global(),
Some(ModuleHandler::new(Box::new( Some(ModuleHandler::new_boxed(Box::new(
task!(fetched_resolve: move || { task!(fetched_resolve: move || {
this.finish_dynamic_module(identity, module_id); this.finish_dynamic_module(identity, module_id);
}), }),
@ -858,7 +858,7 @@ struct ModuleHandler {
} }
impl ModuleHandler { impl ModuleHandler {
pub fn new(task: Box<dyn TaskBox>) -> Box<dyn Callback> { pub fn new_boxed(task: Box<dyn TaskBox>) -> Box<dyn Callback> {
Box::new(Self { Box::new(Self {
task: DomRefCell::new(Some(task)), task: DomRefCell::new(Some(task)),
}) })