Commit 58e46aad authored by Peter Goodspeed-Niklaus's avatar Peter Goodspeed-Niklaus
Browse files

REVERT ME: log when send_msg sends a message to a job

parent 0d6f3841
Pipeline #114922 failed with stages
in 23 minutes and 20 seconds
......@@ -632,6 +632,7 @@ impl<Spawner: SpawnNamed, Job: 'static + JobTrait> Jobs<Spawner, Job> {
/// Send a message to the appropriate job for this `parent_hash`.
async fn send_msg(&mut self, parent_hash: Hash, msg: Job::ToJob) {
if let Entry::Occupied(mut job) = self.running.entry(parent_hash) {
tracing::info!(job = Job::NAME, relay_parent = ?parent_hash, "send_msg sending message");
if job.get_mut().send_msg(msg).await.is_err() {
tracing::debug!(job = Job::NAME, "failed to send message to job, will remove it");
job.remove();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment