diff options
author | Joel Galenson <jgalenson@google.com> | 2020-10-23 09:39:31 -0700 |
---|---|---|
committer | Joel Galenson <jgalenson@google.com> | 2020-10-23 09:52:09 -0700 |
commit | d5495b03381a3ebe0805db353d198b285b535b5c (patch) | |
tree | 778b8524d15fca8b73db0253ee0e1919d0848bb6 /src/runtime/task/harness.rs | |
parent | ba45c5bedf31df8562364c61d3dfb5262f10642e (diff) | |
download | tokio-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.rs | 8 |
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); } } |