Join GitHub today
GitHub is home to over 50 million developers working together to host and review code, manage projects, and build software together.
Sign uptask -> thread #8522
task -> thread #8522
Conversation
highfive
commented
Nov 13, 2015
|
Reviewed 42 of 149 files at r1. ORGANIZATION.md, line 74 [r1] (raw file): ports/cef/interfaces/cef_render_process_handler.rs, line 116 [r1] (raw file): Comments from the review on Reviewable.io |
|
Review status: 31 of 125 files reviewed at latest revision, 2 unresolved discussions, some commit checks failed. ORGANIZATION.md, line 74 [r1] (raw file): ports/cef/interfaces/cef_render_process_handler.rs, line 116 [r1] (raw file): Comments from the review on Reviewable.io |
|
Yeah, rust-task_info refers to Mach tasks (ie. the OS X kernel): https://github.com/wenderen/servo/blob/8512-rename-task-to-thread/support/rust-thread_info/src/task_info.c |
|
(ping) |
|
Reviewed 106 of 149 files at r1. components/profile/Cargo.toml, line 32 [r1] (raw file): Comments from the review on Reviewable.io |
|
Reviewed 4 of 13 files at r2, 10 of 10 files at r3. Comments from the review on Reviewable.io |
|
Review status: all files reviewed at latest revision, 3 unresolved discussions, some commit checks failed. components/profile/Cargo.toml, line 32 [r1] (raw file): Comments from the review on Reviewable.io |
| @@ -300,7 +300,7 @@ impl<QueueData: Sync, WorkData: Send> WorkQueue<QueueData, WorkData> { | |||
| self.work_count += 1 | |||
| } | |||
|
|
|||
| /// Synchronously runs all the enqueued tasks and waits for them to complete. | |||
| /// Synchronously runs all the enqueued threads and waits for them to complete. | |||
This comment has been minimized.
This comment has been minimized.
| @@ -47,15 +47,15 @@ use std::mem; | |||
| use std::ptr; | |||
|
|
|||
| // | |||
| // Implement this structure for asynchronous task execution. If the task is | |||
| // Implement this structure for asynchronous thread execution. If the thread is | |||
This comment has been minimized.
This comment has been minimized.
| @@ -466,13 +466,13 @@ impl WebSocketMethods for WebSocket { | |||
| } | |||
|
|
|||
|
|
|||
| /// Task queued when *the WebSocket connection is established*. | |||
| struct ConnectionEstablishedTask { | |||
| /// Thread queued when *the WebSocket connection is established*. | |||
This comment has been minimized.
This comment has been minimized.
| @@ -496,11 +496,11 @@ impl Runnable for ConnectionEstablishedTask { | |||
| } | |||
| } | |||
|
|
|||
| struct BufferedAmountTask { | |||
| struct BufferedAmountThread { | |||
This comment has been minimized.
This comment has been minimized.
| @@ -514,11 +514,11 @@ impl Runnable for BufferedAmountTask { | |||
| } | |||
| } | |||
|
|
|||
| struct CloseTask { | |||
| struct CloseThread { | |||
This comment has been minimized.
This comment has been minimized.
| @@ -551,16 +551,16 @@ impl Runnable for CloseTask { | |||
| } | |||
| } | |||
|
|
|||
| struct MessageReceivedTask { | |||
| struct MessageReceivedThread { | |||
This comment has been minimized.
This comment has been minimized.
| fn perform_annotated_read_operation(gen_id: GenerationId, data: ReadMetaData, blob_contents: Receiver<Vec<u8>>, | ||
| filereader: TrustedFileReader, script_chan: Box<ScriptChan + Send>) { | ||
| let chan = &script_chan; | ||
| // Step 4 | ||
| let task = box FileReaderEvent::ProcessRead(filereader.clone(), gen_id); | ||
| chan.send(CommonScriptMsg::RunnableMsg(FileRead, task)).unwrap(); | ||
| let thread = box FileReaderEvent::ProcessRead(filereader.clone(), gen_id); |
This comment has been minimized.
This comment has been minimized.
| @@ -404,27 +404,27 @@ impl Runnable for FileReaderEvent { | |||
| } | |||
| } | |||
|
|
|||
| // https://w3c.github.io/FileAPI/#task-read-operation | |||
| // https://w3c.github.io/FileAPI/#thread-read-operation | |||
This comment has been minimized.
This comment has been minimized.
|
|
||
| let task = box FileReaderEvent::ProcessReadData(filereader.clone(), gen_id); | ||
| chan.send(CommonScriptMsg::RunnableMsg(FileRead, task)).unwrap(); | ||
| let thread = box FileReaderEvent::ProcessReadData(filereader.clone(), gen_id); |
This comment has been minimized.
This comment has been minimized.
|
|
||
| let bytes = match blob_contents.recv() { | ||
| Ok(bytes) => bytes, | ||
| Err(_) => { | ||
| let task = box FileReaderEvent::ProcessReadError(filereader, | ||
| let thread = box FileReaderEvent::ProcessReadError(filereader, |
This comment has been minimized.
This comment has been minimized.
| return; | ||
| } | ||
| }; | ||
|
|
||
| let task = box FileReaderEvent::ProcessReadEOF(filereader, gen_id, data, bytes); | ||
| chan.send(CommonScriptMsg::RunnableMsg(FileRead, task)).unwrap(); | ||
| let thread = box FileReaderEvent::ProcessReadEOF(filereader, gen_id, data, bytes); |
This comment has been minimized.
This comment has been minimized.
| @@ -248,20 +248,20 @@ impl WebSocket { | |||
| Ok(channel) => channel, | |||
| Err(e) => { | |||
| debug!("Failed to establish a WebSocket connection: {:?}", e); | |||
| let task = box CloseTask { | |||
| let thread = box CloseThread { | |||
This comment has been minimized.
This comment has been minimized.
| return; | ||
| } | ||
| }; | ||
| let ws_sender = Arc::new(Mutex::new(ws_sender)); | ||
|
|
||
| let open_task = box ConnectionEstablishedTask { | ||
| let open_thread = box ConnectionEstablishedThread { |
This comment has been minimized.
This comment has been minimized.
| @@ -274,19 +274,19 @@ impl WebSocket { | |||
| Ok(Message::Pong(_)) => continue, | |||
| Ok(Message::Close(data)) => { | |||
| ws_sender.lock().unwrap().send_message(Message::Close(data)).unwrap(); | |||
| let task = box CloseTask { | |||
| let thread = box CloseThread { | |||
This comment has been minimized.
This comment has been minimized.
| break; | ||
| }, | ||
| Err(_) => break, | ||
| }; | ||
| let message_task = box MessageReceivedTask { | ||
| let message_thread = box MessageReceivedThread { |
This comment has been minimized.
This comment has been minimized.
| @@ -327,11 +327,11 @@ impl WebSocket { | |||
| if !self.clearing_buffer.get() && self.ready_state.get() == WebSocketRequestState::Open { | |||
| self.clearing_buffer.set(true); | |||
|
|
|||
| let task = box BufferedAmountTask { | |||
| let thread = box BufferedAmountThread { | |||
This comment has been minimized.
This comment has been minimized.
| address: Trusted<WebSocket>, | ||
| message: MessageData, | ||
| } | ||
|
|
||
| impl Runnable for MessageReceivedTask { | ||
| impl Runnable for MessageReceivedThread { |
This comment has been minimized.
This comment has been minimized.
|
@bors-servo: delegate+ |
|
|
|
@wenderen What's the status of this? |
|
@KiChjang apologies for the late response, I was on vacation until yesterday. The rebase is halfway complete (I abandoned the old rebase and re-fetched, so some of my former progress was lost). Should be done by tomorrow night. |
08f3391
to
7eaf55d
|
rebased, squashed and pushed |
|
@wenderen There are still some incorrect renames that I identified that require addressing, if you've got the time. |
|
@jdm Sure, which renames? |
|
@wenderen See all the comments on the earlier comments further up the page. The ones that are still visible haven't been addressed. |
3142e28
to
fbd0f85
|
|
fbd0f85
to
0f5c614
|
Oops. How do I reopen this? |
|
You might have deleted the branch. It'd probably be easier just to open a new pr |
ajnirp commentedNov 13, 2015
for #8512
yay for Python's
os.walk