Remove an invalid assert and some commented out code.
This commit is contained in:
@@ -486,9 +486,7 @@ fn sender_terminate<T: send>(p: *packet<T>) {
|
|||||||
let p = unsafe { &*p };
|
let p = unsafe { &*p };
|
||||||
match swap_state_rel(p.header.state, terminated) {
|
match swap_state_rel(p.header.state, terminated) {
|
||||||
empty => {
|
empty => {
|
||||||
assert p.header.blocked_task.is_null();
|
|
||||||
// The receiver will eventually clean up.
|
// The receiver will eventually clean up.
|
||||||
//unsafe { forget(p) }
|
|
||||||
}
|
}
|
||||||
blocked => {
|
blocked => {
|
||||||
// wake up the target
|
// wake up the target
|
||||||
@@ -500,7 +498,6 @@ fn sender_terminate<T: send>(p: *packet<T>) {
|
|||||||
rustrt::rust_task_deref(old_task);
|
rustrt::rust_task_deref(old_task);
|
||||||
}
|
}
|
||||||
// The receiver will eventually clean up.
|
// The receiver will eventually clean up.
|
||||||
//unsafe { forget(p) }
|
|
||||||
}
|
}
|
||||||
full => {
|
full => {
|
||||||
// This is impossible
|
// This is impossible
|
||||||
@@ -520,7 +517,6 @@ fn receiver_terminate<T: send>(p: *packet<T>) {
|
|||||||
match swap_state_rel(p.header.state, terminated) {
|
match swap_state_rel(p.header.state, terminated) {
|
||||||
empty => {
|
empty => {
|
||||||
// the sender will clean up
|
// the sender will clean up
|
||||||
//unsafe { forget(p) }
|
|
||||||
}
|
}
|
||||||
blocked => {
|
blocked => {
|
||||||
// this shouldn't happen.
|
// this shouldn't happen.
|
||||||
|
|||||||
Reference in New Issue
Block a user