File tree Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Expand file tree Collapse file tree 1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change @@ -131,6 +131,13 @@ impl<T> ChanOne<T> {
131
131
// acquire barrier that keeps the subsequent access of the
132
132
// ~Task pointer from being reordered.
133
133
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
+
134
141
match oldstate {
135
142
STATE_BOTH => {
136
143
// Port is not waiting yet. Nothing to do
@@ -165,8 +172,6 @@ impl<T> ChanOne<T> {
165
172
}
166
173
}
167
174
168
- // Suppress the synchronizing actions in the finalizer. We're done with the packet.
169
- this. suppress_finalize = true ;
170
175
return recvr_active;
171
176
}
172
177
}
You can’t perform that action at this time.
0 commit comments