fix(http2): send INTERNAL_ERROR when user's Service errors

2019-02-28 16:04:53 -08:00
parent 3a6080b14a
commit 8f926a0dae
1 changed files with 6 additions and 1 deletions
--- a/src/proto/h2/server.rs
+++ b/src/proto/h2/server.rs
@@ -209,7 +209,12 @@ where
                            }
                            return Ok(Async::NotReady);
                        }
-                        Err(e) => return Err(::Error::new_user_service(e)),
+                        Err(e) => {
+                            let err = ::Error::new_user_service(e);
+                            warn!("http2 service errored: {}", err);
+                            self.reply.send_reset(Reason::INTERNAL_ERROR);
+                            return Err(err);
+                        },
                    };

                    let (head, mut body) = res.into_parts();