Skip to content

Commit 9a7ff2b

Browse files
committed
---
yaml --- r: 69608 b: refs/heads/auto c: cde6ad3 h: refs/heads/master v: v3
1 parent 51a54f6 commit 9a7ff2b

File tree

2 files changed

+8
-3
lines changed

2 files changed

+8
-3
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -14,6 +14,6 @@ refs/heads/try3: 9387340aab40a73e8424c48fd42f0c521a4875c0
1414
refs/tags/release-0.3.1: 495bae036dfe5ec6ceafd3312b4dca48741e845b
1515
refs/tags/release-0.4: e828ea2080499553b97dfe33b3f4d472b4562ad7
1616
refs/tags/release-0.5: 7e3bcfbf21278251ee936ad53e92e9b719702d73
17-
refs/heads/auto: be7738bfa18989438e3597847cd6a7f3bbbfac12
17+
refs/heads/auto: cde6ad39920ddadd7c70921232ae92adff258367
1818
refs/heads/servo: af82457af293e2a842ba6b7759b70288da276167
1919
refs/tags/release-0.6: b4ebcfa1812664df5e142f0134a5faea3918544c

branches/auto/src/libstd/rt/comm.rs

Lines changed: 7 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -131,6 +131,13 @@ impl<T> ChanOne<T> {
131131
// acquire barrier that keeps the subsequent access of the
132132
// ~Task pointer from being reordered.
133133
let oldstate = (*packet).state.swap(STATE_ONE, SeqCst);
134+
135+
// Suppress the synchronizing actions in the finalizer. We're
136+
// done with the packet. NB: In case of do_resched, this *must*
137+
// happen before waking up a blocked task (or be unkillable),
138+
// because we might get a kill signal during the reschedule.
139+
this.suppress_finalize = true;
140+
134141
match oldstate {
135142
STATE_BOTH => {
136143
// Port is not waiting yet. Nothing to do
@@ -165,8 +172,6 @@ impl<T> ChanOne<T> {
165172
}
166173
}
167174

168-
// Suppress the synchronizing actions in the finalizer. We're done with the packet.
169-
this.suppress_finalize = true;
170175
return recvr_active;
171176
}
172177
}

0 commit comments

Comments
 (0)