[dubbo] branch master updated: fix 4694: consumer return quickly, when the provider interrupts abnormally (#4698)

[victory]

This is an automated email from the ASF dual-hosted git repository.

victory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/dubbo.git


The following commit(s) were added to refs/heads/master by this push:
     new a89b24c  fix 4694: consumer return quickly, when the provider 
interrupts abnormally (#4698)
a89b24c is described below

commit a89b24c5d1d4c8636b37e6a5d59169087338f89f
Author: Zhiwei Zhao <zhaozhiwei...@126.com>
AuthorDate: Tue Sep 17 09:58:30 2019 +0800

    fix 4694: consumer return quickly, when the provider interrupts abnormally 
(#4698)
---
 .../dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java   | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
 
b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
index 2529ac7..e04f930 100644
--- 
a/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
+++ 
b/dubbo-remoting/dubbo-remoting-api/src/main/java/org/apache/dubbo/remoting/exchange/support/header/HeaderExchangeChannel.java
@@ -131,6 +131,8 @@ final class HeaderExchangeChannel implements 
ExchangeChannel {
     @Override
     public void close() {
         try {
+            // graceful close
+            DefaultFuture.closeChannel(channel);
             channel.close();
         } catch (Throwable e) {
             logger.warn(e.getMessage(), e);