aboutsummaryrefslogtreecommitdiff
path: root/src/runtime/task/harness.rs
diff options
context:
space:
mode:
authorJoel Galenson <jgalenson@google.com>2020-10-23 09:39:31 -0700
committerJoel Galenson <jgalenson@google.com>2020-10-23 09:52:09 -0700
commitd5495b03381a3ebe0805db353d198b285b535b5c (patch)
tree778b8524d15fca8b73db0253ee0e1919d0848bb6 /src/runtime/task/harness.rs
parentba45c5bedf31df8562364c61d3dfb5262f10642e (diff)
downloadtokio-d5495b03381a3ebe0805db353d198b285b535b5c.tar.gz
Update to tokio-0.3.1 and add new features
Test: Build Change-Id: I5b5b9b386a21982a019653d0cf0bd3afc505cfac
Diffstat (limited to 'src/runtime/task/harness.rs')
-rw-r--r--src/runtime/task/harness.rs8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/runtime/task/harness.rs b/src/runtime/task/harness.rs
index e86b29e..208d48c 100644
--- a/src/runtime/task/harness.rs
+++ b/src/runtime/task/harness.rs
@@ -102,7 +102,7 @@ where
// If the task is cancelled, avoid polling it, instead signalling it
// is complete.
if snapshot.is_cancelled() {
- Poll::Ready(Err(JoinError::cancelled2()))
+ Poll::Ready(Err(JoinError::cancelled()))
} else {
let res = guard.core.poll(self.header());
@@ -132,7 +132,7 @@ where
}
}
Err(err) => {
- self.complete(Err(JoinError::panic2(err)), snapshot.is_join_interested());
+ self.complete(Err(JoinError::panic(err)), snapshot.is_join_interested());
}
}
}
@@ -297,9 +297,9 @@ where
// Dropping the future panicked, complete the join
// handle with the panic to avoid dropping the panic
// on the ground.
- self.complete(Err(JoinError::panic2(err)), true);
+ self.complete(Err(JoinError::panic(err)), true);
} else {
- self.complete(Err(JoinError::cancelled2()), true);
+ self.complete(Err(JoinError::cancelled()), true);
}
}