I would except this to be implcitly done by the drop though it doesn't hurt here, as this channel is dropped anyway a line later.

But i have the feeling that maybe something with the channel is wrong which leads to this behavior (or maybe did i made a copy somewhere, though i dobt this).
Again, not sure if this is a fix, but i think it doesn't hurt
This commit is contained in:
Marcel Märtens 2020-11-27 10:47:01 +01:00
parent 19eee6dad3
commit 7a7c1f6f50

View File

@ -290,6 +290,7 @@ impl BParticipant {
if let Err(e) = ci.b2r_read_shutdown.send(()) {
trace!(?cid, ?e, "seems like was already shut down");
}
ci.b2w_frame_s.close_channel();
}
//TODO FIXME tags: takeover channel multiple
info!(
@ -652,6 +653,7 @@ impl BParticipant {
itself, ignoring"
);
};
ci.b2w_frame_s.close_channel();
}
//Wait for other bparticipants mgr to close via AtomicUsize