| commit | 8e76d451dd39b5a194c7affeafa3be9c27559d71 | [log] [tgz] |
|---|---|---|
| author | iamqizhao <toqizhao@gmail.com> | Thu Jan 14 17:01:22 2016 -0800 |
| committer | iamqizhao <toqizhao@gmail.com> | Thu Jan 14 17:01:22 2016 -0800 |
| tree | 00b73194124c6ee45079dc4cb18b89238ec4d339 | |
| parent | 7172d5c7a66de543de4beb3ed5e0a9eafa1f43af [diff] |
Add missing trace finish on an uncommon code path
diff --git a/stream.go b/stream.go index 3ac5f6a..d8bdc16 100644 --- a/stream.go +++ b/stream.go
@@ -138,7 +138,9 @@ case <-t.Error(): // Incur transport error, simply exit. case <-s.Context().Done(): - cs.closeTransportStream(transport.ContextErr(s.Context().Err())) + err := s.Context().Err() + cs.finish(err) + cs.closeTransportStream(transport.ContextErr(err)) } }() return cs, nil